PubNub SDK v5.1.1 release.

Author: client-engineering-bot

.pubnub.yml

@@ -1,8 +1,14 @@
 name: python
-version: 5.1.0
+version: 5.1.1
 schema: 1
 scm: github.com/pubnub/python
 changelog:
+  - version: v5.1.1
+    date: Mar 29, 2021
+    changes:
+      -
+        text: "Multiple community Pull Requests for Asyncio related code applied."
+        type: bug
   - version: v5.1.0
     date: Mar 8, 2021
     changes:

CHANGELOG.md

@@ -1,3 +1,9 @@
+## [v5.1.1](https://github.com/pubnub/python/releases/tag/v5.1.1)
+
+[Full Changelog](https://github.com/pubnub/python/compare/v5.1.0...v5.1.1)
+
+- 🐛 Multiple community Pull Requests for Asyncio related code applied. 
+
 ## [v5.1.0](https://github.com/pubnub/python/releases/tag/v5.1.0)
 
 [Full Changelog](https://github.com/pubnub/python/compare/v5.0.1...v5.1.0)

examples/asyncio/__init__.py

@@ -20,7 +20,7 @@
 logger = logging.getLogger("pubnub")
 
 
-class PublishSequenceManager(object):
+class PublishSequenceManager:
     def __init__(self, provided_max_sequence):
         self.max_sequence = provided_max_sequence
         self.next_sequence = 0
@@ -44,23 +44,13 @@ def __init__(self, initial_config):
         self._current_subdomain = 1
 
     def get_base_path(self):
-        if self.config.origin is not None:
+        if self.config.origin:
             return self.config.origin
-        # TODO: should CacheBusting be used?
-        elif False:
-            constructed_url = ("ps%s.%s" % (self._current_subdomain, BasePathManager.DEFAULT_BASE_PATH))
-
-            if self._current_subdomain == BasePathManager.MAX_SUBDOMAIN:
-                self._current_subdomain = 1
-            else:
-                self._current_subdomain += 1
-
-            return constructed_url
         else:
             return "%s.%s" % (BasePathManager.DEFAULT_SUBDOMAIN, BasePathManager.DEFAULT_BASE_PATH)
 
 
-class ReconnectionManager(object):
+class ReconnectionManager:
     INTERVAL = 3
     MINEXPONENTIALBACKOFF = 1
     MAXEXPONENTIALBACKOFF = 32
@@ -99,7 +89,7 @@ def _stop_heartbeat_timer(self):
             self._timer = None
 
 
-class StateManager(object):
+class StateManager:
     def __init__(self):
         self._channels = {}
         self._groups = {}
@@ -186,7 +176,7 @@ def _prepare_membership_list(data_storage, presence_storage, include_presence):
         return response
 
 
-class ListenerManager(object):
+class ListenerManager:
     def __init__(self, pubnub_instance):
         self._pubnub = pubnub_instance
         self._listeners = []
@@ -236,7 +226,7 @@ def announce_file_message(self, file_message):
             callback.file(self._pubnub, file_message)
 
 
-class SubscriptionManager(object):
+class SubscriptionManager:
     __metaclass__ = ABCMeta
 
     HEARTBEAT_INTERVAL_MULTIPLIER = 1000
@@ -368,7 +358,6 @@ def _handle_endpoint_call(self, raw_result, status):
                     message.only_channel_subscription = True
                 self._message_queue_put(message)
 
-        # REVIEW: is int compatible with long for Python 2
         self._timetoken = int(result.metadata.timetoken)
         self._region = int(result.metadata.region)
 
@@ -377,7 +366,7 @@ def _register_heartbeat_timer(self):
         self._stop_heartbeat_timer()
 
 
-class TelemetryManager(object):  # pylint: disable=W0612
+class TelemetryManager:
     TIMESTAMP_DIVIDER = 1000
     MAXIMUM_LATENCY_DATA_AGE = 60
     CLEAN_UP_INTERVAL = 1
@@ -459,6 +448,7 @@ def endpoint_name_for_operation(operation_type):
             PNOperationType.PNHereNowOperation: 'pres',
             PNOperationType.PNGetState: 'pres',
             PNOperationType.PNSetStateOperation: 'pres',
+            PNOperationType.PNHeartbeatOperation: 'pres',
 
             PNOperationType.PNAddChannelsToGroupOperation: 'cg',
             PNOperationType.PNRemoveChannelsFromGroupOperation: 'cg',
@@ -516,7 +506,7 @@ def endpoint_name_for_operation(operation_type):
         return endpoint
 
 
-class TokenManager(object):
+class TokenManager:
 
     def __init__(self):
         self._map = {}

examples/asyncio/http/__init__.py

@@ -39,7 +39,7 @@ def __init__(self):
     def validate(self):
         assert self.uuid is None or isinstance(self.uuid, str)
 
-        if self.uuid is None:
+        if not self.uuid:
             self.uuid = utils.uuid()
 
     def scheme(self):

examples/native_threads/__init__.py

@@ -217,8 +217,7 @@ def _perform_heartbeat_loop(self):
         def heartbeat_callback(raw_result, status):
             heartbeat_verbosity = self._pubnub.config.heartbeat_notification_options
             if status.is_error:
-                if heartbeat_verbosity == PNHeartbeatNotificationOptions.ALL or \
-                        heartbeat_verbosity == PNHeartbeatNotificationOptions.ALL:
+                if heartbeat_verbosity in (PNHeartbeatNotificationOptions.ALL, PNHeartbeatNotificationOptions.FAILURES):
                     self._listener_manager.announce_status(status)
             else:
                 if heartbeat_verbosity == PNHeartbeatNotificationOptions.ALL:
@@ -258,10 +257,16 @@ def disconnect(self):
         self._stop_subscribe_loop()
 
     def _start_worker(self):
-        consumer = NativeSubscribeMessageWorker(self._pubnub, self._listener_manager,
-                                                self._message_queue, self._consumer_event)
-        self._consumer_thread = threading.Thread(target=consumer.run,
-                                                 name="SubscribeMessageWorker")
+        consumer = NativeSubscribeMessageWorker(
+            self._pubnub,
+            self._listener_manager,
+            self._message_queue,
+            self._consumer_event
+        )
+        self._consumer_thread = threading.Thread(
+            target=consumer.run,
+            name="SubscribeMessageWorker"
+        )
         self._consumer_thread.setDaemon(True)
         self._consumer_thread.start()
 
@@ -277,7 +282,7 @@ def _start_subscribe_loop(self):
         def callback(raw_result, status):
             """ SubscribeEndpoint callback"""
             if status.is_error():
-                if status is not None and status.category == PNStatusCategory.PNCancelledCategory:
+                if status and status.category == PNStatusCategory.PNCancelledCategory:
                     return
 
                 if status.category is PNStatusCategory.PNTimeoutCategory and not self._should_stop:
@@ -286,7 +291,7 @@ def callback(raw_result, status):
 
                 logger.error("Exception in subscribe loop: %s" % str(status.error_data.exception))
 
-                if status is not None and status.category == PNStatusCategory.PNAccessDeniedCategory:
+                if status and status.category == PNStatusCategory.PNAccessDeniedCategory:
                     status.operation = PNOperationType.PNUnsubscribeOperation
                     self._listener_manager.announce_status(status)
                     self.unsubscribe_all()
@@ -465,7 +470,7 @@ def reset(self):
         self.done_event.clear()
 
 
-class NativeTelemetryManager(TelemetryManager):  # pylint: disable=W0612
+class NativeTelemetryManager(TelemetryManager):
     def store_latency(self, latency, operation_type):
         super(NativeTelemetryManager, self).store_latency(latency, operation_type)
         self.clean_up_telemetry_data()