76 lines
2.4 KiB
JavaScript
76 lines
2.4 KiB
JavaScript
const express = require('express')
|
|
const router = express.Router()
|
|
const pub = require('../pub')
|
|
const net = require('../net')
|
|
const store = require('../store')
|
|
|
|
router.post('/', net.validators.activity, net.security.verifySignature, function (req, res) {
|
|
req.body._meta = { _target: pub.utils.usernameToIRI(req.user) }
|
|
const toDo = {
|
|
saveActivity: true,
|
|
saveObject: false
|
|
}
|
|
// side effects
|
|
switch (req.body.type) {
|
|
case 'Accept':
|
|
// TODO - side effect necessary for following collection?
|
|
break
|
|
case 'Follow':
|
|
// TODO resolve object and ensure specified target matches inbox user
|
|
// req.body._meta._target = req.body.object.id
|
|
// send acceptance reply
|
|
pub.actor.getOrCreateActor(req.user, true)
|
|
.then(user => {
|
|
const to = [pub.utils.actorFromActivity(req.body)]
|
|
const accept = pub.activity.build('Accept', user.id, req.body, to)
|
|
return pub.activity.addToOutbox(user, accept)
|
|
})
|
|
.catch(e => console.log(e))
|
|
break
|
|
case 'Create':
|
|
toDo.saveObject = true
|
|
pub.actor.getOrCreateActor(req.user, true)
|
|
.then(user => {
|
|
const to = [
|
|
user.followers,
|
|
'https://www.w3.org/ns/activitystreams#Public'
|
|
]
|
|
const cc = [pub.utils.actorFromActivity(req.body)]
|
|
const announce = pub.activity.build('Announce', user.id, req.body.object.id, to, cc)
|
|
return pub.activity.addToOutbox(user, announce)
|
|
}).catch(e => console.log(e))
|
|
break
|
|
case 'Undo':
|
|
pub.activity.undo(req.body.object, req.body.actor)
|
|
.catch(err => console.log(err.message))
|
|
break
|
|
}
|
|
const tasks = []
|
|
if (toDo.saveObject) {
|
|
tasks.push(pub.object.resolve(req.body.object))
|
|
}
|
|
if (toDo.saveActivity) {
|
|
tasks.push(store.stream.save(req.body))
|
|
}
|
|
Promise.all(tasks).then(() => res.status(200).send())
|
|
.catch(err => {
|
|
console.log(err.message)
|
|
res.status(500).send()
|
|
})
|
|
})
|
|
|
|
router.get('/', function (req, res) {
|
|
const db = req.app.get('db')
|
|
db.collection('streams')
|
|
.find({ '_meta._target': pub.utils.usernameToIRI(req.user) })
|
|
.sort({ _id: -1 })
|
|
.project({ _id: 0, _meta: 0, '@context': 0, 'object._id': 0, 'object.@context': 0, 'object._meta': 0 })
|
|
.toArray()
|
|
.then(stream => res.json(pub.utils.arrayToCollection(stream, true)))
|
|
.catch(err => {
|
|
console.log(err.message)
|
|
return res.status(500).send()
|
|
})
|
|
})
|
|
|
|
module.exports = router
|