👌 IMPROVE: syncPackageWorkerMaxConcurrentTasks up to 20 (#322)

cnpm · Oct 2, 2022 · bbc08fd · bbc08fd
1 parent 5852f22
commit bbc08fd
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/config/config.default.ts b/config/config.default.ts
@@ -24,7 +24,7 @@ export default (appInfo: EggAppConfig) => {
     //  - exist: only sync exist packages, effected when `enableCheckRecentlyUpdated` or `enableChangesStream` is enabled
     syncMode: 'none',
     hookEnable: false,
-    syncPackageWorkerMaxConcurrentTasks: 10,
+    syncPackageWorkerMaxConcurrentTasks: 20,
     triggerHookWorkerMaxConcurrentTasks: 10,
     createTriggerHookWorkerMaxConcurrentTasks: 10,
     // stop syncing these packages in future

diff --git a/package.json b/package.json
@@ -102,6 +102,8 @@
   },
   "devDependencies": {
     "@types/mocha": "^9.0.0",
+    "@types/mysql": "^2.15.21",
+    "@types/semver": "^7.3.12",
     "coffee": "^5.4.0",
     "egg-bin": "^4.16.4",
     "egg-mock": "^4.2.0",

diff --git a/test/TestUtil.ts b/test/TestUtil.ts
@@ -64,10 +64,10 @@ export class TestUtil {
     return sqls.join('\n');
   }
 
-  static async query(sql): Promise<any[]> {
+  static async query(sql: string): Promise<any[]> {
     const conn = this.getConnection();
     return new Promise((resolve, reject) => {
-      conn.query(sql, (err, rows) => {
+      conn.query(sql, (err: Error, rows: any[]) => {
         if (err) {
           return reject(err);
         }
@@ -78,7 +78,7 @@ export class TestUtil {
 
   static getConnection() {
     if (!this.connection) {
-      const config = this.getMySqlConfig();
+      const config: any = this.getMySqlConfig();
       if (process.env.CI) {
         console.log('[TestUtil] connection to mysql: %j', config);
       }
@@ -123,7 +123,7 @@ export class TestUtil {
   static async truncateDatabase() {
     const database = this.getDatabase();
     const tables = await this.getTableNames();
-    await Promise.all(tables.map(table => this.query(`TRUNCATE TABLE ${database}.${table};`)));
+    await Promise.all(tables.map((table: string) => this.query(`TRUNCATE TABLE ${database}.${table};`)));
   }
 
   static get app() {