pass in logger to logSyncFailure

Author: charleslien

backend/src/llm-apis/message-cost-tracker.ts

@@ -301,7 +301,12 @@ async function syncMessageToStripe(messageData: {
       { ...logContext, error: errorMessage },
       'Failed to sync usage to Stripe after retries.',
     )
-    await logSyncFailure(messageId, errorMessage, 'stripe')
+    await logSyncFailure({
+      id: messageId,
+      errorMessage,
+      provider: 'stripe',
+      logger,
+    })
   }
 }
 

common/src/util/sync-failure.ts

@@ -1,14 +1,21 @@
 import { sql } from 'drizzle-orm'
 
 import db from '../db'
-import { logger } from './logger'
 import * as schema from '../db/schema'
 
-export async function logSyncFailure(
-  id: string,
-  errorMessage: string,
+import type { Logger } from '@codebuff/types/logger'
+
+export async function logSyncFailure({
+  id,
+  errorMessage,
   provider = 'stripe',
-): Promise<void> {
+  logger,
+}: {
+  id: string
+  errorMessage: string
+  provider: string
+  logger: Logger
+}): Promise<void> {
   try {
     await db
       .insert(schema.syncFailure)

packages/billing/src/grant-credits.ts

@@ -259,7 +259,12 @@ export async function processAndGrantCredit(
       },
     )
   } catch (error: any) {
-    await logSyncFailure(operationId, error.message, 'internal')
+    await logSyncFailure({
+      id: operationId,
+      errorMessage: error.message,
+      provider: 'internal',
+      logger,
+    })
     logger.error(
       { operationId, error },
       'processAndGrantCredit failed after retries, logged to sync_failure',

web/src/app/api/auth/[...nextauth]/auth-options.ts

@@ -67,7 +67,12 @@ async function createAndLinkStripeCustomer(
       { userId, error },
       'Failed to create Stripe customer or update user record.'
     )
-    await logSyncFailure(userId, errorMessage)
+    await logSyncFailure({
+      id: userId,
+      errorMessage,
+      provider: 'stripe',
+      logger,
+    })
     return null
   }
 }
@@ -107,7 +112,12 @@ async function createInitialCreditGrant(
       { userId, error: grantError },
       'Failed to create initial credit grant.'
     )
-    await logSyncFailure(userId, errorMessage)
+    await logSyncFailure({
+      id: userId,
+      errorMessage,
+      provider: 'stripe',
+      logger,
+    })
   }
 }