mirror of
https://github.com/BOSWatch/BW3-Core.git
synced 2026-01-06 16:50:27 +01:00
some edits
This commit is contained in:
parent
b5b5562a5d
commit
f6094618d8
|
|
@ -51,7 +51,7 @@ class Fms:
|
|||
tacticalInfo = data[114:117]
|
||||
fms_id = service + country + location + vehicle + status + direction
|
||||
|
||||
if re.search("[0-9a-f]{8}[0-9a-f]{1}[01]{1}", fms_id):
|
||||
if re.search("[0-9a-f]{8}[0-9a-f][01]", fms_id):
|
||||
logging.debug("found valid FMS")
|
||||
|
||||
bwPacket = packet.Packet()
|
||||
|
|
|
|||
|
|
@ -42,10 +42,10 @@ class Pocsag:
|
|||
@return BOSWatch POCSAG packet or None"""
|
||||
bitrate, ric, subric = Pocsag._getBitrateRicSubric(data)
|
||||
|
||||
if re.search("[0-9]{7}", ric) and re.search("[1-4]{1}", subric):
|
||||
if re.search("[0-9]{7}", ric) and re.search("[1-4]", subric):
|
||||
if "Alpha:" in data:
|
||||
message = data.split('Alpha: ')[1].strip()
|
||||
message = message.replace('<NUL><NUL>', '').replace('<NUL>', '').replace('<NUL', '').replace('< NUL>', '').replace('<EOT>', '').strip()
|
||||
message = message.replace('<NUL>', '').replace('<NUL', '').replace('< NUL>', '').replace('<EOT>', '').strip()
|
||||
else:
|
||||
message = ""
|
||||
subricText = subric.replace("1", "a").replace("2", "b").replace("3", "c").replace("4", "d")
|
||||
|
|
|
|||
|
|
@ -12,7 +12,7 @@
|
|||
@file: descriptor.py
|
||||
@date: 07.01.2018
|
||||
@author: Bastian Schroll
|
||||
@description:
|
||||
@description: Descriptor to load Descriptions from csv files
|
||||
"""
|
||||
import logging
|
||||
import csv
|
||||
|
|
|
|||
|
|
@ -108,6 +108,7 @@ class TCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
|
|||
logging.exception("cannot stop the server")
|
||||
return False
|
||||
|
||||
@staticmethod
|
||||
def clientsConnected(self): # pragma: no cover
|
||||
"""!Number of currently connected Clients
|
||||
|
||||
|
|
@ -119,6 +120,7 @@ class TCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
|
|||
else:
|
||||
return 0
|
||||
|
||||
@staticmethod
|
||||
def getData(self):
|
||||
"""!Function to get the data packages from server
|
||||
must be polled by main program
|
||||
|
|
@ -130,6 +132,7 @@ class TCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
|
|||
return message
|
||||
return None
|
||||
|
||||
@staticmethod
|
||||
def flushData(self):
|
||||
"""!To flush all existing data in queue"""
|
||||
logging.debug("Flush client data queue")
|
||||
|
|
|
|||
Loading…
Reference in a new issue