Method parse_event

atomic-agent/src/hooks/codex.rs:239–325

(&self, hook_type: HookType, input: &[u8])

    }

    fn parse_event(&self, hook_type: HookType, input: &[u8]) -> AgentResult<TurnEvent> {
        let raw_json = self.parse_json(hook_type, input)?;

        match hook_type {
            HookType::SessionStart => {
                let parsed: SessionStartInput = self.parse_value(hook_type, raw_json.clone())?;
                let mut event = TurnEvent::new(
                    Self::extract_session_id(parsed.session_id, parsed.thread_id, &raw_json),
                    hook_type,
                )
                .with_raw_json(with_openai_provider(raw_json));
                if let Some(path) = parsed.transcript_path {
                    event = event.with_transcript_path(path);
                }
                Ok(event)
            }
            HookType::TurnStart => {
                let parsed: UserPromptSubmitInput =
                    self.parse_value(hook_type, raw_json.clone())?;
                let mut event = TurnEvent::new(
                    Self::extract_session_id(parsed.session_id, parsed.thread_id, &raw_json),
                    hook_type,
                )
                .with_raw_json(with_openai_provider(raw_json));
                if let Some(path) = parsed.transcript_path {
                    event = event.with_transcript_path(path);
                }
                if let Some(prompt) = parsed.prompt.filter(|p| !p.is_empty()) {
                    event = event.with_prompt(prompt);
                }
                Ok(event)
            }
            HookType::TurnEnd => {
                let parsed: StopInput = self.parse_value(hook_type, raw_json.clone())?;
                let raw_json = normalize_stop_raw(raw_json);
                let mut event = TurnEvent::new(
                    Self::extract_session_id(parsed.session_id, parsed.thread_id, &raw_json),
                    hook_type,
                )
                .with_raw_json(with_openai_provider(raw_json));
                if let Some(path) = parsed.transcript_path {
                    event = event.with_transcript_path(path);
                }
                Ok(event)
            }
            HookType::PreToolUse | HookType::PostToolUse => {
                let parsed: ToolUseInput = self.parse_value(hook_type, raw_json.clone())?;
                let raw_json = if hook_type == HookType::PostToolUse {
                    normalize_tool_raw(raw_json)
                } else {
                    raw_json
                };
                let mut event = TurnEvent::new(
                    Self::extract_session_id(parsed.session_id, parsed.thread_id, &raw_json),
                    hook_type,
                )
                .with_raw_json(with_openai_provider(raw_json));
                if let Some(path) = parsed.transcript_path {