fix: better handling if confirmed block not found on node

This commit is contained in:
Tyera Eulberg 2020-01-22 13:05:19 -07:00 committed by Michael Vines
parent 43e90a1967
commit 3482953757
2 changed files with 58 additions and 37 deletions

View File

@ -448,46 +448,49 @@ const GetMinimumBalanceForRentExemptionRpcResult = jsonRpcResult('number');
* Expected JSON RPC response for the "getConfirmedBlock" message
*/
export const GetConfirmedBlockRpcResult = jsonRpcResult(
struct({
blockhash: 'string',
previousBlockhash: 'string',
parentSlot: 'number',
transactions: struct.array([
struct({
transaction: struct({
signatures: struct.array(['string']),
message: struct({
accountKeys: struct.array(['string']),
header: struct({
numRequiredSignatures: 'number',
numReadonlySignedAccounts: 'number',
numReadonlyUnsignedAccounts: 'number',
}),
instructions: struct.array([
struct.union([
struct.array(['number']),
struct({
accounts: struct.array(['number']),
data: 'string',
programIdIndex: 'number',
}),
struct.union([
'null',
struct({
blockhash: 'string',
previousBlockhash: 'string',
parentSlot: 'number',
transactions: struct.array([
struct({
transaction: struct({
signatures: struct.array(['string']),
message: struct({
accountKeys: struct.array(['string']),
header: struct({
numRequiredSignatures: 'number',
numReadonlySignedAccounts: 'number',
numReadonlyUnsignedAccounts: 'number',
}),
instructions: struct.array([
struct.union([
struct.array(['number']),
struct({
accounts: struct.array(['number']),
data: 'string',
programIdIndex: 'number',
}),
]),
]),
]),
recentBlockhash: 'string',
recentBlockhash: 'string',
}),
}),
meta: struct.union([
'null',
struct({
status: SignatureStatusResult,
fee: 'number',
preBalances: struct.array(['number']),
postBalances: struct.array(['number']),
}),
]),
}),
meta: struct.union([
'null',
struct({
status: SignatureStatusResult,
fee: 'number',
preBalances: struct.array(['number']),
postBalances: struct.array(['number']),
}),
]),
}),
]),
}),
]),
}),
]),
);
/**
@ -1052,6 +1055,9 @@ export class Connection {
throw new Error(result.error.message);
}
assert(typeof result.result !== 'undefined');
if (!result.result) {
throw new Error('Confirmed block '+slot+' not found');
}
return {
blockhash: new PublicKey(result.result.blockhash).toString(),
previousBlockhash: new PublicKey(

View File

@ -646,6 +646,21 @@ test('get confirmed block', async () => {
}
x++;
}
mockRpc.push([
url,
{
method: 'getConfirmedBlock',
params: [10000],
},
{
error: null,
result: null,
},
]);
await expect(
connection.getConfirmedBlock(10000),
).rejects.toThrow();
});
test('get recent blockhash', async () => {