Contents

require 'socket'
require 'applix/oattr'
require 'gom/remote'

module Gom
  class SensorPort 

    # GOM default Logger instance
    Log = Gom::Logger.new

    Defaults = {
      :interface  => '0.0.0.0',
      :port       => 44470,
      :mode       => :udp,
      :verbose    => false,
    }

    include OAttr
    oattr :interface, :port, :mode

    def initialize path, options = {}
      @path = path
      @options = Defaults.merge(find_gom_node @path).merge(options)
      #puts " -- new sensor port: #{self.inspect}"

      verbose? and (Log.level = ::Logger::DEBUG)
      Log.info "new sensor port: #{self.inspect}"
    end

    def verbose?
      @options[:verbose] || @options[:v]
    end

    def listen
      #puts " -- listen: #{self.inspect}"
      Log.info "listen: #{self.inspect}"
      self.send "listen_#{mode}"
    end

    def listen_udp
      socket = UDPSocket.new
      socket.bind(interface, port)
      loop do
        line, source = socket.recvfrom(1024)
        dispatch_sensor_message line, source
      end
    ensure
      socket.close rescue nil
    end

    def listen_tcp
      raise "not yet implemented"
    end

    def dispatch_sensor_message line, source = nil
      line.strip!
      Log.debug "-->#{line}<-- #{source.inspect}"
      key, value = (line.split /\s*[:=]\s*/)
      value.nil? or value.strip!
      # TODO: val might need type conversion
      Gom::Remote.connection.write "#{@path}:raw", line
      Gom::Remote.connection.write "#{@path}/values:#{key}", value
    end

    # TODO: temporarily here from gom-script
    def find_gom_node path
      json = (Gom::Remote.connection.read "#{path}.json")
      (JSON.parse json)["node"]["entries"].select do |entry|
        # 1. select attribute entries
        entry.has_key? "attribute"
      end.inject({}) do |h, a|
          # 2. make it a key, value list
          h[a["attribute"]["name"].to_sym] = a["attribute"]["value"]
          h
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
gom-sensor-ports-0.2.4	lib/gom/sensor_port.rb
gom-sensor-ports-0.2.3	lib/gom/sensor_port.rb