From b733f53b839a122bab36351cebad9f1cc64a03ca Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Krist=C3=B3f=20T=C3=B3th?= <kristof.toth@avatao.com>
Date: Wed, 4 Sep 2019 17:21:49 +0200
Subject: [PATCH] Remove unused but beautiful product of me being with my muse
 :(

---
 tfw/components/pipe_io/__init__.py        |  2 +-
 tfw/components/pipe_io/pipe_io_handler.py | 37 -----------------------
 2 files changed, 1 insertion(+), 38 deletions(-)

diff --git a/tfw/components/pipe_io/__init__.py b/tfw/components/pipe_io/__init__.py
index 54bc368..2160960 100644
--- a/tfw/components/pipe_io/__init__.py
+++ b/tfw/components/pipe_io/__init__.py
@@ -1,2 +1,2 @@
-from .pipe_io_handler import PipeIOHandler, PipeIOHandlerBase, TransformerPipeIOHandler, CommandHandler
+from .pipe_io_handler import PipeIOHandler, PipeIOHandlerBase, CommandHandler
 from .pipe_connector import ProxyPipeConnectorHandler
diff --git a/tfw/components/pipe_io/pipe_io_handler.py b/tfw/components/pipe_io/pipe_io_handler.py
index 671f1db..55ea133 100644
--- a/tfw/components/pipe_io/pipe_io_handler.py
+++ b/tfw/components/pipe_io/pipe_io_handler.py
@@ -59,43 +59,6 @@ class PipeIOHandler(PipeIOHandlerBase):
         self.connector.send_message(json)
 
 
-class TransformerPipeIOHandler(PipeIOHandlerBase):
-    # pylint: disable=too-many-arguments
-    def __init__(
-            self, in_pipe_path, out_pipe_path,
-            transform_in_cmd, transform_out_cmd,
-            permissions=DEFAULT_PERMISSIONS
-    ):
-        self._transform_in = partial(self._transform_message, transform_in_cmd)
-        self._transform_out = partial(self._transform_message, transform_out_cmd)
-        super().__init__(in_pipe_path, out_pipe_path, permissions)
-
-    @staticmethod
-    def _transform_message(transform_cmd, message):
-        proc = run(
-            transform_cmd,
-            input=message,
-            stdout=PIPE,
-            stderr=PIPE,
-            shell=True
-        )
-        if proc.returncode == 0:
-            return proc.stdout
-        raise ValueError(f'Transforming message {message} failed!')
-
-    def handle_event(self, message, _):
-        json_bytes = dumps(message).encode()
-        transformed_bytes = self._transform_out(json_bytes)
-        if transformed_bytes:
-            self.pipe_io.send_message(transformed_bytes)
-
-    def handle_pipe_event(self, message_bytes):
-        transformed_bytes = self._transform_in(message_bytes)
-        if transformed_bytes:
-            json_message = loads(transformed_bytes)
-            self.connector.send_message(json_message)
-
-
 class CommandHandler(PipeIOHandler):
     def __init__(self, command, permissions=DEFAULT_PERMISSIONS):
         super().__init__(