]>
Commit | Line | Data |
---|---|---|
6fcd19ba | 1 | import * as Promise from 'bluebird' |
0d0e8dd0 | 2 | import { createWriteStream } from 'fs' |
571389d4 | 3 | import * as request from 'request' |
da854ddd C |
4 | import { ACTIVITY_PUB } from '../initializers' |
5 | ||
6 | function doRequest (requestOptions: request.CoreOptions & request.UriOptions & { activityPub?: boolean }) { | |
7 | if (requestOptions.activityPub === true) { | |
8 | if (!Array.isArray(requestOptions.headers)) requestOptions.headers = {} | |
9 | requestOptions.headers['accept'] = ACTIVITY_PUB.ACCEPT_HEADER | |
10 | } | |
e4f97bab | 11 | |
e4f97bab C |
12 | return new Promise<{ response: request.RequestResponse, body: any }>((res, rej) => { |
13 | request(requestOptions, (err, response, body) => err ? rej(err) : res({ response, body })) | |
14 | }) | |
15 | } | |
dac0a531 | 16 | |
0d0e8dd0 C |
17 | function doRequestAndSaveToFile (requestOptions: request.CoreOptions & request.UriOptions, destPath: string) { |
18 | return new Promise<request.RequestResponse>((res, rej) => { | |
19 | request(requestOptions) | |
20 | .on('response', response => res(response as request.RequestResponse)) | |
21 | .on('error', err => rej(err)) | |
22 | .pipe(createWriteStream(destPath)) | |
23 | }) | |
24 | } | |
25 | ||
9f10b292 | 26 | // --------------------------------------------------------------------------- |
dac0a531 | 27 | |
65fcc311 | 28 | export { |
e4f97bab | 29 | doRequest, |
571389d4 | 30 | doRequestAndSaveToFile |
65fcc311 | 31 | } |