189807f5a5
* feat: add commitment param to json rpc requests * fix: tests and examples * fix: docs * fix: epoch info test * fix: budget example * fix: test timeout * fix: remove MAX_COMMITMENT and RECENT_COMMITMENT types
93 lines
2.4 KiB
JavaScript
93 lines
2.4 KiB
JavaScript
// @flow
|
|
|
|
import invariant from 'assert';
|
|
|
|
import {Connection} from '../connection';
|
|
import type {Commitment} from '../connection';
|
|
import {Transaction} from '../transaction';
|
|
import {sleep} from './sleep';
|
|
import type {Account} from '../account';
|
|
import type {TransactionSignature} from '../transaction';
|
|
import {DEFAULT_TICKS_PER_SLOT, NUM_TICKS_PER_SECOND} from '../timing';
|
|
|
|
/**
|
|
* Sign, send and confirm a transaction with recent commitment level
|
|
*/
|
|
export async function sendAndConfirmRecentTransaction(
|
|
connection: Connection,
|
|
transaction: Transaction,
|
|
...signers: Array<Account>
|
|
): Promise<TransactionSignature> {
|
|
return await _sendAndConfirmTransaction(
|
|
connection,
|
|
transaction,
|
|
signers,
|
|
'recent',
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Sign, send and confirm a transaction
|
|
*/
|
|
export async function sendAndConfirmTransaction(
|
|
connection: Connection,
|
|
transaction: Transaction,
|
|
...signers: Array<Account>
|
|
): Promise<TransactionSignature> {
|
|
return await _sendAndConfirmTransaction(connection, transaction, signers);
|
|
}
|
|
|
|
async function _sendAndConfirmTransaction(
|
|
connection: Connection,
|
|
transaction: Transaction,
|
|
signers: Array<Account>,
|
|
commitment: ?Commitment,
|
|
): Promise<TransactionSignature> {
|
|
let sendRetries = 10;
|
|
let signature;
|
|
for (;;) {
|
|
const start = Date.now();
|
|
signature = await connection.sendTransaction(transaction, ...signers);
|
|
|
|
// Wait up to a couple slots for a confirmation
|
|
let status = null;
|
|
let statusRetries = 6;
|
|
for (;;) {
|
|
status = await connection.getSignatureStatus(signature, commitment);
|
|
if (status) {
|
|
break;
|
|
}
|
|
|
|
if (--statusRetries <= 0) {
|
|
break;
|
|
}
|
|
// Sleep for approximately half a slot
|
|
await sleep((500 * DEFAULT_TICKS_PER_SLOT) / NUM_TICKS_PER_SECOND);
|
|
}
|
|
|
|
if (status && 'Ok' in status) {
|
|
break;
|
|
}
|
|
if (--sendRetries <= 0) {
|
|
const duration = (Date.now() - start) / 1000;
|
|
throw new Error(
|
|
`Transaction '${signature}' was not confirmed in ${duration.toFixed(
|
|
2,
|
|
)} seconds (${JSON.stringify(status)})`,
|
|
);
|
|
}
|
|
|
|
if (status && status.Err && !('AccountInUse' in status.Err)) {
|
|
throw new Error(
|
|
`Transaction ${signature} failed (${JSON.stringify(status)})`,
|
|
);
|
|
}
|
|
|
|
// Retry in 0..100ms to try to avoid another AccountInUse collision
|
|
await sleep(Math.random() * 100);
|
|
}
|
|
|
|
invariant(signature !== undefined);
|
|
return signature;
|
|
}
|