-import socket, os, stat, struct, pwd
+import socket, os, stat, struct, pwd, errno
from statemachine import StateMachine
from libtuer import logger
SO_PEERCRED = 17 # DO - NOT - TOUCH
CMDs = {
b'buzz': StateMachine.CMD_BUZZ,
b'unlock': StateMachine.CMD_UNLOCK,
+ b'lock': StateMachine.CMD_LOCK,
+ b'fallback_mode_on': StateMachine.CMD_FALLBACK_ON,
+ b'fallback_mode_off': StateMachine.CMD_FALLBACK_OFF,
+ b'status': StateMachine.CMD_STATUS,
}
def __init__(self, sm):
self._sock.listen(1)
def _answer(self, conn):
- def answer(msg):
+ def answer(msg, lastMsg = True):
# this is called in another thread, so it should be quick and not touch the TySocket
waynesend(conn, msg)
- conn.close()
+ if lastMsg:
+ conn.close()
return answer
def accept(self):
if data in self.CMDs:
self._sm.callback(self.CMDs[data], self._answer(conn))
# _answer will be called, and it will close the connection
+ continue # make sure we break so we don't close it
else:
waynesend(conn, 'Command not found')
- conn.close()
except KeyboardInterrupt:
raise # forward Ctrl-C to the outside
+ except socket.timeout:
+ # it's okay
+ logger.info("TySocket: Connection timed out")
except Exception as e:
- logger.error("TySocket: Something went wrong: %s" % str(e))
+ logger.critical("TySocket: Something went wrong: %s" % str(e))
+ conn.close()