server/tests/fixtures/peertube-plugin-test-four/main.js

   1 async function register ({
   2   peertubeHelpers,
   3   registerHook,
   4   getRouter
   5 }) {
   6   const logger = peertubeHelpers.logger
   7
   8   logger.info('Hello world from plugin four')
   9
  10   {
  11     const username = 'root'
  12     const results = await peertubeHelpers.database.query(
  13       'SELECT "email" from "user" WHERE "username" = $username',
  14       {
  15         type: 'SELECT',
  16         bind: { username }
  17       }
  18     )
  19
  20     logger.info('root email is ' + results[0]['email'])
  21   }
  22
  23   {
  24     registerHook({
  25       target: 'action:api.video.viewed',
  26       handler: async ({ video }) => {
  27         const videoFromDB = await peertubeHelpers.videos.loadByUrl(video.url)
  28         logger.info('video from DB uuid is %s.', videoFromDB.uuid)
  29
  30         await peertubeHelpers.videos.removeVideo(video.id)
  31
  32         logger.info('Video deleted by plugin four.')
  33       }
  34     })
  35   }
  36
  37   {
  38     const serverActor = await peertubeHelpers.server.getServerActor()
  39     logger.info('server actor name is %s', serverActor.preferredUsername)
  40   }
  41
  42   {
  43     logger.info('server url is %s', peertubeHelpers.config.getWebserverUrl())
  44   }
  45
  46   {
  47     const actions = {
  48       blockServer,
  49       unblockServer,
  50       blockAccount,
  51       unblockAccount,
  52       blacklist,
  53       unblacklist
  54     }
  55
  56     const router = getRouter()
  57     router.post('/commander', async (req, res) => {
  58       try {
  59         await actions[req.body.command](peertubeHelpers, req.body)
  60
  61         res.sendStatus(204)
  62       } catch (err) {
  63         logger.error('Error in commander.', { err })
  64         res.sendStatus(500)
  65       }
  66     })
  67   }
  68 }
  69
  70 async function unregister () {
  71   return
  72 }
  73
  74 module.exports = {
  75   register,
  76   unregister
  77 }
  78
  79 // ###########################################################################
  80
  81 async function blockServer (peertubeHelpers, body) {
  82   const serverActor = await peertubeHelpers.server.getServerActor()
  83
  84   await peertubeHelpers.moderation.blockServer({ byAccountId: serverActor.Account.id, hostToBlock: body.hostToBlock })
  85 }
  86
  87 async function unblockServer (peertubeHelpers, body) {
  88   const serverActor = await peertubeHelpers.server.getServerActor()
  89
  90   await peertubeHelpers.moderation.unblockServer({ byAccountId: serverActor.Account.id, hostToUnblock: body.hostToUnblock })
  91 }
  92
  93 async function blockAccount (peertubeHelpers, body) {
  94   const serverActor = await peertubeHelpers.server.getServerActor()
  95
  96   await peertubeHelpers.moderation.blockAccount({ byAccountId: serverActor.Account.id, handleToBlock: body.handleToBlock })
  97 }
  98
  99 async function unblockAccount (peertubeHelpers, body) {
 100   const serverActor = await peertubeHelpers.server.getServerActor()
 101
 102   await peertubeHelpers.moderation.unblockAccount({ byAccountId: serverActor.Account.id, handleToUnblock: body.handleToUnblock })
 103 }
 104
 105 async function blacklist (peertubeHelpers, body) {
 106   await peertubeHelpers.moderation.blacklistVideo({
 107     videoIdOrUUID: body.videoUUID,
 108     createOptions: body
 109   })
 110 }
 111
 112 async function unblacklist (peertubeHelpers, body) {
 113   await peertubeHelpers.moderation.unblacklistVideo({ videoIdOrUUID: body.videoUUID })
 114 }