FritzAB2Matrix/fritzab2matrix.py

160 lines
5.0 KiB
Python
Raw Permalink Normal View History

#!/usr/bin/env python3
2021-06-27 14:01:20 +02:00
from fritzconnection import FritzConnection
from dotenv import load_dotenv
from pydub import AudioSegment
from libs.monitoring import endedCall
from libs.message import conversion as conv
2021-06-27 14:01:20 +02:00
import urllib.request
2021-07-07 22:31:05 +02:00
import xmltodict, json
2021-06-27 14:01:20 +02:00
import sys, os
import smbclient
## Get environment variables from the .env file which will be ignored by git
load_dotenv()
env_user = os.environ.get('FRITZ_USERNAME')
env_pass = os.environ.get('FRITZ_PASSWORD')
env_ip = os.environ.get('FRITZ_IP')
2021-06-30 21:06:06 +02:00
env_voicebox = os.environ.get('FRITZ_VOICEBOX_PATH')
2021-07-07 22:31:05 +02:00
env_tam = json.loads(os.environ.get('FRITZ_TAM'))
env_tmp = os.environ.get('TEMP_DIR')
2021-06-30 21:06:06 +02:00
if env_voicebox is None:
env_voicebox = "/fritz.nas/FRITZ/voicebox/"
2021-07-07 22:31:05 +02:00
if env_tam is None:
env_tam = {
"0" : "!MxRrNGhFuQwnIeEWnX:ismus.net"
}
print(env_tam)
if env_tmp is None:
env_tmp = "/tmp"
2021-06-27 14:01:20 +02:00
# Build the url to download the message via smb
def build_download_url(mid, tam=0):
recording = "rec." + str(tam) + r"." + str(mid).zfill(3)
url = os.path.join("//",env_ip,env_voicebox,"rec",recording)
return url
2021-07-06 23:05:04 +02:00
def download_speex_file(smb_url):
smbclient.register_session(server=env_ip, username=env_user, password=env_pass, auth_protocol="ntlm")
fd = smbclient.open_file(smb_url, mode="rb")
return fd
def get_message_list(url):
""" Get and and convert the xml formatted list of messages into a dictionary. """
with urllib.request.urlopen(url) as f:
doc = f.read()
# Convert the xml formatted message list to dict
messages = xmltodict.parse(doc)
return messages
2021-07-07 22:50:22 +02:00
def fritzab2matrix(tam):
2021-06-27 14:01:20 +02:00
### CHECK AND GET MESSAGES FROM FRITZBOX ###
############################################
2021-06-27 14:01:20 +02:00
## Connect to the FritzBox in the LAN
# We don't use tls because the self-signed cert of the box leads to a malfunction in urllib later on.
fc = FritzConnection(address=env_ip, user=env_user, password=env_pass, use_tls=False)
2021-06-27 14:01:20 +02:00
## Get info about messages from the main answering machine
2021-07-07 22:31:05 +02:00
message_list = fc.call_action("X_AVM-DE_TAM1", "GetMessageList", NewIndex=tam)
message_list_url = message_list['NewURL']
l = get_message_list(message_list_url)
if l['Root'] == None or l['Root']['Message'] == None:
return False
else:
messages = l['Root']['Message']
if type(messages) is not list:
m = []
m.append(messages)
messages = m
for a in messages:
# format the information regarding the message
msg_info = a['Date'] + " - " + a['Number']
if a['Name']:
msg_info += " (" + a['Name'] + ") "
2021-06-27 14:01:20 +02:00
# format the string for sound file's meta information
msg_tags = {'title': msg_info, 'artist': 'Answerting Machine' ,'album': "TAM" + a['Tam'], 'comment': 'Message of a telephone answering machine'}
# Select only new messages
message_new = bool(int(a['New']))
if message_new == True:
# Download and convert the speex files to wav
smb_url = build_download_url(a['Index'])
speex_fd = download_speex_file(smb_url)
2021-07-07 22:31:05 +02:00
conv.speex_convert(speex_fd, os.path.join(env_tmp,"message{}.wav".format(tam)))
# Convert wav to ogg
2021-07-07 22:31:05 +02:00
msg = AudioSegment.from_wav(os.path.join(env_tmp,"message{}.wav".format(tam)))
2021-06-27 14:01:20 +02:00
# Only if message is longer than 5 seconds ...
if msg.duration_seconds > 5.0:
# ... export to ogg ...
2021-07-07 22:31:05 +02:00
msg.export(os.path.join(env_tmp,"message{}.ogg".format(tam)), format="ogg", tags=msg_tags)
# ... and send message and file to Matrix Room
2021-07-07 22:31:05 +02:00
command = "python3 matrix-commander.py --room {} -a ".format(env_tam[tam]) + os.path.join(env_tmp,"message{}.ogg".format(tam)) + " -m '{}'".format(msg_info)
os.system(command)
else:
# Mark MessageInfo as too short for the log
msg_info += " < 6 sec (not posted)"
2021-06-27 14:01:20 +02:00
# Show that message is new
print("** " + msg_info)
2021-06-27 14:01:20 +02:00
# Mark processed messages as 'read'
2021-07-07 22:31:05 +02:00
fc.call_action("X_AVM-DE_TAM1", "MarkMessage", NewIndex=tam, NewMessageIndex=int(a['Index']), NewMarkedAsRead=1)
2021-06-27 14:01:20 +02:00
else:
# Show that message is already read
print("__ " + msg_info)
2021-06-27 14:01:20 +02:00
# ## For testing purposes only
# if a['Date'].endswith('20:53'):
2021-07-07 22:31:05 +02:00
# fc.call_action("X_AVM-DE_TAM1", "MarkMessage", NewIndex=1, NewMessageIndex=int(a['Index']), NewMarkedAsRead=0)
continue
2021-06-27 14:01:20 +02:00
continue
2021-06-27 14:01:20 +02:00
2021-07-07 22:31:05 +02:00
def multitam(tams):
for tam in tams.keys():
print("Check TAM {}.".format(tam))
fritzab2matrix(tam)
2021-06-27 14:01:20 +02:00
if __name__ == "__main__":
2021-07-07 22:31:05 +02:00
multitam(env_tam)
### Monitor the FritzBox and trigger the main script whenever a call disconnects ###
###################################################################################
2021-07-07 22:31:05 +02:00
endedCall(multitam,env_tam, env_ip)
2021-06-27 14:01:20 +02:00