feat: Change max line length to 128kb; add kick for max line length log

Author: tonestory6809

src/pyfsd/protocol/__init__.py

@@ -23,7 +23,7 @@ class LineReceiver(Protocol, metaclass=ABCMeta):
 
     buffer: bytes = b""
     delimiter: bytes = b"\r\n"
-    max_length: int = 1024  # 1kb
+    max_length: int = 1024*128  # 128kb
 
     @abstractmethod
     def line_received(self, line: bytes) -> None:

src/pyfsd/protocol/client.py

@@ -155,6 +155,11 @@ def __init__(self, factory: "ClientFactory") -> None:
         self.timeout_killer_task = None
         # timeout_killer_task and transport will be initialized in connection_made.
 
+    def max_length_exceed(self, length: int) -> None:
+        """Called when line length exceed max length."""
+        logger.info(f"Kicking {self.get_description()}: max length exceeded")
+        return super().max_length_exceed(length)
+
     def add_task(self, task: "Task") -> None:
         """Store a task's strong reference to keep it away from disappear."""
         self.tasks.add(task)