refactor: Run console to pino

apps/api/v1/lib/helpers/captureErrors.ts

@@ -1,13 +1,15 @@
+import pino from 'pino'
 import { captureException as SentryCaptureException } from "@sentry/nextjs";
 import type { NextMiddleware } from "next-api-middleware";
+const logger = pino()
 
 export const captureErrors: NextMiddleware = async (_req, res, next) => {
   try {
     // Catch any errors that are thrown in remaining
     // middleware and the API route handler
     await next();
   } catch (error) {
-    console.error(error);
+    logger.error(error);
     SentryCaptureException(error);
     res.status(500).json({ message: "Something went wrong" });
   }

apps/api/v1/lib/helpers/safeParseJSON.ts

@@ -1,8 +1,10 @@
+import pino from 'pino'
+const logger = pino()
 export default function parseJSONSafely(str: string) {
   try {
     return JSON.parse(str);
   } catch (e) {
-    console.error((e as Error).message);
+    logger.error((e as Error).message);
     if ((e as Error).message.includes("Unexpected token")) {
       return {
         success: false,

apps/api/v1/pages/api/slots/_get.test.ts

@@ -1,4 +1,6 @@
+import pino from 'pino'
 import prismock from "../../../../../../tests/libs/__mocks__/prisma";
+const logger = pino()
 
 import type { Request, Response } from "express";
 import type { NextApiRequest, NextApiResponse } from "next";
@@ -60,7 +62,7 @@ describe("GET /api/slots", () => {
         });
         buildMockData();
         await handler(req, res);
-        console.log({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
+        logger.info({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
         const response = JSON.parse(res._getData());
         expect(response.slots).toEqual(expect.objectContaining({}));
       });
@@ -78,7 +80,7 @@ describe("GET /api/slots", () => {
         });
         buildMockData();
         await handler(req, res);
-        console.log({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
+        logger.info({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
         const response = JSON.parse(res._getData());
         expect(response.slots).toEqual(expect.objectContaining({}));
       });

apps/api/v1/test/lib/bookings/_auth-middleware.integration-test.ts

@@ -1,7 +1,9 @@
+import pino from 'pino'
 import type { Request, Response } from "express";
 import type { NextApiRequest, NextApiResponse } from "next";
 import { createMocks } from "node-mocks-http";
 import { describe, it, expect, test, beforeAll, afterAll } from "vitest";
+const logger = pino()
 
 import { prisma } from "@calcom/prisma";
 import type { User, Team, Prisma } from "@calcom/prisma/client";
@@ -181,13 +183,13 @@ describe("Booking ownership and access in Middleware", () => {
   });
 
   afterAll(async () => {
-    console.log("Cleaning up org", orgRef.id);
+    logger.info("Cleaning up org", orgRef.id);
     await prisma.team.delete({
       where: {
         id: orgRef.id,
       },
     });
-    console.log("Cleaning up users", [
+    logger.info("Cleaning up users", [
       adminUserRef.id,
       ownerUserRef.id,
       orgOwnerUserRef.id,
@@ -203,7 +205,7 @@ describe("Booking ownership and access in Middleware", () => {
   });
 
   test("should not throw error for bookings where user is an attendee", async () => {
-    console.log(createEventResult1.bookings[0].id);
+    logger.info(createEventResult1.bookings[0].id);
     const { req } = createMocks<CustomNextApiRequest, CustomNextApiResponse>({
       method: "GET",
       query: {

apps/api/v1/test/lib/bookings/_get.integration-test.ts

@@ -1,8 +1,10 @@
+import pino from 'pino'
 import type { Request, Response } from "express";
 import type { NextApiRequest, NextApiResponse } from "next";
 import { createMocks } from "node-mocks-http";
 import { describe, expect, it, beforeAll } from "vitest";
 import { ZodError } from "zod";
+const logger = pino()
 
 import { prisma } from "@calcom/prisma";
 
@@ -399,7 +401,7 @@ describe("GET /api/bookings", async () => {
           .filter(([_, count]) => count > 1)
           .map(([id]) => id);
 
-        console.log(`Found duplicate booking IDs: ${duplicates.join(", ")}`);
+        logger.info(`Found duplicate booking IDs: ${duplicates.join(", ")}`);
       }
     });
   });

apps/api/v1/test/lib/bookings/_post.test.ts

@@ -1,3 +1,5 @@
+import pino from 'pino'
+const logger = pino()
 // TODO: Fix tests (These test were never running due to the vitest workspace config)
 import prismaMock from "../../../../../../tests/libs/__mocks__/prismaMock";
 
@@ -385,7 +387,7 @@ describe("POST /api/bookings", () => {
       });
 
       await handler(req, res);
-      console.log({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
+      logger.info({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
 
       expect(res._getStatusCode()).toBe(400);
       expect(JSON.parse(res._getData())).toEqual(
@@ -453,7 +455,7 @@ describe("POST /api/bookings", () => {
         });
 
         await handler(req, res);
-        console.log({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
+        logger.info({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
         createdBooking = JSON.parse(res._getData());
         expect(prismaMock.booking.create).toHaveBeenCalledTimes(1);
       });
@@ -530,7 +532,7 @@ describe("POST /api/bookings", () => {
         });
 
         await handler(req, res);
-        console.log({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
+        logger.info({ statusCode: res._getStatusCode(), data: JSON.parse(res._getData()) });
         const rescheduledBooking = JSON.parse(res._getData()) as Booking;
         expect(prismaMock.booking.create).toHaveBeenCalledTimes(1);
         expect(rescheduledBooking.fromReschedule).toEqual("original-booking-uid");

apps/api/v2/scripts/docker-start.ts

@@ -1,4 +1,6 @@
+import pino from 'pino'
 import { execSync } from "child_process";
+const logger = pino()
 
 function checkCommandExists(command: string): boolean {
   try {
@@ -18,18 +20,18 @@ try {
   // Try docker compose first (new syntax)
   try {
     execSync("docker compose version", { stdio: "ignore" });
-    console.log("Starting containers with docker compose...");
+    logger.info("Starting containers with docker compose...");
     execSync("docker compose up -d", { stdio: "inherit" });
   } catch (e) {
     // Fall back to docker-compose if the above fails
     if (checkCommandExists("docker-compose")) {
-      console.log("Starting containers with docker-compose...");
+      logger.info("Starting containers with docker-compose...");
       execSync("docker-compose up -d", { stdio: "inherit" });
     } else {
       throw new Error("Neither 'docker compose' nor 'docker-compose' command is available");
     }
   }
 } catch (error) {
-  console.error(`Error: ${error instanceof Error ? error.message : "Unknown error occurred"}`);
+  logger.error(`Error: ${error instanceof Error ? error.message : "Unknown error occurred"}`);
   process.exit(1);
 }

apps/api/v2/src/ee/calendars/services/calendars.service.ts

@@ -1,7 +1,9 @@
+import pino from 'pino'
 import { CalendarsRepository } from "@/ee/calendars/calendars.repository";
 import { CalendarsCacheService } from "@/ee/calendars/services/calendars-cache.service";
 import { AppsRepository } from "@/modules/apps/apps.repository";
 import {
+const logger = pino()
   CredentialsRepository,
   CredentialsWithUserEmail,
 } from "@/modules/credentials/credentials.repository";
@@ -75,7 +77,7 @@ export class CalendarsService {
       eventTypeId: null,
       prisma: this.dbWrite.prisma as unknown as PrismaClient,
     });
-    console.log("saving cache", JSON.stringify(result));
+    logger.info("saving cache", JSON.stringify(result));
     await this.calendarsCacheService.setConnectedAndDestinationCalendarsCache(userId, result);
 
     return result;

apps/api/v2/src/ee/event-types/event-types_2024_06_14/controllers/event-types.controller.e2e-spec.ts

@@ -1,3 +1,4 @@
+import pino from 'pino'
 import { bootstrap } from "@/app";
 import { AppModule } from "@/app.module";
 import { CreateEventTypeInput_2024_04_15 } from "@/ee/event-types/event-types_2024_04_15/inputs/create-event-type.input";
@@ -21,6 +22,7 @@ import { TeamRepositoryFixture } from "test/fixtures/repository/team.repository.
 import { UserRepositoryFixture } from "test/fixtures/repository/users.repository.fixture";
 import { randomString } from "test/utils/randomString";
 import { withApiAuth } from "test/utils/withApiAuth";
+const logger = pino()
 
 
 
@@ -1609,23 +1611,23 @@ describe("Event types Endpoints", () => {
       try {
         await eventTypesRepositoryFixture.delete(eventType.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       try {
         await userRepositoryFixture.delete(user.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       try {
         await userRepositoryFixture.delete(falseTestUser.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
 
       try {
         await userRepositoryFixture.delete(orgUser.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       await app.close();
     });
@@ -2588,12 +2590,12 @@ describe("Event types Endpoints", () => {
         await eventTypesRepositoryFixture.delete(legacyEventTypeId1);
         await eventTypesRepositoryFixture.delete(legacyEventTypeId2);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       try {
         await userRepositoryFixture.delete(user.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       await app.close();
     });
@@ -2783,12 +2785,12 @@ describe("Event types Endpoints", () => {
       try {
         await eventTypesRepositoryFixture.delete(legacyEventTypeId1);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       try {
         await userRepositoryFixture.delete(user.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       await app.close();
     });

apps/api/v2/src/main.ts

@@ -1,18 +1,20 @@
+import pino from 'pino'
 import type { AppConfig } from "@/config/type";
 import { Logger } from "@nestjs/common";
 import { ConfigService } from "@nestjs/config";
 import { NestFactory } from "@nestjs/core";
 import type { NestExpressApplication } from "@nestjs/platform-express";
 import "dotenv/config";
 import { WinstonModule } from "nest-winston";
+const logger = pino()
 
 import { bootstrap } from "./app";
 import { AppModule } from "./app.module";
 import { loggerConfig } from "./lib/logger";
 import { generateSwaggerForApp } from "./swagger/generate-swagger";
 
 run().catch((error: Error) => {
-  console.error("Failed to start Cal Platform API", { error: error.stack });
+  logger.error("Failed to start Cal Platform API", { error: error.stack });
   process.exit(1);
 });
 
@@ -27,7 +29,7 @@ async function run() {
     await app.listen(port);
     logger.log(`Application started on port: ${port}`);
   } catch (error) {
-    console.error(error);
+    logger.error(error);
     logger.error("Application crashed", {
       error,
     });

apps/api/v2/src/modules/oauth-clients/controllers/oauth-client-users/oauth-client-users.controller.e2e-spec.ts

@@ -1,3 +1,4 @@
+import pino from 'pino'
 import { bootstrap } from "@/app";
 import { AppModule } from "@/app.module";
 import { DEFAULT_EVENT_TYPES } from "@/ee/event-types/event-types_2024_04_15/constants/constants";
@@ -25,6 +26,7 @@ import { SchedulesRepositoryFixture } from "test/fixtures/repository/schedules.r
 import { TeamRepositoryFixture } from "test/fixtures/repository/team.repository.fixture";
 import { UserRepositoryFixture } from "test/fixtures/repository/users.repository.fixture";
 import { randomString } from "test/utils/randomString";
+const logger = pino()
 
 import { SUCCESS_STATUS } from "@calcom/platform-constants";
 import { slugify } from "@calcom/platform-libraries";
@@ -817,17 +819,17 @@ describe("OAuth Client Users Endpoints", () => {
       try {
         await userRepositoryFixture.delete(postResponseData.user.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       try {
         await userRepositoryFixture.delete(postResponseData2.user.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       try {
         await userRepositoryFixture.delete(platformAdmin.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       await app.close();
     });
@@ -1036,7 +1038,7 @@ describe("OAuth Client Users Endpoints", () => {
       try {
         await userRepositoryFixture.delete(postResponseData.user.id);
       } catch (e) {
-        console.log(e);
+        logger.info(e);
       }
       await app.close();
     });

apps/api/v2/src/modules/organizations/conferencing/organizations-conferencing.controller.ts

@@ -1,3 +1,4 @@
+import pino from 'pino'
 import { API_VERSIONS_VALUES } from "@/lib/api-versions";
 import { PlatformPlan } from "@/modules/auth/decorators/billing/platform-plan.decorator";
 import { GetUser } from "@/modules/auth/decorators/get-user/get-user.decorator";
@@ -9,6 +10,7 @@ import { IsOrgGuard } from "@/modules/auth/guards/organizations/is-org.guard";
 import { RolesGuard } from "@/modules/auth/guards/roles/roles.guard";
 import { IsTeamInOrg } from "@/modules/auth/guards/teams/is-team-in-org.guard";
 import {
+const logger = pino()
   ConferencingAppsOauthUrlOutputDto,
   GetConferencingAppsOauthUrlResponseDto,
 } from "@/modules/conferencing/outputs/get-conferencing-apps-oauth-url";
@@ -256,7 +258,7 @@ export class OrganizationsConferencingController {
       });
     } catch (error) {
       if (error instanceof Error) {
-        console.error(error.message);
+        logger.error(error.message);
       }
       return {
         url: decodedCallbackState.onErrorReturnTo ?? "",

apps/api/v2/src/modules/organizations/stripe/organizations-stripe.controller.ts

@@ -1,3 +1,4 @@
+import pino from 'pino'
 import { API_VERSIONS_VALUES } from "@/lib/api-versions";
 import { PlatformPlan } from "@/modules/auth/decorators/billing/platform-plan.decorator";
 import { GetUser } from "@/modules/auth/decorators/get-user/get-user.decorator";
@@ -10,6 +11,7 @@ import { RolesGuard } from "@/modules/auth/guards/roles/roles.guard";
 import { IsTeamInOrg } from "@/modules/auth/guards/teams/is-team-in-org.guard";
 import { OrganizationsStripeService } from "@/modules/organizations/stripe/services/organizations-stripe.service";
 import {
+const logger = pino()
   StripConnectOutputDto,
   StripConnectOutputResponseDto,
   StripCredentialsCheckOutputResponseDto,
@@ -149,7 +151,7 @@ export class OrganizationsStripeController {
       );
     } catch (error) {
       if (error instanceof Error) {
-        console.error(error.message);
+        logger.error(error.message);
       }
       return {
         url: decodedCallbackState.onErrorReturnTo ?? "",