Add filter condition to update less often

Author: adrian-codecov

Makefile

@@ -48,7 +48,7 @@ lint.install:
 	pip install -Iv ruff
 
 lint.run:
-	ruff check
+	ruff check --fix
 	ruff format
 
 lint.check:

webhook_handlers/tests/test_github.py

@@ -275,8 +275,12 @@ def test_push_updates_only_unmerged_commits_with_branch_name(self):
 
     @patch("redis.Redis.sismember", lambda x, y, z: False)
     def test_push_updates_commit_on_default_branch(self):
-        commit1 = CommitFactory(merged=False, repository=self.repo)
-        commit2 = CommitFactory(merged=False, repository=self.repo)
+        commit1 = CommitFactory(
+            merged=False, repository=self.repo, branch="feature-branch"
+        )
+        commit2 = CommitFactory(
+            merged=False, repository=self.repo, branch="feature-branch"
+        )
 
         merged_branch_name = "merged"
         repo_branch = self.repo.branch

webhook_handlers/tests/test_github_enterprise.py

@@ -231,8 +231,12 @@ def test_push_updates_only_unmerged_commits_with_branch_name(self):
 
     @patch("redis.Redis.sismember", lambda x, y, z: False)
     def test_push_updates_commit_on_default_branch(self):
-        commit1 = CommitFactory(merged=False, repository=self.repo)
-        commit2 = CommitFactory(merged=False, repository=self.repo)
+        commit1 = CommitFactory(
+            merged=False, repository=self.repo, branch="feature-branch"
+        )
+        commit2 = CommitFactory(
+            merged=False, repository=self.repo, branch="feature-branch"
+        )
 
         merged_branch_name = "merged"
         repo_branch = self.repo.branch

webhook_handlers/views/github.py

@@ -5,6 +5,7 @@
 from hashlib import sha1, sha256
 from typing import Optional
 
+from django.db.models import Q
 from django.utils import timezone
 from django.utils.crypto import constant_time_compare
 from rest_framework import status
@@ -239,24 +240,25 @@ def push(self, request, *args, **kwargs):
             )
             return Response(data=WebhookHandlerErrorMessages.SKIP_WEBHOOK_IGNORED)
 
-        branch_name = self.request.data.get("ref")[11:]
+        pushed_to_branch_name = self.request.data.get("ref")[11:]
         commits = self.request.data.get("commits", [])
 
         if not commits:
             log.debug(
-                f"No commits in webhook payload for branch {branch_name}",
+                f"No commits in webhook payload for branch {pushed_to_branch_name}",
                 extra=dict(repoid=repo.repoid, github_webhook_event=self.event),
             )
             return Response()
 
         commits_queryset = Commit.objects.filter(
+            ~Q(branch=pushed_to_branch_name),
             repository=repo,
             commitid__in=[commit.get("id") for commit in commits],
             merged=False,
         )
-        commits_queryset.update(branch=branch_name)
-        if branch_name == repo.branch:
-            commits_queryset.update(merged=True)
+
+        if pushed_to_branch_name == repo.branch:
+            commits_queryset.update(branch=pushed_to_branch_name, merged=True)
             log.info(
                 "Pushed commits to default branch; setting merged to True",
                 extra=dict(
@@ -265,9 +267,11 @@ def push(self, request, *args, **kwargs):
                     commits=[commit.get("id") for commit in commits],
                 ),
             )
+        else:
+            commits_queryset.update(branch=pushed_to_branch_name)
 
         log.info(
-            f"Branch name updated for commits to {branch_name}",
+            f"Branch name updated for commits to {pushed_to_branch_name}",
             extra=dict(
                 repoid=repo.repoid,
                 github_webhook_event=self.event,
@@ -300,7 +304,7 @@ def push(self, request, *args, **kwargs):
             TaskService().status_set_pending(
                 repoid=repo.repoid,
                 commitid=most_recent_commit.get("id"),
-                branch=branch_name,
+                branch=pushed_to_branch_name,
                 on_a_pull_request=False,
             )