feat: separate studio config and handler

eox_tenant/apps.py

@@ -37,7 +37,7 @@ class EdunextOpenedxExtensionsTenantConfig(AppConfig):
                 'relative_path': 'signals',
                 'receivers': [
                     {
-                        'receiver_func_name': 'start_tenant',
+                        'receiver_func_name': 'start_lms_tenant',
                         'signal_path': 'django.core.signals.request_started',
                     },
                     {
@@ -53,7 +53,7 @@ class EdunextOpenedxExtensionsTenantConfig(AppConfig):
                         'signal_path': 'celery.signals.before_task_publish',
                     },
                     {
-                        'receiver_func_name': 'start_async_tenant',
+                        'receiver_func_name': 'start_async_lms_tenant',
                         'signal_path': 'celery.signals.task_prerun',
                     },
                     {
@@ -74,15 +74,15 @@ class EdunextOpenedxExtensionsTenantConfig(AppConfig):
                 'relative_path': 'signals',
                 'receivers': [
                     {
-                        'receiver_func_name': 'start_tenant',
+                        'receiver_func_name': 'start_studio_tenant',
                         'signal_path': 'django.core.signals.request_started',
                     },
                     {
                         'receiver_func_name': 'tenant_context_addition',
                         'signal_path': 'celery.signals.before_task_publish',
                     },
                     {
-                        'receiver_func_name': 'start_async_tenant',
+                        'receiver_func_name': 'start_async_studio_tenant',
                         'signal_path': 'celery.signals.task_prerun',
                     },
                 ],

eox_tenant/constants.py

@@ -2,3 +2,4 @@
 from django.conf import settings
 
 LMS_ENVIRONMENT = getattr(settings, "SERVICE_VARIANT", None) == "lms"
+CMS_ENVIRONMENT = getattr(settings, "SERVICE_VARIANT", None) == "cms"

eox_tenant/models.py

@@ -183,7 +183,7 @@ def get_organizations(self):
         return org_filter
 
     @classmethod
-    def get_configs_for_domain(cls, domain):
+    def get_configs_for_domain(cls, domain, config_key):
         """
         Get edxapp configuration using a domain. There is a compat layer to support microsite until
         deprecation.
@@ -194,7 +194,7 @@ def get_configs_for_domain(cls, domain):
         config = TenantConfig.objects.get_configurations(domain=domain)
 
         if config:
-            return config["lms_configs"], config["external_key"]
+            return config[config_key], config["external_key"]
 
         return {}, None
 

eox_tenant/receivers_helpers.py

@@ -6,7 +6,7 @@
 from eox_tenant.models import Microsite, TenantConfig
 
 
-def get_tenant_config_by_domain(domain):
+def get_tenant_config_by_domain(domain, config_key):
     """
     Reach for the configuration for a given domain.
 
@@ -20,7 +20,7 @@ def get_tenant_config_by_domain(domain):
     if not getattr(settings, 'USE_EOX_TENANT', False):
         return {}, None
 
-    configurations, external_key = TenantConfig.get_configs_for_domain(domain)
+    configurations, external_key = TenantConfig.get_configs_for_domain(domain, config_key)
 
     if configurations and external_key:
         return configurations, external_key

eox_tenant/signals.py

@@ -38,11 +38,11 @@
 EOX_MAX_CONFIG_OVERRIDE_SECONDS = getattr(base_settings, "EOX_MAX_CONFIG_OVERRIDE_SECONDS", 300)
 
 
-def _update_settings(domain):
+def _update_settings(domain, config_key):
     """
     Perform the override procedure on the settings object
     """
-    config, tenant_key = get_tenant_config_by_domain(domain)
+    config, tenant_key = get_tenant_config_by_domain(domain, config_key)
 
     if not config.get("EDNX_USE_SIGNAL"):
         LOG.info("Site %s, does not use eox_tenant signals", domain)
@@ -157,9 +157,24 @@ def _ttl_reached():
     return False
 
 
-def start_tenant(sender, environ, **kwargs):  # pylint: disable=unused-argument
+def start_lms_tenant(sender, environ, **kwargs):  # pylint: disable=unused-argument
+    """
+    This function runs every time a request is started in LMS.
+    Read documentation of `_start_tenant` for more details.
+    """
+    _start_tenant(environ, "lms_configs")
+
+
+def start_studio_tenant(sender, environ, **kwargs):  # pylint: disable=unused-argument
+    """
+    This function runs every time a request is started in studio.
+    Read documentation of `_start_tenant` for more details.
+    """
+    _start_tenant(environ, "studio_configs")
+
+
+def _start_tenant(environ, config_key):
     """
-    This function runs every time a request is started.
     It will analyze the current settings object, the domain from the incoming
     request and the configuration stored in the tenants for this domain.
 
@@ -182,7 +197,7 @@ def start_tenant(sender, environ, **kwargs):  # pylint: disable=unused-argument
         return
 
     # Do the update
-    _update_settings(domain)
+    _update_settings(domain, config_key)
 
 
 def finish_tenant(sender, **kwargs):  # pylint: disable=unused-argument
@@ -219,9 +234,24 @@ def tenant_context_addition(sender, body, headers, *args, **kwargs):  # pylint:
     body['kwargs']['eox_tenant_sender'] = get_host_func(body)
 
 
-def start_async_tenant(sender, *args, **kwargs):  # pylint: disable=unused-argument
+def start_async_lms_tenant(sender, *args, **kwargs):  # pylint: disable=unused-argument
+    """
+    Receiver that runs on the LMS async process to update the settings accordingly to the tenant.
+    Read documentation of `_start_tenant` for more details.
+    """
+    _start_async_tenant(sender, "lms_configs")
+
+
+def start_async_studio_tenant(sender, *args, **kwargs):  # pylint: disable=unused-argument
+    """
+    Receiver that runs on the studio async process to update the settings accordingly to the tenant.
+    Read documentation of `_start_tenant` for more details.
+    """
+    _start_async_tenant(sender, "studio_configs")
+
+
+def _start_async_tenant(sender, config_key):
     """
-    Receiver that runs on the async process to update the settings accordingly to the tenant.
     Dispatched before a task is executed.
     See:
        https://celery.readthedocs.io/en/latest/userguide/signals.html#task-prerun
@@ -245,7 +275,7 @@ def start_async_tenant(sender, *args, **kwargs):  # pylint: disable=unused-argum
         return
 
     # Do the update
-    _update_settings(domain)
+    _update_settings(domain, config_key)
 
 
 def update_tenant_organizations(instance, **kwargs):  # pylint: disable=unused-argument

eox_tenant/test/test_receivers_helpers.py

@@ -34,7 +34,9 @@ def setUp(self):
                 "course_org_filter": ["test5-org", "test1-org"],
                 "value-test": "Hello-World3",
             },
-            studio_configs={},
+            studio_configs={
+                "value-test": "studio",
+            },
             theming_configs={},
             meta={},
         )
