2018-01-15 10:10:46 +00:00
|
|
|
import * as Bluebird from 'bluebird'
|
2017-11-10 13:34:45 +00:00
|
|
|
import { createWriteStream } from 'fs'
|
2017-11-10 16:27:49 +00:00
|
|
|
import * as request from 'request'
|
2017-12-28 10:16:08 +00:00
|
|
|
import { ACTIVITY_PUB } from '../initializers'
|
|
|
|
|
2018-01-15 08:46:46 +00:00
|
|
|
function doRequest (
|
|
|
|
requestOptions: request.CoreOptions & request.UriOptions & { activityPub?: boolean }
|
2018-01-15 09:03:13 +00:00
|
|
|
): Bluebird<{ response: request.RequestResponse, body: any }> {
|
2017-12-28 10:16:08 +00:00
|
|
|
if (requestOptions.activityPub === true) {
|
|
|
|
if (!Array.isArray(requestOptions.headers)) requestOptions.headers = {}
|
|
|
|
requestOptions.headers['accept'] = ACTIVITY_PUB.ACCEPT_HEADER
|
|
|
|
}
|
2017-11-09 16:51:58 +00:00
|
|
|
|
2018-01-15 10:10:46 +00:00
|
|
|
return new Bluebird<{ response: request.RequestResponse, body: any }>((res, rej) => {
|
2017-11-09 16:51:58 +00:00
|
|
|
request(requestOptions, (err, response, body) => err ? rej(err) : res({ response, body }))
|
|
|
|
})
|
|
|
|
}
|
2016-02-05 17:03:20 +00:00
|
|
|
|
2017-11-10 13:34:45 +00:00
|
|
|
function doRequestAndSaveToFile (requestOptions: request.CoreOptions & request.UriOptions, destPath: string) {
|
2018-02-15 17:40:24 +00:00
|
|
|
return new Bluebird<void>((res, rej) => {
|
|
|
|
const file = createWriteStream(destPath)
|
|
|
|
file.on('finish', () => res())
|
|
|
|
|
2017-11-10 13:34:45 +00:00
|
|
|
request(requestOptions)
|
|
|
|
.on('error', err => rej(err))
|
2018-02-15 17:40:24 +00:00
|
|
|
.pipe(file)
|
2017-11-10 13:34:45 +00:00
|
|
|
})
|
|
|
|
}
|
|
|
|
|
2016-02-07 10:23:23 +00:00
|
|
|
// ---------------------------------------------------------------------------
|
2016-02-05 17:03:20 +00:00
|
|
|
|
2017-05-15 20:22:03 +00:00
|
|
|
export {
|
2017-11-09 16:51:58 +00:00
|
|
|
doRequest,
|
2017-11-10 16:27:49 +00:00
|
|
|
doRequestAndSaveToFile
|
2017-05-15 20:22:03 +00:00
|
|
|
}
|