aljaz/cowrie
1
0
Fork 0
mirror of https://github.com/aljazceru/cowrie.git synced 2025-12-18 06:24:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fixes and restructuring for the session management code, as well as

Browse Source 
disconnect handling in general


git-svn-id: https://kippo.googlecode.com/svn/trunk@212 951d7100-d841-11de-b865-b3884708a8e2
This commit is contained in:
desaster
2011-10-23 12:27:01 +00:00
parent f2488b4173
commit 8845b2b0eb
2 changed files with 65 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
kippo/core/interact.py
View File

@@ -65,7 +65,7 @@ class Interact(telnet.Telnet):
if not self.readonly:
if type(bytes) == type(''):
ttylog.ttylog_write(
self.interacting.terminal.ttylog_file,
self.interacting.ttylog_file,
len(bytes), ttylog.TYPE_INTERACT, time.time(), bytes)
recvline.HistoricRecvLine.keystrokeReceived(
self.interacting, bytes, None)
@@ -97,15 +97,13 @@ class Interact(telnet.Telnet):
self.transport.write('** Invalid session ID.\r\n')
return
for s in self.honeypotFactory.sessions:
transport = s.terminal.transport.session.conn.transport
if sessionno == transport.transport.sessionno:
if sessionno == s:
self.view(s)
return
self.transport.write('** No such session found.\r\n')
def view(self, session):
transport = session.terminal.transport.session.conn.transport
sessionno = transport.transport.sessionno
def view(self, sessionno):
session = self.honeypotFactory.sessions[sessionno]
self.transport.write(
'** Attaching to #%d, hit ESC to return\r\n' % sessionno)
session.addInteractor(self)
@@ -114,12 +112,11 @@ class Interact(telnet.Telnet):
def cmd_list(self, args):
self.transport.write('ID clientIP clientVersion\r\n')
for s in self.honeypotFactory.sessions:
transport = s.terminal.transport.session.conn.transport
sessionno = transport.transport.sessionno
session = self.honeypotFactory.sessions[s]
self.transport.write('%s %s %s\r\n' % \
(str(sessionno).ljust(4),
s.realClientIP.ljust(15),
s.clientVersion))
(str(s).ljust(4),
session.realClientIP.ljust(15),
session.clientVersion))
def cmd_help(self, args = ''):
self.transport.write('List of commands:\r\n')
@@ -140,11 +137,10 @@ class Interact(telnet.Telnet):
self.transport.write('** Invalid session ID.\r\n')
return
for s in self.honeypotFactory.sessions:
transport = s.terminal.transport.session.conn.transport
if sessionno == transport.transport.sessionno:
if sessionno == s:
self.transport.write(
'** Disconnecting session #%d\r\n' % sessionno)
transport.loseConnection()
self.honeypotFactory.sessions[s].terminal.loseConnection()
return
self.transport.write('** No such session found.\r\n')