shared/utils/miscs/sql.ts

   1 import * as Sequelize from 'sequelize'
   2
   3 let sequelizes: { [ id: number ]: Sequelize.Sequelize } = {}
   4
   5 function getSequelize (serverNumber: number) {
   6   if (sequelizes[serverNumber]) return sequelizes[serverNumber]
   7
   8   const dbname = 'peertube_test' + serverNumber
   9   const username = 'peertube'
  10   const password = 'peertube'
  11   const host = 'localhost'
  12   const port = 5432
  13
  14   const seq = new Sequelize(dbname, username, password, {
  15     dialect: 'postgres',
  16     host,
  17     port,
  18     operatorsAliases: false,
  19     logging: false
  20   })
  21
  22   sequelizes[serverNumber] = seq
  23
  24   return seq
  25 }
  26
  27 function setActorField (serverNumber: number, to: string, field: string, value: string) {
  28   const seq = getSequelize(serverNumber)
  29
  30   const options = { type: Sequelize.QueryTypes.UPDATE }
  31
  32   return seq.query(`UPDATE actor SET "${field}" = '${value}' WHERE url = '${to}'`, options)
  33 }
  34
  35 function setVideoField (serverNumber: number, uuid: string, field: string, value: string) {
  36   const seq = getSequelize(serverNumber)
  37
  38   const options = { type: Sequelize.QueryTypes.UPDATE }
  39
  40   return seq.query(`UPDATE video SET "${field}" = '${value}' WHERE uuid = '${uuid}'`, options)
  41 }
  42
  43 async function closeAllSequelize (servers: any[]) {
  44   for (let i = 1; i <= servers.length; i++) {
  45     if (sequelizes[ i ]) {
  46       await sequelizes[ i ].close()
  47       delete sequelizes[ i ]
  48     }
  49   }
  50 }
  51
  52 export {
  53   setVideoField,
  54   setActorField,
  55   closeAllSequelize
  56 }