]>
Commit | Line | Data |
---|---|---|
e4f97bab | 1 | import { logger } from '../../../helpers' |
571389d4 C |
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) | |
e4f97bab | 7 | |
571389d4 | 8 | const options = { |
350e31d6 | 9 | method: 'POST', |
571389d4 C |
10 | uri: '', |
11 | json: payload.body | |
12 | } | |
e4f97bab | 13 | |
571389d4 C |
14 | for (const uri of payload.uris) { |
15 | options.uri = uri | |
16 | await doRequest(options) | |
17 | } | |
e4f97bab C |
18 | } |
19 | ||
20 | function onError (err: Error, jobId: number) { | |
571389d4 | 21 | logger.error('Error when broadcasting request in job %d.', jobId, err) |
e4f97bab C |
22 | return Promise.resolve() |
23 | } | |
24 | ||
8e10cf1a | 25 | function onSuccess (jobId: number) { |
571389d4 | 26 | logger.info('Job %d is a success.', jobId) |
8e10cf1a | 27 | return Promise.resolve() |
e4f97bab C |
28 | } |
29 | ||
30 | // --------------------------------------------------------------------------- | |
31 | ||
32 | export { | |
33 | process, | |
34 | onError, | |
35 | onSuccess | |
36 | } |