from threading import Thread
from socket import *
from zlib import compress as c,decompress as d
from pickle import loads,dumps
from sys import argv

send_host = "192.168.1.9"
srvc_host = ""

send_port = int(argv[2])  
srvc_port = int(argv[1]) 


send_skt = socket(AF_INET,SOCK_STREAM) #the other machine were we connect to (server)
srvc_skt = socket(AF_INET,SOCK_STREAM) #data that is supposed to go to server arrives here

srvc_skt.bind((srvc_host,srvc_port))
srvc_skt.listen(10)
srvc_skt,addr=srvc_skt.accept()  #wait for someone to connect

send_skt.connect((send_host,send_port)) #someone is connected(accept() returend) so connect to server

class c_buff:   #buffer
	data=None
sdata_container=c_buff()
rdata_container=c_buff()

def send(send_skt,srvc_skt):  #send data to server as soon as it arives
	global sdata_container
	while True:
		try:
			sdata_container.data=srvc_skt.recv(512)  #get data
			send_data=c(dumps(sdata_container))  #pickle and then compress it
			send_skt.send(send_data)  #send it
			print('send') #log it
		except:
			pass 

def recv(send_skt,srvc_skt):
	global rdata_container
	while True:
		try:
			rdata_container=loads(d(send_skt.recv(512))) #got data from server? so unpickle and decompress it
			recv_data=rdata_container.data #extract data
			srvc_skt.send(recv_data) #send it to whoever asked for it
			print('recv') #log it
		except:
			pass


threads = []
threads.append(Thread(target=send,args=(send_skt,srvc_skt)))
threads.append(Thread(target=recv,args=(send_skt,srvc_skt)))
threads[0].start()
threads[1].start()

from threading import Thread
from socket import *
from zlib import compress as c,decompress as d
from pickle import dumps,loads
from sys import argv

send_host = ""
send_port = int(argv[1])  #send port (to client)
srvc_host = ""
srvc_port = int(argv[2])  #ssh port

send_skt = socket(AF_INET,SOCK_STREAM)
srvc_skt = socket(AF_INET,SOCK_STREAM)

send_skt.bind((send_host,send_port))
send_skt.listen(10)
send_skt,addr=send_skt.accept() #wait for someone to connect

srvc_skt.connect((srvc_host,srvc_port)) #someone connected so connect to ssh

class c_buff: #buffer
	data=None
sdata_container=c_buff()
rdata_container=c_buff()

def send(send_skt,srvc_skt):
	global sdata_container
	while True:
		try:
			sdata_container.data=srvc_skt.recv(512) #get data from ssh
			send_data=c(dumps(sdata_container)) #pickle and compress it
			send_skt.send(send_data) # send it to client
			print('send') #log it
		except:
			pass

def recv(send_skt,srvc_skt):
	global rdata_container
	while True:
		try:
			rdata_container=loads(d(send_skt.recv(512))) #get data from client,decompress and unpickle it
			recv_data=rdata_container.data #extract data
			srvc_skt.send(recv_data)  #send to ssh daemon
			print('recv')#log it
		except:
			pass



threads = []
threads.append(Thread(target=send,args=(send_skt,srvc_skt)))
threads.append(Thread(target=recv,args=(send_skt,srvc_skt)))
threads[0].start() #star reciving data
threads[1].start() #start sending data

def send(send_skt):
    string = "a"
    while True:
        send_skt.send(string.encode('utf8'))
        print('Sent',string)
        string += chr((ord(string[-1])-96)%26+97) #just puts the next letter of the alphabet on
        time.sleep(1)