File size: 10,220 Bytes
0d7db8e
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
f487b74
 
 
 
 
 
 
 
 
 
 
0d7db8e
32a601f
 
0d7db8e
32a601f
f487b74
32a601f
 
 
f487b74
 
 
0d7db8e
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
32a601f
 
 
0d7db8e
32a601f
0d7db8e
 
32a601f
 
 
 
 
 
0d7db8e
 
 
 
 
32a601f
 
 
 
 
 
 
 
 
 
0d7db8e
 
 
 
 
 
 
 
 
 
f487b74
 
 
 
 
 
 
0d7db8e
 
f487b74
 
 
0d7db8e
 
 
 
 
 
 
 
f487b74
0d7db8e
f487b74
 
0d7db8e
 
f487b74
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
0d7db8e
 
 
 
 
 
f487b74
 
 
 
 
0d7db8e
 
 
f487b74
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
0d7db8e
 
f487b74
 
 
 
 
 
0d7db8e
 
 
 
 
 
 
 
 
f487b74
 
 
 
 
 
 
 
 
0d7db8e
 
 
 
 
f487b74
0d7db8e
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
"""Agent memory β€” episodic recall, salience scoring, and reflection.

Memory architecture (three layers):

  1. EpisodicMemory β€” filtered view over the ledger; agents see only events
     they witnessed.  This is the simplest and always-on layer.

  2. SalienceMemory β€” ranks visible events by a composite score:
       salience(e) = w_relΒ·relevance(e,query) + w_recΒ·recency(e,turn) + w_impΒ·importance(e.kind)
     and returns the top-K rather than the most-recent K.  This layer is
     optional (manifest.memory.use_salience=True) and adds ~0 latency.

  3. ReflectionMemory β€” wraps either layer and emits an agent.reflected
     event every threshold events, compacting episodic memories into
     a high-level belief.  Reflection events are themselves visible to
     the agent, so beliefs accumulate over time without blowing the window.

None of these layers maintain a separate *source of truth* β€” they are functions
over the shared append-only ledger.  Memory is always consistent with the ledger
because it *is* the ledger.

The one optional accelerator is a semantic relevance index
(:class:`~src.core.memory_index.MemoryIndex`, attached via ``SalienceMemory.index``
and gated by ``MEMORY_INDEX`` β€” see ADR-0018).  It is a *derived, rebuildable*
view: populated FROM ledger events, keyed by ``event.id`` (idempotent re-index),
and used only to score the relevance term over events the visibility filter
already admits.  Wipe it and it rebuilds from the ledger; with it unattached
(the offline default) relevance is keyword overlap, exactly as below.
"""
from __future__ import annotations

import math
from dataclasses import dataclass, field
from typing import TYPE_CHECKING

from src.core.events import Event

if TYPE_CHECKING:  # pragma: no cover - typing only
    from src.core.memory_index import MemoryIndex

# ── importance weights by event kind ─────────────────────────────────────────

_KIND_IMPORTANCE: dict[str, float] = {
    "run.started": 0.3,
    "world.observed": 0.7,
    "agent.spoke": 0.5,
    "agent.thought": 0.4,
    "agent.reflected": 0.85,  # reflections are high-value compact memories
    "judge.verdict": 0.9,
    "user.injected": 0.95,    # visitor events are always salient
    "hypothesis.proposed": 0.75,
    "clue.found": 0.8,
    "verdict.final": 1.0,
}

_GLOBALLY_VISIBLE: frozenset[str] = frozenset(
    {"world.observed", "judge.verdict", "user.injected", "run.started", "agent.reflected"}
)

# ── layer 1: episodic memory ─────────────────────────────────────────────────

@dataclass
class EpisodicMemory:
    """Per-agent filtered view over the ledger β€” the always-on memory layer.

    An agent sees its own events plus globally-visible event kinds.
    The window is capped at max_recent to stay within small-model context budgets.
    """

    agent_name: str
    max_recent: int = 8

    def visible(self, events: tuple[Event, ...]) -> list[Event]:
        result = [
            e for e in events
            if e.actor == self.agent_name or e.kind in _GLOBALLY_VISIBLE
        ]
        return result[-self.max_recent:]

    def format_for_prompt(self, events: tuple[Event, ...]) -> str:
        recalled = self.visible(events)
        if not recalled:
            return "(no prior memory)"
        lines = []
        for e in recalled:
            text = e.payload.get("text") or e.payload.get("summary") or str(e.payload)
            lines.append(f"[turn {e.turn:03d}][{e.kind}] {text}")
        return "\n".join(lines)


# ── layer 2: salience-scored memory ──────────────────────────────────────────

