transaction sender and waiter for solana

gistfile1.txt

async function transactionSenderAndConfirmationWaiter({
    serializedTransaction,
    blockhashWithExpiryBlockHeight,
    maxRetryTimeMs = 60000, 
}) {
    const startTime = Date.now();

    const txid = await connection.sendRawTransaction(
        serializedTransaction,
        {
            skipPreflight: true,
        }
    );

    const controller = new AbortController();
    const abortSignal = controller.signal;

    const abortableResender = async () => {
        while (Date.now() - startTime < maxRetryTimeMs) {
            await wait(2000);
            if (abortSignal.aborted) return;
            try {
                console.log("resending....");
                await connection.sendRawTransaction(serializedTransaction, {
                    skipPreflight: true,
                });
            } catch (e) {
                console.warn(`Failed to resend transaction: ${e}`);
            }
        }
    };

    try {
        abortableResender();

        const lastValidBlockHeight = blockhashWithExpiryBlockHeight.lastValidBlockHeight;

        await Promise.race([
            connection.confirmTransaction(
                {
                    ...blockhashWithExpiryBlockHeight,
                    lastValidBlockHeight,
                    signature: txid,
                },
                "confirmed"
            ),
            new Promise(async (resolve) => {
                while (!abortSignal.aborted) {
                    await wait(2000);
                    const tx = await connection.getSignatureStatus(txid, {
                        searchTransactionHistory: false,
                    });
                    if (tx?.value?.confirmationStatus === "confirmed") {
                        resolve(tx);
                    }
                }
            }),
        ]);
    } catch (e) {
        if (e instanceof TransactionExpiredBlockheightExceededError) {
            return null;
        } else {
            throw e;
        }
    } finally {
        controller.abort();
    }

    const response = await promiseRetry(
        async (retry) => {
            const response = await connection.getTransaction(txid, {
                commitment: "confirmed",
                maxSupportedTransactionVersion: 0,
            });
            if (!response) {
                retry(response);
            }
            return response;
        },
        {
            retries: 5,
            minTimeout: 1000,
        }
    );

    return response;
}