AIL-framework/bin/modules/Hosts.py

#!/usr/bin/env python3
# -*-coding:UTF-8 -*

"""
The Hosts Module
======================

This module is consuming the Redis-list created by the Global module.

It is looking for Hosts

"""

##################################
# Import External packages
##################################
import os
import re
import sys

sys.path.append(os.environ['AIL_BIN'])
##################################
# Import Project packages
##################################
from modules.abstract_module import AbstractModule
from lib.ConfigLoader import ConfigLoader
from lib.objects.Items import Item

class Hosts(AbstractModule):
    """
    Hosts module for AIL framework
    """

    def __init__(self):
        super(Hosts, self).__init__()

        config_loader = ConfigLoader()
        self.r_cache = config_loader.get_redis_conn("Redis_Cache")

        # regex timeout
        self.regex_timeout = 30

        # Waiting time in seconds between to message processed
        self.pending_seconds = 1

        self.host_regex = r'\b([a-zA-Z\d-]{,63}(?:\.[a-zA-Z\d-]{,63})+)\b'
        re.compile(self.host_regex)

        self.logger.info(f"Module: {self.module_name} Launched")

    def compute(self, message):
        item = self.get_obj()

        # mimetype = item_basic.get_item_mimetype(item.get_id())
        # if mimetype.split('/')[0] == "text":

        content = item.get_content()
        hosts = self.regex_findall(self.host_regex, item.get_id(), content, r_set=True)
        if hosts:
            print(f'{len(hosts)} host     {item.get_id()}')
            for host in hosts:
                # print(host)
                if not host.endswith('.onion'):
                    self.add_message_to_queue(message=str(host), queue='Host')


if __name__ == '__main__':

    module = Hosts()
    module.run()