mirror of
https://github.com/aljazceru/cowrie.git
synced 2025-12-29 20:04:20 +01:00
generate session identifier centrally, so it's same for all plugins
This commit is contained in:
@@ -31,7 +31,6 @@ import datetime
|
||||
import re
|
||||
import copy
|
||||
import socket
|
||||
import uuid
|
||||
|
||||
# KIPP0001 : create session
|
||||
# KIPP0002 : succesful login
|
||||
@@ -144,9 +143,9 @@ class Output(object):
|
||||
|
||||
# connection event is special. adds to session list
|
||||
if ev['eventid'] == 'KIPP0001':
|
||||
self.sessions[sessionno] = uuid.uuid4().hex
|
||||
self.sessions[sessionno] = ev['id']
|
||||
self.ips[sessionno] = ev['src_ip']
|
||||
del ev['system']
|
||||
del ev['id']
|
||||
|
||||
ev['session'] = self.sessions[sessionno]
|
||||
|
||||
|
||||
@@ -232,7 +232,7 @@ class HoneyPotTransport(transport.SSHServerTransport):
|
||||
format='New connection: %(src_ip)s:%(src_port)s (%(dst_ip)s:%(dst_port)s) [session: %(sessionno)s]',
|
||||
src_ip=self.transport.getPeer().host, src_port=self.transport.getPeer().port,
|
||||
dst_ip=self.transport.getHost().host, dst_port=self.transport.getHost().port,
|
||||
sessionno=self.transport.sessionno)
|
||||
id=self.transportId, sessionno=self.transport.sessionno)
|
||||
|
||||
self.transport.write('%s\r\n' % (self.ourVersionString,))
|
||||
self.currentEncryptions = transport.SSHCiphers('none', 'none', 'none', 'none')
|
||||
|
||||
Reference in New Issue
Block a user