Function ParseLineCodex

internal/loop/codex_parser.go:34–125

ParseLineCodex parses a single line of Codex exec --json JSONL output and returns an Event. If the line cannot be parsed or is not relevant, it returns nil.

(line string)

// ParseLineCodex parses a single line of Codex exec --json JSONL output and returns an Event.
// If the line cannot be parsed or is not relevant, it returns nil.
func ParseLineCodex(line string) *Event {
	line = strings.TrimSpace(line)
	if line == "" {
		return nil
	}

	var ev codexEvent
	if err := json.Unmarshal([]byte(line), &ev); err != nil {
		return nil
	}

	switch ev.Type {
	case "thread.started", "turn.started":
		return &Event{Type: EventIterationStart}

	case "turn.failed":
		msg := ""
		if ev.Error != nil {
			msg = ev.Error.Message
		}
		return &Event{Type: EventError, Err: errors.New(msg)}

	case "error":
		msg := ev.Message
		if msg == "" && ev.Error != nil {
			msg = ev.Error.Message
		}
		if msg == "" {
			msg = "unknown error"
		}
		return &Event{Type: EventError, Err: errors.New(msg)}

	case "item.started":
		if ev.Item == nil {
			return nil
		}
		switch ev.Item.Type {
		case "command_execution":
			return &Event{
				Type: EventToolStart,
				Tool: ev.Item.Command,
			}
		case "mcp_tool_call":
			toolName := ev.Item.Tool
			if ev.Item.Server != "" {
				toolName = ev.Item.Server + "/" + ev.Item.Tool
			}
			return &Event{
				Type: EventToolStart,
				Tool: toolName,
			}
		}
		return nil

	case "item.completed":
		if ev.Item == nil {
			return nil
		}