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
use async_trait::async_trait;
use crate::error::DomainError;
use crate::ports::MemoryRecollection;
use crate::value_objects::{
MemoryCapabilities, MemoryEntryId, MemoryMoment, MemoryQuestion, MemoryScope,
};
/// Reading what earlier sessions learned, and why.
///
/// Three ways of asking, because three different questions get asked:
/// what is known about this at all, what does memory say about one
/// thing in particular, and what was known at a moment. The third is
/// not the first two filtered by date — it excludes what was learned
/// later about earlier events, which is the whole point of asking it.
#[async_trait]
pub trait MemoryReaderPort: Send + Sync {
/// Everything memory holds about `scope`.
async fn recall(&self, scope: &MemoryScope) -> Result<MemoryRecollection, DomainError>;
/// What memory says in answer to a question put in words.
async fn ask(
&self,
scope: &MemoryScope,
question: &MemoryQuestion,
) -> Result<MemoryRecollection, DomainError>;
/// What was known about `scope` at `moment`.
async fn as_known_at(
&self,
scope: &MemoryScope,
moment: MemoryMoment,
) -> Result<MemoryRecollection, DomainError>;
/// The chain of reasons leading from `from` back to `to`.
///
/// The question the whole contract exists to answer, and the only
/// one whose failure means the memory has stopped being worth
/// keeping: everything else can be reconstructed by reading, and
/// this cannot.
///
/// It answers with the reasons and not with the prose — the edges
/// on the path, in the order they connect. What each end says is
/// what `recall` is for, and a backend that padded the chain with
/// text would make two contracts out of one.
///
/// An empty chain is a real answer: the two are not connected by
/// anything anyone wrote down.
async fn follow(
&self,
scope: &MemoryScope,
from: &MemoryEntryId,
to: &MemoryEntryId,
) -> Result<MemoryRecollection, DomainError>;
fn capabilities(&self) -> MemoryCapabilities;
}