Extra debug information added to mercury request/response

spotify/mercury/request.py

@@ -111,12 +111,17 @@ def reply(self, header, data):
  else:
  items = self.reply_mercury(header.content_type, data)
 
+ uris = []
+
  for x, (content_type, internal) in enumerate(items):
  uri = self.update_response(
  self.prepared_requests[x], header,
  content_type, internal
  )
 
+ uris.append(uri)
+
+ log.debug('Received %s item(s) - %s', len(uris), repr(uris))
  self.respond()
 
  def reply_mercury(self, content_type, data):
@@ -182,8 +187,12 @@ def get_items(self):
  def respond(self):
  # Check if all objects have been received
  if not self.response or not all(self.response.values()):
+ awaiting = [key for (key, value) in self.response.items() if not value]
+ log.debug('Waiting for %s item(s) - %s', len(awaiting), repr(awaiting))
  return False
 
+ log.debug('Building object(s) from %s item(s)', len(self.response))
+
  items = list(self.get_items()) or self.response.values()
 
  result = []
@@ -204,6 +213,8 @@ def respond(self):
 
  result.append(item)
 
+ log.debug('Returning %s object(s) to response callback', len(result))
+
  # Emit success event
  if len(self.requests) == 1 and not self.multi:
  self.emit('success', result[0] if result else None)