X-Git-Url: https://git.ucc.asn.au/?p=zanchey%2Fdispense2.git;a=blobdiff_plain;f=sql-edition%2Fservers%2FVendServer.py;h=974e0b47b4eb424a70626ce62b5a4de17d0b6894;hp=57a26828471779d39b2f2b52679e40285d6f65fd;hb=7bfe9ec40785e65c830225cc9f006f9012c3f7b7;hpb=891e6406bd0428b82706bbbcc5d71ffc1463b18f diff --git a/sql-edition/servers/VendServer.py b/sql-edition/servers/VendServer.py index 57a2682..974e0b4 100755 --- a/sql-edition/servers/VendServer.py +++ b/sql-edition/servers/VendServer.py @@ -1,44 +1,482 @@ #!/usr/bin/python +# vim:ts=4 -import sys, os, string, socket, time +USE_DB = 0 + +import ConfigParser +import sys, os, string, re, pwd, signal +from traceback import print_tb +if USE_DB: import pg +from time import time, sleep from popen2 import popen2 -from pyPgSQL import PgSQL -from LATClient import LATClient - -class VendingMachine: - def __init__(self, rfh, wfh): - self.rfh = rfh - self.wfh = wfh - self.wfh.write('\n') - self.await_prompt() - - def await_prompt(self): - self.wfh.flush() - state = 0 - s = '' - while state != 3: - s = self.rfh.read(1) - if s == '': raise Exception - if s == '\n' and state == 0: state = 1 - if s == '#' and state == 1: state = 2 - if s == ' ' and state == 2: state = 3 - - def get_response(self): - self.wfh.flush() +from LATClient import LATClient, LATClientException +from VendingMachine import VendingMachine, VendingException +from HorizScroll import HorizScroll +from random import random, seed +from Idler import TrainIdler,GrayIdler +import socket +from posix import geteuid + +GREETING = 'UCC SNACKS' +PIN_LENGTH = 4 + +DOOR = 1 +SWITCH = 2 +KEY = 3 + +class DispenseDatabase: + def __init__(self, vending_machine, host, name, user, password): + self.vending_machine = vending_machine + self.db = pg.DB(dbname = name, host = host, user = user, passwd = password) + 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: + 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 scroll_options(username, mk, welcome = False): + if welcome: + msg = [(center('WELCOME'), False, 0.8), + (center(username), False, 0.8)] + else: + msg = [] + choices = ' '*10+'CHOICES: ' + try: + coke_machine = file('/home/other/coke/coke_contents') + cokes = coke_machine.readlines() + coke_machine.close() + except: + cokes = [] + pass + for c in cokes: + c = c.strip() + (slot_num, price, slot_name) = c.split(' ', 2) + if slot_name == 'dead': continue + choices += '%s8-%s (%sc) '%(slot_num, slot_name, price) + choices += '55-DOOR ' + choices += 'OR A SNACK. ' + choices += '99 TO READ AGAIN. ' + choices += 'CHOICE? ' + msg.append((choices, False, None)) + mk.set_messages(msg) + +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 None + 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(uid) != 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(v): + print "Entering open door mode" + v.display("-FEED ME-") + while True: + e = v.next_event() + if e == None: break + (event, params) = e + if event == DOOR: + if params == 1: # door closed + v.display("-YUM YUM!-") + sleep(1) + return + +def cookie(v): + seed(time()) + messages = [' WASSUP! ', 'PINK FISH ', ' SECRETS ', ' ESKIMO ', ' FORTUNES ', 'MORE MONEY'] + choice = int(random()*len(messages)) + msg = messages[choice] + left = range(len(msg)) + for i in range(len(msg)): + if msg[i] == ' ': left.remove(i) + reveal = 1 + while left: s = '' - while s == '': - s = self.rfh.readline() - if s == '': return None - s = s.strip('\r\n') - return s + for i in range(0, len(msg)): + if i in left: + if reveal == 0: + left.remove(i) + s += msg[i] + else: + s += chr(int(random()*26)+ord('A')) + reveal += 1 + reveal %= 17 + else: + s += msg[i] + v.display(s) - def ping(self): - self.wfh.write('PING\n') - return self.get_response() +def center(str): + LEN = 10 + return ' '*((LEN-len(str))/2)+str -if __name__ == '__main__': - # Open vending machine via LAT - latclient = LATClient(service = 'VEND', password = 'dmscptd') - (rfh, wfh) = latclient.get_fh() +class MessageKeeper: + def __init__(self, vendie): + # Each element of scrolling_message should be a 3-tuple of + # ('message', True/False if it is to be repeated, time to display) + self.scrolling_message = [] + self.v = vendie + self.next_update = None + + def set_message(self, string): + self.scrolling_message = [(string, False, None)] + self.update_display(True) + + def set_messages(self, strings): + self.scrolling_message = strings + self.update_display(True) + + def update_display(self, forced = False): + if not forced and self.next_update != None and time() < self.next_update: + return + if len(self.scrolling_message) > 0: + if len(self.scrolling_message[0][0]) > 10: + (m, r, t) = self.scrolling_message[0] + a = [] + exp = HorizScroll(m).expand(padding = 0, wraparound = True) + if t == None: + t = 0.1 + else: + t = t / len(exp) + for x in exp: + a.append((x, r, t)) + del self.scrolling_message[0] + self.scrolling_message = a + self.scrolling_message + newmsg = self.scrolling_message[0] + if newmsg[2] != None: + self.next_update = time() + newmsg[2] + else: + self.next_update = None + self.v.display(self.scrolling_message[0][0]) + if self.scrolling_message[0][1]: + self.scrolling_message.append(self.scrolling_message[0]) + del self.scrolling_message[0] + + def done(self): + return len(self.scrolling_message) == 0 + +def run_forever(rfh, wfh, options, cf): v = VendingMachine(rfh, wfh) - print v.ping() + print 'PING is', v.ping() + + if USE_DB: db = DispenseDatabase(v, cf.DBServer, cf.DBName, cf.DBUser, cf.DBPassword) + cur_user = '' + cur_pin = '' + cur_selection = '' + + mk = MessageKeeper(v) + mk.set_message(GREETING) + time_to_autologout = None + #idler = TrainIdler(v) + #idler = GrayIdler(v) + idler = GrayIdler(v,one="*",zero="-") + time_to_idle = None + last_timeout_refresh = None + + while True: + if USE_DB: db.handle_events() + + if time_to_autologout != None: + time_left = time_to_autologout - time() + if time_left < 6 and (last_timeout_refresh is None or last_timeout_refresh > time_left): + mk.set_message('LOGOUT: '+str(int(time_left))) + last_timeout_refresh = int(time_left) + cur_selection = '' + + if time_to_autologout != None and time_to_autologout - time() <= 0: + time_to_autologout = None + cur_user = '' + cur_pin = '' + cur_selection = '' + mk.set_message(GREETING) + + if time_to_autologout and not mk.done(): time_to_autologout = None + if cur_user == '' and time_to_autologout: time_to_autologout = None + if len(cur_pin) == PIN_LENGTH and mk.done() and time_to_autologout == None: + # start autologout + time_to_autologout = time() + 15 + + if time_to_idle == None and cur_user == '': time_to_idle = time() + 60 + if time_to_idle != None and cur_user != '': time_to_idle = None + if time_to_idle is not None and time() > time_to_idle: idler.next() + + mk.update_display() + + e = v.next_event(0) + if e == None: + e = v.next_event(0.1) + if e == None: + continue + time_to_idle = None + (event, params) = e + print e + if event == DOOR: + if params == 0: + door_open_mode(v); + cur_user = '' + cur_pin = '' + mk.set_message(GREETING) + 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 = '' + mk.set_message(GREETING) + continue + cur_user += chr(key + ord('0')) + mk.set_message('UID: '+cur_user) + if len(cur_user) == 5: + uid = int(cur_user) + if not has_good_pin(uid): + #mk.set_messages( + #[(center('INVALID'), False, 0.7), + #(center('PIN'), False, 0.7), + #(center('SETUP'), False, 1.0), + #(GREETING, False, None)]) + mk.set_messages( + [(' '*10+'INVALID PIN SETUP'+' '*10, False, 3), + (GREETING, False, None)]) + cur_user = '' + cur_pin = '' + continue + cur_pin = '' + mk.set_message('PIN: ') + continue + elif len(cur_pin) < PIN_LENGTH: + if key == 11: + if cur_pin == '': + cur_user = '' + mk.set_message(GREETING) + continue + cur_pin = '' + mk.set_message('PIN: ') + continue + cur_pin += chr(key + ord('0')) + mk.set_message('PIN: '+'X'*len(cur_pin)) + if len(cur_pin) == PIN_LENGTH: + username = verify_user_pin(int(cur_user), int(cur_pin)) + if username: + v.beep(0, False) + cur_selection = '' + scroll_options(username, mk, True) + continue + else: + v.beep(40, False) + mk.set_messages( + [(center('BAD PIN'), False, 1.0), + (center('SORRY'), False, 0.5), + (GREETING, False, None)]) + cur_user = '' + cur_pin = '' + continue + elif len(cur_selection) == 0: + if key == 11: + cur_pin = '' + cur_user = '' + cur_selection = '' + mk.set_messages( + [(center('BYE!'), False, 1.5), + (GREETING, False, None)]) + continue + cur_selection += chr(key + ord('0')) + mk.set_message('SELECT: '+cur_selection) + time_to_autologout = None + elif len(cur_selection) == 1: + if key == 11: + cur_selection = '' + time_to_autologout = None + scroll_options(username, mk) + continue + else: + cur_selection += chr(key + ord('0')) + #make_selection(cur_selection) + # XXX this should move somewhere else: + if cur_selection == '55': + mk.set_message('OPENSESAME') + if geteuid() == 0: + ret = os.system('su - "%s" -c "dispense door"'%username) + else: + ret = os.system('dispense door') + if ret == 0: + mk.set_message(center('DOOR OPEN')) + else: + mk.set_message(center('BAD DOOR')) + sleep(1) + elif cur_selection == '91': + cookie(v) + elif cur_selection == '99': + scroll_options(username, mk) + cur_selection = '' + continue + elif cur_selection[1] == '8': + v.display('GOT COKE?') + os.system('su - "%s" -c "dispense %s"'%(username, cur_selection[0])) + else: + v.display('HERES A '+cur_selection) + v.vend(cur_selection) + sleep(0.5) + v.display('THANK YOU') + sleep(0.5) + cur_selection = '' + time_to_autologout = time() + 8 + +def connect_to_vend(options, cf): + # Open vending machine via LAT? + if options.use_lat: + latclient = LATClient(service = cf.ServiceName, password = cf.ServicePassword, server_name = cf.ServerName, connect_password = cf.ConnectPassword, priv_password = cf.PrivPassword) + rfh, wfh = latclient.get_fh() + else: + #(rfh, wfh) = popen2('../../virtualvend/vvend.py') + import socket + sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM, 0) + sock.connect((options.host, options.port)) + rfh = sock.makefile('r') + wfh = sock.makefile('w') + + return rfh, wfh + +def parse_args(): + from optparse import OptionParser + + op = OptionParser(usage="%prog [OPTION]...") + op.add_option('-f', '--config-file', default='/etc/dispense/servers.conf', metavar='FILE', dest='config_file', help='use the specified config file instead of /etc/dispense/servers.conf') + op.add_option('-v', '--virtualvend', action='store_false', default=True, dest='use_lat', help='use the virtual vending server instead of LAT') + op.add_option('-n', '--hostname', dest='host', default='localhost', help='the hostname to connect to for virtual vending machine mode (default: localhost)') + op.add_option('-p', '--port', dest='port', default=5150, type='int', help='the port number to connect to (default: 5150)') + op.add_option('-l', '--log-file', metavar='FILE', dest='log_file', default='', help='log output to the specified file') + op.add_option('-s', '--syslog', dest='syslog', action='store_true', default=False, help='log output to syslog') + op.add_option('-d', '--daemon', dest='daemon', action='store_true', default=False, help='run as a daemon') + options, args = op.parse_args() + + if len(args) != 0: + op.error('extra command line arguments: ' + ' '.join(args)) + + return options + +config_options = { + 'DBServer': ('Database', 'Server'), + 'DBName': ('Database', 'Name'), + 'DBUser': ('VendingMachine', 'DBUser'), + 'DBPassword': ('VendingMachine', 'DBPassword'), + + 'ServiceName': ('VendingMachine', 'ServiceName'), + 'ServicePassword': ('VendingMachine', 'Password'), + + 'ServerName': ('DecServer', 'Name'), + 'ConnectPassword': ('DecServer', 'ConnectPassword'), + 'PrivPassword': ('DecServer', 'PrivPassword'), + } + +class VendConfigFile: + def __init__(self, config_file, options): + try: + cp = ConfigParser.ConfigParser() + cp.read(config_file) + + for option in options: + section, name = options[option] + value = cp.get(section, name) + self.__dict__[option] = value + + except ConfigParser.Error, e: + print "Error reading config file "+config_file+": " + str(e) + sys.exit(1) + +def do_vend_server(): + options = parse_args() + config_opts = VendConfigFile(options.config_file, config_options) + + while True: + try: + rfh, wfh = connect_to_vend(options, config_opts) + except (LATClientException, socket.error), e: + (exc_type, exc_value, exc_traceback) = sys.exc_info() + del exc_traceback + print + print "Connection error: "+str(exc_type)+" "+str(e) + print "Trying again in 5 seconds." + sleep(5) + continue + try: + run_forever(rfh, wfh, options, config_opts) + except VendingException: + print + print "Connection died, trying again..." + +if __name__ == '__main__': + def do_nothing(signum, stack): pass + def stop_server(signum, stack): raise KeyboardInterrupt + signal.signal(signal.SIGHUP, do_nothing) + signal.signal(signal.SIGTERM, stop_server) + signal.signal(signal.SIGINT, stop_server) + while True: + try: + do_vend_server() + except KeyboardInterrupt: + print "Killed by signal." + break + except SystemExit, e: + raise e + except: + (exc_type, exc_value, exc_traceback) = sys.exc_info() + print + print "Uh-oh, unhandled " + str(exc_type) + " exception" + print "Message: ", str(exc_value) + print + print_tb(exc_traceback) + del exc_traceback + print + print "This message should be considered a bug in the Vend Server." + print "Please report this to someone who can fix it." + sleep(10) + print + print "Trying again anyway (might not help, but hey...)" +