etherfunlab
diff --git a/‎.env.example‎
Lines changed: 7 additions & 0 deletions b/‎.env.example‎
Lines changed: 7 additions & 0 deletions
diff --git a/‎Cargo.lock‎
Lines changed: 135 additions & 0 deletions b/‎Cargo.lock‎
Lines changed: 135 additions & 0 deletions
diff --git a/‎crates/eros-engine-core/src/pde.rs‎
Lines changed: 1 addition & 0 deletions b/‎crates/eros-engine-core/src/pde.rs‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎crates/eros-engine-core/src/types.rs‎
Lines changed: 71 additions & 2 deletions b/‎crates/eros-engine-core/src/types.rs‎
Lines changed: 71 additions & 2 deletions
diff --git a/‎crates/eros-engine-llm/Cargo.toml‎
Lines changed: 4 additions & 0 deletions b/‎crates/eros-engine-llm/Cargo.toml‎
Lines changed: 4 additions & 0 deletions
@@ -7,6 +7,13 @@ DATABASE_URL=postgres://postgres:<password>@<host>:5432/postgres
 # OpenRouter (chat completions). Same key works for both apps.
 OPENROUTER_API_KEY=sk-or-...
 
+# OpenRouter app attribution (optional). When set, the engine adds
+# these headers to every outbound OpenRouter call so the deployment
+# shows up on OpenRouter's app analytics dashboard. Leave unset to
+# remain anonymous.
+# OPENROUTER_APP_REFERER=https://eros.example
+# OPENROUTER_APP_TITLE=Eros
+
 # Supabase project — same as eros-gateway.
 # Setting SUPABASE_URL is enough on modern projects: the engine derives the
 # JWKS URL (${SUPABASE_URL}/auth/v1/.well-known/jwks.json) and validates
 
@@ -207,6 +207,7 @@ mod tests {
             content: content.into(),
             message_id: Uuid::new_v4(),
             prompt_traits: Vec::new(),
+            audit: None,
         }
     }
 
 
@@ -17,6 +17,21 @@ pub struct PromptTrait {
     pub text: String,
 }
 
+/// Caller-supplied OpenRouter passthrough for per-request audit /
+/// analytics. Engine never inspects these fields; they ride straight to
+/// `openrouter.ai/api/v1/chat/completions` as wire-level `user`,
+/// `session_id`, `metadata`. The HTTP layer applies size/shape caps;
+/// content remains opaque to the engine.
+#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq, Default)]
+pub struct LlmAudit {
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub user: Option<String>,
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub session_id: Option<String>,
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
+}
+
 /// Events that drive the engine pipeline.
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub enum Event {
@@ -28,6 +43,12 @@ pub enum Event {
         /// byte-for-byte.
         #[serde(default)]
         prompt_traits: Vec<PromptTrait>,
+        /// Optional caller-supplied OpenRouter audit passthrough.
+        /// `None` for clients that don't send the field. Engine carries it
+        /// opaquely from request → handler → ChatRequest; content is never
+        /// inspected.
+        #[serde(default)]
+        audit: Option<LlmAudit>,
     },
     Gift {
         gift_id: Uuid,
@@ -75,10 +96,16 @@ pub struct ConversationSignals {
     pub hours_since_last_ghost: Option<f64>,
 }
 
-/// Response from the chat engine — pure text reply.
-#[derive(Debug, Clone)]
+/// Response from the chat engine — text reply plus opaque OpenRouter
+/// wire echoes (`generation_id`, `model`, `usage`). The three echo
+/// fields are `None` when no LLM call was made (handler returned None)
+/// or when upstream omitted them.
+#[derive(Debug, Clone, Default)]
 pub struct ChatResponse {
     pub reply: String,
+    pub generation_id: Option<String>,
+    pub model: Option<String>,
+    pub usage: Option<serde_json::Value>,
 }
 
 /// Input bundle consumed by the PDE.
@@ -116,4 +143,46 @@ mod tests {
         let back: PromptTrait = serde_json::from_str(&json).unwrap();
         assert_eq!(back, t);
     }
+
+    #[test]
+    fn llm_audit_serde_roundtrip_full() {
+        let mut metadata = serde_json::Map::new();
+        metadata.insert("plan".into(), serde_json::Value::String("pro".into()));
+        let a = LlmAudit {
+            user: Some("u_abc".into()),
+            session_id: Some("conv_xyz".into()),
+            metadata: Some(metadata),
+        };
+        let json = serde_json::to_string(&a).unwrap();
+        let back: LlmAudit = serde_json::from_str(&json).unwrap();
+        assert_eq!(back, a);
+    }
+
+    #[test]
+    fn llm_audit_serde_roundtrip_empty_yields_all_none() {
+        let a: LlmAudit = serde_json::from_str("{}").unwrap();
+        assert!(a.user.is_none());
+        assert!(a.session_id.is_none());
+        assert!(a.metadata.is_none());
+    }
+
+    #[test]
+    fn event_user_message_defaults_audit_to_none() {
+        let raw = r#"{"UserMessage":{"content":"hi","message_id":"00000000-0000-0000-0000-000000000001"}}"#;
+        let ev: Event = serde_json::from_str(raw).expect("legacy body deserialises");
+        match ev {
+            Event::UserMessage { audit, .. } => {
+                assert!(audit.is_none(), "missing audit field must default to None");
+            }
+            _ => panic!("expected UserMessage"),
+        }
+    }
+
+    #[test]
+    fn chat_response_defaults_audit_fields_to_none() {
+        let r = ChatResponse { reply: "hi".into(), ..Default::default() };
+        assert!(r.usage.is_none());
+        assert!(r.generation_id.is_none());
+        assert!(r.model.is_none());
+    }
 }
@@ -21,3 +21,7 @@ thiserror = { workspace = true }
 tracing = { workspace = true }
 tokio = { workspace = true }
 toml = "0.8"
+
+[dev-dependencies]
+wiremock = "0.6"
+tokio = { workspace = true, features = ["macros", "rt-multi-thread"] }
Original file line number	Diff line number	Diff line change
`@@ -207,6 +207,7 @@ mod tests {`
`207`	`207`	`content: content.into(),`
`208`	`208`	`message_id: Uuid::new_v4(),`
`209`	`209`	`prompt_traits: Vec::new(),`
	`210`	`+ audit: None,`
`210`	`211`	`}`
`211`	`212`	`}`
`212`	`213`