350 lines
8.2 KiB
Ruby
350 lines
8.2 KiB
Ruby
require 'rubyserial'
|
|
require 'observer'
|
|
require 'timers'
|
|
|
|
#
|
|
# User Configs
|
|
#
|
|
|
|
# 9600 baud, 8 data bits, and no parity
|
|
device = '/dev/ttyUSB0'
|
|
baud = 9600
|
|
bits = 8
|
|
parity = :none
|
|
@serial_line_ending = "\r"
|
|
|
|
#
|
|
# Setup
|
|
#
|
|
|
|
@serial = Serial.new device, baud, bits, parity
|
|
@buffer = Queue.new
|
|
@timers = Timers::Group.new
|
|
|
|
#
|
|
# Convenience function
|
|
#
|
|
|
|
def serial_writeln(str)
|
|
@serial.write(str+@serial_line_ending)
|
|
end
|
|
|
|
#
|
|
# Board interface functions
|
|
#
|
|
|
|
def b_date()
|
|
serial_writeln("d")
|
|
end
|
|
def b_show(num)
|
|
serial_writeln("s #{num}")
|
|
end
|
|
def b_modify(num, mask, tag)
|
|
serial_writeln("m #{num} #{mask} #{tag}")
|
|
end
|
|
def b_all()
|
|
serial_writeln("a")
|
|
end
|
|
def b_remove(num)
|
|
serial_writeln("r #{num}")
|
|
end
|
|
def b_open(num)
|
|
serial_writeln("o #{num}")
|
|
end
|
|
def b_unlock()
|
|
# Listen for an unlock event; raise an error if not found
|
|
foo = @timers.after(5) {
|
|
if @events[:unlocked].changed?
|
|
print "foo"
|
|
else
|
|
print "didn't get an unlock event in time"
|
|
end
|
|
}
|
|
print foo.inspect
|
|
SerialListener.new(@events[:unlocked],
|
|
Proc.new{ |value| print "got unlock event #{value}" }
|
|
)
|
|
serial_writeln("u")
|
|
@timers.fire
|
|
end
|
|
def b_lock()
|
|
serial_writeln("l")
|
|
end
|
|
def b_1()
|
|
serial_writeln("1")
|
|
end
|
|
def b_2()
|
|
serial_writeln("2")
|
|
end
|
|
def b_3()
|
|
serial_writeln("3")
|
|
end
|
|
def b_9()
|
|
serial_writeln("9")
|
|
end
|
|
def b_time(sec,min,hr,day,date,mon,yr)
|
|
serial_writeln("t #{sec} #{min} #{hr} #{day} #{date} #{mon} #{yr}")
|
|
end
|
|
def b_enable(num)
|
|
serial_writeln("e #{num}")
|
|
end
|
|
def b_hardware(num)
|
|
serial_writeln("h #{num}")
|
|
end
|
|
def b_help()
|
|
serial_writeln("?")
|
|
end
|
|
|
|
#
|
|
# Thread functions
|
|
#
|
|
|
|
def console_in()
|
|
run = true
|
|
while run
|
|
# Get console input
|
|
cline = gets
|
|
unless cline.nil?
|
|
case cline
|
|
when /^d/
|
|
b_date()
|
|
when /^s (\d+)/
|
|
b_show($1)
|
|
when /^m (\d+) (\d+) (\d+)/
|
|
b_modify($1,$2,$3)
|
|
when /^a/
|
|
b_all()
|
|
when /^r (\d+)/
|
|
b_remove($1)
|
|
when /^o (\d+)/
|
|
b_open($1)
|
|
when /^u/
|
|
b_unlock()
|
|
when /^l/
|
|
b_lock()
|
|
when /^1/
|
|
b_1()
|
|
when /^2/
|
|
b_2()
|
|
when /^3/
|
|
b_3()
|
|
when /^9/
|
|
b_9()
|
|
when /^t (\d+) (\d+) (\d+) (\d+) (\d+) (\d+) (\d+)/
|
|
b_time($1,$2,$3,$4,$5,$6,$7)
|
|
when /^e (\d+)/
|
|
b_enable($1)
|
|
when /^h (\d+)/
|
|
b_hardware($1)
|
|
when /^?/
|
|
b_help()
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def serial_in()
|
|
run = true
|
|
readbuffer = ""
|
|
|
|
while run
|
|
# begin
|
|
# Get serial input char by char
|
|
sdata = @serial.read(1)
|
|
# If we have data
|
|
unless sdata == ""
|
|
# Look for newlines
|
|
if /\n|\r/.match(sdata)
|
|
# Flush the existing buffer and reset
|
|
@buffer.push(readbuffer)
|
|
readbuffer = ""
|
|
else
|
|
# Append non-newlines to the buffer
|
|
readbuffer += sdata
|
|
end
|
|
end
|
|
# rescue Exception => e
|
|
# print e
|
|
# sline = nil
|
|
# end
|
|
end
|
|
end
|
|
|
|
def parse_in()
|
|
run = true
|
|
|
|
while run
|
|
sline = @buffer.pop()
|
|
if sline != ""
|
|
case sline
|
|
when /(\d*) unlocked$/ # ends line
|
|
print ">Door #{$1} unlocked\n"
|
|
@events[:unlocked].send($1)
|
|
when /All Doors relocked/
|
|
print ">All Doors relocked\n"
|
|
when /Door (\d*) locked$/ # ends line
|
|
print ">Door #{$1} locked\n"
|
|
when /User ([\dA-F]*) presented tag at reader (\d)/
|
|
print ">User #{$1} presented tag at reader #{$2}\n"
|
|
when /User ([\dA-F]*) granted access at reader (\d)/
|
|
print ">User #{$1} granted access at reader #{$2}\n"
|
|
when /User ([\dA-F]*) denied access at reader (\d)/
|
|
print ">User #{$1} denied access at reader #{$2}\n"
|
|
when /Command ([\dA-F]*) entered at reader (\d)/
|
|
print ">Command #{$1} entered at reader #{$2}\n"
|
|
when /Zone (\d?) sensor activated/
|
|
print ">Zone #{$1} sensor activated\n"
|
|
when /User (\d?) unlocked door (\d)/
|
|
print ">User #{$1} unlocked door #{$2}\n"
|
|
when /Door 1 locked for (\d+) bed time/
|
|
print "Door 1 locked for #{$1} bed time\n"
|
|
when /User (\d+) locked out/
|
|
print "User #{$1} locked out\n"
|
|
when /User (\d+) locked out/
|
|
print "User #{$1} locked out\n"
|
|
when /Sensor (\d+) value:(\d+)/
|
|
print "Sensor #{$1} value:#{$2}\n"
|
|
when /Alarm triggered/
|
|
print "Alarm triggered\n"
|
|
when /Alarm level changed to (\d*)/
|
|
print ">Alarm level changed to #{$1}\n"
|
|
when /Alarm armed level changed to (\d*)/
|
|
print ">Alarm armed level changed to #{$1}\n"
|
|
when /User database erased/
|
|
print "User database erased\n"
|
|
when /Invalid user modify attempted/
|
|
print "Invalid user modify attempted\n"
|
|
when /User (\d*) successfully modified/
|
|
print ">User #{$1} successfully modified\n"
|
|
when /Invalid user delete attempted/
|
|
print "Invalid user delete attempted\n"
|
|
when /User deleted at position (\d*)/
|
|
print "User deleted at position #{$1}\n"
|
|
when /User deleted at position (\d*)/
|
|
print ">User deleted at position #{$1}\n"
|
|
when /User (\d+) authenticated/
|
|
print "User #{$1} authenticated\n"
|
|
when /User not found/
|
|
print "User not found\n"
|
|
when /Bad user number/
|
|
print "Bad user number\n"
|
|
when /User dump started/
|
|
print ">User dump started\n"
|
|
when /Invalid door number/
|
|
print "Invalid door number\n"
|
|
when /Alarm armed state \(1=armed\):(\d*)/
|
|
print ">Alarm armed state: #{$1}\n"
|
|
when /Alarm siren state \(1=activated\):(\d*)/
|
|
print ">Alarm siren state: #{$1}\n"
|
|
when /Front door open state \(0=closed\):(\d*)/
|
|
print ">Front door open state: #{$1}\n"
|
|
when /Roll up door open state \(0=closed\):(\d*)/
|
|
print ">Roll up door open state: #{$1}\n"
|
|
when /Door 1 unlocked state\(1=locked\):(\d*)/
|
|
print ">Door 1 unlocked state: #{$1}\n"
|
|
when /Door 2 unlocked state\(1=locked\):(\d*)/
|
|
print ">Door 2 unlocked state: #{$1}\n"
|
|
when /^(\d+)\t+(\d+)\t+([\dA-Fa-f]+)$/
|
|
print ">User #{$1} mask #{$2} tag #{$3}\n" # User dump info
|
|
when /Priveleged mode enabled./
|
|
print ">Priveleged mode enabled.\n"
|
|
when /Priveleged mode disabled./
|
|
print ">Priveleged mode disabled.\n"
|
|
when /Access Denied. Priveleged mode is not enabled./
|
|
print ">Access Denied. Priveleged mode is not enabled.\n"
|
|
when /Valid commands are/
|
|
print "?Valid commands are\n" # Help output
|
|
when /^\(/
|
|
print "?"+sline+"\n" # Help output
|
|
when /^ <day 0..31> <mon 0..12> <year 0.99>/
|
|
print "?"+sline+"\n" # Help output
|
|
when /^[\d:]{5,8}\s+[\d\/]{5,8}\s+[A-Z]{3}\s+$/
|
|
print ">"+sline+"\n" # Date output only
|
|
when /^Old time :([\d:]{5,8})\s+([\d\/]{5,8})\s+([A-Z]{3})\s+$/
|
|
print ">Old time: #{$1} #{$2} #{$3}\n"
|
|
when /^New time :([\d:]{5,8})\s+([\d\/]{5,8})\s+([A-Z]{3})\s+$/
|
|
print ">New time: #{$1} #{$2} #{$3}\n"
|
|
when /Reader1-0:(\d*)/
|
|
print ">Reader1-0:#{$1}\n" # Status output
|
|
when /Reader1-1:(\d*)/
|
|
print ">Reader1-1:#{$1}\n" # Status output
|
|
when /Reader2-0:(\d*)/
|
|
print ">Reader2-0:#{$1}\n" # Status output
|
|
when /Reader2-1:(\d*)/
|
|
print ">Reader2-1:#{$1}\n" # Status output
|
|
when /Zone 1:(\d*)/
|
|
print ">Zone 1:#{$1}\n" # Status output
|
|
when /Zone 2:(\d*)/
|
|
print ">Zone 2:#{$1}\n" # Status output
|
|
when /Zone 3:(\d*)/
|
|
print ">Zone 3:#{$1}\n" # Status output
|
|
when /Zone 4:(\d*)/
|
|
print ">Zone 4:#{$1}\n" # Status output
|
|
when /Zone TAMP:(\d*)/
|
|
print ">Zone TAMP:#{$1}\n" # Status output
|
|
when /Relays and LEDs ([a-z]*)/
|
|
print ">Relays and LEDs #{$1}\n" # Status output
|
|
when /Relays and LEDs ([a-z]*)/
|
|
print ">Relays and LEDs #{$1}\n" # Status output
|
|
when /UserNum: Usermask: TagNum:/
|
|
# print nothing, we don't care
|
|
when /Pass: /
|
|
# print nothing, we don't care
|
|
when /^\d+$/
|
|
# print nothing, we don't care
|
|
else
|
|
print "ERR: UNKNOWN: "+sline.inspect+"\n" # Error output
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
#
|
|
# Classes
|
|
#
|
|
|
|
class SerialEvents
|
|
include Observable
|
|
|
|
@oldvalue = nil
|
|
|
|
def send(value)
|
|
if value != @oldvalue
|
|
changed
|
|
@oldvalue = value
|
|
notify_observers(Time.now, value)
|
|
end
|
|
end
|
|
|
|
end
|
|
|
|
class SerialListener
|
|
@callback = nil
|
|
|
|
def initialize(observable, callback)
|
|
@callback = callback
|
|
observable.add_observer(self)
|
|
end
|
|
|
|
def update(time, value)
|
|
@callback.call(value)
|
|
end
|
|
end
|
|
|
|
#
|
|
# Runtime
|
|
#
|
|
|
|
@events = {
|
|
unlocked: SerialEvents.new,
|
|
locked: SerialEvents.new,
|
|
}
|
|
|
|
puts "> Started threads at #{Time.now}"
|
|
t1 = Thread.new{console_in()}
|
|
t2 = Thread.new{serial_in()}
|
|
t3 = Thread.new{parse_in()}
|
|
t1.join
|
|
t2.join
|
|
t3.join
|
|
puts "> End threads at #{Time.now}" |