Function healthcheck

apps/api/src/controllers/healthcheck.controller.ts:7–64

(
  request: FastifyRequest,
  reply: FastifyReply
)

import { isShuttingDown } from '@/utils/graceful-shutdown';

export async function healthcheck(
  request: FastifyRequest,
  reply: FastifyReply
) {
  const [redisResult, dbResult, chResult] = await Promise.all([
    tryCatch(async () => (await getRedisCache().ping()) === 'PONG'),
    tryCatch(async () => !!(await db.$executeRaw`SELECT 1`)),
    tryCatch(async () => (await chQuery('SELECT 1')).length > 0),
  ]);

  const dependencies = {
    redis: redisResult.ok && redisResult.data,
    db: dbResult.ok && dbResult.data,
    ch: chResult.ok && chResult.data,
  };
  const dependencyErrors = {
    redis: redisResult.error?.message,
    db: dbResult.error?.message,
    ch: chResult.error?.message,
  };

  const failedDependencies = Object.entries(dependencies)
    .filter(([, ok]) => !ok)
    .map(([name]) => name);
  const workingDependencies = Object.entries(dependencies)
    .filter(([, ok]) => ok)
    .map(([name]) => name);

  const status = failedDependencies.length === 0 ? 200 : 503;

  if (status === 200) {
    request.log.debug(
      {
        workingDependencies,
        failedDependencies,
        dependencies,
      },
      'healthcheck passed'
    );
  } else {
    request.log.warn(
      {
        workingDependencies,
        failedDependencies,
        dependencies,
        dependencyErrors,
      },
      'healthcheck failed'
    );
  }

  return reply.status(status).send({
    ready: status === 200,
    ...dependencies,
    failedDependencies,
    workingDependencies,
  });
}