Method ListSteps

internal/requests/sqlite.go:179–214

(ctx context.Context, requestID string)

}

func (s *sqliteStore) ListSteps(ctx context.Context, requestID string) ([]StepRow, error) {
	rows, err := s.db.QueryContext(ctx, `
SELECT request_id, step_index, step_type, input_json, output_json, backend, status, error, latency_ms, metadata_json
FROM request_steps WHERE request_id = ? ORDER BY step_index ASC`, requestID)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	var out []StepRow
	for rows.Next() {
		var srow StepRow
		var inJ, outJ, metaJ sql.NullString
		if err := rows.Scan(&srow.RequestID, &srow.StepIndex, &srow.StepType, &inJ, &outJ, &srow.Backend, &srow.Status, &srow.Error, &srow.LatencyMs, &metaJ); err != nil {
			return nil, err
		}
		if inJ.Valid {
			srow.InputJSON = []byte(inJ.String)
		}
		if outJ.Valid {
			srow.OutputJSON = []byte(outJ.String)
		}
		if metaJ.Valid {
			srow.MetadataJSON = []byte(metaJ.String)
		}
		out = append(out, srow)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	if len(out) == 0 {
		if _, err := s.GetRequest(ctx, requestID); err != nil {
			return nil, err
		}
	}
	return out, nil
}

func (s *sqliteStore) Close() error {
	return s.db.Close()