Function waitForThreadExec

utils/lib/index.ts:36–50

(clockworkProvider, thread: PublicKey, maxWait: number = 60)

let lastThreadExec = BigInt(0);
const waitForThreadExec = async (clockworkProvider, thread: PublicKey, maxWait: number = 60) => {
    let i = 1;
    while (true) {
        const execContext = (await clockworkProvider.getThreadAccount(thread)).execContext;
        if (execContext) {
            if (lastThreadExec.toString() == "0" || execContext.lastExecAt > lastThreadExec) {
                lastThreadExec = execContext.lastExecAt;
                break;
            }
        }
        if (i == maxWait) throw Error("Timeout");
        i += 1;
        await new Promise((r) => setTimeout(r, i * 1000));
    }
}

export {
    print_address,