aboutsummaryrefslogblamecommitdiffhomepage
path: root/shared/extra-utils/server/servers.ts
blob: 87d7e944945b93aaeb59cc1c8f6779865c8c08cc (plain) (tree)
1
2
3
4
5
6
7
8
9


                                                           
 

                                                                                                                              
 
                                                         
 
               

 

                                                                                
 

                                                              

   
                                    

 

                                                           

 
                                                         
                               
 



                                
                            
                                 
                                               




                       


                                                                              

                        
               
                
 
import { ensureDir } from 'fs-extra'
import { isGithubCI } from '../miscs'
import { PeerTubeServer, RunServerOptions } from './server'

async function createSingleServer (serverNumber: number, configOverride?: Object, args = [], options: RunServerOptions = {}) {
  const server = new PeerTubeServer({ serverNumber })

  await server.flushAndRun(configOverride, args, options)

  return server
}

function createMultipleServers (totalServers: number, configOverride?: Object) {
  const serverPromises: Promise<PeerTubeServer>[] = []

  for (let i = 1; i <= totalServers; i++) {
    serverPromises.push(createSingleServer(i, configOverride))
  }

  return Promise.all(serverPromises)
}

async function killallServers (servers: PeerTubeServer[]) {
  return Promise.all(servers.map(s => s.kill()))
}

async function cleanupTests (servers: PeerTubeServer[]) {
  await killallServers(servers)

  if (isGithubCI()) {
    await ensureDir('artifacts')
  }

  let p: Promise<any>[] = []
  for (const server of servers) {
    p = p.concat(server.servers.cleanupTests())
  }

  return Promise.all(p)
}

// ---------------------------------------------------------------------------

export {
  createSingleServer,
  createMultipleServers,
  cleanupTests,
  killallServers
}