from presence import Presence
def handleInterrupt(sig, frame):
- global stopped
+ global stop
if os.getpid() == mainPid:
logging.info( "Got stop signal." )
- stopped = True
+ stop = True
for presence in presences:
presence.stop()
mainPid = os.getpid()
signal.signal(signal.SIGINT, handleInterrupt)
-stopped = False
+stop = False
if len(sys.argv) != 2:
print("Usage: %s <config json>" % sys.argv[0])
with open(sys.argv[1]) as configFile:
config = json.load(configFile)
-while not stopped:
+fifo_dir = os.getenv('MTXBOT_FIFO_DIR', '/run/mtxbot')
+
+while not stop:
presences = []
- for entry in os.listdir(config['paths']['fifodir']):
- fullpath = "%s/%s" % (config['paths']['fifodir'], entry)
+ for entry in os.listdir(fifo_dir):
+ fullpath = "%s/%s" % (fifo_dir, entry)
if stat.S_ISFIFO(os.stat(fullpath).st_mode):
logging.info("Creating presence for %s..." % entry)
presences.append( Presence(entry, fullpath) )
logging.error("No fifos could be found!")
break
asyncio.run(main())
- if not stopped:
+ if not stop:
logging.warning("Main loop exited!")
logging.info("Restarting after grace period...")
time.sleep(3.0)