chore: clean up logging

rubberdok · Jan 11, 2024 · d22a190 · d22a190
1 parent f66ff11
commit d22a190
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/worker.ts b/src/worker.ts
@@ -21,18 +21,19 @@ export function initWorkers() {
  { subject: string; receiverId: string },
  { status: string },
  "welcome" | "waitlist"
- >("email", MailWorker(mailService, userRepository), {
+ >("email", MailWorker(mailService, userRepository, logger), {
  connection: redis,
+ }).on("ready", () => {
+ logger.info("Mail worker ready");
  });
 
  const gracefulShutdown = async (signal: "SIGINT" | "SIGTERM") => {
- console.log(`Received ${signal}, closing server...`);
+ logger.info(`Received ${signal}, closing server...`);
  await worker.close();
  await redis.quit();
  process.exit(0);
  };
 
  process.on("SIGINT", () => gracefulShutdown("SIGINT"));
-
  process.on("SIGTERM", () => gracefulShutdown("SIGTERM"));
 }