[DS-3267] [Streams adapter] 504 error on view-function-multi-chain ad… (#5024)

* [DS-3267] [Streams adapter] 504 error on view-function-multi-chain adapter
Updated ea-framework-js version to support json only FeedId

* Add changeset

* Add tests and update tesgt snapshots
Added FEED_ID_JSON tests for empty and hashed keys
Updated tests snapshots to match actual behavior

* fix test

* revert snapshots

* revert tests

* update dependencies

* fix pnp

* fix tests

---------

Co-authored-by: Ivaylo Novakov <inovakov@gmail.com>
Co-authored-by: app-token-issuer-data-feeds[bot] <134377064+app-token-issuer-data-feeds[bot]@users.noreply.github.com>

Author: 3 people

.changeset/soft-symbols-behave.md

@@ -0,0 +1,6 @@
+---
+'@chainlink/view-function-multi-chain-adapter': minor
+'@chainlink/the-network-firm-adapter': minor
+---
+
+Update ea framework to support json only feed id

packages/sources/the-network-firm/test/integration/adapter.test.ts

@@ -41,6 +41,11 @@ describe('execute', () => {
     })
   })
 
+  beforeEach(() => {
+    testAdapter.adapter.config.settings.FEED_ID_JSON = false
+    testAdapter.adapter.config.settings.METRICS_ENABLED = false
+  })
+
   afterEach(() => {
     nock.cleanAll()
     // clear EA cache
@@ -70,6 +75,17 @@ describe('execute', () => {
     })
   })
 
+  describe('mco2 endpoint empty feed id with FEED_ID_JSON=true', () => {
+    it('should return empty json feed id', async () => {
+      testAdapter.adapter.config.settings.FEED_ID_JSON = true
+      testAdapter.adapter.config.settings.METRICS_ENABLED = true
+      mockMCO2Response()
+      const response = await testAdapter.request()
+      expect(response.statusCode).toBe(200)
+      expect(response.json().meta.metrics.feedId).toBe('{}')
+    })
+  })
+
   describe('stbt endpoint', () => {
     it('should return success', async () => {
       const data = {

packages/sources/view-function-multi-chain/test/integration/adapter.test.ts

@@ -18,6 +18,8 @@ describe('execute', () => {
 
   beforeAll(async () => {
     oldEnv = JSON.parse(JSON.stringify(process.env))
+    const mockDate = new Date('2001-01-01T11:11:11.111Z')
+    spy = jest.spyOn(Date, 'now').mockReturnValue(mockDate.getTime())
     process.env.ETHEREUM_MAINNET_RPC_URL =
       process.env.ETHEREUM_MAINNET_RPC_URL ?? 'http://localhost:8545'
     process.env.ETHEREUM_MAINNET_CHAIN_ID = process.env.ETHEREUM_MAINNET_CHAIN_ID ?? '1'
@@ -27,9 +29,6 @@ describe('execute', () => {
     process.env.BACKGROUND_EXECUTE_MS = '0'
     process.env.APTOS_URL = process.env.APTOS_URL ?? 'http://fake-aptos'
     process.env.APTOS_TESTNET_URL = process.env.APTOS_TESTNET_URL ?? 'http://fake-aptos-testnet'
-    const mockDate = new Date('2001-01-01T11:11:11.111Z')
-    spy = jest.spyOn(Date, 'now').mockReturnValue(mockDate.getTime())
-
     const adapter = (await import('./../../src')).adapter
     adapter.rateLimiting = undefined
     testAdapter = await TestAdapter.startWithMockedCache(adapter, {
@@ -45,6 +44,12 @@ describe('execute', () => {
     spy.mockRestore()
   })
 
+  beforeEach(() => {
+    testAdapter.adapter.config.settings.MAX_COMMON_KEY_SIZE = 500
+    testAdapter.adapter.config.settings.FEED_ID_JSON = false
+    testAdapter.adapter.config.settings.METRICS_ENABLED = false
+  })
+
   afterEach(() => {
     nock.cleanAll()
   })
@@ -62,6 +67,21 @@ describe('execute', () => {
       expect(response.json()).toMatchSnapshot()
     })
 
+    it('should return hash code if data length exceeds max key size', async () => {
+      testAdapter.adapter.config.settings.MAX_COMMON_KEY_SIZE = 1
+      testAdapter.adapter.config.settings.FEED_ID_JSON = true
+      testAdapter.adapter.config.settings.METRICS_ENABLED = true
+      const data = {
+        contract: '0x2c1d072e956AFFC0D435Cb7AC38EF18d24d9127c',
+        function: 'function latestAnswer() external view returns (int256)',
+        network: 'ethereum_mainnet',
+      }
+      mockETHMainnetContractCallResponseSuccess()
+      const response = await testAdapter.request(data)
+      expect(response.statusCode).toBe(200)
+      expect(response.json().meta.metrics.feedId).toBe('{"hash":"oZQF1WbGvmgrgf32HSV0Mm5GSyo="}')
+    })
+
     it('should return success for different network', async () => {
       const data = {
         contract: '0x779877a7b0d9e8603169ddbd7836e478b4624789',

packages/streams-adapter/helpers/helpers.go

@@ -3,7 +3,8 @@ package helpers
 import (
 	"errors"
 	"fmt"
-	"sort"
+	"maps"
+	"slices"
 	"strings"
 
 	"github.com/goccy/go-json"
@@ -65,11 +66,7 @@ func CalculateCacheKey(params types.RequestParams) (string, error) {
 	}
 
 	// Extract and sort keys for deterministic ordering
-	keys := make([]string, 0, len(params))
-	for key := range params {
-		keys = append(keys, key)
-	}
-	sort.Strings(keys)
+	keys := slices.Sorted(maps.Keys(params))
 
 	// Build the cache key
 	var parts []string