33 lines
1 KiB
JavaScript
33 lines
1 KiB
JavaScript
const express = require('express')
|
|
const router = express.Router()
|
|
const net = require('../net')
|
|
const pub = require('../pub')
|
|
const store = require('../store')
|
|
|
|
router.post('/', net.security.auth, net.validators.outboxActivity, function (req, res) {
|
|
store.actor.get(pub.utils.usernameToIRI(req.user), true)
|
|
.then(actor => {
|
|
return pub.activity.addToOutbox(actor, req.body)
|
|
})
|
|
.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({ actor: pub.utils.usernameToIRI(req.user), type: { $in: ['Announce', 'Create'] } })
|
|
.sort({ _id: -1 })
|
|
.project({ _id: 0, _meta: 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
|