envoie du message au process sur mise à jour des horaires
This commit is contained in:
@@ -136,7 +136,7 @@ def update_params():
|
||||
with open(current_app.config['DB_PATH'], 'w') as f:
|
||||
json.dump(data, f)
|
||||
|
||||
conn = Sock(addr=current_app.config['UNIX_ADDR'], logger=current_app.logger)
|
||||
conn = Sock(addr=current_app.config['UNIX_ADDR'], logger=current_app.logger)
|
||||
if not conn.connect():
|
||||
current_app.logger.error("impossible de se connecter au serveur")
|
||||
abort(status.HTTP_406_NOT_ACCEPTABLE, description="Impossible de se connecter au serveur")
|
||||
|
||||
@@ -24,6 +24,8 @@ import shutil
|
||||
import hashlib
|
||||
from werkzeug.exceptions import HTTPException
|
||||
|
||||
from ConfBack.manager import Sock
|
||||
|
||||
#########################################################
|
||||
# Class et Methods #
|
||||
|
||||
@@ -116,6 +118,19 @@ def update_scheduler():
|
||||
|
||||
with open(current_app.config['DB_PATH'], 'w') as f:
|
||||
json.dump(data_db, f)
|
||||
|
||||
conn = Sock(addr=current_app.config['UNIX_ADDR'], logger=current_app.logger)
|
||||
if not conn.connect():
|
||||
current_app.logger.error("impossible de se connecter au serveur")
|
||||
abort(status.HTTP_406_NOT_ACCEPTABLE, description="Impossible de se connecter au serveur")
|
||||
|
||||
# send order to KineIntercom process
|
||||
if not conn.send(b"RELOAD_HOURS\n"):
|
||||
conn.disconnect()
|
||||
current_app.logger.error("impossible de communiquer avec le serveur")
|
||||
abort(status.HTTP_406_NOT_ACCEPTABLE, description="Impossible de communiquer avec le serveur")
|
||||
|
||||
conn.disconnect()
|
||||
content = {'message':'maj parameters successful!'}
|
||||
return content, status.HTTP_200_OK
|
||||
|
||||
|
||||
Reference in New Issue
Block a user