odie/pyBMNotify
1
0
Fork 0
mirror of https://codeberg.org/mclemens/pyBMNotify.git synced 2024-12-23 06:16:28 -05:00
Code Issues Packages Projects Releases Wiki Activity

added more info

Browse Source
This commit is contained in:
Michael Clemens 2020-12-08 01:32:31 +01:00
parent e3a4b1a07f
commit 055d6950c8
2 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
README.md
View File

@ -1,6 +1,8 @@
# pyBMNotify # pyBMNotify
Monitors a defined set of Brandmeister talkgroups and callsigns for activity and sends push notifications via Pushover. Monitors a defined set of Brandmeister talkgroups and callsigns for activity. It then sends push notifications via Pushover for any transmission in / of the monitored talk groups / call signs.
In order to prevent message flooding, the script only notifes you again after 300 (configurable) seconds of silence in a TG or from a monitored call sign.
## Credits ## Credits

12
pyBMNotify.py
View File

@ -35,7 +35,7 @@ def construct_message(c):
duration = c["Stop"] - c["Start"] duration = c["Stop"] - c["Start"]
# convert unix time stamp to human readable format # convert unix time stamp to human readable format
time = dt.datetime.utcfromtimestamp(c["Start"]).strftime("%Y/%m/%d %H:%M") time = dt.datetime.utcfromtimestamp(c["Start"]).strftime("%Y/%m/%d %H:%M")
# construct text message from various QSO properties # construct text message from various transmission properties
out += c["SourceCall"] + ' (' + c["SourceName"] + ') was active on ' out += c["SourceCall"] + ' (' + c["SourceName"] + ') was active on '
out += str(tg) + ' (' + c["DestinationName"] + ') at ' out += str(tg) + ' (' + c["DestinationName"] + ') at '
out += time + ' (' + str(duration) + ' seconds)' out += time + ' (' + str(duration) + ' seconds)'
@ -43,24 +43,24 @@ def construct_message(c):
return out return out
def on_mqtt(*args): def on_mqtt(*args):
# get json data of QSO # get json data of transmission
call = json.loads(args[0]['payload']) call = json.loads(args[0]['payload'])
tg = call["DestinationID"] tg = call["DestinationID"]
callsign = call["SourceCall"] callsign = call["SourceCall"]
start_time = call["Start"] start_time = call["Start"]
stop_time = call["Stop"] stop_time = call["Stop"]
msg = "" msg = ""
# check if callsign is monitored, the over has already been finished # check if callsign is monitored, the transmission has already been finished
# and the person was inactive for n seconds # and the person was inactive for n seconds
if callsign in cfg.callsigns: if callsign in cfg.callsigns:
if callsign not in last_OM_activity or (last_OM_activity[callsign] + cfg.min_silence) < start_time: if callsign not in last_OM_activity or (last_OM_activity[callsign] + cfg.min_silence) < start_time:
# If the activity has happened in a monitored TG, remember the QSO start time stamp # If the activity has happened in a monitored TG, remember the transmission start time stamp
if tg in cfg.talkgroups and stop_time > 0: if tg in cfg.talkgroups and stop_time > 0:
last_TG_activity[tg] = start_time last_TG_activity[tg] = start_time
# remember the QSO's time stamp of this particular DMR user # remember the transmission time stamp of this particular DMR user
last_OM_activity[callsign] = start_time last_OM_activity[callsign] = start_time
msg = construct_message(call) msg = construct_message(call)
# Continue if the talkgroup is monitored, the over has been finished and there was no activity # Continue if the talkgroup is monitored, the transmission has been finished and there was no activity
# during the last n seconds in this talkgroup # during the last n seconds in this talkgroup
elif tg in cfg.talkgroups and stop_time > 0: elif tg in cfg.talkgroups and stop_time > 0:
if tg not in last_TG_activity or (last_TG_activity[tg] + cfg.min_silence) < start_time: if tg not in last_TG_activity or (last_TG_activity[tg] + cfg.min_silence) < start_time: