Save the commit info from the webhook

Signed-off-by: Cristian Le <[email protected]>

Author: LecrisUT

packit_service/events/github/push.py

@@ -1,11 +1,15 @@
 # Copyright Contributors to the Packit project.
 # SPDX-License-Identifier: MIT
 
-from packit_service.service.db_project_events import AddBranchPushEventToDb
+from packit_service.service.db_project_events import AddBranchPushEventToDb, CommitInfo
 
 from .abstract import GithubEvent
 
 
+class GithubCommitInfo(CommitInfo):
+    pass
+
+
 class Commit(AddBranchPushEventToDb, GithubEvent):
     def __init__(
         self,
@@ -15,6 +19,7 @@ def __init__(
         project_url: str,
         commit_sha: str,
         commit_sha_before: str,
+        commits: list[GithubCommitInfo],
     ):
         super().__init__(project_url=project_url)
         self.repo_namespace = repo_namespace
@@ -23,6 +28,7 @@ def __init__(
         self.commit_sha = commit_sha
         self.commit_sha_before = commit_sha_before
         self.identifier = git_ref
+        self.commits = commits
 
     @classmethod
     def event_type(cls) -> str:

packit_service/events/gitlab/push.py

@@ -1,13 +1,15 @@
 # Copyright Contributors to the Packit project.
 # SPDX-License-Identifier: MIT
 
-from packit_service.service.db_project_events import (
-    AddBranchPushEventToDb,
-)
+from packit_service.service.db_project_events import AddBranchPushEventToDb, CommitInfo
 
 from .abstract import GitlabEvent
 
 
+class GitlabCommitInfo(CommitInfo):
+    pass
+
+
 class Commit(AddBranchPushEventToDb, GitlabEvent):
     def __init__(
         self,
@@ -17,6 +19,7 @@ def __init__(
         project_url: str,
         commit_sha: str,
         commit_sha_before: str,
+        commits: list[GitlabCommitInfo],
     ):
         super().__init__(project_url=project_url)
         self.repo_namespace = repo_namespace
@@ -25,6 +28,7 @@ def __init__(
         self.commit_sha = commit_sha
         self.commit_sha_before = commit_sha_before
         self.identifier = git_ref
+        self.commits = commits
 
     @classmethod
     def event_type(cls) -> str:

packit_service/service/db_project_events.py

@@ -5,7 +5,7 @@
 This file contains helper classes for events.
 """
 
-from typing import Optional
+from typing import Optional, TypedDict
 
 from ogr.abstract import GitProject
 
@@ -61,12 +61,22 @@ def get_dict(self, default_dict: Optional[dict] = None) -> dict:
         return result
 
 
+class CommitInfo(TypedDict, total=False):
+    id: str
+    title: str
+    message: str
+    added: list[str]
+    modified: list[str]
+    removed: list[str]
+
+
 class AddBranchPushEventToDb:
     git_ref: str
     repo_namespace: str
     repo_name: str
     project_url: str
     commit_sha: str
+    commits: list[CommitInfo]
     _branch: GitBranchModel = None
     _event: ProjectEventModel = None
 

packit_service/worker/parser.py

@@ -9,7 +9,7 @@
 from dataclasses import dataclass
 from datetime import datetime, timezone
 from os import getenv
-from typing import Any, Callable, ClassVar, Optional, Union
+from typing import Any, Callable, ClassVar, Optional, Union, cast
 
 from ogr.parsing import RepoUrl, parse_git_repo
 from packit.config import JobConfigTriggerType
@@ -64,8 +64,9 @@ class _GitlabCommonData:
     project_url: str
     parsed_url: Optional[RepoUrl]
     ref: str
-    head_commit: dict
+    head_commit: gitlab.push.GitlabCommitInfo
     commit_sha_before: str
+    commits: list[gitlab.push.GitlabCommitInfo]
 
     @property
     def commit_sha(self) -> str:
@@ -420,7 +421,9 @@ def get_gitlab_push_common_data(event) -> _GitlabCommonData:
         before = event.get("before")
         checkout_sha = event.get("checkout_sha")
         actor = event.get("user_username")
-        commits = event.get("commits", [])
+        commits = [
+            cast(gitlab.push.GitlabCommitInfo, commit) for commit in event.get("commits", [])
+        ]
         number_of_commits = event.get("total_commits_count")
 
         if not Parser.is_gitlab_push_a_create_event(event):
@@ -455,6 +458,7 @@ def get_gitlab_push_common_data(event) -> _GitlabCommonData:
             ref=ref,
             head_commit=head_commit,
             commit_sha_before=before,
+            commits=commits,
         )
 
     @staticmethod
@@ -515,6 +519,7 @@ def parse_gitlab_push_event(event) -> Optional[gitlab.push.Commit]:
             project_url=data.project_url,
             commit_sha=data.commit_sha,
             commit_sha_before=data.commit_sha_before,
+            commits=data.commits,
         )
 
     @staticmethod
@@ -561,13 +566,16 @@ def parse_github_push_event(event) -> Optional[github.push.Commit]:
 
         repo_url = nested_get(event, "repository", "html_url")
 
+        commits = [cast(github.push.GithubCommitInfo, commit) for commit in event.get("commits")]
+
         return github.push.Commit(
             repo_namespace=repo_namespace,
             repo_name=repo_name,
             git_ref=ref,
             project_url=repo_url,
             commit_sha=head_commit,
             commit_sha_before=before,
+            commits=commits,
         )
 
     @staticmethod