encrypt/gancio
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mastodon bot fix

Browse Source
This commit is contained in:
lesion
2019-07-08 00:06:56 +02:00
parent cd44051a48
commit 506cf56e11
5 changed files with 26 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
server/api/controller/bot.js
View File

@@ -20,41 +20,21 @@ const botController = {
const listener = botController.bot.stream('/streaming/user')
listener.on('message', botController.message)
listener.on('error', botController.error)
// const botUsers = await User.findAll({ where: { mastodon_auth: { [Op.ne]: null } } })
// console.log(botUsers)
// botController.bots = botUsers.map(user => {
// console.log('initialize bot ', user.name)
// console.log('.. ', user.mastodon_auth)
// const { client_id, client_secret, access_token } = user.mastodon_auth
// const bot = new Mastodon({ access_token, api_url: `https://${user.mastodon_instance}/api/v1/` })
// const listener = bot.stream('streaming/direct')
// listener.on('message', botController.message)
// return { email: user.email, bot }
// })
// console.log(botController.bots)
// },
// add (user, token) {
// const bot = new Mastodon({ access_token: user.mastodon_auth.access_token, api_url: `https://${user.mastodon_instance}/api/v1/` })
// const listener = bot.stream('streaming/direct')
// listener.on('message', botController.message)
// listener.on('error', botController.error)
// botController.bots.push({ email: user.email, bot })
},
async post(instance, access_token, event) {
async post(event) {
const status = `${event.title} @${event.place.name} ${moment(event.start_datetime*1000).format('ddd, D MMMM HH:mm')} -
${event.description.length > 200 ? event.description.substr(0, 200) + '...' : event.description} - ${event.tags.map(t => '#' + t.tag).join(' ')} ${config.baseurl}/event/${event.id}`
let media
if (event.image_path) {
const file = path.join(config.upload_path, event.image_path)
const file = path.resolve(config.upload_path, event.image_path)
if (fs.statSync(file)) {
media = await botController.bot.post('media', { file: fs.createReadStream(file) })
media = await botController.bot.post('/media', { file: fs.createReadStream(file) })
}
}
return botController.bot.post('/statuses', { status, media_ids: media ? [media.data.id] : [] })
},
// TOFIX: enable message deletion
async message(msg) {
const type = msg.event
@@ -66,7 +46,6 @@ ${event.description.length > 200 ? event.description.substr(0, 200) + '...' : ev
}
const activitypub_id = String(msg.data.status.in_reply_to_id)
console.error('il toot di reply ', activitypub_id)
if (!activitypub_id) return
let event = await Event.findOne({ where: { activitypub_id } })
if (!event) {

4
server/api/controller/settings.js
View File

@@ -47,7 +47,9 @@ const settingsController = {
// get public settings and public configuration
const settings = {
...settingsController.settings,
baseurl: config.baseurl
baseurl: config.baseurl,
title: config.title,
description: config.description
}
res.json(settings)
},