chore: update verisim-normalizer lib.rs + storage_regenerator

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: hyperpolymath

verisimdb/rust-core/verisim-normalizer/src/lib.rs

@@ -20,6 +20,7 @@
 #![forbid(unsafe_code)]
 pub mod conflict;
 pub mod regeneration;
+pub mod storage_regenerator;
 
 use async_trait::async_trait;
 use chrono::{DateTime, Utc};
@@ -46,6 +47,15 @@ pub enum NormalizerError {
 
     #[error("Channel error: {0}")]
     ChannelError(String),
+
+    #[error("Missing modality: {0}")]
+    MissingModality(String),
+
+    #[error("Storage error: {0}")]
+    StorageError(String),
+
+    #[error("No viable source: {0}")]
+    NoViableSource(String),
 }
 
 /// Result of a normalization operation

verisimdb/rust-core/verisim-normalizer/src/storage_regenerator.rs

@@ -301,8 +301,11 @@ impl ModalityRegenerator for StorageRegenerator {
                     graph.edges.len()
                 );
                 let input = OctadInput {
-                    title: Some("[regenerated from graph]".to_string()),
-                    body: Some(body.clone()),
+                    document: Some(OctadDocumentInput {
+                        title: "[regenerated from graph]".to_string(),
+                        body: body.clone(),
+                        fields: HashMap::new(),
+                    }),
                     ..Default::default()
                 };
                 self.write_back(octad, input).await?;
@@ -319,7 +322,10 @@ impl ModalityRegenerator for StorageRegenerator {
                     .ok_or_else(|| NormalizerError::MissingModality("Graph".into()))?;
                 let types = graph.types.clone();
                 let input = OctadInput {
-                    types: Some(types.clone()),
+                    semantic: Some(OctadSemanticInput {
+                        types: types.clone(),
+                        properties: HashMap::new(),
+                    }),
                     ..Default::default()
                 };
                 self.write_back(octad, input).await?;
@@ -412,7 +418,10 @@ impl ModalityRegenerator for StorageRegenerator {
                 }
 
                 let input = OctadInput {
-                    embedding: Some(merged),
+                    vector: Some(OctadVectorInput {
+                        embedding: merged,
+                        model: Some("fnv1a-trigram-384-merged".to_string()),
+                    }),
                     ..Default::default()
                 };
                 self.write_back(octad, input).await?;
@@ -453,7 +462,10 @@ impl ModalityRegenerator for StorageRegenerator {
                 all_types.dedup();
 
                 let input = OctadInput {
-                    types: Some(all_types.clone()),
+                    semantic: Some(OctadSemanticInput {
+                        types: all_types.clone(),
+                        properties: HashMap::new(),
+                    }),
                     ..Default::default()
                 };
                 self.write_back(octad, input).await?;