def scan_ip_addresses_for_domain_name_scan(
self,
org_uuid=None,
domain_uuid=None,
domain_scan_uuid=None,
order_uuid=None,
):
"""
Kick off tasks for scanning all of the IP addresses discovered during the given domain name scan.
:param org_uuid: The UUID of the organization to scan endpoints for.
:param domain_uuid: The UUID of the domain name that was scanned.
:param domain_scan_uuid: The UUID of the domain name scan to kick off endpoint scanning tasks
for.
:return: None
"""
logger.info(
"Now kicking off all tasks for scanning IP addresses associated with domain %s."
% (domain_uuid,)
)
ip_addresses = get_ip_addresses_from_domain_name_scan(domain_scan_uuid=domain_scan_uuid, org_uuid=org_uuid)
if len(ip_addresses) == 0:
logger.info(
"No IP addresses discovered for domain %s during scan %s."
% (domain_uuid, domain_scan_uuid)
)
return
task_sigs = []
domain = self.domain
for ip_address in ip_addresses:
ip_address_model = get_ip_address_for_organization(
db_session=self.db_session,
org_uuid=org_uuid,
ip_address=ip_address,
)
domain.ip_addresses.append(ip_address_model)
task_sigs.append(scan_ip_address.si(
org_uuid=org_uuid,
ip_address_uuid=ip_address_model.uuid,
order_uuid=order_uuid,
))
group(task_sigs).apply_async()
#USED
评论列表
文章目录