only one arira2 socket channel

package/main.ts

@@ -75,12 +75,13 @@ export async function bundle(...args) {
   const fullHash = await caculateSHA256(filePath);
   const fullSize = (await fs.statAsync(filePath)).size;
 
-  let fullPath = path.join(path.dirname(filePath), `${fullHash}.tar.gz`);
+  let fullPath = path.join(dist_path, `${fullHash}.tar.gz`);
   await fs.renameAsync(filePath, fullPath);
 
+  await fs.removeAsync(uploadFile_path);
+  await fs.removeAsync(package_path);
+
   return {
-    uploadFilePath: uploadFile_path,
-    pckagePath: package_path,
     distPath: dist_path,
     files: Array.from(files.values()),
     archives: Array.from(archives.values()),

src/routes/upload.ts

@@ -14,6 +14,11 @@ import config from '../../config';
 import {UploadOSS} from '../utils';
 import Router = require('koa-router');
 
+const downloader = new Aria2;
+
+downloader.open();
+
+
 const checkFilePath = async (file) => {
   if (['.gz', '.rar', '.zip', '.7z'].indexOf(path.extname(file.path)) === -1) {
     console.log(file);
@@ -148,15 +153,12 @@ const uploadPackageUrl = async (ctx: Context) => {
   }
   // testUrl: https://r.my-card.in/release/dist/0c16a3ecb115fd7cf575ccdd64f62a8f3edc635b087950e4ed4f3f781972bbfd.tar.gz
 
-  const downloader = new Aria2;
   let pack = await mongodb.Packages.findOne({_id: toObjectID(ctx.request.body._id)});
   if (!pack) {
     return ctx.throw(400, 'pack not exists');
   }
 
 
-  await downloader.open();
-
   downloader.onDownloadStart = async () => {
     pack!.status = 'uploading';
     await pack!.save();
@@ -183,8 +185,6 @@ const uploadPackageUrl = async (ctx: Context) => {
 
       // 上传完，干掉本地目录
       await fs.removeAsync(bundled.distPath);
-      await fs.removeAsync(bundled.pckagePath);
-      await fs.removeAsync(bundled.uploadFilePath);
     } catch (e) {
       console.trace(e);
       pack!.status = 'failed';