fix: updrageded to beta 8

lib/resolver.content.js

@@ -62,6 +62,7 @@ export default class PodletClientContentResolver {
                 error,
             );
         });
+        this.#http.metrics.pipe(this.#metrics);
     }
 
     get metrics() {

lib/resolver.fallback.js

@@ -57,6 +57,7 @@ export default class PodletClientFallbackResolver {
                 error,
             );
         });
+        this.#http.metrics.pipe(this.#metrics);
     }
 
     get metrics() {

lib/resolver.manifest.js

@@ -58,6 +58,7 @@ export default class PodletClientManifestResolver {
                 error,
             );
         });
+        this.#http.metrics.pipe(this.#metrics);
     }
 
     get metrics() {

package.json

@@ -39,7 +39,7 @@
   "dependencies": {
     "@hapi/boom": "10.0.1",
     "@metrics/client": "2.5.3",
-    "@podium/http-client": "1.0.0-beta.5",
+    "@podium/http-client": "1.0.0-beta.8",
     "@podium/schemas": "5.1.0",
     "@podium/utils": "5.3.2",
     "abslog": "2.4.4",

tests/integration.basic.test.js

@@ -394,25 +394,29 @@ tap.test('integration basic - metrics stream objects created', async (t) => {
 
     const metrics = [];
     client.metrics.on('data', (metric) => {
-        if (metric.name !== 'http_client_breaker_events') metrics.push(metric);
+        if (
+            metric.name !== 'http_client_breaker_events' &&
+            metric.name.indexOf('podium_client') !== -1
+        )
+            metrics.push(metric);
     });
     client.metrics.on('end', async () => {
-        t.equal(metrics.length, 6);
-        t.equal(metrics[1].name, 'podium_client_resolver_manifest_resolve');
-        t.equal(metrics[1].type, 5);
-        t.same(metrics[1].labels[0], {
+        t.equal(metrics.length, 3);
+        t.equal(metrics[0].name, 'podium_client_resolver_manifest_resolve');
+        t.equal(metrics[0].type, 5);
+        t.same(metrics[0].labels[0], {
             name: 'name',
             value: 'clientName',
         });
-        t.equal(metrics[3].name, 'podium_client_resolver_fallback_resolve');
-        t.equal(metrics[3].type, 5);
-        t.same(metrics[3].labels[0], {
+        t.equal(metrics[1].name, 'podium_client_resolver_fallback_resolve');
+        t.equal(metrics[1].type, 5);
+        t.same(metrics[1].labels[0], {
             name: 'name',
             value: 'clientName',
         });
-        t.equal(metrics[5].name, 'podium_client_resolver_content_resolve');
-        t.equal(metrics[5].type, 5);
-        t.same(metrics[5].labels[0], {
+        t.equal(metrics[2].name, 'podium_client_resolver_content_resolve');
+        t.equal(metrics[2].type, 5);
+        t.same(metrics[2].labels[0], {
             name: 'name',
             value: 'clientName',
         });

tests/resolver.test.js

@@ -40,21 +40,18 @@ tap.test(
         function verify(stream) {
             return new Promise((resolve) => {
                 const metrics = [];
-                stream.on('data', (metric) => metrics.push(metric));
+                stream.on('data', (metric) => {
+                    if (metric.name.indexOf('podium') !== -1) {
+                        metrics.push(metric);
+                    }
+                });
                 stream.on('end', async () => {
-                    t.equal(metrics.length, 3);
-
-                    t.equal(metrics[1].name, 'http_client_breaker_events');
-                    t.equal(metrics[1].type, 2);
-                    t.same(metrics[1].labels[0], {
-                        name: 'name',
-                        value: 'success',
-                    });
+                    t.equal(metrics.length, 1);
                     t.equal(
-                        metrics[2].name,
+                        metrics[0].name,
                         'podium_client_resolver_manifest_resolve',
                     );
-                    t.equal(metrics[2].type, 5);
+                    t.equal(metrics[0].type, 5);
                     resolve();
                 });
             });