import { Modules } from "@medusajs/framework/utils"
import {
  WorkflowResponse,
  createHook,
  createWorkflow,
  transform,
} from "@medusajs/framework/workflows-sdk"
import {
  createRemoteLinkStep,
  emitEventStep,
} from "@medusajs/medusa/core-flows"
import { AlgoliaEvents, CreateReviewDTO } from "@mercurjs/framework"
import { REVIEW_MODULE } from "../../../modules/reviews"
import { createReviewStep, validateReviewStep } from "../steps"

const SELLER_MODULE = "seller"

export const createReviewWorkflow = createWorkflow(
  {
    name: "create-review",
  },
  function (input: CreateReviewDTO) {
    // Validate review data
    validateReviewStep(input)
    
    // Create the review
    const review = createReviewStep(input)

    // Create appropriate module link based on reference type
    const link = transform({ input, review }, ({ input, review }) => {
      return input.reference === "product"
        ? [
            {
              [Modules.PRODUCT]: {
                product_id: input.reference_id,
              },
              [REVIEW_MODULE]: {
                review_id: review.id,
              },
            },
          ]
        : [
            {
              [SELLER_MODULE]: {
                seller_id: input.reference_id,
              },
              [REVIEW_MODULE]: {
                review_id: review.id,
              },
            },
          ]
    })

    createRemoteLinkStep(link)
    
    // Emit event for search engine reindexing
    emitEventStep({
      eventName: AlgoliaEvents.REVIEW_CHANGED,
      data: { review },
    })

    // Emit workflow hook
    const reviewCreatedHook = createHook("reviewCreated", {
      review_id: review.id,
    })
    
    return new WorkflowResponse(review, {
      hooks: [reviewCreatedHook],
    })
  }
)

import {
  AuthenticatedMedusaRequest,
  MedusaResponse,
} from "@medusajs/framework"
import { ContainerRegistrationKeys } from "@medusajs/framework/utils"
import { createReviewWorkflow } from "../../../workflows/review/workflows"

export const POST = async (
  req: AuthenticatedMedusaRequest,
  res: MedusaResponse
) => {
  // Execute the createReviewWorkflow
  const { result } = await createReviewWorkflow.run({
    container: req.scope,
    input: {
      ...req.validatedBody,
      customer_id: req.auth_context.actor_id,
    },
  })

  const query = req.scope.resolve(ContainerRegistrationKeys.QUERY)

  const {
    data: [review],
  } = await query.graph({
    entity: "review",
    fields: req.queryConfig.fields,
    filters: {
      id: result.id,
    },
  })

  res.status(201).json({ review })
}