Merge pull request #521 from vtex/chore/clean-metrics-backport

Chore backport socket metrics cleanup

Author: Jeymisson

CHANGELOG.md

@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 
+## [3.77.8] - 2022-12-15
+### Changed
+- Remove socket metrics per origin
+
 ## [3.77.7] - 2022-04-14
 
 ### Fixed
@@ -1013,3 +1017,7 @@ instead
 ## [0.48.0] - 2018-09-21
 ### Changed
 - `HttpClient` now adds `'Accept-Encoding': 'gzip'` header by default.
+
+
+[Unreleased]: https://github.com/vtex/node-vtex-api/compare/v3.77.8...HEAD
+[3.77.8]: https://github.com/vtex/node-vtex-api/compare/v3.77.7...v3.77.8

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@vtex/api",
-  "version": "3.77.7",
+  "version": "3.77.8",
   "description": "VTEX I/O API client",
   "main": "lib/index.js",
   "typings": "lib/index.d.ts",

src/HttpClient/middlewares/request.ts

@@ -92,28 +92,22 @@ export const requestMiddleware = (limit?: Limit) => async (ctx: MiddlewareContex
   ctx.response = await (limit ? limit(makeRequest) : makeRequest())
 }
 
-function countPerOrigin (obj: { [key: string]: any[] }) {
+function count (obj: { [key: string]: any[] }) {
   try {
-    return mapObjIndexed(val => val.length, obj)
+    return Object.values(obj).reduce((acc, val) => acc += val.length, 0)
   } catch (_) {
-    return {}
+    return 0
   }
 }
 
 export function httpAgentStats () {
-  const socketsPerOrigin = countPerOrigin(httpAgent.sockets)
-  const sockets = sum(values(socketsPerOrigin))
-  const freeSocketsPerOrigin = countPerOrigin((httpAgent as any).freeSockets)
-  const freeSockets = sum(values(freeSocketsPerOrigin))
-  const pendingRequestsPerOrigin = countPerOrigin(httpAgent.requests)
-  const pendingRequests = sum(values(pendingRequestsPerOrigin))
+    const sockets = count(httpAgent.sockets)
+    const freeSockets = count((httpAgent as any).freeSockets)
+    const pendingRequests = count(httpAgent.requests)
 
   return {
     freeSockets,
-    freeSocketsPerOrigin,
     pendingRequests,
-    pendingRequestsPerOrigin,
     sockets,
-    socketsPerOrigin,
   }
 }