Function parseEventsJSONLMetrics

pkg/cli/copilot_events_jsonl.go:173–322

parseEventsJSONLMetrics parses a Copilot events.jsonl file and extracts log metrics. events.jsonl provides precise, structured data about a Copilot CLI session: - "session.start": session metadata (sessionId, copilotVersion) - "user.message": one per conversation turn (used to co

(path string, verbose bool)

// Returns the extracted metrics and nil on success, or empty metrics and an
// error if the file cannot be read or contains no recognizable events.
func parseEventsJSONLMetrics(path string, verbose bool) (workflow.LogMetrics, error) {
	copilotEventsJSONLLog.Printf("Parsing events.jsonl from: %s", path)

	var metrics workflow.LogMetrics

	// Sanitize path to prevent traversal
	cleanPath := filepath.Clean(path)

	file, err := os.Open(cleanPath)
	if err != nil {
		return metrics, fmt.Errorf("failed to open events.jsonl: %w", err)
	}
	defer file.Close()

	toolCallMap := make(map[string]*workflow.ToolCallInfo)
	var currentSequence []string
	turns := 0
	totalTokens := 0
	foundAnyEvent := false

	// Per-turn timestamps used to compute Time Between Turns (TBT)
	var turnTimestamps []time.Time

	scanner := bufio.NewScanner(file)
	buf := make([]byte, maxScannerBufferSize)
	scanner.Buffer(buf, maxScannerBufferSize)

	for scanner.Scan() {
		line := strings.TrimSpace(scanner.Text())
		if line == "" || !strings.HasPrefix(line, "{") {
			continue
		}

		var entry copilotEventsJSONLEntry
		if err := json.Unmarshal([]byte(line), &entry); err != nil {
			copilotEventsJSONLLog.Printf("Skipping malformed events.jsonl line: %v", err)
			continue
		}

		foundAnyEvent = true

		switch entry.Type {
		case "session.start":
			copilotEventsJSONLLog.Printf("session.start: sessionId=%s copilotVersion=%s",
				entry.Data.SessionID, entry.Data.CopilotVersion)

		case "user.message":
			// Each user message represents one conversation turn.
			// Save the current tool sequence before starting a new turn.
			turns++
			if len(currentSequence) > 0 {
				metrics.ToolSequences = append(metrics.ToolSequences, currentSequence)
				currentSequence = []string{}
			}
			// Record the timestamp for TBT computation.
			if entry.Timestamp != "" {
				if ts, parseErr := time.Parse(time.RFC3339Nano, entry.Timestamp); parseErr == nil {
					turnTimestamps = append(turnTimestamps, ts)