app.ts

import * as Sentry from '@sentry/deno';
import { createClient } from 'redis';

Sentry.init({
  environment: 'qa',
  dsn: Deno.env.get('E2E_TEST_DSN'),
  debug: !!Deno.env.get('DEBUG'),
  tunnel: 'http://localhost:3031/',
  tracesSampleRate: 1,
});

// One shared client per process. node-redis publishes to the
// `node-redis:command` / `:batch` / `:connect` diagnostics channels for every
// operation on this client; denoRedisIntegration is already subscribed to
// those (it's part of the default integrations on Deno 2.7.13+).
const redis = createClient({
  url: Deno.env.get('REDIS_URL') ?? 'redis://127.0.0.1:6379',
});
redis.on('error', err => {
  // eslint-disable-next-line no-console
  console.error('redis client error', err);
});
await redis.connect();

const port = 3030;

Deno.serve({ port, hostname: '0.0.0.0' }, async (req: Request) => {
  const url = new URL(req.url);

  // GET — exercises the command channel, success path.
  if (url.pathname === '/redis-get') {
    const key = url.searchParams.get('key') ?? 'cache:key';
    const value = await redis.get(key);
    return Response.json({ key, value });
  }

  // SET then GET — exercises two commands inside a single transaction so we
  // can assert the parent has two db.redis children.
  if (url.pathname === '/redis-set-get') {
    const key = url.searchParams.get('key') ?? 'cache:key';
    const value = url.searchParams.get('value') ?? 'hello';
    await redis.set(key, value);
    const echoed = await redis.get(key);
    return Response.json({ key, value: echoed });
  }

  // MULTI — exercises the batch channel.
  if (url.pathname === '/redis-multi') {
    const result = await redis.multi().set('multi:a', '1').set('multi:b', '2').get('multi:a').exec();
    return Response.json({ result });
  }

  return new Response('Not found', { status: 404 });
});