mleku/warp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Random sequencer selection

Browse Source
This commit is contained in:
Michał Szynwelski
2023-12-07 10:07:27 +01:00
parent 0f5c58cd02
commit 672c620e32
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/contract/sequencer/SequencerClient.ts
View File

@@ -45,9 +45,9 @@ export interface SequencerClient {
*/ */
type SequencerAddress = { type SequencerAddress = {
/** /**
* The URL address of the sequencer * Sequencer URLs
*/ */
url: string; urls: [string];
/** /**
* The type of sequencer * The type of sequencer
*/ */
@@ -68,13 +68,16 @@ export const createSequencerClient = async (
): Promise<SequencerClient> => { ): Promise<SequencerClient> => {
const response = warpFetchWrapper.fetch(`${stripTrailingSlash(gatewayUrl)}/gateway/sequencer/address`); const response = warpFetchWrapper.fetch(`${stripTrailingSlash(gatewayUrl)}/gateway/sequencer/address`);
const address = await getJsonResponse<SequencerAddress>(response); const address = await getJsonResponse<SequencerAddress>(response);
// if there are several sequencer nodes to choose from, we randomly select one
const sequencerAddress =
address.urls.length > 1 ? address.urls[Math.floor(Math.random() * address.urls.length)] : address.urls[0];
if (address.type == 'centralized') { if (address.type == 'centralized') {
return new CentralizedSequencerClient(address.url, warpFetchWrapper); return new CentralizedSequencerClient(sequencerAddress, warpFetchWrapper);
} }
if (address.type == 'decentralized') { if (address.type == 'decentralized') {
return new DecentralizedSequencerClient(address.url, gatewayUrl, warpFetchWrapper); return new DecentralizedSequencerClient(sequencerAddress, gatewayUrl, warpFetchWrapper);
} }
throw new Error('Unknown sequencer type: ' + address.type); throw new Error('Unknown sequencer type: ' + address.type);