formatting

Author: glaslos

conpot/core/databus.py

@@ -25,7 +25,6 @@
 import gevent.event
 from lxml import etree
 
-
 logger = logging.getLogger(__name__)
 
 

conpot/core/fs_utils.py

@@ -18,6 +18,7 @@
 """
 Utils related to ConpotVFS
 """
+
 import fs
 from typing import Optional, Union
 from fs.permissions import Permissions

conpot/core/loggers/sqlite_log.py

@@ -44,8 +44,7 @@ def __init__(self, db_path="logs/conpot.db"):
 
     def _create_db(self):
         cursor = self.conn.cursor()
-        cursor.execute(
-            """CREATE TABLE IF NOT EXISTS events
+        cursor.execute("""CREATE TABLE IF NOT EXISTS events
             (
                 id INTEGER PRIMARY KEY AUTOINCREMENT,
                 session TEXT,
@@ -54,8 +53,7 @@ def _create_db(self):
                 protocol TEXT,
                 request TEXT,
                 response TEXT
-            )"""
-        )
+            )""")
 
     def log(self, event):
         cursor = self.conn.cursor()

conpot/emulators/kamstrup/usage_simulator.py

@@ -20,7 +20,6 @@
 import gevent
 import conpot.core as conpot_core
 
-
 logger = logging.getLogger(__name__)
 
 

conpot/protocols/__init__.py

@@ -28,7 +28,6 @@
 from .snmp.snmp_server import SNMPServer
 from .tftp.tftp_server import TftpServer
 
-
 # Defines protocol directory names inside template directories
 name_mapping = {
     "bacnet": BacnetServer,

conpot/protocols/http/command_responder.py

@@ -32,7 +32,6 @@
 from conpot.utils.networking import str_to_bytes
 import gevent
 
-
 logger = logging.getLogger(__name__)
 
 
@@ -333,7 +332,7 @@ def load_status(
                 if status != 503:
                     # we're handling another error here.
                     # generate a 503 response from configuration.
-                    (status, headers, trailers, payload, chunks) = self.load_status(
+                    status, headers, trailers, payload, chunks = self.load_status(
                         503,
                         requeststring,
                         self.headers,
@@ -497,7 +496,7 @@ def load_entity(self, requeststring, headers, configuration, docpath):
 
             except:
                 status = 503
-                (status, headers, trailers, payload, chunks) = self.load_status(
+                status, headers, trailers, payload, chunks = self.load_status(
                     status, requeststring, self.headers, headers, configuration, docpath
                 )
 
@@ -565,7 +564,7 @@ def send_error(self, code, message=None):
                 logger.info(message)
 
         # generate the appropriate status code, header and payload
-        (status, headers, trailers, payload, chunks) = self.load_status(
+        status, headers, trailers, payload, chunks = self.load_status(
             code,
             requeststring.partition("?")[0],
             self.headers,
@@ -626,7 +625,7 @@ def do_TRACE(self):
         if self.server.disable_method_trace is True:
             # Method disabled by configuration. Fall back to 501.
             status = 501
-            (status, headers, _, payload, _) = self.load_status(
+            status, headers, _, payload, _ = self.load_status(
                 status, self.path, self.headers, headers, configuration, docpath
             )
 
@@ -689,7 +688,7 @@ def do_HEAD(self):
         if self.server.disable_method_head is True:
             # Method disabled by configuration. Fall back to 501.
             status = 501
-            (status, headers, _, _, _) = self.load_status(
+            status, headers, _, _, _ = self.load_status(
                 status, self.path, self.headers, headers, configuration, docpath
             )
 
@@ -709,14 +708,14 @@ def do_HEAD(self):
 
             if entity_xml:
                 # A config item exists for this entity. Handle it..
-                (status, headers, _, _, _) = self.load_entity(
+                status, headers, _, _, _ = self.load_entity(
                     self.path, headers, configuration, docpath
                 )
 
             else:
                 # No config item could be found. Fall back to a standard 404..
                 status = 404
-                (status, headers, _, _, _) = self.load_status(
+                status, headers, _, _, _ = self.load_status(
                     status, self.path, self.headers, headers, configuration, docpath
                 )
 
@@ -762,7 +761,7 @@ def do_OPTIONS(self):
         if self.server.disable_method_options is True:
             # Method disabled by configuration. Fall back to 501.
             status = 501
-            (status, headers, _, payload, _) = self.load_status(
+            status, headers, _, payload, _ = self.load_status(
                 status, self.path, self.headers, headers, configuration, docpath
             )
 
@@ -846,14 +845,14 @@ def do_GET(self):
 
         if entity_xml:
             # A config item exists for this entity. Handle it..
-            (status, headers, trailers, payload, chunks) = self.load_entity(
+            status, headers, trailers, payload, chunks = self.load_entity(
                 self.path, headers, configuration, docpath
             )
 
         else:
             # No config item could be found. Fall back to a standard 404..
             status = 404
-            (status, headers, trailers, payload, chunks) = self.load_status(
+            status, headers, trailers, payload, chunks = self.load_status(
                 status, self.path, self.headers, headers, configuration, docpath, "GET"
             )
 
@@ -914,14 +913,14 @@ def do_POST(self):
 
         if entity_xml:
             # A config item exists for this entity. Handle it..
-            (status, headers, trailers, payload, chunks) = self.load_entity(
+            status, headers, trailers, payload, chunks = self.load_entity(
                 self.path, headers, configuration, docpath
             )
 
         else:
             # No config item could be found. Fall back to a standard 404..
             status = 404
-            (status, headers, trailers, payload, chunks) = self.load_status(
+            status, headers, trailers, payload, chunks = self.load_status(
                 status,
                 self.path,
                 self.headers,

conpot/protocols/ipmi/fakebmc.py

@@ -19,7 +19,6 @@
 
 from pyghmi.ipmi.bmc import Bmc
 
-
 logger = logging.getLogger()
 
 

conpot/protocols/ipmi/ipmi_server.py

@@ -162,7 +162,7 @@ def initiate_session(self, data, address, session):
                     if channel != 0xE:
                         self.close_server_session()
                         return
-                    (clientaddr, clientlun) = struct.unpack("BB", data[17:19])
+                    clientaddr, clientlun = struct.unpack("BB", data[17:19])
                     level &= 0b1111
                     self.send_auth_cap(
                         myaddr, mylun, clientaddr, clientlun, session.sockaddr

conpot/protocols/kamstrup_management/command_responder.py

@@ -19,7 +19,6 @@
 
 from . import commands
 
-
 logger = logging.getLogger(__name__)
 
 

conpot/protocols/kamstrup_meter/command_responder.py

@@ -22,7 +22,6 @@
 
 from .register import KamstrupRegister
 
-
 logger = logging.getLogger(__name__)