fix: add support for extracted activities in git integration v2 (#3370)

Author: mbani01

services/apps/git_integration/src/crowdgit/services/commit/commit_service.py

@@ -437,9 +437,11 @@ def create_activities_from_commit(
         Args:
             remote: The remote repository URL
             commit: The commit dictionary containing commit data
+            segment_id: Segment identifier
+            integration_id: Integration identifier
 
         Returns:
-            List of activity dictionaries
+            Tuple of (activities_db, activities_queue) lists
         """
         activities_db = []
         activities_queue = []
@@ -497,6 +499,40 @@ def create_activities_from_commit(
             activities_db.append(activity_db)
             activities_queue.append(activity_kafka)
 
+        # Process extracted activities from commit message
+        extracted_activities = CommitService.extract_activities(commit["message"])
+        for extracted_activity in extracted_activities:
+            activity_type, member_data = list(extracted_activity.items())[0]
+
+            # Convert activity type to lowercase and add "-commit" suffix
+            # This matches the legacy behavior: "signed-off-by" -> "signed-off-commit"
+            activity_type = activity_type.lower().replace("-by", "") + "-commit"
+
+            member = {
+                "username": member_data["email"],
+                "displayName": member_data["name"],
+                "emails": [member_data["email"]],
+            }
+
+            # Generate unique source ID for extracted activity
+            source_id = hashlib.sha1(
+                (commit_hash + activity_type + member_data["email"]).encode("utf-8")
+            ).hexdigest()
+            activity = CommitService.create_activity(
+                remote=remote,
+                commit=commit,
+                activity_type=activity_type,
+                member=member,
+                source_id=source_id,
+                source_parent_id=commit_hash,
+                segment_id=segment_id,
+            )
+            activity_db, activity_kafka = CommitService.prepare_activity_for_db_and_queue(
+                activity, segment_id, integration_id
+            )
+            activities_db.append(activity_db)
+            activities_queue.append(activity_kafka)
+
         return activities_db, activities_queue
 
     @staticmethod

services/apps/git_integration/src/crowdgit/settings.py

@@ -15,7 +15,9 @@ def load_env_var(key: str, required=True, default=None):
 CROWD_DB_DATABASE = load_env_var("CROWD_DB_DATABASE")
 WORKER_POLLING_INTERVAL_SEC = int(load_env_var("WORKER_POLLING_INTERVAL_SEC", default=5))
 WORKER_ERROR_BACKOFF_SEC = int(load_env_var("WORKER_ERROR_BACKOFF_SEC", default=10))
-REPOSITORY_UPDATE_INTERVAL_HOURS = int(load_env_var("REPOSITORY_UPDATE_INTERVAL_HOURS", default=24))
+REPOSITORY_UPDATE_INTERVAL_HOURS = int(
+    load_env_var("REPOSITORY_UPDATE_INTERVAL_HOURS", default=24)
+)
 MAX_WORKER_PROCESSES = int(load_env_var("MAX_WORKER_PROCESSES", default=min(4, os.cpu_count())))
 DEFAULT_TENANT_ID = load_env_var(
     "CROWD_SSO_LF_TENANT_ID", default="875c38bd-2b1b-4e91-ad07-0cfbabb4c49f"