mirror of
https://github.com/openplotter/openplotter-maiana.git
synced 2025-05-15 22:50:13 -07:00
113 lines
5.1 KiB
Python
113 lines
5.1 KiB
Python
#!/usr/bin/env python3
|
|
|
|
# This file is part of OpenPlotter.
|
|
# Copyright (C) 2022 by Sailoog <https://github.com/openplotter/openplotter-maiana>
|
|
#
|
|
# Openplotter 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 2 of the License, or
|
|
# any later version.
|
|
# Openplotter 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 Openplotter. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
import os, socket, time, ssl, json, datetime
|
|
from openplotterSettings import conf
|
|
from openplotterSettings import platform
|
|
from openplotterSettings import language
|
|
from websocket import create_connection
|
|
|
|
def main():
|
|
platform2 = platform.Platform()
|
|
conf2 = conf.Conf()
|
|
currentdir = os.path.dirname(os.path.abspath(__file__))
|
|
currentLanguage = conf2.get('GENERAL', 'lang')
|
|
package = 'openplotter-maiana'
|
|
language.Language(currentdir, package, currentLanguage)
|
|
token = conf2.get('MAIANA', 'token')
|
|
device = conf2.get('MAIANA', 'device')
|
|
if conf2.get('GENERAL', 'debug') == 'yes': debug = True
|
|
else: debug = False
|
|
if token and device:
|
|
ws = False
|
|
sock = False
|
|
while True:
|
|
try:
|
|
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
server_address = ('localhost', 10110)
|
|
sock.connect(server_address)
|
|
sock.setblocking(0)
|
|
|
|
uri = platform2.ws+'localhost:'+platform2.skPort+'/signalk/v1/stream?subscribe=none'
|
|
headers = {'Authorization': 'Bearer '+token}
|
|
ws = create_connection(uri, header=headers, sslopt={"cert_reqs": ssl.CERT_NONE})
|
|
|
|
tick = time.perf_counter()
|
|
while True:
|
|
time.sleep(0.01)
|
|
if (time.perf_counter() - tick) > 3: raise Exception('')
|
|
data = False
|
|
try: data = sock.recv(1024)
|
|
except: pass
|
|
if data:
|
|
tick = time.perf_counter()
|
|
data = data.decode("utf-8")
|
|
if '$PA' in data:
|
|
data = data.splitlines()
|
|
for data2 in data:
|
|
SKdata = {}
|
|
data3 = data2.split('*')
|
|
data3 = data3[0].split(',')
|
|
#$PAINF,A,0x20*5B
|
|
if data3[0] == '$PAINF':
|
|
try:
|
|
noiseValue = int(data3[2],16)
|
|
SKdata.update({"MAIANA.channel"+data3[1]+".noiseFloor":noiseValue})
|
|
if conf2.get('MAIANA', 'noiseDetect') == '1':
|
|
if noiseValue > 64:
|
|
now = datetime.datetime.utcnow()
|
|
now = now.strftime("%Y-%m-%dT%H:%M:%S.%fZ")
|
|
SKdata.update({"notifications.MAIANA.channel"+data3[1]+".noiseFloor":{"message":_("There may be electromagnetic interference near the MAIANA AIS antenna"),"state":"alert","method": ["visual", "sound"],"timestamp":now}})
|
|
else:
|
|
SKdata.update({"notifications.MAIANA.channel"+data3[1]+".noiseFloor":None})
|
|
except: pass
|
|
#$PAITX,A,18*1C
|
|
elif data3[0] == '$PAITX':
|
|
SKdata.update({"MAIANA.channel"+data3[1]+".transmittedMessageType":data3[2]})
|
|
#$PAISYS,11.3.0,4.0.0,,STM32L422,1,1*05
|
|
elif data3[0] == '$PAISYS':
|
|
try: SKdata.update({"MAIANA.hardwareRevision":data3[1],"MAIANA.firmwareRevision":data3[2],"MAIANA.serialNumber":data3[3],"MAIANA.MCUtype":data3[4],"MAIANA.breakoutGeneration":data3[5],"MAIANA.bootloader":data3[6]})
|
|
except:
|
|
try: SKdata.update({"MAIANA.hardwareRevision":data3[1],"MAIANA.firmwareRevision":data3[2],"MAIANA.serialNumber":data3[3],"MAIANA.MCUtype":data3[4],"MAIANA.breakoutGeneration":'',"MAIANA.bootloader":''})
|
|
except: SKdata.update({"MAIANA.hardwareRevision":data3[1],"MAIANA.firmwareRevision":data3[2],"MAIANA.serialNumber":data3[3],"MAIANA.MCUtype":'',"MAIANA.breakoutGeneration":'',"MAIANA.bootloader":''})
|
|
#$PAISTN,987654321,NAUT,,37,0,0,0,0*2A
|
|
elif data3[0] == '$PAISTN':
|
|
try:
|
|
SKdata.update({"MAIANA.station.MMSI":data3[1],"MAIANA.station.vesselName":data3[2],"MAIANA.station.callSign":data3[3],"MAIANA.station.vesselType":int(data3[4]),"MAIANA.station.LOA":int(data3[5]),"MAIANA.station.beam":int(data3[6]),"MAIANA.station.portOffset":int(data3[7]),"MAIANA.station.bowOffset":int(data3[8])})
|
|
except: pass
|
|
#$PAITXCFG,1,0,1,1,0*0
|
|
elif data3[0] == '$PAITXCFG':
|
|
try:
|
|
SKdata.update({"MAIANA.transmission.hardwarePresent":int(data3[1]),"MAIANA.transmission.hardwareSwitch":int(data3[2]),"MAIANA.transmission.softwareSwitch":int(data3[3]),"MAIANA.transmission.stationData":int(data3[4]),"MAIANA.transmission.status":int(data3[5])})
|
|
except: pass
|
|
keys = []
|
|
for i in SKdata:
|
|
keys.append({"path":i,"value":SKdata[i]})
|
|
if keys:
|
|
SignalK = {"updates":[{"$source":"OpenPlotter.maiana","values":keys}]}
|
|
SignalK = json.dumps(SignalK)
|
|
ws.send(SignalK+'\r\n')
|
|
except Exception as e:
|
|
if debug: print(str(e))
|
|
if ws: ws.close()
|
|
if sock: sock.close()
|
|
time.sleep(5)
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main() |