"""Neo4J sync DLQ processing daemon."""

import signal
import sys

import sentry_sdk

from neo4j_sync_dlq import config
from neo4j_sync_dlq.connectors import kafka
from neo4j_sync_dlq.logic.kafka import KafkaWorker


def signal_handler(sig, frame):
    """Signal handler for graceful shutdown."""
    worker.do_work = False
    sys.exit(0)


signal.signal(signal.SIGINT, signal_handler)

try:
    kafka_config = kafka.get_kafka_config()
    worker = KafkaWorker(
        dlq_topic=config.KAFKA_DLQ_TOPIC, group_id=config.KAFKA_CONSUMER_GROUP,
        kafka_configuration=kafka_config)
    worker.run()
except:  # noqa
    sentry_sdk.capture_exception()
    exit(1)