"""Publish event logic."""

from kafka_utils.producer.helpers import build_product_event

from src import config
from src import kafka_connector


def publish_review_event(product_id, review_queue_id, resolution, user_uuid, note):
    """Publish a review event."""
    result = build_product_event(
            operation_type='create',
            operation_context=resolution,
            event_payload={
                'product_id': product_id,
                'review_queue_id': review_queue_id,
                'user_id': user_uuid,
                'review_note': note,
            },
        )
    kafka_connector.get_producer().produce(
        topic=config.KAFKA_REVIEW_TOPIC,
        event_key=f'product_{product_id}',
        event_value=result
    )