using MQTTnet;

using MQTTnet.Client;

using Newtonsoft.Json;

using System;

using System.Text;

using MQTTnet.Extensions.ManagedClient;

using System.Threading.Tasks;

using Newtonsoft.Json.Linq;

using System.Data.SqlClient;

using System.Collections.Generic;

​

class Program

{

    static void Main(string[] args)

    {

        var mqttClient = new MqttFactory().CreateManagedMqttClient();

​

        var options = new MqttClientOptionsBuilder()

            .WithClientId("MQTTSubscriber")

            .WithTcpServer("5fa017d6dda9448dbb473a3d76ea9ddd.s1.eu.hivemq.cloud", 8883)

            .WithCredentials("Aledc", "Ghisa2024")

            .WithTls()

            .Build();

​

        mqttClient.ApplicationMessageReceivedAsync += async e =>

        {

            Console.WriteLine("Message received");

            var payload = Encoding.UTF8.GetString(e.ApplicationMessage.PayloadSegment);

            JObject dati = JObject.Parse(payload); // Dati in formato json

​

            // Insert(dati);

            Console.WriteLine(payload);

            await Task.CompletedTask;

        };

​

        try

        {

            // Connessione al broker

            mqttClient.StartAsync(

                new ManagedMqttClientOptionsBuilder()

                    .WithAutoReconnectDelay(TimeSpan.FromSeconds(5))

                    .WithClientOptions(options)

                    .Build()).Wait();

​

            Console.WriteLine("Connected");

​

            string topic = "Macchinari";

​

            if (args.Length > 0)

            {

                topic = args[0];

            }

​

            // Iscrizione al topic

            var topicFilter = new MqttTopicFilterBuilder().WithTopic(topic).Build();

            mqttClient.SubscribeAsync(new List<MQTTnet.Packets.MqttTopicFilter> { topicFilter }).Wait();

​

            Console.WriteLine($"Subscribed to '{topic}' (Press any key for exit).");

            Console.ReadLine();

​

            // Disconnessione dal broker

            mqttClient.StopAsync().Wait();

            Console.WriteLine("Disconnected");

        }

        catch (Exception ex)

        {

            Console.WriteLine($"Error: {ex.Message}");

        }

    }

​

/*    private static void Insert(JObject dati)

    {

        string connectionString = "Data Source=10.0.0.23;Initial Catalog=TEST;User ID=grupposga;Password=agsoppurg;";

        using (SqlConnection connection = new SqlConnection(connectionString))

        {

            try

            {

                connection.Open();

​

                // Comando SQL per l'inserimento

                string insertSql = "INSERT INTO tblStageMqtt (Topic, Macchinario, Valore) VALUES (@topic, @macchinario, @valore)";

​

                // Creazione e esecuzione del comando SQL

                using (SqlCommand command = new SqlCommand(insertSql, connection))

                {

                    // Definizione dei parametri

                    command.Parameters.AddWithValue("@topic", (String)dati["Topic"]);

                    command.Parameters.AddWithValue("@macchinario", (String)dati["Macchinario"]);

                    command.Parameters.AddWithValue("@valore", (float)dati["Valore"]);

​

                    // Esecuzione del comando

                    int rowsAffected = command.ExecuteNonQuery();

​

                    Console.WriteLine($"Numero di righe inserite: {rowsAffected}");

                }

            }

            catch (Exception ex)

            {

                Console.WriteLine($"Errore durante l'inserimento: {ex.Message}");

            }

        }

    }*/

}