Function sweepProject

packages/plugin/src/plugin/dream-timer.ts:266–392

* Run all per-project maintenance for one registration: git commit indexing * (when enabled) plus dream schedule check + queue processing (when enabled). * * Each registered project gets its own pass per tick — Desktop loads the * plugin once per project in the same process, and every project ne

(
    reg: ProjectRegistration,
    origin: "startup" | "interval",
    db: Database,
    gitCommitEnabled?: boolean,
)

 * own commits indexed and its own dream schedule honored.
 */
async function sweepProject(
    reg: ProjectRegistration,
    origin: "startup" | "interval",
    db: Database,
    gitCommitEnabled?: boolean,
): Promise<void> {
    // Dead-directory guard: a registration whose directory no longer exists
    // (e.g. a finalized mason worktree) can't have meaningful dreamer work —
    // git indexing + key-files/verify would ENOENT reading from the gone path.
    // Skip it and unregister so it stops being swept. For a `dir:` identity
    // (path-unique → truly orphaned once the path is gone) also GC its schedule
    // rows; a `git:` identity is SHARED across worktrees/clones, so a single dead
    // worktree must NOT delete the shared project's schedule.
    if (!directoryStillExists(reg.directory)) {
        log(
            `[dreamer] project directory no longer exists (${reg.projectIdentity}); skipping + unregistering`,
        );
        if (reg.projectIdentity.startsWith("dir:")) {
            try {
                const removed = deleteTaskScheduleRowsForProject(db, reg.projectIdentity);
                if (removed > 0) {
                    log(
                        `[dreamer] GC'd ${removed} orphaned schedule row(s) for ${reg.projectIdentity}`,
                    );
                }
            } catch (error) {
                log(`[dreamer] orphan schedule GC failed for ${reg.projectIdentity}:`, error);
            }
        }
        registeredProjects.delete(reg.directory);
        return;
    }

    await reg.ensureRegistered(reg.directory, db);
    const embeddingSnapshot = getProjectEmbeddingSnapshot(reg.projectIdentity);
    const commitIndexingEnabled = gitCommitEnabled ?? embeddingSnapshot?.gitCommitEnabled === true;
    const gc = sweepStaleEmbeddingIdentitiesForProject(db, reg.projectIdentity);
    const gcDeleted = gc.memoryRowsDeleted + gc.commitRowsDeleted + gc.chunkRowsDeleted;
    if (gcDeleted > 0) {
        log(
            `[magic-context] GC'd ${gcDeleted} stale embedding row(s) for ${reg.projectIdentity} ` +
                `(memory=${gc.memoryRowsDeleted} commit=${gc.commitRowsDeleted} chunk=${gc.chunkRowsDeleted})`,
        );
    }

    const dreamerConfig = reg.dreamerConfig;
    const dreamingEnabled = Boolean(dreamerConfig && dreamerConfig.disable !== true);
    if (commitIndexingEnabled && reg.gitCommitIndexing) {
        await sweepGitCommits({
            directory: reg.directory,
            gitCommitIndexing: reg.gitCommitIndexing,
            projectIdentity: reg.projectIdentity,
            db,
        });
    }

    if (!dreamingEnabled || !dreamerConfig) {
        return;