rpg-mcp

import { z } from 'zod'; import { getDb } from '../storage/index.js'; import { NpcMemoryRepository, Familiarity, Disposition, Importance } from '../storage/repos/npc-memory.repo.js'; import { SessionContext } from './types.js'; import { CharacterRepository } from '../storage/repos/character.repo.js'; import { SpatialRepository } from '../storage/repos/spatial.repo.js'; import { calculateHearingRadius } from '../engine/social/hearing.js'; import { rollStealthVsPerception, isDeafened, getEnvironmentModifier } from '../engine/social/stealth-perception.js'; import { VolumeLevel } from '../engine/social/hearing.js'; /** * HIGH-004: NPC Memory Tools * Tools for tracking NPC relationships and conversation memories */ // ============================================================ // TOOL DEFINITIONS // ============================================================ export const NpcMemoryTools = { GET_NPC_RELATIONSHIP: { name: 'get_npc_relationship', description: 'Get relationship status (familiarity, disposition) between a PC and NPC.', inputSchema: z.object({ characterId: z.string().describe('ID of the player character'), npcId: z.string().describe('ID of the NPC') }) }, UPDATE_NPC_RELATIONSHIP: { name: 'update_npc_relationship', description: 'Update or create a PC-NPC relationship. Familiarity: stranger→acquaintance→friend→close_friend/rival/enemy.', inputSchema: z.object({ characterId: z.string().describe('ID of the player character'), npcId: z.string().describe('ID of the NPC'), familiarity: z.enum(['stranger', 'acquaintance', 'friend', 'close_friend', 'rival', 'enemy']) .describe('Level of familiarity'), disposition: z.enum(['hostile', 'unfriendly', 'neutral', 'friendly', 'helpful']) .describe('NPC\'s attitude toward the character'), notes: z.string().optional().describe('Additional notes about the relationship') }) }, RECORD_CONVERSATION_MEMORY: { name: 'record_conversation_memory', description: 'Record a significant conversation/interaction. Importance: low (chat), medium, high (plot), critical.', inputSchema: z.object({ characterId: z.string().describe('ID of the player character'), npcId: z.string().describe('ID of the NPC'), summary: z.string().describe('Summary of the conversation/interaction'), importance: z.enum(['low', 'medium', 'high', 'critical']).default('medium') .describe('How important this memory is'), topics: z.array(z.string()).default([]) .describe('Keywords/topics for searching (e.g., ["quest", "dragon", "treasure"])') }) }, GET_CONVERSATION_HISTORY: { name: 'get_conversation_history', description: 'Get conversation history between PC and NPC. Filter by minimum importance level.', inputSchema: z.object({ characterId: z.string().describe('ID of the player character'), npcId: z.string().describe('ID of the NPC'), minImportance: z.enum(['low', 'medium', 'high', 'critical']).optional() .describe('Minimum importance to include'), limit: z.number().int().positive().optional() .describe('Maximum number of memories to return') }) }, GET_RECENT_INTERACTIONS: { name: 'get_recent_interactions', description: 'Get recent conversation memories across all NPCs for context building.', inputSchema: z.object({ characterId: z.string().describe('ID of the player character'), limit: z.number().int().positive().default(10) .describe('Maximum number of memories to return') }) }, GET_NPC_CONTEXT: { name: 'get_npc_context', description: 'Get relationship + conversation history for LLM NPC dialogue prompts.', inputSchema: z.object({ characterId: z.string().describe('ID of the player character'), npcId: z.string().describe('ID of the NPC'), memoryLimit: z.number().int().positive().default(5) .describe('Maximum number of memories to include') }) }, // PHASE-2: Social Hearing Mechanics INTERACT_SOCIALLY: { name: 'interact_socially', description: 'Social interaction with spatial awareness. Handles hearing range, stealth vs perception, and memory recording.', inputSchema: z.object({ speakerId: z.string().describe('ID of the character speaking'), targetId: z.string().optional().describe('ID of the intended recipient (optional for broadcasts)'), content: z.string().min(1).describe('What is being said'), volume: z.enum(['WHISPER', 'TALK', 'SHOUT']).describe('Volume level of speech'), intent: z.string().optional().describe('Social intent: gossip, interrogate, negotiate, threaten, etc.') }) } } as const; // ============================================================ // TOOL HANDLERS // ============================================================ function getRepo(): NpcMemoryRepository { const db = getDb(process.env.NODE_ENV === 'test' ? ':memory:' : 'rpg.db'); return new NpcMemoryRepository(db); } export async function handleGetNpcRelationship(args: unknown, _ctx: SessionContext) { const parsed = NpcMemoryTools.GET_NPC_RELATIONSHIP.inputSchema.parse(args); const repo = getRepo(); const relationship = repo.getRelationship(parsed.characterId, parsed.npcId); if (!relationship) { // Default stranger status return { content: [{ type: 'text' as const, text: JSON.stringify({ characterId: parsed.characterId, npcId: parsed.npcId, familiarity: 'stranger', disposition: 'neutral', notes: null, firstMetAt: null, lastInteractionAt: null, interactionCount: 0, isNew: true }, null, 2) }] }; } return { content: [{ type: 'text' as const, text: JSON.stringify({ ...relationship, isNew: false }, null, 2) }] }; } export async function handleUpdateNpcRelationship(args: unknown, _ctx: SessionContext) { const parsed = NpcMemoryTools.UPDATE_NPC_RELATIONSHIP.inputSchema.parse(args); const repo = getRepo(); const relationship = repo.upsertRelationship({ characterId: parsed.characterId, npcId: parsed.npcId, familiarity: parsed.familiarity as Familiarity, disposition: parsed.disposition as Disposition, notes: parsed.notes ?? null }); return { content: [{ type: 'text' as const, text: JSON.stringify({ success: true, relationship }, null, 2) }] }; } export async function handleRecordConversationMemory(args: unknown, _ctx: SessionContext) { const parsed = NpcMemoryTools.RECORD_CONVERSATION_MEMORY.inputSchema.parse(args); const repo = getRepo(); const memory = repo.recordMemory({ characterId: parsed.characterId, npcId: parsed.npcId, summary: parsed.summary, importance: parsed.importance as Importance, topics: parsed.topics }); return { content: [{ type: 'text' as const, text: JSON.stringify({ success: true, memory }, null, 2) }] }; } export async function handleGetConversationHistory(args: unknown, _ctx: SessionContext) { const parsed = NpcMemoryTools.GET_CONVERSATION_HISTORY.inputSchema.parse(args); const repo = getRepo(); const memories = repo.getConversationHistory( parsed.characterId, parsed.npcId, { minImportance: parsed.minImportance as Importance | undefined, limit: parsed.limit } ); return { content: [{ type: 'text' as const, text: JSON.stringify({ characterId: parsed.characterId, npcId: parsed.npcId, count: memories.length, memories }, null, 2) }] }; } export async function handleGetRecentInteractions(args: unknown, _ctx: SessionContext) { const parsed = NpcMemoryTools.GET_RECENT_INTERACTIONS.inputSchema.parse(args); const repo = getRepo(); const memories = repo.getRecentInteractions(parsed.characterId, parsed.limit); return { content: [{ type: 'text' as const, text: JSON.stringify({ characterId: parsed.characterId, count: memories.length, memories }, null, 2) }] }; } export async function handleGetNpcContext(args: unknown, _ctx: SessionContext) { const parsed = NpcMemoryTools.GET_NPC_CONTEXT.inputSchema.parse(args); const repo = getRepo(); // Get relationship const relationship = repo.getRelationship(parsed.characterId, parsed.npcId); // Get conversation history const memories = repo.getConversationHistory( parsed.characterId, parsed.npcId, { limit: parsed.memoryLimit } ); // Build context for LLM injection const context = { relationship: relationship ?? { characterId: parsed.characterId, npcId: parsed.npcId, familiarity: 'stranger', disposition: 'neutral', notes: null, firstMetAt: null, lastInteractionAt: null, interactionCount: 0 }, recentMemories: memories, // Generate LLM-ready summary contextSummary: buildContextSummary(relationship, memories) }; return { content: [{ type: 'text' as const, text: JSON.stringify(context, null, 2) }] }; } export async function handleInteractSocially(args: unknown, _ctx: SessionContext) { const parsed = NpcMemoryTools.INTERACT_SOCIALLY.inputSchema.parse(args); const db = getDb(process.env.NODE_ENV === 'test' ? ':memory:' : 'rpg.db'); const charRepo = new CharacterRepository(db); const spatialRepo = new SpatialRepository(db); const memoryRepo = new NpcMemoryRepository(db); // 1. Validate speaker exists const speaker = charRepo.findById(parsed.speakerId); if (!speaker) { throw new Error(`Speaker with ID ${parsed.speakerId} not found`); } // 2. Check speaker is in a room if (!speaker.currentRoomId) { throw new Error(`Speaker ${speaker.name} is not in any room`); } const room = spatialRepo.findById(speaker.currentRoomId); if (!room) { throw new Error(`Room ${speaker.currentRoomId} not found`); } // 3. Validate target if specified let target = null; if (parsed.targetId) { target = charRepo.findById(parsed.targetId); if (!target) { throw new Error(`Target with ID ${parsed.targetId} not found`); } } // 4. Calculate hearing radius based on volume and environment const hearingRadius = calculateHearingRadius({ volume: parsed.volume as VolumeLevel, biomeContext: room.biomeContext, atmospherics: room.atmospherics }); // 5. Get environment modifier for perception checks const envModifier = getEnvironmentModifier(room.atmospherics); // 6. Find all potential listeners in the same room (excluding speaker) const potentialListeners = room.entityIds .filter(id => id !== parsed.speakerId) .map(id => charRepo.findById(id)) .filter((char): char is NonNullable<typeof char> => char !== null); // 7. Track who hears what const hearingResults: Array<{ listenerId: string; listenerName: string; heardFully: boolean; opposedRoll?: { speakerRoll: number; speakerTotal: number; listenerRoll: number; listenerTotal: number; success: boolean; margin: number; }; }> = []; // 8. Target always hears full content (no roll needed) if (target && target.currentRoomId === room.id) { hearingResults.push({ listenerId: target.id, listenerName: target.name, heardFully: true }); // Record full conversation for target memoryRepo.recordMemory({ characterId: target.id, npcId: speaker.id, summary: `${speaker.name} said (${parsed.volume.toLowerCase()}): "${parsed.content}"${parsed.intent ? ` [Intent: ${parsed.intent}]` : ''}`, importance: parsed.volume === 'SHOUT' ? 'high' : 'medium', topics: parsed.intent ? [parsed.intent] : [] }); } // 9. For each other listener, roll Stealth vs Perception const eavesdroppers = potentialListeners.filter(listener => listener.id !== parsed.targetId && !isDeafened(listener) ); for (const listener of eavesdroppers) { // Perform opposed roll const roll = rollStealthVsPerception(speaker, listener, envModifier); if (roll.success) { // Listener overheard the conversation hearingResults.push({ listenerId: listener.id, listenerName: listener.name, heardFully: false, opposedRoll: { speakerRoll: roll.speakerRoll, speakerTotal: roll.speakerTotal, listenerRoll: roll.listenerRoll, listenerTotal: roll.listenerTotal, success: roll.success, margin: roll.margin } }); // Record eavesdropped conversation (partial content) memoryRepo.recordMemory({ characterId: listener.id, npcId: speaker.id, summary: `Overheard ${speaker.name} ${parsed.volume === 'WHISPER' ? 'whispering' : parsed.volume === 'SHOUT' ? 'shouting' : 'talking'}${target ? ` to ${target.name}` : ''} about something${parsed.intent ? ` (${parsed.intent})` : ''}`, importance: parsed.volume === 'SHOUT' ? 'medium' : 'low', topics: parsed.intent ? [parsed.intent, 'eavesdropped'] : ['eavesdropped'] }); } else { // Listener failed to overhear hearingResults.push({ listenerId: listener.id, listenerName: listener.name, heardFully: false, opposedRoll: { speakerRoll: roll.speakerRoll, speakerTotal: roll.speakerTotal, listenerRoll: roll.listenerRoll, listenerTotal: roll.listenerTotal, success: roll.success, margin: roll.margin } }); } } // 10. Return results return { content: [{ type: 'text' as const, text: JSON.stringify({ success: true, speaker: { id: speaker.id, name: speaker.name }, target: target ? { id: target.id, name: target.name, heard: true } : null, volume: parsed.volume, hearingRadius, room: { id: room.id, name: room.name, biome: room.biomeContext, atmospherics: room.atmospherics }, listeners: hearingResults, totalListeners: hearingResults.length, whoHeard: hearingResults.filter(r => r.heardFully || r.opposedRoll?.success).length, whoMissed: hearingResults.filter(r => !r.heardFully && !r.opposedRoll?.success).length }, null, 2) }] }; } /** * Build a human-readable context summary for LLM injection */ function buildContextSummary( relationship: { familiarity: string; disposition: string; notes: string | null; interactionCount: number } | null, memories: Array<{ summary: string; importance: string; topics: string[] }> ): string { const lines: string[] = []; if (relationship) { lines.push(`RELATIONSHIP: ${relationship.familiarity} (${relationship.disposition})`); lines.push(`Previous interactions: ${relationship.interactionCount}`); if (relationship.notes) { lines.push(`Notes: ${relationship.notes}`); } } else { lines.push(`RELATIONSHIP: First meeting (stranger, neutral)`); } if (memories.length > 0) { lines.push(''); lines.push('PREVIOUS CONVERSATIONS:'); for (const memory of memories) { const importance = memory.importance === 'critical' ? '!!!' : memory.importance === 'high' ? '!!' : memory.importance === 'medium' ? '!' : ''; lines.push(`${importance} ${memory.summary}`); if (memory.topics.length > 0) { lines.push(` Topics: ${memory.topics.join(', ')}`); } } } return lines.join('\n'); }