X-Git-Url: https://git.ucc.asn.au/?p=zanchey%2Fdispense2.git;a=blobdiff_plain;f=sql-edition%2Fservers%2FVendServer.py;h=184546cf1185190e5657ac5dbb002aa672629ad4;hp=25a24b68a1cd81243a53d1e1633779542fa46207;hb=e462ec5b3bed1437b58a6fa88652089dcd0c70d4;hpb=62cea4c2f0e367c6784f2f294a5a47f1bbc021be diff --git a/sql-edition/servers/VendServer.py b/sql-edition/servers/VendServer.py index 25a24b6..184546c 100755 --- a/sql-edition/servers/VendServer.py +++ b/sql-edition/servers/VendServer.py @@ -1,17 +1,29 @@ #!/usr/bin/python +# vim:ts=4 -import sys, os, string, time, re, pwd -import pg +USE_DB = 0 + +import sys, os, string, re, pwd +if USE_DB: import pg +from time import time, sleep +from popen2 import popen2 from LATClient import LATClient from VendingMachine import VendingMachine +from ConfigParser import ConfigParser +from HorizScroll import HorizScroll +from random import random, seed GREETING = 'UCC SNACKS' PIN_LENGTH = 4 +DOOR = 1 +SWITCH = 2 +KEY = 3 + class DispenseDatabase: - def __init__(self, vending_machine): + def __init__(self, vending_machine, host, name, user, password): self.vending_machine = vending_machine - self.db = pg.DB(dbname = 'dispense', host = 'dispense.ucc.gu.uwa.edu.au', user = 'vendserver', passwd = 'revresdnev') + self.db = pg.DB(dbname = name, host = host, user = user, passwd = password) self.db.query('LISTEN vend_requests') def process_requests(self): @@ -38,6 +50,32 @@ class DispenseDatabase: 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) @@ -48,7 +86,7 @@ def get_pin(uid): try: s = os.stat(pinfile) except OSError: - return False + return None if s.st_mode & 077: return None try: @@ -62,7 +100,7 @@ def get_pin(uid): return int(pinstr) def has_good_pin(uid): - return get_pin != None + return get_pin(uid) != None def verify_user_pin(uid, pin): if get_pin(uid) == pin: @@ -73,133 +111,320 @@ def verify_user_pin(uid, pin): def door_open_mode(vending_machine): print "Entering open door mode" - v.display("DOOR OPEN") + v.display("-FEED ME-") 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 + 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 + +class Idler: + def __init__(self, v): + self.idle_state = 0 + self.v = v + + def put_shark(self, s, l): + if self.s[l] == ' ': + self.s[l] = s + elif self.s[l] == 'X': + self.s[l] = '*' + else: + self.s[l] = 'X' + + def next(self): + # does the next stage of a dance + self.s = [' ']*10 + shark1 = self.idle_state % 18 + if shark1 < 9: + self.put_shark('^', shark1) + else: + self.put_shark('^', 18-shark1) + + shark2 = ((self.idle_state+4) % 36)/2 + if shark2 < 9: + self.put_shark('<', shark2) + else: + self.put_shark('<', 18-shark2) + + shark3 = ((self.idle_state+7) % 54)/3 + if shark3 < 9: + self.put_shark('>', 9-shark3) + else: + self.put_shark('>', 9-(18-shark3)) + + train1 = ((self.idle_state%(18*36))) + train1_start = 122 + if train1 > train1_start and train1 < train1_start+(10*2): + for i in range(5): + ptr = i+train1-train1_start-5 + if ptr >= 0 and ptr < 10: self.s[ptr] = '#' + + train2 = ((self.idle_state%(18*36))) + train2_start = 400 + if train2 > train2_start and train2 < train2_start+(10*2): + for i in range(5): + ptr = i+train2-train2_start-5 + if ptr >= 0 and ptr < 10: self.s[9-ptr] = '#' + + train3 = ((self.idle_state%(18*36))) + train3_start = 230 + if train3 > train3_start and train3 < train3_start+(10*2): + for i in range(10): + ptr = i+train3-train3_start-10 + if ptr >= 0 and ptr < 10: self.s[ptr] = '-' + + self.v.display(string.join(self.s, '')) + self.idle_state += 1 + self.idle_state %= 18*36*54 + +def cookie(v): + seed(time()) + messages = [' WASSUP! ', 'PINK FISH ', ' SECRETS '] + 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 = '' + 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')) + else: + s += msg[i] + reveal += 1 + reveal %= 173 + v.display(s) + +def center(str): + LEN = 10 + return ' '*((LEN-len(str))/2)+str + +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 if __name__ == '__main__': + cp = ConfigParser() + cp.read('/etc/dispense/servers.conf') + DBServer = cp.get('Database', 'Server') + DBName = cp.get('Database', 'Name') + DBUser = cp.get('VendingMachine', 'DBUser') + DBPassword = cp.get('VendingMachine', 'DBPassword') + + ServiceName = cp.get('VendingMachine', 'ServiceName') + ServicePassword = cp.get('VendingMachine', 'Password') # Open vending machine via LAT - latclient = LATClient(service = 'VEND', password = 'dmscptd') - (rfh, wfh) = latclient.get_fh() + if 0: + latclient = LATClient(service = ServiceName, password = ServicePassword) + (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(('localhost', 5150)) + rfh = sock.makefile('r') + wfh = sock.makefile('w') 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('WELCOME') - print 'S is', v.get_switches() - - db = DispenseDatabase(v) - db.process_requests() + + if USE_DB: db = DispenseDatabase(v, DBServer, DBName, DBUser, DBPassword) cur_user = '' cur_pin = '' cur_selection = '' - scrolling_message = [GREETING] - scrolling_wraps = False - need_repaint = True - timeout = None - last_tick = time.time() + mk = MessageKeeper(v) + mk.set_message(GREETING) + time_to_autologout = None + idler = Idler(v) + time_to_idle = None + last_timeout_refresh = None 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); + if USE_DB: db.handle_events() + + if time_to_autologout != None: + time_left = time_to_autologout - time() + if time_left < 5 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 + (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)]) + cur_user = '' + cur_pin = '' + continue 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: + mk.set_message('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 + mk.set_message(GREETING) 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: ') + 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 - elif len(cur_pin) < PIN_LENGTH: - if key == 11: - if cur_pin == '': - cur_user = '' - scrolling_message = [GREETING] - scrolling_wraps = False - need_repaint = 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 = '' - 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() + elif len(cur_selection) == 0: + if key == 11: + cur_pin = '' + cur_user = '' + cur_selection = '' + v.display('BYE!') + sleep(0.5) + mk.set_message(GREETING) + 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': + v.display('GOT DOOR?') + os.system('su - "%s" -c "dispense door"'%username) + 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() + 10