Remove encoding check (#279)
* remove encoding check
* remove explicit string escaping when failure to encode as json
diff --git a/provider/consumer.py b/provider/consumer.py
index 3819072..4bf62cf 100644
--- a/provider/consumer.py
+++ b/provider/consumer.py
@@ -450,13 +450,6 @@
return offsets
def __encodeMessageIfNeeded(self, value):
- # let's make sure whatever data we're getting is utf-8 encoded
- try:
- value = value.encode('utf-8')
- except UnicodeDecodeError:
- logging.warn('[{}] Value contains non-unicode bytes. Replacing invalid bytes.'.format(self.trigger))
- value = unicode(value, errors='replace').encode('utf-8')
-
if self.encodeValueAsJSON:
try:
parsed = json.loads(value)
@@ -465,7 +458,6 @@
except ValueError:
# no big deal, just return the original value
logging.warn('[{}] I was asked to encode a message as JSON, but I failed.'.format(self.trigger))
- value = "\"{}\"".format(value)
pass
elif self.encodeValueAsBase64:
try: