From 7bebea087cc35b95c4065c1dd9f554a8ec002771 Mon Sep 17 00:00:00 2001 From: MeiMei <30769358+mei23@users.noreply.github.com> Date: Thu, 21 Mar 2019 04:50:44 +0900 Subject: Fix #4546 (#4548) * Refactor download * emoji type --- src/misc/donwload-url.ts | 61 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 61 insertions(+) create mode 100644 src/misc/donwload-url.ts (limited to 'src/misc/donwload-url.ts') diff --git a/src/misc/donwload-url.ts b/src/misc/donwload-url.ts new file mode 100644 index 0000000000..0dd4e4ef5d --- /dev/null +++ b/src/misc/donwload-url.ts @@ -0,0 +1,61 @@ +import * as fs from 'fs'; +import * as URL from 'url'; +import * as request from 'request'; +import config from '../config'; +import chalk from 'chalk'; +import Logger from '../services/logger'; + +export async function downloadUrl(url: string, path: string) { + const logger = new Logger('download-url'); + + await new Promise((res, rej) => { + logger.info(`Downloading ${chalk.cyan(url)} ...`); + + const writable = fs.createWriteStream(path); + + writable.on('finish', () => { + logger.succ(`Download finished: ${chalk.cyan(url)}`); + res(); + }); + + writable.on('error', error => { + logger.error(`Download failed: ${chalk.cyan(url)}: ${error}`, { + url: url, + e: error + }); + rej(error); + }); + + const requestUrl = URL.parse(url).pathname.match(/[^\u0021-\u00ff]/) ? encodeURI(url) : url; + + const req = request({ + url: requestUrl, + proxy: config.proxy, + timeout: 10 * 1000, + headers: { + 'User-Agent': config.userAgent + } + }); + + req.pipe(writable); + + req.on('response', response => { + if (response.statusCode !== 200) { + logger.error(`Got ${response.statusCode} (${url})`); + writable.close(); + rej(response.statusCode); + } + }); + + req.on('error', error => { + logger.error(`Failed to start download: ${chalk.cyan(url)}: ${error}`, { + url: url, + e: error + }); + writable.close(); + rej(error); + }); + + logger.succ(`Downloaded to: ${path}`); + }); +} -- cgit v1.2.3-freya