Function checkpointExists

src/utils/checkpoint.ts:10–20

* Check if a checkpoint exists for the given thread_id

(checkpointer: SqliteSaver, threadId: string)

 * Check if a checkpoint exists for the given thread_id
 */
async function checkpointExists(checkpointer: SqliteSaver, threadId: string): Promise<boolean> {
    try {
        const checkpoints = checkpointer.list({ configurable: { thread_id: threadId } }, { limit: 1 });
        const firstCheckpoint = await checkpoints.next();
        return !firstCheckpoint.done && firstCheckpoint.value !== undefined;
    } catch (error) {
        const errorMessage = error instanceof Error ? error.message : String(error);
        logger.printTestLog(`Error checking checkpoint: ${errorMessage}`);
        return false;
    }
}

/**
 * Clear checkpoint for the given thread_id