require 'paho-mqtt'

class MQTTService
  def initialize
    @client = PahoMqtt::Client.new(
      host: "host_name",
      port: "8883",
      persistent: true,
      username: "username",
      password: "password"
    )

    certificate_path = "/etc/mosquitto/ca_certificates/server.crt"
    key_path = "/etc/mosquitto/ca_certificates/server.key"

    @client.config_ssl_context(certificate_path, key_path)
    register_callbacks
  end

  def connect
    @client.connect
  end

  def subscribe(topic, standard=1)
    @client.subscribe([topic, standard])
  end

  def publish(topic, message, retain=false, standard=1)
    @client.publish(topic, message, retain, standard)
  end

  def register_connection_callback
    @client.on_connack = proc { puts "Successfully Connected" }
  end

  def register_new_message_received_callback
    @client.on_message do |packet|
      puts "New message received on topic: #{packet.topic}\n>>>#{packet.payload}"
    end
  end

  def register_publication_callback
    waiting_puback = true
    @client.on_puback do
      waiting_puback = false
      puts "Message Acknowledged"
    end
  end

  def register_message_fetched_callback
    message_counter = 0
    @client.on_message do |message|
      puts "Message recieved on topic: #{message.topic}\n>>> #{message.payload}"
      message_counter += 1
    end
  end

  def register_subscription_callback
    waiting_suback = true
    @client.on_suback do
      waiting_suback = false
      puts "Subscribed"
    end
  end

  def register_callbacks
    register_subscription_callback
    register_message_fetched_callback
    register_publication_callback
    register_new_message_received_callback
    register_connection_callback
  end


end