Skip to content

Commit 28a250c

Browse files
Fix node selection test (#13817)
1 parent 73b34ae commit 28a250c

1 file changed

Lines changed: 3 additions & 17 deletions

File tree

packages/sdk/src/sdk/services/StorageNodeSelector/StorageNodeSelector.ts

Lines changed: 3 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -89,12 +89,9 @@ export class StorageNodeSelector implements StorageNodeSelectorService {
8989
this.selectedNode = selectedNode
9090
this.logger.info('Selected content node', this.selectedNode)
9191
} else {
92-
// No healthy nodes found. Fall back to a random node
93-
this.selectedNode = this.getRandomNode()
94-
this.logger.warn(
95-
'No healthy nodes found. Falling back to random node:',
96-
this.selectedNode
97-
)
92+
// No healthy nodes found
93+
this.selectedNode = null
94+
this.logger.warn('No healthy nodes found')
9895
this.selectionState = 'failed_all'
9996
}
10097

@@ -130,17 +127,6 @@ export class StorageNodeSelector implements StorageNodeSelectorService {
130127
return selectedNode
131128
}
132129

133-
private getRandomNode(): string | null {
134-
if (!this.orderedNodes?.length) {
135-
this.orderedNodes = this.orderNodes(new Date().toString())
136-
}
137-
if (this.orderedNodes.length === 0) {
138-
return null
139-
}
140-
const randomIndex = Math.floor(Math.random() * this.orderedNodes.length)
141-
return this.orderedNodes[randomIndex] ?? null
142-
}
143-
144130
private orderNodes(key: string) {
145131
const endpoints = this.nodes.map((node) => node.endpoint.toLowerCase())
146132
const hash = new RendezvousHash(...endpoints)

0 commit comments

Comments
 (0)