Merge pull request #83 from ApiliumCode/dev

release: AIngle v0.6.3 — total data integrity hardening

Author: ApiliumDevTeam

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "aingle_ai"
-version = "0.6.2"
+version = "0.6.3"
 description = "AI integration layer for AIngle - Ineru, Nested Learning, Kaneru"
 license = "Apache-2.0 OR LicenseRef-Commercial"
 repository = "https://github.com/ApiliumCode/aingle"

crates/aingle_ai/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "aingle_contracts"
-version = "0.6.2"
+version = "0.6.3"
 description = "Smart Contracts DSL and WASM Runtime for AIngle"
 license = "Apache-2.0 OR LicenseRef-Commercial"
 repository = "https://github.com/ApiliumCode/aingle"

crates/aingle_contracts/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "aingle_cortex"
-version = "0.6.2"
+version = "0.6.3"
 description = "Córtex API - REST/GraphQL/SPARQL interface for AIngle semantic graphs"
 license = "Apache-2.0 OR LicenseRef-Commercial"
 repository = "https://github.com/ApiliumCode/aingle"
@@ -102,6 +102,7 @@ openraft = { version = "0.10.0-alpha.17", features = ["serde", "type-alias"], op
 tokio-rustls = { version = "0.26", default-features = false, features = ["ring"], optional = true }
 rustls-pemfile = { version = "2", optional = true }
 
+sled = "0.34"
 dirs = "6"
 mdns-sd = { version = "0.18", optional = true }
 if-addrs = { version = "0.13", optional = true }

crates/aingle_cortex/Cargo.toml

@@ -12,6 +12,23 @@ use crate::error::Error;
 #[cfg(feature = "cluster")]
 use crate::server::CortexServer;
 
+#[cfg(feature = "cluster")]
+use aingle_raft::state_machine::{ProofSnapshot, ProofSnapshotProvider};
+
+#[cfg(feature = "cluster")]
+use crate::proofs::ProofStore;
+
+#[cfg(feature = "cluster")]
+impl ProofSnapshotProvider for ProofStore {
+    fn export_proofs(&self) -> Vec<ProofSnapshot> {
+        self.export_proofs_sync()
+    }
+
+    fn import_proofs(&self, proofs: &[ProofSnapshot]) {
+        self.import_proofs_sync(proofs);
+    }
+}
+
 /// Configuration for cluster mode.
 #[cfg(feature = "cluster")]
 #[derive(Debug, Clone)]
@@ -362,12 +379,14 @@ pub async fn init_cluster(
     server.state_mut().wal = Some(log_store.wal().clone());
     server.state_mut().cluster_secret = config.secret.clone();
 
-    let state_machine = std::sync::Arc::new(
-        aingle_raft::state_machine::CortexStateMachine::new(
+    let state_machine = {
+        let mut sm = aingle_raft::state_machine::CortexStateMachine::new(
             server.state().graph.clone(),
             server.state().memory.clone(),
-        ),
-    );
+        );
+        sm.set_proof_provider(server.state().proof_store.clone());
+        std::sync::Arc::new(sm)
+    };
 
     let resolver = std::sync::Arc::new(aingle_raft::network::NodeResolver::new());
     let node_id = config.node_id;

crates/aingle_cortex/src/cluster_init.rs

@@ -153,7 +153,7 @@ pub struct MutationRoot;
 
 #[Object]
 impl MutationRoot {
-    /// Create a new triple
+    /// Create a new triple (routed through the same path as REST for DAG/Raft consistency)
     async fn create_triple(&self, ctx: &Context<'_>, input: TripleInput) -> Result<Triple> {
         let state = ctx.data::<AppState>()?;
 
@@ -165,9 +165,45 @@ impl MutationRoot {
             object,
         );
 
+        // Insert triple + record DAG action (same path as REST API)
         {
             let graph = state.graph.read().await;
             graph.insert(triple.clone())?;
+
+            #[cfg(feature = "dag")]
+            if let Some(dag_store) = graph.dag_store() {
+                let dag_author = state
+                    .dag_author
+                    .clone()
+                    .unwrap_or_else(|| aingle_graph::NodeId::named("node:local"));
+                let dag_seq = state
+                    .dag_seq_counter
+                    .fetch_add(1, std::sync::atomic::Ordering::SeqCst);
+                let parents = dag_store.tips().unwrap_or_default();
+
+                let mut action = aingle_graph::dag::DagAction {
+                    parents,
+                    author: dag_author,
+                    seq: dag_seq,
+                    timestamp: chrono::Utc::now(),
+                    payload: aingle_graph::dag::DagPayload::TripleInsert {
+                        triples: vec![aingle_graph::dag::TripleInsertPayload {
+                            subject: input.subject.clone(),
+                            predicate: input.predicate.clone(),
+                            object: serde_json::json!({}),
+                        }],
+                    },
+                    signature: None,
+                };
+
+                if let Some(ref key) = state.dag_signing_key {
+                    key.sign(&mut action);
+                }
+
+                dag_store.put(&action).map_err(|e| {
+                    Error::new(format!("DAG action failed: {e}"))
+                })?;
+            }
         }
 
         // Broadcast event
@@ -183,7 +219,7 @@ impl MutationRoot {
         Ok(triple.into())
     }
 
-    /// Delete a triple by ID
+    /// Delete a triple by ID (routed through the same path as REST for DAG/Raft consistency)
     async fn delete_triple(&self, ctx: &Context<'_>, id: ID) -> Result<bool> {
         let state = ctx.data::<AppState>()?;
 
@@ -192,7 +228,43 @@ impl MutationRoot {
 
         let deleted = {
             let graph = state.graph.read().await;
-            graph.delete(&triple_id)?
+            let result = graph.delete(&triple_id)?;
+
+            #[cfg(feature = "dag")]
+            if result {
+                if let Some(dag_store) = graph.dag_store() {
+                    let dag_author = state
+                        .dag_author
+                        .clone()
+                        .unwrap_or_else(|| aingle_graph::NodeId::named("node:local"));
+                    let dag_seq = state
+                        .dag_seq_counter
+                        .fetch_add(1, std::sync::atomic::Ordering::SeqCst);
+                    let parents = dag_store.tips().unwrap_or_default();
+
+                    let mut action = aingle_graph::dag::DagAction {
+                        parents,
+                        author: dag_author,
+                        seq: dag_seq,
+                        timestamp: chrono::Utc::now(),
+                        payload: aingle_graph::dag::DagPayload::TripleDelete {
+                            triple_ids: vec![*triple_id.as_bytes()],
+                            subjects: vec![],
+                        },
+                        signature: None,
+                    };
+
+                    if let Some(ref key) = state.dag_signing_key {
+                        key.sign(&mut action);
+                    }
+
+                    dag_store.put(&action).map_err(|e| {
+                        Error::new(format!("DAG action failed: {e}"))
+                    })?;
+                }
+            }
+
+            result
         };
 
         if deleted {