From 87cf5b7055451a387c64bd488dacf2bc03917913 Mon Sep 17 00:00:00 2001
From: Dmitriy Zaporozhets <dmitriy.zaporozhets@gmail.com>
Date: Fri, 26 Sep 2014 10:46:48 +0300
Subject: [PATCH] Fix GitPush service

Signed-off-by: Dmitriy Zaporozhets <dmitriy.zaporozhets@gmail.com>
---
 app/services/git_push_service.rb | 57 +++++++++++++++++---------------
 1 file changed, 31 insertions(+), 26 deletions(-)

diff --git a/app/services/git_push_service.rb b/app/services/git_push_service.rb
index 715b5690751..6a13778d67c 100644
--- a/app/services/git_push_service.rb
+++ b/app/services/git_push_service.rb
@@ -17,39 +17,38 @@ class GitPushService
   def execute(project, user, oldrev, newrev, ref)
     @project, @user = project, user
 
-    # Collect data for this git push
-    @push_commits = project.repository.commits_between(oldrev, newrev)
-    @push_data = post_receive_data(oldrev, newrev, ref)
-
-    create_push_event
-
     project.ensure_satellite_exists
     project.repository.expire_cache
     project.update_repository_size
 
-    if push_to_existing_branch?(ref, oldrev)
-      project.update_merge_requests(oldrev, newrev, ref, @user)
-      process_commit_messages(ref)
-    end
-
     if push_to_branch?(ref)
-      project.execute_hooks(@push_data.dup, :push_hooks)
-      project.execute_services(@push_data.dup)
-    end
+      if push_to_existing_branch?(ref, oldrev)
+        # Collect data for this git push
+        @push_commits = project.repository.commits_between(oldrev, newrev)
+        project.update_merge_requests(oldrev, newrev, ref, @user)
+        process_commit_messages(ref)
+      elsif push_to_new_branch?(ref, oldrev)
+        # Re-find the pushed commits.
+        if is_default_branch?(ref)
+          # Initial push to the default branch. Take the full history of that branch as "newly pushed".
+          @push_commits = project.repository.commits(newrev)
+        else
+          # Use the pushed commits that aren't reachable by the default branch
+          # as a heuristic. This may include more commits than are actually pushed, but
+          # that shouldn't matter because we check for existing cross-references later.
+          @push_commits = project.repository.commits_between(project.default_branch, newrev)
+        end
 
-    if push_to_new_branch?(ref, oldrev)
-      # Re-find the pushed commits.
-      if is_default_branch?(ref)
-        # Initial push to the default branch. Take the full history of that branch as "newly pushed".
-        @push_commits = project.repository.commits(newrev)
-      else
-        # Use the pushed commits that aren't reachable by the default branch
-        # as a heuristic. This may include more commits than are actually pushed, but
-        # that shouldn't matter because we check for existing cross-references later.
-        @push_commits = project.repository.commits_between(project.default_branch, newrev)
+        process_commit_messages(ref)
+
+      elsif push_remove_branch_branch?(ref, newrev)
+        @push_commits = []
       end
 
-      process_commit_messages(ref)
+      @push_data = post_receive_data(oldrev, newrev, ref)
+      create_push_event(@push_data)
+      project.execute_hooks(@push_data.dup, :push_hooks)
+      project.execute_services(@push_data.dup)
     end
   end
 
@@ -65,7 +64,7 @@ class GitPushService
 
   protected
 
-  def create_push_event
+  def create_push_event(push_data)
     Event.create!(
       project: project,
       action: Event::PUSHED,
@@ -179,6 +178,12 @@ class GitPushService
     ref_parts[1] =~ /heads/ && oldrev == "0000000000000000000000000000000000000000"
   end
 
+  def push_remove_branch? ref, newrev
+    ref_parts = ref.split('/')
+
+    ref_parts[1] =~ /heads/ && newrev == "0000000000000000000000000000000000000000"
+  end
+
   def push_to_branch? ref
     ref =~ /refs\/heads/
   end