import json
from kafka import KafkaConsumer

from main import validate_request


consumer = KafkaConsumer(
    "ivt_requests",
    bootstrap_servers="localhost:9092",
    group_id="ivt-validator-test-2",
    auto_offset_reset="latest",
    value_deserializer=lambda v: json.loads(v.decode("utf-8"))
)

print("Kafka Consumer started...")

for message in consumer:

    request = message.value

    print("\nOpenRTB request received:")
    print(json.dumps(request, indent=2))

    # Send request to IVT Validator
    result = validate_request(request)

    print("\nIVT Validation Result:")
    print(json.dumps(result, indent=2))