from __future__ import annotations

import json

from app.communication.mqtt.client import mqtt
from app.communication.mqtt.topics import DEVICE_COMMAND, DEVICE_CONFIG, DEVICE_OTA


async def publish_command(device_uid: str, command: dict) -> None:
    topic = DEVICE_COMMAND.format(device_uid=device_uid)
    mqtt.client.publish(topic, json.dumps(command))


async def publish_config(device_uid: str, config: dict) -> None:
    topic = DEVICE_CONFIG.format(device_uid=device_uid)
    mqtt.client.publish(topic, json.dumps(config))


async def publish_ota(device_uid: str, ota_info: dict) -> None:
    topic = DEVICE_OTA.format(device_uid=device_uid)
    mqtt.client.publish(topic, json.dumps(ota_info))