X-Git-Url: https://git.ucc.asn.au/?p=uccvend-vendserver.git;a=blobdiff_plain;f=sql-edition%2Fservers%2FVendServer.py;h=25a24b68a1cd81243a53d1e1633779542fa46207;hp=c6a9416c6957148e9048cdaa1cb3169ffcef7c93;hb=ae5bb2bd19b75664847d40e5bdaaf16ddad06745;hpb=d3ee0fb585f9df7ffa84987091f05b5a932b7e65 diff --git a/sql-edition/servers/VendServer.py b/sql-edition/servers/VendServer.py index c6a9416..25a24b6 100755 --- a/sql-edition/servers/VendServer.py +++ b/sql-edition/servers/VendServer.py @@ -1,120 +1,90 @@ #!/usr/bin/python -import sys, os, string, socket, time, re -from popen2 import popen2 -from pyPgSQL import PgSQL +import sys, os, string, time, re, pwd +import pg from LATClient import LATClient -from CRC import do_crc -from binascii import unhexlify - -asynchronous_responses = [ '400', '401', # door open/closed - '610', # switches changed - ] - -class VendingMachine: - def __init__(self, rfh, wfh): - self.secret = 'AAAAAAAAAAAAAAAA' - self.rfh = rfh - self.wfh = wfh - self.challenge = None - # Initialise ourselves into a known state - self.wfh.write('\n') - self.await_prompt() - self.wfh.write('echo off\n') - self.await_prompt() - self.wfh.write('PING\n') - code = '' - while code != '000': - (code, _) = self.get_response() - - def await_prompt(self): - self.wfh.flush() - state = 1 - prefix = '' - s = '' - while True: - s = self.rfh.read(1) - if s == '': raise Exception - if s == '\n' or s == '\r': - state = 1 - prefix = '' - if (s == '#' or s == '%') and state == 1: state = 2 - if s == ' ' and state == 2: - if prefix == '': - self.challenge = None - return - if re.search('^[0-9a-fA-F]{4}$', prefix): - self.challenge = unhexlify(prefix) - return +from VendingMachine import VendingMachine - def get_response(self): - self.wfh.flush() - while True: - s = '' - while s == '': - s = self.rfh.readline() - if s == '': return None - s = s.strip('\r\n') - code = s[0:3] - text = s[4:] - if code in asynchronous_responses: - self.handle_event(code, text) +GREETING = 'UCC SNACKS' +PIN_LENGTH = 4 + +class DispenseDatabase: + def __init__(self, vending_machine): + self.vending_machine = vending_machine + self.db = pg.DB(dbname = 'dispense', host = 'dispense.ucc.gu.uwa.edu.au', user = 'vendserver', passwd = 'revresdnev') + self.db.query('LISTEN vend_requests') + + def process_requests(self): + print 'processing' + query = 'SELECT request_id, request_slot FROM vend_requests WHERE request_handled = false' + try: + outstanding = self.db.query(query).getresult() + except (pg.error,), db_err: + sys.stderr.write('Failed to query database: %s\n'%(db_err.strip())) + return + for (id, slot) in outstanding: + (worked, code, string) = self.vending_machine.vend(slot) + print (worked, code, string) + if worked: + query = 'SELECT vend_success(%s)'%id + self.db.query(query).getresult() else: - self.await_prompt() - return (code, text) - - def handle_event(self, code, text): - pass - - def authed_message(self, message): - if self.challenge == None: - return message - crc = do_crc('%c%c'%(self.challenge >> 8, self.challenge & 0xff)) - crc = do_crc(self.secret, crc) - crc = do_crc(message, crc) - return message+'|'+('%04x'%crc) - - def ping(self): - self.wfh.write('PING\n') - (code, string) = self.get_response() - return (code == '000', code, string) - - def vend(self, item): - if not re.search('^[0-9][0-9]$', item): - return (False, 'Invalid item requested (%s)'%item) - self.wfh.write(self.authed_message(('V%s\n'%item)+'\n')) - (code, string) = self.get_response() - return (code, string) - - def beep(self, duration = None, synchronous = True): - msg = 'B' - if synchronous: msg += 'S' - if duration != None: - if duration > 255: duration = 255 - if duration < 1: duration = 1 - msg += '%02x'%duration - self.wfh.write(msg+'\n') - (code, string) = self.get_response() - return (code == '500', code, string) - - def silence(self, duration = None, synchronous = True): - msg = 'C' - if synchronous: msg += 'S' - if duration != None: - if duration > 255: duration = 255 - if duration < 1: duration = 1 - msg += '%02x'%duration - self.wfh.write(msg+'\n') - (code, string) = self.get_response() - # FIXME: workaround a bug in rom W. should be just: return (code == '500', code, string) - return (code == '500' or code == '501', code, string) - - def display(self, string): - if len(string) > 10: - string = string[0:10] - self.wfh.write('D'+string+'\n') - (code, string) = self.get_response() - return (code == '300', code, string) + query = 'SELECT vend_failed(%s)'%id + self.db.query(query).getresult() + + def handle_events(self): + notifier = self.db.getnotify() + while notifier is not None: + self.process_requests() + notify = self.db.getnotify() + +def get_pin(uid): + try: + info = pwd.getpwuid(uid) + except KeyError: + return None + if info.pw_dir == None: return False + pinfile = os.path.join(info.pw_dir, '.pin') + try: + s = os.stat(pinfile) + except OSError: + return False + if s.st_mode & 077: + return None + try: + f = file(pinfile) + except IOError: + return None + pinstr = f.readline() + f.close() + if not re.search('^'+'[0-9]'*PIN_LENGTH+'$', pinstr): + return None + return int(pinstr) + +def has_good_pin(uid): + return get_pin != None + +def verify_user_pin(uid, pin): + if get_pin(uid) == pin: + info = pwd.getpwuid(uid) + return info.pw_name + else: + return None + +def door_open_mode(vending_machine): + print "Entering open door mode" + v.display("DOOR OPEN") + while True: + v.wait_for_events(1) + while True: + e = v.next_event() + if e == None: break + (event, params) = e + if event == DOOR: + if params == 1: # door closed + v.display("BYE BYE!") + time.sleep(1) + return if __name__ == '__main__': # Open vending machine via LAT @@ -122,7 +92,114 @@ if __name__ == '__main__': (rfh, wfh) = latclient.get_fh() v = VendingMachine(rfh, wfh) print 'PING is', v.ping() - print 'BEEP is', v.beep() - print 'VEND 11 is', v.vend('11') - print 'SILENCE is', v.silence() - print 'DISPLAY is', v.display('GOOD NIGHT') + #print 'BEEP is', v.beep() + #print 'VEND 11 is', v.vend('11') + #print 'SILENCE is', v.silence() + #print 'DISPLAY is', v.display('WELCOME') + print 'S is', v.get_switches() + + db = DispenseDatabase(v) + db.process_requests() + cur_user = '' + cur_pin = '' + cur_selection = '' + + scrolling_message = [GREETING] + scrolling_wraps = False + need_repaint = True + timeout = None + last_tick = time.time() + + while True: + if timeout != None and timeout > 0 and time.time() > last_tick+1: + timeout -= 1 + if len(scrolling_message) > 0: + need_repaint = True + if need_repaint and len(scrolling_message) > 0: + v.display(scrolling_message[0]) + if scrolling_wraps: + scrolling_message.append(scrolling_message[0]) + del scrolling_message[0] + need_repaint = False + + v.wait_for_events(1) + while True: + e = v.next_event() + if e == None: break + (event, params) = e + if event == DOOR: + if params == 0: + door_open_mode(v); + cur_user = '' + cur_pin = '' + scrolling_message = [GREETING] + scrolling_wraps = False + need_repaint = True + elif event == SWITCH: + # don't care right now. + pass + elif event == KEY: + key = params + # complicated key handling here: + if len(cur_user) < 5: + if key == 11: + cur_user = '' + scrolling_message = [GREETING] + scrolling_wraps = False + need_repaint = True + continue + cur_user += chr(key + ord('0')) + v.display('UID: '+cur_user) + if len(cur_user) == 5: + uid = int(cur_user) + if not has_good_pin(uid): + v.display('PIN NO GOOD') + time.sleep(1) + continue + v.display('PIN: ') + continue + elif len(cur_pin) < PIN_LENGTH: + if key == 11: + if cur_pin == '': + cur_user = '' + scrolling_message = [GREETING] + scrolling_wraps = False + need_repaint = True + continue + cur_pin = '' + v.display('PIN: ') + continue + cur_pin += chr(key + ord('0')) + v.display('PIN: '+'X'*len(cur_pin)) + if len(cur_pin) == PIN_LENGTH: + name = verify_user_pin(int(cur_user), int(cur_pin)) + if name: + v.beep(0, False) + cur_selection = '' + + scrolling_message = [' WELCOME ', name] + scrolling_message.append('OR A SNACK') + scrolling_wraps = True + need_repaint = True + else: + v.beep(255, False) + scrolling_message = [' BAD PIN ', ' SORRY ', GREETING] + scrolling_wraps = False + need_repaint = True + + cur_user = '' + cur_pin = '' + continue + elif len(cur_selection) < 2: + if key == 11: + if cur_selection == '': + cur_pin = '' + cur_user = '' + v.display(GREETING) + continue + cur_selection += chr(key + ord('0')) + if len(cur_selection) == 2: + make_selection(cur_selection) + + + db.handle_events()