@dataclass
class SalienceMemory:
    """Ranks visible events by salience instead of pure recency.

    salience(e) = w_relΒ·relevance + w_recΒ·recency + w_impΒ·importance

    relevance:  semantic similarity between the event and the current scene when
                a :class:`~src.core.memory_index.MemoryIndex` is attached
                (``index`` set), else keyword (Jaccard) overlap between the event
                text and the scene.  The index is a *derived* lens over the same
                ledger events β€” it changes only how the relevance term is scored,
                never which events are eligible (see ``visible``) nor the recency
                or importance terms.
    recency:    exponential decay β€” exp(βˆ’Ξ»Β·Ξ”turn).  Ξ»=0.1 gives half-life β‰ˆ7 turns.
    importance: event-kind weight from _KIND_IMPORTANCE table.

    Attach an index via ``index=...`` to use semantic relevance; with ``index``
    left ``None`` (the default) the scoring is exactly the offline keyword path.
    """

    agent_name: str
    top_k: int = 8
    w_relevance: float = 0.3
    w_recency: float = 0.4
    w_importance: float = 0.3
    decay_lambda: float = 0.1
    index: "MemoryIndex | None" = None

    def _keyword_relevance(self, event: Event, query: str) -> float:
        event_words = set(str(event.payload.get("text", "")).lower().split())
        query_words = set(query.lower().split())
        if not query_words or not event_words:
            return 0.0
        return len(query_words & event_words) / len(query_words | event_words)

    def score(
        self,
        event: Event,
        current_turn: int,
        query: str,
        relevance: float | None = None,
    ) -> float:
        """Composite salience.  *relevance* may be supplied (e.g. a semantic rank);
        when ``None`` it is computed from keyword overlap as before."""
        recency = math.exp(-self.decay_lambda * max(0, current_turn - event.turn))
        importance = _KIND_IMPORTANCE.get(event.kind, 0.5)
        if relevance is None:
            relevance = self._keyword_relevance(event, query)
        return (
            self.w_relevance * relevance
            + self.w_recency * recency
            + self.w_importance * importance
        )

    def _candidates(self, events: tuple[Event, ...]) -> list[Event]:
        """Ledger-derived visibility filter β€” unchanged whether or not an index
        is attached: an agent only ever recalls its own events plus globally
        visible kinds."""
        return [
            e for e in events
            if e.actor == self.agent_name or e.kind in _GLOBALLY_VISIBLE
        ]

    def _relevance_map(
        self, candidates: list[Event], query: str
    ) -> dict[str, float] | None:
        """When an index is attached, derive a semantic relevance score per
        candidate event (id β†’ score in [0,1] by descending rank); else ``None``
        so :meth:`score` uses keyword overlap.

        The index is populated from the candidate events first, then queried β€”
        derive, then read β€” so it never reports events the ledger has not
        produced, and re-indexing is idempotent (keyed by ``event.id``).
        """
        if self.index is None or not query or not candidates:
            return None
        self.index.index(tuple(candidates))
        hits = self.index.search(query, k=len(candidates))
        eligible = {e.id for e in candidates}
        ranked = [h.id for h in hits if h.id in eligible]
        if not ranked:
            return {}
        n = len(ranked)
        return {eid: (n - i) / n for i, eid in enumerate(ranked)}

    def visible(self, events: tuple[Event, ...], current_turn: int, query: str) -> list[Event]:
        candidates = self._candidates(events)
        relevance = self._relevance_map(candidates, query)
        scored = sorted(
            candidates,
            key=lambda e: self.score(
                e,
                current_turn,
                query,
                relevance=None if relevance is None else relevance.get(e.id, 0.0),
            ),
            reverse=True,
        )
        # Return in chronological order so prompts read naturally
        top = scored[: self.top_k]
        return sorted(top, key=lambda e: e.turn)

    def format_for_prompt(
        self, events: tuple[Event, ...], current_turn: int, query: str
    ) -> str:
        candidates = self._candidates(events)
        relevance = self._relevance_map(candidates, query)

        def _score(e: Event) -> float:
            rel = None if relevance is None else relevance.get(e.id, 0.0)
            return self.score(e, current_turn, query, relevance=rel)

        top = sorted(candidates, key=_score, reverse=True)[: self.top_k]
        recalled = sorted(top, key=lambda e: e.turn)
        if not recalled:
            return "(no salient memories)"
        lines = []
        for e in recalled:
            text = e.payload.get("text") or e.payload.get("summary") or str(e.payload)
            lines.append(f"[turn {e.turn:03d}][{e.kind}][sal={_score(e):.2f}] {text}")
        return "\n".join(lines)


# ── layer 3: reflection trigger ───────────────────────────────────────────────

@dataclass
class ReflectionTracker:
    """Tracks whether this agent is due to emit a reflection event.

    Reflection events compact recent episodic memories into a high-level
    belief ("the baker resents me") that is cheaper to carry than raw history
    and richer.  The belief becomes an agent.reflected event in the ledger β€”
    which EpisodicMemory picks up in future turns because it is globally visible.
    """

    agent_name: str
    threshold: int  # emit reflection every N visible events
    _seen_count: int = field(default=0, init=False, repr=False)

    def observe(self, events: tuple[Event, ...]) -> bool:
        """Return True when a reflection should be emitted this turn."""
        visible_count = sum(
            1 for e in events
            if e.actor == self.agent_name or e.kind in _GLOBALLY_VISIBLE
        )
        due = (
            visible_count > 0
            and visible_count != self._seen_count
            and visible_count % self.threshold == 0
        )
        self._seen_count = visible_count
        return due