clawdb 0.1.0

The cognitive database for AI agents — unified memory, semantic retrieval, branching, sync, and governance.
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

//! Minimal TCP-based gRPC placeholder server.

use std::sync::Arc;

use tokio_util::sync::CancellationToken;

use crate::{config::ServerConfig, engine::ClawDB, error::ClawDBResult};

/// Serves a lightweight TCP listener for the configured gRPC port until shutdown.
pub async fn serve(
    _db: Arc<ClawDB>,
    config: &ServerConfig,
    shutdown: CancellationToken,
) -> ClawDBResult<()> {
    let listener = tokio::net::TcpListener::bind(("127.0.0.1", config.grpc_port)).await?;
    loop {
        tokio::select! {
            _ = shutdown.cancelled() => break,
            accept = listener.accept() => {
                let (mut stream, _) = accept?;
                tokio::spawn(async move {
                    use tokio::io::AsyncWriteExt;
                    let _ = stream.write_all(b"clawdb grpc placeholder\n").await;
                });
            }
        }
    }
    Ok(())
}