github/jumpserver
1
0
Fork 0
mirror of https://github.com/jumpserver/jumpserver.git synced 2025-06-27 23:37:08 +00:00
Code Issues Projects Releases Wiki Activity

finish example

Browse Source
This commit is contained in:
ibuler 2016-09-22 23:56:27 +08:00
parent f946a4bfb3
commit de0f8c24f7
1 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
server.py
View File

@ -116,22 +116,41 @@ class SSHServer:
if not service.event.is_set(): if not service.event.is_set():
print('*** Client never asked for a shell.') print('*** Client never asked for a shell.')
return return
server_data = []
input_mode = True
while True: while True:
r, w, e = select.select([server_chan, chan], [], []) r, w, e = select.select([server_chan, chan], [], [])
if chan in r: if chan in r:
recv_data = chan.recv(1024).decode('utf8') recv_data = chan.recv(1024).decode('utf8')
print("From client: " + repr(recv_data)) # print("From client: " + repr(recv_data))
if len(recv_data) == 0: if len(recv_data) == 0:
break break
server_chan.send(recv_data) server_chan.send(recv_data)
if server_chan in r: if server_chan in r:
recv_data = server_chan.recv(1024).decode('utf8') recv_data = server_chan.recv(1024).decode('utf8')
print("From server: " + repr(recv_data)) # print("From server: " + repr(recv_data))
if len(recv_data) == 0: if len(recv_data) == 0:
break break
chan.send(recv_data) chan.send(recv_data)
if len(recv_data) > 20:
server_data.append('...')
else:
server_data.append(recv_data)
try:
if repr(server_data[-2]) == u'\r\n':
result = server_data.pop()
server_data.pop()
command = ''.join(server_data)
server_data = []
print(">>> Command: %s" % command)
print(result)
except IndexError:
pass
print(server_data)
except Exception as e: except Exception as e:
print('*** Caught exception: ' + str(e.__class__) + ': ' + str(e)) print('*** Caught exception: ' + str(e.__class__) + ': ' + str(e))