Blob Blame History Raw
From 436a1f289231c5d7276be0fbb427c6d079c24f4e Mon Sep 17 00:00:00 2001
From: clime <clime@redhat.com>
Date: Sat, 24 Feb 2018 06:46:33 +0100
Subject: [PATCH] [backend] monkey-patch bytes vs. str problem in msgbus

---
 backend/backend/msgbus.py | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/backend/msgbus.py b/backend/msgbus.py
index 50e9a73a..958d8071 100644
--- a/backend/msgbus.py
+++ b/backend/msgbus.py
@@ -237,6 +237,13 @@ class MsgBusFedmsg(MsgBus):
         }
         content.update(kwargs)
 
+        self.log.info("Preprocessing message content: {}".format(content))
+        for key, val in content.items():
+            if isinstance(val, bytes):
+                self.log.warning("{} for key {} is of type bytes. Converting."
+                                 .format(val, key))
+                content[key] = val.decode('utf-8')
+
         if topic in self.messages:
             for key in self.messages[topic]:
                 content[key] = self.messages[topic][key].format(**content)
@@ -244,4 +251,5 @@ class MsgBusFedmsg(MsgBus):
         self.send(topic, content)
 
     def _send(self, topic, content, headers):
+        self.log.info("Sending content: {}".format(content))
         fedmsg.publish(modname='copr', topic=topic, msg=content)
-- 
2.14.3