@@ -44,11 +46,11 @@ def setUp(self):
             config=TenantConfig.objects.get(external_key="tenant-key1"),
         )
 
-    def test_tenant_get_config_by_domain(self):
+    def test_tenant_get_lms_config_by_domain(self):
         """
         Test to get the configuration and external key for a given domain.
         """
-        configurations, external_key = get_tenant_config_by_domain("domain1")
+        configurations, external_key = get_tenant_config_by_domain("domain1", "lms_configs")
 
         self.assertEqual(external_key, "tenant-key1")
         self.assertDictEqual(
@@ -59,12 +61,34 @@ def test_tenant_get_config_by_domain(self):
             },
         )
 
-        configurations, external_key = get_tenant_config_by_domain("domain2")
+    def test_tenant_get_studio_config_by_domain(self):
+        """
+        Test to get the configuration and external key for a given domain.
+        """
+        configurations, external_key = get_tenant_config_by_domain("domain1", "studio_configs")
+
+        self.assertEqual(external_key, "tenant-key1")
+        self.assertDictEqual(
+            configurations,
+            {
+                "value-test": "studio",
+            },
+        )
+
+    def test_no_tenant_get_config_by_domain(self):
+        """
+        Test to get the configuration and external key for a non-existent domain.
+        """
+        configurations, external_key = get_tenant_config_by_domain("domain2", "lms_configs")
 
         self.assertEqual(external_key, None)
         self.assertDictEqual(configurations, {})
 
-        configurations, external_key = get_tenant_config_by_domain("first.test.prod.edunext")
+    def test_microsite_get_config_by_domain(self):
+        """
+        Test to get the configuration and external key for a given domain from Microsite table.
+        """
+        configurations, external_key = get_tenant_config_by_domain("first.test.prod.edunext", "lms_configs")
 
         self.assertEqual(external_key, "test_fake_key")
         self.assertDictEqual(