Add attribute traceId to all pubsub events

index.js

@@ -1,5 +1,5 @@
 import nock from "nock";
-import { randomUUID } from "crypto";
+import { randomUUID, randomBytes } from "crypto";
 import { pathToRegexp, match } from "path-to-regexp";
 
 const uuidRegex = /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89abcd][0-9a-f]{3}-[0-9a-f]{12}$/i;
@@ -139,7 +139,10 @@ export async function addSlug(slug) {
 
   if (!publishTime) {
     slug.publishTime = new Date().toISOString();
+  } else if (publishTime instanceof Date) {
+    slug.publishTime = publishTime.toISOString();
   }
+
   slugs.push(slug);
 
   const valueContent = contentByType[type][id];
@@ -190,7 +193,7 @@ async function sendEvent(type, id, event) {
       id,
       updated: new Date(),
     })),
-    attributes: {},
+    attributes: { traceId: randomBytes(16).toString("hex") },
   };
   await pubSubListener(message);
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@bonniernews/fake-tool-api",
-  "version": "1.7.1",
+  "version": "1.7.2",
   "type": "module",
   "description": "Mocked Bonnier News tool api, for use in automated tests",
   "main": "index.js",

test/index.spec.js

@@ -648,23 +648,39 @@ describe("Fake tool api", () => {
       const articleId = randomUUID();
       const slugId1 = randomUUID();
       const slugId2 = randomUUID();
+      const slugId3 = randomUUID();
+      const slugId4 = randomUUID();
       const publishTime1 = "2024-01-01T09:00:00.000Z";
       const publishTime2 = "2024-01-01T11:00:00.000Z";
+      const publishTime3 = new Date("2024-01-01T10:00:00.000Z");
+      const publishTime4 = new Date("2024-01-01T12:00:00.000Z");
 
       await fakeToolApi.addSlug({ id: slugId1, value: articleId, publishTime: publishTime1 });
       await fakeToolApi.addSlug({ id: slugId2, value: articleId, publishTime: publishTime2 });
+      await fakeToolApi.addSlug({ id: slugId3, value: articleId, publishTime: publishTime3 });
+      await fakeToolApi.addSlug({ id: slugId4, value: articleId, publishTime: publishTime4 });
 
       const res = await fetch(`${baseUrl}/slug/byValue/${articleId}`);
       expect(res.status).to.equal(200);
 
       const data = await res.json();
       expect(data).to.deep.equal({
         slugs: [
+          {
+            id: slugId4,
+            value: articleId,
+            publishTime: publishTime4.toISOString(),
+          },
           {
             id: slugId2,
             value: articleId,
             publishTime: publishTime2,
           },
+          {
+            id: slugId3,
+            value: articleId,
+            publishTime: publishTime3.toISOString(),
+          },
           {
             id: slugId1,
             value: articleId,