diff --git a/kineintercom/intercom.py b/kineintercom/intercom.py index df6ac30..63de0d4 100644 --- a/kineintercom/intercom.py +++ b/kineintercom/intercom.py @@ -562,19 +562,26 @@ def listener(sock, logger): try: data += clientsocket.recv(1) if data.decode('utf-8').endswith('\n'): + logger.debug("datas recv: {}".format(data.decode('utf-8'))) if data.decode('utf-8').startswith('RELOAD_DB'): - logger.debug("==> RELOAD DB") FLAG_CONF_UPDATE = True + data = b'' elif data.decode('utf-8').startswith('RELOAD_HOURS'): - logger.debug("==> RELOAD HOURS") FLAG_CONF_UPDATE = True FLAG_HORAIRE_UPDATE = True + data = b'' + elif data.decode('utf-8').startswith('ALIVE?'): + clientsocket.sendall(b"ALIVE\n") + data = b'' + elif len(data) == 0: + # deconnexion du client + logger.info("deconnexion du client ...") clientsocket = None flag = False except: continue - if not data: - break + #if not data: + # break logger.debug("Fin du serveur de communication") return @@ -954,6 +961,7 @@ def main(): minute='*', id="job_id") FLAG_HORAIRE_UPDATE = False + FLAG_CONF_UPDATE = False # Si le module GSM est ouvert