import { deliverToEndpoint } from '@admin/actions/webhooks/deliver-to-endpoint'
import { getActiveEndpointsForEvent } from '@admin/actions/webhooks/internal-get-active-endpoints'

export async function deliverWebhookEvent(
  eventId: string,
  event: string,
  body: string
): Promise<void> {
  try {
    const endpoints = await getActiveEndpointsForEvent(event)
    if (endpoints.length === 0) return

    await Promise.allSettled(
      endpoints.map((endpoint) => deliverToEndpoint(endpoint, eventId, event, body))
    )
  } catch (error) {
    console.error('Webhook delivery failed:', { event, error })
  }
}