update

webserver/malcom_in_the_middle.py

@@ -0,0 +1,62 @@
+import socket
+import threading
+import sys
+
+def server_loop(local_host, local_port, target_host, target_port):
+	server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	try:
+		server.bind((local_host, local_port))
+	except:
+		print "[!] Failed to connect to %s:%d" % (local_host, local_port)
+		sys.exit(0)
+
+	server.listen(5)
+	while True:
+		client_sock, addr = server.accept()
+		print "[===>] Recieving incoming connection from %s:%d" % (addr[0], addr[1])
+		proxy_thread = threading.Thread(target=proxy_handler, args=(client_sock, target_host, target_port))
+		proxy_thread.start()
+	client_sock.close()
+
+def proxy_handler(client_socket, target_host, target_port):
+	target_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	try:
+		target_server.bind((target_host, target_port))
+	except:
+		print "[!] Failed to connect to %s:%d" % (target_host, target_port)
+		sys.exit(0)
+
+	target_server.listen(5)
+	
+	while True:
+		target_socket, target_addr = target_server.accept()
+		target_socket.send("Type something")
+		target_buffer = target_socket.recv(1024)
+		print "[<===] Recieving data from %s:%d" % (target_host, target_port)
+		print(target_buffer)
+		return(target_buffer)
+		
+
+def forward(proxy_handler):
+	if len(proxy_handler):
+		print "Does that even work ? "
+		server.send(proxy_handler)
+	else:
+		sys.exit(0)
+
+def main():
+	if len(sys.argv[1:]) != 4:
+		print "Usage: python script.py 127.0.0.1 8888 127.0.0.1 9999"
+		sys.exit(0)
+
+	local_host = sys.argv[1]
+	local_port = int(sys.argv[2])
+
+	target_host = sys.argv[3]
+	target_port = int(sys.argv[4])
+
+	server_loop(local_host, local_port, target_host, target_port)
+	forward()
+
+if __name__ == '__main__':
+	main()

webserver/malcom_in_the_middle_2.py

@@ -0,0 +1,39 @@
+import socket
+
+def main():
+	if len(sys.argv[1:]) != 4:
+		print "Usage: python script.py 127.0.0.1 8888 127.0.0.1 9999"
+		sys.exit(0)
+
+	local_host = sys.argv[1]
+	local_port = int(sys.argv[2])
+
+	target_host = sys.argv[3]
+	target_port = int(sys.argv[4])
+
+	server_loop(local_host, local_port, target_host, target_port)
+	forward()
+
+
+first_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+first_server.bind(("", 5353))
+first_server.listen(5)
+first_client, first_addr = first_server.accept()
+print "First server up"
+
+second_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+second_server.bind(("", 9999))
+second_server.listen(5)
+second_client, second_addr = second_server.accept()
+print "Second server up"
+
+while True:
+	first_client.send("Write something \n")
+	data = first_client.recv(1024)
+	if not data :
+		break
+	second_client.send(data)
+	print "Forwarding data"
+
+first_client.close()
+second_client.close()

webserver/server_thread.py

@@ -2,7 +2,7 @@ import thread
 from socket import * 
 
 
-HOST, PORT = '', 8888
+HOST, PORT = '', 5353
 BUFF = 1024
 
 

webserver/simple_proxy_server.py

@@ -1,19 +1,18 @@
 import socket
 
 first_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-first_server.bind(("", 8888))
+first_server.bind(("80.67.181.208", 38330))
 first_server.listen(5)
 first_client, first_addr = first_server.accept()
 print "First server up"
 
 second_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-second_server.bind(("", 9999))
+second_server.bind(("127.0.0.1", 9999))
 second_server.listen(5)
 second_client, second_addr = second_server.accept()
 print "Second server up"
 
 while True:
-	first_client.send("Write something \n")
 	data = first_client.recv(1024)
 	if not data :
 		break