Merge branch 'main' into develop

Author: susrisha

.github/workflows/blank.yml

@@ -0,0 +1,36 @@
+# This is a basic workflow to help you get started with Actions
+
+name: CI
+
+# Controls when the workflow will run
+on:
+  # Triggers the workflow on push or pull request events but only for the "main" branch
+  push:
+    branches: [ "main" ]
+  pull_request:
+    branches: [ "main" ]
+
+  # Allows you to run this workflow manually from the Actions tab
+  workflow_dispatch:
+
+# A workflow run is made up of one or more jobs that can run sequentially or in parallel
+jobs:
+  # This workflow contains a single job called "build"
+  build:
+    # The type of runner that the job will run on
+    runs-on: ubuntu-latest
+
+    # Steps represent a sequence of tasks that will be executed as part of the job
+    steps:
+      # Checks-out your repository under $GITHUB_WORKSPACE, so your job can access it
+      - uses: actions/checkout@v3
+
+      # Runs a single command using the runners shell
+      - name: Run a one-line script
+        run: echo Hello, world!
+
+      # Runs a set of commands using the runners shell
+      - name: Run a multi-line script
+        run: |
+          echo Add other actions to build,
+          echo test, and deploy your project.

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Change log
 
+# 0.0.18
+- Adds extra checks in service bus for retries
+- Additional logging done if there is no network and  service bus crashes
+- Service bus subscription picks up messages even if there is network outtage
 
 ### 0.0.17
 - Added Unit Test Cases

README.md

@@ -239,7 +239,7 @@ In case `api_url` is not provided for `Hosted` auth provider, the core will pick
 
 #### Requesting if certain permission is valid:
 
-Use the method `has_ermission(request_params)` to know if the permission request is valid/not.
+Use the method `has_permission(request_params)` to know if the permission request is valid/not.
 
 ```python
 

src/python_ms_core/core/topic/topic.py

@@ -40,17 +40,21 @@ def process_message(self, message:str):
     # Starts listening to the messages
     def start_listening(self, provider, topic, subscription):
         with provider.client: # service bus client
-            while True:
-                logger.info('Initiatig receiver')
-                topic_receiver = provider.client.get_subscription_receiver(topic, subscription_name=subscription) # servicebusclientsubscriptionreceiver
-                with topic_receiver:
-                    for message in topic_receiver:
-                        try:
-                            self.process_message(message=str(message)) # sync call. [By default 1minute ] -> lock renewal for 300 seconds
-                        except Exception as e:
-                            print(f'Error : {e}, Invalid message received : {message}')
-                        finally:
-                            topic_receiver.complete_message(message)
+            logger.info('Initiating receiver')
+            topic_receiver = provider.client.get_subscription_receiver(topic, subscription_name=subscription) # servicebusclientsubscriptionreceiver
+            logger.info('Done')
+            with topic_receiver:
+                while True:
+                    try:
+                        for message in topic_receiver:
+                            try:
+                                self.process_message(message=str(message)) # sync call. [By default 1minute ] -> lock renewal for 300 seconds
+                            except Exception as e:
+                                print(f'Error : {e}, Invalid message received : {message}')
+                            finally:
+                                topic_receiver.complete_message(message)
+                    except Exception as et:
+                        print(f'Error in service bus connection : {et}')
                         # Change mode from PEEK_LOCK to RECEIVE_AND_DELETE
                 logger.info('Topic receiver invalidated')