Blob Blame History Raw
From ee811019b09bf775ff79b0a181f758d3197c733d 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..a706e5cc 100644
--- a/backend/msgbus.py
+++ b/backend/msgbus.py
@@ -244,4 +244,12 @@ class MsgBusFedmsg(MsgBus):
         self.send(topic, content)
 
     def _send(self, topic, content, headers):
+        self.log.info("Preprocessing message 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')
+
         fedmsg.publish(modname='copr', topic=topic, msg=content)
-- 
2.14.3