[backend] use cache storage service for workspace schema cache (#4342)

* [backend] add cache storage module * update docs * update default TTL to a week * Use cacheStorageService for WorkspaceSchemaCache * remove memory storage module * revert pattern * remove logs
twentyhq · Mar 12, 2024 · 0d8e700 · 0d8e700
1 parent 1b485c2
commit 0d8e700
Show file tree

Hide file tree

Showing 18 changed files with 54 additions and 345 deletions.
diff --git a/packages/twenty-server/src/integrations/cache-storage/cache-storage.service.ts b/packages/twenty-server/src/integrations/cache-storage/cache-storage.service.ts
@@ -18,4 +18,8 @@ export class CacheStorageService {
   async set<T>(key: string, value: T, ttl?: number) {
     return this.cacheManager.set(`${this.namespace}:${key}`, value, ttl);
   }
+
+  async del(key: string) {
+    return this.cacheManager.del(`${this.namespace}:${key}`);
+  }
 }
diff --git a/packages/twenty-server/src/integrations/cache-storage/types/cache-storage-namespace.enum.ts b/packages/twenty-server/src/integrations/cache-storage/types/cache-storage-namespace.enum.ts
@@ -1,3 +1,4 @@
 export enum CacheStorageNamespace {
   Messaging = 'messaging',
+  WorkspaceSchema = 'workspaceSchema',
 }
diff --git a/...enty-server/src/integrations/memory-storage/decorators/inject-memory-storage.decorator.ts b/...enty-server/src/integrations/memory-storage/decorators/inject-memory-storage.decorator.ts
diff --git a/...ver/src/integrations/memory-storage/drivers/interfaces/memory-storage-driver.interface.ts b/...ver/src/integrations/memory-storage/drivers/interfaces/memory-storage-driver.interface.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/drivers/local.driver.ts b/packages/twenty-server/src/integrations/memory-storage/drivers/local.driver.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/interfaces/index.ts b/packages/twenty-server/src/integrations/memory-storage/interfaces/index.ts
diff --git a/...ages/twenty-server/src/integrations/memory-storage/interfaces/memory-storage.interface.ts b/...ages/twenty-server/src/integrations/memory-storage/interfaces/memory-storage.interface.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/memory-storage.constants.ts b/packages/twenty-server/src/integrations/memory-storage/memory-storage.constants.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/memory-storage.module.ts b/packages/twenty-server/src/integrations/memory-storage/memory-storage.module.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/memory-storage.service.spec.ts b/packages/twenty-server/src/integrations/memory-storage/memory-storage.service.spec.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/memory-storage.service.ts b/packages/twenty-server/src/integrations/memory-storage/memory-storage.service.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/memory-storage.util.ts b/packages/twenty-server/src/integrations/memory-storage/memory-storage.util.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/serializers/default.serializer.ts b/packages/twenty-server/src/integrations/memory-storage/serializers/default.serializer.ts
diff --git a/...integrations/memory-storage/serializers/interfaces/memory-storage-serializer.interface.ts b/...integrations/memory-storage/serializers/interfaces/memory-storage-serializer.interface.ts
diff --git a/packages/twenty-server/src/integrations/memory-storage/serializers/json.serializer.ts b/packages/twenty-server/src/integrations/memory-storage/serializers/json.serializer.ts
diff --git a/...s/twenty-server/src/workspace/workspace-schema-storage/workspace-schema-storage.module.ts b/...s/twenty-server/src/workspace/workspace-schema-storage/workspace-schema-storage.module.ts
@@ -1,40 +1,11 @@
 import { Module } from '@nestjs/common';
 
-import { MemoryStorageDriverType } from 'src/integrations/memory-storage/interfaces';
-import { MemoryStorageModule } from 'src/integrations/memory-storage/memory-storage.module';
-import { MemoryStorageJsonSerializer } from 'src/integrations/memory-storage/serializers/json.serializer';
-import { ObjectMetadataEntity } from 'src/metadata/object-metadata/object-metadata.entity';
 import { ObjectMetadataModule } from 'src/metadata/object-metadata/object-metadata.module';
 import { WorkspaceCacheVersionModule } from 'src/metadata/workspace-cache-version/workspace-cache-version.module';
 import { WorkspaceSchemaStorageService } from 'src/workspace/workspace-schema-storage/workspace-schema-storage.service';
 
 @Module({
-  imports: [
-    ObjectMetadataModule,
-    WorkspaceCacheVersionModule,
-    MemoryStorageModule.forRoot({
-      identifier: 'objectMetadataCollection',
-      type: MemoryStorageDriverType.Local,
-      options: {},
-      serializer: new MemoryStorageJsonSerializer<ObjectMetadataEntity[]>(),
-    }),
-    MemoryStorageModule.forRoot({
-      identifier: 'typeDefs',
-      type: MemoryStorageDriverType.Local,
-      options: {},
-    }),
-    MemoryStorageModule.forRoot({
-      identifier: 'usedScalarNames',
-      type: MemoryStorageDriverType.Local,
-      options: {},
-      serializer: new MemoryStorageJsonSerializer<string[]>(),
-    }),
-    MemoryStorageModule.forRoot({
-      identifier: 'cacheVersion',
-      type: MemoryStorageDriverType.Local,
-      options: {},
-    }),
-  ],
+  imports: [ObjectMetadataModule, WorkspaceCacheVersionModule],
   providers: [WorkspaceSchemaStorageService],
   exports: [WorkspaceSchemaStorageService],
 })