krebs/taobin_sheet
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[sheet-service] update recovery payload

Browse source
This commit is contained in:
Ittipat Lusuk 2026-05-25 14:36:26 +07:00
parent 0296cb57f0
commit 3bb8351d55
1 changed files with 8 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

21
main.py
View file

@ -221,11 +221,18 @@ def timeout_sweeper_task():
if lock: if lock:
try: try:
payload = lock.get("payload", {})
# recovery Channel # recovery Channel
recovery_payload = { recovery_payload = {
"type": "recovery", "type": "recovery",
"payload": lock.get("payload", {}) "payload": {
"user_info": payload.get("user_info"),
"srv_name": "gen-service",
"values": payload.get("values")
} }
}
r.publish(RECOVERY_CHANNEL, json.dumps(recovery_payload)) r.publish(RECOVERY_CHANNEL, json.dumps(recovery_payload))
print(f"[{SERVICE_NAME}] User {user_id} timed out from {catalog}. Sent to recovery.") print(f"[{SERVICE_NAME}] User {user_id} timed out from {catalog}. Sent to recovery.")
except Exception as e: except Exception as e:
@ -320,18 +327,6 @@ def redis_message_handler():
lock_manager.release(country, catalog, user_id) lock_manager.release(country, catalog, user_id)
print(f"[{SERVICE_NAME}] Exit Room (Force/Command): {catalog} | User: {user_id}") print(f"[{SERVICE_NAME}] Exit Room (Force/Command): {catalog} | User: {user_id}")
try:
# public recovery files
recovery_payload = {
"type": "recovery",
"payload": payload,
}
r.publish(RECOVERY_CHANNEL, json.dumps(recovery_payload))
print(f"[{SERVICE_NAME}] Sent user {user_id} to recovery channel (Exit).")
except Exception as e:
print(f"[{SERVICE_NAME}] Failed to sent user {user_id} to recovery channel (Exit).")
elif channel == GET_CATALOG_CHANNEL: elif channel == GET_CATALOG_CHANNEL:
try: try:
if not FRONTEND_NOTIFY_URL: if not FRONTEND_NOTIFY_URL: