Add EventBatcher transport

packages/browser/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@hawk.so/browser",
-  "version": "3.4.0",
+  "version": "3.4.1",
   "description": "JavaScript Browser errors tracking for Hawk.so",
   "files": [
     "dist"
@@ -45,7 +45,7 @@
     "web-vitals": "^5.1.0"
   },
   "devDependencies": {
-    "@hawk.so/types": "0.5.8",
+    "@hawk.so/types": "0.6.4",
     "@vitest/coverage-v8": "^4.0.18",
     "jsdom": "^28.0.0",
     "vite": "^7.3.1",

packages/browser/src/catcher.ts

@@ -7,7 +7,7 @@ import type { VueIntegrationAddons } from '@hawk.so/types';
 import type { JavaScriptCatcherIntegrations } from '@/types';
 import { ConsoleCatcher } from './addons/consoleCatcher';
 import { BrowserBreadcrumbStore } from './addons/breadcrumbs';
-import { BaseCatcher, HawkUserManager, isLoggerSet, log, setLogger, decodeIntegrationId } from '@hawk.so/core';
+import { BaseCatcher, HawkUserManager, isLoggerSet, log, setLogger, decodeIntegrationId, EventDedupeTransport } from '@hawk.so/core';
 import { HawkLocalStorage } from './utils/hawk-local-storage';
 import { createBrowserLogger } from './utils/logger';
 import { BrowserRandomGenerator } from './utils/random';
@@ -112,6 +112,11 @@ export default class Catcher extends BaseCatcher<typeof Catcher.type> {
         },
       });
 
