fix: align with TransportError class from squash-merged SDK-84

The squash merge of PR #2839 changed TransportError from an interface
to a class extending Error. Update test fixtures and the partial-success
detection in httpSend to use `new TransportError(...)` instead of plain
object literals.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: ImmutableJeffrey

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

@@ -1,5 +1,6 @@
 import { createConsentManager } from './consent';
 import type { HttpSend } from './transport';
+import { TransportError } from './errors';
 
 function createMockSend() {
   return jest.fn<ReturnType<HttpSend>, Parameters<HttpSend>>().mockResolvedValue({ ok: true });
@@ -123,11 +124,11 @@ describe('createConsentManager', () => {
       const queue = createMockQueue();
       const send = jest.fn<ReturnType<HttpSend>, Parameters<HttpSend>>().mockResolvedValue({
         ok: false,
-        error: {
+        error: new TransportError({
           status: 503,
           endpoint: 'https://api.dev.immutable.com/v1/audience/tracking-consent',
           body: { code: 'SERVICE_UNAVAILABLE' },
-        },
+        }),
       });
       const onError = jest.fn();
       const manager = createConsentManager(queue, send, 'pk_test', 'anon-1', 'dev', 'pixel', 'none', onError);
@@ -149,11 +150,11 @@ describe('createConsentManager', () => {
       const queue = createMockQueue();
       const send = jest.fn<ReturnType<HttpSend>, Parameters<HttpSend>>().mockResolvedValue({
         ok: false,
-        error: {
+        error: new TransportError({
           status: 0,
           endpoint: 'https://api.dev.immutable.com/v1/audience/tracking-consent',
           cause: new TypeError('Failed to fetch'),
-        },
+        }),
       });
       const onError = jest.fn();
       const manager = createConsentManager(queue, send, 'pk_test', 'anon-1', 'dev', 'pixel', 'none', onError);
@@ -185,7 +186,7 @@ describe('createConsentManager', () => {
       const queue = createMockQueue();
       const send = jest.fn<ReturnType<HttpSend>, Parameters<HttpSend>>().mockResolvedValue({
         ok: false,
-        error: { status: 500, endpoint: 'x', body: null },
+        error: new TransportError({ status: 500, endpoint: 'x', body: null }),
       });
       const onError = jest.fn().mockImplementation(() => { throw new Error('callback boom'); });
       const manager = createConsentManager(queue, send, 'pk_test', 'anon-1', 'dev', 'pixel', 'none', onError);

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

@@ -1,5 +1,5 @@
 import {
-  AudienceError, toAudienceError, type TransportError,
+  AudienceError, TransportError, toAudienceError,
 } from './errors';
 
 describe('AudienceError', () => {
@@ -37,17 +37,17 @@ describe('AudienceError', () => {
 });
 
 describe('toAudienceError', () => {
-  const httpError: TransportError = {
+  const httpError = new TransportError({
     status: 500,
     endpoint: 'https://api.dev.immutable.com/v1/audience/messages',
     body: { code: 'INTERNAL_ERROR' },
-  };
+  });
 
-  const networkError: TransportError = {
+  const networkError = new TransportError({
     status: 0,
     endpoint: 'https://api.dev.immutable.com/v1/audience/messages',
     cause: new TypeError('Failed to fetch'),
-  };
+  });
 
   describe('flush source', () => {
     it('maps HTTP error to FLUSH_FAILED with status in message', () => {
@@ -98,11 +98,11 @@ describe('toAudienceError', () => {
 
   describe('partial-rejection (2xx with rejected > 0)', () => {
     it('maps to VALIDATION_REJECTED with backend body preserved', () => {
-      const partialError: TransportError = {
+      const partialError = new TransportError({
         status: 200,
         endpoint: 'https://api.dev.immutable.com/v1/audience/messages',
         body: { accepted: 50, rejected: 50 },
-      };
+      });
 
       const err = toAudienceError(partialError, 'flush', 100);
 
@@ -113,11 +113,11 @@ describe('toAudienceError', () => {
     });
 
     it('handles missing accepted/rejected fields gracefully', () => {
-      const partialError: TransportError = {
+      const partialError = new TransportError({
         status: 200,
         endpoint: 'https://api.dev.immutable.com/v1/audience/messages',
         body: {},
-      };
+      });
 
       const err = toAudienceError(partialError, 'flush');
 

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

@@ -1,6 +1,6 @@
 import { MessageQueue } from './queue';
 import type { HttpSend } from './transport';
-import type { AudienceError, TransportResult } from './errors';
+import { TransportError, type AudienceError, type TransportResult } from './errors';
 import type { Message } from './types';
 import * as storage from './storage';
 
@@ -206,7 +206,9 @@ describe('MessageQueue', () => {
     const onError = jest.fn();
     const send = jest.fn<ReturnType<HttpSend>, Parameters<HttpSend>>().mockResolvedValue({
       ok: false,
-      error: { status: 500, endpoint: 'https://api.immutable.com/v1/audience/messages', body: null },
+      error: new TransportError({
+        status: 500, endpoint: 'https://api.immutable.com/v1/audience/messages', body: null,
+      }),
     });
     const queue = createQueue(send, { onError });
 
@@ -225,11 +227,11 @@ describe('MessageQueue', () => {
     const onError = jest.fn();
     const send = jest.fn<ReturnType<HttpSend>, Parameters<HttpSend>>().mockResolvedValue({
       ok: false,
-      error: {
+      error: new TransportError({
         status: 0,
         endpoint: 'https://api.immutable.com/v1/audience/messages',
         cause: new TypeError('Failed to fetch'),
-      },
+      }),
     });
     const queue = createQueue(send, { onError });
 
@@ -275,11 +277,11 @@ describe('MessageQueue', () => {
     const onError = jest.fn();
     const send = jest.fn<ReturnType<HttpSend>, Parameters<HttpSend>>().mockResolvedValue({
       ok: false,
-      error: {
+      error: new TransportError({
         status: 200,
         endpoint: 'https://api.immutable.com/v1/audience/messages',
         body: { accepted: 1, rejected: 1 },
-      },
+      }),
     });
     const queue = createQueue(send, { onError });
 

packages/audience/core/src/transport.ts

@@ -82,11 +82,11 @@ export const httpSend: HttpSend = async (
       });
       return {
         ok: false,
-        error: {
+        error: new TransportError({
           status: response.status,
           endpoint: url,
           body: bodyObj,
-        },
+        }),
       };
     }