From 0cf2845d885a6385e4ac3731b87c491c7d264564 Mon Sep 17 00:00:00 2001 From: Simon Date: Wed, 5 Jan 2022 15:39:25 +0000 Subject: [PATCH] do this in branch --- CCCC.py | 124 -------------------------------------------------------- 1 file changed, 124 deletions(-) delete mode 100644 CCCC.py diff --git a/CCCC.py b/CCCC.py deleted file mode 100644 index 5bb27f3..0000000 --- a/CCCC.py +++ /dev/null @@ -1,124 +0,0 @@ - -#import log -#import config - -from time import time -from random import randint - -from twisted.internet import reactor,task -from twisted.internet.defer import Deferred -from twisted.internet.protocol import ClientFactory,ReconnectingClientFactory,Protocol -from twisted.protocols.basic import LineReceiver - -#from pyrtp import * - -# The module needs logging logging, but handlers, etc. are controlled by the parent -#import logging -#logger = logging.getLogger(__name__) - - -class CCCC(): - def __init__(self,host,port): - self._CCClient = self.CCClient - self._rnd_number = randint(0x00, 0xFFFFFFFF) - self.hex_id = bytes(hex(self._rnd_number),'utf8') - self.bytes_id = self._rnd_number.to_bytes(4,byteorder="big") - - self.CF = reactor.connectTCP(host, port, self.CCClientFactory(self._CCClient,self.hex_id)) - - def closeConnection(self): - self.transport.loseConnection() - - class CCClient(LineReceiver): - - delimiter = b'\n' - - end = b"Bye-bye!" - - def connectionMade(self): - #self.peer = self.transport.getPeer() - _hexid = self.hex_id - # - #CCCC._ssrc_list[_hexid] = self._peer - _linkid = b'91 ' - _channel_name = b'CC outbound link' - _local_site_name = b'FreeDMR-Testing' - #Generate a random MAC that looks like a real one - #We don't really want to share our MAC ;-) - _local_mac = bytes(hex(randint(0x00, 0xFFFFFFFFFFFF)),'utf8') - #Fake a recent code_rev of CBridge - _code_rev = b'9959__December_5_2021__13.25.28' - #We'll use artistic licence on this one - _os_ver = b'FreeDMR Peer Server' - - self.sendLine(_hexid) - self.sendLine(_linkid) - self.sendLine(_channel_name) - self.sendLine(_local_site_name) - self.sendLine(b'Server Inbound') - self.sendLine(_local_mac) - self.sendLine(_code_rev) - self.sendLine(_os_ver) - - def lineReceived(self,line): - packet_dict = {} - #If we get codec AMBE (that's all we support) - if line == b'AMBE' or self._counter != 0: - self._counter = 6 - else: - self.transport.loseConnection() - - if self._counter: - if self._counter == 6: - self._ms_window = line - self._counter = 5 - elif self._counter == 5: - self._seconds_microseconds = line - self._counter = 4 - elif self._counter == 4: - self._syn_and_safe_ver_date = line - self._counter = 3 - elif self._counter == 3: - self._remote_sys_name = line - self._counter = 2 - elif self._counter == 2: - self._remote_tos_value = line - self._counter = 1 - elif self._counter == 1: - self._remote_os_ver = line - self._counter = 0 - - line = line.decode("utf8") - if line[0:1] == 'B': - if line[1:3] == '01': - packet_dict['type'] = 'ON' - packet_dict['linkid'] = line[3:5] - packet_dict['line'] = line - else: - packet_dict['type'] = 'OFF' - packet_dict['linkid'] = line[1:3] - packet_dict['line'] = line - - self.controlLine(packet_dict) - - def controlLine(self,packet_dict): - pass - - - - class CCClientFactory(ReconnectingClientFactory): - def __init__(self,CCClient,hex_id): - self.done = Deferred() - self.protocol = CCClient - self.protocol.hex_id = hex_id - - - def clientConnectionFailed(self, connector, reason): - print("connection failed:", reason.getErrorMessage()) - ReconnectingClientFactory.clientConnectionLost(self, connector, reason) - - def clientConnectionLost(self, connector, reason): - print("connection lost:", reason.getErrorMessage()) - ReconnectingClientFactory.clientConnectionLost(self, connector, reason) - -