77 lines
2.6 KiB
TypeScript
77 lines
2.6 KiB
TypeScript
// SPDX-FileCopyrightText: 2024 John Livingston <https://www.john-livingston.fr/>
|
|
//
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import type { RegisterServerOptions } from '@peertube/peertube-types'
|
|
import { listProsodyRooms, updateProsodyRoom } from '../api/manage-rooms'
|
|
import * as path from 'path'
|
|
import * as fs from 'fs'
|
|
import { Emojis } from '../../emojis'
|
|
|
|
/**
|
|
* Livechat v11.1.0: we must send channel custom emojis regexp to Prosody.
|
|
*
|
|
* This script will only be launched one time.
|
|
*/
|
|
async function updateProsodyChannelEmojisRegex (options: RegisterServerOptions): Promise<void> {
|
|
const logger = options.peertubeHelpers.logger
|
|
|
|
// First, detect if we already run this script.
|
|
const doneFilePath = path.resolve(options.peertubeHelpers.plugin.getDataDirectoryPath(), 'fix-v11.1-emojis')
|
|
if (fs.existsSync(doneFilePath)) {
|
|
logger.debug('[migratev11_1_ChannelEmojis] Channel Emojis Regex already updated on Prosody.')
|
|
return
|
|
}
|
|
|
|
logger.info('[migratev11_1_ChannelEmojis] Updating Channel custom emojis regexp on Prosody')
|
|
|
|
const emojis = Emojis.singleton()
|
|
const rooms = await listProsodyRooms(options)
|
|
logger.debug('[migratev11_1_ChannelEmojis] Found ' + rooms.length.toString() + ' rooms.')
|
|
|
|
for (const room of rooms) {
|
|
try {
|
|
let channelId: number
|
|
logger.info('[migratev11_1_ChannelEmojis] Must update custom emojis regexp for room ' + room.localpart)
|
|
const matches = room.localpart.match(/^channel\.(\d+)$/)
|
|
if (matches?.[1]) {
|
|
// room associated to a channel
|
|
channelId = parseInt(matches[1])
|
|
} else {
|
|
// room associated to a video
|
|
const video = await options.peertubeHelpers.videos.loadByIdOrUUID(room.localpart)
|
|
if (!video || video.remote) {
|
|
logger.info('[migratev11_1_ChannelEmojis] Video ' + room.localpart + ' not found or remote, skipping')
|
|
continue
|
|
}
|
|
channelId = video.channelId
|
|
}
|
|
|
|
if (!channelId) {
|
|
throw new Error('Cant find channelId')
|
|
}
|
|
|
|
const regexp = await emojis.getChannelCustomEmojisRegexp(channelId)
|
|
if (regexp === undefined) {
|
|
logger.info('[migratev11_1_ChannelEmojis] Room ' + room.localpart + ' channel has no custom emojis, skipping.')
|
|
continue
|
|
}
|
|
|
|
await updateProsodyRoom(options, room.jid, {
|
|
livechat_custom_emoji_regexp: regexp
|
|
})
|
|
} catch (err) {
|
|
logger.error(
|
|
'[migratev11_1_ChannelEmojis] Failed to handle room ' + room.localpart + ', skipping. Error: ' + (err as string)
|
|
)
|
|
continue
|
|
}
|
|
}
|
|
|
|
await fs.promises.writeFile(doneFilePath, '')
|
|
}
|
|
|
|
export {
|
|
updateProsodyChannelEmojisRegex
|
|
}
|