How to use the black.workers.common.async_task.AsyncTask.__init__ function in black

To help you get started, we’ve selected a few black examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github c0rvax / project-black / black / workers / dnsscan / DNSScanTask.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(self, task_id, 'dnsscan', target, params, project_uuid)
        # program_params = params['program']
        # self.params_object = program_params

        self.request_queue = asyncio.Queue()
        self.resolver = aiodns.DNSResolver()

        self.pool_size = 10

        self.new_ips_ids = list()
        self.new_hosts_ids = list()
github c0rvax / project-black / black / workers / nmap / nmap_task.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(self, task_id, 'nmap', target, params, project_uuid)
        self.proc = None

        self.exit_code = None
        self.stdout = []
        self.stderr = []
github c0rvax / project-black / black / workers / patator / patator_task.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(
            self, task_id, 'patator', target, params, project_uuid
        )

        self.patator_proc = None
        self.socket_path = None

        self.loop = asyncio.get_event_loop()

        self.all_done = asyncio.Lock()
github c0rvax / project-black / black / workers / amass / amass_task.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(self, task_id, 'amass', target, params, project_uuid)
        self.proc = None

        self.exit_code = None
        self.stdout = []
        self.stderr = []
github c0rvax / project-black / black / workers / nmap / nmap_task.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(self, task_id, 'nmap', target, params, project_uuid)
        self.proc = None

        self.exit_code = None
        self.stdout = []
        self.stderr = []
github c0rvax / project-black / black / workers / dirsearch / dirsearch_task.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(
            self, task_id, 'dirsearch', target, params, project_uuid
        )

        program_params = params['program']
        self.params_object = program_params

        self.dirsearch_proc = None
        self.socket_path = None

        self.loop = asyncio.get_event_loop()

        self.all_done = asyncio.Lock()
github c0rvax / project-black / black / workers / masscan / masscan_task.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(self, task_id, 'masscan', target, params, project_uuid)
        self.proc = None

        self.exit_code = None
        self.stdout = []
        self.stderr = []

        if type(self.target) == list:
            self.target = ",".join(self.target)
github c0rvax / project-black / black / workers / dirsearch / dirsearch_task.py View on Github external
def __init__(self, task_id, target, params, project_uuid):
        AsyncTask.__init__(
            self, task_id, 'dirsearch', target, params, project_uuid
        )

        program_params = params['program']
        self.params_object = program_params

        self.dirsearch_proc = None
        self.socket_path = None

        self.loop = asyncio.get_event_loop()

        self.all_done = asyncio.Lock()