Phase 29: NPC memory retrieval quality

.env.example

@@ -88,6 +88,10 @@ EMBED_BASE_URL=https://openrouter.ai/api/v1
 REFLECT_EVERY_N=5
 SUMMARIZE_THRESHOLD=100
 SUMMARIZE_BATCH_SIZE=50
+# Phase 29 — vector retrieval forgetting curve (Ebbinghaus; S = max(ε, S0 × importance/5))
+MEMORY_RECENCY_HALFLIFE_HOURS=72
+MEMORY_RECENCY_FLOOR=0.3
+MEMORY_RECENCY_S_EPSILON=0.001
 
 # Phase 11 — chunk lore LLM (T0/T1 tiering)
 LLM_PROVIDER_LORE=agnes

README.md

@@ -20,6 +20,7 @@ AI-driven multiplayer life-simulation web game: guide memory-bearing NPCs throug
 - [Testing](#testing)
 - [Documentation](#documentation)
 - [Contributing](#contributing)
+- [Asset Credits](#asset-credits)
 - [License](#license)
 
 ## About
@@ -230,6 +231,12 @@ Action schema: [packages/game-actions/README.md](./packages/game-actions/README.
 
 Issues and PRs welcome. Read [CONTRIBUTING.md](./CONTRIBUTING.md) first. Never commit `.env` or API keys.
 
+## Asset Credits
+
+| Asset | Author | Use |
+|-------|--------|-----|
+| [The Fantasy Tileset](https://ventilatore.itch.io/the-fantasy-tileset) | [Ventilatore](https://ventilatore.itch.io) | Beginning Fields home map (16×16 tiles, Tiled) |
+
 ## License
 
 [MIT](./LICENSE)

README.zh-CN.md

@@ -20,6 +20,7 @@ AI 驱动的多人联机生活模拟 Web 游戏：与拥有记忆的 NPC 用自
 - [测试](#测试)
 - [文档](#文档)
 - [贡献](#贡献)
+- [素材贡献](#素材贡献)
 - [License](#license)
 
 ## 项目简介
@@ -231,6 +232,12 @@ Action schema：[packages/game-actions/README.md](./packages/game-actions/README
 
 欢迎 Issue 与 PR。请先阅读 [CONTRIBUTING.md](./CONTRIBUTING.md)。请勿提交 `.env` 或 API 密钥。
 
+## 素材贡献
+
+| 素材 | 作者 | 用途 |
+|------|------|------|
+| [The Fantasy Tileset](https://ventilatore.itch.io/the-fantasy-tileset) | [Ventilatore](https://ventilatore.itch.io) | 始源区（Beginning Fields）家园地图（16×16 瓦片，Tiled） |
+
 ## License
 
 [MIT](./LICENSE)

apps/ai-gateway/app/guards/reply.py

@@ -5,11 +5,14 @@
 import re
 from typing import Any
 
-FALLBACK_REPLY = "我还不能确定能否那样做——让我先试着与房间互动。"
+FALLBACK_REPLY = "抱歉，我这边还做不到。"
 
 STATE_CHANGE_PATTERNS = [
-    re.compile(r"\b(opened|closed|moved|picked up|picked|walked|went to|entered|left)\b", re.I),
-    re.compile(r"(打开了|关闭了|移动到|走向|拿起了|捡起了|去把门打开|就去打开|把门打开|我现在就去)", re.I),
+    re.compile(r"\b(opened|closed|picked up|walked|went to|entered|moved to)\b", re.I),
+    re.compile(
+        r"(打开了|关闭了|移动到|走向了|走向门|拿起了|捡起了|去把门打开|就去打开|把门打开|我现在就去(?:把门|打开|拿|捡|走|过去))",
+        re.I,
+    ),
 ]
 
 STATE_CHANGING_TOOLS = frozenset({"move", "interact", "transfer", "wait"})

apps/ai-gateway/tests/test_check_reply.py

@@ -12,3 +12,12 @@ def test_allows_with_interact_tool():
 def test_allows_neutral():
     text = "需要我帮你做什么吗？"
     assert audit_reply(text, []) == text
+
+
+def test_allows_emotional_moved_without_tools():
+    reply = "I'm moved that you asked, but I won't say my age."
+    assert audit_reply(reply, []) == reply
+
+
+def test_fallback_is_chat_neutral():
+    assert "房间" not in FALLBACK_REPLY

apps/game-server/src/collective/service.test.ts

@@ -1,11 +1,37 @@
-import { describe, expect, it, beforeEach } from "vitest";
+import { describe, expect, it, beforeEach, afterEach, vi } from "vitest";
 import { CollectiveRepository } from "@aetherlife/npc-memory";
-import { KIND_FIXED_DELTA, personalitySeedForNpc } from "@aetherlife/shared";
+import {
+  KIND_FIXED_DELTA,
+  PROPAGATION_MAX_FANOUT,
+  personalitySeedForNpc,
+  type RelationshipEdgePublic,
+} from "@aetherlife/shared";
 import { CollectiveService } from "./service.js";
+import * as npcRelationships from "../world/npc-relationships-repository.js";
+
+function propEdge(
+  partial: Pick<RelationshipEdgePublic, "npcAId" | "npcBId" | "baseTag" | "affection">,
+): RelationshipEdgePublic {
+  return {
+    trust: 50,
+    interactionCount: 0,
+    lastInteractAt: null,
+    currentStatus: [],
+    historySummary: "",
+    updatedAt: new Date().toISOString(),
+    ...partial,
+  };
+}
 
 describe("CollectiveService", () => {
   beforeEach(() => {
     CollectiveService.resetForTests(new CollectiveRepository(null));
+    // Avoid real Postgres when DATABASE_URL is set (propagation list can hang / flake).
+    vi.spyOn(npcRelationships, "listRelationshipsForRoom").mockResolvedValue([]);
+  });
+
+  afterEach(() => {
+    vi.restoreAllMocks();
   });
 
   it("records event when two players in window", async () => {
@@ -86,4 +112,141 @@ describe("CollectiveService", () => {
     const rep = await repo.getAttitude("solo-worker", "npc-1", "p-a");
     expect(rep).toBe(personalitySeedForNpc("npc-1") + (-8));
   });
+
+  it("propagation applies friend reputation without extra collective events", async () => {
+    const listSpy = vi.spyOn(npcRelationships, "listRelationshipsForRoom").mockResolvedValue([
+      propEdge({
+        npcAId: "npc-1",
+        npcBId: "npc-friend",
+        baseTag: "ally",
+        affection: 50,
+      }),
+    ]);
+
+    const svc = CollectiveService.getInstance();
+    const repo = svc.repoRef();
+    const result = await svc.recordRuleEvent({
+      roomId: "prop-room",
+      npcId: "npc-1",
+      kind: "rude",
+      summary: "玩家粗鲁",
+      playerIds: ["p-a"],
+      npcPositions: new Map([["npc-1", { x: 0, y: 0 }]]),
+      singlePlayerOk: true,
+    });
+
+    expect(listSpy).toHaveBeenCalledWith(
+      "prop-room",
+      expect.objectContaining({
+        npcId: "npc-1",
+        limit: PROPAGATION_MAX_FANOUT * 5,
+      }),
+    );
+    expect(result).toEqual(expect.objectContaining({ recorded: true }));
+    const events = await repo.listEventsInWindow("prop-room", "npc-1", 300_000);
+    expect(events).toHaveLength(1);
+
+    const friendRep = await repo.getAttitude("prop-room", "npc-friend", "p-a");
+    expect(friendRep).toBe(personalitySeedForNpc("npc-friend") + Math.round(-8 * 0.3));
+  });
+
+  it("recordWorkerEvent propagation keeps event count === 1", async () => {
+    vi.spyOn(npcRelationships, "listRelationshipsForRoom").mockResolvedValue([
+      propEdge({
+        npcAId: "npc-1",
+        npcBId: "npc-friend",
+        baseTag: "ally",
+        affection: 50,
+      }),
+    ]);
+
+    const svc = CollectiveService.getInstance();
+    const repo = svc.repoRef();
+    await svc.recordWorkerEvent({
+      roomId: "prop-worker",
+      npcId: "npc-1",
+      kind: "rude",
+      summary: "worker rude",
+      playerIds: ["p-a"],
+      deltaScore: -8,
+      npcPositions: new Map([["npc-1", { x: 0, y: 0 }]]),
+    });
+
+    const events = await repo.listEventsInWindow("prop-worker", "npc-1", 300_000);
+    expect(events).toHaveLength(1);
+    const friendRep = await repo.getAttitude("prop-worker", "npc-friend", "p-a");
+    expect(friendRep).toBe(personalitySeedForNpc("npc-friend") - 2);
+  });
+
+  it("relationship list failure does not throw out of recordRuleEvent", async () => {
+    vi.spyOn(npcRelationships, "listRelationshipsForRoom").mockRejectedValueOnce(
+      new Error("db unavailable"),
+    );
+
+    const svc = CollectiveService.getInstance();
+    const repo = svc.repoRef();
+    const result = await svc.recordRuleEvent({
+      roomId: "prop-fail",
+      npcId: "npc-1",
+      kind: "help",
+      summary: "help",
+      playerIds: ["p-a", "p-b"],
+      npcPositions: new Map([["npc-1", { x: 0, y: 0 }]]),
+    });
+
+    expect(result).toEqual(expect.objectContaining({ recorded: true }));
+    const rep = await repo.getAttitude("prop-fail", "npc-1", "p-a");
+    expect(rep).toBe(personalitySeedForNpc("npc-1") + KIND_FIXED_DELTA.help);
+  });
+
+  it("getCollectiveContext carries semantic from attitude row (D-BELIEF-05)", async () => {
+    const svc = CollectiveService.getInstance();
+    const repo = svc.repoRef();
+    await repo.upsertSemanticState("r-sem-ctx", "npc-1", "p-a", {
+      mood: "恼火",
+      beliefs: ["我不信他的承诺"],
+      summary: "玩家曾失信",
+    });
+
+    const ctx = await svc.getCollectiveContext("r-sem-ctx", "npc-1", "p-a");
+    expect(ctx.currentMood).toBe("恼火");
+    expect(ctx.keyBeliefs).toEqual(["我不信他的承诺"]);
+    expect(ctx.summary).toBe("玩家曾失信");
+    expect(ctx.band).toBeTruthy();
+    expect(ctx.allowedTools.length).toBeGreaterThan(0);
+    expect(typeof ctx.playerReputation).toBe("number");
+  });
+
+  it("getCollectiveContext omits semantic when no attitude row", async () => {
+    const svc = CollectiveService.getInstance();
+    const ctx = await svc.getCollectiveContext("r-no-att", "npc-1", "p-missing");
+    expect(ctx.currentMood).toBeNull();
+    expect(ctx.keyBeliefs).toBeNull();
+    expect(ctx.summary).toBeNull();
+    expect(ctx.playerReputation).toBe(personalitySeedForNpc("npc-1"));
+  });
+
+  it("getCollectiveState public payload strips mood/beliefs/summary (D-BELIEF-11)", async () => {
+    const svc = CollectiveService.getInstance();
+    const repo = svc.repoRef();
+    await repo.upsertSemanticState("default", "npc-1", "p-pub", {
+      mood: "戏谑",
+      beliefs: ["他爱开玩笑"],
+      summary: "内部摘要勿泄露",
+    });
+
+    const ctx = await svc.getCollectiveContext("default", "npc-1", "p-pub");
+    expect(ctx.currentMood).toBe("戏谑");
+
+    const publicPayload = await svc.getCollectiveState("default", "p-pub", "npc-1");
+    const row = publicPayload.attitudes.find((a) => a.npcId === "npc-1");
+    expect(row).toBeDefined();
+    expect(row).not.toHaveProperty("currentMood");
+    expect(row).not.toHaveProperty("keyBeliefs");
+    expect(row).not.toHaveProperty("summary");
+    expect(row).not.toHaveProperty("mood");
+    expect(row).not.toHaveProperty("beliefs");
+    expect(JSON.stringify(publicPayload)).not.toContain("戏谑");
+    expect(JSON.stringify(publicPayload)).not.toContain("内部摘要勿泄露");
+  });
 });