Neo4j Memory Server

/** * Manage Relations Use Case * Clean Architecture Application Layer */ import { MemoryRepository } from '../../domain/repositories/memory-repository'; import { createErrorMessage } from '../../infrastructure/utilities'; import { MCPResourceNotFoundError, MCPErrorCodes } from '../../infrastructure/errors'; export interface RelationRequest { fromId: string; toId: string; relationType: string; // Enhanced metadata fields (simplified without context complexity) strength?: number; // 0.0-1.0, defaults to 0.5 source?: 'agent' | 'user' | 'system'; // Defaults to 'agent' } export class ManageRelationsUseCase { constructor(private memoryRepository: MemoryRepository) {} async createRelation(request: RelationRequest): Promise<void> { // Verify both memories exist const fromMemory = await this.memoryRepository.findById(request.fromId); if (!fromMemory) { throw new MCPResourceNotFoundError('Source memory', request.fromId, MCPErrorCodes.MEMORY_NOT_FOUND); } const toMemory = await this.memoryRepository.findById(request.toId); if (!toMemory) { throw new MCPResourceNotFoundError('Target memory', request.toId, MCPErrorCodes.MEMORY_NOT_FOUND); } // Enhanced relation creation without context complexity const enhancedRequest = { fromId: request.fromId, toId: request.toId, relationType: request.relationType, strength: request.strength || 0.5, // Default strength source: request.source || 'agent', // Default source createdAt: new Date().toISOString() // Always system-generated }; // Create the enhanced relation return await this.memoryRepository.createEnhancedRelation(enhancedRequest); } async deleteRelation(request: RelationRequest): Promise<void> { // Verify relation exists const fromMemory = await this.memoryRepository.findById(request.fromId); if (!fromMemory) { throw new MCPResourceNotFoundError('Source memory', request.fromId, MCPErrorCodes.MEMORY_NOT_FOUND); } // Delete the relation return await this.memoryRepository.deleteRelation( request.fromId, request.toId, request.relationType ); } async executeMany( operation: 'create' | 'delete', requests: RelationRequest[] ): Promise<{ processed: number; errors: string[] }> { const results: { processed: number; errors: string[] } = { processed: 0, errors: [] }; for (const request of requests) { try { if (operation === 'create') { await this.createRelation(request); } else { await this.deleteRelation(request); } results.processed++; } catch (error) { results.errors.push( createErrorMessage(`Failed to ${operation} relation ${request.fromId} -> ${request.toId}`, error) ); } } return results; } }