clair/CVM-Sentry
1
0
Fork 0
Code Activity

log change

Browse Source
This commit is contained in:
Clair Delafuente
2025-10-13 10:29:37 -04:00
parent c5d7c7d24c
commit 906f26c220
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cvmsentry.py
View File

@@ -24,7 +24,7 @@ LOG_LEVEL = getattr(config, "log_level", "INFO")
if not os.path.exists("logs"): if not os.path.exists("logs"):
os.makedirs("logs") os.makedirs("logs")
log_format = logging.Formatter( log_format = logging.Formatter(
"[%(asctime)s:%(name)s] {%(filename)s:%(lineno)d} %(levelname)s - %(message)s" "[%(asctime)s:%(name)s] %(levelname)s - %(message)s"
) )
stdout_handler = logging.StreamHandler(sys.stdout) stdout_handler = logging.StreamHandler(sys.stdout)
stdout_handler.setFormatter(log_format) stdout_handler.setFormatter(log_format)
@@ -377,7 +377,6 @@ async def connect(vm_name: str):
queue == vms[vm_name]["turn_queue"] queue == vms[vm_name]["turn_queue"]
and current_turn == vms[vm_name]["active_turn_user"] and current_turn == vms[vm_name]["active_turn_user"]
): ):
# log.debug(f"({STATE.name} - {vm_name}) Incoming turn update matches the VM's state. Dropping update.")
continue continue
for user in vms[vm_name]["users"]: for user in vms[vm_name]["users"]:
vms[vm_name]["turn_queue"] = queue vms[vm_name]["turn_queue"] = queue
@@ -385,6 +384,8 @@ async def connect(vm_name: str):
current_turn if current_turn != "" else None current_turn if current_turn != "" else None
) )
if current_turn: if current_turn:
log.info(f"[{vm_name}] It's now {current_turn}'s turn. Queue: {queue}")
utc_now = datetime.now(timezone.utc) utc_now = datetime.now(timezone.utc)
utc_day = utc_now.strftime("%Y-%m-%d") utc_day = utc_now.strftime("%Y-%m-%d")
timestamp = utc_now.isoformat() timestamp = utc_now.isoformat()
@@ -410,9 +411,6 @@ async def connect(vm_name: str):
log_file.seek(0) log_file.seek(0)
json.dump(log_data, log_file, indent=4) json.dump(log_data, log_file, indent=4)
log_file.truncate() log_file.truncate()
# log.debug(
# f"({STATE.name} - {vm_name}) Turn update: turn_time={turn_time}, count={count}, current_turn={current_turn}, queue={queue}"
# )
case ["remuser", count, *list]: case ["remuser", count, *list]:
for i in range(int(count)): for i in range(int(count)):