Pubnub 4.x

requirements.txt

@@ -1,3 +1,4 @@
 observable>=0.3.1
-pubnub==3.*
+pubnub==4.*
+pycryptodome>=3.4.4
 requests>=2.12.4

ringcentral/subscription/subscription.py

@@ -148,34 +148,37 @@ def _subscribe_at_pubnub(self):
         if not self.alive():
             raise Exception('Subscription is not alive')
 
-        from pubnub import Pubnub
-
-        s_key = self._subscription['deliveryMode']['subscriberKey']
-        self._pubnub = Pubnub(subscribe_key=s_key, ssl_on=False, publish_key='')
-
-        def callback(message, channel=''):
-            self._notify(message)
-
-        def error(message):
-            self.trigger(Events.connectionError, message)
-
-        def connect(message):
-            pass
-
-        def reconnect(message):
-            pass
-
-        def disconnect(message):
-            pass
-
-        self._pubnub.subscribe(
-            self._subscription['deliveryMode']['address'],
-            callback=callback,
-            error=error,
-            connect=connect,
-            reconnect=reconnect,
-            disconnect=disconnect
-        )
+        from pubnub.pubnub import PubNub
+        from pubnub.pnconfiguration import PNConfiguration
+        from pubnub.callbacks import SubscribeCallback
+        from pubnub.enums import PNStatusCategory
+
+        pnconf = PNConfiguration()
+        pnconf.subscribe_key = self._subscription['deliveryMode']['subscriberKey']
+        self._pubnub = PubNub(pnconf)
+
+        subscription = self
+
+        class SubscribeCallbackImpl(SubscribeCallback):
+            def presence(self, pubnub, presence):
+                pass  # handle incoming presence data
+
+            def status(self, pubnub, status):
+                if status.category == PNStatusCategory.PNUnexpectedDisconnectCategory:
+                    subscription.trigger(Events.connectionError, 'Connectivity loas')
+                    pass
+                elif status.category == PNStatusCategory.PNConnectedCategory:
+                    pass
+                elif status.category == PNStatusCategory.PNReconnectedCategory:
+                    pass
+                elif status.category == PNStatusCategory.PNDecryptionErrorCategory:
+                    pass
+
+            def message(self, pubnub, pnmessage):  # instance of PNMessageResult
+                subscription._notify(pnmessage.message)
+
+        self._pubnub.add_listener(SubscribeCallbackImpl())
+        self._pubnub.subscribe().channels(self._subscription['deliveryMode']['address']).execute()
 
     def _notify(self, message):
         message = self._decrypt(message)
@@ -185,7 +188,7 @@ def _decrypt(self, message):
         if not self.alive():
             raise Exception('Subscription is not alive')
 
-        from pubnub import AES
+        from Crypto.Cipher import AES
 
         delivery_mode = self._subscription['deliveryMode']
         is_encrypted = ('encryption' in delivery_mode) and ('encryptionKey' in delivery_mode)
@@ -201,7 +204,7 @@ def _decrypt(self, message):
 
     def _unsubscribe_at_pubnub(self):
         if self._pubnub and self.alive():
-            self._pubnub.unsubscribe(self._subscription['deliveryMode']['address'])
+            self._pubnub.unsubscribe().channels(self._subscription['deliveryMode']['address']).execute()
 
     def _get_full_events_filter(self):
         return [self._platform.create_url(e) for e in self._event_filters]

ringcentral/test/testcase.py

@@ -31,6 +31,14 @@ def get_sdk(self, mock):
             text=''
         )
 
+        matcher = re.compile('ps\.pndsn\.com')
+
+        mock.register_uri(
+            method=requests_mock.ANY,
+            url=matcher,
+            text=''
+        )
+
         return sdk
 
     def add(self, mock, method, url, body, status=200):

setup.py

@@ -20,7 +20,8 @@
     keywords=['sdk', 'ringcentral', 'connect', 'platform', 'api', 'python'],
     install_requires=[
         'observable>=0.3.1',
-        'pubnub==3.*',
+        'pubnub==4.*',
+        'pycryptodome>=3.4.4',
         'requests>=2.7.0'
     ],
     classifiers=[]