Implement Call Recording for STT and Replay #3
@@ -187,7 +187,7 @@ async def mqtt_lifecycle_manager():
|
|||||||
payload = {
|
payload = {
|
||||||
"node_id": NODE_ID,
|
"node_id": NODE_ID,
|
||||||
"status": "online",
|
"status": "online",
|
||||||
"timestamp": datetime.now().isoformat(),
|
"timestamp": datetime.utcnow().isoformat(),
|
||||||
"is_listening": op25_status.get("is_running", False),
|
"is_listening": op25_status.get("is_running", False),
|
||||||
"active_system": op25_status.get("active_system"),
|
"active_system": op25_status.get("active_system"),
|
||||||
# Only scan library if needed, otherwise it's heavy I/O
|
# Only scan library if needed, otherwise it's heavy I/O
|
||||||
@@ -307,7 +307,7 @@ async def mqtt_lifecycle_manager():
|
|||||||
break
|
break
|
||||||
if current_tgid: break
|
if current_tgid: break
|
||||||
|
|
||||||
now = datetime.now()
|
now = datetime.utcnow()
|
||||||
|
|
||||||
# Logic for handling call start/end events
|
# Logic for handling call start/end events
|
||||||
if current_tgid != 0:
|
if current_tgid != 0:
|
||||||
|
|||||||
Reference in New Issue
Block a user