Merge pull request #237 from sotatek-dev/feat/add-token

feat: job priority
sotatek-dev · Jan 7, 2025 · 95ba5c5 · 95ba5c5
2 parents 95506af + f6271f3
commit 95ba5c5
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 3 deletions.
diff --git a/src/constants/queue.constant.ts b/src/constants/queue.constant.ts
@@ -5,3 +5,9 @@ export enum EQueueName {
 }
 export const getEvmValidatorQueueName = (index: number) => `EVM_VALIDATOR_${index}`;
 export const getMinaValidatorQueueName = (index: number) => `MINA_VALIDATOR_${index}`;
+
+// job priority, lower index is higher priority
+export enum EJobPriority {
+  DEPLOY_TOKEN,
+  UNLOCK,
+}
diff --git a/src/modules/crawler/deploy-token.ts b/src/modules/crawler/deploy-token.ts
@@ -7,7 +7,7 @@ import { IsNull } from 'typeorm';
 
 import { ETokenPairStatus } from '../../constants/blockchain.constant.js';
 import { EEnvKey } from '../../constants/env.constant.js';
-import { EQueueName } from '../../constants/queue.constant.js';
+import { EJobPriority, EQueueName } from '../../constants/queue.constant.js';
 import { CommonConfigRepository } from '../../database/repositories/common-configuration.repository.js';
 import { LoggerService } from '../../shared/modules/logger/logger.service.js';
 import { QueueService } from '../../shared/modules/queue/queue.service.js';
@@ -148,6 +148,7 @@ export class TokenDeployer {
         jobId: `deploy-token-${tokenPairId}`,
         removeOnComplete: true,
         removeOnFail: true,
+        priority: EJobPriority.DEPLOY_TOKEN,
       },
     );
   }
@@ -160,7 +161,12 @@ export class TokenDeployer {
           tokenPairId,
         },
       },
-      { jobId: `deploy-token-${tokenPairId}`, removeOnComplete: true, removeOnFail: true },
+      {
+        jobId: `deploy-token-${tokenPairId}`,
+        removeOnComplete: true,
+        removeOnFail: true,
+        priority: EJobPriority.DEPLOY_TOKEN,
+      },
     );
   }
 }
diff --git a/src/modules/crawler/job-unlock.provider.ts b/src/modules/crawler/job-unlock.provider.ts
@@ -7,7 +7,12 @@ import { QueryDeepPartialEntity } from 'typeorm/query-builder/QueryPartialEntity
 
 import { ENetworkName } from '../../constants/blockchain.constant.js';
 import { EEnvKey } from '../../constants/env.constant.js';
-import { EQueueName, getEvmValidatorQueueName, getMinaValidatorQueueName } from '../../constants/queue.constant.js';
+import {
+  EJobPriority,
+  EQueueName,
+  getEvmValidatorQueueName,
+  getMinaValidatorQueueName,
+} from '../../constants/queue.constant.js';
 import { CommonConfigRepository } from '../../database/repositories/common-configuration.repository.js';
 import { EventLogRepository } from '../../database/repositories/event-log.repository.js';
 import { LoggerService } from '../../shared/modules/logger/logger.service.js';
@@ -188,6 +193,7 @@ export class JobUnlockProvider {
         jobId: `send-unlock-${data.eventLogId}`,
         removeOnComplete: true,
         removeOnFail: true,
+        priority: EJobPriority.UNLOCK,
       },
     );
   }

diff --git a/src/modules/users/admin.service.ts b/src/modules/users/admin.service.ts
@@ -40,6 +40,7 @@ export class AdminService {
       newCommonConfig.mintingFee = payload.mintingFee;
       newCommonConfig.unlockingFee = payload.unlockingFee;
       newCommonConfig.status = ETokenPairStatus.CREATED;
+      newCommonConfig.isHidden = true;
       return newCommonConfig.save();
     });
     assert(isNumber(newTokenPair.id), 'Token pair invalid!');