1331726028
As of now, dmrlink.py is only a behind the scenes worker... It's just the base class to take care of link establishment and maintenance. Applications, such as bridging or logging will now be in their own files and inherit from dmrlink.py
94 lines
4.1 KiB
Python
94 lines
4.1 KiB
Python
# Copyright (c) 2013 Cortney T. Buffington, N0MJS n0mjs@me.com
|
|
#
|
|
# This work is licensed under the Creative Commons Attribution-ShareAlike
|
|
# 3.0 Unported License.To view a copy of this license, visit
|
|
# http://creativecommons.org/licenses/by-sa/3.0/ or send a letter to
|
|
# Creative Commons, 444 Castro Street, Suite 900, Mountain View,
|
|
# California, 94041, USA.
|
|
|
|
from __future__ import print_function
|
|
from twisted.internet.protocol import DatagramProtocol
|
|
from twisted.internet import reactor
|
|
from twisted.internet import task
|
|
|
|
import time
|
|
import binascii
|
|
import dmrlink
|
|
from dmrlink import IPSC, UnauthIPSC, NETWORK, networks, get_info, int_id
|
|
|
|
class logIPSC(IPSC):
|
|
def __init__(self, *args, **kwargs):
|
|
IPSC.__init__(self, *args, **kwargs)
|
|
self.ACTIVE_CALLS = []
|
|
|
|
#************************************************
|
|
# CALLBACK FUNCTIONS FOR USER PACKET TYPES
|
|
#************************************************
|
|
|
|
def call_ctl_1(self, _network, _data):
|
|
print('({}) Call Control Type 1 Packet Received From: {}' .format(_network, _src_sub))
|
|
|
|
def call_ctl_2(self, _network, _data):
|
|
print('({}) Call Control Type 2 Packet Received' .format(_network))
|
|
|
|
def call_ctl_3(self, _network, _data):
|
|
print('({}) Call Control Type 3 Packet Received' .format(_network))
|
|
|
|
def xcmp_xnl(self, _network, _data):
|
|
print('({}) XCMP/XNL Packet Received From: {}' .format(_network, _src_sub))
|
|
|
|
def group_voice(self, _network, _src_sub, _dst_sub, _ts, _end, _peerid, _data):
|
|
# _log = logger.debug
|
|
if (_ts not in self.ACTIVE_CALLS) or _end:
|
|
_time = time.strftime('%m/%d/%y %H:%M:%S')
|
|
_dst_sub = get_info(int_id(_dst_sub))
|
|
_peerid = get_info(int_id(_peerid))
|
|
_src_sub = get_info(int_id(_src_sub))
|
|
if not _end: self.ACTIVE_CALLS.append(_ts)
|
|
if _end: self.ACTIVE_CALLS.remove(_ts)
|
|
|
|
if _ts: _ts = 2
|
|
else: _ts = 1
|
|
if _end: _end = 'END'
|
|
else: _end = 'START'
|
|
|
|
print('{} ({}) Call {} Group Voice: \n\tIPSC Source:\t{}\n\tSubscriber:\t{}\n\tDestination:\t{}\n\tTimeslot\t{}' .format(_time, _network, _end, _peerid, _src_sub, _dst_sub, _ts))
|
|
|
|
def private_voice(self, _network, _src_sub, _dst_sub, _ts, _end, _peerid, _data):
|
|
# _log = logger.debug
|
|
if (_ts not in self.ACTIVE_CALLS) or _end:
|
|
_time = time.strftime('%m/%d/%y %H:%M:%S')
|
|
_dst_sub = get_info(int_id(_dst_sub))
|
|
_peerid = get_info(int_id(_peerid))
|
|
_src_sub = get_info(int_id(_src_sub))
|
|
if not _end: self.ACTIVE_CALLS.append(_ts)
|
|
if _end: self.ACTIVE_CALLS.remove(_ts)
|
|
|
|
if _ts: _ts = 2
|
|
else: _ts = 1
|
|
if _end: _end = 'END'
|
|
else: _end = 'START'
|
|
|
|
print('{} ({}) Call {} Private Voice: \n\tIPSC Source:\t{}\n\tSubscriber:\t{}\n\tDestination:\t{}\n\tTimeslot\t{}' .format(_time, _network, _end, _peerid, _src_sub, _dst_sub, _ts))
|
|
|
|
def group_data(self, _network, _src_sub, _dst_sub, _ts, _end, _peerid, _data):
|
|
_dst_sub = get_info(int_id(_dst_sub))
|
|
_peerid = get_info(int_id(_peerid))
|
|
_src_sub = get_info(int_id(_src_sub))
|
|
print('({}) Group Data Packet Received From: {}' .format(_network, _src_sub))
|
|
|
|
def private_data(self, _network, _src_sub, _dst_sub, _ts, _end, _peerid, _data):
|
|
_dst_sub = get_info(int_id(_dst_sub))
|
|
_peerid = get_info(int_id(_peerid))
|
|
_src_sub = get_info(int_id(_src_sub))
|
|
print('({}) Private Data Packet Received From: {} To: {}' .format(_network, _src_sub, _dst_sub))
|
|
|
|
|
|
for ipsc_network in NETWORK:
|
|
if (NETWORK[ipsc_network]['LOCAL']['ENABLED']):
|
|
if NETWORK[ipsc_network]['LOCAL']['AUTH_ENABLED'] == True:
|
|
networks[ipsc_network] = logIPSC(ipsc_network)
|
|
else:
|
|
networks[ipsc_network] = UnauthIPSC(ipsc_network)
|
|
reactor.listenUDP(NETWORK[ipsc_network]['LOCAL']['PORT'], networks[ipsc_network])
|
|
reactor.run() |