using UnityEngine;
using UVC.Data;
using UVC.Data.Mqtt;
using UVC.Network;

public class WebGLSample : MonoBehaviour
{
    private string domain = "localhost";//"simulator.flexing.ai";
    private int port = 1883;
    private bool useWebSocket = false;
    private bool useTLS = false;

    void Start()
    {

//#if UNITY_WEBGL && !UNITY_EDITOR
        port = 8083;
        useWebSocket = true;
//#endif

        //TestMqttReceiver();
        TestMQTTService();

    }

    private void TestMqttReceiver()
    {
        var mqttConfig = new MqttSubscriptionConfig("#");
        mqttConfig.SetHandler((dataObject) =>
        {
            if (dataObject != null)
            {
                Debug.Log($"WebGLSample MqttReceiver: {dataObject.ToString()}");
            }
        });

        DataRepository.Instance.MqttReceiver.SetDomainPort(domain, port);
        DataRepository.Instance.MqttReceiver.SetUseWebSocket(useWebSocket);
        DataRepository.Instance.MqttReceiver.SetUseTLS(useTLS);
        DataRepository.Instance.MqttReceiver.Add(mqttConfig);
        DataRepository.Instance.MqttReceiver.Start();
    }

    private void TestMQTTService()
    {
        var mqttService = new MQTTService(domain, port, useWebSocket, useTLS);
        mqttService.AddTopicHandler("#", (topic, message) =>
        {
            Debug.Log($"WebGLSample MQTTService. Topic:{topic}, Message:{message}");
        });
        mqttService.Connect();
    }

}