Function createOpencodeStorageScanner

cli/src/opencode/utils/opencodeStorageScanner.ts:63–77

(
    opts: OpencodeStorageScannerOptions
)

const REPLAY_CLOCK_SKEW_MS = 2000;

export async function createOpencodeStorageScanner(
    opts: OpencodeStorageScannerOptions
): Promise<OpencodeStorageScannerHandle> {
    const scanner = new OpencodeStorageScanner(opts);
    await scanner.start();

    return {
        cleanup: async () => {
            await scanner.cleanup();
        },
        onNewSession: (sessionId: string) => {
            void scanner.onNewSession(sessionId);
        }
    };
}

class OpencodeStorageScanner {
    private readonly storageDir: string;