Update/df 21604 kaiko state wbtc quote as btc (#3937)

* DF-21604 cache wbtc quotes as /btc

* add changeset

Author: mmcallister-cll

.changeset/hot-zebras-cross.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/kaiko-state-adapter': minor
+---
+
+Cache wbtc quotes as /btc

packages/sources/kaiko-state/src/transport/state.ts

@@ -1,13 +1,13 @@
+import { EndpointContext } from '@chainlink/external-adapter-framework/adapter'
 import { TransportDependencies } from '@chainlink/external-adapter-framework/transports'
-import { sleep, makeLogger } from '@chainlink/external-adapter-framework/util'
 import { SubscriptionTransport } from '@chainlink/external-adapter-framework/transports/abstract/subscription'
-import { EndpointContext } from '@chainlink/external-adapter-framework/adapter'
+import { makeLogger, sleep } from '@chainlink/external-adapter-framework/util'
 import { BaseEndpointTypes } from '../endpoint/state'
 
-import { generateCreds, getProviderIndicatedTimeUnixMs } from './utils'
 import { ClientReadableStream, ServiceError } from '@grpc/grpc-js'
-import { BehaviorSubject, distinctUntilChanged, from, fromEvent, switchMap } from 'rxjs'
 import { backOff } from 'exponential-backoff'
+import { BehaviorSubject, distinctUntilChanged, from, fromEvent, switchMap } from 'rxjs'
+import { generateCreds, getProviderIndicatedTimeUnixMs } from './utils'
 
 import { StreamAggregatedStatePriceServiceV1Client } from '@kaiko-data/sdk-node/sdk/sdk_grpc_pb'
 import { StreamAggregatedStatePriceRequestV1 } from '@kaiko-data/sdk-node/sdk/stream/aggregated_state_price_v1/request_pb'
@@ -73,10 +73,17 @@ export class KaikoStateTransport extends SubscriptionTransport<KaikoStateTranspo
 
     subscription.on('data', (response: StreamAggregatedStatePriceResponseV1) => {
       const cacheData = []
+
       if (response.getAggregatedPriceLst().length > 0) {
+        const quote =
+          response.getLstQuote().toUpperCase() == 'WETH'
+            ? 'ETH'
+            : response.getLstQuote().toUpperCase() == 'WBTC'
+            ? 'BTC'
+            : response.getLstQuote()
         cacheData.push(
           this._generateResponse(
-            response.getLstQuote().toUpperCase() == 'WETH' ? 'ETH' : response.getLstQuote(),
+            quote,
             response.getAggregatedPriceLst(),
             providerDataRequestedUnixMs,
             response,

packages/sources/kaiko-state/test/integration/__snapshots__/adapter.test.ts.snap

@@ -14,3 +14,30 @@ exports[`execute state endpoint should return success 1`] = `
 }
 `;
 
+exports[`execute state endpoint should return success with BTC quote 1`] = `
+{
+  "data": {
+    "result": 100.5,
+  },
+  "result": 100.5,
+  "statusCode": 200,
+  "timestamps": {
+    "providerDataReceivedUnixMs": 978347471111,
+    "providerDataRequestedUnixMs": 978347471111,
+  },
+}
+`;
+
+exports[`execute state endpoint should return success with ETH quote 1`] = `
+{
+  "data": {
+    "result": 100.3,
+  },
+  "result": 100.3,
+  "statusCode": 200,
+  "timestamps": {
+    "providerDataReceivedUnixMs": 978347471111,
+    "providerDataRequestedUnixMs": 978347471111,
+  },
+}
+`;

packages/sources/kaiko-state/test/integration/adapter.test.ts

@@ -49,5 +49,23 @@ describe('execute', () => {
       expect(response.statusCode).toBe(200)
       expect(response.json()).toMatchSnapshot()
     })
+    it('should return success with ETH quote', async () => {
+      const data = {
+        base: 'RETH',
+        quote: 'ETH',
+      }
+      const response = await testAdapter.request(data)
+      expect(response.statusCode).toBe(200)
+      expect(response.json()).toMatchSnapshot()
+    })
+    it('should return success with BTC quote', async () => {
+      const data = {
+        base: 'SOLVBTC',
+        quote: 'BTC',
+      }
+      const response = await testAdapter.request(data)
+      expect(response.statusCode).toBe(200)
+      expect(response.json()).toMatchSnapshot()
+    })
   })
 })

packages/sources/kaiko-state/test/integration/fixtures.ts

@@ -7,6 +7,18 @@ export class MockClientReadableStream {
         getLstQuote: jest.fn(() => 'WETH'),
         getAggregatedPriceUsd: jest.fn(() => '100.2'),
       })
+      handler({
+        getBase: jest.fn(() => 'RETH'),
+        getAggregatedPriceLst: jest.fn(() => '100.3'),
+        getLstQuote: jest.fn(() => 'WETH'),
+        getAggregatedPriceUsd: jest.fn(() => '100.4'),
+      })
+      handler({
+        getBase: jest.fn(() => 'SOLVBTC'),
+        getAggregatedPriceLst: jest.fn(() => '100.5'),
+        getLstQuote: jest.fn(() => 'WBTC'),
+        getAggregatedPriceUsd: jest.fn(() => '100.6'),
+      })
     }
     return this
   })