source: de.wigbels.ruby/hotcoldrain/hotcoldrain.rb @ 516b934

#!/usr/bin/env ruby
#
# Author: Norbert Wigbels - foobla.wigbels.de/uber-foobla
#
# HotColdRain continously reads output of USB-WDE1
# and pushes data to mosquitto-db
#
# todos: 
# 

#------------------------------------------
# Tainted mode 0-4
$SAFE=0


#------------------------------------------
require 'logger'
require 'serialport'
require 'mqtt'

#------------------------------------------
class HotColdRain < Logger::Application
  attr_accessor :temp1, :humidity1, :serialport

  def initialize(application_name)
    super(application_name)
    @serialport = SerialPort.new("/dev/ttyUSB0", 9600, 8, 1, SerialPort::NONE)
  end

  def run
    begin
      while true do
        openformat = @serialport.readline
        datagrams = openformat.split(';')
#        puts openformat
        puts "TemperaturUnten: " + datagrams[3]
        puts "LuftfeuchtigkeitUnten: " + datagrams[11]
        puts
        puts "TemperaturOben: " + datagrams[4]
        puts "LuftfeuchtigkeitOben: " + datagrams[12]
        puts        
        puts "TemperaturAussen: " + datagrams[19]
        puts "LuftfeuchtigkeitAussen: " + datagrams[20]
        puts "Windgeschwindigkeit km/h: " + datagrams[21]
        puts "Niederschlag: " + datagrams[22]
        puts "Regen ja/nein: " + datagrams[23]        
        puts "---------------------"
        MQTT::Client.connect('mqtt://notwist:pixies@wigbels.net') do |c|
          c.publish('oben/temperatur', datagrams[3])
        end
        #log(INFO, 'added 100 liter of gas to sensor-database')
      end
      @serialport.close
    rescue => msg
      log(ERROR, "error: #{msg}")
      retry
    ensure
      @serialport.close
    end
#    puts "Filename: "+__FILE__.to_s
#    puts "Linenumber: "+__LINE__.to_s
#    log(WARN, 'warning',  'mymethod' )
#    @log.error('my_method2') { 'Error!' }
  end
end


#------------------------------------------
status = HotColdRain.new("HotColdRain").start

#if status != 0
#  puts "Some error occured."
#endd