[7b22594] | 1 | #!/usr/bin/env ruby |
---|
| 2 | # |
---|
| 3 | # Author: Norbert Wigbels - foobla.wigbels.de/uber-foobla |
---|
| 4 | # |
---|
| 5 | # HotHotRead continously reads the status of a |
---|
| 6 | # reed contact attached to the avr-net-io |
---|
| 7 | # |
---|
| 8 | # The reed measures gas usage. |
---|
| 9 | # |
---|
| 10 | # A magig URL is formed and called; the url |
---|
| 11 | # stores the sensor-data to wigbels.net |
---|
| 12 | # |
---|
| 13 | # todo: status-led |
---|
| 14 | # |
---|
| 15 | |
---|
| 16 | #------------------------------------------ |
---|
| 17 | # Tainted mode 0-4 |
---|
| 18 | $SAFE=0 |
---|
| 19 | |
---|
| 20 | |
---|
| 21 | #------------------------------------------ |
---|
| 22 | require 'logger' |
---|
| 23 | require 'socket' |
---|
| 24 | require 'net/http' |
---|
| 25 | |
---|
| 26 | #------------------------------------------ |
---|
| 27 | class HotHotRead < Logger::Application |
---|
| 28 | attr_accessor :socket, :socketaddr |
---|
| 29 | |
---|
| 30 | def initialize(application_name) |
---|
| 31 | super(application_name) |
---|
| 32 | @socket = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM, 0) |
---|
| 33 | @sockaddr = Socket.sockaddr_in(2701, '192.168.14.42') |
---|
| 34 | end |
---|
| 35 | |
---|
| 36 | def run |
---|
| 37 | begin |
---|
| 38 | @socket.connect(@sockaddr) |
---|
| 39 | high2low = false; |
---|
| 40 | while true do |
---|
| 41 | @socket.print "io get pin 0\r\n" |
---|
| 42 | rawdata = @socket.recvfrom(128) |
---|
| 43 | # data contains "port 0: 0xfe"; extract last part |
---|
| 44 | data = rawdata.to_s.split(" ")[2] |
---|
| 45 | # we are only interested in the changes from high to low of the reed sensor |
---|
| 46 | if (data=="0xff") |
---|
| 47 | high2low = true |
---|
| 48 | else |
---|
| 49 | if (high2low==true) |
---|
| 50 | high2low = false |
---|
| 51 | Net::HTTP.get(URI.parse('http://www.wigbels.net/cgi-bin/hhw.rb?sensorid=1&data=10')) |
---|
| 52 | # fixme: response.body auswerten |
---|
| 53 | # bei fehler, lokales backlog schreibe |
---|
| 54 | log(INFO, 'added 100 liter of gas to sensor-database') |
---|
| 55 | end |
---|
| 56 | end |
---|
| 57 | sleep(0.2) |
---|
| 58 | end |
---|
| 59 | # and terminate the connection when we're done |
---|
| 60 | rescue => msg |
---|
| 61 | log(ERROR, "error: #{msg}") |
---|
| 62 | retry |
---|
| 63 | ensure |
---|
| 64 | @socket.close |
---|
| 65 | end |
---|
| 66 | #puts "Filename: "+__FILE__.to_s |
---|
| 67 | #puts "Linenumber: "+__LINE__.to_s |
---|
| 68 | #log(WARN, 'warning', 'mymethod' ) |
---|
| 69 | #@log.error('my_method2') { 'Error!' } |
---|
| 70 | end |
---|
| 71 | end |
---|
| 72 | |
---|
| 73 | |
---|
| 74 | #------------------------------------------ |
---|
| 75 | status = HotHotRead.new("HotHotRead").start |
---|
| 76 | |
---|
| 77 | #if status != 0 |
---|
| 78 | # puts "Some error occured." |
---|
| 79 | #end |
---|