feat: async tasker for google calendar events

apps/api/v2/package.json

@@ -38,7 +38,7 @@
     "@axiomhq/winston": "^1.2.0",
     "@calcom/platform-constants": "*",
     "@calcom/platform-enums": "*",
-    "@calcom/platform-libraries": "npm:@calcom/platform-libraries@0.0.335",
+    "@calcom/platform-libraries": "npm:@calcom/platform-libraries@9.9.9",
     "@calcom/platform-types": "*",
     "@calcom/platform-utils": "*",
     "@calcom/prisma": "*",

apps/api/v2/src/lib/logger.bridge.ts

@@ -1,4 +1,4 @@
-import { Injectable, Logger as NestLogger, Scope } from "@nestjs/common";
+import { Logger as NestLogger } from "@nestjs/common";
 
 // 1. Define an interface for the settings
 interface IMyLoggerSettings {
@@ -22,7 +22,7 @@ const LogLevel = {
  * from platform libraries. It forwards logs to NestLogger, allowing centralization
  * (e.g., sending to Axiom) and adds an optional prefix for context.
  */
-@Injectable({ scope: Scope.TRANSIENT }) // TRANSIENT ensures getSubLogger provides truly independent instances if needed elsewhere
+// TODO: now that we have dependency injection, we need to correctly handle adding the request object to this logger using decorators on api v2
 export class Logger {
   // Use NestLogger for the actual logging output
   private readonly nestLogger = new NestLogger("LoggerBridge");

apps/api/v2/src/lib/modules/google-calendar-tasker.module.ts

@@ -0,0 +1,12 @@
+import { Logger } from "@/lib/logger.bridge";
+import { GoogleCalendarSyncTasker } from "@/lib/services/taskers/google-calendar-sync-tasker.service";
+import { GoogleCalendarTasker } from "@/lib/services/taskers/google-calendar-tasker.service";
+import { GoogleCalendarTriggerDevTasker } from "@/lib/services/taskers/google-calendar-trigger-tasker.service";
+import { Module } from "@nestjs/common";
+
+@Module({
+  imports: [],
+  providers: [GoogleCalendarSyncTasker, GoogleCalendarTriggerDevTasker, Logger, GoogleCalendarTasker],
+  exports: [GoogleCalendarTasker],
+})
+export class GoogleCalendarTaskerModule {}

apps/api/v2/src/lib/services/taskers/google-calendar-sync-tasker.service.ts

@@ -0,0 +1,13 @@
+import { Logger } from "@/lib/logger.bridge";
+import { Injectable } from "@nestjs/common";
+
+import { GoogleCalendarSyncTasker as BaseGoogleCalendarSyncTasker } from "@calcom/platform-libraries/taskers";
+
+@Injectable()
+export class GoogleCalendarSyncTasker extends BaseGoogleCalendarSyncTasker {
+  constructor(logger: Logger) {
+    super({
+      logger,
+    });
+  }
+}

apps/api/v2/src/lib/services/taskers/google-calendar-tasker.service.ts

@@ -0,0 +1,22 @@
+import { Logger } from "@/lib/logger.bridge";
+import { Injectable } from "@nestjs/common";
+
+import { GoogleCalendarTasker as BaseGoogleCalendarTasker } from "@calcom/platform-libraries/taskers";
+
+import { GoogleCalendarSyncTasker } from "./google-calendar-sync-tasker.service";
+import { GoogleCalendarTriggerDevTasker } from "./google-calendar-trigger-tasker.service";
+
+@Injectable()
+export class GoogleCalendarTasker extends BaseGoogleCalendarTasker {
+  constructor(
+    primaryTasker: GoogleCalendarTriggerDevTasker,
+    fallbackTasker: GoogleCalendarSyncTasker,
+    logger: Logger
+  ) {
+    super({
+      primaryTasker: primaryTasker,
+      fallbackTasker: fallbackTasker,
+      logger,
+    });
+  }
+}

apps/api/v2/src/lib/services/taskers/google-calendar-trigger-tasker.service.ts

@@ -0,0 +1,13 @@
+import { Logger } from "@/lib/logger.bridge";
+import { Injectable } from "@nestjs/common";
+
+import { GoogleCalendarTriggerDevTasker as BaseGoogleCalendarTriggerDevTasker } from "@calcom/platform-libraries/taskers";
+
+@Injectable()
+export class GoogleCalendarTriggerDevTasker extends BaseGoogleCalendarTriggerDevTasker {
+  constructor(logger: Logger) {
+    super({
+      logger,
+    });
+  }
+}

apps/api/v2/tsconfig.json

@@ -28,7 +28,8 @@
       "@calcom/platform-libraries/conferencing": ["../../../packages/platform/libraries/conferencing.ts"],
       "@calcom/platform-libraries/repositories": ["../../../packages/platform/libraries/repositories.ts"],
       "@calcom/platform-libraries/bookings": ["../../../packages/platform/libraries/bookings.ts"],
-      "@calcom/platform-libraries/private-links": ["../../../packages/platform/libraries/private-links.ts"]
+      "@calcom/platform-libraries/private-links": ["../../../packages/platform/libraries/private-links.ts"],
+      "@calcom/platform-libraries/taskers": ["../../../packages/platform/libraries/taskers.ts"]
     },
     "incremental": true,
     "skipLibCheck": true,

apps/web/package.json

@@ -41,6 +41,7 @@
     "@calcom/platform-enums": "*",
     "@calcom/platform-types": "*",
     "@calcom/prisma": "*",
+    "@calcom/trigger": "workspace:^",
     "@calcom/trpc": "*",
     "@calcom/tsconfig": "*",
     "@calcom/ui": "*",

packages/features/tasker/SafeDispatchTasker.ts

@@ -0,0 +1,48 @@
+// No need for a generic base 'TaskerInterface'. We will use the specific domain interface directly.
+// For example, ICalendarTasker.
+import type { ILogger } from "./types/logger";
+
+export abstract class BaseTaskerService<T> {
+  // T is now just a placeholder for the class that extends this
+  // The dependencies are now typed with the specific interfaces
+  protected readonly primaryTasker: T;
+  protected readonly fallbackTasker: T;
+  protected readonly logger: ILogger;
+
+  constructor(dependencies: { primaryTasker: T; fallbackTasker: T; logger: ILogger }) {
+    this.primaryTasker = dependencies.primaryTasker;
+    this.fallbackTasker = dependencies.fallbackTasker;
+    this.logger = dependencies.logger;
+  }
+
+  public async dispatch<K extends keyof T>(
+    taskName: K,
+    ...args: T[K] extends (...args: any[]) => any ? Parameters<T[K]> : never
+  ): Promise<T[K] extends (...args: any[]) => any ? Awaited<ReturnType<T[K]>> : never> {
+    this.logger.info(`Dispatching task '${String(taskName)}'`, { args });
+    return this.safeDispatch(taskName, ...args);
+  }
+
+  // The dispatch method is now strongly typed to the keys of T
+  protected async safeDispatch<K extends keyof T>(
+    taskName: K,
+    // We infer the arguments directly from the method on T
+    ...args: T[K] extends (...args: any[]) => any ? Parameters<T[K]> : never
+  ): Promise<T[K] extends (...args: any[]) => any ? Awaited<ReturnType<T[K]>> : never> {
+    try {
+      const method = this.primaryTasker[taskName] as (...args: any[]) => any;
+      return await method.apply(this.primaryTasker, args);
+    } catch (err) {
+      this.logger.error(`Primary tasker failed for '${String(taskName)}'.`, err as Error);
+
+      if (this.primaryTasker === this.fallbackTasker) {
+        throw err;
+      }
+
+      this.logger.warn(`Falling back to SyncTasker for '${String(taskName)}'.`);
+
+      const fallbackMethod = this.fallbackTasker[taskName] as (...args: any[]) => any;
+      return fallbackMethod.apply(this.fallbackTasker, args);
+    }
+  }
+}