Pass release monitoring project ID to sync_release (#2263)

Pass release monitoring project ID to sync_release

So that it can be linked from the PR description.
Followup of packit/packit#2173

RELEASE NOTES BEGIN
N/A
RELEASE NOTES END

Reviewed-by: František Lachman <[email protected]>

packit_service/worker/events/new_hotness.py

@@ -20,13 +20,19 @@
 @use_for_job_config_trigger(trigger_type=JobConfigTriggerType.release)
 class NewHotnessUpdateEvent(Event):
     def __init__(
-        self, package_name: str, version: str, distgit_project_url: str, bug_id: int
+        self,
+        package_name: str,
+        version: str,
+        distgit_project_url: str,
+        bug_id: int,
+        release_monitoring_project_id: int,
     ):
         super().__init__()
         self.package_name = package_name
         self.version = version
         self.distgit_project_url = distgit_project_url
         self.bug_id = bug_id
+        self.release_monitoring_project_id = release_monitoring_project_id
 
         self._repo_url: Optional[RepoUrl] = None
         self._db_project_object: Optional[ProjectReleaseModel]

packit_service/worker/handlers/distgit.py

@@ -243,6 +243,9 @@ def sync_branch(
                 sync_default_files=not is_pull_from_upstream_job,
                 add_pr_instructions=True,
                 resolved_bugs=self.get_resolved_bugs(),
+                release_monitoring_project_id=self.data.event_dict.get(
+                    "release_monitoring_project_id"
+                ),
             )
         except PackitDownloadFailedException as ex:
             # the archive has not been uploaded to PyPI yet

packit_service/worker/parser.py

@@ -1551,6 +1551,9 @@ def parse_new_hotness_update_event(event) -> Optional[NewHotnessUpdateEvent]:
         version = nested_get(event, "trigger", "msg", "project", "version")
 
         bug_id = nested_get(event, "bug", "bug_id")
+        release_monitoring_project_id = nested_get(
+            event, "trigger", "msg", "project", "id"
+        )
 
         logger.info(
             f"New hotness update event for package: {package_name}, version: {version},"
@@ -1562,6 +1565,7 @@ def parse_new_hotness_update_event(event) -> Optional[NewHotnessUpdateEvent]:
             version=version,
             distgit_project_url=distgit_project_url,
             bug_id=bug_id,
+            release_monitoring_project_id=release_monitoring_project_id,
         )
 
     # The .__func__ are needed for Python < 3.10

tests/integration/test_new_hotness_update.py

@@ -151,6 +151,7 @@ def test_new_hotness_update(new_hotness_update, sync_release_model):
         sync_default_files=False,
         add_pr_instructions=True,
         resolved_bugs=["rhbz#2106196"],
+        release_monitoring_project_id=4181,
     ).and_return(pr).once()
     flexmock(PackitAPI).should_receive("clean")
 

tests/integration/test_pr_comment.py

@@ -2611,6 +2611,7 @@ def _get_project(url, *_, **__):
         sync_default_files=False,
         add_pr_instructions=True,
         resolved_bugs=["rhbz#123", "rhbz#124"],
+        release_monitoring_project_id=None,
     ).and_return(pr).once()
     flexmock(PackitAPI).should_receive("clean")
 

tests/integration/test_release_event.py

@@ -179,6 +179,7 @@ def test_dist_git_push_release_handle(github_release_webhook, propose_downstream
         sync_default_files=True,
         add_pr_instructions=True,
         resolved_bugs=[],
+        release_monitoring_project_id=None,
     ).and_return(pr).once()
     flexmock(PackitAPI).should_receive("clean")
 
@@ -299,6 +300,7 @@ def test_dist_git_push_release_handle_multiple_branches(
             sync_default_files=True,
             add_pr_instructions=True,
             resolved_bugs=[],
+            release_monitoring_project_id=None,
         ).and_return(pr).once()
 
         flexmock(ProposeDownstreamJobHelper).should_receive(
@@ -429,6 +431,7 @@ def test_dist_git_push_release_handle_one_failed(
                 sync_default_files=True,
                 add_pr_instructions=True,
                 resolved_bugs=[],
+                release_monitoring_project_id=None,
             ).and_return(pr).once()
             flexmock(ProposeDownstreamJobHelper).should_receive(
                 "report_status_for_branch"
@@ -448,6 +451,7 @@ def test_dist_git_push_release_handle_one_failed(
                 sync_default_files=True,
                 add_pr_instructions=True,
                 resolved_bugs=[],
+                release_monitoring_project_id=None,
             ).and_raise(Exception, f"Failed {model.branch}").once()
             flexmock(ProposeDownstreamJobHelper).should_receive(
                 "report_status_for_branch"
@@ -686,6 +690,7 @@ def test_retry_propose_downstream_task(
         sync_default_files=True,
         add_pr_instructions=True,
         resolved_bugs=[],
+        release_monitoring_project_id=None,
     ).and_raise(
         PackitDownloadFailedException, "Failed to download source from example.com"
     ).once()
@@ -794,6 +799,7 @@ def test_dont_retry_propose_downstream_task(
         sync_default_files=True,
         add_pr_instructions=True,
         resolved_bugs=[],
+        release_monitoring_project_id=None,
     ).and_raise(
         PackitDownloadFailedException, "Failed to download source from example.com"
     ).once()

tests/unit/test_events.py

@@ -1672,6 +1672,7 @@ def test_parse_new_hotness_update(
         assert isinstance(event_object, NewHotnessUpdateEvent)
         assert isinstance(event_object.project, PagureProject)
         assert event_object.package_name == "redis"
+        assert event_object.release_monitoring_project_id == 4181
         assert event_object.repo_namespace == repo_namespace
         assert event_object.repo_name == repo_name
         assert (

tests/unit/test_steve.py

@@ -163,6 +163,7 @@ def test_process_message(event, private, enabled_private_namespaces, success):
         sync_default_files=True,
         add_pr_instructions=True,
         resolved_bugs=[],
+        release_monitoring_project_id=None,
     ).and_return(pr).times(1 if success else 0)
     flexmock(shutil).should_receive("rmtree").with_args("")