2020-12-29 23:38:03 -05:00
#!/usr/bin/env python3
2020-11-22 01:54:01 -05:00
#
###############################################################################
2020-11-27 12:32:19 -05:00
# HBLink - Copyright (C) 2020 Cortney T. Buffington, N0MJS <n0mjs@me.com>
# GPS/Data - Copyright (C) 2020 Eric Craw, KF7EEL <kf7eel@qsl.net>
2020-11-22 01:54:01 -05:00
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software Foundation,
# Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
###############################################################################
'''
This is a GPS and Data application . It decodes and reassambles DMR GPS packets and
uploads them th APRS - IS .
'''
# Python modules we need
import sys
from bitarray import bitarray
from time import time
from importlib import import_module
from types import ModuleType
# Twisted is pretty important, so I keep it separate
from twisted . internet . protocol import Factory , Protocol
from twisted . protocols . basic import NetstringReceiver
from twisted . internet import reactor , task
# Things we import from the main hblink module
from hblink import HBSYSTEM , OPENBRIDGE , systems , hblink_handler , reportFactory , REPORT_OPCODES , config_reports , mk_aliases , acl_check
from dmr_utils3 . utils import bytes_3 , int_id , get_alias
from dmr_utils3 import decode , bptc , const
import config
import log
import const
# The module needs logging logging, but handlers, etc. are controlled by the parent
import logging
logger = logging . getLogger ( __name__ )
# Other modules we need for data and GPS
from bitarray import bitarray
from binascii import b2a_hex as ahex
import re
##from binascii import a2b_hex as bhex
import aprslib
import datetime
from bitarray . util import ba2int as ba2num
2020-11-22 21:54:02 -05:00
from bitarray . util import ba2hex as ba2hx
import codecs
2020-12-06 19:38:19 -05:00
import time
2020-11-22 15:51:11 -05:00
#Needed for working with NMEA
import pynmea2
2020-11-25 18:55:44 -05:00
# Modules for executing commands/scripts
import os
from gps_functions import cmd_list
2020-11-30 13:00:19 -05:00
# Module for maidenhead grids
2021-01-31 16:22:33 -05:00
try :
import maidenhead as mh
except :
logger . info ( ' Error importing maidenhead module, make sure it is installed. ' )
# Module for sending email
try :
import smtplib
except :
logger . info ( ' Error importing smtplib module, make sure it is installed. ' )
2020-11-30 13:00:19 -05:00
2020-11-27 12:32:19 -05:00
#Modules for APRS settings
import ast
from pathlib import Path
2020-11-22 01:54:01 -05:00
# Does anybody read this stuff? There's a PEP somewhere that says I should do this.
__author__ = ' Cortney T. Buffington, N0MJS; Eric Craw, KF7EEL '
__copyright__ = ' Copyright (c) 2020 Cortney T. Buffington '
__credits__ = ' Colin Durbridge, G4EML, Steve Zingman, N4IRS; Mike Zingman, N4IRR; Jonathan Naylor, G4KLX; Hans Barthen, DL5DI; Torsten Shultze, DG1HT '
__license__ = ' GNU GPLv3 '
__maintainer__ = ' Eric Craw, KF7EEL '
__email__ = ' kf7eel@qsl.net '
__status__ = ' pre-alpha '
# Known to work with: AT-D878
# Must have the following at line 1054 in bridge.py to forward group vcsbk, also there is a typo there:
# self.group_received(_peer_id, _rf_src, _dst_id, _seq, _slot, _frame_type, _dtype_vseq, _stream_id, _data)
##################################################################################################
# Headers for GPS by model of radio:
# AT-D878 - Compressed UDP
# MD-380 - Unified Data Transport
2020-12-26 12:59:51 -05:00
hdr_type = ' '
2020-12-26 16:43:55 -05:00
btf = ' '
2021-01-12 16:55:40 -05:00
ssid = ' '
2020-11-22 01:54:01 -05:00
# From dmr_utils3, modified to decode entire packet. Works for 1/2 rate coded data.
def decode_full ( _data ) :
binlc = bitarray ( endian = ' big ' )
binlc . extend ( [ _data [ 136 ] , _data [ 121 ] , _data [ 106 ] , _data [ 91 ] , _data [ 76 ] , _data [ 61 ] , _data [ 46 ] , _data [ 31 ] ] )
binlc . extend ( [ _data [ 152 ] , _data [ 137 ] , _data [ 122 ] , _data [ 107 ] , _data [ 92 ] , _data [ 77 ] , _data [ 62 ] , _data [ 47 ] , _data [ 32 ] , _data [ 17 ] , _data [ 2 ] ] )
binlc . extend ( [ _data [ 123 ] , _data [ 108 ] , _data [ 93 ] , _data [ 78 ] , _data [ 63 ] , _data [ 48 ] , _data [ 33 ] , _data [ 18 ] , _data [ 3 ] , _data [ 184 ] , _data [ 169 ] ] )
binlc . extend ( [ _data [ 94 ] , _data [ 79 ] , _data [ 64 ] , _data [ 49 ] , _data [ 34 ] , _data [ 19 ] , _data [ 4 ] , _data [ 185 ] , _data [ 170 ] , _data [ 155 ] , _data [ 140 ] ] )
binlc . extend ( [ _data [ 65 ] , _data [ 50 ] , _data [ 35 ] , _data [ 20 ] , _data [ 5 ] , _data [ 186 ] , _data [ 171 ] , _data [ 156 ] , _data [ 141 ] , _data [ 126 ] , _data [ 111 ] ] )
binlc . extend ( [ _data [ 36 ] , _data [ 21 ] , _data [ 6 ] , _data [ 187 ] , _data [ 172 ] , _data [ 157 ] , _data [ 142 ] , _data [ 127 ] , _data [ 112 ] , _data [ 97 ] , _data [ 82 ] ] )
binlc . extend ( [ _data [ 7 ] , _data [ 188 ] , _data [ 173 ] , _data [ 158 ] , _data [ 143 ] , _data [ 128 ] , _data [ 113 ] , _data [ 98 ] , _data [ 83 ] ] )
#This is the rest of the Full LC data -- the RS1293 FEC that we don't need
2020-11-27 12:32:19 -05:00
# This is extremely important for SMS and GPS though.
2020-11-22 01:54:01 -05:00
binlc . extend ( [ _data [ 68 ] , _data [ 53 ] , _data [ 174 ] , _data [ 159 ] , _data [ 144 ] , _data [ 129 ] , _data [ 114 ] , _data [ 99 ] , _data [ 84 ] , _data [ 69 ] , _data [ 54 ] , _data [ 39 ] ] )
binlc . extend ( [ _data [ 24 ] , _data [ 145 ] , _data [ 130 ] , _data [ 115 ] , _data [ 100 ] , _data [ 85 ] , _data [ 70 ] , _data [ 55 ] , _data [ 40 ] , _data [ 25 ] , _data [ 10 ] , _data [ 191 ] ] )
return binlc
2020-12-29 23:38:03 -05:00
2020-11-22 01:54:01 -05:00
n_packet_assembly = 0
packet_assembly = ' '
2020-11-22 23:39:02 -05:00
final_packet = ' '
2020-11-22 01:54:01 -05:00
#Convert DMR packet to binary from MMDVM packet and remove Slot Type and EMB Sync stuff to allow for BPTC 196,96 decoding
def bptc_decode ( _data ) :
binary_packet = bitarray ( decode . to_bits ( _data [ 20 : ] ) )
del binary_packet [ 98 : 166 ]
return decode_full ( binary_packet )
2020-11-23 15:53:59 -05:00
# Placeholder for future header id
def header_ID ( _data ) :
hex_hdr = str ( ahex ( bptc_decode ( _data ) ) )
return hex_hdr [ 2 : 6 ]
2020-11-22 01:54:01 -05:00
# Work in progress, used to determine data format
2020-11-23 15:53:59 -05:00
## pass
2020-11-30 13:00:19 -05:00
def aprs_send ( packet ) :
AIS = aprslib . IS ( aprs_callsign , passwd = aprs_passcode , host = aprs_server , port = aprs_port )
AIS . connect ( )
AIS . sendall ( packet )
AIS . close ( )
2020-12-27 23:41:57 -05:00
def dashboard_loc_write ( call , lat , lon , time ) :
#try:
dash_entries = ast . literal_eval ( os . popen ( ' cat /tmp/gps_data_user_loc.txt ' ) . read ( ) )
# except:
# dash_entries = []
dash_entries . insert ( 0 , { ' call ' : call , ' lat ' : lat , ' lon ' : lon , ' time ' : time } )
with open ( " /tmp/gps_data_user_loc.txt " , ' w ' ) as user_loc_file :
user_loc_file . write ( str ( dash_entries [ : 15 ] ) )
user_loc_file . close ( )
logger . info ( ' User location saved for dashboard ' )
#logger.info(dash_entries)
def dashboard_bb_write ( call , dmr_id , time , bulletin ) :
#try:
dash_bb = ast . literal_eval ( os . popen ( ' cat /tmp/gps_data_user_bb.txt ' ) . read ( ) )
# except:
# dash_entries = []
dash_bb . insert ( 0 , { ' call ' : call , ' dmr_id ' : dmr_id , ' time ' : time , ' bulliten ' : bulletin } )
with open ( " /tmp/gps_data_user_bb.txt " , ' w ' ) as user_bb_file :
2021-01-26 11:50:48 -05:00
user_bb_file . write ( str ( dash_bb [ : 10 ] ) )
2020-12-27 23:41:57 -05:00
user_bb_file . close ( )
logger . info ( ' User bulletin entry saved. ' )
#logger.info(dash_bb)
2021-01-31 16:22:33 -05:00
# Send email via SMTP function
def send_email ( to_email , email_subject , email_message ) :
global smtp_server
sender_address = email_sender
account_password = email_password
smtp_server = smtplib . SMTP_SSL ( smtp_server , int ( smtp_port ) )
smtp_server . login ( sender_address , account_password )
message = " From: " + aprs_callsign + " D-APRS Gateway \n To: " + to_email + " \n Content-type: text/html \n Subject: " + email_subject + " \n \n " + ' <strong> ' + email_subject + ' </strong><p> </p><h3> ' + email_message + ' </h3><p> </p><p>This message was sent to you from a D-APRS gateway operated by <strong> ' + aprs_callsign + ' </strong>. Do not reply as this gateway is only one way at this time.</p> '
smtp_server . sendmail ( sender_address , to_email , message )
smtp_server . close ( )
2020-12-27 23:41:57 -05:00
2020-11-30 15:37:51 -05:00
# Thanks for this forum post for this - https://stackoverflow.com/questions/2579535/convert-dd-decimal-degrees-to-dms-degrees-minutes-seconds-in-python
def decdeg2dms ( dd ) :
is_positive = dd > = 0
dd = abs ( dd )
minutes , seconds = divmod ( dd * 3600 , 60 )
degrees , minutes = divmod ( minutes , 60 )
degrees = degrees if is_positive else - degrees
return ( degrees , minutes , seconds )
2020-11-27 12:32:19 -05:00
def user_setting_write ( dmr_id , setting , value ) :
## try:
# Open file and load as dict for modification
with open ( " ./user_settings.txt " , ' r ' ) as f :
## if f.read() == '{}':
## user_dict = {}
user_dict = ast . literal_eval ( f . read ( ) )
2020-11-30 17:09:22 -05:00
logger . info ( ' Current settings: ' + str ( user_dict ) )
2020-11-27 12:32:19 -05:00
if dmr_id not in user_dict :
user_dict [ dmr_id ] = [ { ' call ' : str ( get_alias ( ( dmr_id ) , subscriber_ids ) ) } , { ' ssid ' : ' ' } , { ' icon ' : ' ' } , { ' comment ' : ' ' } ]
if setting . upper ( ) == ' ICON ' :
user_dict [ dmr_id ] [ 2 ] [ ' icon ' ] = value
if setting . upper ( ) == ' SSID ' :
user_dict [ dmr_id ] [ 1 ] [ ' ssid ' ] = value
if setting . upper ( ) == ' COM ' :
user_comment = user_dict [ dmr_id ] [ 3 ] [ ' comment ' ] = value [ 0 : 35 ]
2020-11-30 17:09:22 -05:00
f . close ( )
logger . info ( ' Loaded user settings. Preparing to write... ' )
2020-11-27 12:32:19 -05:00
# Write modified dict to file
with open ( " ./user_settings.txt " , ' w ' ) as user_dict_file :
user_dict_file . write ( str ( user_dict ) )
user_dict_file . close ( )
2020-11-28 12:16:25 -05:00
logger . info ( ' User setting saved ' )
2020-11-30 17:09:22 -05:00
f . close ( )
2020-11-28 12:16:25 -05:00
packet_assembly = ' '
2020-11-27 12:32:19 -05:00
## except:
## logger.info('No data file found, creating one.')
## #Path('./user_settings.txt').mkdir(parents=True, exist_ok=True)
## Path('./user_settings.txt').touch()
2020-11-30 15:37:51 -05:00
##def retrieve_aprs_settings(_rf_src):
## user_settings = ast.literal_eval(os.popen('cat ./user_settings.txt').read())
## if int_id(_rf_src) not in user_settings:
## aprs_loc_packet = str(get_alias(int_id(_rf_src), subscriber_ids)) + '-' + str(user_ssid) + '>APRS,TCPIP*:/' + str(datetime.datetime.utcnow().strftime("%H%M%Sh")) + str(loc.lat[0:7]) + str(loc.lat_dir) + '/' + str(loc.lon[0:8]) + str(loc.lon_dir) + '[' + str(round(loc.true_course)).zfill(3) + '/' + str(round(loc.spd_over_grnd)).zfill(3) + '/' + aprs_comment + ' DMR ID: ' + str(int_id(_rf_src))
## else:
## if user_settings[int_id(_rf_src)][1]['ssid'] == '':
## ssid = user_ssid
## if user_settings[int_id(_rf_src)][3]['comment'] == '':
## comment = aprs_comment + ' DMR ID: ' + str(int_id(_rf_src))
## if user_settings[int_id(_rf_src)][2]['icon'] == '':
## icon_table = '/'
## icon_icon = '['
## if user_settings[int_id(_rf_src)][2]['icon'] != '':
## icon_table = user_settings[int_id(_rf_src)][2]['icon'][0]
## icon_icon = user_settings[int_id(_rf_src)][2]['icon'][1]
## if user_settings[int_id(_rf_src)][1]['ssid'] != '':
## ssid = user_settings[int_id(_rf_src)][1]['ssid']
## if user_settings[int_id(_rf_src)][3]['comment'] != '':
## comment = user_settings[int_id(_rf_src)][3]['comment']
## return ssid, icon, comment
##
2020-11-27 12:32:19 -05:00
2020-11-23 15:53:59 -05:00
# Process SMS, do something bases on message
2020-11-30 15:37:51 -05:00
def process_sms ( _rf_src , sms ) :
2020-11-23 15:53:59 -05:00
if sms == ' ID ' :
logger . info ( str ( get_alias ( int_id ( from_id ) , subscriber_ids ) ) + ' - ' + str ( int_id ( from_id ) ) )
2020-12-01 14:49:53 -05:00
elif sms == ' TEST ' :
2020-11-25 18:55:44 -05:00
logger . info ( ' It works! ' )
2020-12-01 14:49:53 -05:00
elif ' @ICON ' in sms :
2020-11-30 15:37:51 -05:00
user_setting_write ( int_id ( _rf_src ) , re . sub ( ' .*|@ ' , ' ' , sms ) , re . sub ( ' @ICON| ' , ' ' , sms ) )
2020-12-01 14:49:53 -05:00
elif ' @SSID ' in sms :
2020-11-30 15:37:51 -05:00
user_setting_write ( int_id ( _rf_src ) , re . sub ( ' .*|@ ' , ' ' , sms ) , re . sub ( ' @SSID| ' , ' ' , sms ) )
2020-12-01 14:49:53 -05:00
elif ' @COM ' in sms :
2020-11-30 15:37:51 -05:00
user_setting_write ( int_id ( _rf_src ) , re . sub ( ' .*|@ ' , ' ' , sms ) , re . sub ( ' @COM |@COM ' , ' ' , sms ) )
2020-12-27 23:41:57 -05:00
elif ' @BB ' in sms :
2021-01-01 13:00:17 -05:00
dashboard_bb_write ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) , int_id ( _rf_src ) , time . strftime ( ' % H: % M: % S - % m/ %d / % y ' ) , re . sub ( ' @BB|@BB ' , ' ' , sms ) )
2021-02-01 20:28:57 -05:00
elif ' @ ' and ' E- ' in sms :
email_message = re . sub ( ' .*@|.* E- ' , ' ' , sms )
to_email = re . sub ( ' E-.* ' , ' ' , sms )
2021-01-31 16:22:33 -05:00
email_subject = ' New message from ' + str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) )
2021-02-01 20:28:57 -05:00
logger . info ( ' Email to: ' + to_email )
logger . info ( ' Message: ' + email_message )
try :
send_email ( to_email , email_subject , email_message )
logger . info ( ' Email sent. ' )
except :
logger . info ( ' Failed to send email. ' )
2020-12-01 14:49:53 -05:00
elif ' @MH ' in sms :
2020-11-30 15:37:51 -05:00
grid_square = re . sub ( ' @MH ' , ' ' , sms )
if len ( grid_square ) < 6 :
pass
else :
lat = decdeg2dms ( mh . to_location ( grid_square ) [ 0 ] )
lon = decdeg2dms ( mh . to_location ( grid_square ) [ 1 ] )
if lon [ 0 ] < 0 :
lon_dir = ' W '
if lon [ 0 ] > 0 :
lon_dir = ' E '
if lat [ 0 ] < 0 :
lat_dir = ' S '
if lat [ 0 ] > 0 :
lat_dir = ' N '
#logger.info(lat)
#logger.info(lat_dir)
2021-01-31 12:18:36 -05:00
#aprs_lat = str(str(re.sub('\..*|-', '', str(lat[0]))) + str(re.sub('\..*', '', str(lat[1])) + '.').ljust(5) + lat_dir)
#aprs_lon = str(str(re.sub('\..*|-', '', str(lon[0]))) + str(re.sub('\..*', '', str(lon[1])) + '.').ljust(5) + lon_dir)
aprs_lat = str ( str ( re . sub ( ' \ ..*|- ' , ' ' , str ( lat [ 0 ] ) ) ) + str ( re . sub ( ' \ ..* ' , ' ' , str ( lat [ 1 ] ) ) + ' . ' ) ) . zfill ( 5 ) + ' ' + lat_dir
aprs_lon = str ( str ( re . sub ( ' \ ..*|- ' , ' ' , str ( lon [ 0 ] ) ) ) + str ( re . sub ( ' \ ..* ' , ' ' , str ( lon [ 1 ] ) ) + ' . ' ) ) . zfill ( 6 ) + ' ' + lon_dir
2020-11-30 15:37:51 -05:00
#logger.info(mh.to_location(grid_square))
#logger.info(str(lat) + ', ' + str(lon))
logger . info ( ' Latitude: ' + str ( aprs_lat ) )
logger . info ( ' Longitude: ' + str ( aprs_lon ) )
user_settings = ast . literal_eval ( os . popen ( ' cat ./user_settings.txt ' ) . read ( ) )
if int_id ( _rf_src ) not in user_settings :
2020-12-06 15:30:59 -05:00
aprs_loc_packet = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + str ( user_ssid ) + ' >APHBL3,TCPIP*:/ ' + str ( datetime . datetime . utcnow ( ) . strftime ( " % H % M % Sh " ) ) + str ( aprs_lat ) + ' / ' + str ( aprs_lon ) + ' [/ ' + aprs_comment + ' DMR ID: ' + str ( int_id ( _rf_src ) )
2020-11-30 15:37:51 -05:00
else :
if user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ] == ' ' :
ssid = user_ssid
if user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ] == ' ' :
comment = aprs_comment + ' DMR ID: ' + str ( int_id ( _rf_src ) )
if user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] == ' ' :
icon_table = ' / '
icon_icon = ' [ '
if user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] != ' ' :
icon_table = user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] [ 0 ]
icon_icon = user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] [ 1 ]
if user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ] != ' ' :
ssid = user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ]
if user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ] != ' ' :
comment = user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ]
2020-12-06 15:30:59 -05:00
aprs_loc_packet = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + ssid + ' >APHBL3,TCPIP*:/ ' + str ( datetime . datetime . utcnow ( ) . strftime ( " % H % M % Sh " ) ) + str ( aprs_lat ) + icon_table + str ( aprs_lon ) + icon_icon + ' / ' + str ( comment )
2020-11-30 15:37:51 -05:00
logger . info ( aprs_loc_packet )
try :
aprslib . parse ( aprs_loc_packet )
aprs_send ( aprs_loc_packet )
2020-12-27 23:41:57 -05:00
dashboard_loc_write ( str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + ssid , aprs_lat , aprs_lon , time . strftime ( ' % H: % M: % S - % m/ %d / % y ' ) )
logger . info ( ' Sent manual position to APRS ' )
2020-11-30 15:37:51 -05:00
except :
logger . info ( ' Exception. Not uploaded ' )
packet_assembly = ' '
2021-01-12 16:55:40 -05:00
elif ' A- ' in sms and ' @ ' in sms :
#Example SMS text: @ARMDS A-This is a test.
aprs_dest = re . sub ( ' @| A-.* ' , ' ' , sms )
aprs_msg = re . sub ( ' @.* A-| ' , ' ' , sms )
logger . info ( ' APRS message to ' + aprs_dest . upper ( ) + ' . Message: ' + aprs_msg )
user_settings = ast . literal_eval ( os . popen ( ' cat ./user_settings.txt ' ) . read ( ) )
if int_id ( _rf_src ) in user_settings and user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ] != ' ' :
ssid = user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ]
else :
ssid = user_ssid
aprs_msg_pkt = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + str ( ssid ) + ' >APHBL3,TCPIP*:: ' + str ( aprs_dest ) . ljust ( 9 ) . upper ( ) + ' : ' + aprs_msg [ 0 : 73 ]
logger . info ( aprs_msg_pkt )
try :
aprslib . parse ( aprs_msg_pkt )
aprs_send ( aprs_msg_pkt )
logger . info ( ' Packet sent. ' )
except :
logger . info ( ' Error uploading MSG packet. ' )
2020-11-25 18:55:44 -05:00
try :
if sms in cmd_list :
logger . info ( ' Executing command/script. ' )
os . popen ( cmd_list [ sms ] ) . read ( )
2020-11-29 18:15:28 -05:00
packet_assembly = ' '
2020-11-25 18:55:44 -05:00
except :
logger . info ( ' Exception. Command possibly not in list, or other error. ' )
2020-11-29 18:15:28 -05:00
packet_assembly = ' '
2020-11-23 15:53:59 -05:00
else :
pass
2020-11-22 01:54:01 -05:00
###########
class DATA_SYSTEM ( HBSYSTEM ) :
## global n_packet_assembly, packet_assembly
def __init__ ( self , _name , _config , _report ) :
HBSYSTEM . __init__ ( self , _name , _config , _report )
def dmrd_received ( self , _peer_id , _rf_src , _dst_id , _seq , _slot , _call_type , _frame_type , _dtype_vseq , _stream_id , _data ) :
# Capture data headers
2020-12-26 16:43:55 -05:00
global n_packet_assembly , hdr_type
2021-02-01 20:28:57 -05:00
logger . info ( _dtype_vseq )
2020-12-06 15:30:59 -05:00
logger . info ( time . strftime ( ' % H: % M: % S - % m/ %d / % y ' ) )
2020-12-26 17:31:55 -05:00
#logger.info('Special debug for developement:')
#logger.info(ahex(bptc_decode(_data)))
2020-12-26 16:43:55 -05:00
#logger.info(hdr_type)
2020-12-26 17:31:55 -05:00
#logger.info((ba2num(bptc_decode(_data)[8:12])))
2020-11-22 01:54:01 -05:00
if int_id ( _dst_id ) == data_id :
#logger.info(type(_seq))
if type ( _seq ) is bytes :
pckt_seq = int . from_bytes ( _seq , ' big ' )
else :
pckt_seq = _seq
2020-11-23 15:53:59 -05:00
# Try to classify header
2020-12-23 18:21:54 -05:00
# UDT header has DPF of 0101, which is 5.
# If 5 is at position 3, then this should be a UDT header for MD-380 type radios.
# Coordinates are usually in the very next block after the header, we will discard the rest.
#logger.info(ahex(bptc_decode(_data)[0:10]))
2020-12-26 17:31:55 -05:00
if _call_type == call_type and header_ID ( _data ) [ 3 ] == ' 5 ' and ba2num ( bptc_decode ( _data ) [ 69 : 72 ] ) == 0 and ba2num ( bptc_decode ( _data ) [ 8 : 12 ] ) == 0 or ( _call_type == ' vcsbk ' and header_ID ( _data ) [ 3 ] == ' 5 ' and ba2num ( bptc_decode ( _data ) [ 69 : 72 ] ) == 0 and ba2num ( bptc_decode ( _data ) [ 8 : 12 ] ) == 0 ) :
2020-12-26 16:43:55 -05:00
global udt_block
2020-12-23 18:21:54 -05:00
logger . info ( ' MD-380 type UDT header detected. Very next packet should be location. ' )
hdr_type = ' 380 '
if _dtype_vseq == 6 and hdr_type == ' 380 ' or _dtype_vseq == ' group ' and hdr_type == ' 380 ' :
udt_block = 1
if _dtype_vseq == 7 and hdr_type == ' 380 ' :
udt_block = udt_block - 1
if udt_block == 0 :
logger . info ( ' MD-380 type packet. This should contain the GPS location. ' )
2020-12-26 16:43:55 -05:00
logger . info ( ' Packet: ' + str ( ahex ( bptc_decode ( _data ) ) ) )
2020-12-23 18:21:54 -05:00
if ba2num ( bptc_decode ( _data ) [ 1 : 2 ] ) == 1 :
lat_dir = ' N '
if ba2num ( bptc_decode ( _data ) [ 1 : 2 ] ) == 0 :
lat_dir = ' S '
if ba2num ( bptc_decode ( _data ) [ 2 : 3 ] ) == 1 :
lon_dir = ' E '
if ba2num ( bptc_decode ( _data ) [ 2 : 3 ] ) == 0 :
lon_dir = ' W '
lat_deg = ba2num ( bptc_decode ( _data ) [ 11 : 18 ] )
lon_deg = ba2num ( bptc_decode ( _data ) [ 38 : 46 ] )
lat_min = ba2num ( bptc_decode ( _data ) [ 18 : 24 ] )
lon_min = ba2num ( bptc_decode ( _data ) [ 46 : 52 ] )
2021-01-26 11:50:48 -05:00
lat_min_dec = str ( ba2num ( bptc_decode ( _data ) [ 24 : 38 ] ) ) . zfill ( 4 )
lon_min_dec = str ( ba2num ( bptc_decode ( _data ) [ 52 : 66 ] ) ) . zfill ( 4 )
2020-12-23 18:21:54 -05:00
aprs_lat = str ( str ( lat_deg ) + str ( lat_min ) + ' . ' + str ( lat_min_dec ) [ 0 : 2 ] ) . zfill ( 7 ) + lat_dir
aprs_lon = str ( str ( lon_deg ) + str ( lon_min ) + ' . ' + str ( lon_min_dec ) [ 0 : 2 ] ) . zfill ( 8 ) + lon_dir
# Form APRS packet
# For future use below
#aprs_loc_packet = str(get_alias(int_id(_rf_src), subscriber_ids)) + '-' + ssid + '>APHBL3,TCPIP*:/' + str(datetime.datetime.utcnow().strftime("%H%M%Sh")) + str(aprs_lat) + icon_table + str(aprs_lon) + icon_icon + '/' + str(comment)
#logger.info(aprs_loc_packet)
2020-12-23 19:18:29 -05:00
logger . info ( ' Lat: ' + str ( aprs_lat ) + ' Lon: ' + str ( aprs_lon ) )
2020-12-23 18:21:54 -05:00
user_settings = ast . literal_eval ( os . popen ( ' cat ./user_settings.txt ' ) . read ( ) )
if int_id ( _rf_src ) not in user_settings :
aprs_loc_packet = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + str ( user_ssid ) + ' >APHBL3,TCPIP*:/ ' + str ( datetime . datetime . utcnow ( ) . strftime ( " % H % M % Sh " ) ) + str ( aprs_lat ) + ' / ' + str ( aprs_lon ) + ' [/ ' + aprs_comment + ' DMR ID: ' + str ( int_id ( _rf_src ) )
else :
if user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ] == ' ' :
ssid = user_ssid
if user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ] == ' ' :
comment = aprs_comment + ' DMR ID: ' + str ( int_id ( _rf_src ) )
if user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] == ' ' :
icon_table = ' / '
icon_icon = ' [ '
if user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] != ' ' :
icon_table = user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] [ 0 ]
icon_icon = user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] [ 1 ]
if user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ] != ' ' :
ssid = user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ]
if user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ] != ' ' :
comment = user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ]
aprs_loc_packet = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + ssid + ' >APHBL3,TCPIP*:/ ' + str ( datetime . datetime . utcnow ( ) . strftime ( " % H % M % Sh " ) ) + str ( aprs_lat ) + icon_table + str ( aprs_lon ) + icon_icon + ' / ' + str ( comment )
logger . info ( aprs_loc_packet )
# Attempt to prevent malformed packets from being uploaded.
2020-12-26 16:43:55 -05:00
try :
aprslib . parse ( aprs_loc_packet )
float ( lat_deg ) < 91
float ( lon_deg ) < 121
aprs_send ( aprs_loc_packet )
2020-12-27 23:41:57 -05:00
dashboard_loc_write ( str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + ssid , aprs_lat , aprs_lon , time . strftime ( ' % H: % M: % S - % m/ %d / % y ' ) )
2020-12-26 16:43:55 -05:00
logger . info ( ' Sent APRS packet ' )
except :
logger . info ( ' Error. Failed to send packet. Packet may be malformed. ' )
udt_block = 1
hdr_type = ' '
else :
pass
2020-12-23 18:21:54 -05:00
#NMEA type packets for Anytone like radios.
2021-01-30 12:16:00 -05:00
if _call_type == call_type or ( _call_type == ' vcsbk ' and pckt_seq > 3 ) : #int.from_bytes(_seq, 'big') > 3 ):
2020-12-26 16:43:55 -05:00
global packet_assembly , btf
2020-11-22 01:54:01 -05:00
if _dtype_vseq == 6 or _dtype_vseq == ' group ' :
2020-11-23 15:53:59 -05:00
global btf , hdr_start
hdr_start = str ( header_ID ( _data ) )
2020-11-22 16:51:54 -05:00
logger . info ( ' Header from ' + str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' . DMR ID: ' + str ( int_id ( _rf_src ) ) )
2020-11-22 01:54:01 -05:00
logger . info ( ahex ( bptc_decode ( _data ) ) )
logger . info ( ' Blocks to follow: ' + str ( ba2num ( bptc_decode ( _data ) [ 65 : 72 ] ) ) )
btf = ba2num ( bptc_decode ( _data ) [ 65 : 72 ] )
2020-11-30 13:00:19 -05:00
# Try resetting packet_assembly
packet_assembly = ' '
2020-11-22 01:54:01 -05:00
# Data blocks at 1/2 rate, see https://github.com/g4klx/MMDVM/blob/master/DMRDefines.h for data types. _dtype_seq defined here also
if _dtype_vseq == 7 :
btf = btf - 1
logger . info ( ' Block #: ' + str ( btf ) )
#logger.info(_seq)
2020-11-22 16:51:54 -05:00
logger . info ( ' Data block from ' + str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' . DMR ID: ' + str ( int_id ( _rf_src ) ) )
2020-11-22 01:54:01 -05:00
logger . info ( ahex ( bptc_decode ( _data ) ) )
if _seq == 0 :
n_packet_assembly = 0
packet_assembly = ' '
if btf < btf + 1 :
n_packet_assembly = n_packet_assembly + 1
packet_assembly = packet_assembly + str ( bptc_decode ( _data ) ) #str((decode_full_lc(b_packet)).strip('bitarray('))
# Use block 0 as trigger. $GPRMC must also be in string to indicate NMEA.
# This triggers the APRS upload
2020-11-22 23:39:02 -05:00
if btf == 0 : #_seq == 12:
2020-11-22 15:51:11 -05:00
final_packet = str ( bitarray ( re . sub ( " \ )| \ (|bitarray| ' " , ' ' , packet_assembly ) ) . tobytes ( ) . decode ( ' utf-8 ' , ' ignore ' ) )
2020-11-22 21:54:02 -05:00
sms_hex = str ( ba2hx ( bitarray ( re . sub ( " \ )| \ (|bitarray| ' " , ' ' , packet_assembly ) ) ) )
2020-12-01 14:49:53 -05:00
sms_hex_string = re . sub ( " b ' | ' " , ' ' , str ( sms_hex ) )
2020-11-22 21:54:02 -05:00
#NMEA GPS sentence
2021-01-12 12:59:53 -05:00
if ' $GPRMC ' in final_packet or ' $GNRMC ' in final_packet :
2020-11-23 16:49:34 -05:00
logger . info ( final_packet + ' \n ' )
2021-02-02 14:37:05 -05:00
# Eliminate excess bytes based on NMEA type
# GPRMC
if ' GPRMC ' in final_packet :
logger . info ( ' GPRMC location ' )
nmea_parse = re . sub ( ' A \ *.*|.* \ $ ' , ' ' , str ( final_packet ) )
# GNRMC
if ' GNRMC ' in final_packet :
logger . info ( ' GNRMC location ' )
nmea_parse = re . sub ( ' \n .*|V \ *.* ' , ' ' , final_packet )
2020-11-22 21:54:02 -05:00
loc = pynmea2 . parse ( nmea_parse , check = False )
2020-11-23 13:19:58 -05:00
logger . info ( ' Latitude: ' + str ( loc . lat ) + str ( loc . lat_dir ) + ' Longitude: ' + str ( loc . lon ) + str ( loc . lon_dir ) + ' Direction: ' + str ( loc . true_course ) + ' Speed: ' + str ( loc . spd_over_grnd ) + ' \n ' )
2020-11-22 01:54:01 -05:00
# Begin APRS format and upload
2020-11-22 21:54:02 -05:00
## aprs_loc_packet = str(get_alias(int_id(_rf_src), subscriber_ids)) + '-' + str(user_ssid) + '>APRS,TCPIP*:/' + str(datetime.datetime.utcnow().strftime("%H%M%Sh")) + str(final_packet[29:36]) + str(final_packet[39]) + '/' + str(re.sub(',', '', final_packet[41:49])) + str(final_packet[52]) + '[/' + aprs_comment + ' DMR ID: ' + str(int_id(_rf_src))
2020-11-27 12:32:19 -05:00
try :
2020-11-30 13:00:19 -05:00
# Disable opening file for reading to reduce "collision" or reading and writing at same time.
2020-11-30 15:37:51 -05:00
with open ( " ./user_settings.txt " , ' r ' ) as f :
user_settings = ast . literal_eval ( f . read ( ) )
2020-11-30 13:00:19 -05:00
user_settings = ast . literal_eval ( os . popen ( ' cat ./user_settings.txt ' ) . read ( ) )
if int_id ( _rf_src ) not in user_settings :
2020-12-06 15:30:59 -05:00
aprs_loc_packet = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + str ( user_ssid ) + ' >APHBL3,TCPIP*:/ ' + str ( datetime . datetime . utcnow ( ) . strftime ( " % H % M % Sh " ) ) + str ( loc . lat [ 0 : 7 ] ) + str ( loc . lat_dir ) + ' / ' + str ( loc . lon [ 0 : 8 ] ) + str ( loc . lon_dir ) + ' [ ' + str ( round ( loc . true_course ) ) . zfill ( 3 ) + ' / ' + str ( round ( loc . spd_over_grnd ) ) . zfill ( 3 ) + ' / ' + aprs_comment + ' DMR ID: ' + str ( int_id ( _rf_src ) )
2020-11-30 13:00:19 -05:00
else :
if user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ] == ' ' :
ssid = user_ssid
if user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ] == ' ' :
comment = aprs_comment + ' DMR ID: ' + str ( int_id ( _rf_src ) )
if user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] == ' ' :
icon_table = ' / '
icon_icon = ' [ '
if user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] != ' ' :
icon_table = user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] [ 0 ]
icon_icon = user_settings [ int_id ( _rf_src ) ] [ 2 ] [ ' icon ' ] [ 1 ]
if user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ] != ' ' :
ssid = user_settings [ int_id ( _rf_src ) ] [ 1 ] [ ' ssid ' ]
if user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ] != ' ' :
comment = user_settings [ int_id ( _rf_src ) ] [ 3 ] [ ' comment ' ]
2020-11-30 15:37:51 -05:00
#logger.info(retrieve_aprs_settings(_rf_src))
2020-12-06 15:30:59 -05:00
aprs_loc_packet = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + ssid + ' >APHBL3,TCPIP*:/ ' + str ( datetime . datetime . utcnow ( ) . strftime ( " % H % M % Sh " ) ) + str ( loc . lat [ 0 : 7 ] ) + str ( loc . lat_dir ) + icon_table + str ( loc . lon [ 0 : 8 ] ) + str ( loc . lon_dir ) + icon_icon + str ( round ( loc . true_course ) ) . zfill ( 3 ) + ' / ' + str ( round ( loc . spd_over_grnd ) ) . zfill ( 3 ) + ' / ' + str ( comment )
2020-11-27 12:32:19 -05:00
logger . info ( aprs_loc_packet )
2020-11-28 12:16:25 -05:00
logger . info ( ' User comment: ' + comment )
logger . info ( ' User SSID: ' + ssid )
logger . info ( ' User icon: ' + icon_table + icon_icon )
2020-11-30 13:00:19 -05:00
## f.close()
2020-11-27 12:32:19 -05:00
except :
logger . info ( ' Error or user settings file not found, proceeding with default settings. ' )
2020-12-06 15:30:59 -05:00
aprs_loc_packet = str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + str ( user_ssid ) + ' >APHBL3,TCPIP*:/ ' + str ( datetime . datetime . utcnow ( ) . strftime ( " % H % M % Sh " ) ) + str ( loc . lat [ 0 : 7 ] ) + str ( loc . lat_dir ) + ' / ' + str ( loc . lon [ 0 : 8 ] ) + str ( loc . lon_dir ) + ' [ ' + str ( round ( loc . true_course ) ) . zfill ( 3 ) + ' / ' + str ( round ( loc . spd_over_grnd ) ) . zfill ( 3 ) + ' / ' + aprs_comment + ' DMR ID: ' + str ( int_id ( _rf_src ) )
2020-11-22 01:54:01 -05:00
try :
2020-12-27 23:41:57 -05:00
# Try parse of APRS packet. If it fails, it will not upload to APRS-IS
2020-11-22 01:54:01 -05:00
aprslib . parse ( aprs_loc_packet )
2020-12-27 23:41:57 -05:00
# Float values of lat and lon. Anything that is not a number will cause it to fail.
2020-11-23 16:49:34 -05:00
float ( loc . lat )
float ( loc . lon )
2020-11-30 13:00:19 -05:00
aprs_send ( aprs_loc_packet )
2020-12-27 23:41:57 -05:00
dashboard_loc_write ( str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' - ' + ssid , str ( loc . lat [ 0 : 7 ] ) + str ( loc . lat_dir ) , str ( loc . lon [ 0 : 8 ] ) + str ( loc . lon_dir ) , time . strftime ( ' % H: % M: % S - % m/ %d / % y ' ) )
2020-11-22 01:54:01 -05:00
except :
logger . info ( ' Failed to parse packet. Packet may be deformed. Not uploaded. ' )
2021-02-02 14:37:05 -05:00
#final_packet = ''
2020-11-22 01:54:01 -05:00
# Get callsign based on DMR ID
# End APRS-IS upload
2020-11-22 21:54:02 -05:00
# Assume this is an SMS message
2021-02-02 14:37:05 -05:00
elif ' $GPRMC ' not in final_packet or ' $GNRMC ' not in final_packet :
2020-12-23 18:21:54 -05:00
2020-12-01 14:49:53 -05:00
#### # Motorola type SMS header
## if '824a' in hdr_start or '024a' in hdr_start:
## logger.info('\nMotorola type SMS')
## sms = codecs.decode(bytes.fromhex(''.join(sms_hex[74:-8].split('00'))), 'utf-8')
## logger.info('\n\n' + 'Received SMS from ' + str(get_alias(int_id(_rf_src), subscriber_ids)) + ', DMR ID: ' + str(int_id(_rf_src)) + ': ' + str(sms) + '\n')
## process_sms(_rf_src, sms)
## packet_assembly = ''
## # ETSI? type SMS header
## elif '0244' in hdr_start or '8244' in hdr_start:
## logger.info('ETSI? type SMS')
## sms = codecs.decode(bytes.fromhex(''.join(sms_hex[64:-8].split('00'))), 'utf-8')
## logger.info('\n\n' + 'Received SMS from ' + str(get_alias(int_id(_rf_src), subscriber_ids)) + ', DMR ID: ' + str(int_id(_rf_src)) + ': ' + str(sms) + '\n')
## #logger.info(final_packet)
## #logger.info(sms_hex[64:-8])
## process_sms(_rf_src, sms)
## packet_assembly = ''
####
## else:
2020-12-01 15:13:48 -05:00
logger . info ( ' \n SMS detected. Attempting to parse. ' )
2020-11-30 20:24:36 -05:00
#logger.info(final_packet)
logger . info ( sms_hex )
2020-12-01 15:13:48 -05:00
## logger.info(type(sms_hex))
2020-12-01 12:16:32 -05:00
logger . info ( ' Attempting to find command... ' )
2020-12-01 14:49:53 -05:00
## sms = codecs.decode(bytes.fromhex(''.join(sms_hex[:-8].split('00'))), 'utf-8', 'ignore')
sms = codecs . decode ( bytes . fromhex ( ' ' . join ( sms_hex_string [ : - 8 ] . split ( ' 00 ' ) ) ) , ' utf-8 ' , ' ignore ' )
2020-12-01 12:16:32 -05:00
msg_found = re . sub ( ' .* \n ' , ' ' , sms )
logger . info ( ' \n \n ' + ' Received SMS from ' + str ( get_alias ( int_id ( _rf_src ) , subscriber_ids ) ) + ' , DMR ID: ' + str ( int_id ( _rf_src ) ) + ' : ' + str ( msg_found ) + ' \n ' )
process_sms ( _rf_src , msg_found )
2020-11-29 18:09:47 -05:00
packet_assembly = ' '
2020-11-23 15:53:59 -05:00
pass
#logger.info(bitarray(re.sub("\)|\(|bitarray|'", '', str(bptc_decode(_data)).tobytes().decode('utf-8', 'ignore'))))
#logger.info('\n\n' + 'Received SMS from ' + str(get_alias(int_id(_rf_src), subscriber_ids)) + ', DMR ID: ' + str(int_id(_rf_src)) + ': ' + str(sms) + '\n')
2020-11-22 23:39:02 -05:00
# Reset the packet assembly to prevent old data from returning.
2020-11-23 15:53:59 -05:00
hdr_start = ' '
2020-11-22 23:39:02 -05:00
#logger.info(_seq)
2020-11-30 20:24:36 -05:00
#packet_assembly = '' #logger.info(_dtype_vseq)
2020-11-23 13:19:58 -05:00
#logger.info(ahex(bptc_decode(_data)).decode('utf-8', 'ignore'))
2020-11-22 01:54:01 -05:00
#logger.info(bitarray(re.sub("\)|\(|bitarray|'", '', str(bptc_decode(_data)).tobytes().decode('utf-8', 'ignore'))))
else :
pass
#************************************************
# MAIN PROGRAM LOOP STARTS HERE
#************************************************
if __name__ == ' __main__ ' :
2020-11-23 13:19:58 -05:00
#global aprs_callsign, aprs_passcode, aprs_server, aprs_port, user_ssid, aprs_comment, call_type, data_id
2020-11-22 01:54:01 -05:00
import argparse
import sys
import os
import signal
from dmr_utils3 . utils import try_download , mk_id_dict
# Change the current directory to the location of the application
os . chdir ( os . path . dirname ( os . path . realpath ( sys . argv [ 0 ] ) ) )
2020-11-27 12:32:19 -05:00
# Check if user_settings (for APRS settings of users) exists. Creat it if not.
if Path ( ' ./user_settings.txt ' ) . is_file ( ) :
pass
else :
Path ( ' ./user_settings.txt ' ) . touch ( )
with open ( " ./user_settings.txt " , ' w ' ) as user_dict_file :
user_dict_file . write ( " { 1: [ { ' call ' : ' N0CALL ' }, { ' ssid ' : ' ' }, { ' icon ' : ' ' }, { ' comment ' : ' ' }]} " )
user_dict_file . close ( )
2020-12-27 23:41:57 -05:00
# Check to see if dashboard files exist
2021-01-06 14:30:17 -05:00
if Path ( ' /tmp/gps_data_user_loc.txt ' ) . is_file ( ) :
2020-12-27 23:41:57 -05:00
pass
else :
Path ( ' /tmp/gps_data_user_loc.txt ' ) . touch ( )
with open ( " /tmp/gps_data_user_loc.txt " , ' w ' ) as user_loc_file :
user_loc_file . write ( " [] " )
user_loc_file . close ( )
if Path ( ' /tmp/gps_data_user_bb.txt ' ) . is_file ( ) :
pass
else :
Path ( ' /tmp/gps_data_user_bb.txt ' ) . touch ( )
with open ( " /tmp/gps_data_user_bb.txt " , ' w ' ) as user_bb_file :
user_bb_file . write ( " [] " )
user_bb_file . close ( )
2020-11-22 01:54:01 -05:00
# CLI argument parser - handles picking up the config file from the command line, and sending a "help" message
parser = argparse . ArgumentParser ( )
2020-12-01 12:16:32 -05:00
parser . add_argument ( ' -c ' , ' --config ' , action = ' store ' , dest = ' CONFIG_FILE ' , help = ' /full/path/to/config.file (usually gps_data.cfg) ' )
2020-11-22 01:54:01 -05:00
parser . add_argument ( ' -l ' , ' --logging ' , action = ' store ' , dest = ' LOG_LEVEL ' , help = ' Override config file logging level. ' )
cli_args = parser . parse_args ( )
# Ensure we have a path for the config file, if one wasn't specified, then use the default (top of file)
if not cli_args . CONFIG_FILE :
2020-12-01 12:16:32 -05:00
cli_args . CONFIG_FILE = os . path . dirname ( os . path . abspath ( __file__ ) ) + ' /gps_data.cfg '
2020-11-22 01:54:01 -05:00
# Call the external routine to build the configuration dictionary
CONFIG = config . build_config ( cli_args . CONFIG_FILE )
2020-11-23 13:19:58 -05:00
data_id = int ( CONFIG [ ' GPS_DATA ' ] [ ' DATA_DMR_ID ' ] )
# Group call or Unit (private) call
call_type = CONFIG [ ' GPS_DATA ' ] [ ' CALL_TYPE ' ]
# APRS-IS login information
aprs_callsign = CONFIG [ ' GPS_DATA ' ] [ ' APRS_LOGIN_CALL ' ]
aprs_passcode = int ( CONFIG [ ' GPS_DATA ' ] [ ' APRS_LOGIN_PASSCODE ' ] )
aprs_server = CONFIG [ ' GPS_DATA ' ] [ ' APRS_SERVER ' ]
aprs_port = int ( CONFIG [ ' GPS_DATA ' ] [ ' APRS_PORT ' ] )
user_ssid = CONFIG [ ' GPS_DATA ' ] [ ' USER_APRS_SSID ' ]
aprs_comment = CONFIG [ ' GPS_DATA ' ] [ ' USER_APRS_COMMENT ' ]
2021-01-31 16:22:33 -05:00
# EMAIL variables
email_sender = CONFIG [ ' GPS_DATA ' ] [ ' EMAIL_SENDER ' ]
email_password = CONFIG [ ' GPS_DATA ' ] [ ' EMAIL_PASSWORD ' ]
smtp_server = CONFIG [ ' GPS_DATA ' ] [ ' SMTP_SERVER ' ]
smtp_port = CONFIG [ ' GPS_DATA ' ] [ ' SMTP_PORT ' ]
2020-11-22 01:54:01 -05:00
# Start the system logger
if cli_args . LOG_LEVEL :
CONFIG [ ' LOGGER ' ] [ ' LOG_LEVEL ' ] = cli_args . LOG_LEVEL
logger = log . config_logging ( CONFIG [ ' LOGGER ' ] )
logger . info ( ' \n \n Copyright (c) 2013, 2014, 2015, 2016, 2018, 2019 \n \t The Regents of the K0USY Group. All rights reserved. \n GPS and Data decoding by Eric, KF7EEL ' )
logger . debug ( ' Logging system started, anything from here on gets logged ' )
# Set up the signal handler
def sig_handler ( _signal , _frame ) :
logger . info ( ' SHUTDOWN: >>>GPS and Data Decoder<<< IS TERMINATING WITH SIGNAL %s ' , str ( _signal ) )
hblink_handler ( _signal , _frame )
logger . info ( ' SHUTDOWN: ALL SYSTEM HANDLERS EXECUTED - STOPPING REACTOR ' )
reactor . stop ( )
# Set signal handers so that we can gracefully exit if need be
for sig in [ signal . SIGTERM , signal . SIGINT ] :
signal . signal ( sig , sig_handler )
# Create the name-number mapping dictionaries
peer_ids , subscriber_ids , talkgroup_ids = mk_aliases ( CONFIG )
# INITIALIZE THE REPORTING LOOP
if CONFIG [ ' REPORTS ' ] [ ' REPORT ' ] :
report_server = config_reports ( CONFIG , reportFactory )
else :
report_server = None
logger . info ( ' (REPORT) TCP Socket reporting not configured ' )
# HBlink instance creation
logger . info ( ' HBlink \' gps_data.py \' -- SYSTEM STARTING... ' )
for system in CONFIG [ ' SYSTEMS ' ] :
if CONFIG [ ' SYSTEMS ' ] [ system ] [ ' ENABLED ' ] :
if CONFIG [ ' SYSTEMS ' ] [ system ] [ ' MODE ' ] == ' OPENBRIDGE ' :
systems [ system ] = OPENBRIDGE ( system , CONFIG , report_server )
else :
systems [ system ] = DATA_SYSTEM ( system , CONFIG , report_server )
reactor . listenUDP ( CONFIG [ ' SYSTEMS ' ] [ system ] [ ' PORT ' ] , systems [ system ] , interface = CONFIG [ ' SYSTEMS ' ] [ system ] [ ' IP ' ] )
logger . debug ( ' %s instance created: %s , %s ' , CONFIG [ ' SYSTEMS ' ] [ system ] [ ' MODE ' ] , system , systems [ system ] )
reactor . run ( )
# John 3:16 - For God so loved the world, that he gave his only Son,
# that whoever believes in him should not perish but have eternal life.
