swisskyrepo
/
NetExec
mirror of https://github.com/swisskyrepo/NetExec.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor(add_computer): refactor and add docstrings to add_computer module

main
Marshall Hallenbeck 2023-09-20 12:24:42 -04:00 committed by Marshall Hallenbeck
parent e80c4807a6
commit a8b14cee7f
1 changed files with 215 additions and 187 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

250
nxc/modules/add_computer.py
View File

@ -1,17 +1,18 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
# -*- coding: utf-8 -*
# -*- coding: utf-8 -*- import ssl
import ldap3 import ldap3
from impacket.dcerpc.v5 import samr, epm, transport from impacket.dcerpc.v5 import samr, epm, transport
class NXCModule: class NXCModule:
''' """
Module by CyberCelt: @Cyb3rC3lt Module by CyberCelt: @Cyb3rC3lt
Initial module: Initial module:
https://github.com/Cyb3rC3lt/CrackMapExec-Modules https://github.com/Cyb3rC3lt/CrackMapExec-Modules
Thanks to the guys at impacket for the original code Thanks to the guys at impacket for the original code
''' """
name = 'add-computer' name = 'add-computer'
description = 'Adds or deletes a domain computer' description = 'Adds or deletes a domain computer'
@ -20,7 +21,7 @@ class NXCModule:
multiple_hosts = False multiple_hosts = False
def options(self, context, module_options): def options(self, context, module_options):
''' """
add-computer: Specify add-computer to call the module using smb add-computer: Specify add-computer to call the module using smb
NAME: Specify the NAME option to name the Computer to be added NAME: Specify the NAME option to name the Computer to be added
PASSWORD: Specify the PASSWORD option to supply a password for the Computer to be added PASSWORD: Specify the PASSWORD option to supply a password for the Computer to be added
@ -29,7 +30,7 @@ class NXCModule:
Usage: nxc smb $DC-IP -u Username -p Password -M add-computer -o NAME="BADPC" PASSWORD="Password1" Usage: nxc smb $DC-IP -u Username -p Password -M add-computer -o NAME="BADPC" PASSWORD="Password1"
nxc smb $DC-IP -u Username -p Password -M add-computer -o NAME="BADPC" DELETE=True nxc smb $DC-IP -u Username -p Password -M add-computer -o NAME="BADPC" DELETE=True
nxc smb $DC-IP -u Username -p Password -M add-computer -o NAME="BADPC" PASSWORD="Password2" CHANGEPW=True nxc smb $DC-IP -u Username -p Password -M add-computer -o NAME="BADPC" PASSWORD="Password2" CHANGEPW=True
''' """
self.__baseDN = None self.__baseDN = None
self.__computerGroup = None self.__computerGroup = None
@ -61,8 +62,6 @@ class NXCModule:
exit(1) exit(1)
def on_login(self, context, connection): def on_login(self, context, connection):
#Set some variables
self.__domain = connection.domain self.__domain = connection.domain
self.__domainNetbios = connection.domain self.__domainNetbios = connection.domain
self.__kdcHost = connection.hostname + "." + connection.domain self.__kdcHost = connection.hostname + "." + connection.domain
@ -86,85 +85,103 @@ class NXCModule:
self.__lmhash = "00000000000000000000000000000000" self.__lmhash = "00000000000000000000000000000000"
# First try to add via SAMR over SMB # First try to add via SAMR over SMB
self.doSAMRAdd(context) self.do_samr_add(context)
# If SAMR fails now try over LDAPS # If SAMR fails now try over LDAPS
if not self.noLDAPRequired: if not self.noLDAPRequired:
self.doLDAPSAdd(connection,context) self.do_ldaps_add(connection, context)
else: else:
exit(1) exit(1)
def doSAMRAdd(self,context): def do_samr_add(self, context):
"""
Connects to a target server and performs various operations related to adding or deleting machine accounts.
Args:
context (object): The context object.
Returns:
None
"""
target = self.__targetIp or self.__target
string_binding = epm.hept_map(target, samr.MSRPC_UUID_SAMR, protocol="ncacn_np")
rpc_transport = transport.DCERPCTransportFactory(string_binding)
rpc_transport.set_dport(self.__port)
if self.__targetIp is not None: if self.__targetIp is not None:
stringBinding = epm.hept_map(self.__targetIp, samr.MSRPC_UUID_SAMR, protocol = 'ncacn_np') rpc_transport.setRemoteHost(self.__targetIp)
else: rpc_transport.setRemoteName(self.__target)
stringBinding = epm.hept_map(self.__target, samr.MSRPC_UUID_SAMR, protocol = 'ncacn_np')
rpctransport = transport.DCERPCTransportFactory(stringBinding)
rpctransport.set_dport(self.__port)
if self.__targetIp is not None: if hasattr(rpc_transport, 'set_credentials'):
rpctransport.setRemoteHost(self.__targetIp)
rpctransport.setRemoteName(self.__target)
if hasattr(rpctransport, 'set_credentials'):
# This method exists only for selected protocol sequences. # This method exists only for selected protocol sequences.
rpctransport.set_credentials(self.__username, self.__password, self.__domain, self.__lmhash, rpc_transport.set_credentials(
self.__nthash, self.__aesKey) self.__username,
self.__password,
self.__domain,
self.__lmhash,
self.__nthash,
self.__aesKey
)
rpctransport.set_kerberos(self.__doKerberos, self.__kdcHost) rpc_transport.set_kerberos(self.__doKerberos, self.__kdcHost)
dce = rpctransport.get_dce_rpc() dce = rpc_transport.get_dce_rpc()
servHandle = None
domainHandle = None
userHandle = None
try:
dce.connect() dce.connect()
dce.bind(samr.MSRPC_UUID_SAMR) dce.bind(samr.MSRPC_UUID_SAMR)
samrConnectResponse = samr.hSamrConnect5(dce, '\\\\%s\x00' % self.__target, samr_connect_response = samr.hSamrConnect5(
samr.SAM_SERVER_ENUMERATE_DOMAINS | samr.SAM_SERVER_LOOKUP_DOMAIN ) dce,
servHandle = samrConnectResponse['ServerHandle'] '\\\\%s\x00' % self.__target,
samr.SAM_SERVER_ENUMERATE_DOMAINS | samr.SAM_SERVER_LOOKUP_DOMAIN
)
serv_handle = samr_connect_response['ServerHandle']
samrEnumResponse = samr.hSamrEnumerateDomainsInSamServer(dce, servHandle) samr_enum_response = samr.hSamrEnumerateDomainsInSamServer(dce, serv_handle)
domains = samrEnumResponse['Buffer']['Buffer'] domains = samr_enum_response['Buffer']['Buffer']
domainsWithoutBuiltin = list(filter(lambda x : x['Name'].lower() != 'builtin', domains)) domains_without_builtin = [
domain for domain in domains if domain['Name'].lower() != 'builtin'
if len(domainsWithoutBuiltin) > 1: ]
if len(domains_without_builtin) > 1:
domain = list(filter(lambda x: x['Name'].lower() == self.__domainNetbios, domains)) domain = list(filter(lambda x: x['Name'].lower() == self.__domainNetbios, domains))
if len(domain) != 1: if len(domain) != 1:
context.log.highlight(u'{}'.format( context.log.highlight(u'{}'.format('This domain does not exist: "' + self.__domainNetbios + '"'))
'This domain does not exist: "' + self.__domainNetbios + '"')) context.log.highlight("Available domain(s):")
logging.critical("Available domain(s):")
for domain in domains: for domain in domains:
logging.error(" * %s" % domain['Name']) context.log.highlight(f" * {domain['Name']}")
raise Exception() raise Exception()
else: else:
selectedDomain = domain[0]['Name'] selected_domain = domain[0]["Name"]
else: else:
selectedDomain = domainsWithoutBuiltin[0]['Name'] selected_domain = domains_without_builtin[0]["Name"]
samrLookupDomainResponse = samr.hSamrLookupDomainInSamServer(dce, servHandle, selectedDomain) samr_lookup_domain_response = samr.hSamrLookupDomainInSamServer(
domainSID = samrLookupDomainResponse['DomainId'] dce, serv_handle, selected_domain
)
domain_sid = samr_lookup_domain_response["DomainId"]
if logging.getLogger().level == logging.DEBUG: context.log.debug(f"Opening domain {selected_domain}...")
logging.info("Opening domain %s..." % selectedDomain) samr_open_domain_response = samr.hSamrOpenDomain(
samrOpenDomainResponse = samr.hSamrOpenDomain(dce, servHandle, samr.DOMAIN_LOOKUP | samr.DOMAIN_CREATE_USER , domainSID) dce, serv_handle, samr.DOMAIN_LOOKUP | samr.DOMAIN_CREATE_USER, domain_sid
domainHandle = samrOpenDomainResponse['DomainHandle'] )
domain_handle = samr_open_domain_response["DomainHandle"]
if self.__noAdd or self.__delete: if self.__noAdd or self.__delete:
try: try:
checkForUser = samr.hSamrLookupNamesInDomain(dce, domainHandle, [self.__computerName]) check_for_user = samr.hSamrLookupNamesInDomain(
dce, domain_handle, [self.__computerName]
)
except samr.DCERPCSessionError as e: except samr.DCERPCSessionError as e:
if e.error_code == 0xc0000073: if e.error_code == 0xc0000073:
context.log.highlight(u'{}'.format( context.log.highlight(
self.__computerName + ' not found in domain ' + selectedDomain)) f"{self.__computerName} not found in domain {selected_domain}"
)
self.noLDAPRequired = True self.noLDAPRequired = True
raise Exception() raise Exception()
else: else:
raise raise
userRID = checkForUser['RelativeIds']['Element'][0] user_rid = check_for_user['RelativeIds']['Element'][0]
if self.__delete: if self.__delete:
access = samr.DELETE access = samr.DELETE
message = "delete" message = "delete"
@ -172,8 +189,8 @@ class NXCModule:
access = samr.USER_FORCE_PASSWORD_CHANGE access = samr.USER_FORCE_PASSWORD_CHANGE
message = "set the password for" message = "set the password for"
try: try:
openUser = samr.hSamrOpenUser(dce, domainHandle, access, userRID) open_user = samr.hSamrOpenUser(dce, domain_handle, access, user_rid)
userHandle = openUser['UserHandle'] user_handle = open_user['UserHandle']
except samr.DCERPCSessionError as e: except samr.DCERPCSessionError as e:
if e.error_code == 0xc0000022: if e.error_code == 0xc0000022:
context.log.highlight(u'{}'.format( context.log.highlight(u'{}'.format(
@ -185,7 +202,7 @@ class NXCModule:
else: else:
if self.__computerName is not None: if self.__computerName is not None:
try: try:
checkForUser = samr.hSamrLookupNamesInDomain(dce, domainHandle, [self.__computerName]) samr.hSamrLookupNamesInDomain(dce, domain_handle, [self.__computerName])
self.noLDAPRequired = True self.noLDAPRequired = True
context.log.highlight(u'{}'.format( context.log.highlight(u'{}'.format(
'Computer account already exists with the name: "' + self.__computerName + '"')) 'Computer account already exists with the name: "' + self.__computerName + '"'))
@ -194,18 +211,18 @@ class NXCModule:
if e.error_code != 0xc0000073: if e.error_code != 0xc0000073:
raise raise
else: else:
foundUnused = False found_unused = False
while not foundUnused: while not found_unused:
self.__computerName = self.generateComputerName() self.__computerName = self.generateComputerName()
try: try:
checkForUser = samr.hSamrLookupNamesInDomain(dce, domainHandle, [self.__computerName]) samr.hSamrLookupNamesInDomain(dce, domain_handle, [self.__computerName])
except samr.DCERPCSessionError as e: except samr.DCERPCSessionError as e:
if e.error_code == 0xc0000073: if e.error_code == 0xc0000073:
foundUnused = True found_unused = True
else: else:
raise raise
try: try:
createUser = samr.hSamrCreateUser2InDomain(dce, domainHandle, self.__computerName, samr.USER_WORKSTATION_TRUST_ACCOUNT, samr.USER_FORCE_PASSWORD_CHANGE,) create_user = samr.hSamrCreateUser2InDomain(dce, domain_handle, self.__computerName, samr.USER_WORKSTATION_TRUST_ACCOUNT, samr.USER_FORCE_PASSWORD_CHANGE,)
self.noLDAPRequired = True self.noLDAPRequired = True
context.log.highlight('Successfully added the machine account: "' + self.__computerName + '" with Password: "' + self.__computerPassword + '"') context.log.highlight('Successfully added the machine account: "' + self.__computerName + '" with Password: "' + self.__computerPassword + '"')
except samr.DCERPCSessionError as e: except samr.DCERPCSessionError as e:
@ -219,89 +236,100 @@ class NXCModule:
raise Exception() raise Exception()
else: else:
raise raise
userHandle = createUser['UserHandle'] user_handle = create_user['UserHandle']
if self.__delete: if self.__delete:
samr.hSamrDeleteUser(dce, userHandle) samr.hSamrDeleteUser(dce, user_handle)
context.log.highlight(u'{}'.format('Successfully deleted the "' + self.__computerName + '" Computer account')) context.log.highlight(u'{}'.format('Successfully deleted the "' + self.__computerName + '" Computer account'))
self.noLDAPRequired=True self.noLDAPRequired=True
userHandle = None user_handle = None
else: else:
samr.hSamrSetPasswordInternal4New(dce, userHandle, self.__computerPassword) samr.hSamrSetPasswordInternal4New(dce, user_handle, self.__computerPassword)
if self.__noAdd: if self.__noAdd:
context.log.highlight(u'{}'.format( context.log.highlight(u'{}'.format(
'Successfully set the password of machine "' + self.__computerName + '" with password "' + self.__computerPassword + '"')) 'Successfully set the password of machine "' + self.__computerName + '" with password "' + self.__computerPassword + '"'))
self.noLDAPRequired=True self.noLDAPRequired=True
else: else:
checkForUser = samr.hSamrLookupNamesInDomain(dce, domainHandle, [self.__computerName]) check_for_user = samr.hSamrLookupNamesInDomain(dce, domain_handle, [self.__computerName])
userRID = checkForUser['RelativeIds']['Element'][0] user_rid = check_for_user['RelativeIds']['Element'][0]
openUser = samr.hSamrOpenUser(dce, domainHandle, samr.MAXIMUM_ALLOWED, userRID) open_user = samr.hSamrOpenUser(
userHandle = openUser['UserHandle'] dce, domain_handle, access, user_rid
)
user_handle = open_user['UserHandle']
req = samr.SAMPR_USER_INFO_BUFFER() req = samr.SAMPR_USER_INFO_BUFFER()
req['tag'] = samr.USER_INFORMATION_CLASS.UserControlInformation req['tag'] = samr.USER_INFORMATION_CLASS.UserControlInformation
req['Control']['UserAccountControl'] = samr.USER_WORKSTATION_TRUST_ACCOUNT req['Control']['UserAccountControl'] = samr.USER_WORKSTATION_TRUST_ACCOUNT
samr.hSamrSetInformationUser2(dce, userHandle, req) samr.hSamrSetInformationUser2(dce, user_handle, req)
if not self.noLDAPRequired: if not self.noLDAPRequired:
context.log.highlight(u'{}'.format( context.log.highlight(u'{}'.format(
'Successfully added the machine account "' + self.__computerName + '" with Password: "' + self.__computerPassword + '"')) 'Successfully added the machine account "' + self.__computerName + '" with Password: "' + self.__computerPassword + '"'))
self.noLDAPRequired = True self.noLDAPRequired = True
except Exception: if user_handle is not None:
if logging.getLogger().level == logging.DEBUG: samr.hSamrCloseHandle(dce, user_handle)
import traceback if domain_handle is not None:
traceback.print_exc() samr.hSamrCloseHandle(dce, domain_handle)
finally: if serv_handle is not None:
if userHandle is not None: samr.hSamrCloseHandle(dce, serv_handle)
samr.hSamrCloseHandle(dce, userHandle)
if domainHandle is not None:
samr.hSamrCloseHandle(dce, domainHandle)
if servHandle is not None:
samr.hSamrCloseHandle(dce, servHandle)
dce.disconnect() dce.disconnect()
def doLDAPSAdd(self, connection, context): def do_ldaps_add(self, connection, context):
"""
Performs an LDAPS add operation.
Args:
connection (Connection): The LDAP connection object.
context (Context): The context object.
Returns:
None
Raises:
None
"""
ldap_domain = connection.domain.replace(".", ",dc=") ldap_domain = connection.domain.replace(".", ",dc=")
spns = [ spns = [
'HOST/%s' % self.__computerName, f"HOST/{self.__computerName}",
'HOST/%s.%s' % (self.__computerName, connection.domain), f"HOST/{self.__computerName}.{connection.domain}",
'RestrictedKrbHost/%s' % self.__computerName, f"RestrictedKrbHost/{self.__computerName}",
'RestrictedKrbHost/%s.%s' % (self.__computerName, connection.domain), f"RestrictedKrbHost/{self.__computerName}.{connection.domain}",
] ]
ucd = { ucd = {
'dnsHostName': '%s.%s' % (self.__computerName, connection.domain), "dnsHostName": f"{self.__computerName}.{connection.domain}",
'userAccountControl': 0x1000, "userAccountControl": 0x1000,
'servicePrincipalName': spns, "servicePrincipalName": spns,
'sAMAccountName': self.__computerName, "sAMAccountName": self.__computerName,
'unicodePwd': ('"%s"' % self.__computerPassword).encode('utf-16-le') "unicodePwd": f'"{self.__computerPassword}"'.encode('utf-16-le')
} }
tls = ldap3.Tls(validate=ssl.CERT_NONE, version=ssl.PROTOCOL_TLSv1_2, ciphers='ALL:@SECLEVEL=0') tls = ldap3.Tls(validate=ssl.CERT_NONE, version=ssl.PROTOCOL_TLSv1_2, ciphers="ALL:@SECLEVEL=0")
ldapServer = ldap3.Server(connection.host, use_ssl=True, port=636, get_info=ldap3.ALL, tls=tls) ldap_server = ldap3.Server(connection.host, use_ssl=True, port=636, get_info=ldap3.ALL, tls=tls)
c = Connection(ldapServer, connection.username + '@' + connection.domain, connection.password) c = ldap3.Connection(ldap_server, f"{connection.username}@{connection.domain}", connection.password)
c.bind() c.bind()
if (self.__delete): if self.__delete:
result = c.delete("cn=" + self.__computerName + ",cn=Computers,dc=" + ldap_domain) result = c.delete(f"cn={self.__computerName},cn=Computers,dc={ldap_domain}")
if result: if result:
context.log.highlight(u'{}'.format('Successfully deleted the "' + self.__computerName + '" Computer account')) context.log.highlight(f'Successfully deleted the "{self.__computerName}" Computer account')
elif result is False and c.last_error == "noSuchObject": elif result is False and c.last_error == "noSuchObject":
context.log.highlight(u'{}'.format('Computer named "' + self.__computerName + '" was not found')) context.log.highlight(f'Computer named "{self.__computerName}" was not found')
elif result is False and c.last_error == "insufficientAccessRights": elif result is False and c.last_error == "insufficientAccessRights":
context.log.highlight(f'Insufficient Access Rights to delete the Computer "{self.__computerName}"')
else:
context.log.highlight( context.log.highlight(
u'{}'.format('Insufficient Access Rights to delete the Computer "' + self.__computerName + '"')) f'Unable to delete the "{self.__computerName}" Computer account. The error was: {c.last_error}')
else: else:
context.log.highlight(u'{}'.format( result = c.add(
'Unable to delete the "' + self.__computerName + '" Computer account. The error was: ' + c.last_error)) f"cn={self.__computerName},cn=Computers,dc={ldap_domain}",
else: ['top', 'person', 'organizationalPerson', 'user', 'computer'],
result = c.add("cn=" + self.__computerName + ",cn=Computers,dc=" + ldap_domain, ucd
['top', 'person', 'organizationalPerson', 'user', 'computer'], ucd) )
if result: if result:
context.log.highlight('Successfully added the machine account: "' + self.__computerName + '" with Password: "' + self.__computerPassword + '"') context.log.highlight(
context.log.highlight(u'{}'.format('You can try to verify this with the nxc command:')) f'Successfully added the machine account: "{self.__computerName}" with Password: "{self.__computerPassword}"')
context.log.highlight(u'{}'.format( context.log.highlight("You can try to verify this with the nxc command:")
'nxc ldap ' + connection.host + ' -u ' + connection.username + ' -p ' + connection.password + ' -M group-mem -o GROUP="Domain Computers"')) context.log.highlight(f"nxc ldap {connection.host} -u {connection.username} -p {connection.password} -M group-mem -o GROUP='Domain Computers'")
elif result is False and c.last_error == "entryAlreadyExists": elif result is False and c.last_error == "entryAlreadyExists":
context.log.highlight(u'{}'.format('The Computer account "' + self.__computerName + '" already exists')) context.log.highlight(f"The Computer account '{self.__computerName}' already exists")
elif not result: elif not result:
context.log.highlight(u'{}'.format( context.log.highlight(f"Unable to add the '{self.__computerName}' Computer account. The error was: {c.last_error}")
'Unable to add the "' + self.__computerName + '" Computer account. The error was: ' + c.last_error))
c.unbind() c.unbind()