bun.test.ts

import { beforeAll, afterAll } from 'bun:test';
import { $ } from 'bun';
import net from 'node:net';

let startedLocalRedis = false;

async function isTcpPortReachable(host: string, port: number): Promise<boolean> {
  return new Promise((resolve) => {
    const socket = net.createConnection({ host, port });

    socket.setTimeout(1_000);
    socket.once('connect', () => {
      socket.end();
      resolve(true);
    });
    socket.once('timeout', () => {
      socket.destroy();
      resolve(false);
    });
    socket.once('error', () => {
      socket.destroy();
      resolve(false);
    });
  });
}

beforeAll(async () => {
  if (await isTcpPortReachable('127.0.0.1', 6379)) {
    return;
  }

  await $`docker compose up redis -d`;
  startedLocalRedis = true;
});

afterAll(async () => {
  const { redis } = await import('./server/redis.js');
  await redis.close();

  if (startedLocalRedis) {
    await $`docker compose down`;
  }
});