Function logSyncFailure

packages/internal/src/util/sync-failure.ts:8–42

({
  id,
  errorMessage,
  provider = 'stripe',
  logger,
}: {
  id: string
  errorMessage: string
  provider: string
  logger: Logger
})

import type { Logger } from '@codebuff/common/types/contracts/logger'

export async function logSyncFailure({
  id,
  errorMessage,
  provider = 'stripe',
  logger,
}: {
  id: string
  errorMessage: string
  provider: string
  logger: Logger
}): Promise<void> {
  try {
    await db
      .insert(schema.syncFailure)
      .values({
        id,
        provider,
        last_error: errorMessage,
        last_attempt_at: new Date(),
      })
      .onConflictDoUpdate({
        target: schema.syncFailure.id,
        set: {
          last_error: errorMessage,
          last_attempt_at: new Date(),
          retry_count: sql`${schema.syncFailure.retry_count} + 1`,
        },
      })
  } catch (dbError) {
    logger.error(
      { id, provider, error: dbError },
      'Failed to log sync failure to database.',
    )
  }
}