import { SubscriberArgs, SubscriberConfig } from '@medusajs/framework'
import { ContainerRegistrationKeys, Modules } from '@medusajs/framework/utils'

import { AlgoliaEvents, IntermediateEvents } from '../modules/algolia/types'
import productSellerLink from '@mercurjs/core/links/product-seller-link'
import sellerServiceZone from '@mercurjs/core/links/service-zone-seller-link'

export default async function serviceZoneChangedHandler({
  event,
  container
}: SubscriberArgs<{ id: string }>) {
  const service_zone_id = event.data.id
  const query = container.resolve(ContainerRegistrationKeys.QUERY)
  const eventBus = container.resolve(Modules.EVENT_BUS)

  const {
    data: [seller]
  } = await query.graph({
    entity: sellerServiceZone.entryPoint,
    fields: ['seller_id'],
    filters: {
      service_zone_id
    },
    withDeleted: true
  })

  if (!seller) {
    return
  }

  const { data: products } = await query.graph({
    entity: productSellerLink.entryPoint,
    fields: ['product_id'],
    filters: {
      seller_id: seller.seller_id
    }
  })

  await eventBus.emit({
    name: AlgoliaEvents.PRODUCTS_CHANGED,
    data: { ids: products.map((p) => p.product_id) }
  })
}

export const config: SubscriberConfig = {
  event: IntermediateEvents.SERVICE_ZONE_CHANGED,
  context: {
    subscriberId: 'service-zone-changed-handler'
  }
}