X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fhelpers%2Frequests.ts;h=ee9e804040e8364a00723f2312d3917c221fd830;hb=40ed9f6aaeb9e78fc8d9a5f82bd7dbad16639051;hp=eb8a12868137802fec658275874ed9e488f74597;hpb=6b2ef589ed8ef5d253f6213e1bb275cbe135f2b4;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/helpers/requests.ts b/server/helpers/requests.ts index eb8a12868..ee9e80404 100644 --- a/server/helpers/requests.ts +++ b/server/helpers/requests.ts @@ -1,5 +1,5 @@ import * as Bluebird from 'bluebird' -import { createWriteStream } from 'fs' +import { createWriteStream } from 'fs-extra' import * as request from 'request' import { ACTIVITY_PUB } from '../initializers' @@ -17,11 +17,13 @@ function doRequest ( } function doRequestAndSaveToFile (requestOptions: request.CoreOptions & request.UriOptions, destPath: string) { - return new Bluebird((res, rej) => { + return new Bluebird((res, rej) => { + const file = createWriteStream(destPath) + file.on('finish', () => res()) + request(requestOptions) - .on('response', response => res(response as request.RequestResponse)) .on('error', err => rej(err)) - .pipe(createWriteStream(destPath)) + .pipe(file) }) }