Function createCodeReviewAttempt

apps/web/src/lib/code-reviews/db/code-reviews.ts:420–489

(params: {
  codeReviewId: string;
  retryOfAttemptId?: string;
  retryReason?: string;
  status?: CodeReviewAttemptStatus;
  sessionId?: string;
  cliSessionId?: string;
  executionId?: string;
  errorMessage?: string;
  terminalReason?: CodeReviewTerminalReason;
  startedAt?: Date;
  completedAt?: Date;
  analyticsEnabledAtDispatch?: boolean;
})

          reconsiderable_work.owner_type,
          reconsiderable_work.owner_id,
          reconsiderable_work.oldest_reconsiderable_at,
          COALESCE(active_work.active_count, 0) AS active_count,
          CASE
            WHEN reconsiderable_work.owner_type = 'org'
              THEN ${MAX_CONCURRENT_CODE_REVIEWS_PER_ORG}::bigint
            WHEN COALESCE(
              ${kilocode_users.total_microdollars_acquired},
              0
            ) - COALESCE(${kilocode_users.microdollars_used}, 0) > ${FUNDED_CODE_REVIEW_BALANCE_THRESHOLD_MICRODOLLARS}
              THEN ${MAX_CONCURRENT_CODE_REVIEWS_PER_FUNDED_USER}::bigint
            ELSE ${MAX_CONCURRENT_CODE_REVIEWS_PER_DEFAULT_USER}::bigint
          END AS capacity_limit
        FROM reconsiderable_work
        LEFT JOIN active_work
          ON active_work.owner_type = reconsiderable_work.owner_type
          AND active_work.owner_id = reconsiderable_work.owner_id
        LEFT JOIN ${kilocode_users}
          ON reconsiderable_work.owner_type = 'user'
          AND ${kilocode_users.id} = reconsiderable_work.owner_id
      )
      SELECT owner_type, owner_id
      FROM capacity_candidates
      WHERE active_count < capacity_limit
      ORDER BY oldest_reconsiderable_at ASC, owner_type ASC, owner_id ASC
      LIMIT ${limit + 1}
    `);

    const hasMore = result.rows.length > limit;
    const owners = result.rows.slice(0, limit).map(row =>
      row.owner_type === 'org'
        ? ({
            type: 'org',
            id: row.owner_id,
          } satisfies DispatchableCodeReviewOwnerCandidate)
        : ({
            type: 'user',
            id: row.owner_id,
          } satisfies DispatchableCodeReviewOwnerCandidate)
    );

    return { owners, hasMore };
  } catch (error) {
    captureException(error, {
      tags: { operation: 'listDispatchableCodeReviewOwnerCandidates' },
      extra: { limit },
    });
    throw error;
  }
}

export async function listCodeReviewAttempts(
  codeReviewId: string
): Promise<CloudAgentCodeReviewAttempt[]> {
  try {
    return await db
      .select()
      .from(cloud_agent_code_review_attempts)
      .where(eq(cloud_agent_code_review_attempts.code_review_id, codeReviewId))