Function insert_to_network_events_queue

database/connector.py:108–146

insert other network events (port scan, etc..) to network_events_queue Args: network_event: Object of NetworkEvent Class with event parameters network_events_queue: Multiprocessing queue which stores the list of network_events in _dict_ format

(network_event: NetworkEvent, network_events_queue: Queue)

def insert_to_network_events_queue(network_event: NetworkEvent, network_events_queue: Queue):
    """
    insert other network events (port scan, etc..) to network_events_queue

    Args:
        network_event: Object of NetworkEvent Class with event parameters
        network_events_queue: Multiprocessing queue which stores the list of
                              network_events in _dict_ format

    Returns:
        None
    """

    verbose_info(
        messages["received_network_event"].format(
            network_event.ip_dest,
            network_event.port_dest,
            network_event.ip_src,
            network_event.port_src,
            network_event.machine_name
        )
    )

    # Get country of the source IP Address
    network_event.country_ip_src = byte_to_str(
        IP2Location.get_country_short(
            network_event.ip_src
        )
    )

    # Get country of the destination IP Address
    network_event.country_ip_dest = byte_to_str(
        IP2Location.get_country_short(
            network_event.ip_dest
        )
    )

    network_events_queue.put(network_event.__dict__)
    return


def push_events_queues_to_database(honeypot_events_queue, network_events_queue):