scriptoriumadmin/fabro
1
0
Fork 0
mirror of https://github.com/fabro-sh/fabro.git synced 2026-09-12 23:02:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

fabro(01KX1P0VV0DAQTT0N2NADX8J8J): simplify_gpt (succeeded)

Browse source 
Fabro-Run: 01KX1P0VV0DAQTT0N2NADX8J8J
Fabro-Completed: 7

⚒️ Generated with [Fabro](https://fabro.sh)
This commit is contained in:
Fabro 2026-07-08 21:50:52 +00:00
parent d787531fa7
commit 315b14fe60
2 changed files with 11 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
lib/crates/fabro-workflow/src/event/redaction.rs
View file

@ -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)
}
}

2
lib/crates/fabro-workflow/src/runtime_store.rs
View file

@ -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)