chore: add pino

package.json

@@ -102,6 +102,7 @@
  "luxon": "^3.4.4",
  "node-fetch": "^3.3.2",
  "openid-client": "^5.6.4",
+ "pino": "^8.17.2",
  "postmark": "^4.0.2",
  "prisma": "^5.8.0",
  "yargs": "^17.7.2",

src/lib/fastify/logging.ts

@@ -1,12 +1,11 @@
-import type { FastifyServerOptions } from "fastify";
-import type { PinoLoggerOptions } from "fastify/types/logger.js";
+import type { LoggerOptions } from "pino";
 import { env } from "~/config.js";
 
 /**
  * Redact personally identifiable information (PII) from logs
  * to try to be GDPR compliant, and avoid storing sensitive data in logs.
  */
-const redact: PinoLoggerOptions["redact"] = [
+const redact: LoggerOptions["redact"] = [
  "*.firstName",
  "*.lastName",
  "*.email",
@@ -17,7 +16,7 @@ const redact: PinoLoggerOptions["redact"] = [
 
 export const envToLogger: Record<
  "development" | "production" | "test",
- Exclude<FastifyServerOptions["logger"], boolean>
+ Omit<LoggerOptions, "hooks">
 > = {
  development: {
  enabled: env.LOG_ENABLED,

src/services/mail/worker.ts

@@ -1,5 +1,6 @@
 import type { User } from "@prisma/client";
 import type { Processor } from "bullmq";
+import type { Logger } from "pino";
 import type { MailService } from "./index.js";
 
 type UserRepository = {
@@ -9,16 +10,16 @@ type UserRepository = {
 const MailWorker = (
  mailService: MailService,
  userRepository: UserRepository,
+ log?: Logger,
 ): Processor<
  { subject: string; receiverId: string },
  { status: string },
  "waitlist" | "welcome"
 > => {
  return async (job) => {
+ log?.info({ job: { name: job.name, data: job.data } }, "starting job");
  const { subject, receiverId } = job.data;
- console.log("sending email", job.name);
  const user = await userRepository.get(receiverId);
- console.log("Sending email to", user.id);
  switch (job.name) {
  case "waitlist":
  await mailService.send({

src/worker.ts

@@ -1,6 +1,8 @@
 import { Worker } from "bullmq";
 import { Redis } from "ioredis";
+import { pino } from "pino";
 import { env } from "./config.js";
+import { envToLogger } from "./lib/fastify/logging.js";
 import postmark from "./lib/postmark.js";
 import prisma from "./lib/prisma.js";
 import { UserRepository } from "./repositories/users/index.js";
@@ -12,7 +14,7 @@ export function initWorkers() {
  keepAlive: 1_000 * 60 * 3, // 3 minutes
  maxRetriesPerRequest: 0,
  });
-
+ const logger = pino(envToLogger[env.NODE_ENV]);
  const mailService = new MailService(postmark, env.NO_REPLY_EMAIL);
  const userRepository = new UserRepository(prisma);
  const worker = new Worker<