diff --git a/packages/sdk/src/sdk/services/StorageNodeSelector/StorageNodeSelector.ts b/packages/sdk/src/sdk/services/StorageNodeSelector/StorageNodeSelector.ts index c97996bd185..5ba98f96af2 100644 --- a/packages/sdk/src/sdk/services/StorageNodeSelector/StorageNodeSelector.ts +++ b/packages/sdk/src/sdk/services/StorageNodeSelector/StorageNodeSelector.ts @@ -89,12 +89,9 @@ export class StorageNodeSelector implements StorageNodeSelectorService { this.selectedNode = selectedNode this.logger.info('Selected content node', this.selectedNode) } else { - // No healthy nodes found. Fall back to a random node - this.selectedNode = this.getRandomNode() - this.logger.warn( - 'No healthy nodes found. Falling back to random node:', - this.selectedNode - ) + // No healthy nodes found + this.selectedNode = null + this.logger.warn('No healthy nodes found') this.selectionState = 'failed_all' } @@ -130,17 +127,6 @@ export class StorageNodeSelector implements StorageNodeSelectorService { return selectedNode } - private getRandomNode(): string | null { - if (!this.orderedNodes?.length) { - this.orderedNodes = this.orderNodes(new Date().toString()) - } - if (this.orderedNodes.length === 0) { - return null - } - const randomIndex = Math.floor(Math.random() * this.orderedNodes.length) - return this.orderedNodes[randomIndex] ?? null - } - private orderNodes(key: string) { const endpoints = this.nodes.map((node) => node.endpoint.toLowerCase()) const hash = new RendezvousHash(...endpoints)