fix: update upload file

Author: sobird

.eslintrc.cjs

@@ -10,5 +10,6 @@ module.exports = {
     }],
     'import/no-unresolved': 'off',
     'arrow-body-style': ['error', 'always'],
+    'no-restricted-syntax': ['error', 'ForInStatement', 'LabeledStatement', 'WithStatement'],
   },
 };

command/upload.ts

@@ -13,45 +13,38 @@ export const uploadCommand = new Command('upload')
   .argument('[pattern]', 'glob pattern', '*')
   .argument('[remote]', 'remote path', sep)
   .option('-t --token [token]', 'access token')
-  .option('-b --bytes <number>', 'Split upload bytes size', Number, 1073741824)
+  .option('-b --bytes <number>', 'split upload bytes size', Number, 1073741824)
   .option('--thread', 'Thread')
-  .action(async (pattern, remote, options, command) => {
-    const { pcs } = command;
-
+  .action(async (pattern, remote, options, { pcs }) => {
     const files = await glob(pattern, {
       nodir: true,
     });
     const { bytes } = options;
-
     const temp = join(os.tmpdir(), 'pcs-cli');
-    try {
-      // 串行上传
-      files.reduce(async (previousValue, currentValue) => {
-        await previousValue;
-        const fileStat = statSync(currentValue);
 
+    try {
+      for await (const file of files) {
+        const fileStat = statSync(file);
         if (Number.isInteger(bytes) && fileStat.size > bytes) {
           // 分片上传
-          const pieces = await splitFile(currentValue, bytes, temp);
+          const pieces = await splitFile(file, bytes, temp);
           const blocks = [];
 
           // eslint-disable-next-line no-restricted-syntax
           for (const piece of pieces as string[]) {
             //
             // eslint-disable-next-line no-await-in-loop
-            const { md5 } = await pcs.upload(piece, '', 'overwrite', 'tmpfile') as any;
+            const { md5 } = await pcs.upload(piece, '', 'overwrite', 'tmpfile');
             blocks.push(md5);
           }
           const param = {
             block_list: blocks,
           };
-          return pcs.createSuperFile(join(remote, currentValue), param) as unknown as Promise<void>;
+          await pcs.createSuperFile(join(remote, file), param);
         }
-        console.log(`${chalk.blueBright('==>')} Uploading ${currentValue}`);
-        return pcs.upload(currentValue, join(remote, currentValue)) as Promise<void>;
-      }, Promise.resolve());
-
-      // todo
+        console.log(`${chalk.blueBright('==>')} Uploading ${file}`);
+        await pcs.upload(file, join(remote, file));
+      }
     } catch (err: any) {
       const { response: { data } } = err;
       console.log(`error code ${data.error_code} : ${data.error_msg}`);

package.json

@@ -41,7 +41,7 @@
     "axios": "^1.13.2",
     "bytes": "^3.1.2",
     "chalk": "^5.6.2",
-    "cliui": "^9.0.1",
+    "cliui": "^8.0.1",
     "commander": "^14.0.2",
     "dayjs": "^1.11.19",
     "glob": "^13.0.0",
@@ -50,8 +50,8 @@
     "prompts": "^2.4.2"
   },
   "devDependencies": {
-    "@commitlint/cli": "^19.2.2",
-    "@commitlint/config-conventional": "^19.2.2",
+    "@commitlint/cli": "^20.2.0",
+    "@commitlint/config-conventional": "^20.2.0",
     "@rollup/plugin-commonjs": "^25.0.7",
     "@rollup/plugin-json": "^6.1.0",
     "@rollup/plugin-node-resolve": "^15.2.3",