CH-67 Add background initialization for auth and events to main.py template

Author: condar-metacell

application-templates/django-app/api/templates/main.jinja2

@@ -66,10 +66,12 @@ async def add_process_time_header(request: Request, call_next):
 
 if os.environ.get('KUBERNETES_SERVICE_HOST', None):
     # init the auth service when running in/for k8s
-    from cloudharness_django.services import init_services, get_auth_service
-    init_services()
+    from cloudharness_django.services import init_services_in_background, get_auth_service
+    init_services_in_background()
+
     # start the kafka event listener when running in/for k8s
-    import cloudharness_django.services.events
+    from cloudharness_django.services.events import init_listener_in_background
+    init_listener_in_background()
 
 async def has_access():
     """

infrastructure/common-images/cloudharness-django/libraries/cloudharness-django/cloudharness_django/services/__init__.py

@@ -43,3 +43,28 @@ def init_services(
         admin_role=admin_role)
     _user_service = UserService(_auth_service)
     return _auth_service
+
+
+def init_services_in_background(
+        client_name: str = settings.KC_CLIENT_NAME,
+        client_roles: List[str] = settings.KC_ALL_ROLES,
+        privileged_roles: List[str] = settings.KC_PRIVILEGED_ROLES,
+        admin_role: str = settings.KC_ADMIN_ROLE,
+        default_user_role: str = settings.KC_DEFAULT_USER_ROLE
+):
+    import threading
+    import time
+    from cloudharness import log
+
+    def background_operation():
+        services_initialized = False
+
+        while not services_initialized:
+            try:
+                init_services(client_name, client_roles, privileged_roles, admin_role, default_user_role)
+                services_initialized = True
+            except:
+                log.exception("Error initializing services. Retrying in 5 seconds...")
+                time.sleep(5)
+
+    threading.Thread(target=background_operation).start()

infrastructure/common-images/cloudharness-django/libraries/cloudharness-django/cloudharness_django/services/events.py

@@ -96,3 +96,23 @@ def init_listener():
         _message_service_singleton = KeycloakMessageService(settings.PROJECT_NAME).setup_event_service()
 
     _message_service_singleton.setup_event_service()
+
+
+def init_listener_in_background():
+    import threading
+    import time
+    from cloudharness import log
+
+    def background_operation():
+        listener_initialized = False
+
+        while not listener_initialized:
+            try:
+                init_listener()
+                log.info('User sync events listener started')
+                listener_initialized = True
+            except:
+                log.exception('Error initializing event queue. Retrying in 5 seconds...')
+                time.sleep(5)
+
+    threading.Thread(target=background_operation).start()