Handle deserializing older SharQ payloads

...that were present before moving to python3 where the payload format
changed.

Signed-off-by: Prashanth Pai <prashanth.pai@plivo.com>

Author: ppai-plivo

sharq/queue.py

@@ -217,6 +217,13 @@ def dequeue(self, queue_type='default'):
             return response
 
         queue_id, job_id, payload, requeues_remaining = dequeue_response
+
+        if payload is None:
+            response = {
+                'status': 'failure'
+            }
+            return response
+
         payload = deserialize_payload(payload)
 
         response = {

sharq/utils.py

@@ -65,6 +65,10 @@ def serialize_payload(payload):
 def deserialize_payload(payload):
     """Tries to deserialize the payload using msgpack.
     """
+    # Handle older SharQ payloads as well (before py3 migration)
+    if payload.startswith(b'"') and payload.endswith(b'"'):
+        return msgpack.unpackb(payload[1:-1], raw=False)
+
     return msgpack.unpackb(payload, raw=False)
 
 
@@ -83,4 +87,4 @@ def convert_to_str(queue_set):
         except Exception as e:
             queue_list.append(queue)
             pass
-    return queue_list
+    return queue_list