From bb29b2070f667a6fe20365e67064c9a7e578062c Mon Sep 17 00:00:00 2001
From: aar2dee2 <85004512+aar2dee2@users.noreply.github.com>
Date: Thu, 31 Aug 2023 15:49:15 +0530
Subject: [PATCH] use logger for console logs

---
 packages/app-store/_utils/nodeScheduler.ts | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/packages/app-store/_utils/nodeScheduler.ts b/packages/app-store/_utils/nodeScheduler.ts
index 9f03228401..a5e3ee6293 100644
--- a/packages/app-store/_utils/nodeScheduler.ts
+++ b/packages/app-store/_utils/nodeScheduler.ts
@@ -4,11 +4,14 @@ import { v4 } from "uuid";
 
 import { getHumanReadableLocationValue } from "@calcom/core/location";
 import { getCalEventResponses } from "@calcom/features/bookings/lib/getCalEventResponses";
+import logger from "@calcom/lib/logger";
 import { getTranslation } from "@calcom/lib/server";
 import prisma from "@calcom/prisma";
 import type { ApiKey } from "@calcom/prisma/client";
 import { BookingStatus, WebhookTriggerEvents } from "@calcom/prisma/enums";
 
+const log = logger.getChildLogger({ prefix: ["[node-scheduler]"] });
+
 export async function addSubscription({
   appApiKey,
   triggerEvent,
@@ -58,7 +61,7 @@ export async function addSubscription({
 
     return createSubscription;
   } catch (error) {
-    return console.error(
+    return log.error(
       `Error creating subscription for user ${appApiKey.userId} and appId ${appApiKey.appId}.`
     );
   }
@@ -117,7 +120,7 @@ export async function deleteSubscription({
     }
     return deleteWebhook;
   } catch (err) {
-    return console.error(
+    return log.error(
       `Error deleting subscription for user ${appApiKey.userId}, webhookId ${webhookId}, appId ${appId}`
     );
   }
@@ -196,7 +199,7 @@ export async function listBookings(appApiKey: ApiKey) {
 
     return updatedBookings;
   } catch (err) {
-    return console.error(
+    return log.error(
       `Error retrieving list of bookings for user ${appApiKey.userId} and appId ${appApiKey.appId}.`
     );
   }
@@ -248,7 +251,7 @@ export async function scheduleTrigger(
       },
     });
   } catch (error) {
-    console.error("Error cancelling scheduled jobs", error);
+    log.error("Error cancelling scheduled jobs", error);
   }
 }
 
@@ -291,6 +294,6 @@ export async function cancelScheduledJobs(
   try {
     await Promise.all(promises);
   } catch (error) {
-    console.error("Error cancelling scheduled jobs", error);
+    log.error("Error cancelling scheduled jobs", error);
   }
 }