From cb2ca5be46681d7435f6791abb2eae81a3fe3e1a Mon Sep 17 00:00:00 2001
From: Ilija Lazoroski <ilija.la@live.com>
Date: Tue, 14 Dec 2021 14:48:44 +0100
Subject: [PATCH] Agent: Remove MySQL fingerprinter

---
 monkey/infection_monkey/example.conf          |  1 -
 .../infection_monkey/network/mysqlfinger.py   | 85 -------------------
 2 files changed, 86 deletions(-)
 delete mode 100644 monkey/infection_monkey/network/mysqlfinger.py

diff --git a/monkey/infection_monkey/example.conf b/monkey/infection_monkey/example.conf
index 42b37ddf4..8468b1422 100644
--- a/monkey/infection_monkey/example.conf
+++ b/monkey/infection_monkey/example.conf
@@ -38,7 +38,6 @@
     "SSHFinger",
     "HTTPFinger",
     "SMBFinger",
-    "MySQLFinger",
     "MSSQLFingerprint",
     "ElasticFinger"
   ],
diff --git a/monkey/infection_monkey/network/mysqlfinger.py b/monkey/infection_monkey/network/mysqlfinger.py
deleted file mode 100644
index d0bc14dc6..000000000
--- a/monkey/infection_monkey/network/mysqlfinger.py
+++ /dev/null
@@ -1,85 +0,0 @@
-import logging
-import socket
-
-import infection_monkey.config
-from infection_monkey.network.HostFinger import HostFinger
-from infection_monkey.network.tools import struct_unpack_tracker, struct_unpack_tracker_string
-
-MYSQL_PORT = 3306
-SQL_SERVICE = "mysqld-3306"
-logger = logging.getLogger(__name__)
-
-
-class MySQLFinger(HostFinger):
-    """
-    Fingerprints mysql databases, only on port 3306
-    """
-
-    _SCANNED_SERVICE = "MySQL"
-    SOCKET_TIMEOUT = 0.5
-    HEADER_SIZE = 4  # in bytes
-
-    def __init__(self):
-        self._config = infection_monkey.config.WormConfiguration
-
-    def get_host_fingerprint(self, host):
-        """
-        Returns mySQLd data using the host header
-        :param host:
-        :return: Success/failure, data is saved in the host struct
-        """
-        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-        s.settimeout(self.SOCKET_TIMEOUT)
-
-        try:
-            s.connect((host.ip_addr, MYSQL_PORT))
-            header = s.recv(self.HEADER_SIZE)  # max header size?
-
-            response, curpos = struct_unpack_tracker(header, 0, "I")
-            response = response[0]
-            response_length = response & 0xFF  # first byte is significant
-            data = s.recv(response_length)
-            # now we can start parsing
-            protocol, curpos = struct_unpack_tracker(data, 0, "B")
-            protocol = protocol[0]
-
-            if protocol == 0xFF:
-                # error code, bug out
-                logger.debug("Mysql server returned error")
-                return False
-
-            version, curpos = struct_unpack_tracker_string(
-                data, curpos
-            )  # special coded to solve string parsing
-            version = version[0].decode()
-            self.init_service(host.services, SQL_SERVICE, MYSQL_PORT)
-            host.services[SQL_SERVICE]["version"] = version
-            version = version.split("-")[0].split(".")
-            host.services[SQL_SERVICE]["major_version"] = version[0]
-            host.services[SQL_SERVICE]["minor_version"] = version[1]
-            host.services[SQL_SERVICE]["build_version"] = version[2]
-            thread_id, curpos = struct_unpack_tracker(data, curpos, "<I")  # ignore thread id
-            # protocol parsing taken from
-            # https://nmap.org/nsedoc/scripts/mysql-info.html
-            if protocol == 10:
-                # new protocol
-                self._parse_protocol_10(curpos, data, host)
-                return True
-            if protocol == 9:
-                return True
-            s.close()
-
-        except Exception as err:
-            logger.debug("Error getting mysql fingerprint: %s", err)
-
-        return False
-
-    def _parse_protocol_10(self, curpos, data, host):
-        salt, curpos = struct_unpack_tracker(data, curpos, "s8B")
-        capabilities, curpos = struct_unpack_tracker(data, curpos, "<H")
-        host.services[SQL_SERVICE]["capabilities"] = capabilities[0]
-        charset, curpos = struct_unpack_tracker(data, curpos, "B")
-        status, curpos = struct_unpack_tracker(data, curpos, "<H")
-        extcapabilities, curpos = struct_unpack_tracker(data, curpos, "<H")
-        host.services[SQL_SERVICE]["extcapabilities"] = extcapabilities[0]
-        # there's more data but it doesn't matter