standard logging module

Author: superdiana

opentok/opentok.py

@@ -12,6 +12,7 @@
 import xml.dom.minidom as xmldom  # create_session
 from jose import jwt  # _create_jwt_auth_header
 import random  # _create_jwt_auth_header
+import logging  # logging
 
 # compat
 from six.moves.urllib.parse import urlencode
@@ -76,6 +77,9 @@ class ArchiveModes(Enum):
     """The session will be automatically archived."""
 
 
+logger = logging.getLogger("opentok")
+
+
 class OpenTok(object):
     """Use this SDK to create tokens and interface with the server-side portion
     of the Opentok API.
@@ -370,6 +374,13 @@ def create_session(
             options[u("location")] = location
 
         try:
+            logger.debug(
+                "POST to %r with params %r, headers %r, proxies %r",
+                self.endpoints.session_url(),
+                options,
+                self.headers(),
+                self.proxies,
+            )
             response = requests.post(
                 self.endpoints.session_url(),
                 data=options,
@@ -494,6 +505,14 @@ def start_archive(
             "resolution": resolution,
         }
 
+        logger.debug(
+            "POST to %r with params %r, headers %r, proxies %r",
+            self.endpoints.archive_url(),
+            json.dumps(payload),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.post(
             self.endpoints.archive_url(),
             data=json.dumps(payload),
@@ -533,6 +552,13 @@ def stop_archive(self, archive_id):
 
         :rtype: The Archive object corresponding to the archive being stopped.
         """
+        logger.debug(
+            "POST to %r with headers %r, proxies %r",
+            self.endpoints.archive_url(archive_id) + "/stop",
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.post(
             self.endpoints.archive_url(archive_id) + "/stop",
             headers=self.json_headers(),
@@ -561,6 +587,13 @@ def delete_archive(self, archive_id):
 
         :param String archive_id: The archive ID of the archive to be deleted.
         """
+        logger.debug(
+            "DELETE to %r with headers %r, proxies %r",
+            self.endpoints.archive_url(archive_id),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.delete(
             self.endpoints.archive_url(archive_id),
             headers=self.json_headers(),
@@ -584,6 +617,13 @@ def get_archive(self, archive_id):
 
         :rtype: The Archive object.
         """
+        logger.debug(
+            "GET to %r with headers %r, proxies %r",
+            self.endpoints.archive_url(archive_id),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.get(
             self.endpoints.archive_url(archive_id),
             headers=self.json_headers(),
@@ -623,6 +663,13 @@ def get_archives(self, offset=None, count=None, session_id=None):
 
         endpoint = self.endpoints.archive_url() + "?" + urlencode(params)
 
+        logger.debug(
+            "GET to %r with headers %r, proxies %r",
+            endpoint,
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.get(
             endpoint,
             headers=self.json_headers(),
@@ -661,6 +708,14 @@ def signal(self, session_id, payload, connection_id=None):
         the signal is sent to the specified client. Otherwise, the signal is sent to all clients
         connected to the session
         """
+        logger.debug(
+            "POST to %r with params %r, headers %r, proxies %r",
+            self.endpoints.signaling_url(session_id, connection_id),
+            json.dumps(payload),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.post(
             self.endpoints.signaling_url(session_id, connection_id),
             data=json.dumps(payload),
@@ -700,6 +755,14 @@ def get_stream(self, session_id, stream_id):
         -layoutClassList: It's an array of the layout classes for the stream
         """
         endpoint = self.endpoints.get_stream_url(session_id, stream_id)
+
+        logger.debug(
+            "GET to %r with headers %r, proxies %r",
+            endpoint,
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.get(
             endpoint,
             headers=self.json_headers(),
@@ -730,6 +793,13 @@ def list_streams(self, session_id):
         """
         endpoint = self.endpoints.get_stream_url(session_id)
 
+        logger.debug(
+            "GET to %r with headers %r, proxies %r",
+            endpoint,
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.get(
             endpoint,
             headers=self.json_headers(),
@@ -758,6 +828,14 @@ def force_disconnect(self, session_id, connection_id):
         :param String connection_id: The connection ID of the client that will be disconnected
         """
         endpoint = self.endpoints.force_disconnect_url(session_id, connection_id)
+
+        logger.debug(
+            "DELETE to %r with headers %r, proxies %r",
+            endpoint,
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.delete(
             endpoint,
             headers=self.json_headers(),
@@ -803,6 +881,15 @@ def set_archive_layout(self, archive_id, layout_type, stylesheet=None):
                 payload["stylesheet"] = stylesheet
 
         endpoint = self.endpoints.set_archive_layout_url(archive_id)
+
+        logger.debug(
+            "PUT to %r with params %r, headers %r, proxies %r",
+            endpoint,
+            json.dumps(payload),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.put(
             endpoint,
             data=json.dumps(payload),
@@ -874,6 +961,15 @@ def dial(self, session_id, token, sip_uri, options=[]):
             payload["sip"]["secure"] = options["secure"]
 
         endpoint = self.endpoints.dial_url()
+
+        logger.debug(
+            "POST to %r with params %r, headers %r, proxies %r",
+            endpoint,
+            json.dumps(payload),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.post(
             endpoint,
             data=json.dumps(payload),
@@ -919,6 +1015,15 @@ class names (Strings) to apply to the stream. For example:
         items_payload = {"items": payload}
 
         endpoint = self.endpoints.set_stream_class_lists_url(session_id)
+
+        logger.debug(
+            "PUT to %r with params %r, headers %r, proxies %r",
+            endpoint,
+            json.dumps(items_payload),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.put(
             endpoint,
             data=json.dumps(items_payload),
@@ -982,6 +1087,15 @@ def start_broadcast(self, session_id, options):
         payload.update(options)
 
         endpoint = self.endpoints.broadcast_url()
+
+        logger.debug(
+            "POST to %r with params %r, headers %r, proxies %r",
+            endpoint,
+            json.dumps(payload),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.post(
             endpoint,
             data=json.dumps(payload),
@@ -1016,6 +1130,14 @@ def stop_broadcast(self, broadcast_id):
         projectId, createdAt, updatedAt and resolution
         """
         endpoint = self.endpoints.broadcast_url(broadcast_id, stop=True)
+
+        logger.debug(
+            "POST to %r with headers %r, proxies %r",
+            endpoint,
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.post(
             endpoint,
             headers=self.json_headers(),
@@ -1050,6 +1172,14 @@ def get_broadcast(self, broadcast_id):
         projectId, createdAt, updatedAt, resolution, broadcastUrls and status
         """
         endpoint = self.endpoints.broadcast_url(broadcast_id)
+
+        logger.debug(
+            "GET to %r with headers %r, proxies %r",
+            endpoint,
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.get(
             endpoint,
             headers=self.json_headers(),
@@ -1092,6 +1222,15 @@ def set_broadcast_layout(self, broadcast_id, layout_type, stylesheet=None):
                 payload["stylesheet"] = stylesheet
 
         endpoint = self.endpoints.broadcast_url(broadcast_id, layout=True)
+
+        logger.debug(
+            "PUT to %r with params %r, headers %r, proxies %r",
+            endpoint,
+            json.dumps(payload),
+            self.json_headers(),
+            self.proxies,
+        )
+
         response = requests.put(
             endpoint,
             data=json.dumps(payload),