Function runtimeFileEvents

internal/provenance/explain.go:764–782

(db *sql.DB, runID, filePath string)

}

func runtimeFileEvents(db *sql.DB, runID, filePath string) ([]telemetry.EventRecord, error) {
	events, err := telemetry.ListEventsFiltered(db, telemetry.Filter{RunID: runID})
	if err != nil {
		return nil, err
	}
	needle1 := fmt.Sprintf(`"path":"%s"`, filePath)
	needle2 := fmt.Sprintf(`"file":"%s"`, filePath)
	filtered := []telemetry.EventRecord{}
	for _, event := range events {
		if event.EventType != "file_write" && event.EventType != "file_open" {
			continue
		}
		if !strings.Contains(event.Payload, needle1) && !strings.Contains(event.Payload, needle2) {
			continue
		}
		filtered = append(filtered, event)
	}
	return filtered, nil
}

func explainEvents(runID string, events []telemetry.EventRecord) []ExplainEvent {
	out := make([]ExplainEvent, 0, len(events))