from django.core.management.base import BaseCommand
from mqtt_processor.mqtt_client import start_mqtt_client # type: ignore
import os
import time


import time
class Command(BaseCommand):
    help = 'Start MQTT client'

    def handle(self, *args, **kwargs):
        global client
        import os
        import time
    
        client = start_mqtt_client()
        try:
            while True:
                time.sleep(5)
        except KeyboardInterrupt:
            print("Exiting...")
            if client:
                client.loop_stop()
                client.disconnect()
            # Удаляем lock-файл
            lock_file = '/tmp/mqtt_client.lock'
            if os.path.exists(lock_file):
                os.remove(lock_file)
            print("MQTT client stopped")