Function shadowCapture

api/src/plugins/shadow-capture.ts:26–60

(fastify, _options, done)

 * @param done Callback to signal that the logic has completed.
 */
const shadowCapture: FastifyPluginCallback = (fastify, _options, done) => {
  mkdirSync(LOGS_DIRECTORY, { recursive: true });
  fastify.addHook('onRequest', (req, rep, done) => {
    // Attach timestamp at beginning of lifecycle
    // @ts-expect-error Exists
    req.__timestamp = Date.now();

    // Give request and response same id to match.
    const id = randomUUID();
    // @ts-expect-error Exists
    req.__id = id;
    // @ts-expect-error Exists
    rep.__id = id;
    done();
  });

  // Body is only included after `Parsing` lifecycle
  fastify.addHook('preValidation', (req, rep, done) => {
    captureRequest(req);
    done();
  });

  fastify.addHook('onSend', async (_req, rep, payload) => {
    // @ts-expect-error Exists
    rep.__payload = payload;
    return payload;
  });

  fastify.addHook('onResponse', (_req, rep, done) => {
    captureReply(rep);
    done();
  });

  done();
};

/* eslint-disable @typescript-eslint/no-unsafe-assignment */
function captureRequest(req: FastifyRequest) {