refactor(audience): make httpSend generic for consent PUT

Add method option to TransportOptions so consent module can use httpSend
instead of raw fetch. Type the consent payload as ConsentUpdatePayload
and widen httpSend to accept both BatchPayload and ConsentUpdatePayload.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: bkbooth

packages/audience/core/src/consent.test.ts

@@ -1,8 +1,11 @@
 import { createConsentManager } from './consent';
+import { httpSend } from './transport';
 
-// Mock fetch globally
-const mockFetch = jest.fn().mockResolvedValue({ ok: true });
-global.fetch = mockFetch;
+jest.mock('./transport', () => ({
+  httpSend: jest.fn().mockResolvedValue(true),
+}));
+
+const mockHttpSend = httpSend as jest.MockedFunction<typeof httpSend>;
 
 function createMockQueue() {
   return {
@@ -81,16 +84,11 @@ describe('createConsentManager', () => {
 
     manager.setLevel('anonymous');
 
-    expect(mockFetch).toHaveBeenCalledWith(
+    expect(mockHttpSend).toHaveBeenCalledWith(
       'https://api.dev.immutable.com/v1/audience/tracking-consent',
-      expect.objectContaining({
-        method: 'PUT',
-        headers: expect.objectContaining({
-          'Content-Type': 'application/json',
-          'x-immutable-publishable-key': 'pk_test',
-        }),
-        body: JSON.stringify({ anonymousId: 'anon-1', status: 'anonymous', source: 'pixel' }),
-      }),
+      'pk_test',
+      { anonymousId: 'anon-1', status: 'anonymous', source: 'pixel' },
+      { method: 'PUT', keepalive: true },
     );
   });
 
@@ -101,7 +99,7 @@ describe('createConsentManager', () => {
     manager.setLevel('anonymous');
     expect(queue.purge).not.toHaveBeenCalled();
     expect(queue.transform).not.toHaveBeenCalled();
-    expect(mockFetch).not.toHaveBeenCalled();
+    expect(mockHttpSend).not.toHaveBeenCalled();
   });
 
   it('respects DNT by defaulting to none', () => {

packages/audience/core/src/consent.ts

@@ -1,6 +1,9 @@
-import type { ConsentLevel, Message, Environment } from './types';
+import type {
+  ConsentLevel, ConsentUpdatePayload, Message, Environment,
+} from './types';
 import type { MessageQueue } from './queue';
 import { CONSENT_PATH, getBaseUrl } from './config';
+import { httpSend } from './transport';
 
 export interface ConsentManager {
   level: ConsentLevel;
@@ -40,19 +43,8 @@ export function createConsentManager(
 
   function notifyBackend(level: ConsentLevel): void {
     const url = `${getBaseUrl(environment)}${CONSENT_PATH}`;
-    const payload = { anonymousId, status: level, source };
-    // Uses fetch directly rather than httpSend because this is a PUT
-    // to a different endpoint with a different payload shape than the
-    // message ingest POST that httpSend is designed for.
-    fetch(url, {
-      method: 'PUT',
-      headers: {
-        'Content-Type': 'application/json',
-        'x-immutable-publishable-key': publishableKey,
-      },
-      body: JSON.stringify(payload),
-      keepalive: true,
-    }).catch(() => {});
+    const payload: ConsentUpdatePayload = { anonymousId, status: level, source };
+    httpSend(url, publishableKey, payload, { method: 'PUT', keepalive: true });
   }
 
   const manager: ConsentManager = {

packages/audience/core/src/index.ts

@@ -13,6 +13,7 @@ export type {
   BatchPayload,
   ConsentLevel,
   ConsentStatus,
+  ConsentUpdatePayload,
 } from './types';
 
 export {
@@ -37,7 +38,7 @@ export {
 
 export { generateId, getTimestamp, isBrowser } from './utils';
 
-export type { Transport } from './transport';
+export type { Transport, TransportOptions } from './transport';
 export { httpTransport, httpSend } from './transport';
 export { MessageQueue } from './queue';
 export { collectContext } from './context';

packages/audience/core/src/transport.test.ts

@@ -51,6 +51,20 @@ describe('httpSend', () => {
     }));
   });
 
+  it('uses specified method from options', async () => {
+    const mockFetch = jest.fn().mockResolvedValue({ ok: true });
+    global.fetch = mockFetch;
+
+    const consentPayload = { anonymousId: 'anon-1', status: 'anonymous' as const, source: 'pixel' };
+    await httpSend('https://example.com/consent', 'pk', consentPayload, { method: 'PUT', keepalive: true });
+
+    expect(mockFetch).toHaveBeenCalledWith('https://example.com/consent', expect.objectContaining({
+      method: 'PUT',
+      keepalive: true,
+      body: JSON.stringify(consentPayload),
+    }));
+  });
+
   it('returns true on success', async () => {
     global.fetch = jest.fn().mockResolvedValue({ ok: true });
     expect(await httpSend('https://example.com', 'pk', payload)).toBe(true);

packages/audience/core/src/transport.ts

@@ -1,7 +1,8 @@
 import { track, trackError } from '@imtbl/metrics';
-import type { BatchPayload } from './types';
+import type { BatchPayload, ConsentUpdatePayload } from './types';
 
 export interface TransportOptions {
+  method?: string;
   keepalive?: boolean;
 }
 
@@ -12,12 +13,12 @@ export interface Transport {
 export async function httpSend(
   url: string,
   publishableKey: string,
-  payload: BatchPayload,
+  payload: BatchPayload | ConsentUpdatePayload,
   options?: TransportOptions,
 ): Promise<boolean> {
   try {
     const response = await fetch(url, {
-      method: 'POST',
+      method: options?.method ?? 'POST',
       headers: {
         'Content-Type': 'application/json',
         'x-immutable-publishable-key': publishableKey,

packages/audience/core/src/types.ts

@@ -97,3 +97,12 @@ export type ConsentLevel = 'none' | 'anonymous' | 'full';
  * - `'full'` — User accepted full tracking.
  */
 export type ConsentStatus = 'not_set' | 'none' | 'anonymous' | 'full';
+
+/**
+ * PUT body for `/v1/audience/tracking-consent`.
+ */
+export interface ConsentUpdatePayload {
+  anonymousId: string;
+  status: ConsentLevel;
+  source: string;
+}