server/lib/jobs/http-request-job-scheduler/http-request-broadcast-handler.ts

   1 import { logger } from '../../../helpers'
   2 import { doRequest } from '../../../helpers/requests'
   3 import { HTTPRequestPayload } from './http-request-job-scheduler'
   4
   5 async function process (payload: HTTPRequestPayload, jobId: number) {
   6   logger.info('Processing broadcast in job %d.', jobId)
   7
   8   const options = {
   9     uri: '',
  10     json: payload.body
  11   }
  12
  13   for (const uri of payload.uris) {
  14     options.uri = uri
  15     await doRequest(options)
  16   }
  17 }
  18
  19 function onError (err: Error, jobId: number) {
  20   logger.error('Error when broadcasting request in job %d.', jobId, err)
  21   return Promise.resolve()
  22 }
  23
  24 async function onSuccess (jobId: number) {
  25   logger.info('Job %d is a success.', jobId)
  26 }
  27
  28 // ---------------------------------------------------------------------------
  29
  30 export {
  31   process,
  32   onError,
  33   onSuccess
  34 }