Method GetRequest

internal/requests/sqlite.go:149–177

(ctx context.Context, requestID string)

}

func (s *sqliteStore) GetRequest(ctx context.Context, requestID string) (RequestRow, error) {
	row := s.db.QueryRowContext(ctx, `
SELECT request_id, trace_id, request_type, tenant_id, task_type, priority, pipeline_ref,
  input_json, context_json, ai_request_json, policy_snapshot_json, status, selected_backend, route_reason,
  created_at, updated_at
FROM requests WHERE request_id = ?`, requestID)
	var r RequestRow
	var createdMs, updatedMs int64
	var policySnap, aiReq sql.NullString
	if err := row.Scan(
		&r.RequestID, &r.TraceID, &r.RequestType, &r.TenantID, &r.TaskType, &r.Priority, &r.PipelineRef,
		&r.InputJSON, &r.ContextJSON, &aiReq, &policySnap, &r.Status, &r.SelectedBackend, &r.RouteReason,
		&createdMs, &updatedMs,
	); err != nil {
		if errors.Is(err, sql.ErrNoRows) {
			return RequestRow{}, ErrNotFound
		}
		return RequestRow{}, err
	}
	if aiReq.Valid {
		r.AIRequestJSON = []byte(aiReq.String)
	}
	if policySnap.Valid {
		r.PolicySnapshot = []byte(policySnap.String)
	}
	r.CreatedAt = time.UnixMilli(createdMs)
	r.UpdatedAt = time.UnixMilli(updatedMs)
	return r, nil
}

func (s *sqliteStore) ListSteps(ctx context.Context, requestID string) ([]StepRow, error) {
	rows, err := s.db.QueryContext(ctx, `