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