Implement Call Recording for STT and Replay #3
@@ -3,4 +3,7 @@ MQTT_BROKER=
|
||||
ICECAST_SERVER=
|
||||
AUDIO_BUCKET=
|
||||
NODE_LAT=
|
||||
NODE_LONG=
|
||||
NODE_LONG=
|
||||
HTTP_SERVER_PROTOCOL=
|
||||
HTTP_SERVER_ADDRESS=
|
||||
HTTP_SERVER_PORT=
|
||||
@@ -20,6 +20,9 @@ app.include_router(create_op25_router(), prefix="/op25")
|
||||
# Configuration
|
||||
NODE_ID = os.getenv("NODE_ID", "standalone-node")
|
||||
MQTT_BROKER = os.getenv("MQTT_BROKER", None)
|
||||
HTTP_SERVER_PROTOCOL = os.getenv("HTTP_SERVER_PROTOCOL", "http")
|
||||
HTTP_SERVER_ADDRESS = os.getenv("HTTP_SERVER_ADDRESS", "127.0.0.1")
|
||||
HTTP_SERVER_PORT = os.getenv("HTTP_SERVER_PORT", 8000)
|
||||
NODE_LAT = os.getenv("NODE_LAT")
|
||||
NODE_LONG = os.getenv("NODE_LONG")
|
||||
|
||||
@@ -251,7 +254,7 @@ async def mqtt_lifecycle_manager():
|
||||
try:
|
||||
with open(local_path, "rb") as f:
|
||||
files = {"file": (f"{call_id}.mp3", f, "audio/mpeg")}
|
||||
response = requests.post(f"http://{MQTT_BROKER}/upload", files=files, data={"node_id": NODE_ID, "call_id": call_id}, timeout=30)
|
||||
response = requests.post(f"{HTTP_SERVER_PROTOCOL}://{HTTP_SERVER_ADDRESS}:{HTTP_SERVER_PORT}/upload", files=files, data={"node_id": NODE_ID, "call_id": call_id}, timeout=30)
|
||||
response.raise_for_status()
|
||||
return response.json().get("url")
|
||||
except Exception as e:
|
||||
|
||||
@@ -22,6 +22,9 @@ services:
|
||||
- MQTT_BROKER=${MQTT_BROKER}
|
||||
- ICECAST_SERVER=${ICECAST_SERVER}
|
||||
- AUDIO_BUCKET=${AUDIO_BUCKET}
|
||||
- HTTP_SERVER_PROTOCOL=${HTTP_SERVER_PROTOCOL}
|
||||
- HTTP_SERVER_HOST=${HTTP_SERVER_HOST}
|
||||
- HTTP_SERVER_PORT=${HTTP_SERVER_PORT}
|
||||
networks:
|
||||
- radio-shared-net
|
||||
|
||||
|
||||
Reference in New Issue
Block a user