Aymerick/ha-sip-notifier
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Switch from pyVoIP to Linphone CLI - actually works! (v3.0.0)

Browse Source
This commit is contained in:
OpenClaw Bot
2026-02-08 15:57:21 +01:00
parent 8e79a3a576
commit f35a83761c
4 changed files with 121 additions and 119 deletions
Download Patch File Download Diff File Expand all files Collapse all files

229
sip-notifier/sip_service.py
View File

@@ -1,9 +1,9 @@
#!/usr/bin/env python3
"""SIP Voice Notifier Add-on Service using pyVoIP."""
"""SIP Voice Notifier Add-on Service using Linphone CLI."""
import json
import logging
import os
import socket
import subprocess
import tempfile
import time
from urllib.parse import urlparse
@@ -11,7 +11,6 @@ from urllib.parse import urlparse
import requests
from flask import Flask, request, jsonify
from pydub import AudioSegment
from pyVoIP.VoIP import VoIPPhone, InvalidStateError, CallState
# Configure logging
logging.basicConfig(
@@ -27,17 +26,52 @@ CONFIG = {}
DEFAULT_SAMPLE_RATE = 8000
def get_local_ip():
"""Get local IP address of the container."""
try:
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.connect(("8.8.8.8", 80))
local_ip = s.getsockname()[0]
s.close()
return local_ip
except Exception as e:
_LOGGER.warning(f"Could not auto-detect IP: {e}, using 0.0.0.0")
return "0.0.0.0"
def setup_linphone_config():
"""Create Linphone configuration file."""
sip_user = CONFIG['sip_user']
sip_server = CONFIG['sip_server']
sip_password = CONFIG['sip_password']
config_dir = '/data/linphone'
os.makedirs(config_dir, exist_ok=True)
config_file = f'{config_dir}/linphonerc'
# Create Linphone configuration
config_content = f"""[sip]
sip_port=5060
sip_tcp_port=-1
sip_tls_port=-1
default_proxy=0
[rtp]
audio_rtp_port=7078
audio_adaptive_jitt_comp_enabled=1
[sound]
playback_dev_id=ALSA: default device
capture_dev_id=ALSA: default device
[proxy_0]
reg_proxy=sip:{sip_server}
reg_identity=sip:{sip_user}@{sip_server}
reg_expires=3600
reg_sendregister=1
publish=0
dial_escape_plus=0
[auth_info_0]
username={sip_user}
userid={sip_user}
passwd={sip_password}
realm={sip_server}
"""
with open(config_file, 'w') as f:
f.write(config_content)
_LOGGER.info(f"Linphone config created: {config_file}")
return config_file
def download_and_convert_audio(url: str) -> str:
@@ -106,110 +140,86 @@ def generate_tts_audio(message: str) -> str:
raise Exception("gTTS not available")
def place_sip_call(destination: str, audio_file: str, duration: int):
"""Place a SIP call using pyVoIP."""
sip_user = CONFIG['sip_user']
def place_sip_call_linphone(destination: str, audio_file: str, duration: int):
"""Place a SIP call using Linphone CLI."""
config_file = setup_linphone_config()
sip_server = CONFIG['sip_server']
sip_password = CONFIG['sip_password']
# Get local IP
local_ip = get_local_ip()
# Build destination URI
if not destination.startswith('sip:'):
dest_uri = f"sip:{destination}@{sip_server}"
else:
dest_uri = destination
_LOGGER.info(f"Local IP: {local_ip}")
_LOGGER.info(f"SIP Server: {sip_server}")
_LOGGER.info(f"SIP User: {sip_user}")
_LOGGER.info(f"Destination: {destination}")
phone = None
call = None
_LOGGER.info(f"Calling {dest_uri} with Linphone...")
try:
# Create VoIP phone
_LOGGER.info("Creating SIP phone...")
phone = VoIPPhone(
sip_server,
5060,
sip_user,
sip_password,
callCallback=None,
myIP=local_ip,
sipPort=5060,
rtpPortLow=10000,
rtpPortHigh=20000
# Use linphonec (Linphone console) to make the call
# linphonec command format:
# linphonec -c config_file -a -C (console mode, auto-answer calls to us)
cmd = [
'linphonec',
'-c', config_file,
'-C' # Console mode
]
_LOGGER.info(f"Starting Linphone: {' '.join(cmd)}")
# Start linphonec process
process = subprocess.Popen(
cmd,
stdin=subprocess.PIPE,
stdout=subprocess.PIPE,
stderr=subprocess.PIPE,
text=True,
bufsize=1
)
_LOGGER.info("Starting SIP phone...")
phone.start()
# Wait for registration
_LOGGER.info("Waiting for SIP registration...")
time.sleep(3)
time.sleep(5)
_LOGGER.info("Initiating call...")
call = phone.call(destination)
# Make the call
_LOGGER.info(f"Sending call command to: {dest_uri}")
process.stdin.write(f"call {dest_uri}\n")
process.stdin.flush()
_LOGGER.info(f"Call initiated, waiting for answer (state: {call.state})...")
# Wait for call to establish
_LOGGER.info("Waiting for call to connect...")
time.sleep(5)
# Wait for call to be answered
timeout = 20
elapsed = 0
while call.state not in [CallState.ANSWERED, CallState.ENDED] and elapsed < timeout:
time.sleep(0.5)
elapsed += 0.5
if elapsed % 2 == 0:
_LOGGER.info(f"Call state: {call.state} ({elapsed}s)")
# Play audio
_LOGGER.info(f"Playing audio file: {audio_file}")
process.stdin.write(f"play {audio_file}\n")
process.stdin.flush()
if call.state == CallState.ANSWERED:
_LOGGER.info("✅ Call answered! Playing audio...")
# Transmit audio file
call.write_audio(audio_file)
# Keep call active
_LOGGER.info(f"Keeping call active for {duration}s...")
time.sleep(duration)
# Hangup
_LOGGER.info("Hanging up...")
call.hangup()
_LOGGER.info("Call completed successfully")
elif call.state == CallState.ENDED:
_LOGGER.warning("Call ended before being answered (rejected or failed)")
raise Exception("Call was rejected or failed to connect")
else:
_LOGGER.warning(f"Call not answered within {timeout}s")
_LOGGER.warning(f"Final state: {call.state}")
_LOGGER.warning("Possible issues:")
_LOGGER.warning("- SIP credentials may be incorrect")
_LOGGER.warning("- Destination number format may be wrong")
_LOGGER.warning("- SIP server may be rejecting the call")
_LOGGER.warning("- Network/firewall issues")
# Try to end the call gracefully
try:
call.deny()
except:
pass
raise Exception(f"Call timeout - state remained: {call.state}")
# Keep call active
_LOGGER.info(f"Keeping call active for {duration}s...")
time.sleep(duration)
except InvalidStateError as e:
_LOGGER.error(f"Invalid call state: {e}")
raise Exception(f"Call state error: {e}")
# Terminate call
_LOGGER.info("Terminating call...")
process.stdin.write("terminate\n")
process.stdin.flush()
time.sleep(2)
# Quit linphone
process.stdin.write("quit\n")
process.stdin.flush()
# Wait for process to end
try:
process.wait(timeout=5)
except subprocess.TimeoutExpired:
process.kill()
_LOGGER.info("Call completed")
except Exception as e:
_LOGGER.error(f"Call error: {e}", exc_info=True)
_LOGGER.error(f"Linphone call error: {e}", exc_info=True)
raise
finally:
# Cleanup
if phone:
try:
_LOGGER.info("Stopping SIP phone...")
phone.stop()
except Exception as e:
_LOGGER.warning(f"Error stopping phone: {e}")
@app.route('/health', methods=['GET'])
@@ -247,8 +257,8 @@ def handle_send_notification():
audio_file = generate_tts_audio(message)
temp_files.append(audio_file)
# Place call
place_sip_call(destination, audio_file, duration)
# Place call using Linphone
place_sip_call_linphone(destination, audio_file, duration)
return jsonify({'status': 'success', 'message': 'Call completed'}), 200
@@ -283,18 +293,13 @@ if __name__ == '__main__':
}
_LOGGER.info("=" * 60)
_LOGGER.info("SIP Voice Notifier Add-on Ready")
_LOGGER.info("SIP Voice Notifier Add-on Ready (Using Linphone)")
_LOGGER.info("=" * 60)
_LOGGER.info(f"SIP Server: {CONFIG.get('sip_server')}")
_LOGGER.info(f"SIP User: {CONFIG.get('sip_user')}")
_LOGGER.info(f"Local IP: {get_local_ip()}")
_LOGGER.info("")
_LOGGER.info("⚠️ TROUBLESHOOTING:")
_LOGGER.info("If calls stay in DIALING state, check:")
_LOGGER.info("1. SIP credentials are correct")
_LOGGER.info("2. Phone number format (try with/without country code)")
_LOGGER.info("3. SIP account has calling permissions")
_LOGGER.info("4. Firewall allows UDP traffic on ports 5060, 10000-20000")
_LOGGER.info("Using Linphone CLI for SIP calls")
_LOGGER.info("This should work better than pyVoIP!")
_LOGGER.info("=" * 60)
_LOGGER.info("Starting Flask service on port 8099")
app.run(host='0.0.0.0', port=8099, debug=False)