( jobId: string, cloudconvert: CloudConvertClient, logger: Logger, callbacks: JobCompletionCallbacks )
| 273 | } |
| 274 | |
| 275 | function subscribeToJobEvents( |
| 276 | jobId: string, |
| 277 | cloudconvert: CloudConvertClient, |
| 278 | logger: Logger, |
| 279 | callbacks: JobCompletionCallbacks |
| 280 | ): void { |
| 281 | cloudconvert.socket?.on?.('error', error => { |
| 282 | logger.error(error.message); |
| 283 | }); |
| 284 | |
| 285 | void cloudconvert.jobs.subscribeTaskEvent(jobId, 'failed', event => { |
| 286 | logger.error( |
| 287 | `Task \`${event.task.name}\` failed: ${event.task.message ?? ''} (Code: ${ |
| 288 | event.task.code ?? 'UNKNOWN_ERROR' |
| 289 | })` |
| 290 | ); |
| 291 | }); |
| 292 | |
| 293 | void cloudconvert.jobs.subscribeEvent(jobId, 'failed', event => { |
| 294 | callbacks.failJob(event.job); |
| 295 | }); |
| 296 | |
| 297 | void cloudconvert.jobs.subscribeEvent(jobId, 'finished', event => { |
| 298 | callbacks.finishJob(event.job); |
| 299 | }); |
| 300 | } |
| 301 | |
| 302 | async function uploadFiles( |
| 303 | job: Job, |
no test coverage detected