test-integration.js

// node test-integration.js
// Sends a realistic batch to localhost:3737/ingest and prints the result.

const ENDPOINT = 'http://localhost:3737/ingest';
const ORG_ID = 'test-org';

const batch = {
  sdkVersion: '0.1.0',
  sentAt: Date.now(),
  events: [
    {
      count: 3,
      dedupeKey: JSON.stringify({ method: 'GET', domain: 'api.example.com', path: '/users', keys: ['page'] }),
      data: {
        method: 'GET',
        protocol: 'https',
        domain: 'api.example.com',
        path: '/users',
        queryParams: { page: 'a3f2c8b4e1d9f0a1c2e3a3f2c8b4e1d9f0a1c2e3a3f2c8b4e1d9f0a1c2e3aabb' },
        requestHeaders: { authorization: 'a3f2c8b4e1d9f0a1c2e3aabb d9f0a1c2e3a3f2c8b4e1d9f0a1c2e3aabbccdd' },
        requestBody: null,
        responseStatus: 200,
        responseHeaders: { 'content-type': 'a3f2c8b4e1d9f0a1c2e3aabbccdd1122334455667788990011223344556677889900' },
        responseBody: { type: 'json', data: { users: [{ id: 'hashhashhash', name: 'hashhashhash' }] } },
        timestamp: Date.now() - 200,
        duration: 142,
      },
    },
    {
      count: 1,
      dedupeKey: JSON.stringify({ method: 'POST', domain: 'api.example.com', path: '/graphql', keys: [], op: 'GetCurrentUser' }),
      data: {
        method: 'POST',
        protocol: 'https',
        domain: 'api.example.com',
        path: '/graphql',
        queryParams: {},
        requestHeaders: { 'content-type': 'a3f2c8b4e1d9f0a1c2e3aabb' },
        requestBody: { type: 'graphql', operationName: 'GetCurrentUser', data: { query: 'hashhashhash', variables: { id: 'hashhashhash' } } },
        responseStatus: 200,
        responseHeaders: {},
        responseBody: { type: 'graphql', operationName: 'GetCurrentUser', data: { data: { me: { id: 'hashhashhash' } } } },
        timestamp: Date.now() - 100,
        duration: 88,
        graphqlOperationName: 'GetCurrentUser',
      },
    },
  ],
};

const res = await fetch(ENDPOINT, {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'X-Org-Id': ORG_ID,
  },
  body: JSON.stringify(batch),
});

console.log(`POST ${ENDPOINT}  →  ${res.status} ${res.statusText}`);
if (!res.ok) {
  const text = await res.text();
  console.error('Response body:', text);
  process.exit(1);
}
console.log('OK — check server output for the parsed batch.');