NoLog.cz/gancio-upstream
6
0
Fork 0
mirror of https://framagit.org/les/gancio.git synced 2025-01-31 16:42:22 +01:00
Code Issues Projects Releases Packages Wiki Activity

check event on comment from federation

Browse source
This commit is contained in:
les 2019-08-09 14:37:51 +02:00
parent 181557aa43
commit f722187c65
3 changed files with 16 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
server/federation/comments.js
View file

@ -1,25 +1,26 @@
const { event: Event, comment: Comment } = require('../api/models')
const config = require('config')
const debug = require('debug')('fediverse:comment')
module.exports = {
async create (body) {
async create (req, res) {
//search for related event
const inReplyTo = body.object.inReplyTo
const event_id = inReplyTo.match(`${config.baseurl}/federation/m/(.*)`)[1]
const match = inReplyTo.match(`${config.baseurl}/federation/m/(.*)`)
if (!match || match.length<2) return res.status(404).send('Event not found!')
const event = await Event.findByPk(Number(match[1]))
console.error(event_id)
const event = await Event.findByPk(event_id)
if (!event) {
return console.error('event not found!')
}
if (!event) return res.status(404).send('Event not found!')
debug('comment from %s to %s', req.body.actor, event.titles)
return await Comment.create({
activitypub_id: body.object.id,
data: body.object,
eventId: event.id
})
await Comment.create({
activitypub_id: body.object.id,
data: body.object,
eventId: event.id
})
res.sendStatus(201)
}
}

3
server/federation/index.js
View file

@ -62,8 +62,7 @@ router.post('/u/:name/inbox', Helpers.verifySignature, async (req, res) => {
case 'Create':
// this is a reply
if (b.object.type === 'Note' && b.object.inReplyTo) {
await Comments.create(b)
res.status(201).send()
await Comments.create(req, res)
} else {
console.error('Create what? ', b.object.type)
}

4
server/federation/webfinger.js
View file

@ -96,12 +96,12 @@ router.get('/nodeinfo', async (req, res) => {
// Handle 404
router.use(function(req, res) {
res.send('404: Page not Found', 404)
res.status(404).send('404: Page not Found')
})
// Handle 500
router.use(function(error, req, res, next) {
res.send('500: Internal Server Error', 500)
res.status(500).send('500: Internal Server Error')
})
module.exports = router