Migrate rebase_in_progress? to Gitaly

Closes gitaly#866

lib/gitlab/git/repository.rb

@@ -1234,8 +1234,14 @@ module Gitlab
       end
 
       def rebase_in_progress?(rebase_id)
+        gitaly_migrate(:rebase_in_progress) do |is_enabled|
+          if is_enabled
+            gitaly_repository_client.rebase_in_progress?(rebase_id)
+          else
             fresh_worktree?(worktree_path(REBASE_WORKTREE_PREFIX, rebase_id))
           end
+        end
+      end
 
       def squash(user, squash_id, branch:, start_sha:, end_sha:, author:, message:)
         squash_path = worktree_path(SQUASH_WORKTREE_PREFIX, squash_id)

lib/gitlab/gitaly_client/repository_service.rb

@@ -100,6 +100,23 @@ module Gitlab
         )
       end
 
+      def rebase_in_progress?(rebase_id)
+        request = Gitaly::IsRebaseInProgressRequest.new(
+          repository: @gitaly_repo,
+          rebase_id: rebase_id.to_s
+        )
+
+        response = GitalyClient.call(
+          @storage,
+          :repository_service,
+          :is_rebase_in_progress,
+          request,
+          timeout: GitalyClient.default_timeout
+        )
+
+        response.in_progress
+      end
+
       def fetch_source_branch(source_repository, source_branch, local_ref)
         request = Gitaly::FetchSourceBranchRequest.new(
           repository: @gitaly_repo,

spec/models/merge_request_spec.rb

@@ -1915,38 +1915,44 @@ describe MergeRequest do
   end
 
   describe '#rebase_in_progress?' do
-    # Create merge request and project before we stub file calls
+    shared_examples 'checking whether a rebase is in progress' do
+      let(:repo_path) { subject.source_project.repository.path }
+      let(:rebase_path) { File.join(repo_path, "gitlab-worktree", "rebase-#{subject.id}") }
+
       before do
-      subject
+        system(*%W(#{Gitlab.config.git.bin_path} -C #{repo_path} worktree add --detach #{rebase_path} master))
       end
 
       it 'returns true when there is a current rebase directory' do
-      allow(File).to receive(:exist?).and_return(true)
-      allow(File).to receive(:mtime).and_return(Time.now)
-
         expect(subject.rebase_in_progress?).to be_truthy
       end
 
       it 'returns false when there is no rebase directory' do
-      allow(File).to receive(:exist?).and_return(false)
+        FileUtils.rm_rf(rebase_path)
 
         expect(subject.rebase_in_progress?).to be_falsey
       end
 
       it 'returns false when the rebase directory has expired' do
-      allow(File).to receive(:exist?).and_return(true)
-      allow(File).to receive(:mtime).and_return(20.minutes.ago)
+        time = 20.minutes.ago.to_time
+        File.utime(time, time, rebase_path)
 
         expect(subject.rebase_in_progress?).to be_falsey
       end
 
       it 'returns false when the source project has been removed' do
         allow(subject).to receive(:source_project).and_return(nil)
-      allow(File).to receive(:exist?).and_return(true)
-      allow(File).to receive(:mtime).and_return(Time.now)
 
-      expect(File).not_to have_received(:exist?)
         expect(subject.rebase_in_progress?).to be_falsey
       end
     end
+
+    context 'when Gitaly rebase_in_progress is enabled' do
+      it_behaves_like 'checking whether a rebase is in progress'
+    end
+
+    context 'when Gitaly rebase_in_progress is enabled', :disable_gitaly do
+      it_behaves_like 'checking whether a rebase is in progress'
+    end
+  end
 end