Function syncOwner

services/security-sync/src/sync.ts:1604–1823

(params: {
  db: WorkerDb;
  gitTokenService: GitTokenService;
  owner: SecurityReviewOwner;
  runId: string;
  trigger?: 'scheduled' | 'manual';
  actor?: { id: string; email?: string | null; name?: string | null };
  repoFullName?: string;
  notificationMaterializationEnabled?: boolean;
})

  let pending = 0;
  let cancelled = 0;
  for (const row of result.rows) {
    if (row.status === 'pending') pending = row.count;
    if (row.status === 'cancelled') cancelled = row.count;
  }
  return { pending, cancelled };
}

type AutoAnalysisQueueSyncResult = {
  enqueueCount: number;
  eligibleCount: number;
  boundarySkipCount: number;
  unknownSeverityCount: number;
};

const AUTO_ANALYSIS_REOPEN_REQUEUE_CAP = 2;
export function isFindingEligibleForAutoAnalysis(params: {
  findingCreatedAt: string;
  findingStatus: string;
  severity: string | null;
  ownerAutoAnalysisEnabledAt: string | null;
  isAgentEnabled: boolean;
  autoAnalysisEnabled: boolean;
  autoAnalysisMinSeverity: AutoAnalysisMinSeverity;
  autoAnalysisIncludeExisting?: boolean;
}): { eligible: boolean; severityRank: number } {
  const decision = decideAutoAnalysisEligibility({
    findingCreatedAt: params.findingCreatedAt,
    findingStatus: params.findingStatus,
    findingSeverity: params.severity,
    autoAnalysisEnabledAt: params.ownerAutoAnalysisEnabledAt,
    isAgentEnabled: params.isAgentEnabled,
    autoAnalysisEnabled: params.autoAnalysisEnabled,
    autoAnalysisMinSeverity: params.autoAnalysisMinSeverity,
    autoAnalysisIncludeExisting: params.autoAnalysisIncludeExisting,
  });

  return { eligible: decision.eligible, severityRank: decision.severityRank };
}

export async function syncAutoAnalysisQueueForFinding(
  db: WorkerDb,
  params: {
    owner: SecurityReviewOwner;
    findingId: string;
    findingCreatedAt: string;
    previousStatus: SecurityFindingStatus | null;
    currentStatus: SecurityFindingStatus;
    severity: string | null;
    isAgentEnabled: boolean;
    autoAnalysisEnabled: boolean;
    autoAnalysisMinSeverity: AutoAnalysisMinSeverity;
    ownerAutoAnalysisEnabledAt: string | null;
    autoAnalysisIncludeExisting?: boolean;
  }
): Promise<AutoAnalysisQueueSyncResult> {
  const decision = decideAutoAnalysisEligibility({
    findingCreatedAt: params.findingCreatedAt,
    findingStatus: params.currentStatus,