chore: add unit tests

course_discovery/apps/course_metadata/management/commands/tests/test_populate_product_catalog.py

@@ -27,6 +27,7 @@ def setUp(self):
         self.organization = OrganizationFactory(partner=self.partner)
         self.course_type = CourseTypeFactory(slug=CourseType.AUDIT)
         self.source = SourceFactory.create(slug="edx")
+        self.source_2 = SourceFactory.create(slug="test-source")
         self.courses = CourseFactory.create_batch(
             2,
             product_source=self.source,
@@ -304,6 +305,93 @@ def test_populate_product_catalog_excludes_non_marketable_degrees(self):
                 # Check that the marketable degree with no language field has the default language populated
                 self.assertEqual(matching_rows[0].get("Languages"), 'en-us')
 
+    def test_populate_product_catalog_supports_multiple_product_sources(self):
+        """
+        Test that the populate_product_catalog command supports multiple product sources.
+        """
+        marketable_degree = DegreeFactory.create(
+            product_source=self.source,
+            partner=self.partner,
+            additional_metadata=None,
+            type=self.program_type,
+            status=ProgramStatus.Active,
+            marketing_slug="valid-marketing-slug",
+            title="Marketable Degree",
+            authoring_organizations=[self.organization],
+            card_image=factory.django.ImageField(),
+            product_source=self.source,
+        )
+        marketable_degree_2 = DegreeFactory.create(
+            product_source=self.source,
+            partner=self.partner,
+            additional_metadata=None,
+            type=self.program_type,
+            status=ProgramStatus.Active,
+            marketing_slug="valid-marketing-slug",
+            title="Marketable Degree - with different product sources",
+            authoring_organizations=[self.organization],
+            card_image=factory.django.ImageField(),
+            language_override=None,
+            product_source=self.source_2,
+        )
+
+        with NamedTemporaryFile() as output_csv:
+            call_command(
+                "populate_product_catalog",
+                product_type="degree",
+                output_csv=output_csv.name,
+                product_source="edx",
+                gspread_client_flag=False,
+            )
+
+            with open(output_csv.name, "r") as output_csv_file:
+                csv_reader = csv.DictReader(output_csv_file)
+                rows = list(csv_reader)
+
+                # Check that the marketable degree is in the CSV for the specified product source
+                matching_rows = [
+                    row for row in rows if row["UUID"] == str(marketable_degree.uuid.hex)
+                ]
+                self.assertEqual(
+                    len(matching_rows), 1, f"Marketable degree '{marketable_degree.title}' should be in the CSV",
+                )
+
+                # Check that the marketable degree with different product sources is not in the CSV
+                matching_rows = [
+                    row for row in rows if row["UUID"] == str(marketable_degree_2.uuid.hex)
+                ]
+                self.assertEqual(
+                    len(matching_rows), 0,
+                    f"'{marketable_degree_2.title}' with different product sources should not be in the CSV",
+                )
+
+        with NamedTemporaryFile() as output_csv:
+            call_command(
+                "populate_product_catalog",
+                product_type="degree",
+                output_csv=output_csv.name,
+                product_source="edx,test-source",
+                gspread_client_flag=False,
+            )
+
+            with open(output_csv.name, "r") as output_csv_file:
+                csv_reader = csv.DictReader(output_csv_file)
+                rows = list(csv_reader)
+
+                # Check that the marketable degree is in the CSV for the specified product sources
+                matching_rows = [
+                    row for row in rows if row["UUID"] == str(marketable_degree.uuid.hex)
+                ]
+                self.assertEqual(
+                    len(matching_rows), 1, f"Marketable degree '{marketable_degree.title}' should be in the CSV",
+                )
+                matching_rows = [
+                    row for row in rows if row["UUID"] == str(marketable_degree_2.uuid.hex)
+                ]
+                self.assertEqual(
+                    len(matching_rows), 1, f"'{marketable_degree_2.title}' should be in the CSV",
+                )
+
     def test_populate_product_catalog_with_degrees_having_overrides(self):
         """
         Test that the populate_product_catalog command includes the overridden subjects and languages for degrees.