From ff23314d3302f85f376672d65bcac5cb103c4590 Mon Sep 17 00:00:00 2001
From: chr <chr@cybre.space>
Date: Fri, 3 Apr 2020 03:53:24 +0000
Subject: [PATCH] attempted bugfixes

---
 wrapper.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/wrapper.py b/wrapper.py
index c5ce272..4a67585 100644
--- a/wrapper.py
+++ b/wrapper.py
@@ -28,6 +28,7 @@ class ProcessWrapper:
 
     def send(self, msg):
         self.proc.stdin.write(msg)
+        self.proc.stdin.flush()
 
     def wait(self):
         return self.proc.wait()
@@ -55,9 +56,12 @@ def send_process_output(
 def relay_queue_input(
     process: ProcessWrapper, msg_queue: message_queue.MessageQueue
 ):
+    log = LOG.getChild("relay_input")
     for message in msg_queue:
+        log.debug(message)
         if "command" in message:
-            process.send(message["command"])
+            log.debug("forwarding to process")
+            process.send(message["command"] + "\n")
         else:
             LOG.debug(message)