grpc_verify/
grpc_verify.rs

1use synapse_core::server::proto::semantic_engine_client::SemanticEngineClient;
2use synapse_core::server::proto::{
3    IngestRequest, Triple, Provenance, HybridSearchRequest, SearchMode, ReasoningRequest, ReasoningStrategy
4};
5use tonic::transport::Channel;
6
7#[tokio::main]
8async fn main() -> Result<(), Box<dyn std::error::Error>> {
9    println!("Connecting to Synapse gRPC server...");
10    let mut client = SemanticEngineClient::connect("http://[::1]:50051").await?;
11
12    println!("✅ Connected!");
13
14    // 1. Ingest Data
15    let triple = Triple {
16        subject: "http://example.org/Socrates".to_string(),
17        predicate: "http://www.w3.org/1999/02/22-rdf-syntax-ns#type".to_string(),
18        object: "http://example.org/Human".to_string(),
19        provenance: Some(Provenance {
20            source: "client_test".to_string(),
21            timestamp: "now".to_string(),
22            method: "grpc".to_string(),
23        }),
24        embedding: vec![],
25    };
26    
27    let triple2 = Triple {
28        subject: "http://example.org/Human".to_string(),
29        predicate: "http://www.w3.org/2000/01/rdf-schema#subClassOf".to_string(),
30        object: "http://example.org/Mortal".to_string(),
31        provenance: Some(Provenance {
32            source: "client_test".to_string(),
33            timestamp: "now".to_string(),
34            method: "grpc".to_string(),
35        }),
36        embedding: vec![],
37    };
38
39    println!("Sending IngestRequest...");
40    let response = client.ingest_triples(IngestRequest {
41        triples: vec![triple, triple2],
42        namespace: "test_verification".to_string(),
43    }).await?;
44    println!("Response: {:?}", response.into_inner());
45
46    // 2. Apply Reasoning (RDFS Transitivity)
47    println!("\nApplying RDFS Reasoning (Internal)...");
48    let reasoning_response = client.apply_reasoning(ReasoningRequest {
49        namespace: "test_verification".to_string(),
50        strategy: ReasoningStrategy::Rdfs as i32,
51        materialize: false,
52    }).await?;
53    println!("Reasoning Result: {:?}", reasoning_response.into_inner());
54
55    // 3. Hybrid Search
56    println!("\nPerforming Hybrid Search for 'Socrates'...");
57    let search_response = client.hybrid_search(HybridSearchRequest {
58        query: "Socrates".to_string(),
59        namespace: "test_verification".to_string(),
60        vector_k: 5,
61        graph_depth: 1,
62        mode: SearchMode::Hybrid as i32,
63        limit: 10,
64    }).await?;
65    
66    println!("Search Results:");
67    for result in search_response.into_inner().results {
68        println!(" - [Score: {:.4}] {} ({})", result.score, result.content, result.uri);
69    }
70
71    Ok(())
72}
grpc_verify/grpc_verify.rs

grpc_verify/
grpc_verify.rs
