sdfsddgs

#!/usr/bin/env python
import sys
import socket
from threading import Thread


vpn = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_2 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_3 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_4 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_5 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_6 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_7 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_8 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
vpn_9 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

global TCP_IP_APACHE
global TCP_PORT_APACHE
global vpn_conns
vpn_conns = []
TCP_IP = '192.168.216.130'
TCP_IP_APACHE = '127.0.0.1'
TCP_PORT_VPN = 6666
TCP_PORT_VPN_1 = TCP_PORT_VPN + 1
TCP_PORT_VPN_2 = TCP_PORT_VPN + 2
TCP_PORT_VPN_3 = TCP_PORT_VPN + 3
TCP_PORT_VPN_4 = TCP_PORT_VPN + 4
TCP_PORT_VPN_5 = TCP_PORT_VPN + 5
TCP_PORT_VPN_6 = TCP_PORT_VPN + 6
TCP_PORT_VPN_7 = TCP_PORT_VPN + 7
TCP_PORT_VPN_8 = TCP_PORT_VPN + 8
TCP_PORT_VPN_9 = TCP_PORT_VPN + 9
TCP_PORT_APACHE = 443
BUFFER_SIZE = 131072
client_token = "gd358gd65gd36gf583d87gdf53"



vpn.connect((TCP_IP, TCP_PORT_VPN))
vpn_1.connect((TCP_IP, TCP_PORT_VPN_1))
vpn_2.connect((TCP_IP, TCP_PORT_VPN_2))
vpn_3.connect((TCP_IP, TCP_PORT_VPN_3))
vpn_4.connect((TCP_IP, TCP_PORT_VPN_4))
vpn_5.connect((TCP_IP, TCP_PORT_VPN_5))
vpn_6.connect((TCP_IP, TCP_PORT_VPN_6))
vpn_7.connect((TCP_IP, TCP_PORT_VPN_7))
vpn_8.connect((TCP_IP, TCP_PORT_VPN_8))
vpn_9.connect((TCP_IP, TCP_PORT_VPN_9))

vpn_conns.append(vpn)
vpn_conns.append(vpn_1)
vpn_conns.append(vpn_2)
vpn_conns.append(vpn_3)
vpn_conns.append(vpn_4)
vpn_conns.append(vpn_5)
vpn_conns.append(vpn_6)
vpn_conns.append(vpn_7)
vpn_conns.append(vpn_8)
vpn_conns.append(vpn_9)

vpn.send(client_token.encode('UTF-8'))
if vpn.recv(BUFFER_SIZE).decode('UTF-8') == "nope":
	print("token refused !")
	sys.exit(0)
else:
	print("token accepted !")




def redirection(msg):

	apache1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
	apache1.connect((TCP_IP_APACHE, TCP_PORT_APACHE))
	apache1.send(msg)
	#msg2 = apache1.recv(BUFFER_SIZE)
	#vpn.send(msg2)
	while 1:
		msg2 = apache1.recv(BUFFER_SIZE)
		vpn.send(msg2)
	apache1.close()
	print("REDIRECTED")


def a_v(vpn_tmp, apache_tmp):
	while 1:
		msg = apache_tmp.recv(BUFFER_SIZE)
		vpn_tmp.send(msg)


def v_a(vpn_tmp, apache_tmp, data_first):
	apache_tmp.send(data_first)
	while 1:
		msg = vpn_tmp.recv(BUFFER_SIZE)
		apache_tmp.send(msg)


def vpn(number):
	data = vpn_conns[number].recv(BUFFER_SIZE)
	apache_1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
	apache_1.connect((TCP_IP_APACHE, TCP_PORT_APACHE))
	thread_av = Thread(target = a_v, args=(vpn_conns[number],apache_1,))
	thread_av.start()
	thread_va = Thread(target = v_a, args=(vpn_conns[number],apache_1,data,))
	thread_va.start()








thread_vpn_0 = Thread(target = vpn, args=(0,))
thread_vpn_0.start()
thread_vpn_1 = Thread(target = vpn, args=(1,))
thread_vpn_1.start()
thread_vpn_2 = Thread(target = vpn, args=(2,))
thread_vpn_2.start()
thread_vpn_3 = Thread(target = vpn, args=(3,))
thread_vpn_3.start()
thread_vpn_4 = Thread(target = vpn, args=(4,))
thread_vpn_4.start()
thread_vpn_5 = Thread(target = vpn, args=(5,))
thread_vpn_5.start()
thread_vpn_6 = Thread(target = vpn, args=(6,))
thread_vpn_6.start()
thread_vpn_7 = Thread(target = vpn, args=(7,))
thread_vpn_7.start()
thread_vpn_8 = Thread(target = vpn, args=(8,))
thread_vpn_8.start()
thread_vpn_9 = Thread(target = vpn, args=(9,))
thread_vpn_9.start()

input("press any key to stop")

		#apache.send(msg)



#thread_main = Thread(target = main)
#thread_main.start()
#thread_main.join()