shared/extra-utils/miscs/sql.ts

   1 import { QueryTypes, Sequelize } from 'sequelize'
   2 import { ServerInfo } from '../server/servers'
   3
   4 const sequelizes: { [ id: number ]: Sequelize } = {}
   5
   6 function getSequelize (internalServerNumber: number) {
   7   if (sequelizes[internalServerNumber]) return sequelizes[internalServerNumber]
   8
   9   const dbname = 'peertube_test' + internalServerNumber
  10   const username = 'peertube'
  11   const password = 'peertube'
  12   const host = 'localhost'
  13   const port = 5432
  14
  15   const seq = new Sequelize(dbname, username, password, {
  16     dialect: 'postgres',
  17     host,
  18     port,
  19     logging: false
  20   })
  21
  22   sequelizes[internalServerNumber] = seq
  23
  24   return seq
  25 }
  26
  27 function deleteAll (internalServerNumber: number, table: string) {
  28   const seq = getSequelize(internalServerNumber)
  29
  30   const options = { type: QueryTypes.DELETE }
  31
  32   return seq.query(`DELETE FROM "${table}"`, options)
  33 }
  34
  35 async function getCount (internalServerNumber: number, table: string) {
  36   const seq = getSequelize(internalServerNumber)
  37
  38   const options = { type: QueryTypes.SELECT as QueryTypes.SELECT }
  39
  40   const [ { total } ] = await seq.query<{ total: string }>(`SELECT COUNT(*) as total FROM "${table}"`, options)
  41   if (total === null) return 0
  42
  43   return parseInt(total, 10)
  44 }
  45
  46 function setActorField (internalServerNumber: number, to: string, field: string, value: string) {
  47   const seq = getSequelize(internalServerNumber)
  48
  49   const options = { type: QueryTypes.UPDATE }
  50
  51   return seq.query(`UPDATE actor SET "${field}" = '${value}' WHERE url = '${to}'`, options)
  52 }
  53
  54 function setVideoField (internalServerNumber: number, uuid: string, field: string, value: string) {
  55   const seq = getSequelize(internalServerNumber)
  56
  57   const options = { type: QueryTypes.UPDATE }
  58
  59   return seq.query(`UPDATE video SET "${field}" = '${value}' WHERE uuid = '${uuid}'`, options)
  60 }
  61
  62 function setPlaylistField (internalServerNumber: number, uuid: string, field: string, value: string) {
  63   const seq = getSequelize(internalServerNumber)
  64
  65   const options = { type: QueryTypes.UPDATE }
  66
  67   return seq.query(`UPDATE "videoPlaylist" SET "${field}" = '${value}' WHERE uuid = '${uuid}'`, options)
  68 }
  69
  70 async function countVideoViewsOf (internalServerNumber: number, uuid: string) {
  71   const seq = getSequelize(internalServerNumber)
  72
  73   // tslint:disable
  74   const query = 'SELECT SUM("videoView"."views") AS "total" FROM "videoView" ' +
  75     `INNER JOIN "video" ON "video"."id" = "videoView"."videoId" WHERE "video"."uuid" = '${uuid}'`
  76
  77   const options = { type: QueryTypes.SELECT as QueryTypes.SELECT }
  78   const [ { total } ] = await seq.query<{ total: number }>(query, options)
  79
  80   if (!total) return 0
  81
  82   return parseInt(total + '', 10)
  83 }
  84
  85 function getActorImage (internalServerNumber: number, filename: string) {
  86   return selectQuery(internalServerNumber, `SELECT * FROM "actorImage" WHERE filename = '${filename}'`)
  87     .then(rows => rows[0])
  88 }
  89
  90 function selectQuery (internalServerNumber: number, query: string) {
  91   const seq = getSequelize(internalServerNumber)
  92   const options = { type: QueryTypes.SELECT as QueryTypes.SELECT }
  93
  94   return seq.query<any>(query, options)
  95 }
  96
  97 function updateQuery (internalServerNumber: number, query: string) {
  98   const seq = getSequelize(internalServerNumber)
  99   const options = { type: QueryTypes.UPDATE as QueryTypes.UPDATE }
 100
 101   return seq.query(query, options)
 102 }
 103
 104 async function closeAllSequelize (servers: ServerInfo[]) {
 105   for (const server of servers) {
 106     if (sequelizes[server.internalServerNumber]) {
 107       await sequelizes[server.internalServerNumber].close()
 108       // eslint-disable-next-line
 109       delete sequelizes[server.internalServerNumber]
 110     }
 111   }
 112 }
 113
 114 function setPluginField (internalServerNumber: number, pluginName: string, field: string, value: string) {
 115   const seq = getSequelize(internalServerNumber)
 116
 117   const options = { type: QueryTypes.UPDATE }
 118
 119   return seq.query(`UPDATE "plugin" SET "${field}" = '${value}' WHERE "name" = '${pluginName}'`, options)
 120 }
 121
 122 function setPluginVersion (internalServerNumber: number, pluginName: string, newVersion: string) {
 123   return setPluginField(internalServerNumber, pluginName, 'version', newVersion)
 124 }
 125
 126 function setPluginLatestVersion (internalServerNumber: number, pluginName: string, newVersion: string) {
 127   return setPluginField(internalServerNumber, pluginName, 'latestVersion', newVersion)
 128 }
 129
 130 function setActorFollowScores (internalServerNumber: number, newScore: number) {
 131   const seq = getSequelize(internalServerNumber)
 132
 133   const options = { type: QueryTypes.UPDATE }
 134
 135   return seq.query(`UPDATE "actorFollow" SET "score" = ${newScore}`, options)
 136 }
 137
 138 function setTokenField (internalServerNumber: number, accessToken: string, field: string, value: string) {
 139   const seq = getSequelize(internalServerNumber)
 140
 141   const options = { type: QueryTypes.UPDATE }
 142
 143   return seq.query(`UPDATE "oAuthToken" SET "${field}" = '${value}' WHERE "accessToken" = '${accessToken}'`, options)
 144 }
 145
 146 export {
 147   setVideoField,
 148   setPlaylistField,
 149   setActorField,
 150   countVideoViewsOf,
 151   setPluginVersion,
 152   setPluginLatestVersion,
 153   selectQuery,
 154   getActorImage,
 155   deleteAll,
 156   setTokenField,
 157   updateQuery,
 158   setActorFollowScores,
 159   closeAllSequelize,
 160   getCount
 161 }