processor

daydreamsai · Jan 25, 2025 · 22417b4 · 22417b4
1 parent 3b7d0a7
commit 22417b4
Showing 1 changed file with 0 additions and 69 deletions.
diff --git a/packages/core/src/core/processor.ts b/packages/core/src/core/processor.ts
@@ -262,73 +262,4 @@ export class MessageProcessor extends BaseProcessor {
             };
         }
     }
-
-    // Check if we've already processed this content
-    // private async hasProcessedContent(
-    //     contentId: string,
-    //     room: Room
-    // ): Promise<boolean> {
-    //     try {
-    //         // Use findSimilarInRoom but with exact metadata matching
-    //         const results = await this.vectorDb.findSimilarInRoom(
-    //             contentId, // Simple query text since we're using metadata matching
-    //             room.id,
-    //             1,
-    //             {
-    //                 contentId: contentId,
-    //             }
-    //         );
-
-    //         return results.length > 0;
-    //     } catch (error) {
-    //         this.logger.error("Processor.hasProcessedContent", "Check failed", {
-    //             error: error instanceof Error ? error.message : String(error),
-    //             contentId,
-    //             roomId: room.id,
-    //         });
-    //         return false;
-    //     }
-    // }
-
-    // Mark content as processed
-    // private async markContentAsProcessed(
-    //     contentId: string,
-    //     room: Room
-    // ): Promise<void> {
-    //     try {
-    //         const markerId = `processed_${contentId}`;
-
-    //         await this.vectorDb.storeInRoom(
-    //             `Processed marker for content: ${contentId}`,
-    //             room.id,
-    //             {
-    //                 type: "processed_marker",
-    //                 contentId: contentId,
-    //                 timestamp: new Date().toISOString(),
-    //             }
-    //         );
-
-    //         this.logger.debug(
-    //             "Processor.markContentAsProcessed",
-    //             "Marked content as processed",
-    //             {
-    //                 contentId,
-    //                 roomId: room.id,
-    //                 markerId,
-    //             }
-    //         );
-    //     } catch (error) {
-    //         this.logger.error(
-    //             "Processor.markContentAsProcessed",
-    //             "Failed to mark content",
-    //             {
-    //                 error:
-    //                     error instanceof Error ? error.message : String(error),
-    //                 contentId,
-    //                 roomId: room.id,
-    //             }
-    //         );
-    //         throw error;
-    //     }
-    // }
 }