Implement server-side ad slot templates with PBS and APS auction

Cargo.toml

@@ -65,6 +65,7 @@ fastly = "0.11.12"
 fern = "0.7.1"
 flate2 = "1.1"
 futures = "0.3"
+glob = "0.3"
 hex = "0.4.3"
 hmac = "0.12.1"
 http = "1.4.0"

crates/js/lib/src/integrations/gpt/index.test.ts

@@ -0,0 +1,215 @@
+import { describe, it, expect, vi, beforeEach } from 'vitest';
+
+interface SlotRenderEvent {
+  isEmpty: boolean;
+  slot: {
+    getSlotElementId(): string;
+    getTargeting(key: string): string[];
+  };
+}
+
+type TestWindow = Window & {
+  googletag?: unknown;
+  __ts_ad_slots?: unknown;
+  __ts_bids?: unknown;
+  __tsAdInit?: () => void;
+};
+
+describe('installTsAdInit', () => {
+  beforeEach(() => {
+    vi.resetModules();
+    delete (window as TestWindow).__ts_ad_slots;
+    delete (window as TestWindow).__ts_bids;
+    delete (window as TestWindow).__tsAdInit;
+    // jsdom does not implement navigator.sendBeacon; polyfill it for tests
+    if (!('sendBeacon' in navigator)) {
+      Object.defineProperty(navigator, 'sendBeacon', {
+        value: vi.fn().mockReturnValue(true),
+        writable: true,
+        configurable: true,
+      });
+    }
+  });
+
+  it('reads window.__ts_bids synchronously and applies bid targeting before refresh', async () => {
+    const mockSlot = {
+      addService: vi.fn().mockReturnThis(),
+      setTargeting: vi.fn().mockReturnThis(),
+      getSlotElementId: vi.fn().mockReturnValue('atf'),
+      getTargeting: vi.fn().mockReturnValue(['abc']),
+    };
+    const mockPubads = {
+      enableSingleRequest: vi.fn(),
+      addEventListener: vi.fn(),
+      refresh: vi.fn(),
+    };
+    (window as TestWindow).googletag = {
+      cmd: { push: vi.fn((fn: () => void) => fn()) },
+      defineSlot: vi.fn().mockReturnValue(mockSlot),
+      pubads: vi.fn().mockReturnValue(mockPubads),
+      enableServices: vi.fn(),
+    };
+    (window as TestWindow).__ts_ad_slots = [
+      {
+        id: 'atf',
+        gam_unit_path: '/123/atf',
+        div_id: 'atf',
+        formats: [[300, 250]],
+        targeting: { pos: 'atf' },
+      },
+    ];
+    (window as TestWindow).__ts_bids = {
+      atf: {
+        hb_pb: '1.00',
+        hb_bidder: 'kargo',
+        hb_adid: 'abc',
+        nurl: 'https://ssp/win',
+        burl: 'https://ssp/bill',
+      },
+    };
+
+    const fetchSpy = vi.spyOn(global, 'fetch');
+
+    const { installTsAdInit } = await import('./index');
+    installTsAdInit();
+    (window as TestWindow).__tsAdInit!();
+
+    expect(fetchSpy).not.toHaveBeenCalled();
+    expect(mockSlot.setTargeting).toHaveBeenCalledWith('hb_pb', '1.00');
+    expect(mockSlot.setTargeting).toHaveBeenCalledWith('hb_bidder', 'kargo');
+    expect(mockSlot.setTargeting).toHaveBeenCalledWith('ts_initial', '1');
+    expect(mockPubads.refresh).toHaveBeenCalled();
+
+    fetchSpy.mockRestore();
+  });
+
+  it('fires both nurl and burl via sendBeacon on slotRenderEnded when our bid won', async () => {
+    const beaconSpy = vi.spyOn(navigator, 'sendBeacon').mockReturnValue(true);
+    let capturedListener: ((e: SlotRenderEvent) => void) | undefined;
+
+    const mockSlot = {
+      addService: vi.fn().mockReturnThis(),
+      setTargeting: vi.fn().mockReturnThis(),
+      getSlotElementId: vi.fn().mockReturnValue('atf'),
+      getTargeting: vi.fn().mockReturnValue(['abc']),
+    };
+    const mockPubads = {
+      enableSingleRequest: vi.fn(),
+      refresh: vi.fn(),
+      addEventListener: vi.fn((event: string, fn: (e: SlotRenderEvent) => void) => {
+        if (event === 'slotRenderEnded') capturedListener = fn;
+      }),
+    };
+    (window as TestWindow).googletag = {
+      cmd: { push: vi.fn((fn: () => void) => fn()) },
+      defineSlot: vi.fn().mockReturnValue(mockSlot),
+      pubads: vi.fn().mockReturnValue(mockPubads),
+      enableServices: vi.fn(),
+    };
+    (window as TestWindow).__ts_ad_slots = [
+      {
+        id: 'atf',
+        gam_unit_path: '/123/atf',
+        div_id: 'atf',
+        formats: [[300, 250]],
+        targeting: {},
+      },
+    ];
+    (window as TestWindow).__ts_bids = {
+      atf: {
+        hb_pb: '1.00',
+        hb_bidder: 'kargo',
+        hb_adid: 'abc',
+        nurl: 'https://ssp/win',
+        burl: 'https://ssp/bill',
+      },
+    };
+
+    const { installTsAdInit } = await import('./index');
+    installTsAdInit();
+    (window as TestWindow).__tsAdInit!();
+
+    expect(capturedListener).toBeDefined();
+    capturedListener!({ isEmpty: false, slot: mockSlot });
+
+    expect(beaconSpy).toHaveBeenCalledWith('https://ssp/win');
+    expect(beaconSpy).toHaveBeenCalledWith('https://ssp/bill');
+    beaconSpy.mockRestore();
+  });
+
+  it('does not fire nurl/burl when bid did not win GAM line item', async () => {
+    const beaconSpy = vi.spyOn(navigator, 'sendBeacon').mockReturnValue(true);
+    let capturedListener: ((e: SlotRenderEvent) => void) | undefined;
+
+    const mockSlotNoMatch = {
+      addService: vi.fn().mockReturnThis(),
+      setTargeting: vi.fn().mockReturnThis(),
+      getSlotElementId: vi.fn().mockReturnValue('atf'),
+      getTargeting: vi.fn().mockReturnValue(['OTHER_BID_ID']),
+    };
+    const mockPubads = {
+      enableSingleRequest: vi.fn(),
+      refresh: vi.fn(),
+      addEventListener: vi.fn((event: string, fn: (e: SlotRenderEvent) => void) => {
+        if (event === 'slotRenderEnded') capturedListener = fn;
+      }),
+    };
+    (window as TestWindow).googletag = {
+      cmd: { push: vi.fn((fn: () => void) => fn()) },
+      defineSlot: vi.fn().mockReturnValue(mockSlotNoMatch),
+      pubads: vi.fn().mockReturnValue(mockPubads),
+      enableServices: vi.fn(),
+    };
+    (window as TestWindow).__ts_ad_slots = [
+      {
+        id: 'atf',
+        gam_unit_path: '/123/atf',
+        div_id: 'atf',
+        formats: [[300, 250]],
+        targeting: {},
+      },
+    ];
+    (window as TestWindow).__ts_bids = {
+      atf: {
+        hb_pb: '1.00',
+        hb_bidder: 'kargo',
+        hb_adid: 'abc',
+        nurl: 'https://ssp/win',
+        burl: 'https://ssp/bill',
+      },
+    };
+
+    const { installTsAdInit } = await import('./index');
+    installTsAdInit();
+    (window as TestWindow).__tsAdInit!();
+    capturedListener!({ isEmpty: false, slot: mockSlotNoMatch });
+
+    expect(beaconSpy).not.toHaveBeenCalled();
+    beaconSpy.mockRestore();
+  });
+
+  it('calls refresh even when __ts_bids is empty (graceful fallback)', async () => {
+    const mockPubads = {
+      enableSingleRequest: vi.fn(),
+      addEventListener: vi.fn(),
+      refresh: vi.fn(),
+    };
+    (window as TestWindow).googletag = {
+      cmd: { push: vi.fn((fn: () => void) => fn()) },
+      defineSlot: vi.fn().mockReturnValue({
+        addService: vi.fn().mockReturnThis(),
+        setTargeting: vi.fn().mockReturnThis(),
+      }),
+      pubads: vi.fn().mockReturnValue(mockPubads),
+      enableServices: vi.fn(),
+    };
+    (window as TestWindow).__ts_ad_slots = [];
+    (window as TestWindow).__ts_bids = {};
+
+    const { installTsAdInit } = await import('./index');
+    installTsAdInit();
+    (window as TestWindow).__tsAdInit!();
+
+    expect(mockPubads.refresh).toHaveBeenCalled();
+  });
+});