aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/controllers/api/runners/jobs.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/controllers/api/runners/jobs.ts')
-rw-r--r--server/controllers/api/runners/jobs.ts14
1 files changed, 9 insertions, 5 deletions
diff --git a/server/controllers/api/runners/jobs.ts b/server/controllers/api/runners/jobs.ts
index 5d687e689..be5911b53 100644
--- a/server/controllers/api/runners/jobs.ts
+++ b/server/controllers/api/runners/jobs.ts
@@ -22,7 +22,7 @@ import {
22 cancelRunnerJobValidator, 22 cancelRunnerJobValidator,
23 errorRunnerJobValidator, 23 errorRunnerJobValidator,
24 getRunnerFromTokenValidator, 24 getRunnerFromTokenValidator,
25 jobOfRunnerGetValidator, 25 jobOfRunnerGetValidatorFactory,
26 runnerJobGetValidator, 26 runnerJobGetValidator,
27 successRunnerJobValidator, 27 successRunnerJobValidator,
28 updateRunnerJobValidator 28 updateRunnerJobValidator
@@ -85,7 +85,7 @@ runnerJobsRouter.post('/jobs/:jobUUID/accept',
85 85
86runnerJobsRouter.post('/jobs/:jobUUID/abort', 86runnerJobsRouter.post('/jobs/:jobUUID/abort',
87 apiRateLimiter, 87 apiRateLimiter,
88 asyncMiddleware(jobOfRunnerGetValidator), 88 asyncMiddleware(jobOfRunnerGetValidatorFactory([ RunnerJobState.PROCESSING ])),
89 abortRunnerJobValidator, 89 abortRunnerJobValidator,
90 asyncMiddleware(abortRunnerJob) 90 asyncMiddleware(abortRunnerJob)
91) 91)
@@ -93,13 +93,13 @@ runnerJobsRouter.post('/jobs/:jobUUID/abort',
93runnerJobsRouter.post('/jobs/:jobUUID/update', 93runnerJobsRouter.post('/jobs/:jobUUID/update',
94 runnerJobUpdateVideoFiles, 94 runnerJobUpdateVideoFiles,
95 apiRateLimiter, // Has to be after multer middleware to parse runner token 95 apiRateLimiter, // Has to be after multer middleware to parse runner token
96 asyncMiddleware(jobOfRunnerGetValidator), 96 asyncMiddleware(jobOfRunnerGetValidatorFactory([ RunnerJobState.PROCESSING, RunnerJobState.COMPLETING, RunnerJobState.COMPLETED ])),
97 updateRunnerJobValidator, 97 updateRunnerJobValidator,
98 asyncMiddleware(updateRunnerJobController) 98 asyncMiddleware(updateRunnerJobController)
99) 99)
100 100
101runnerJobsRouter.post('/jobs/:jobUUID/error', 101runnerJobsRouter.post('/jobs/:jobUUID/error',
102 asyncMiddleware(jobOfRunnerGetValidator), 102 asyncMiddleware(jobOfRunnerGetValidatorFactory([ RunnerJobState.PROCESSING ])),
103 errorRunnerJobValidator, 103 errorRunnerJobValidator,
104 asyncMiddleware(errorRunnerJob) 104 asyncMiddleware(errorRunnerJob)
105) 105)
@@ -107,7 +107,7 @@ runnerJobsRouter.post('/jobs/:jobUUID/error',
107runnerJobsRouter.post('/jobs/:jobUUID/success', 107runnerJobsRouter.post('/jobs/:jobUUID/success',
108 postRunnerJobSuccessVideoFiles, 108 postRunnerJobSuccessVideoFiles,
109 apiRateLimiter, // Has to be after multer middleware to parse runner token 109 apiRateLimiter, // Has to be after multer middleware to parse runner token
110 asyncMiddleware(jobOfRunnerGetValidator), 110 asyncMiddleware(jobOfRunnerGetValidatorFactory([ RunnerJobState.PROCESSING ])),
111 successRunnerJobValidator, 111 successRunnerJobValidator,
112 asyncMiddleware(postRunnerJobSuccess) 112 asyncMiddleware(postRunnerJobSuccess)
113) 113)
@@ -272,6 +272,10 @@ async function updateRunnerJobController (req: express.Request, res: express.Res
272 const runner = runnerJob.Runner 272 const runner = runnerJob.Runner
273 const body: RunnerJobUpdateBody = req.body 273 const body: RunnerJobUpdateBody = req.body
274 274
275 if (runnerJob.state === RunnerJobState.COMPLETING || runnerJob.state === RunnerJobState.COMPLETED) {
276 return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
277 }
278
275 const payloadBuilder = jobUpdateBuilders[runnerJob.type] 279 const payloadBuilder = jobUpdateBuilders[runnerJob.type]
276 const updatePayload = payloadBuilder 280 const updatePayload = payloadBuilder
277 ? payloadBuilder(body.payload, req.files as UploadFiles) 281 ? payloadBuilder(body.payload, req.files as UploadFiles)