2022-04-01 15:18:18 +00:00
# MIT License
#
# Copyright (c) 2016-2022 Mark Qvist / unsigned.io
#
# Permission is hereby granted, free of charge, to any person obtaining a copy
# of this software and associated documentation files (the "Software"), to deal
# in the Software without restriction, including without limitation the rights
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
# copies of the Software, and to permit persons to whom the Software is
# furnished to do so, subject to the following conditions:
#
# The above copyright notice and this permission notice shall be included in all
# copies or substantial portions of the Software.
#
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
# SOFTWARE.
2020-05-11 14:09:00 +00:00
from . Interface import Interface
import socketserver
import threading
2021-09-23 14:07:57 +00:00
import platform
2020-05-11 14:09:00 +00:00
import socket
import time
import sys
import os
import RNS
class HDLC ( ) :
FLAG = 0x7E
ESC = 0x7D
ESC_MASK = 0x20
@staticmethod
def escape ( data ) :
data = data . replace ( bytes ( [ HDLC . ESC ] ) , bytes ( [ HDLC . ESC , HDLC . ESC ^ HDLC . ESC_MASK ] ) )
data = data . replace ( bytes ( [ HDLC . FLAG ] ) , bytes ( [ HDLC . ESC , HDLC . FLAG ^ HDLC . ESC_MASK ] ) )
return data
2021-12-06 12:07:12 +00:00
class KISS ( ) :
FEND = 0xC0
FESC = 0xDB
TFEND = 0xDC
TFESC = 0xDD
CMD_DATA = 0x00
CMD_UNKNOWN = 0xFE
@staticmethod
def escape ( data ) :
data = data . replace ( bytes ( [ 0xdb ] ) , bytes ( [ 0xdb , 0xdd ] ) )
data = data . replace ( bytes ( [ 0xc0 ] ) , bytes ( [ 0xdb , 0xdc ] ) )
return data
2020-05-11 14:09:00 +00:00
class ThreadingTCPServer ( socketserver . ThreadingMixIn , socketserver . TCPServer ) :
pass
class TCPClientInterface ( Interface ) :
2022-04-18 16:09:31 +00:00
BITRATE_GUESS = 10 * 1000 * 1000
2021-09-18 20:49:04 +00:00
RECONNECT_WAIT = 5
RECONNECT_MAX_TRIES = None
2020-05-11 14:09:00 +00:00
2021-09-23 14:07:57 +00:00
# TCP socket options
2022-06-12 09:50:09 +00:00
TCP_USER_TIMEOUT = 24
2021-09-23 14:07:57 +00:00
TCP_PROBE_AFTER = 5
2022-06-12 09:50:09 +00:00
TCP_PROBE_INTERVAL = 2
TCP_PROBES = 12
2021-09-23 14:07:57 +00:00
2022-09-15 13:35:28 +00:00
INITIAL_CONNECT_TIMEOUT = 5
SYNCHRONOUS_START = True
2022-06-12 09:50:09 +00:00
I2P_USER_TIMEOUT = 45
2022-01-31 22:31:29 +00:00
I2P_PROBE_AFTER = 10
2022-06-12 09:50:09 +00:00
I2P_PROBE_INTERVAL = 9
I2P_PROBES = 5
2022-01-31 22:31:29 +00:00
2022-09-15 13:35:28 +00:00
def __init__ ( self , owner , name , target_ip = None , target_port = None , connected_socket = None , max_reconnect_tries = None , kiss_framing = False , i2p_tunneled = False , connect_timeout = None ) :
2021-09-24 18:10:04 +00:00
self . rxb = 0
self . txb = 0
2022-05-29 13:43:50 +00:00
self . HW_MTU = 1064
2020-05-13 11:08:48 +00:00
self . IN = True
self . OUT = False
self . socket = None
2020-05-11 14:09:00 +00:00
self . parent_interface = None
2020-05-13 11:08:48 +00:00
self . name = name
2021-09-18 20:49:04 +00:00
self . initiator = False
2021-09-23 14:07:57 +00:00
self . reconnecting = False
self . never_connected = True
2021-09-24 09:20:10 +00:00
self . owner = owner
self . writing = False
self . online = False
2021-09-24 14:42:31 +00:00
self . detached = False
2021-12-06 12:07:12 +00:00
self . kiss_framing = kiss_framing
2022-01-31 22:31:29 +00:00
self . i2p_tunneled = i2p_tunneled
2022-02-25 21:10:55 +00:00
self . mode = RNS . Interfaces . Interface . Interface . MODE_FULL
2022-04-18 16:09:31 +00:00
self . bitrate = TCPClientInterface . BITRATE_GUESS
2022-02-25 21:10:55 +00:00
2021-09-18 20:49:04 +00:00
if max_reconnect_tries == None :
self . max_reconnect_tries = TCPClientInterface . RECONNECT_MAX_TRIES
else :
self . max_reconnect_tries = max_reconnect_tries
2020-05-11 19:52:20 +00:00
2020-05-11 14:09:00 +00:00
if connected_socket != None :
2020-05-13 11:08:48 +00:00
self . receives = True
self . target_ip = None
2020-05-11 14:09:00 +00:00
self . target_port = None
2020-05-13 11:08:48 +00:00
self . socket = connected_socket
2020-05-11 14:09:00 +00:00
2021-09-23 14:07:57 +00:00
if platform . system ( ) == " Linux " :
self . set_timeouts_linux ( )
elif platform . system ( ) == " Darwin " :
self . set_timeouts_osx ( )
2020-05-11 14:09:00 +00:00
elif target_ip != None and target_port != None :
2020-05-13 11:08:48 +00:00
self . receives = True
self . target_ip = target_ip
2020-05-11 14:09:00 +00:00
self . target_port = target_port
2021-09-24 09:20:10 +00:00
self . initiator = True
2022-09-15 13:35:28 +00:00
if connect_timeout != None :
self . connect_timeout = connect_timeout
else :
self . connect_timeout = TCPClientInterface . INITIAL_CONNECT_TIMEOUT
2021-09-24 09:20:10 +00:00
2022-09-15 13:35:28 +00:00
if TCPClientInterface . SYNCHRONOUS_START :
self . initial_connect ( )
2021-09-24 09:20:10 +00:00
else :
2022-09-15 13:35:28 +00:00
thread = threading . Thread ( target = self . initial_connect )
2022-09-30 17:02:25 +00:00
thread . daemon = True
2021-09-24 09:20:10 +00:00
thread . start ( )
2022-09-15 13:35:28 +00:00
def initial_connect ( self ) :
if not self . connect ( initial = True ) :
thread = threading . Thread ( target = self . reconnect )
2022-09-30 17:02:25 +00:00
thread . daemon = True
2022-09-15 13:35:28 +00:00
thread . start ( )
else :
thread = threading . Thread ( target = self . read_loop )
2022-09-30 17:02:25 +00:00
thread . daemon = True
2022-09-15 13:35:28 +00:00
thread . start ( )
if not self . kiss_framing :
self . wants_tunnel = True
2020-05-11 14:09:00 +00:00
2021-09-23 14:07:57 +00:00
def set_timeouts_linux ( self ) :
2022-01-31 22:31:29 +00:00
if not self . i2p_tunneled :
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_USER_TIMEOUT , int ( TCPClientInterface . TCP_USER_TIMEOUT * 1000 ) )
self . socket . setsockopt ( socket . SOL_SOCKET , socket . SO_KEEPALIVE , 1 )
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_KEEPIDLE , int ( TCPClientInterface . TCP_PROBE_AFTER ) )
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_KEEPINTVL , int ( TCPClientInterface . TCP_PROBE_INTERVAL ) )
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_KEEPCNT , int ( TCPClientInterface . TCP_PROBES ) )
2022-06-12 09:50:09 +00:00
2022-01-31 22:31:29 +00:00
else :
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_USER_TIMEOUT , int ( TCPClientInterface . I2P_USER_TIMEOUT * 1000 ) )
self . socket . setsockopt ( socket . SOL_SOCKET , socket . SO_KEEPALIVE , 1 )
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_KEEPIDLE , int ( TCPClientInterface . I2P_PROBE_AFTER ) )
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_KEEPINTVL , int ( TCPClientInterface . I2P_PROBE_INTERVAL ) )
self . socket . setsockopt ( socket . IPPROTO_TCP , socket . TCP_KEEPCNT , int ( TCPClientInterface . I2P_PROBES ) )
2021-09-23 14:07:57 +00:00
def set_timeouts_osx ( self ) :
if hasattr ( socket , " TCP_KEEPALIVE " ) :
TCP_KEEPIDLE = socket . TCP_KEEPALIVE
else :
TCP_KEEPIDLE = 0x10
2022-01-21 01:34:55 +00:00
self . socket . setsockopt ( socket . SOL_SOCKET , socket . SO_KEEPALIVE , 1 )
2022-01-31 22:31:29 +00:00
if not self . i2p_tunneled :
self . socket . setsockopt ( socket . IPPROTO_TCP , TCP_KEEPIDLE , int ( TCPClientInterface . TCP_PROBE_AFTER ) )
else :
self . socket . setsockopt ( socket . IPPROTO_TCP , TCP_KEEPIDLE , int ( TCPClientInterface . I2P_PROBE_AFTER ) )
2021-09-24 14:09:07 +00:00
def detach ( self ) :
if self . socket != None :
if hasattr ( self . socket , " close " ) :
if callable ( self . socket . close ) :
RNS . log ( " Detaching " + str ( self ) , RNS . LOG_DEBUG )
2021-09-24 14:42:31 +00:00
self . detached = True
try :
self . socket . shutdown ( socket . SHUT_RDWR )
except Exception as e :
RNS . log ( " Error while shutting down socket for " + str ( self ) + " : " + str ( e ) )
try :
self . socket . close ( )
except Exception as e :
RNS . log ( " Error while closing socket for " + str ( self ) + " : " + str ( e ) )
2021-09-24 14:09:07 +00:00
self . socket = None
2021-09-24 09:20:10 +00:00
def connect ( self , initial = False ) :
try :
2022-09-15 13:35:28 +00:00
if initial :
RNS . log ( " Establishing TCP connection for " + str ( self ) + " ... " , RNS . LOG_DEBUG )
2021-09-24 09:20:10 +00:00
self . socket = socket . socket ( socket . AF_INET , socket . SOCK_STREAM )
2022-09-15 13:35:28 +00:00
self . socket . settimeout ( TCPClientInterface . INITIAL_CONNECT_TIMEOUT )
2021-09-24 09:20:10 +00:00
self . socket . connect ( ( self . target_ip , self . target_port ) )
2022-09-15 13:35:28 +00:00
self . socket . settimeout ( None )
2021-09-24 09:20:10 +00:00
self . online = True
2022-09-15 13:35:28 +00:00
if initial :
RNS . log ( " TCP connection for " + str ( self ) + " established " , RNS . LOG_DEBUG )
2021-09-24 09:20:10 +00:00
except Exception as e :
if initial :
RNS . log ( " Initial connection for " + str ( self ) + " could not be established: " + str ( e ) , RNS . LOG_ERROR )
RNS . log ( " Leaving unconnected and retrying connection in " + str ( TCPClientInterface . RECONNECT_WAIT ) + " seconds. " , RNS . LOG_ERROR )
return False
else :
raise e
2021-09-23 14:07:57 +00:00
if platform . system ( ) == " Linux " :
self . set_timeouts_linux ( )
elif platform . system ( ) == " Darwin " :
self . set_timeouts_osx ( )
self . online = True
self . writing = False
self . never_connected = False
2021-09-24 09:20:10 +00:00
return True
2021-09-23 14:07:57 +00:00
2021-09-18 20:49:04 +00:00
def reconnect ( self ) :
if self . initiator :
2021-09-23 14:07:57 +00:00
if not self . reconnecting :
self . reconnecting = True
attempts = 0
while not self . online :
time . sleep ( TCPClientInterface . RECONNECT_WAIT )
attempts + = 1
2021-09-18 20:49:04 +00:00
2021-09-23 14:07:57 +00:00
if self . max_reconnect_tries != None and attempts > self . max_reconnect_tries :
RNS . log ( " Max reconnection attempts reached for " + str ( self ) , RNS . LOG_ERROR )
self . teardown ( )
break
2021-09-18 20:49:04 +00:00
2021-09-23 14:07:57 +00:00
try :
self . connect ( )
2021-09-18 20:49:04 +00:00
2021-09-23 14:07:57 +00:00
except Exception as e :
RNS . log ( " Connection attempt for " + str ( self ) + " failed: " + str ( e ) , RNS . LOG_DEBUG )
2021-09-18 20:49:04 +00:00
2021-09-23 14:07:57 +00:00
if not self . never_connected :
2022-06-12 16:55:06 +00:00
RNS . log ( " Reconnected socket for " + str ( self ) + " . " , RNS . LOG_INFO )
2021-09-18 20:49:04 +00:00
2021-09-23 14:07:57 +00:00
self . reconnecting = False
thread = threading . Thread ( target = self . read_loop )
2022-09-30 17:02:25 +00:00
thread . daemon = True
2021-09-23 14:07:57 +00:00
thread . start ( )
2021-12-06 12:07:12 +00:00
if not self . kiss_framing :
RNS . Transport . synthesize_tunnel ( self )
2021-09-18 20:49:04 +00:00
else :
RNS . log ( " Attempt to reconnect on a non-initiator TCP interface. This should not happen. " , RNS . LOG_ERROR )
raise IOError ( " Attempt to reconnect on a non-initiator TCP interface " )
2020-05-11 14:09:00 +00:00
def processIncoming ( self , data ) :
2021-09-24 18:10:04 +00:00
self . rxb + = len ( data )
if hasattr ( self , " parent_interface " ) and self . parent_interface != None :
self . parent_interface . rxb + = len ( data )
2020-05-11 14:09:00 +00:00
self . owner . inbound ( data , self )
def processOutgoing ( self , data ) :
if self . online :
2022-06-09 15:14:43 +00:00
# while self.writing:
# time.sleep(0.01)
2020-05-13 11:08:48 +00:00
2020-05-11 14:09:00 +00:00
try :
2020-05-13 11:08:48 +00:00
self . writing = True
2021-12-06 12:07:12 +00:00
if self . kiss_framing :
data = bytes ( [ KISS . FEND ] ) + bytes ( [ KISS . CMD_DATA ] ) + KISS . escape ( data ) + bytes ( [ KISS . FEND ] )
else :
data = bytes ( [ HDLC . FLAG ] ) + HDLC . escape ( data ) + bytes ( [ HDLC . FLAG ] )
2020-05-11 14:09:00 +00:00
self . socket . sendall ( data )
2020-05-13 11:08:48 +00:00
self . writing = False
2021-09-24 18:10:04 +00:00
self . txb + = len ( data )
if hasattr ( self , " parent_interface " ) and self . parent_interface != None :
self . parent_interface . txb + = len ( data )
2020-05-11 14:09:00 +00:00
except Exception as e :
RNS . log ( " Exception occurred while transmitting via " + str ( self ) + " , tearing down interface " , RNS . LOG_ERROR )
RNS . log ( " The contained exception was: " + str ( e ) , RNS . LOG_ERROR )
self . teardown ( )
def read_loop ( self ) :
try :
in_frame = False
escape = False
data_buffer = b " "
2021-12-06 12:07:12 +00:00
command = KISS . CMD_UNKNOWN
2020-05-11 14:09:00 +00:00
while True :
2020-05-13 11:08:48 +00:00
data_in = self . socket . recv ( 4096 )
2020-05-11 14:09:00 +00:00
if len ( data_in ) > 0 :
2020-05-12 06:50:51 +00:00
pointer = 0
while pointer < len ( data_in ) :
byte = data_in [ pointer ]
pointer + = 1
2021-12-06 12:07:12 +00:00
if self . kiss_framing :
# Read loop for KISS framing
if ( in_frame and byte == KISS . FEND and command == KISS . CMD_DATA ) :
in_frame = False
self . processIncoming ( data_buffer )
elif ( byte == KISS . FEND ) :
in_frame = True
command = KISS . CMD_UNKNOWN
data_buffer = b " "
2022-05-29 13:43:50 +00:00
elif ( in_frame and len ( data_buffer ) < self . HW_MTU ) :
2021-12-06 12:07:12 +00:00
if ( len ( data_buffer ) == 0 and command == KISS . CMD_UNKNOWN ) :
# We only support one HDLC port for now, so
# strip off the port nibble
byte = byte & 0x0F
command = byte
elif ( command == KISS . CMD_DATA ) :
if ( byte == KISS . FESC ) :
escape = True
else :
if ( escape ) :
if ( byte == KISS . TFEND ) :
byte = KISS . FEND
if ( byte == KISS . TFESC ) :
byte = KISS . FESC
escape = False
data_buffer = data_buffer + bytes ( [ byte ] )
else :
# Read loop for HDLC framing
if ( in_frame and byte == HDLC . FLAG ) :
in_frame = False
self . processIncoming ( data_buffer )
elif ( byte == HDLC . FLAG ) :
in_frame = True
data_buffer = b " "
2022-05-29 13:43:50 +00:00
elif ( in_frame and len ( data_buffer ) < self . HW_MTU ) :
2021-12-06 12:07:12 +00:00
if ( byte == HDLC . ESC ) :
escape = True
else :
if ( escape ) :
if ( byte == HDLC . FLAG ^ HDLC . ESC_MASK ) :
byte = HDLC . FLAG
if ( byte == HDLC . ESC ^ HDLC . ESC_MASK ) :
byte = HDLC . ESC
escape = False
data_buffer = data_buffer + bytes ( [ byte ] )
2020-05-11 14:09:00 +00:00
else :
2021-09-18 20:49:04 +00:00
self . online = False
2021-09-24 14:42:31 +00:00
if self . initiator and not self . detached :
2022-06-12 16:55:06 +00:00
RNS . log ( " The socket for " + str ( self ) + " was closed, attempting to reconnect... " , RNS . LOG_WARNING )
2021-09-18 20:49:04 +00:00
self . reconnect ( )
2021-09-23 14:07:57 +00:00
else :
2022-06-12 16:55:06 +00:00
RNS . log ( " The socket for remote client " + str ( self ) + " was closed. " , RNS . LOG_VERBOSE )
2021-09-23 14:07:57 +00:00
self . teardown ( )
2021-09-18 20:49:04 +00:00
2020-05-11 14:09:00 +00:00
break
except Exception as e :
self . online = False
2021-09-23 14:07:57 +00:00
RNS . log ( " An interface error occurred for " + str ( self ) + " , the contained exception was: " + str ( e ) , RNS . LOG_WARNING )
if self . initiator :
RNS . log ( " Attempting to reconnect... " , RNS . LOG_WARNING )
self . reconnect ( )
else :
self . teardown ( )
2020-05-11 14:09:00 +00:00
def teardown ( self ) :
2021-09-24 18:10:04 +00:00
if self . initiator and not self . detached :
2021-09-23 14:07:57 +00:00
RNS . log ( " The interface " + str ( self ) + " experienced an unrecoverable error and is being torn down. Restart Reticulum to attempt to open this interface again. " , RNS . LOG_ERROR )
if RNS . Reticulum . panic_on_interface_error :
RNS . panic ( )
else :
RNS . log ( " The interface " + str ( self ) + " is being torn down. " , RNS . LOG_VERBOSE )
2020-05-11 14:09:00 +00:00
self . online = False
self . OUT = False
self . IN = False
2021-09-23 14:07:57 +00:00
2021-09-24 18:10:04 +00:00
if hasattr ( self , " parent_interface " ) and self . parent_interface != None :
self . parent_interface . clients - = 1
2020-05-12 14:45:51 +00:00
if self in RNS . Transport . interfaces :
2021-10-08 15:06:00 +00:00
if not self . initiator :
RNS . Transport . interfaces . remove ( self )
2020-05-11 14:09:00 +00:00
def __str__ ( self ) :
return " TCPInterface[ " + str ( self . name ) + " / " + str ( self . target_ip ) + " : " + str ( self . target_port ) + " ] "
class TCPServerInterface ( Interface ) :
2022-04-18 16:09:31 +00:00
BITRATE_GUESS = 10 * 1000 * 1000
2021-08-19 18:13:53 +00:00
@staticmethod
def get_address_for_if ( name ) :
2021-12-01 10:39:40 +00:00
import importlib
2021-12-01 10:46:19 +00:00
if importlib . util . find_spec ( ' netifaces ' ) != None :
2021-12-01 10:39:40 +00:00
import netifaces
return netifaces . ifaddresses ( name ) [ netifaces . AF_INET ] [ 0 ] [ ' addr ' ]
else :
RNS . log ( " Getting interface addresses from device names requires the netifaces module. " , RNS . LOG_CRITICAL )
RNS . log ( " You can install it with the command: python3 -m pip install netifaces " , RNS . LOG_CRITICAL )
RNS . panic ( )
2021-08-19 18:13:53 +00:00
2021-12-01 10:39:40 +00:00
@staticmethod
2021-08-19 18:13:53 +00:00
def get_broadcast_for_if ( name ) :
2021-12-01 10:39:40 +00:00
import importlib
2021-12-01 10:46:19 +00:00
if importlib . util . find_spec ( ' netifaces ' ) != None :
2021-12-01 10:39:40 +00:00
import netifaces
return netifaces . ifaddresses ( name ) [ netifaces . AF_INET ] [ 0 ] [ ' broadcast ' ]
else :
RNS . log ( " Getting interface addresses from device names requires the netifaces module. " , RNS . LOG_CRITICAL )
RNS . log ( " You can install it with the command: python3 -m pip install netifaces " , RNS . LOG_CRITICAL )
RNS . panic ( )
2020-05-11 14:09:00 +00:00
2022-01-31 22:31:29 +00:00
def __init__ ( self , owner , name , device = None , bindip = None , bindport = None , i2p_tunneled = False ) :
2021-09-24 18:10:04 +00:00
self . rxb = 0
self . txb = 0
2022-05-29 13:43:50 +00:00
self . HW_MTU = 1064
2021-09-24 18:10:04 +00:00
self . online = False
self . clients = 0
2020-05-11 14:09:00 +00:00
self . IN = True
self . OUT = False
self . name = name
2022-09-06 10:23:52 +00:00
self . detached = False
2020-05-11 14:09:00 +00:00
2022-01-31 22:31:29 +00:00
self . i2p_tunneled = i2p_tunneled
2022-02-25 21:10:55 +00:00
self . mode = RNS . Interfaces . Interface . Interface . MODE_FULL
2022-01-31 22:31:29 +00:00
2021-08-19 18:13:53 +00:00
if device != None :
bindip = TCPServerInterface . get_address_for_if ( device )
2020-05-11 14:09:00 +00:00
if ( bindip != None and bindport != None ) :
self . receives = True
self . bind_ip = bindip
self . bind_port = bindport
def handlerFactory ( callback ) :
def createHandler ( * args , * * keys ) :
return TCPInterfaceHandler ( callback , * args , * * keys )
return createHandler
self . owner = owner
address = ( self . bind_ip , self . bind_port )
2021-09-24 14:42:31 +00:00
2021-09-24 14:09:07 +00:00
ThreadingTCPServer . allow_reuse_address = True
2020-05-11 14:09:00 +00:00
self . server = ThreadingTCPServer ( address , handlerFactory ( self . incoming_connection ) )
2022-04-18 16:09:31 +00:00
self . bitrate = TCPServerInterface . BITRATE_GUESS
2020-05-11 14:09:00 +00:00
thread = threading . Thread ( target = self . server . serve_forever )
2022-09-30 17:02:25 +00:00
thread . daemon = True
2020-05-11 14:09:00 +00:00
thread . start ( )
2021-09-24 18:10:04 +00:00
self . online = True
2020-05-11 14:09:00 +00:00
def incoming_connection ( self , handler ) :
RNS . log ( " Accepting incoming TCP connection " , RNS . LOG_VERBOSE )
interface_name = " Client on " + self . name
2022-01-31 22:31:29 +00:00
spawned_interface = TCPClientInterface ( self . owner , interface_name , target_ip = None , target_port = None , connected_socket = handler . request , i2p_tunneled = self . i2p_tunneled )
2020-05-11 14:09:00 +00:00
spawned_interface . OUT = self . OUT
spawned_interface . IN = self . IN
spawned_interface . target_ip = handler . client_address [ 0 ]
spawned_interface . target_port = str ( handler . client_address [ 1 ] )
spawned_interface . parent_interface = self
2022-04-18 16:09:31 +00:00
spawned_interface . bitrate = self . bitrate
2022-11-03 13:16:00 +00:00
2022-04-27 11:20:46 +00:00
spawned_interface . ifac_size = self . ifac_size
spawned_interface . ifac_netname = self . ifac_netname
spawned_interface . ifac_netkey = self . ifac_netkey
2022-11-03 13:16:00 +00:00
if spawned_interface . ifac_netname != None or spawned_interface . ifac_netkey != None :
ifac_origin = b " "
if spawned_interface . ifac_netname != None :
ifac_origin + = RNS . Identity . full_hash ( spawned_interface . ifac_netname . encode ( " utf-8 " ) )
if spawned_interface . ifac_netkey != None :
ifac_origin + = RNS . Identity . full_hash ( spawned_interface . ifac_netkey . encode ( " utf-8 " ) )
ifac_origin_hash = RNS . Identity . full_hash ( ifac_origin )
spawned_interface . ifac_key = RNS . Cryptography . hkdf (
length = 64 ,
derive_from = ifac_origin_hash ,
salt = RNS . Reticulum . IFAC_SALT ,
context = None
)
spawned_interface . ifac_identity = RNS . Identity . from_bytes ( spawned_interface . ifac_key )
spawned_interface . ifac_signature = spawned_interface . ifac_identity . sign ( RNS . Identity . full_hash ( spawned_interface . ifac_key ) )
2022-05-14 16:09:38 +00:00
spawned_interface . announce_rate_target = self . announce_rate_target
spawned_interface . announce_rate_grace = self . announce_rate_grace
spawned_interface . announce_rate_penalty = self . announce_rate_penalty
2022-05-22 22:06:26 +00:00
spawned_interface . mode = self . mode
2022-05-29 13:43:50 +00:00
spawned_interface . HW_MTU = self . HW_MTU
2021-09-24 12:11:04 +00:00
spawned_interface . online = True
2020-05-11 14:09:00 +00:00
RNS . log ( " Spawned new TCPClient Interface: " + str ( spawned_interface ) , RNS . LOG_VERBOSE )
RNS . Transport . interfaces . append ( spawned_interface )
2021-09-24 18:10:04 +00:00
self . clients + = 1
2020-05-11 14:09:00 +00:00
spawned_interface . read_loop ( )
def processOutgoing ( self , data ) :
pass
2022-09-06 10:23:52 +00:00
def detach ( self ) :
if self . server != None :
if hasattr ( self . server , " shutdown " ) :
if callable ( self . server . shutdown ) :
try :
RNS . log ( " Detaching " + str ( self ) , RNS . LOG_DEBUG )
self . server . shutdown ( )
self . detached = True
self . server = None
except Exception as e :
RNS . log ( " Error while shutting down server for " + str ( self ) + " : " + str ( e ) )
2020-05-11 14:09:00 +00:00
def __str__ ( self ) :
return " TCPServerInterface[ " + self . name + " / " + self . bind_ip + " : " + str ( self . bind_port ) + " ] "
2022-09-06 15:42:13 +00:00
2020-05-11 14:09:00 +00:00
class TCPInterfaceHandler ( socketserver . BaseRequestHandler ) :
def __init__ ( self , callback , * args , * * keys ) :
self . callback = callback
socketserver . BaseRequestHandler . __init__ ( self , * args , * * keys )
def handle ( self ) :
2022-01-21 01:34:55 +00:00
self . callback ( handler = self )