Function sweepGitCommits

packages/plugin/src/plugin/dream-timer.ts:441–519

(args: {
    directory: string;
    projectIdentity: string;
    db: Database;
    gitCommitIndexing: { enabled: boolean; since_days: number; max_commits: number };
})

}

async function sweepGitCommits(args: {
    directory: string;
    projectIdentity: string;
    db: Database;
    gitCommitIndexing: { enabled: boolean; since_days: number; max_commits: number };
}): Promise<void> {
    const { directory, projectIdentity, db, gitCommitIndexing } = args;
    const holderId = crypto.randomUUID();
    const lease = acquireGitSweepLease(db, projectIdentity, holderId);
    if (!lease.acquired) {
        const reason =
            lease.reason === "cooldown_active"
                ? `cooldown active until ${lease.nextAllowedAt}`
                : `lease held by ${lease.leaseHolder ?? "another holder"} until ${lease.leaseExpiresAt ?? "unknown"}`;
        log(`[git-commits] sweep skipped for ${projectIdentity}: ${reason}`);
        return;
    }

    const startedAt = Date.now();
    const stopRenewal = startGitSweepLeaseRenewal(db, projectIdentity, holderId);
    log(
        `[git-commits] sweep starting for ${projectIdentity} (sinceDays=${gitCommitIndexing.since_days} maxCommits=${gitCommitIndexing.max_commits})`,
    );
    try {
        const result = await indexCommitsForProject(db, projectIdentity, directory, {
            sinceDays: gitCommitIndexing.since_days,
            maxCommits: gitCommitIndexing.max_commits,
        });
        if (result.nonIndexable) {
            // Not a repo / repo with no commits: park on the long re-probe
            // cooldown so the timer doesn't retry (and log) every tick.
            if (!parkGitSweepNonIndexable(db, projectIdentity, holderId)) {
                releaseGitSweepLease(db, projectIdentity, holderId);
            }
            return;
        }
        // Drain any remaining embedding backlog from this sweep (indexer caps per run).
        let drainedEmbeddings = 0;
        if (result.embedded > 0) {
            drainedEmbeddings = await embedUnembeddedCommits(db, projectIdentity);
        }
        const cooldownMarked = markGitSweepSuccessAndRelease(db, projectIdentity, holderId);
        if (!cooldownMarked) {
            releaseGitSweepLease(db, projectIdentity, holderId);
            log(
                `[git-commits] sweep finished for ${projectIdentity}, but lease was no longer active; cooldown not advanced`,
            );
        }

        const memorySnapshot = getProjectEmbeddingSnapshot(projectIdentity);
        let backlogDrained = 0;
        if (memorySnapshot?.gitCommitEnabled) {
            try {
                backlogDrained = await drainCommitBacklogForProject(
                    db,
                    projectIdentity,
                    Date.now() + GIT_COMMIT_BACKLOG_DRAIN_MAX_MS,
                );