Method parse_event

atomic-agent/src/hooks/agy.rs:901–990

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

    }

    fn parse_event(&self, hook_type: HookType, input: &[u8]) -> AgentResult<TurnEvent> {
        if input.is_empty() {
            return Err(AgentError::HookInputEmpty {
                agent: self.name().to_string(),
                hook_type: hook_type.as_str().to_string(),
            });
        }

        let raw_json: Value =
            serde_json::from_slice(input).map_err(|e| AgentError::HookParseFailed {
                agent: self.name().to_string(),
                hook_type: hook_type.as_str().to_string(),
                reason: e.to_string(),
            })?;

        match hook_type {
            HookType::TurnStart => {
                // Antigravity: PreInvocation → TurnStart
                let parsed: PreInvocationInput =
                    serde_json::from_value(raw_json.clone()).map_err(|e| {
                        AgentError::HookParseFailed {
                            agent: self.name().to_string(),
                            hook_type: hook_type.as_str().to_string(),
                            reason: e.to_string(),
                        }
                    })?;

                Ok(self
                    .base_event(hook_type, parsed.conversation_id, parsed.transcript_path)
                    .with_raw_json(raw_json))
            }

            HookType::TurnEnd => {
                // Antigravity: Stop → TurnEnd
                let parsed: StopInput = serde_json::from_value(raw_json.clone()).map_err(|e| {
                    AgentError::HookParseFailed {
                        agent: self.name().to_string(),
                        hook_type: hook_type.as_str().to_string(),
                        reason: e.to_string(),
                    }
                })?;

                // Normalize the termination reason into the `finish_reason`
                // field the record pipeline understands (mirrors the Codex
                // adapter's stop normalization).
                let raw_json = normalize_stop_raw(raw_json);

                Ok(self
                    .base_event(hook_type, parsed.conversation_id, parsed.transcript_path)
                    .with_raw_json(raw_json))
            }

            HookType::PostToolUse => {
                let parsed: PostToolUseInput =
                    serde_json::from_value(raw_json.clone()).map_err(|e| {
                        AgentError::HookParseFailed {
                            agent: self.name().to_string(),
                            hook_type: hook_type.as_str().to_string(),