diff --git a/openedx/features/enterprise_support/signals.py b/openedx/features/enterprise_support/signals.py index f3af522dc8..63acc22948 100644 --- a/openedx/features/enterprise_support/signals.py +++ b/openedx/features/enterprise_support/signals.py @@ -13,6 +13,8 @@ from django.dispatch import receiver from email_marketing.tasks import update_user from enterprise.models import EnterpriseCourseEnrollment, EnterpriseCustomer, EnterpriseCustomerUser +from integrated_channels.integrated_channel.tasks import transmit_single_learner_data +from openedx.core.djangoapps.signals.signals import COURSE_GRADE_NOW_PASSED from openedx.features.enterprise_support.tasks import clear_enterprise_customer_data_consent_share_cache from openedx.features.enterprise_support.utils import clear_data_consent_share_cache @@ -64,3 +66,15 @@ def update_dsc_cache_on_enterprise_customer_update(sender, instance, **kwargs): task_id=result.task_id, kwargs=kwargs, )) + + +@receiver(COURSE_GRADE_NOW_PASSED, dispatch_uid="new_passing_enterprise_learner") +def handle_enterprise_learner_passing_grade(sender, user, course_id, **kwargs): # pylint: disable=unused-argument + """ + Listen for a learner passing a course, transmit data to relevant integrated channel + """ + kwargs = { + 'username': six.text_type(user.username), + 'course_run_id': six.text_type(course_id) + } + transmit_single_learner_data.apply_async(kwargs=kwargs) diff --git a/openedx/features/enterprise_support/tests/test_signals.py b/openedx/features/enterprise_support/tests/test_signals.py index e5fc14dd45..0e40e3b258 100644 --- a/openedx/features/enterprise_support/tests/test_signals.py +++ b/openedx/features/enterprise_support/tests/test_signals.py @@ -6,8 +6,12 @@ import logging import ddt from django.test import TestCase from mock import patch -from student.tests.factories import UserFactory + from edx_django_utils.cache import TieredCache +from opaque_keys.edx.keys import CourseKey + +from student.tests.factories import UserFactory +from openedx.core.djangoapps.signals.signals import COURSE_GRADE_NOW_PASSED from openedx.features.enterprise_support.tests.factories import ( EnterpriseCourseEnrollmentFactory, EnterpriseCustomerFactory, @@ -104,3 +108,20 @@ class EnterpriseSupportSignals(TestCase): enterprise_customer.save() self.assertFalse(self._is_dsc_cache_found(self.user.id, self.course_id)) + + def test_handle_enterprise_learner_passing_grade(self): + """ + Test to assert transmit_single_learner_data is called when COURSE_GRADE_NOW_PASSED signal is fired + """ + with patch( + 'integrated_channels.integrated_channel.tasks.transmit_single_learner_data.apply_async', + return_value=None + ) as mock_task_apply: + course_key = CourseKey.from_string(self.course_id) + COURSE_GRADE_NOW_PASSED.disconnect(dispatch_uid='new_passing_learner') + COURSE_GRADE_NOW_PASSED.send(sender=None, user=self.user, course_id=course_key) + task_kwargs = { + 'username': self.user.username, + 'course_run_id': self.course_id + } + mock_task_apply.assert_called_once_with(kwargs=task_kwargs)