draft changes

Author: asadali145

src/ol_openedx_course_propagator/BUILD

@@ -1,5 +1,9 @@
 python_sources(
     name="ol_openedx_course_propagator_source",
+    dependencies=[
+        "//:external_dependencies#edx-opaque-keys",
+        "//:external_dependencies#celery",
+    ],
 )
 
 python_distribution(
@@ -15,9 +19,7 @@ python_distribution(
         zip_safe=False,
         keywords="Python edx",
         entry_points={
-            "lms.djangoapp": [
-                "ol_openedx_course_propagator = ol_openedx_course_propagator.apps:OLOpenEdxCoursePropagatorConfig",
-            ],
+            "lms.djangoapp": [],
             "cms.djangoapp": [
                 "ol_openedx_course_propagator = ol_openedx_course_propagator.apps:OLOpenEdxCoursePropagatorConfig",
             ],

src/ol_openedx_course_propagator/apps.py

@@ -8,3 +8,17 @@
 class OLOpenEdxCoursePropagatorConfig(AppConfig):
     name = "ol_openedx_course_propagator"
     verbose_name = "Open edX Course Propagator"
+
+    plugin_app = {
+        PluginSignals.CONFIG: {
+            ProjectType.CMS: {
+                PluginSignals.RECEIVERS: [
+                    {
+                        PluginSignals.RECEIVER_FUNC_NAME: "listen_for_course_publish",
+                        PluginSignals.SIGNAL_PATH: "xmodule.modulestore.django.COURSE_PUBLISHED",  # noqa: E501
+                        PluginSignals.DISPATCH_UID: "ol_openedx_course_propagator.signals.listen_for_course_publish",  # noqa: E501
+                    }
+                ],
+            },
+        },
+    }

src/ol_openedx_course_propagator/models.py

@@ -0,0 +1,16 @@
+from django.conf import settings
+from django.db import models
+from jsonfield import JSONField
+from model_utils.models import TimeStampedModel
+from opaque_keys.edx.django.models import (
+    CourseKeyField,
+    UsageKeyField,
+)
+
+class CourseSyncMasterOrg(models.Model):
+    organization = models.CharField(max_length=255, unique=True)
+
+
+class CourseSyncMapping(models.Model):
+    source_course = CourseKeyField(max_length=255)
+    target_courses = model.TextField(null=True, blank=True, help_text="Comma separated list of target course keys")

src/ol_openedx_course_propagator/signals.py

@@ -0,0 +1,41 @@
+"""
+Utility methods for ol-openedx-course-propagator plugin
+"""
+from xmodule.modulestore.django import modulestore
+from xmodule.modulestore.django import SignalHandler
+from xmodule.modulestore import ModuleStoreEnum
+from opaque_keys.edx.locator import CourseLocator
+from xmodule.modulestore.django import SignalHandler
+
+from ol_openedx_course_propagator.models import CourseSyncMasterOrg, CourseSyncMapping
+from ol_openedx_course_propagator.tasks import async_course_propagator
+
+log = logging.getLogger(__name__)
+
+
+@receiver(SignalHandler.course_published)
+def listen_for_course_publish(
+    sender,  # noqa: ARG001
+    course_key,
+    **kwargs,  # noqa: ARG001
+):
+    """
+    Copy course content from source course to destination course.
+    """
+    if CourseSyncMasterOrg.objects.filter(organization=course_key.org).exists():
+        # Get the source and destination course IDs
+        course_sync_mapping = CourseSyncMapping.objects.filter(
+            source_course=course_key
+        ).first()
+        if course_sync_mapping:
+            source_course = str(course_sync_mapping.source_course)
+            user_id = 2
+            for target_course_key in course_sync_mapping.target_courses.split(","):
+                # Call the async task to copy the course content
+                async_course_propagator.delay(user_id, source_course, target_course)
+        else:
+            log.warning(
+                "No mapping found for course %s. Skipping copy.", course_key.id
+            )
+            return
+

src/ol_openedx_course_propagator/utils.py renamed to src/ol_openedx_course_propagator/tasks.py

@@ -1,14 +1,14 @@
-"""
-Utility methods for ol-openedx-course-propagator plugin
-"""
+from celery import shared_task  # pylint: disable=import-error
+from celery.utils.log import get_task_logger
+from cms.djangoapps.contentstore.git_export_utils import GitExportError, export_to_git
+from opaque_keys.edx.keys import CourseKey
 from xmodule.modulestore.django import modulestore
-from xmodule.modulestore.django import SignalHandler
-from opaque_keys.edx.locator import CourseLocator
 
-def copy_course(user_id, source_course_id, dest_course_id):
-    """
-    Copy course content from source course to destination course.
-    """
+LOGGER = get_task_logger(__name__)
+
+
+@shared_task
+def async_course_propagator(user_id, source_course_id, dest_course_id):
     module_store = modulestore()
     source_course_key = CourseLocator.from_string(source_course_id)
     source_course_draft = source_course_key.for_branch("draft-branch")