using System.Text;
using System.Text.Json;
using InnovEnergy.App.GrowattCommunication.DataTypes;
using RabbitMQ.Client;

namespace InnovEnergy.App.GrowattCommunication.MiddlewareClasses;

public static class RabbitMqManager
{
    private static ConnectionFactory?  _factory ;
    private static IConnection ?       _connection;
    private static IModel?             _channel;
    
    public static Boolean SubscribeToQueue(StatusMessage currentSalimaxState, String? s3Bucket,String VpnServerIp)
    {
        try
        {
            //_factory    = new ConnectionFactory { HostName = VpnServerIp };
            
            _factory = new ConnectionFactory
            {
                HostName = VpnServerIp,
                Port = 5672,
                VirtualHost = "/",
                UserName = "producer",
                Password = "b187ceaddb54d5485063ddc1d41af66f",
               
            };
            
            _connection = _factory.CreateConnection();
            _channel    = _connection.CreateModel();
            _channel.QueueDeclare(queue: "statusQueue", durable: true, exclusive: false, autoDelete: false, arguments: null);
            
            Console.WriteLine("The controller sends its status to the middleware for the first time");
            if (s3Bucket != null) InformMiddleware(currentSalimaxState);
    
            
        }
        catch (Exception ex)
        {
            Console.WriteLine("An error occurred while connecting to the RabbitMQ queue: " + ex.Message);
            return false;
        }
        return true;
    }
    
    public static void  InformMiddleware(StatusMessage status)
    {        
        var message = JsonSerializer.Serialize(status);
        var body    = Encoding.UTF8.GetBytes(message);

        _channel.BasicPublish(exchange: string.Empty,
            routingKey: "statusQueue",
            basicProperties: null,
            body: body);
        
        Console.WriteLine($"Producer sent message: {message}");
    }

    
}