apunkt/dograh
1
0
Fork 0
mirror of https://github.com/dograh-hq/dograh.git synced 2026-06-16 08:25:18 +02:00
Code Issues Projects Releases Packages Wiki Activity

fix: disable file logging for docker compose mode

Browse source
This commit is contained in:
Abhishek Kumar 2026-02-04 22:42:13 +05:30
parent 7d1e22d53c
commit b5cb044f8c
6 changed files with 68 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

5
api/Dockerfile
View file

@ -58,8 +58,11 @@ COPY ./scripts/start_services.sh ./scripts/start_services.sh
ENV PYTHONPATH=/app
# Disable file logging in Docker - logs go to stdout for docker logs
ENV LOG_TO_FILE=false
# Expose the port FastAPI will run on
EXPOSE 8000
# Run the FastAPI app with uvicorn
CMD ["bash", "-c", "./scripts/start_services.sh && tail -f ./logs/latest/*.log"]
CMD ["./scripts/start_services.sh"]

9
api/services/pipecat/run_pipeline.py
View file

@ -44,6 +44,7 @@ from api.services.telephony.stasis_rtp_connection import StasisRTPConnection
from api.services.workflow.dto import ReactFlowDTO
from api.services.workflow.pipecat_engine import PipecatEngine
from api.services.workflow.workflow import WorkflowGraph
from pipecat.audio.turn.smart_turn.local_smart_turn_v3 import LocalSmartTurnAnalyzerV3
from pipecat.extensions.voicemail.voicemail_detector import VoicemailDetector
from pipecat.pipeline.base_task import PipelineTaskParams
from pipecat.processors.aggregators.llm_response_universal import (
@ -65,7 +66,7 @@ from pipecat.turns.user_start.vad_user_turn_start_strategy import (
)
from pipecat.turns.user_stop import (
ExternalUserTurnStopStrategy,
TranscriptionUserTurnStopStrategy,
TurnAnalyzerUserTurnStopStrategy,
)
from pipecat.turns.user_turn_strategies import UserTurnStrategies
from pipecat.utils.context import set_current_run_id
@ -566,7 +567,11 @@ async def _run_pipeline(
else:
user_turn_strategies = UserTurnStrategies(
start=[VADUserTurnStartStrategy(), TranscriptionUserTurnStartStrategy()],
stop=[TranscriptionUserTurnStopStrategy()],
stop=[
TurnAnalyzerUserTurnStopStrategy(
turn_analyzer=LocalSmartTurnAnalyzerV3()
)
],
)
# Create user mute strategies

60
api/tests/test_is_private_ip_candidate.py
View file

@ -6,37 +6,51 @@ class TestIsPrivateIpCandidate:
def test_private_ip_192_168(self):
"""192.168.x.x addresses are detected as private."""
candidate = "candidate:123 1 udp 2122260223 192.168.50.24 63603 typ host generation 0"
candidate = (
"candidate:123 1 udp 2122260223 192.168.50.24 63603 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_private_ip_10_x(self):
"""10.x.x.x addresses are detected as private."""
candidate = "candidate:456 1 udp 2122260223 10.0.0.1 12345 typ host generation 0"
candidate = (
"candidate:456 1 udp 2122260223 10.0.0.1 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_private_ip_172_16(self):
"""172.16.x.x addresses are detected as private."""
candidate = "candidate:789 1 udp 2122260223 172.16.0.1 54321 typ host generation 0"
candidate = (
"candidate:789 1 udp 2122260223 172.16.0.1 54321 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_private_ip_172_31(self):
"""172.31.x.x addresses are detected as private."""
candidate = "candidate:101 1 udp 2122260223 172.31.255.255 12345 typ host generation 0"
candidate = (
"candidate:101 1 udp 2122260223 172.31.255.255 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_cgnat_ip(self):
"""CGNAT addresses (100.64.0.0/10) are detected as private."""
candidate = "candidate:202 1 udp 2122260223 100.64.0.1 12345 typ host generation 0"
candidate = (
"candidate:202 1 udp 2122260223 100.64.0.1 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_cgnat_ip_upper_bound(self):
"""Upper bound of CGNAT range is detected."""
candidate = "candidate:303 1 udp 2122260223 100.127.255.255 12345 typ host generation 0"
candidate = (
"candidate:303 1 udp 2122260223 100.127.255.255 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_public_ip(self):
"""Public IP addresses return False."""
candidate = "candidate:404 1 udp 2122260223 142.250.190.46 12345 typ host generation 0"
candidate = (
"candidate:404 1 udp 2122260223 142.250.190.46 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is False
def test_public_ip_8_8_8_8(self):
@ -46,17 +60,23 @@ class TestIsPrivateIpCandidate:
def test_non_cgnat_100_range(self):
"""100.x.x.x outside CGNAT range is public."""
candidate = "candidate:606 1 udp 2122260223 100.128.0.1 12345 typ host generation 0"
candidate = (
"candidate:606 1 udp 2122260223 100.128.0.1 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is False
def test_172_15_is_public(self):
"""172.15.x.x is outside private range and should be public."""
candidate = "candidate:707 1 udp 2122260223 172.15.255.255 12345 typ srflx generation 0"
candidate = (
"candidate:707 1 udp 2122260223 172.15.255.255 12345 typ srflx generation 0"
)
assert is_private_ip_candidate(candidate) is False
def test_172_32_is_public(self):
"""172.32.x.x is outside private range and should be public."""
candidate = "candidate:808 1 udp 2122260223 172.32.0.1 12345 typ srflx generation 0"
candidate = (
"candidate:808 1 udp 2122260223 172.32.0.1 12345 typ srflx generation 0"
)
assert is_private_ip_candidate(candidate) is False
def test_srflx_candidate_type(self):
@ -66,17 +86,23 @@ class TestIsPrivateIpCandidate:
def test_relay_candidate_type(self):
"""Relay candidates are parsed correctly."""
candidate = "candidate:111 1 udp 41885439 1.1.1.1 50000 typ relay raddr 0.0.0.0 rport 0"
candidate = (
"candidate:111 1 udp 41885439 1.1.1.1 50000 typ relay raddr 0.0.0.0 rport 0"
)
assert is_private_ip_candidate(candidate) is False
def test_loopback_ip(self):
"""Loopback addresses are detected as private."""
candidate = "candidate:222 1 udp 2122260223 127.0.0.1 12345 typ host generation 0"
candidate = (
"candidate:222 1 udp 2122260223 127.0.0.1 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_link_local_ip(self):
"""Link-local addresses (169.254.x.x) are detected as private."""
candidate = "candidate:333 1 udp 2122260223 169.254.1.1 12345 typ host generation 0"
candidate = (
"candidate:333 1 udp 2122260223 169.254.1.1 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is True
def test_ipv6_link_local(self):
@ -100,7 +126,9 @@ class TestIsPrivateIpCandidate:
def test_malformed_candidate_invalid_ip(self):
"""Candidate with invalid IP returns False."""
candidate = "candidate:777 1 udp 2122260223 not.an.ip 12345 typ host generation 0"
candidate = (
"candidate:777 1 udp 2122260223 not.an.ip 12345 typ host generation 0"
)
assert is_private_ip_candidate(candidate) is False
def test_malformed_candidate_short(self):
@ -110,5 +138,7 @@ class TestIsPrivateIpCandidate:
def test_tcp_candidate(self):
"""TCP candidates are parsed correctly."""
candidate = "candidate:999 1 tcp 1518280447 192.168.1.100 9 typ host tcptype active"
candidate = (
"candidate:999 1 tcp 1518280447 192.168.1.100 9 typ host tcptype active"
)
assert is_private_ip_candidate(candidate) is True