119 lines
3.2 KiB
JavaScript
119 lines
3.2 KiB
JavaScript
async function register ({
|
|
peertubeHelpers,
|
|
registerHook,
|
|
getRouter
|
|
}) {
|
|
const logger = peertubeHelpers.logger
|
|
|
|
logger.info('Hello world from plugin four')
|
|
|
|
{
|
|
const username = 'root'
|
|
const results = await peertubeHelpers.database.query(
|
|
'SELECT "email" from "user" WHERE "username" = $username',
|
|
{
|
|
type: 'SELECT',
|
|
bind: { username }
|
|
}
|
|
)
|
|
|
|
logger.info('root email is ' + results[0]['email'])
|
|
}
|
|
|
|
{
|
|
registerHook({
|
|
target: 'action:api.video.viewed',
|
|
handler: async ({ video }) => {
|
|
const videoFromDB1 = await peertubeHelpers.videos.loadByUrl(video.url)
|
|
const videoFromDB2 = await peertubeHelpers.videos.loadByIdOrUUID(video.id)
|
|
const videoFromDB3 = await peertubeHelpers.videos.loadByIdOrUUID(video.uuid)
|
|
|
|
if (videoFromDB1.uuid !== videoFromDB2.uuid || videoFromDB2.uuid !== videoFromDB3.uuid) return
|
|
|
|
logger.info('video from DB uuid is %s.', videoFromDB1.uuid)
|
|
|
|
await peertubeHelpers.videos.removeVideo(video.id)
|
|
|
|
logger.info('Video deleted by plugin four.')
|
|
}
|
|
})
|
|
}
|
|
|
|
{
|
|
const serverActor = await peertubeHelpers.server.getServerActor()
|
|
logger.info('server actor name is %s', serverActor.preferredUsername)
|
|
}
|
|
|
|
{
|
|
logger.info('server url is %s', peertubeHelpers.config.getWebserverUrl())
|
|
}
|
|
|
|
{
|
|
const actions = {
|
|
blockServer,
|
|
unblockServer,
|
|
blockAccount,
|
|
unblockAccount,
|
|
blacklist,
|
|
unblacklist
|
|
}
|
|
|
|
const router = getRouter()
|
|
router.post('/commander', async (req, res) => {
|
|
try {
|
|
await actions[req.body.command](peertubeHelpers, req.body)
|
|
|
|
res.sendStatus(204)
|
|
} catch (err) {
|
|
logger.error('Error in commander.', { err })
|
|
res.sendStatus(500)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
async function unregister () {
|
|
return
|
|
}
|
|
|
|
module.exports = {
|
|
register,
|
|
unregister
|
|
}
|
|
|
|
// ###########################################################################
|
|
|
|
async function blockServer (peertubeHelpers, body) {
|
|
const serverActor = await peertubeHelpers.server.getServerActor()
|
|
|
|
await peertubeHelpers.moderation.blockServer({ byAccountId: serverActor.Account.id, hostToBlock: body.hostToBlock })
|
|
}
|
|
|
|
async function unblockServer (peertubeHelpers, body) {
|
|
const serverActor = await peertubeHelpers.server.getServerActor()
|
|
|
|
await peertubeHelpers.moderation.unblockServer({ byAccountId: serverActor.Account.id, hostToUnblock: body.hostToUnblock })
|
|
}
|
|
|
|
async function blockAccount (peertubeHelpers, body) {
|
|
const serverActor = await peertubeHelpers.server.getServerActor()
|
|
|
|
await peertubeHelpers.moderation.blockAccount({ byAccountId: serverActor.Account.id, handleToBlock: body.handleToBlock })
|
|
}
|
|
|
|
async function unblockAccount (peertubeHelpers, body) {
|
|
const serverActor = await peertubeHelpers.server.getServerActor()
|
|
|
|
await peertubeHelpers.moderation.unblockAccount({ byAccountId: serverActor.Account.id, handleToUnblock: body.handleToUnblock })
|
|
}
|
|
|
|
async function blacklist (peertubeHelpers, body) {
|
|
await peertubeHelpers.moderation.blacklistVideo({
|
|
videoIdOrUUID: body.videoUUID,
|
|
createOptions: body
|
|
})
|
|
}
|
|
|
|
async function unblacklist (peertubeHelpers, body) {
|
|
await peertubeHelpers.moderation.unblacklistVideo({ videoIdOrUUID: body.videoUUID })
|
|
}
|