Testing

import { describe, expect, it } from 'vitest';
import {
  tunnelListResponseSchema,
  tunnelTelemetryIngestRequestSchema
} from '../src/contracts.ts';

describe('shared contracts', () => {
  it('accepts tunnel list entries with lease null or object', () => {
    const parsed = tunnelListResponseSchema.parse([
      {
        id: '11111111-1111-1111-1111-111111111111',
        hostname: 'demo.tunnel.example.com',
        slug: 'demo',
        status: 'active',
        requestedPort: 3000,
        createdAt: '2026-01-01T00:00:00.000Z',
        lease: null,
        stoppedAt: null,
        lastError: null,
      }
    ]);

    expect(parsed.length).toBe(1);
    expect(parsed[0]?.lease).toBeNull();
  });

  it('rejects telemetry payloads with more than 200 requests', () => {
    const payload = {
      region: null,
      metrics: { /* ... */ },
      requests: Array.from({ length: 201 }, () => ({ /* ... */ }))
    };

    expect(() => tunnelTelemetryIngestRequestSchema.parse(payload))
      .toThrow();
  });
});

import { describe, expect, it } from 'vitest';
import { startLocalProxy } from './local-proxy.js';

describe('startLocalProxy', () => {
  it('forwards HTTP requests and tracks connections', async () => {
    const requestEvents = [];
    const connectionEvents = [];

    const backend = await listenHttpServer((req, res) => {
      if (req.url === '/ok') {
        res.writeHead(200, { 'content-type': 'text/plain' });
        res.end('ok');
        return;
      }
      res.writeHead(404);
      res.end('not found');
    });

    const proxy = await startLocalProxy({
      targetPort: backend.port,
      onRequest: (event) => requestEvents.push(event),
      onConnectionChange: (snapshot) => connectionEvents.push(snapshot),
    });

    try {
      const response = await fetch(
        `http://127.0.0.1:${proxy.port}/ok`,
        { headers: { connection: 'close' } }
      );

      expect(response.status).toBe(200);
      expect(await response.text()).toBe('ok');
      expect(requestEvents.length).toBe(1);
      expect(requestEvents[0]?.statusCode).toBe(200);
    } finally {
      await proxy.stop();
      await closeServer(backend.server);
    }
  });
});