Fix postPath configuration being ignored (close #1376)

common/changes/@snowplow/tracker-core/issue-fix_post_path_2024-11-11-14-42.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@snowplow/tracker-core",
+      "comment": "Fix customPostPath configuration being ignored (close #1376)",
+      "type": "none"
+    }
+  ],
+  "packageName": "@snowplow/tracker-core"
+}

libraries/tracker-core/src/emitter/index.ts

@@ -198,6 +198,7 @@ interface RequestResult {
 export function newEmitter({
   endpoint,
   eventMethod = 'post',
+  postPath,
   protocol,
   port,
   maxPostBytes = 40000,
@@ -320,6 +321,7 @@ export function newEmitter({
       maxPostBytes,
       useStm,
       credentials,
+      postPath,
     });
   }
 

libraries/tracker-core/test/emitter/index.test.ts

@@ -333,3 +333,21 @@ test('adds a timeout to the request', async (t) => {
   t.is(requests.length, 1);
   t.is(await eventStore.count(), 1);
 });
+
+test('uses custom POST path configured in the emitter', async (t) => {
+  const requests: Request[] = [];
+  const mockFetch = createMockFetch(200, requests);
+  const eventStore = newInMemoryEventStore({});
+  const emitter: Emitter = newEmitter({
+    endpoint: 'https://example.com',
+    customFetch: mockFetch,
+    postPath: '/custom',
+    eventStore,
+  });
+
+  await emitter.input({ e: 'pv' });
+  await emitter.flush();
+
+  t.is(requests.length, 1);
+  t.is(requests[0].url, 'https://example.com/custom');
+});