+    const batcher = new EventDedupeTransport(transport);
+
+    // Flush buffered events before the socket closes on page hide
+    window.addEventListener('pagehide', () => batcher.flush(), { capture: true });
+
     let breadcrumbStore: BrowserBreadcrumbStore | null = null;
 
     if (token && settings.breadcrumbs !== false) {
@@ -120,7 +125,7 @@ export default class Catcher extends BaseCatcher<typeof Catcher.type> {
 
     super(
       token,
-      transport,
+      batcher,
       userManager,
       settings.release !== undefined ? String(settings.release) : undefined,
       settings.context || undefined,

packages/browser/tests/catcher.addons.test.ts

@@ -1,4 +1,4 @@
-import { describe, it, expect, vi, beforeEach } from 'vitest';
+import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';
 import type * as HawkCore from '@hawk.so/core';
 import { BrowserBreadcrumbStore } from '../src/addons/breadcrumbs';
 import { wait, createTransport, getLastPayload, createCatcher } from './catcher.helpers';
@@ -21,6 +21,11 @@ describe('Catcher', () => {
     localStorage.clear();
     mockParse.mockResolvedValue([]);
     breadcrumbStore.instance?.destroy();
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
   });
 
   // ── Environment addons ────────────────────────────────────────────────────

packages/browser/tests/catcher.before-send.test.ts

@@ -1,4 +1,4 @@
-import { describe, it, expect, vi } from 'vitest';
+import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';
 import { createCatcher, createTransport, wait, getLastPayload } from './catcher.helpers';
 
 vi.mock('@hawk.so/core', async (importOriginal) => {
@@ -7,6 +7,14 @@ vi.mock('@hawk.so/core', async (importOriginal) => {
 });
 
 describe('Catcher', () => {
+  beforeEach(() => {
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
+  });
+
   it('should send event as-is when beforeSend returns it unchanged', async () => {
     const { sendSpy, transport } = createTransport();
     const hawk = createCatcher(transport, { beforeSend: (event) => event });

packages/browser/tests/catcher.breadcrumbs.test.ts

@@ -1,4 +1,4 @@
-import { describe, it, expect, vi, beforeEach } from 'vitest';
+import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';
 import { BrowserBreadcrumbStore } from '../src/addons/breadcrumbs';
 import { wait, createTransport, getLastPayload, createCatcher } from './catcher.helpers';
 
@@ -13,6 +13,11 @@ describe('Catcher', () => {
     localStorage.clear();
     mockParse.mockResolvedValue([]);
     (BrowserBreadcrumbStore as any).instance?.destroy();
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
   });
 
   // ── Breadcrumbs trail ─────────────────────────────────────────────────────

packages/browser/tests/catcher.context.test.ts

@@ -1,4 +1,4 @@
-import { describe, it, expect, vi, beforeEach } from 'vitest';
+import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';
 import { BrowserBreadcrumbStore } from '../src/addons/breadcrumbs';
 import { wait, createTransport, getLastPayload, createCatcher } from './catcher.helpers';
 
@@ -13,6 +13,11 @@ describe('Catcher', () => {
     localStorage.clear();
     mockParse.mockResolvedValue([]);
     (BrowserBreadcrumbStore as any).instance?.destroy();
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
   });
 
   // ── Context enrichment ────────────────────────────────────────────────────

packages/browser/tests/catcher.global-handlers.test.ts

@@ -14,6 +14,11 @@ describe('Catcher', () => {
     localStorage.clear();
     mockParse.mockResolvedValue([]);
     (BrowserBreadcrumbStore as any).instance?.destroy();
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
   });
 
   // ── Global error handlers ─────────────────────────────────────────────────

packages/browser/tests/catcher.helpers.ts

@@ -2,9 +2,16 @@ import { vi } from 'vitest';
 import Catcher from '../src/catcher';
 import type { Transport } from '../src';
 import type { MessageProcessor } from '@hawk.so/core';
+import { DEFAULT_EVENT_DEDUPE_WINDOW_MS } from '@hawk.so/core';
 
 export const TEST_TOKEN = 'eyJpbnRlZ3JhdGlvbklkIjoiOTU3MmQyOWQtNWJhZS00YmYyLTkwN2MtZDk5ZDg5MGIwOTVmIiwic2VjcmV0IjoiZTExODFiZWItMjdlMS00ZDViLWEwZmEtZmUwYTM1Mzg5OWMyIn0=';
-export const wait = (): Promise<void> => new Promise((r) => setTimeout(r, 0));
+
+/**
+ * Advances past the Catcher's default EventDedupeTransport window so buffered
+ * events are forwarded to the underlying transport. Requires fake timers
+ * (`vi.useFakeTimers()`) to be active in the calling test file.
+ */
+export const wait = (): Promise<void> => vi.advanceTimersByTimeAsync(DEFAULT_EVENT_DEDUPE_WINDOW_MS);
 
 export function createTransport() {
   const sendSpy = vi.fn().mockResolvedValue(undefined);

packages/browser/tests/catcher.message-processor.test.ts

@@ -1,4 +1,4 @@
-import { describe, expect, it, vi } from 'vitest';
+import { describe, expect, it, vi, beforeEach, afterEach } from 'vitest';
 import { createCatcher, createTransport, getLastPayload, injectProcessor, wait } from './catcher.helpers';
 import { MessageProcessor, ProcessingPayload } from '@hawk.so/core';
 
@@ -10,6 +10,14 @@ vi.mock('../src/modules/stackParser', () => ({
 }));
 
 describe('Catcher', () => {
+  beforeEach(() => {
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
+  });
+
   describe('message processor', () => {
     it('should send original message when processor does not modify it', async () => {
       const { sendSpy, transport } = createTransport();

packages/browser/tests/catcher.release.test.ts

@@ -1,4 +1,4 @@
-import { describe, expect, it, vi } from "vitest";
+import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
 import { createCatcher, createTransport, getLastPayload, wait } from "./catcher.helpers";
 
 vi.mock('@hawk.so/core', async (importOriginal) => {
@@ -7,6 +7,14 @@ vi.mock('@hawk.so/core', async (importOriginal) => {
 });
 
 describe('Catcher', () => {
+  beforeEach(() => {
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
+  });
+
   it('should include release version when configured', async () => {
     const { sendSpy, transport } = createTransport();
 

packages/browser/tests/catcher.test.ts

@@ -17,6 +17,11 @@ describe('Catcher', () => {
     localStorage.clear();
     mockParse.mockResolvedValue([]);
     (BrowserBreadcrumbStore as any).instance?.destroy();
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
   });
 
   // ── Constructor variants ──────────────────────────────────────────────────
@@ -114,15 +119,16 @@ describe('Catcher', () => {
       expect(sendSpy).toHaveBeenCalledTimes(2);
     });
 
-    it('should send payload for same strings without deduplication', async () => {
+    it('should merge repeated identical string occurrences into a single send with count', async () => {
       const { sendSpy, transport } = createTransport();
       const hawk = createCatcher(transport);
 
       hawk.send('reason');
       hawk.send('reason');
       await wait();
 
-      expect(sendSpy).toHaveBeenCalledTimes(2);
+      expect(sendSpy).toHaveBeenCalledTimes(1);
+      expect(sendSpy.mock.calls[0][0].count).toBe(2);
     });
   });
 

packages/browser/tests/catcher.transport.test.ts

@@ -1,4 +1,4 @@
-import { describe, it, expect, vi, beforeEach } from 'vitest';
+import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';
 import { BrowserBreadcrumbStore } from '../src/addons/breadcrumbs';
 import type { Transport } from '../src';
 import { wait, createCatcher, createTransport } from './catcher.helpers';
@@ -14,6 +14,11 @@ describe('Catcher', () => {
     localStorage.clear();
     mockParse.mockResolvedValue([]);
     (BrowserBreadcrumbStore as any).instance?.destroy();
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
   });
 
   describe('transport failure', () => {

packages/browser/tests/catcher.user.test.ts

@@ -1,4 +1,4 @@
-import { describe, it, expect, vi, beforeEach } from 'vitest';
+import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';
 import { BrowserBreadcrumbStore } from '../src/addons/breadcrumbs';
 import { wait, createTransport, getLastPayload, createCatcher } from './catcher.helpers';
 
@@ -13,6 +13,11 @@ describe('Catcher', () => {
     localStorage.clear();
     mockParse.mockResolvedValue([]);
     (BrowserBreadcrumbStore as any).instance?.destroy();
+    vi.useFakeTimers();
+  });
+
+  afterEach(() => {
+    vi.useRealTimers();
   });
 
   // ── User identity ─────────────────────────────────────────────────────────

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@hawk.so/core",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "Base implementation for all Hawk.so JavaScript SDKs",
   "files": [
     "dist"
@@ -37,7 +37,7 @@
   },
   "homepage": "https://github.com/codex-team/hawk.javascript#readme",
   "dependencies": {
-    "@hawk.so/types": "0.5.8"
+    "@hawk.so/types": "0.6.4"
   },
   "devDependencies": {
     "@vitest/coverage-v8": "^4.0.18",

packages/core/src/index.ts

@@ -16,3 +16,5 @@ export type { MessageProcessor, ProcessingPayload } from './types/message-proces
 export { BaseCatcher } from './catcher';
 export type { BeforeSendHook } from './catcher';
 export { decodeIntegrationId } from './utils/integration-id-decoder';
+export { EventDedupeTransport, DEFAULT_EVENT_DEDUPE_WINDOW_MS } from './utils/event-dedupe-transport';
+export type { EventDedupeTransportOptions } from './utils/event-dedupe-transport';