aingle_cortex 0.6.3

Córtex API - REST/GraphQL/SPARQL interface for AIngle semantic graphs
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
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

// Copyright 2019-2026 Apilium Technologies OÜ. All rights reserved.
// SPDX-License-Identifier: Apache-2.0 OR Commercial

//! REST API endpoints for Córtex
//!
//! ## Endpoints
//!
//! ### Triples
//! - `POST   /api/v1/triples` - Create triple
//! - `POST   /api/v1/triples/batch` - Batch insert triples (atomic)
//! - `GET    /api/v1/triples/:id` - Get triple by hash
//! - `DELETE /api/v1/triples/:id` - Delete triple
//! - `GET    /api/v1/triples` - List triples (with filters)
//!
//! ### Queries
//! - `POST   /api/v1/query` - Pattern matching query
//! - `GET    /api/v1/graph/stats` - Graph statistics
//!
//! ### Validation
//! - `POST   /api/v1/validate` - Validate triple(s)
//! - `GET    /api/v1/proof/:hash` - Get proof
//! - `POST   /api/v1/verify` - Verify proof
//!
//! ### Skill Verification (Phase 3)
//! - `POST   /api/v1/skills/validate` - Validate semantic skill manifest
//! - `POST   /api/v1/skills/sandbox` - Create temporary sandbox namespace
//! - `DELETE /api/v1/skills/sandbox/:id` - Clean up sandbox namespace
//!
//! ### Reputation (Phase 3)
//! - `GET    /api/v1/agents/:id/consistency` - Agent assertion consistency score
//! - `POST   /api/v1/assertions/verify-batch` - Batch verify assertion proofs

pub mod audit;
#[cfg(feature = "cluster")]
pub mod cluster;
#[cfg(feature = "cluster")]
pub(crate) mod cluster_utils;
#[cfg(feature = "cluster")]
pub mod raft_rpc;
#[cfg(feature = "dag")]
pub mod dag;
mod memory;
mod observability;
#[cfg(feature = "p2p")]
mod p2p;
mod proof;
mod proof_api;
mod query;
mod reputation;
mod skill_verification;
mod stats;
mod triples;

// Re-export from proof (legacy validation endpoints)
pub use proof::{
    ProofDto, ProofStepDto, StatementInput, ValidateRequest, ValidateResponse, ValidateTripleInput,
    ValidationMessage, VerificationDetails, VerifyProofRequest,
};

// Re-export from proof_api (ZK proof storage endpoints)
pub use proof_api::{
    BatchSubmitRequest, BatchSubmitResponse, BatchVerifyRequest, BatchVerifyResponse,
    DeleteProofResponse, ListProofsQuery, ListProofsResponse, ProofResponse, ProofStatsResponse,
    SubmitProofResponse,
};

// Re-export from other modules
pub use query::*;
pub use stats::*;
pub use triples::*;

use crate::state::AppState;
use axum::{
    routing::{delete, get, post},
    Router,
};

/// Create REST API router
pub fn router() -> Router<AppState> {
    let router = Router::new()
        // Triple CRUD
        .route("/api/v1/triples", post(triples::create_triple))
        .route("/api/v1/triples", get(triples::list_triples))
        .route(
            "/api/v1/triples/batch",
            post(triples::batch_insert_triples),
        )
        .route("/api/v1/triples/{id}", get(triples::get_triple))
        .route("/api/v1/triples/{id}", delete(triples::delete_triple))
        // Query endpoints
        .route("/api/v1/query", post(query::query_pattern))
        .route("/api/v1/query/subjects", get(query::list_subjects))
        .route("/api/v1/query/predicates", get(query::list_predicates))
        // Stats & Management
        .route("/api/v1/stats", get(stats::get_stats))
        .route("/api/v1/health", get(stats::health_check))
        .route("/api/v1/flush", post(stats::flush_data))
        // Validation/Proofs (legacy)
        .route("/api/v1/validate", post(proof::validate_triples))
        .route("/api/v1/proof/{hash}", get(proof::get_proof))
        .route("/api/v1/verify", post(proof::verify_proof))
        // ZK Proof API (new proof storage system)
        .route("/api/v1/proofs", post(proof_api::submit_proof))
        .route("/api/v1/proofs", get(proof_api::list_proofs))
        .route("/api/v1/proofs/batch", post(proof_api::submit_proofs_batch))
        .route("/api/v1/proofs/stats", get(proof_api::get_proof_stats))
        .route(
            "/api/v1/proofs/verify/batch",
            post(proof_api::verify_proofs_batch),
        )
        .route("/api/v1/proofs/{id}", get(proof_api::get_proof))
        .route("/api/v1/proofs/{id}", delete(proof_api::delete_proof))
        .route(
            "/api/v1/proofs/{id}/verify",
            get(proof_api::verify_proof_by_id),
        )
        // Ineru memory endpoints
        .merge(memory::memory_router())
        // Semantic Observability endpoints
        .merge(observability::observability_router())
        // Skill Verification endpoints (Phase 3)
        .merge(skill_verification::skill_verification_router())
        // Reputation endpoints (Phase 3)
        .merge(reputation::reputation_router())
        // Audit log endpoints (Phase 6.5)
        .merge(audit::audit_router());

    // P2P endpoints (feature-gated)
    #[cfg(feature = "p2p")]
    let router = router.merge(p2p::p2p_router());

    // Cluster endpoints (feature-gated)
    #[cfg(feature = "cluster")]
    let router = router
        .merge(cluster::cluster_router())
        .merge(raft_rpc::raft_rpc_router());

    // DAG endpoints (feature-gated)
    #[cfg(feature = "dag")]
    let router = router.merge(dag::dag_router());

    router
}