add tasks for rules evaluation

Signed-off-by: tdruez <tdruez@aboutcode.org>

Author: tdruez

policy/engine.py

@@ -50,13 +50,13 @@ def evaluate_rule(policy_rule, product):
         return None
 
 
-def evaluate_rules(dataspace, product):
+def evaluate_rules(product):
     """
     Evaluate all active PolicyRules for the given product.
     Returns the list of active ProductPolicyViolation instances.
     """
     violations = []
-    for policy_rule in PolicyRule.objects.scope(dataspace).active():
+    for policy_rule in PolicyRule.objects.scope(product.dataspace).active():
         violation = evaluate_rule(policy_rule, product)
         if violation:
             violations.append(violation)

policy/tasks.py

@@ -0,0 +1,35 @@
+#
+# Copyright (c) nexB Inc. and others. All rights reserved.
+# DejaCode is a trademark of nexB Inc.
+# SPDX-License-Identifier: AGPL-3.0-only
+# See https://github.com/aboutcode-org/dejacode for support or download.
+# See https://aboutcode.org for more information about AboutCode FOSS projects.
+#
+
+from django.apps import apps
+
+from django_rq import job
+
+from policy.engine import evaluate_rules
+
+
+@job
+def evaluate_product_rules_task(product_uuid):
+    """Evaluate all active PolicyRules for the given product UUID."""
+    Product = apps.get_model("product_portfolio", "product")
+
+    try:
+        product = Product.objects.select_related("dataspace").get(uuid=product_uuid)
+    except Product.DoesNotExist:
+        return
+
+    evaluate_rules(product)
+
+
+@job
+def evaluate_all_products_rules_task():
+    """Enqueue evaluate_product_rules_task for every product."""
+    Product = apps.get_model("product_portfolio", "product")
+
+    for product in Product.objects.select_related("dataspace").all():
+        evaluate_product_rules_task.delay(product_uuid=product.uuid)