cortex-memory 0.3.1

Self-organizing graph memory for AI agents. Single binary, zero dependencies.
Documentation 
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

use async_trait::async_trait;
use cortex_core::ingest::{IngestAdapter, IngestEvent};
use cortex_core::Result;
use futures::stream::{self, BoxStream, StreamExt};

pub struct StdinAdapter;

#[async_trait]
impl IngestAdapter for StdinAdapter {
    fn name(&self) -> &str {
        "stdin"
    }

    async fn subscribe(&self) -> Result<BoxStream<'static, IngestEvent>> {
        use tokio::io::{AsyncBufReadExt, BufReader};

        let stdin = tokio::io::stdin();
        let reader = BufReader::new(stdin);
        let lines = reader.lines();

        let s = stream::unfold(lines, |mut lines| async move {
            match lines.next_line().await {
                Ok(Some(line)) => {
                    let event = serde_json::from_str::<IngestEvent>(&line).ok();
                    Some((event, lines))
                }
                _ => None,
            }
        })
        .filter_map(|opt| async move { opt });

        Ok(Box::pin(s))
    }
}