Reuse duration helper in federation metrics

Use the shared duration helper for queued inbox processing metrics and
cover remote host attributes on failed delivery metric assertions.

#755 (comment)
#755 (comment)
#755 (comment)

Assisted-by: gpt-5.5

Author: dahlia

packages/fedify/src/federation/middleware.ts

@@ -103,7 +103,11 @@ import {
 import { routeActivity } from "./inbox.ts";
 import { KvKeyCache } from "./keycache.ts";
 import type { KvKey, KvStore } from "./kv.ts";
-import { getFederationMetrics, getRemoteHost } from "./metrics.ts";
+import {
+  getDurationMs,
+  getFederationMetrics,
+  getRemoteHost,
+} from "./metrics.ts";
 import type { MessageQueue } from "./mq.ts";
 import { acceptsJsonLd } from "./negotiation.ts";
 import type {
@@ -913,7 +917,7 @@ export class FederationImpl<TContextData>
             getFederationMetrics(this.meterProvider)
               .recordInboxProcessingDuration(
                 activityType,
-                Math.max(0, performance.now() - started),
+                getDurationMs(started),
               );
           }
         } catch (error) {

packages/fedify/src/federation/send.test.ts

@@ -593,12 +593,20 @@ test("sendActivity() records OpenTelemetry delivery metrics", async (t) => {
       sent[0].attributes["activitypub.activity.type"],
       "https://www.w3.org/ns/activitystreams#Follow",
     );
+    assertEquals(
+      sent[0].attributes["activitypub.remote.host"],
+      "metrics.example",
+    );
 
     const durations = recorder.getMeasurements(
       "activitypub.delivery.duration",
     );
     assertEquals(durations.length, 1);
     assertGreaterOrEqual(durations[0].value, 0);
+    assertEquals(
+      durations[0].attributes["activitypub.remote.host"],
+      "metrics.example",
+    );
 
     recorder.clear();
     fetchMock.hardReset();