feat(capabilities/webapi): use a round robin selector in handler

[MStreet3]

This PR:

• adds a round robin selector that cycles through a slice of gateway IDs
• replaces the gateway selection in the outgoing connector handler to use the round robin selector

Logs below show subsequent requests for the same message ID using gateways iteratively.

2025-01-31T12:18:23.727-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:82 sending request to gateway      {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:18:23.727-0500    info    WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:96 selected gateway, awaiting connection   {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0", "gatewayID": "por_gateway"}
2025-01-31T12:18:24.339-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:124        handling gateway request        {"version": "0.0.1@unset", "gatewayID": "por_gateway", "method": "workflow_syncer", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:18:24.339-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:108        received response from gateway  {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:18:24.339-0500    debug   WorkflowRegistrySyncer.FetcherService   syncer/fetcher.go:103   received gateway response       {"version": "0.0.1@unset", "donID": "1", "msgID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:25:15.147-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:82 sending request to gateway      {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:25:15.147-0500    info    WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:96 selected gateway, awaiting connection   {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0", "gatewayID": "por_gateway_2"}
2025-01-31T12:25:15.743-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:124        handling gateway request        {"version": "0.0.1@unset", "gatewayID": "por_gateway_2", "method": "workflow_syncer", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:25:15.743-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:108        received response from gateway  {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:25:15.744-0500    debug   WorkflowRegistrySyncer.FetcherService   syncer/fetcher.go:103   received gateway response       {"version": "0.0.1@unset", "donID": "1", "msgID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:38:43.718-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:82 sending request to gateway      {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:38:43.719-0500    info    WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:96 selected gateway, awaiting connection   {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0", "gatewayID": "por_gateway_2"}
2025-01-31T12:38:44.314-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:124        handling gateway request        {"version": "0.0.1@unset", "gatewayID": "por_gateway_2", "method": "workflow_syncer", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}
2025-01-31T12:38:44.314-0500    debug   WorkflowRegistrySyncer.FetcherService.OutgoingConnectorHandler  webapi/outgoing_connector_handler.go:108        received response from gateway  {"version": "0.0.1@unset", "messageID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0", "gatewayID": "por_gateway_2"}
2025-01-31T12:38:44.314-0500    debug   WorkflowRegistrySyncer.FetcherService   syncer/fetcher.go:103   received gateway response       {"version": "0.0.1@unset", "donID": "1", "msgID": "workflow_syncer/c494b627c6e7c35b55b10b3904e91885c29f13fade8f2739cb8be3e2d53ab3b0"}

Requires

Supports

[cedric-cordenier]

@MStreet3 Thinking about this a bit more -- Is this safe? It basically queries GatewayIDs once, at instantiation time; I wonder if there could be some weird races where we haven't connected to everything and so our list is shorter than it otherwise could be. Maybe it's worth passing in the list of IDs every time we make a choice?

[cedric-cordenier]

Actually 🤦 nvm, you can see that the size of the list doesn't change here:

chainlink/core/services/gateway/connector/connector.go

Line 129 in 331a2e8

for _, gw := range config.Gateways {

[github-actions]

AER Report: CI Core ran successfully ✅

aer_workflow , commit

AER Report: Operator UI CI ran successfully ✅

aer_workflow , commit

[cl-sonarqube-production]

Quality Gate passed

Issues
0 New issues
0 Fixed issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube