Function readExtractorFailure

internal/daemon/memory_runtime.go:416–447

(path string)

}

func readExtractorFailure(path string) (extractorFailure, error) {
	data, err := os.ReadFile(path)
	if err != nil {
		return extractorFailure{}, fmt.Errorf("daemon: read extractor failure %q: %w", path, err)
	}
	var report extractorFailureReport
	if err := json.Unmarshal(data, &report); err != nil {
		return extractorFailure{}, fmt.Errorf("daemon: decode extractor failure %q: %w", path, err)
	}
	createdAt := parseMemoryTime(report.RecordedAt)
	if createdAt.IsZero() {
		if info, statErr := os.Stat(path); statErr == nil {
			createdAt = info.ModTime().UTC()
		}
	}
	if createdAt.IsZero() {
		createdAt = time.Now().UTC()
	}
	sessionID, workspaceID, agentName := failureCandidateMetadata(report.Content)
	return extractorFailure{
		Payload: contract.MemoryExtractorFailurePayload{
			ID:          strings.TrimSuffix(filepath.Base(path), ".json"),
			SessionID:   sessionID,
			WorkspaceID: workspaceID,
			AgentName:   agentName,
			Reason:      firstNonEmptyString(report.Error, report.Stage),
			Path:        path,
			CreatedAt:   createdAt,
		},
		Report: report,
	}, nil
}

func (f extractorFailure) Candidates() ([]memcontract.Candidate, error) {
	scanner := bufio.NewScanner(strings.NewReader(f.Report.Content))