diff --git a/packages/core/src/core/processor.ts b/packages/core/src/core/processor.ts index bd3757f7..49e639e3 100644 --- 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 { - // 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 { - // 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; - // } - // } }