feat: activated redis queue manager

skybase-int · May 8, 2024 · 05b7dc2 · 05b7dc2
1 parent a805aab
commit 05b7dc2
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 6 deletions.
diff --git a/api/package.json b/api/package.json
@@ -23,7 +23,7 @@
     "body-parser": "^1.20.2",
     "cookie-parser": "^1.4.6",
     "cors": "^2.8.5",
-    "document-drive": "1.0.0-experimental.2",
+    "document-drive": "1.0.0-experimental.4",
     "document-model": "1.1.0-experimental.1",
     "document-model-libs": "^1.42.0",
     "dotenv": "^16.4.5",

diff --git a/api/pnpm-lock.yaml b/api/pnpm-lock.yaml
diff --git a/api/src/modules/document/model.ts b/api/src/modules/document/model.ts
@@ -20,6 +20,8 @@ import {
 } from 'document-model-libs/document-drive';
 import RedisCache from 'document-drive/cache/redis';
 import MemoryCache from 'document-drive/cache/memory';
+import { RedisQueueManager } from 'document-drive/queue/redis';
+import { BaseQueueManager } from 'document-drive/queue/base';
 
 import { init } from './listenerManager';
 import { getChildLogger } from '../../logger';
@@ -52,7 +54,8 @@ export function getDocumentDriveCRUD(prisma: Prisma.TransactionClient) {
   driveServer = new DocumentDriveServer(
     documentModels,
     new PrismaStorage(prisma as PrismaClient),
-    redisClient ? new RedisCache(redisClient) : new MemoryCache()
+    redisClient ? new RedisCache(redisClient) : new MemoryCache(),
+    redisClient ? new RedisQueueManager(3, 10, redisClient) : new BaseQueueManager(3, 10),
   );
 
   initialize();