update

tcp_client.py

 import socket
+from scapy.all import *
+
 def client_program(op1):
-    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-    sock.connect(("192.168.88.128", 53530))
-    print(op1)
-    sock.send(op1)
-    response = b""
+    s = socket.socket(socket.AF_INET, socket.SOCK_RAW, socket.IPPROTO_TCP)
+    #s.setsockopt(socket.IPPROTO_IP, socket.IP_HDRINCL, 1)
+    packet=op1[34:]
+    print(packet.hex())
+    # #packet=packet.replace(b'\xd1\x1b',b'\xd1\x1a')
+    packet=bytes.fromhex(packet.hex().replace("d11b","d11a"))
+    # packet=IP(packet)
+    # del(packet[IP].chksum)
+    # del(packet[TCP].chksum)
+    # #packet.show2()
+    # packet=bytes(packet)
+    # print(packet)
+    # sport=Ether(bytes(op1))[TCP].sport
+    # s.bind(("192.168.88.128",sport))
+    #packet=bytes.fromhex("4500002c8aa700003206cbd3c0a85880c0a858808f25d11aed730e9c000000006002040005850000020405b4")
+    s.sendto(packet, ('192.168.88.128', 53530))
     while True:
-        chunk = sock.recv(4096)
-        if len(chunk) == 0:     # No more data received, quitting
-            break
-        response = response + chunk;
-    return response
-
+        data,address=s.recvfrom(65535)
+        # if(IP(data)[TCP].dport==sport):
+        #     print(IP(data).show())
 
 if __name__ == '__main__':
     client_program()
\ No newline at end of file

tcp_server.py

 import socket
 import udp_client
 from time import sleep
+import binascii
+from scapy.all import *
+
+def redirect(pkt):
+    rec_pkt=bytes(pkt)
+    #res=rec_pkt.replace(b'53531',bytes('53530'.encode('utf-8')))
+    print(pkt)
+    rec_data=udp_client.udp_client_program(rec_pkt)
 
 def server_program():
-    SERVER_HOST = '192.168.88.132'
-    SERVER_PORT = 53530
+    SERVER_HOST = '192.168.88.128'
+    SERVER_PORT = 53531
+    # server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    # server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    # server_socket.bind((SERVER_HOST, SERVER_PORT))
+    # server_socket.listen(100)
+    # print('Listening on port %s ...' % SERVER_PORT)
+
+    # while True:
+    #     # Wait for client connections
+    #     client_connection, client_address = server_socket.accept()
+    #     request = client_connection.recv(8192)
+    #     print(request)
+    #     res=request.replace(b'192.168.88.130:53531',bytes('192.168.88.130:53530'.encode('utf-8')))
+    #     rec_data=udp_client.udp_client_program(res)
+    #     #print(rec_data.hex())
+    #     client_connection.sendall(rec_data)
+    #     client_connection.close()
+    # server_socket.close()
+    #-----------------------------------------
+    # with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+    #     s.bind((SERVER_HOST, SERVER_PORT))
+    #     s.listen()
+    #     conn, addr = s.accept()
+    # with conn:
+    #     print(f"Connected by {addr}")
+    #     while True:
+    #             data = conn.recv(1024)
+    #             print(data)
+    #             res=data.replace(b'192.168.88.130:53531',bytes('192.168.88.130:53530'.encode('utf-8')))
+    #             print(res.hex())
+    #             rec_data=udp_client.udp_client_program(res)
+    #             if not data:
+    #                 break
+    #             conn.sendall(res)
     server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
     server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
     server_socket.bind((SERVER_HOST, SERVER_PORT))
-    server_socket.listen(100)
-    print('Listening on port %s ...' % SERVER_PORT)
-
-    while True:
-        # Wait for client connections
-        client_connection, client_address = server_socket.accept()
-        request = client_connection.recv(1024)
-        rec_data=udp_client.udp_client_program(request)
-        print(rec_data)
-        client_connection.sendall(rec_data)
-        client_connection.close()
-    server_socket.close()
+    sniff(filter='dst host 192.168.88.128 and dst port 53531',prn=redirect)
+
+
+
 
 
 if __name__ == '__main__':

test.py

+import socket
+from scapy.all import *
+s = socket.socket(socket.AF_INET, socket.SOCK_RAW, socket.IPPROTO_TCP)
+s.setsockopt(socket.IPPROTO_IP, socket.IP_HDRINCL, 1)
+packet=bytes.fromhex("4500002c8aa700003206cbd3c0a85880c0a858808f25d11aed730e9c000000006002040005850000020405b4")
+print(packet)
+packet=IP(packet)
+del(packet[IP].chksum)
+del(packet[TCP].chksum)
+print(packet.show())
+packet=bytes(packet)
+s.bind(("192.168.88.128",36645))
+s.sendto(packet, ('192.168.88.128', 53530))
+while True:
+    data,address=s.recvfrom(65535)
+    if(IP(data)[TCP].dport==36645):
+        print(IP(data).show())
\ No newline at end of file

udp_client.py

@@ -4,8 +4,7 @@ bufferSize          = 1024
 def udp_client_program(data):
     msgFromClient       = data
     bytesToSend         = msgFromClient
-    print(bytesToSend)
-    serverAddressPort   = ("127.0.0.1", 20001)
+    serverAddressPort   = ("192.168.88.128", 53532)
     # Create a UDP socket at client side
     UDPClientSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
     # Send to server using created UDP socket

udp_server.py

 import socket
 import tcp_client
 
-localIP     = "127.0.0.1"
-localPort   = 20001
-bufferSize  = 1024
+localIP     = "192.168.88.128"
+localPort   = 53532
+bufferSize  = 8192
 
 
 # Create a datagram socket
@@ -22,6 +22,7 @@ while(True):
     clientMsg = message
     clientIP  = "Client IP Address:{}".format(address)
     msgFromServer       = tcp_client.client_program(clientMsg)
+    print(msgFromServer)
     bytesToSend         = msgFromServer
     # Sending a reply to client
     UDPServerSocket.sendto(bytesToSend, address)
\ No newline at end of file