mirror of
https://codeberg.org/mclemens/pyBMNotify.git
synced 2024-06-13 13:00:43 +00:00
93 lines
3.5 KiB
Python
93 lines
3.5 KiB
Python
#!/usr/bin/env python
|
|
from socketIO_client import SocketIO
|
|
import json
|
|
import datetime as dt
|
|
import time
|
|
import config as cfg
|
|
import http.client, urllib
|
|
|
|
last_TG_activity = {}
|
|
last_OM_activity = {}
|
|
|
|
def on_connect():
|
|
print('Connecting to the Brandmeister API')
|
|
|
|
def on_disconnect():
|
|
print('Disconnected')
|
|
|
|
def on_reconnect():
|
|
print('Reconnecting')
|
|
|
|
def push_message(msg):
|
|
if cfg.pushover_token != "" and cfg.pushover_user != "":
|
|
conn = http.client.HTTPSConnection("api.pushover.net:443")
|
|
conn.request("POST", "/1/messages.json",
|
|
urllib.parse.urlencode({
|
|
"token": cfg.pushover_token,
|
|
"user": cfg.pushover_user,
|
|
"message": msg,
|
|
}), { "Content-type": "application/x-www-form-urlencoded" })
|
|
conn.getresponse()
|
|
|
|
def construct_message(c):
|
|
tg = c["DestinationID"]
|
|
out = ""
|
|
duration = c["Stop"] - c["Start"]
|
|
# convert unix time stamp to human readable format
|
|
time = dt.datetime.utcfromtimestamp(c["Start"]).strftime("%Y/%m/%d %H:%M")
|
|
# construct text message from various transmission properties
|
|
out += c["SourceCall"] + ' (' + c["SourceName"] + ') was active on '
|
|
out += str(tg) + ' (' + c["DestinationName"] + ') at '
|
|
out += time + ' (' + str(duration) + ' seconds)'
|
|
# finally return the text message
|
|
return out
|
|
|
|
def on_mqtt(*args):
|
|
# get json data of transmission
|
|
call = json.loads(args[0]['payload'])
|
|
tg = call["DestinationID"]
|
|
callsign = call["SourceCall"]
|
|
start_time = call["Start"]
|
|
stop_time = call["Stop"]
|
|
msg = ""
|
|
now = int(time.time())
|
|
# check if callsign is monitored, the transmission has already been finished
|
|
# and the person was inactive for n seconds
|
|
if callsign in cfg.callsigns:
|
|
if callsign not in last_OM_activity:
|
|
last_OM_activity[callsign] = 9999999
|
|
inactivity = now - last_OM_activity[callsign]
|
|
if callsign not in last_OM_activity or inactivity >= cfg.min_silence:
|
|
# If the activity has happened in a monitored TG, remember the transmission start time stamp
|
|
if tg in cfg.talkgroups and stop_time > 0:
|
|
last_TG_activity[tg] = now
|
|
# remember the transmission time stamp of this particular DMR user
|
|
last_OM_activity[callsign] = now
|
|
msg = construct_message(call)
|
|
# Continue if the talkgroup is monitored, the transmission has been finished and there was no activity
|
|
# during the last n seconds in this talkgroup
|
|
elif tg in cfg.talkgroups and stop_time > 0:
|
|
if tg not in last_TG_activity:
|
|
last_TG_activity[tg] = 9999999
|
|
inactivity = now - last_TG_activity[tg]
|
|
# calculate duration of key down
|
|
duration = stop_time - start_time
|
|
# only proceed if the key down has been long enough
|
|
if duration >= cfg.min_duration:
|
|
if tg not in last_TG_activity or inactivity >= cfg.min_silence:
|
|
msg = construct_message(call)
|
|
# DEBUG else:
|
|
# DEBUG print("ignored activity in TG " + str(tg) + " from " + callsign + ": last action " + str(inactivity) + " seconds ago.")
|
|
last_TG_activity[tg] = now
|
|
# finally write the message to the console and send a push notification
|
|
if msg != "":
|
|
print(construct_message(call))
|
|
push_message(construct_message(call))
|
|
|
|
socket = SocketIO('https://api.brandmeister.network/lh')
|
|
socket.on('connect', on_connect)
|
|
socket.on('disconnect', on_disconnect)
|
|
socket.on('reconnect', on_reconnect)
|
|
socket.on('mqtt', on_mqtt)
|
|
socket.wait()
|