mirror of
https://github.com/Jeuners/Logpy-AgentOne.git
synced 2026-09-15 17:56:12 +02:00
394a0faa27
Bruecke zwischen FreeSWITCH/mod_audio_stream und dem neuen Astra-Telefonie- Endpunkt (/telefon/inbound) - erlaubt echte, live gefuehrte Gespraeche statt nur Aufnahme+Nachbearbeitung: - dialog/pipecat_bootstrap.py: nimmt Kanaele per socket() entgegen (Nebenstelle 7501 intern, oder von dialog/anrufen.py ausgehend), startet uuid_audio_stream und haengt fuer die gesamte Gespraechsdauer auf der Leitung, um mod_audio_stream::play-Events abzuspielen (playback() - mod_audio_stream schreibt nur eine Datei und feuert ein Event, spielt selbst nichts ab). uuid_audio_stream laeuft bewusst ueber einen separaten fs_cli-Prozess, nicht ueber die eigene ESL-Verbindung (siehe Kommentar im Modul - sonst schlaegt der WebSocket-Connect bei echten externen Anrufen zuverlaessig fehl, amigniter/mod_audio_stream#92). - dialog/anrufen.py: loest ausgehende Anrufe aus (python3 -m dialog.anrufen <Nummer>), haengt sie an dieselbe Bruecke. - .env.example, requirements.txt (greenswitch), telefon/starten.sh: Bootstrap als vierten Hintergrunddienst mitstarten, wenn ASTRA_TELEFON_WS_URL gesetzt ist. mod_audio_stream selbst (gebaut mit -DUSE_TLS=ON) und die FreeSWITCH-Gateway- Konfiguration (Domain/Proxy-Trennung fuer Outbound, siehe agentzwei_sbc.xml) liegen direkt in der FreeSWITCH-Konfiguration, nicht in diesem Repo. Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01BfxZnUC9dZ8QT36pkfEPmM
68 lines
2.8 KiB
Python
68 lines
2.8 KiB
Python
"""Outbound-Call-Trigger fuer die Pipecat-Testleitung.
|
|
|
|
Ruft eine Nummer ueber den Plusnet-Trunk an und uebergibt sie nach Abheben an
|
|
dieselbe Bruecke wie die interne Testnebenstelle 7501
|
|
(dialog/pipecat_bootstrap.py, Port 8095) - answer()+uuid_audio_stream+park()
|
|
laeuft dort identisch, unabhaengig davon ob der Anruf rein- oder rausgeht. Der
|
|
Dialplan-Umweg (Nebenstelle 7501) entfaellt hier: `&socket(...)` haengt den
|
|
ausgehenden Kanal direkt nach Abheben an den Bootstrap, ohne Dialplan-Lookup.
|
|
|
|
Nutzung: python3 -m dialog.anrufen <Nummer>
|
|
"""
|
|
|
|
import os
|
|
import sys
|
|
|
|
import greenswitch
|
|
|
|
FS_HOST = "127.0.0.1"
|
|
FS_PORT = int(os.environ.get("FS_PORT", "8022"))
|
|
FS_ESL_PASSWORD = os.environ.get("FS_ESL_PASSWORD", "ClueCon")
|
|
BOOTSTRAP_PORT = int(os.environ.get("PIPECAT_BOOTSTRAP_PORT", "8095"))
|
|
# DW9 ("rufagent") - the only account confirmed capable of outbound so far.
|
|
# Needs "proxy" (R-URI domain, must be sip.plusnet.de - Plusnet 403s otherwise)
|
|
# split from "outbound-proxy" (actual packet routing, sbc.sip.plusnet.de) in
|
|
# its gateway XML - see sip_profiles/external/agentzwei_sbc.xml.
|
|
GATEWAY = os.environ.get("ANRUF_GATEWAY", "agentzwei_sbc")
|
|
CALLER_ID = os.environ.get("ANRUF_CALLER_ID", "+49210378916179")
|
|
|
|
|
|
def normalisiere(nummer: str) -> str:
|
|
"""Wie pipe/kontakte.py: nur Ziffern, Deutschland-Annahme 0 -> 49,
|
|
kein '+' - so erwartet es der Trunk auch fuer DW3_DDI in der .env."""
|
|
ziffern = "".join(zeichen for zeichen in nummer if zeichen.isdigit() or zeichen == "+")
|
|
if ziffern.startswith("+"):
|
|
return ziffern[1:]
|
|
if ziffern.startswith("00"):
|
|
return ziffern[2:]
|
|
if ziffern.startswith("0"):
|
|
return "49" + ziffern[1:]
|
|
return ziffern
|
|
|
|
|
|
def main():
|
|
if len(sys.argv) != 2:
|
|
sys.exit("Nutzung: python3 -m dialog.anrufen <Nummer>")
|
|
ziel = normalisiere(sys.argv[1])
|
|
# The &socket(...) part MUST stay in single quotes: originate splits its
|
|
# arguments on spaces, so an unquoted "&socket(127.0.0.1:8095 async full)"
|
|
# reaches the channel as plain "socket(127.0.0.1:8095)" - "async full"
|
|
# silently dropped (seen in freeswitch.log's own EXECUTE line, 2026-09-13).
|
|
# Without "full", mod_event_socket refuses every command past sendmsg on
|
|
# an outbound listener, so pipecat_bootstrap's CUSTOM-event subscription
|
|
# ("event plain CUSTOM mod_audio_stream::play") is answered with
|
|
# "-ERR command not found" and no audio is ever played back.
|
|
befehl = (
|
|
f"originate {{origination_caller_id_number={CALLER_ID}}}"
|
|
f"sofia/gateway/{GATEWAY}/{ziel} "
|
|
f"'&socket({FS_HOST}:{BOOTSTRAP_PORT} async full)'"
|
|
)
|
|
print(f"Rufe {ziel} an ueber: {befehl}")
|
|
fs = greenswitch.InboundESL(host=FS_HOST, port=FS_PORT, password=FS_ESL_PASSWORD)
|
|
fs.connect()
|
|
antwort = fs.send(f"api {befehl}")
|
|
print(antwort.data)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|