Elwood adapter update

.changeset/brave-boxes-laugh.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/elwood-adapter': patch
+---
+
+Add a delay between subscribe requests

packages/sources/elwood/src/config/index.ts

@@ -1,4 +1,5 @@
 import { AdapterConfig } from '@chainlink/external-adapter-framework/config'
+import { validator } from '@chainlink/external-adapter-framework/validation/utils'
 
 export const config = new AdapterConfig({
   API_KEY: {
@@ -17,4 +18,11 @@ export const config = new AdapterConfig({
     type: 'string',
     default: 'https://api.chk.elwood.systems/v1/stream',
   },
+  SUBSCRIBE_DELAY_MS: {
+    type: 'number',
+    description:
+      'The minimum time (ms) to wait before sending another subscription message to the /stream endpoint',
+    default: 500,
+    validate: validator.integer({ min: 0, max: 10_000 }),
+  },
 })

packages/sources/elwood/src/transport/crypto.ts

@@ -1,6 +1,6 @@
 import { BaseEndpointTypes } from '../endpoint/crypto'
 import { WebSocketTransport } from '@chainlink/external-adapter-framework/transports'
-import { makeLogger } from '@chainlink/external-adapter-framework/util'
+import { makeLogger, sleep } from '@chainlink/external-adapter-framework/util'
 import {
   DEFAULT_TRANSPORT_NAME,
   EndpointContext,
@@ -158,6 +158,10 @@ export const transport: WebSocketTransport<WsTransportTypes> =
             ])
           }
         })
+
+        if (messages.length > 1) {
+          sleep(context.adapterSettings.SUBSCRIBE_DELAY_MS || 0)
+        }
       }
     }
   })()

packages/sources/elwood/src/transport/lwba.ts

@@ -1,6 +1,6 @@
 import { BaseEndpointTypesLwba } from '../endpoint/crypto-lwba'
 import { WebSocketTransport } from '@chainlink/external-adapter-framework/transports'
-import { makeLogger } from '@chainlink/external-adapter-framework/util'
+import { makeLogger, sleep } from '@chainlink/external-adapter-framework/util'
 import {
   DEFAULT_TRANSPORT_NAME,
   EndpointContext,
@@ -160,6 +160,10 @@ export const transport: WebSocketTransport<WsTransportTypes> =
             ])
           }
         })
+
+        if (messages.length > 1) {
+          sleep(context.adapterSettings.SUBSCRIBE_DELAY_MS || 0)
+        }
       }
     }
   })()

packages/sources/elwood/test/integration/adapter.test.ts

@@ -42,6 +42,8 @@ describe('websocket', () => {
     oldEnv = JSON.parse(JSON.stringify(process.env))
     process.env['API_KEY'] = apiKey
     process.env['METRICS_ENABLED'] = 'false'
+    process.env['SUBSCRIBE_DELAY_MS'] = '0'
+
     // Start mock web socket server
     mockWebSocketProvider(WebSocketClassProvider)
     mockWsServer = mockWebSocketServer(