Function updateCodeReviewStatus

apps/web/src/lib/code-reviews/db/code-reviews.ts:886–966

(
  reviewId: string,
  status: CodeReviewStatus,
  updates: {
    sessionId?: string;
    cliSessionId?: string;
    errorMessage?: string;
    terminalReason?: CodeReviewTerminalReason;
    startedAt?: Date;
    completedAt?: Date;
    agentVersion?: string;
    model?: string;
    totalTokensIn?: number;
    totalTokensOut?: number;
    totalCostMusd?: number;
  } = {}
)

      .set(
        buildAttemptUpdateData({
          status: params.status,
          sessionId: params.sessionId,
          cliSessionId: params.cliSessionId,
          executionId: params.executionId,
          errorMessage: params.errorMessage,
          terminalReason: params.terminalReason,
          startedAt: params.startedAt,
          completedAt: params.completedAt,
        })
      )
      .where(eq(cloud_agent_code_review_attempts.id, targetAttempt.id))
      .returning();

    if (!updated) {
      throw new Error('Failed to update code review attempt');
    }

    return updated;
  } catch (error) {
    captureException(error, {
      tags: { operation: 'updateCodeReviewAttemptForCallback' },
      extra: { params },
    });
    throw error;
  }
}

export async function hasInfraRetryAttempt(codeReviewId: string): Promise<boolean> {
  try {
    const [attempt] = await db
      .select({ id: cloud_agent_code_review_attempts.id })
      .from(cloud_agent_code_review_attempts)
      .where(
        and(
          eq(cloud_agent_code_review_attempts.code_review_id, codeReviewId),
          eq(cloud_agent_code_review_attempts.retry_reason, 'infra_failure')
        )
      )
      .limit(1);

    return !!attempt;
  } catch (error) {
    captureException(error, {
      tags: { operation: 'hasInfraRetryAttempt' },
      extra: { codeReviewId },
    });
    throw error;
  }
}

export async function ensureCurrentCodeReviewAttemptFromReview(
  review: CloudAgentCodeReview,
  analyticsEnabledAtDispatch?: boolean
): Promise<CloudAgentCodeReviewAttempt> {
  let attempt = await getLatestCodeReviewAttempt(review.id);
  if (attempt) {
    if (
      attempt.status === 'pending' &&