import { resolveNotificationService } from '@open-mercato/core/modules/notifications/lib/notificationService'
import { buildFeatureNotificationFromType } from '@open-mercato/core/modules/notifications/lib/notificationBuilder'
import { createRequestContainer } from '@open-mercato/shared/lib/di/container'
import { notificationTypes } from '../notifications'
import { dispatchCheckoutEmailJob } from '../lib/emailQueue'
import { createLogger } from '@open-mercato/shared/lib/logger'

const logger = createLogger('checkout').child({ component: 'transaction-failed-notify' })

export const metadata = {
  event: 'checkout.transaction.failed',
  persistent: true,
  id: 'checkout:transaction-failed-notify',
}

type FailedPayload = {
  transactionId: string
  linkId: string
  slug?: string | null
  status: string
  amount?: number | null
  currency?: string | null
  tenantId: string
  organizationId: string
}

export default async function handle(payload: FailedPayload) {
  if (!payload.transactionId || !payload.tenantId || !payload.organizationId) return

  try {
    const container = await createRequestContainer()
    const notificationService = resolveNotificationService(container)
    const typeDef = notificationTypes.find((n) => n.type === 'checkout.transaction.failed')

    if (typeDef) {
      const input = buildFeatureNotificationFromType(typeDef, {
        requiredFeature: 'checkout.view',
        bodyVariables: {
          amount: payload.amount != null ? String(payload.amount) : '',
          currency: payload.currency ?? '',
        },
        sourceEntityType: 'checkout:checkout_transaction',
        sourceEntityId: payload.transactionId,
        linkHref: `/backend/checkout/transactions/${payload.transactionId}`,
      })
      await notificationService.createForFeature(input, {
        tenantId: payload.tenantId,
        organizationId: payload.organizationId,
      })
    }
  } catch (err) {
    logger.error('notification failed', { transactionId: payload.transactionId, err })
  }

  try {
    await dispatchCheckoutEmailJob({
      type: 'error',
      transactionId: payload.transactionId,
      tenantId: payload.tenantId,
      organizationId: payload.organizationId,
    })
  } catch (err) {
    logger.error('email enqueue failed', { transactionId: payload.transactionId, err })
  }
}