chore: add workflow running key (#681)

* chore: add workflow running key * chore: add workflow event key
teableio · Jun 29, 2024 · 383b162 · 383b162
1 parent 9e5bbb6
commit 383b162
Show file tree

Hide file tree

Showing 6 changed files with 21 additions and 9 deletions.
diff --git a/apps/nestjs-backend/src/cache/cache.service.ts b/apps/nestjs-backend/src/cache/cache.service.ts
@@ -15,6 +15,7 @@ export class CacheService {
   async set<TKey extends keyof ICacheStore>(
     key: TKey,
     value: ICacheStore[TKey],
+    // seconds, and will add random 20-60 seconds
     ttl?: number
   ): Promise<void> {
     await this.cacheManager.set(key, value, ttl ? (ttl + getRandomInt(20, 60)) * 1000 : undefined);

diff --git a/apps/nestjs-backend/src/cache/types.ts b/apps/nestjs-backend/src/cache/types.ts
@@ -11,6 +11,8 @@ export interface ICacheStore {
   [key: `auth:session-expire:${string}`]: boolean;
   [key: `oauth2:${string}`]: IOauth2State;
   [key: `reset-password-email:${string}`]: IResetPasswordEmailCache;
+  [key: `workflow:running:${string}`]: string;
+  [key: `workflow:repeatKey:${string}`]: string;
 }
 
 export interface IAttachmentSignatureCache {

diff --git a/apps/nestjs-backend/src/event-emitter/events/event.enum.ts b/apps/nestjs-backend/src/event-emitter/events/event.enum.ts
@@ -43,4 +43,7 @@ export enum Events {
 
   COLLABORATOR_CREATE = 'collaborator.create',
   COLLABORATOR_DELETE = 'collaborator.delete',
+
+  WORKFLOW_ACTIVATE = 'workflow.activate',
+  WORKFLOW_DEACTIVATE = 'workflow.deactivate',
 }
diff --git a/apps/nestjs-backend/src/ws/ws.gateway.dev.ts b/apps/nestjs-backend/src/ws/ws.gateway.dev.ts
@@ -54,12 +54,16 @@ export class DevWsGateway implements OnModuleInit, OnModuleDestroy {
   }
 
   onModuleDestroy() {
-    this.agents?.map((agent) => agent?.close());
-    this.shareDb.close();
-    this.server.close((err) => {
-      if (err) {
-        this.logger.error('DevWsGateway close error', err?.stack);
-      }
-    });
+    try {
+      this.agents?.map((agent) => agent?.close());
+      this.shareDb.close();
+      this.server.close((err) => {
+        if (err) {
+          this.logger.error('DevWsGateway close error', err?.stack);
+        }
+      });
+    } catch (err) {
+      this.logger.error('dev module close error: ' + (err as Error).message, (err as Error)?.stack);
+    }
   }
 }
diff --git a/packages/common-i18n/src/locales/en/common.json b/packages/common-i18n/src/locales/en/common.json
@@ -26,7 +26,8 @@
     "rename": "Rename",
     "change": "Change",
     "upgrade": "Upgrade",
-    "search": "Search"
+    "search": "Search",
+    "loadMore": "Load more"
   },
   "quickAction": {
     "title": "Quick Actions...",

diff --git a/packages/common-i18n/src/locales/zh/common.json b/packages/common-i18n/src/locales/zh/common.json
@@ -26,7 +26,8 @@
     "rename": "重命名",
     "change": "变更",
     "upgrade": "升级",
-    "search": "搜索"
+    "search": "搜索",
+    "loadMore": "加载更多"
   },
   "quickAction": {
     "title": "快捷搜索...",