Method commit_hook_event

atomic-agent/src/turn/orchestrator/provenance.rs:170–208

(&self, event: &TurnEvent, turn_number: u32)

    }

    pub(super) fn commit_hook_event(&self, event: &TurnEvent, turn_number: u32) -> AgentResult<()> {
        self.migrate_legacy_accumulator(
            &event.session_id,
            turn_number,
            event.timestamp.timestamp_millis(),
        )?;
        let discriminator = match event.event_type {
            HookType::TurnStart => "goal".to_string(),
            HookType::PreToolUse => format!(
                "tool-before:{}",
                event
                    .tool_use_id
                    .clone()
                    .unwrap_or_else(|| anonymous_tool_key(event))
            ),
            HookType::PostToolUse => format!(
                "tool-after:{}",
                event
                    .tool_use_id
                    .clone()
                    .unwrap_or_else(|| anonymous_tool_key(event))
            ),
            HookType::TurnEnd => "turn-end".to_string(),
            HookType::SessionStart => "session-start".to_string(),
            HookType::SessionEnd => "session-end".to_string(),
        };
        let event_id = stable_journal_id(&event.session_id, turn_number, &discriminator);
        let envelope = ProvenanceJournalEnvelope::from_turn_event(&event_id, turn_number, 1, event);
        self.commit_journal_drafts(
            &event.session_id,
            turn_number,
            vec![JournalDraft {
                event_id,
                timestamp_ms: envelope.timestamp_ms,
                causal_parent_ids: Vec::new(),
                event: envelope.event,
            }],
        )
    }

    pub(super) fn commit_turn_completion_events(
        &self,