my bad

Author: Sebastian Molenda

tests/integrational/native_threads/subscribe/test_subscribe.py

@@ -39,7 +39,7 @@ class TestPubNubSubscription(unittest.TestCase):
     @pn_vcr.use_cassette('tests/integrational/fixtures/native_threads/subscribe/subscribe_unsubscribe.json',
                          filter_query_parameters=['seqn', 'pnsdk', 'tr', 'tt'], serializer='pn_json',
                          allow_playback_repeats=True)
-    def test_subscribe_unsubscribe(self):
+    def orig_test_subscribe_unsubscribe(self):
         pubnub = PubNub(pnconf_env_copy(enable_subscribe=True, daemon=True))
         ch = "test-subscribe-sub-unsub"
 
@@ -68,7 +68,7 @@ def test_subscribe_unsubscribe(self):
         finally:
             pubnub.stop()
 
-    def test_subscribe_pub_unsubscribe(self):
+    def orig_test_subscribe_pub_unsubscribe(self):
         ch = "test-subscribe-pub-unsubscribe"
         pubnub = PubNub(pnconf_env_copy(enable_subscribe=True, daemon=True))
         subscribe_listener = SubscribeListener()
@@ -104,7 +104,7 @@ def test_subscribe_pub_unsubscribe(self):
         finally:
             pubnub.stop()
 
-    def test_join_leave(self):
+    def orig_test_join_leave(self):
         ch = helper.gen_channel("test-subscribe-join-leave")
         pubnub = PubNub(pnconf_env_copy(enable_subscribe=True, daemon=True))
         pubnub_listener = PubNub(pnconf_env_copy(enable_subscribe=True, daemon=True))
@@ -153,7 +153,7 @@ def test_join_leave(self):
     @pn_vcr.use_cassette('tests/integrational/fixtures/native_threads/subscribe/cg_subscribe_unsubscribe.json',
                          filter_query_parameters=['seqn', 'pnsdk', 'tr', 'tt'], serializer='pn_json',
                          allow_playback_repeats=True)
-    def test_cg_subscribe_unsubscribe(self):
+    def orig_test_cg_subscribe_unsubscribe(self):
         ch = "test-subscribe-unsubscribe-channel"
         gr = "test-subscribe-unsubscribe-group"
 
@@ -188,7 +188,7 @@ def test_cg_subscribe_unsubscribe(self):
     @pn_vcr.use_cassette('tests/integrational/fixtures/native_threads/subscribe/subscribe_cg_publish_unsubscribe.json',
                          filter_query_parameters=['seqn', 'pnsdk', 'tr', 'tt'], serializer='pn_json',
                          allow_playback_repeats=True)
-    def test_subscribe_cg_publish_unsubscribe(self):
+    def orig_test_subscribe_cg_publish_unsubscribe(self):
         ch = "test-subscribe-unsubscribe-channel"
         gr = "test-subscribe-unsubscribe-group"
         message = "hey"
@@ -225,7 +225,7 @@ def test_subscribe_cg_publish_unsubscribe(self):
 
         pubnub.stop()
 
-    def test_subscribe_cg_join_leave(self):
+    def orig_test_subscribe_cg_join_leave(self):
         ch = helper.gen_channel("test-subscribe-unsubscribe-channel")
         gr = helper.gen_channel("test-subscribe-unsubscribe-group")
         pubnub = PubNub(pnconf_env_copy(enable_subscribe=True, daemon=True))
@@ -282,7 +282,7 @@ def test_subscribe_cg_join_leave(self):
         pubnub.stop()
         pubnub_listener.stop()
 
-    def test_subscribe_pub_unencrypted_unsubscribe(self):
+    def orig_test_subscribe_pub_unencrypted_unsubscribe(self):
         ch = helper.gen_channel("test-subscribe-pub-unencrypted-unsubscribe")
 
         pubnub_plain = PubNub(pnconf_env_copy(enable_subscribe=True, daemon=True))
@@ -332,7 +332,7 @@ def test_subscribe_pub_unencrypted_unsubscribe(self):
         finally:
             pubnub.stop()
 
-    def test_subscribe_retry_policy_none(self):
+    def orig_test_subscribe_retry_policy_none(self):
         ch = "test-subscribe-retry-policy-none"
         pubnub = PubNub(pnconf_env_copy(enable_subscribe=True, daemon=True, origin='127.0.0.1',
                                         reconnect_policy=PNReconnectionPolicy.NONE))
@@ -348,7 +348,7 @@ def test_subscribe_retry_policy_none(self):
         except PubNubException as e:
             self.fail(e)
 
-    def test_subscribe_retry_policy_linear(self):
+    def orig_test_subscribe_retry_policy_linear(self):
         # we don't test the actual delay calculation here, just everything around it
         def mock_calculate(*args, **kwargs):
             return 0.2
@@ -371,7 +371,7 @@ def mock_calculate(*args, **kwargs):
 
             assert calculate_mock.call_count == LinearDelay.MAX_RETRIES + 1
 
-    def test_subscribe_retry_policy_exponential(self):
+    def orig_test_subscribe_retry_policy_exponential(self):
         # we don't test the actual delay calculation here, just everything around it
         def mock_calculate(*args, **kwargs):
             return 0.2
@@ -394,7 +394,7 @@ def mock_calculate(*args, **kwargs):
 
             assert calculate_mock.call_count == ExponentialDelay.MAX_RETRIES + 1
 
-    def test_subscribe_retry_policy_linear_with_max_retries(self):
+    def orig_test_subscribe_retry_policy_linear_with_max_retries(self):
         # we don't test the actual delay calculation here, just everything around it
         def mock_calculate(*args, **kwargs):
             return 0.2
@@ -418,7 +418,7 @@ def mock_calculate(*args, **kwargs):
 
             assert calculate_mock.call_count == 3
 
-    def test_subscribe_retry_policy_exponential_with_max_retries(self):
+    def orig_test_subscribe_retry_policy_exponential_with_max_retries(self):
         # we don't test the actual delay calculation here, just everything around it
         def mock_calculate(*args, **kwargs):
             return 0.2
@@ -442,7 +442,7 @@ def mock_calculate(*args, **kwargs):
 
             assert calculate_mock.call_count == 3
 
-    def test_subscribe_retry_policy_linear_with_custom_interval(self):
+    def orig_test_subscribe_retry_policy_linear_with_custom_interval(self):
         # we don't test the actual delay calculation here, just everything around it
         def mock_calculate(*args, **kwargs):
             return 0.2