From 315b14fe608429bee9da0fe2b913f735a17c4e15 Mon Sep 17 00:00:00 2001
From: Fabro <noreply@fabro.sh>
Date: Wed, 8 Jul 2026 21:50:52 +0000
Subject: [PATCH] fabro(01KX1P0VV0DAQTT0N2NADX8J8J): simplify_gpt (succeeded)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Fabro-Run: 01KX1P0VV0DAQTT0N2NADX8J8J
Fabro-Completed: 7

⚒️ Generated with [Fabro](https://fabro.sh)
---
 .../fabro-workflow/src/event/redaction.rs     | 19 ++++++++++---------
 .../fabro-workflow/src/runtime_store.rs       |  2 +-
 2 files changed, 11 insertions(+), 10 deletions(-)

diff --git a/lib/crates/fabro-workflow/src/event/redaction.rs b/lib/crates/fabro-workflow/src/event/redaction.rs
index 5e5cc97e4..fde417297 100644
--- a/lib/crates/fabro-workflow/src/event/redaction.rs
+++ b/lib/crates/fabro-workflow/src/event/redaction.rs
@@ -20,16 +20,16 @@ pub fn build_redacted_event_payload(
 /// event is reparsed from that same value, so every downstream consumer
 /// observes identical redacted data without re-running the redaction passes.
 pub struct RedactedRunEvent {
-    event: RunEvent,
-    value: Value,
+    event:   RunEvent,
+    payload: EventPayload,
 }
 
 impl RedactedRunEvent {
     pub fn new(event: &RunEvent, redactor: &SecretRedactor) -> Result<Self> {
-        let value = redacted_event_value(event, redactor)?;
-        let event =
-            RunEvent::from_ref(&value).context("Failed to reparse redacted event payload")?;
-        Ok(Self { event, value })
+        let payload = build_redacted_event_payload(event, &event.run_id, redactor)?;
+        let event = RunEvent::from_ref(payload.as_value())
+            .context("Failed to reparse redacted event payload")?;
+        Ok(Self { event, payload })
     }
 
     #[must_use]
@@ -37,12 +37,13 @@ impl RedactedRunEvent {
         &self.event
     }
 
-    pub fn payload(&self) -> Result<EventPayload> {
-        EventPayload::new(self.value.clone(), &self.event.run_id).map_err(anyhow::Error::from)
+    #[must_use]
+    pub fn payload(&self) -> &EventPayload {
+        &self.payload
     }
 
     pub fn json_line(&self) -> Result<String> {
-        serde_json::to_string(&self.value).map_err(anyhow::Error::from)
+        serde_json::to_string(self.payload.as_value()).map_err(anyhow::Error::from)
     }
 }
 
diff --git a/lib/crates/fabro-workflow/src/runtime_store.rs b/lib/crates/fabro-workflow/src/runtime_store.rs
index 899271c44..b78bf76d9 100644
--- a/lib/crates/fabro-workflow/src/runtime_store.rs
+++ b/lib/crates/fabro-workflow/src/runtime_store.rs
@@ -87,7 +87,7 @@ impl RunStoreBackend for LocalRunStoreBackend {
 
     async fn append_run_event(&self, event: &RedactedRunEvent) -> Result<()> {
         self.run_store
-            .append_event(&event.payload()?)
+            .append_event(event.payload())
             .await
             .map(|_| ())
             .map_err(anyhow::Error::from)