Class: Aurora::MQTTModBus

Inherits:
Object
  • Object
show all
Defined in:
lib/aurora/mqtt_modbus.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(uri) ⇒ MQTTModBus

Returns a new instance of MQTTModBus.



10
11
12
13
14
15
16
 
# File 'lib/aurora/mqtt_modbus.rb', line 10

def initialize(uri)
  @mqtt = MQTT::Client.new(uri)
  @mqtt.connect

  @base_topic = uri.path[1..-1]
  @mqtt.subscribe("#{@base_topic}/getregs/response")
end

Instance Attribute Details

#logger ⇒ Object

Returns the value of attribute logger.



8
9
10
 
# File 'lib/aurora/mqtt_modbus.rb', line 8

def logger
  @logger
end

Instance Method Details

#read_multiple_holding_registers(*queries) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/aurora/mqtt_modbus.rb', line 18

def read_multiple_holding_registers(*queries)
  query_id = SecureRandom.uuid
  mqtt_query = queries.map { |m| m.is_a?(Range) ? "#{m.begin},#{m.count}" : m }.join(";")
  @mqtt.publish("#{@base_topic}/getregs", "#{query_id}:#{mqtt_query}", qos: 1)
  Timeout.timeout(5) do
    result = {}
    loop do
      packet = @mqtt.get
      response_id, registers_flat = packet.payload.split(":")
      next unless response_id == query_id

      values = registers_flat.split(",").map(&:to_i)
      result_index = 0
      queries.each do |query|
        Array(query).each do |i|
          result[i] = values[result_index]
          result_index += 1
        end
      end
      break
    end
    result
  end
end

#write_holding_register(addr, value) ⇒ Object 



43
44
45
 
# File 'lib/aurora/mqtt_modbus.rb', line 43

def write_holding_register(addr, value)
  @mqtt.publish("#{@base_topic}/#{addr}/set", value, qos: 1)
end