fix(integration): purge per-user unfurl cache on disconnect

apps/server/src/core/integration/integration-connection.service.ts

@@ -2,12 +2,14 @@ import { Injectable, NotFoundException } from '@nestjs/common';
 import { IntegrationConnectionRepo } from './repos/integration-connection.repo';
 import { IntegrationRepo } from './repos/integration.repo';
 import { IntegrationConnection } from '@docmost/db/types/entity.types';
+import { UnfurlService } from './unfurl/unfurl.service';
 
 @Injectable()
 export class IntegrationConnectionService {
   constructor(
     private readonly connectionRepo: IntegrationConnectionRepo,
     private readonly integrationRepo: IntegrationRepo,
+    private readonly unfurlService: UnfurlService,
   ) {}
 
   async getConnectionStatus(
@@ -79,5 +81,7 @@ export class IntegrationConnectionService {
       integrationId,
       userId,
     );
+
+    await this.unfurlService.purgeUserCache(workspaceId, userId);
   }
 }

apps/server/src/core/integration/unfurl/unfurl.service.ts

@@ -113,6 +113,22 @@ export class UnfurlService {
     }
   }
 
+  async purgeUserCache(workspaceId: string, userId: string): Promise<void> {
+    const pattern = `${UNFURL_CACHE_PREFIX}${workspaceId}:${userId}:*`;
+    try {
+      const stream = this.redis.scanStream({ match: pattern, count: 100 });
+      for await (const keys of stream as AsyncIterable<string[]>) {
+        if (keys.length) {
+          await this.redis.unlink(...keys);
+        }
+      }
+    } catch (err) {
+      this.logger.error(
+        `Failed to purge unfurl cache for user ${userId}: ${(err as Error).message}`,
+      );
+    }
+  }
+
   private buildNeedsConnection(
     provider: IntegrationProvider,
     integrationId: string,