Function pipeRequest

framework/utils/lib/utils.ts:341–367

(req: superagent.Request, w: fs.WriteStream, timeout?: number, name?: string)

}

export async function pipeRequest(req: superagent.Request, w: fs.WriteStream, timeout?: number, name?: string) {
    try {
        await new Promise((resolve, reject) => {
            w.on('finish', () => {
                resolve(null);
            });
            req.buffer(false).timeout({
                response: Math.min(10000, timeout),
                deadline: timeout,
            }).parse((resp, cb) => {
                if (resp.statusCode !== 200) throw new Error(`${resp.statusCode}`);
                else {
                    resp.pipe(w);
                    resp.on('end', () => {
                        cb(null, undefined);
                    });
                    resp.on('error', (err) => {
                        cb(err, undefined);
                        reject(err);
                    });
                }
            }).catch(reject);
        });
    } catch (e: any) {
        throw new Error(`Download${e.errno === 'ETIMEDOUT' ? 'Timedout' : 'Error'}(${name ? `${name}, ` : ''}${e.message})`);
    }
}

export * as yaml from 'js-yaml';