From bf54587a3e2ad9c2c186828f2a5682b91ee2cc00 Mon Sep 17 00:00:00 2001
From: Chocobozzz <me@florianbigard.com>
Date: Fri, 17 Dec 2021 09:29:23 +0100
Subject: shared/ typescript types dir server-commands

---
 shared/extra-utils/server/jobs.ts | 84 ---------------------------------------
 1 file changed, 84 deletions(-)
 delete mode 100644 shared/extra-utils/server/jobs.ts

(limited to 'shared/extra-utils/server/jobs.ts')

diff --git a/shared/extra-utils/server/jobs.ts b/shared/extra-utils/server/jobs.ts
deleted file mode 100644
index 34fefd444..000000000
--- a/shared/extra-utils/server/jobs.ts
+++ /dev/null
@@ -1,84 +0,0 @@
-
-import { expect } from 'chai'
-import { JobState, JobType } from '../../models'
-import { wait } from '../miscs'
-import { PeerTubeServer } from './server'
-
-async function waitJobs (serversArg: PeerTubeServer[] | PeerTubeServer, skipDelayed = false) {
-  const pendingJobWait = process.env.NODE_PENDING_JOB_WAIT
-    ? parseInt(process.env.NODE_PENDING_JOB_WAIT, 10)
-    : 250
-
-  let servers: PeerTubeServer[]
-
-  if (Array.isArray(serversArg) === false) servers = [ serversArg as PeerTubeServer ]
-  else servers = serversArg as PeerTubeServer[]
-
-  const states: JobState[] = [ 'waiting', 'active' ]
-  if (!skipDelayed) states.push('delayed')
-
-  const repeatableJobs: JobType[] = [ 'videos-views-stats', 'activitypub-cleaner' ]
-  let pendingRequests: boolean
-
-  function tasksBuilder () {
-    const tasks: Promise<any>[] = []
-
-    // Check if each server has pending request
-    for (const server of servers) {
-      for (const state of states) {
-        const p = server.jobs.list({
-          state,
-          start: 0,
-          count: 10,
-          sort: '-createdAt'
-        }).then(body => body.data)
-          .then(jobs => jobs.filter(j => !repeatableJobs.includes(j.type)))
-          .then(jobs => {
-            if (jobs.length !== 0) {
-              pendingRequests = true
-            }
-          })
-
-        tasks.push(p)
-      }
-
-      const p = server.debug.getDebug()
-        .then(obj => {
-          if (obj.activityPubMessagesWaiting !== 0) {
-            pendingRequests = true
-          }
-        })
-
-      tasks.push(p)
-    }
-
-    return tasks
-  }
-
-  do {
-    pendingRequests = false
-    await Promise.all(tasksBuilder())
-
-    // Retry, in case of new jobs were created
-    if (pendingRequests === false) {
-      await wait(pendingJobWait)
-      await Promise.all(tasksBuilder())
-    }
-
-    if (pendingRequests) {
-      await wait(pendingJobWait)
-    }
-  } while (pendingRequests)
-}
-
-async function expectNoFailedTranscodingJob (server: PeerTubeServer) {
-  const { data } = await server.jobs.listFailed({ jobType: 'video-transcoding' })
-  expect(data).to.have.lengthOf(0)
-}
-
-// ---------------------------------------------------------------------------
-
-export {
-  waitJobs,
-  expectNoFailedTranscodingJob
-}
-- 
cgit v1.2.3