Fix acceptance tests

Author: jguz-pubnub

.github/workflows/run-tests.yml

@@ -87,7 +87,7 @@ jobs:
 
           pip3 install --user --ignore-installed -r requirements-dev.txt
           behave --junit tests/acceptance/pam
-          behave --junit tests/acceptance/encryption/cryptor-module.feature -t=~na=python -k
+          behave --junit tests/acceptance/encryption/cryptor-module.feature -t=~na=python
           behave --junit tests/acceptance/subscribe
       - name: Expose acceptance tests reports
         uses: actions/upload-artifact@v4

pubnub/event_engine/models/states.py

@@ -568,7 +568,7 @@ def reconnect_failure(self, event: events.ReceiveReconnectFailureEvent, context:
         return PNTransition(
             state=ReceiveReconnectingState,
             context=self._context,
-            invocation=invocations.EmitStatusInvocation(PNStatusCategory.UnexpectedDisconnectCategory,
+            invocation=invocations.EmitStatusInvocation(PNStatusCategory.PNUnexpectedDisconnectCategory,
                                                         operation=PNOperationType.PNSubscribeOperation,
                                                         context=self._context)
         )

tests/acceptance/pam/steps/then_steps.py

@@ -1,5 +1,6 @@
 import json
 from behave import then
+
 from pubnub.exceptions import PubNubException
 
 
@@ -19,6 +20,12 @@ def step_impl(context, channel):
     assert context.token_resource
 
 
+@then("token {data_type} permission {permission}")
+def step_impl(context, data_type, permission):
+    assert context.token_resource
+    assert context.token_resource[permission.lower()]
+
+
 @then("the token contains the authorized UUID {test_uuid}")
 def step_impl(context, test_uuid):
     assert context.parsed_token.get("authorized_uuid") == test_uuid.strip('"')
@@ -80,6 +87,75 @@ def step_impl(context):
     context.pam_call_error = json.loads(context.pam_call_result._errormsg)
 
 
+@then("the error status code is {error_code}")
+def step_impl(context, error_code):
+    assert context.pam_call_error['status'] == int(error_code)
+
+
+@then("the auth error message is '{error_message}'")
+@then("the error message is '{error_message}'")
+def step_impl(context, error_message):
+    if 'message' in context.pam_call_error:
+        assert context.pam_call_error['message'] == error_message
+    elif 'error' in context.pam_call_error and 'message' in context.pam_call_error['error']:
+        assert context.pam_call_error['error']['message'] == error_message
+    else:
+        raise AssertionError("Unexpected payload: {}".format(context.pam_call_error))
+
+
+@then("the error detail message is not empty")
+def step_impl(context):
+    if 'error' in context.pam_call_error and 'details' in context.pam_call_error['error']:
+        assert len(context.pam_call_error['error']['details']) > 0
+        assert 'message' in context.pam_call_error['error']['details'][0]
+        assert len(context.pam_call_error['error']['details'][0]['message']) > 0
+    else:
+        raise AssertionError("Unexpected payload: {}".format(context.pam_call_error))
+
+
+@then("the error detail message is '{details_message}'")
+def step_impl(context, details_message):
+    if 'error' in context.pam_call_error and 'details' in context.pam_call_error['error']:
+        assert len(context.pam_call_error['error']['details']) > 0
+        assert 'message' in context.pam_call_error['error']['details'][0]
+        assert context.pam_call_error['error']['details'][0]['message'] == details_message
+    else:
+        raise AssertionError("Unexpected payload: {}".format(context.pam_call_error))
+
+
+@then("the error detail location is '{details_location}'")
+def step_impl(context, details_location):
+    if 'error' in context.pam_call_error and 'details' in context.pam_call_error['error']:
+        assert len(context.pam_call_error['error']['details']) > 0
+        assert 'location' in context.pam_call_error['error']['details'][0]
+        assert context.pam_call_error['error']['details'][0]['location'] == details_location
+    else:
+        raise AssertionError("Unexpected payload: {}".format(context.pam_call_error))
+
+
+@then("the error detail location type is '{details_location_type}'")
+def step_impl(context, details_location_type):
+    if 'error' in context.pam_call_error and 'details' in context.pam_call_error['error']:
+        assert len(context.pam_call_error['error']['details']) > 0
+        assert 'locationType' in context.pam_call_error['error']['details'][0]
+        assert context.pam_call_error['error']['details'][0]['locationType'] == details_location_type
+    else:
+        raise AssertionError("Unexpected payload: {}".format(context.pam_call_error))
+
+
+@then("the error service is '{error_service}'")
+def step_impl(context, error_service):
+    assert context.pam_call_error['service'] == error_service
+
+
+@then("the error source is '{error_source}'")
+def step_impl(context, error_source):
+    if 'error' in context.pam_call_error and 'source' in context.pam_call_error['error']:
+        assert context.pam_call_error['error']['source'] == error_source
+    else:
+        raise AssertionError("Unexpected payload: {}".format(context.pam_call_error))
+
+
 @then("the result is successful")
 def step_impl(context):
     assert context.publish_result.result.timetoken

tests/acceptance/subscribe/steps/then_steps.py

@@ -25,7 +25,7 @@ async def step_impl(ctx: PNContext):
     await ctx.pubnub.stop()
 
 
-@then("I observe the following")
+@then("I observe the following:")
 @async_run_until_complete
 async def step_impl(ctx):
     def parse_log_line(line: str):
@@ -74,7 +74,7 @@ async def step_impl(ctx: PNContext, wait_time: str):
     await asyncio.sleep(int(wait_time))
 
 
-@then(u'I observe the following Events and Invocations of the Presence EE')
+@then(u'I observe the following Events and Invocations of the Presence EE:')
 @async_run_until_complete
 async def step_impl(ctx):
     def parse_log_line(line: str):