feat: getBlocks API is added (#19854)
This commit is contained in:
parent
afa04f7abd
commit
ea5fed937f
|
@ -3107,6 +3107,26 @@ export class Connection {
|
|||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Fetch confirmed blocks between two slots
|
||||
*/
|
||||
async getBlocks(
|
||||
startSlot: number,
|
||||
endSlot?: number,
|
||||
commitment?: Finality,
|
||||
): Promise<Array<number>> {
|
||||
const args = this._buildArgsAtLeastConfirmed(
|
||||
endSlot !== undefined ? [startSlot, endSlot] : [startSlot],
|
||||
commitment,
|
||||
);
|
||||
const unsafeRes = await this._rpcRequest('getBlocks', args);
|
||||
const res = create(unsafeRes, jsonRpcResult(array(number())));
|
||||
if ('error' in res) {
|
||||
throw new Error('failed to get blocks: ' + res.error.message);
|
||||
}
|
||||
return res.result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Fetch a list of Signatures from the cluster for a confirmed block, excluding rewards
|
||||
*/
|
||||
|
|
|
@ -2078,6 +2078,54 @@ describe('Connection', () => {
|
|||
);
|
||||
});
|
||||
|
||||
it('get blocks between two slots', async () => {
|
||||
await mockRpcResponse({
|
||||
method: 'getBlocks',
|
||||
params: [0, 10],
|
||||
value: [1, 2, 3, 4, 5, 6, 7, 8, 9, 10],
|
||||
});
|
||||
|
||||
await mockRpcResponse({
|
||||
method: 'getSlot',
|
||||
params: [],
|
||||
value: 10,
|
||||
});
|
||||
|
||||
const latestSlot = await connection.getSlot();
|
||||
const blocks = await connection.getBlocks(0, latestSlot);
|
||||
expect(blocks).to.have.length(latestSlot);
|
||||
expect(blocks).to.contain(1);
|
||||
expect(blocks).to.contain(latestSlot);
|
||||
});
|
||||
|
||||
it('get blocks from starting slot', async () => {
|
||||
await mockRpcResponse({
|
||||
method: 'getBlocks',
|
||||
params: [0],
|
||||
value: [
|
||||
1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20,
|
||||
21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38,
|
||||
39, 40, 41, 42,
|
||||
],
|
||||
});
|
||||
|
||||
await mockRpcResponse({
|
||||
method: 'getSlot',
|
||||
params: [],
|
||||
value: 20,
|
||||
});
|
||||
|
||||
while ((await connection.getSlot()) <= 0) {
|
||||
continue;
|
||||
}
|
||||
|
||||
const blocks = await connection.getBlocks(0);
|
||||
const latestSlot = await connection.getSlot();
|
||||
expect(blocks).to.have.lengthOf.greaterThanOrEqual(latestSlot);
|
||||
expect(blocks).to.contain(1);
|
||||
expect(blocks).to.contain(latestSlot);
|
||||
});
|
||||
|
||||
it('get confirmed block signatures', async () => {
|
||||
await mockRpcResponse({
|
||||
method: 'getSlot',
|
||||
|
|
Loading…
Reference in New Issue