honeypot.py

import logging
import threading
from socket import socket, timeout


class honey(object):

    def __init__(self, bind_ip, ports, log_filepath):
        if len(ports) < 1:
            raise Exception("No ports provided.")

        self.bind_ip = bind_ip
        self.ports = ports
        self.log_filepath = log_filepath
        self.listener_threads = {}
        self.logger = self.mylogger()

        self.logger.info("Honeypot initializing...")
        self.logger.info("Ports: %s" % self.ports)
        self.logger.info("Log filepath: %s" % self.log_filepath)

    def incoming(self, client_socket, port, ip, remote_port):
        self.logger.info(
            "Connection received: %s: %s:%d" %
            (port, ip, remote_port))

        client_socket.settimeout(4)
        try:
            data = client_socket.recv(64)
            self.logger.info(
                "Data received: %s: %s:%d: %s" %
                (port, ip, remote_port, data))
            client_socket.send("Access denied.\n".encode('utf8'))
        except timeout:
            pass
        client_socket.close()

    def listening_thread(self, port):
        # Create a new listener
        listener = socket()
        listener.bind((self.bind_ip, int(port)))
        self.logger.info("Honeypot running on port %d" % (port))
        listener.listen(5)
        while True:
            client, addr = listener.accept()
            client_handler = threading.Thread(
                target=self.incoming, args=(
                    client, port, addr[0], addr[1]))
            client_handler.start()

    def start_listening(self):
        for port in self.ports:
            self.listener_threads[port] = threading.Thread(
                target=self.listening_thread, args=(port,))
            self.listener_threads[port].start()

    def run(self):
        self.start_listening()

    def mylogger(self):
        logging.basicConfig(level=logging.DEBUG,
                            format='%(asctime)s %(levelname)-8s %(message)s',
                            datefmt='%Y-%m-%d %H:%M:%s',
                            filename=self.log_filepath,
                            filemode='w')
        logger = logging.getLogger(__name__)

        # Adding console handler
        console_handler = logging.StreamHandler()
        console_handler.setLevel(logging.DEBUG)
        logger.addHandler(console_handler)
        return logger