mirror of
https://github.com/Pennyw0rth/NetExec
synced 2026-06-06 16:34:30 +00:00
byt3bl33d3r
94d1c040c8
it deserves its own blog post! Fixed a bug with the smbexec execution method which would cause it to exit without retrieving output
98 lines
3.4 KiB
Python
98 lines
3.4 KiB
Python
import ntpath
|
|
import traceback
|
|
|
|
from gevent import sleep
|
|
from core.helpers import gen_random_string
|
|
from impacket.dcerpc.v5.dcomrt import DCOMConnection
|
|
from impacket.dcerpc.v5.dcom import wmi
|
|
from impacket.dcerpc.v5.dtypes import NULL
|
|
|
|
class WMIEXEC:
|
|
def __init__(self, target, username, password, domain, smbconnection, hashes=None, share=None):
|
|
self.__target = target
|
|
self.__username = username
|
|
self.__password = password
|
|
self.__domain = domain
|
|
self.__lmhash = ''
|
|
self.__nthash = ''
|
|
self.__share = share
|
|
self.__smbconnection = smbconnection
|
|
self.__output = '\\' + gen_random_string(6)
|
|
self.__outputBuffer = ''
|
|
self.__shell = 'cmd.exe /Q /c '
|
|
self.__pwd = 'C:\\'
|
|
self.__aesKey = None
|
|
self.__doKerberos = False
|
|
self.__retOutput = True
|
|
if hashes is not None:
|
|
self.__lmhash, self.__nthash = hashes.split(':')
|
|
|
|
if self.__password is None:
|
|
self.__password = ''
|
|
|
|
self.__dcom = DCOMConnection(self.__target, self.__username, self.__password, self.__domain, self.__lmhash, self.__nthash, self.__aesKey, oxidResolver = True, doKerberos=self.__doKerberos)
|
|
iInterface = self.__dcom.CoCreateInstanceEx(wmi.CLSID_WbemLevel1Login,wmi.IID_IWbemLevel1Login)
|
|
iWbemLevel1Login = wmi.IWbemLevel1Login(iInterface)
|
|
iWbemServices= iWbemLevel1Login.NTLMLogin('//./root/cimv2', NULL, NULL)
|
|
iWbemLevel1Login.RemRelease()
|
|
|
|
self.__win32Process,_ = iWbemServices.GetObject('Win32_Process')
|
|
|
|
def execute(self, command, output=False):
|
|
self.__retOutput = output
|
|
try:
|
|
if self.__retOutput:
|
|
self.__smbconnection.setTimeout(100000)
|
|
self.cd('\\')
|
|
|
|
self.execute_remote(command)
|
|
self.__dcom.disconnect()
|
|
return self.__outputBuffer
|
|
except Exception as e:
|
|
traceback.print_exc()
|
|
self.__dcom.disconnect()
|
|
|
|
|
|
def cd(self, s):
|
|
self.execute_remote('cd ' + s)
|
|
if len(self.__outputBuffer.strip('\r\n')) > 0:
|
|
print self.__outputBuffer
|
|
self.__outputBuffer = ''
|
|
else:
|
|
self.__pwd = ntpath.normpath(ntpath.join(self.__pwd, s))
|
|
self.execute_remote('cd ')
|
|
self.__pwd = self.__outputBuffer.strip('\r\n')
|
|
self.prompt = self.__pwd + '>'
|
|
self.__outputBuffer = ''
|
|
|
|
def execute_remote(self, data):
|
|
command = self.__shell + data
|
|
if self.__retOutput:
|
|
command += ' 1> ' + '\\\\127.0.0.1\\%s' % self.__share + self.__output + ' 2>&1'
|
|
self.__win32Process.Create(command, self.__pwd, None)
|
|
self.get_output()
|
|
|
|
def get_output(self):
|
|
|
|
if self.__retOutput is False:
|
|
self.__outputBuffer = ''
|
|
return
|
|
|
|
def output_callback(data):
|
|
self.__outputBuffer += data
|
|
|
|
while True:
|
|
try:
|
|
self.__smbconnection.getFile(self.__share, self.__output, output_callback)
|
|
break
|
|
except Exception as e:
|
|
if str(e).find('STATUS_SHARING_VIOLATION') >=0:
|
|
# Output not finished, let's wait
|
|
sleep(2)
|
|
pass
|
|
else:
|
|
#print str(e)
|
|
pass
|
|
|
|
self.__smbconnection.deleteFile(self.__share, self.__output)
|