Merge branch 'add_new_diff_stat_rpc' into 'master'

Add new diff stat rpc

See merge request gitlab-org/gitaly!2694

7 files changed, 702 insertions, 57 deletions

diff --git a/internal/git/subcommand.go b/internal/git/subcommand.go
index 0a837723b..9f75fdc94 100644
--- a/internal/git/subcommand.go
+++ b/internal/git/subcommand.go
@@ -11,6 +11,7 @@ const (
 	scMultiPackIndex = "multi-pack-index"
 	scRepack         = "repack"
 	scDiff           = "diff"
+	scDiffTree       = "diff-tree"
 	scPackRefs       = "pack-refs"
 	scMergeBase      = "merge-base"
 	scHashObject     = "hash-object"
@@ -35,6 +36,7 @@ var knownReadOnlyCmds = map[string]struct{}{
 	scRevParse:      struct{}{},
 	scCountObjects:  struct{}{},
 	scDiff:          struct{}{},
+	scDiffTree:      struct{}{},
 	scMergeBase:     struct{}{},
 	scShowRef:       struct{}{},
 	scUploadPack:    struct{}{},
diff --git a/internal/gitaly/service/diff/find_changed_paths.go b/internal/gitaly/service/diff/find_changed_paths.go
new file mode 100644
index 000000000..8140bcf95
--- /dev/null
+++ b/internal/gitaly/service/diff/find_changed_paths.go
@@ -0,0 +1,155 @@
+package diff
+
+import (
+	"bufio"
+	"context"
+	"fmt"
+	"io"
+	"strings"
+
+	"github.com/golang/protobuf/proto"
+	"gitlab.com/gitlab-org/gitaly/internal/git"
+	"gitlab.com/gitlab-org/gitaly/internal/helper/chunk"
+	"gitlab.com/gitlab-org/gitaly/proto/go/gitalypb"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+)
+
+const (
+	numStatDelimiter = 0
+)
+
+func (s *server) FindChangedPaths(in *gitalypb.FindChangedPathsRequest, stream gitalypb.DiffService_FindChangedPathsServer) error {
+	if err := s.validateFindChangedPathsRequestParams(stream.Context(), in); err != nil {
+		return err
+	}
+
+	diffChunker := chunk.New(&findChangedPathsSender{stream: stream})
+
+	cmd, err := git.SafeCmd(stream.Context(), in.Repository, nil, git.SubCmd{
+		Name: "diff-tree",
+		Flags: []git.Option{
+			git.Flag{Name: "-z"},
+			git.Flag{Name: "--stdin"},
+			git.Flag{Name: "-m"},
+			git.Flag{Name: "-r"},
+			git.Flag{Name: "--name-status"},
+			git.Flag{Name: "--no-renames"},
+			git.Flag{Name: "--no-commit-id"},
+			git.Flag{Name: "--diff-filter=AMDTC"},
+		},
+	}, git.WithStdin(strings.NewReader(strings.Join(in.GetCommits(), "\n")+"\n")))
+	if err != nil {
+		if _, ok := status.FromError(err); ok {
+			return fmt.Errorf("FindChangedPaths Stdin Err: %w", err)
+		}
+		return status.Errorf(codes.Internal, "FindChangedPaths: Cmd Err: %v", err)
+	}
+
+	if err := parsePaths(bufio.NewReader(cmd), diffChunker); err != nil {
+		return fmt.Errorf("FindChangedPaths Parsing Err: %w", err)
+	}
+
+	if err := cmd.Wait(); err != nil {
+		return status.Errorf(codes.Unavailable, "FindChangedPaths: Cmd Wait Err: %v", err)
+	}
+
+	return diffChunker.Flush()
+}
+
+func parsePaths(reader *bufio.Reader, chunker *chunk.Chunker) error {
+	for {
+		path, err := nextPath(reader)
+		if err != nil {
+			if err == io.EOF {
+				break
+			}
+
+			return fmt.Errorf("FindChangedPaths Next Path Err: %w", err)
+		}
+
+		if err := chunker.Send(path); err != nil {
+			return fmt.Errorf("FindChangedPaths: err sending to chunker: %v", err)
+		}
+	}
+
+	return nil
+}
+
+func nextPath(reader *bufio.Reader) (*gitalypb.ChangedPaths, error) {
+	pathStatus, err := reader.ReadBytes(numStatDelimiter)
+	if err != nil {
+		return nil, err
+	}
+
+	path, err := reader.ReadBytes(numStatDelimiter)
+	if err != nil {
+		return nil, err
+	}
+
+	statusTypeMap := map[string]gitalypb.ChangedPaths_Status{
+		"M": gitalypb.ChangedPaths_MODIFIED,
+		"D": gitalypb.ChangedPaths_DELETED,
+		"T": gitalypb.ChangedPaths_TYPE_CHANGE,
+		"C": gitalypb.ChangedPaths_COPIED,
+		"A": gitalypb.ChangedPaths_ADDED,
+	}
+
+	parsedPath, ok := statusTypeMap[string(pathStatus[:len(pathStatus)-1])]
+	if !ok {
+		return nil, status.Errorf(codes.Internal, "FindChangedPaths: Unknown changed paths returned: %v", string(pathStatus))
+	}
+
+	changedPath := &gitalypb.ChangedPaths{
+		Status: parsedPath,
+		Path:   path[:len(path)-1],
+	}
+
+	return changedPath, nil
+}
+
+// This sender implements the interface in the chunker class
+type findChangedPathsSender struct {
+	paths  []*gitalypb.ChangedPaths
+	stream gitalypb.DiffService_FindChangedPathsServer
+}
+
+func (t *findChangedPathsSender) Reset() {
+	t.paths = nil
+}
+
+func (t *findChangedPathsSender) Append(m proto.Message) {
+	t.paths = append(t.paths, m.(*gitalypb.ChangedPaths))
+}
+
+func (t *findChangedPathsSender) Send() error {
+	return t.stream.Send(&gitalypb.FindChangedPathsResponse{
+		Paths: t.paths,
+	})
+}
+
+func (s *server) validateFindChangedPathsRequestParams(ctx context.Context, in *gitalypb.FindChangedPathsRequest) error {
+	repo := in.GetRepository()
+	if _, err := s.locator.GetRepoPath(repo); err != nil {
+		return err
+	}
+
+	gitRepo := git.NewRepository(repo)
+
+	for _, commit := range in.GetCommits() {
+		if commit == "" {
+			return status.Errorf(codes.InvalidArgument, "FindChangedPaths: commits cannot contain an empty commit")
+		}
+
+		containsRef, err := gitRepo.ContainsRef(ctx, commit+"^{commit}")
+		if err != nil {
+			return fmt.Errorf("contains ref err: %w", err)
+		}
+
+		if !containsRef {
+			return status.Errorf(codes.NotFound, "FindChangedPaths: commit: %v can not be found", commit)
+		}
+	}
+
+	return nil
+}
diff --git a/internal/gitaly/service/diff/find_changed_paths_test.go b/internal/gitaly/service/diff/find_changed_paths_test.go
new file mode 100644
index 000000000..06a47c5f4
--- /dev/null
+++ b/internal/gitaly/service/diff/find_changed_paths_test.go
@@ -0,0 +1,180 @@
+package diff
+
+import (
+	"io"
+	"path/filepath"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+	"gitlab.com/gitlab-org/gitaly/internal/testhelper"
+	"gitlab.com/gitlab-org/gitaly/proto/go/gitalypb"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+)
+
+func TestFindChangedPathsRequest_success(t *testing.T) {
+	server, serverSocketPath := runDiffServer(t)
+	defer server.Stop()
+
+	client, conn := newDiffClient(t, serverSocketPath)
+	defer conn.Close()
+
+	testRepo, _, cleanupFn := testhelper.NewTestRepo(t)
+	defer cleanupFn()
+
+	ctx, cancel := testhelper.Context()
+	defer cancel()
+
+	testCases := []struct {
+		desc          string
+		commits       []string
+		expectedPaths []*gitalypb.ChangedPaths
+	}{
+		{
+			"Returns the expected results without a merge commit",
+			[]string{"e4003da16c1c2c3fc4567700121b17bf8e591c6c", "57290e673a4c87f51294f5216672cbc58d485d25", "8a0f2ee90d940bfb0ba1e14e8214b0649056e4ab", "d59c60028b053793cecfb4022de34602e1a9218e"},
+			[]*gitalypb.ChangedPaths{
+				{
+					Status: gitalypb.ChangedPaths_MODIFIED,
+					Path:   []byte("CONTRIBUTING.md"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_MODIFIED,
+					Path:   []byte("MAINTENANCE.md"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("gitaly/テスト.txt"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("gitaly/deleted-file"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("gitaly/file-with-multiple-chunks"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("gitaly/mode-file"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("gitaly/mode-file-with-mods"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("gitaly/named-file"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("gitaly/named-file-with-mods"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_DELETED,
+					Path:   []byte("files/js/commit.js.coffee"),
+				},
+			},
+		},
+		{
+			"Returns the expected results with a merge commit",
+			[]string{"7975be0116940bf2ad4321f79d02a55c5f7779aa", "55bc176024cfa3baaceb71db584c7e5df900ea65"},
+			[]*gitalypb.ChangedPaths{
+				{
+					Status: gitalypb.ChangedPaths_ADDED,
+					Path:   []byte("files/images/emoji.png"),
+				},
+				{
+					Status: gitalypb.ChangedPaths_MODIFIED,
+					Path:   []byte(".gitattributes"),
+				},
+			},
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.desc, func(t *testing.T) {
+			rpcRequest := &gitalypb.FindChangedPathsRequest{Repository: testRepo, Commits: tc.commits}
+
+			stream, err := client.FindChangedPaths(ctx, rpcRequest)
+			require.NoError(t, err)
+
+			var paths []*gitalypb.ChangedPaths
+			for {
+				fetchedPaths, err := stream.Recv()
+				if err == io.EOF {
+					break
+				}
+
+				require.NoError(t, err)
+
+				paths = append(paths, fetchedPaths.GetPaths()...)
+			}
+
+			require.Equal(t, tc.expectedPaths, paths)
+		})
+	}
+}
+
+func TestFindChangedPathsRequest_failing(t *testing.T) {
+	server, serverSocketPath := runDiffServer(t)
+	defer server.Stop()
+
+	client, conn := newDiffClient(t, serverSocketPath)
+	defer conn.Close()
+
+	ctx, cancel := testhelper.Context()
+	defer cancel()
+
+	testRepo, _, cleanupFn := testhelper.NewTestRepo(t)
+	defer cleanupFn()
+
+	tests := []struct {
+		desc    string
+		repo    *gitalypb.Repository
+		commits []string
+		err     error
+	}{
+		{
+			desc:    "Repo not found",
+			repo:    &gitalypb.Repository{StorageName: testRepo.GetStorageName(), RelativePath: "bar.git"},
+			commits: []string{"e4003da16c1c2c3fc4567700121b17bf8e591c6c", "8a0f2ee90d940bfb0ba1e14e8214b0649056e4ab"},
+			err:     status.Errorf(codes.NotFound, "GetRepoPath: not a git repository: %q", filepath.Join(testhelper.GitlabTestStoragePath(), "bar.git")),
+		},
+		{
+			desc:    "Storage not found",
+			repo:    &gitalypb.Repository{StorageName: "foo", RelativePath: "bar.git"},
+			commits: []string{"e4003da16c1c2c3fc4567700121b17bf8e591c6c", "8a0f2ee90d940bfb0ba1e14e8214b0649056e4ab"},
+			err:     status.Error(codes.InvalidArgument, "GetStorageByName: no such storage: \"foo\""),
+		},
+		{
+			desc:    "Commits cannot contain an empty commit",
+			repo:    testRepo,
+			commits: []string{""},
+			err:     status.Error(codes.InvalidArgument, "FindChangedPaths: commits cannot contain an empty commit"),
+		},
+		{
+			desc:    "Invalid commit",
+			repo:    testRepo,
+			commits: []string{"invalidinvalidinvalid", "8a0f2ee90d940bfb0ba1e14e8214b0649056e4ab"},
+			err:     status.Error(codes.NotFound, "FindChangedPaths: commit: invalidinvalidinvalid can not be found"),
+		},
+		{
+			desc:    "Commit not found",
+			repo:    testRepo,
+			commits: []string{"z4003da16c1c2c3fc4567700121b17bf8e591c6c", "8a0f2ee90d940bfb0ba1e14e8214b0649056e4ab"},
+			err:     status.Error(codes.NotFound, "FindChangedPaths: commit: z4003da16c1c2c3fc4567700121b17bf8e591c6c can not be found"),
+		},
+	}
+
+	for _, tc := range tests {
+		rpcRequest := &gitalypb.FindChangedPathsRequest{Repository: tc.repo, Commits: tc.commits}
+		stream, err := client.FindChangedPaths(ctx, rpcRequest)
+		require.NoError(t, err)
+
+		t.Run(tc.desc, func(t *testing.T) {
+			_, err := stream.Recv()
+			require.Equal(t, tc.err, err)
+		})
+	}
+}
diff --git a/proto/diff.proto b/proto/diff.proto
index 24b728edc..b7199fb23 100644
--- a/proto/diff.proto
+++ b/proto/diff.proto
@@ -35,6 +35,12 @@ service DiffService {
       op: ACCESSOR
     };
   }
+  // Return a list of files changed along with the status of each file
+  rpc FindChangedPaths(FindChangedPathsRequest) returns (stream FindChangedPathsResponse) {
+    option (op_type) = {
+      op: ACCESSOR
+    };
+  }
 }
 
 message CommitDiffRequest {
@@ -143,3 +149,31 @@ message DiffStats {
 message DiffStatsResponse {
   repeated DiffStats stats = 1;
 }
+
+// Given a list of commits, return the files changed. Each commit is compared
+// to its parent. Merge commits will show files which are different to all of
+// its parents.
+message FindChangedPathsRequest {
+  Repository repository = 1 [(target_repository)=true];
+  repeated string commits = 2;
+}
+
+// Returns a list of files that have been changed in the commits given
+message FindChangedPathsResponse {
+  repeated ChangedPaths paths = 1;
+}
+
+// Includes the path of the file, and the status of the change
+message ChangedPaths {
+  enum Status {
+    ADDED = 0;
+    MODIFIED = 1;
+    DELETED = 2;
+    TYPE_CHANGE = 3;
+    COPIED = 4;
+  }
+
+  bytes path = 1;
+  Status status = 2;
+}
+
diff --git a/proto/go/gitalypb/diff.pb.go b/proto/go/gitalypb/diff.pb.go
index f7590c051..0b0d0f294 100644
--- a/proto/go/gitalypb/diff.pb.go
+++ b/proto/go/gitalypb/diff.pb.go
@@ -24,6 +24,40 @@ var _ = math.Inf
 // proto package needs to be updated.
 const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
 
+type ChangedPaths_Status int32
+
+const (
+	ChangedPaths_ADDED       ChangedPaths_Status = 0
+	ChangedPaths_MODIFIED    ChangedPaths_Status = 1
+	ChangedPaths_DELETED     ChangedPaths_Status = 2
+	ChangedPaths_TYPE_CHANGE ChangedPaths_Status = 3
+	ChangedPaths_COPIED      ChangedPaths_Status = 4
+)
+
+var ChangedPaths_Status_name = map[int32]string{
+	0: "ADDED",
+	1: "MODIFIED",
+	2: "DELETED",
+	3: "TYPE_CHANGE",
+	4: "COPIED",
+}
+
+var ChangedPaths_Status_value = map[string]int32{
+	"ADDED":       0,
+	"MODIFIED":    1,
+	"DELETED":     2,
+	"TYPE_CHANGE": 3,
+	"COPIED":      4,
+}
+
+func (x ChangedPaths_Status) String() string {
+	return proto.EnumName(ChangedPaths_Status_name, int32(x))
+}
+
+func (ChangedPaths_Status) EnumDescriptor() ([]byte, []int) {
+	return fileDescriptor_686521effc814b25, []int{14, 0}
+}
+
 type CommitDiffRequest struct {
 	Repository             *Repository `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"`
 	LeftCommitId           string      `protobuf:"bytes,2,opt,name=left_commit_id,json=leftCommitId,proto3" json:"left_commit_id,omitempty"`
@@ -834,7 +868,146 @@ func (m *DiffStatsResponse) GetStats() []*DiffStats {
 	return nil
 }
 
+// Given a list of commits, return the files changed. Each commit is compared
+// to its parent. Merge commits will show files which are different to all of
+// its parents.
+type FindChangedPathsRequest struct {
+	Repository           *Repository `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"`
+	Commits              []string    `protobuf:"bytes,2,rep,name=commits,proto3" json:"commits,omitempty"`
+	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
+	XXX_unrecognized     []byte      `json:"-"`
+	XXX_sizecache        int32       `json:"-"`
+}
+
+func (m *FindChangedPathsRequest) Reset()         { *m = FindChangedPathsRequest{} }
+func (m *FindChangedPathsRequest) String() string { return proto.CompactTextString(m) }
+func (*FindChangedPathsRequest) ProtoMessage()    {}
+func (*FindChangedPathsRequest) Descriptor() ([]byte, []int) {
+	return fileDescriptor_686521effc814b25, []int{12}
+}
+
+func (m *FindChangedPathsRequest) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_FindChangedPathsRequest.Unmarshal(m, b)
+}
+func (m *FindChangedPathsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_FindChangedPathsRequest.Marshal(b, m, deterministic)
+}
+func (m *FindChangedPathsRequest) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_FindChangedPathsRequest.Merge(m, src)
+}
+func (m *FindChangedPathsRequest) XXX_Size() int {
+	return xxx_messageInfo_FindChangedPathsRequest.Size(m)
+}
+func (m *FindChangedPathsRequest) XXX_DiscardUnknown() {
+	xxx_messageInfo_FindChangedPathsRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_FindChangedPathsRequest proto.InternalMessageInfo
+
+func (m *FindChangedPathsRequest) GetRepository() *Repository {
+	if m != nil {
+		return m.Repository
+	}
+	return nil
+}
+
+func (m *FindChangedPathsRequest) GetCommits() []string {
+	if m != nil {
+		return m.Commits
+	}
+	return nil
+}
+
+// Returns a list of files that have been changed in the commits given
+type FindChangedPathsResponse struct {
+	Paths                []*ChangedPaths `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
+	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
+	XXX_unrecognized     []byte          `json:"-"`
+	XXX_sizecache        int32           `json:"-"`
+}
+
+func (m *FindChangedPathsResponse) Reset()         { *m = FindChangedPathsResponse{} }
+func (m *FindChangedPathsResponse) String() string { return proto.CompactTextString(m) }
+func (*FindChangedPathsResponse) ProtoMessage()    {}
+func (*FindChangedPathsResponse) Descriptor() ([]byte, []int) {
+	return fileDescriptor_686521effc814b25, []int{13}
+}
+
+func (m *FindChangedPathsResponse) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_FindChangedPathsResponse.Unmarshal(m, b)
+}
+func (m *FindChangedPathsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_FindChangedPathsResponse.Marshal(b, m, deterministic)
+}
+func (m *FindChangedPathsResponse) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_FindChangedPathsResponse.Merge(m, src)
+}
+func (m *FindChangedPathsResponse) XXX_Size() int {
+	return xxx_messageInfo_FindChangedPathsResponse.Size(m)
+}
+func (m *FindChangedPathsResponse) XXX_DiscardUnknown() {
+	xxx_messageInfo_FindChangedPathsResponse.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_FindChangedPathsResponse proto.InternalMessageInfo
+
+func (m *FindChangedPathsResponse) GetPaths() []*ChangedPaths {
+	if m != nil {
+		return m.Paths
+	}
+	return nil
+}
+
+// Includes the path of the file, and the status of the change
+type ChangedPaths struct {
+	Path                 []byte              `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
+	Status               ChangedPaths_Status `protobuf:"varint,2,opt,name=status,proto3,enum=gitaly.ChangedPaths_Status" json:"status,omitempty"`
+	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
+	XXX_unrecognized     []byte              `json:"-"`
+	XXX_sizecache        int32               `json:"-"`
+}
+
+func (m *ChangedPaths) Reset()         { *m = ChangedPaths{} }
+func (m *ChangedPaths) String() string { return proto.CompactTextString(m) }
+func (*ChangedPaths) ProtoMessage()    {}
+func (*ChangedPaths) Descriptor() ([]byte, []int) {
+	return fileDescriptor_686521effc814b25, []int{14}
+}
+
+func (m *ChangedPaths) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_ChangedPaths.Unmarshal(m, b)
+}
+func (m *ChangedPaths) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_ChangedPaths.Marshal(b, m, deterministic)
+}
+func (m *ChangedPaths) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_ChangedPaths.Merge(m, src)
+}
+func (m *ChangedPaths) XXX_Size() int {
+	return xxx_messageInfo_ChangedPaths.Size(m)
+}
+func (m *ChangedPaths) XXX_DiscardUnknown() {
+	xxx_messageInfo_ChangedPaths.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_ChangedPaths proto.InternalMessageInfo
+
+func (m *ChangedPaths) GetPath() []byte {
+	if m != nil {
+		return m.Path
+	}
+	return nil
+}
+
+func (m *ChangedPaths) GetStatus() ChangedPaths_Status {
+	if m != nil {
+		return m.Status
+	}
+	return ChangedPaths_ADDED
+}
+
 func init() {
+	proto.RegisterEnum("gitaly.ChangedPaths_Status", ChangedPaths_Status_name, ChangedPaths_Status_value)
 	proto.RegisterType((*CommitDiffRequest)(nil), "gitaly.CommitDiffRequest")
 	proto.RegisterType((*CommitDiffResponse)(nil), "gitaly.CommitDiffResponse")
 	proto.RegisterType((*CommitDeltaRequest)(nil), "gitaly.CommitDeltaRequest")
@@ -847,68 +1020,80 @@ func init() {
 	proto.RegisterType((*DiffStatsRequest)(nil), "gitaly.DiffStatsRequest")
 	proto.RegisterType((*DiffStats)(nil), "gitaly.DiffStats")
 	proto.RegisterType((*DiffStatsResponse)(nil), "gitaly.DiffStatsResponse")
+	proto.RegisterType((*FindChangedPathsRequest)(nil), "gitaly.FindChangedPathsRequest")
+	proto.RegisterType((*FindChangedPathsResponse)(nil), "gitaly.FindChangedPathsResponse")
+	proto.RegisterType((*ChangedPaths)(nil), "gitaly.ChangedPaths")
 }
 
 func init() { proto.RegisterFile("diff.proto", fileDescriptor_686521effc814b25) }
 
 var fileDescriptor_686521effc814b25 = []byte{
-	// 882 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x56, 0xcd, 0x6e, 0xe3, 0x36,
-	0x10, 0x86, 0x6c, 0x59, 0x91, 0xc7, 0x8a, 0x93, 0x30, 0x45, 0x56, 0xf1, 0xf6, 0x60, 0x08, 0xfb,
-	0x63, 0xa0, 0x6d, 0xb2, 0x48, 0x2f, 0x7b, 0xe8, 0x29, 0x1b, 0xb4, 0xc8, 0x22, 0x41, 0x03, 0xf5,
-	0x50, 0xa0, 0x17, 0x81, 0x36, 0x29, 0x9b, 0xa8, 0x24, 0xba, 0x22, 0x1b, 0x27, 0x8f, 0xd0, 0x27,
-	0xe8, 0xb6, 0x2f, 0x50, 0xa0, 0xc7, 0x3e, 0x44, 0x9f, 0xa9, 0xe8, 0xa9, 0xe0, 0x50, 0x92, 0xe5,
-	0x75, 0xd0, 0xb3, 0x6f, 0x9a, 0xef, 0xfb, 0x34, 0x1c, 0x7e, 0x33, 0x23, 0x1b, 0x80, 0x89, 0x34,
-	0x3d, 0x5b, 0x96, 0x52, 0x4b, 0xe2, 0xcd, 0x85, 0xa6, 0xd9, 0xe3, 0x08, 0x32, 0x51, 0x68, 0x8b,
-	0x8d, 0x02, 0xb5, 0xa0, 0x25, 0x67, 0x36, 0x8a, 0xfe, 0x74, 0xe1, 0xe8, 0x9d, 0xcc, 0x73, 0xa1,
-	0xaf, 0x44, 0x9a, 0xc6, 0xfc, 0xa7, 0x9f, 0xb9, 0xd2, 0xe4, 0x2d, 0x40, 0xc9, 0x97, 0x52, 0x09,
-	0x2d, 0xcb, 0xc7, 0xd0, 0x19, 0x3b, 0x93, 0xc1, 0x05, 0x39, 0xb3, 0xc9, 0xce, 0xe2, 0x86, 0xb9,
-	0x74, 0x3f, 0xfc, 0xfd, 0xb9, 0x13, 0xb7, 0xb4, 0xe4, 0x05, 0x0c, 0x33, 0x9e, 0xea, 0x64, 0x86,
-	0x39, 0x13, 0xc1, 0xc2, 0xce, 0xd8, 0x99, 0xf4, 0xe3, 0xc0, 0xa0, 0xf6, 0xa0, 0x6b, 0x46, 0x5e,
-	0xc1, 0x41, 0x29, 0xe6, 0x8b, 0xb6, 0xac, 0x8b, 0xb2, 0x7d, 0x84, 0x1b, 0xdd, 0x5b, 0x08, 0xc5,
-	0xbc, 0x90, 0x25, 0x4f, 0x56, 0x0b, 0xa1, 0xb9, 0x5a, 0xd2, 0x19, 0x4f, 0x66, 0x0b, 0x5a, 0xcc,
-	0x79, 0xe8, 0x8e, 0x9d, 0x89, 0x1f, 0x9f, 0x58, 0xfe, 0xfb, 0x86, 0x7e, 0x87, 0x2c, 0xf9, 0x04,
-	0x7a, 0x4b, 0xaa, 0x17, 0x2a, 0xec, 0x8d, 0xbb, 0x93, 0x20, 0xb6, 0x01, 0x79, 0x09, 0xc3, 0x99,
-	0xcc, 0x32, 0xba, 0x54, 0x3c, 0x31, 0x36, 0xa9, 0xd0, 0xc3, 0x2c, 0xfb, 0x35, 0x6a, 0x4c, 0x40,
-	0x19, 0x2f, 0x52, 0x59, 0xce, 0x78, 0x92, 0x89, 0x5c, 0x68, 0x15, 0xee, 0x59, 0x59, 0x85, 0xde,
-	0x20, 0x48, 0x9e, 0x43, 0x3f, 0xa7, 0x0f, 0x49, 0x2a, 0x32, 0xae, 0x42, 0x7f, 0xec, 0x4c, 0x7a,
-	0xb1, 0x9f, 0xd3, 0x87, 0xaf, 0x4d, 0x5c, 0x93, 0x99, 0x28, 0xb8, 0x0a, 0xfb, 0x0d, 0x79, 0x63,
-	0xe2, 0x9a, 0x9c, 0x3e, 0x6a, 0xae, 0x42, 0x68, 0xc8, 0x4b, 0x13, 0x1b, 0x73, 0x0c, 0xb9, 0xa4,
-	0x7a, 0xb6, 0xa8, 0x24, 0x43, 0x94, 0xec, 0xe7, 0xf4, 0xe1, 0xce, 0xa0, 0x56, 0xf7, 0x02, 0x86,
-	0x8a, 0xa6, 0x3c, 0x59, 0xd7, 0x30, 0x40, 0x59, 0x60, 0xd0, 0xdb, 0xba, 0x8e, 0xb6, 0xca, 0x16,
-	0x13, 0x6c, 0xa8, 0x6c, 0x41, 0x6d, 0x95, 0x3d, 0x72, 0x7f, 0x43, 0x85, 0x27, 0x46, 0xff, 0x74,
-	0x80, 0xb4, 0x87, 0x45, 0x2d, 0x65, 0xa1, 0xb8, 0xb9, 0x4d, 0x5a, 0xca, 0xdc, 0x54, 0xbc, 0xc0,
-	0x61, 0x09, 0x62, 0xdf, 0x00, 0x77, 0x54, 0x2f, 0xc8, 0x33, 0xd8, 0xd3, 0xd2, 0x52, 0x1d, 0xa4,
-	0x3c, 0x2d, 0x6b, 0x02, 0xdf, 0x6a, 0x7a, 0xef, 0x99, 0xf0, 0x9a, 0x91, 0x63, 0xe8, 0x69, 0x69,
-	0x60, 0x17, 0x61, 0x57, 0xcb, 0x6b, 0x46, 0x4e, 0xc1, 0x97, 0x19, 0x4b, 0x72, 0xc9, 0x78, 0xd8,
-	0xc3, 0xd2, 0xf6, 0x64, 0xc6, 0x6e, 0x25, 0xe3, 0x86, 0x2a, 0xf8, 0xca, 0x52, 0x9e, 0xa5, 0x0a,
-	0xbe, 0x42, 0xea, 0x04, 0xbc, 0xa9, 0x28, 0x68, 0xf9, 0x58, 0x35, 0xb0, 0x8a, 0xcc, 0x75, 0x4b,
-	0xba, 0xaa, 0x2c, 0x66, 0x54, 0x53, 0xec, 0x50, 0x10, 0x07, 0x25, 0x5d, 0xa1, 0xc3, 0x57, 0x54,
-	0x53, 0x32, 0x86, 0x80, 0x17, 0x2c, 0x91, 0xa9, 0x15, 0x62, 0xa3, 0xfc, 0x18, 0x78, 0xc1, 0xbe,
-	0x4d, 0x51, 0x45, 0x5e, 0xc3, 0x81, 0xbc, 0xe7, 0x65, 0x9a, 0xc9, 0x55, 0x92, 0xd3, 0xf2, 0x47,
-	0x5e, 0x62, 0x0f, 0xfc, 0x78, 0x58, 0xc3, 0xb7, 0x88, 0x92, 0x4f, 0xa1, 0x5f, 0x8f, 0x18, 0xc3,
-	0x06, 0xf8, 0xf1, 0x1a, 0x30, 0x06, 0x6a, 0x29, 0x93, 0x8c, 0x96, 0x73, 0x8e, 0xc6, 0xfb, 0xb1,
-	0xaf, 0xa5, 0xbc, 0x31, 0xf1, 0x7b, 0xd7, 0xf7, 0x0f, 0xfb, 0xd1, 0x5f, 0x4e, 0x63, 0x3d, 0xcf,
-	0x34, 0xdd, 0xb5, 0x45, 0x6d, 0xd6, 0xcd, 0x6d, 0xad, 0x5b, 0xf4, 0x87, 0x03, 0x83, 0x56, 0xd1,
-	0xbb, 0x3b, 0x28, 0xd1, 0x25, 0x1c, 0x6f, 0xb8, 0x5b, 0x4d, 0xf6, 0x67, 0xe0, 0x31, 0x03, 0xa8,
-	0xd0, 0x19, 0x77, 0x27, 0x83, 0x8b, 0xe3, 0xda, 0xda, 0xb6, 0xb8, 0x92, 0x44, 0x1f, 0x1c, 0x18,
-	0xc6, 0x74, 0xb5, 0x83, 0xdf, 0xd1, 0xe8, 0x25, 0x1c, 0x34, 0x95, 0x55, 0x57, 0x23, 0xe0, 0xe2,
-	0xe0, 0xdb, 0x36, 0xe0, 0x73, 0xf4, 0x9b, 0x83, 0x3a, 0x9c, 0xed, 0x5d, 0xbb, 0xc2, 0x2b, 0x38,
-	0x5c, 0x97, 0xf6, 0x3f, 0x77, 0xf8, 0xdd, 0x81, 0x43, 0x73, 0xd1, 0xef, 0x34, 0xd5, 0x6a, 0xd7,
-	0x2e, 0x71, 0x0f, 0xfd, 0xa6, 0x36, 0x53, 0x7d, 0x6b, 0x11, 0xf0, 0xd9, 0x7c, 0x27, 0x28, 0x63,
-	0x42, 0x0b, 0x59, 0x28, 0x3c, 0xa9, 0x17, 0xaf, 0x01, 0xc3, 0x32, 0x9e, 0x71, 0xcb, 0x76, 0x2d,
-	0xdb, 0x00, 0xf5, 0xe4, 0x63, 0x4e, 0x17, 0x73, 0x9a, 0xc9, 0x37, 0x2b, 0x14, 0x7d, 0x05, 0x47,
-	0x2d, 0x4f, 0x2a, 0xf7, 0x5e, 0x43, 0x4f, 0x19, 0xa0, 0x9a, 0xed, 0xa3, 0xda, 0x8f, 0xb5, 0xd2,
-	0xf2, 0x17, 0xbf, 0x74, 0x61, 0x80, 0x20, 0x2f, 0xef, 0xc5, 0x8c, 0x93, 0x5b, 0x80, 0xf5, 0xaf,
-	0x00, 0x39, 0xfd, 0x68, 0x27, 0xd6, 0xe3, 0x3f, 0x1a, 0x3d, 0x45, 0xd9, 0xd3, 0x23, 0xef, 0xdf,
-	0x5f, 0x27, 0x1d, 0xbf, 0xf3, 0xc6, 0x21, 0x77, 0x9b, 0x1f, 0x89, 0xd1, 0x53, 0x3b, 0x56, 0x25,
-	0x7c, 0xfe, 0x24, 0xb7, 0x95, 0xf1, 0x0a, 0xf6, 0xaa, 0x71, 0x27, 0x27, 0x4d, 0x97, 0x37, 0x36,
-	0x73, 0xf4, 0x6c, 0x0b, 0xdf, 0xca, 0xf2, 0x0d, 0xf8, 0xf5, 0xc4, 0x91, 0xb6, 0xbc, 0xbd, 0x1e,
-	0xa3, 0x70, 0x9b, 0xd8, 0x4a, 0xf4, 0xbe, 0xdd, 0xf5, 0x70, 0xdb, 0xe6, 0x2a, 0xd5, 0xe9, 0x13,
-	0xcc, 0xc7, 0xb9, 0x2e, 0xdf, 0xfc, 0x60, 0x54, 0x19, 0x9d, 0x9e, 0xcd, 0x64, 0x7e, 0x6e, 0x1f,
-	0xbf, 0x90, 0xe5, 0xfc, 0xdc, 0xbe, 0x7b, 0x8e, 0xff, 0xea, 0xce, 0xe7, 0xb2, 0x8a, 0x97, 0xd3,
-	0xa9, 0x87, 0xd0, 0x97, 0xff, 0x05, 0x00, 0x00, 0xff, 0xff, 0x98, 0x12, 0xa9, 0x58, 0x18, 0x0a,
-	0x00, 0x00,
+	// 1040 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x56, 0xcd, 0x6e, 0xdb, 0x46,
+	0x10, 0x2e, 0x25, 0x8a, 0xa2, 0x46, 0xb4, 0xac, 0xac, 0x03, 0x9b, 0x96, 0x0b, 0x54, 0x20, 0xf2,
+	0x23, 0xf4, 0x47, 0x0e, 0x9c, 0x4b, 0x0e, 0xbd, 0xc4, 0xa6, 0x9c, 0x2a, 0xb5, 0x6a, 0x81, 0x09,
+	0x50, 0xb4, 0x17, 0x62, 0x25, 0x2e, 0x25, 0xa2, 0x24, 0x57, 0x25, 0x37, 0x96, 0xfd, 0x24, 0x4d,
+	0x7b, 0x2e, 0x50, 0xa0, 0xc7, 0x3e, 0x44, 0x1f, 0xa6, 0x4f, 0x50, 0xf4, 0x54, 0xec, 0x2e, 0x49,
+	0x51, 0x96, 0xd2, 0x53, 0x0f, 0xba, 0x71, 0xbe, 0xef, 0xf3, 0xec, 0xec, 0xb7, 0x33, 0x23, 0x03,
+	0x78, 0x81, 0xef, 0xf7, 0x17, 0x09, 0x65, 0x14, 0x69, 0xb3, 0x80, 0xe1, 0xf0, 0xae, 0x03, 0x61,
+	0x10, 0x33, 0x89, 0x75, 0x8c, 0x74, 0x8e, 0x13, 0xe2, 0xc9, 0xc8, 0xfa, 0x5d, 0x85, 0x07, 0x17,
+	0x34, 0x8a, 0x02, 0x66, 0x07, 0xbe, 0xef, 0x90, 0x1f, 0xdf, 0x91, 0x94, 0xa1, 0x17, 0x00, 0x09,
+	0x59, 0xd0, 0x34, 0x60, 0x34, 0xb9, 0x33, 0x95, 0xae, 0xd2, 0x6b, 0x9e, 0xa1, 0xbe, 0x4c, 0xd6,
+	0x77, 0x0a, 0xe6, 0x5c, 0x7d, 0xff, 0xe7, 0xe7, 0x8a, 0x53, 0xd2, 0xa2, 0x47, 0xd0, 0x0a, 0x89,
+	0xcf, 0xdc, 0xa9, 0xc8, 0xe9, 0x06, 0x9e, 0x59, 0xe9, 0x2a, 0xbd, 0x86, 0x63, 0x70, 0x54, 0x1e,
+	0x34, 0xf4, 0xd0, 0x13, 0xd8, 0x4f, 0x82, 0xd9, 0xbc, 0x2c, 0xab, 0x0a, 0xd9, 0x9e, 0x80, 0x0b,
+	0xdd, 0x0b, 0x30, 0x83, 0x59, 0x4c, 0x13, 0xe2, 0x2e, 0xe7, 0x01, 0x23, 0xe9, 0x02, 0x4f, 0x89,
+	0x3b, 0x9d, 0xe3, 0x78, 0x46, 0x4c, 0xb5, 0xab, 0xf4, 0x74, 0xe7, 0x50, 0xf2, 0xdf, 0x16, 0xf4,
+	0x85, 0x60, 0xd1, 0x43, 0xa8, 0x2d, 0x30, 0x9b, 0xa7, 0x66, 0xad, 0x5b, 0xed, 0x19, 0x8e, 0x0c,
+	0xd0, 0x63, 0x68, 0x4d, 0x69, 0x18, 0xe2, 0x45, 0x4a, 0x5c, 0x6e, 0x53, 0x6a, 0x6a, 0x22, 0xcb,
+	0x5e, 0x8e, 0x72, 0x13, 0x84, 0x8c, 0xc4, 0x3e, 0x4d, 0xa6, 0xc4, 0x0d, 0x83, 0x28, 0x60, 0xa9,
+	0x59, 0x97, 0xb2, 0x0c, 0xbd, 0x12, 0x20, 0x3a, 0x81, 0x46, 0x84, 0x6f, 0x5d, 0x3f, 0x08, 0x49,
+	0x6a, 0xea, 0x5d, 0xa5, 0x57, 0x73, 0xf4, 0x08, 0xdf, 0x5e, 0xf2, 0x38, 0x27, 0xc3, 0x20, 0x26,
+	0xa9, 0xd9, 0x28, 0xc8, 0x2b, 0x1e, 0xe7, 0xe4, 0xe4, 0x8e, 0x91, 0xd4, 0x84, 0x82, 0x3c, 0xe7,
+	0x31, 0x37, 0x87, 0x93, 0x0b, 0xcc, 0xa6, 0xf3, 0x4c, 0xd2, 0x12, 0x92, 0xbd, 0x08, 0xdf, 0x8e,
+	0x39, 0x2a, 0x75, 0x8f, 0xa0, 0x95, 0x62, 0x9f, 0xb8, 0xab, 0x1a, 0x9a, 0x42, 0x66, 0x70, 0x74,
+	0x94, 0xd7, 0x51, 0x56, 0xc9, 0x62, 0x8c, 0x35, 0x95, 0x2c, 0xa8, 0xac, 0x92, 0x47, 0xee, 0xad,
+	0xa9, 0xc4, 0x89, 0xd6, 0xdf, 0x15, 0x40, 0xe5, 0x66, 0x49, 0x17, 0x34, 0x4e, 0x09, 0xbf, 0x8d,
+	0x9f, 0xd0, 0x88, 0x57, 0x3c, 0x17, 0xcd, 0x62, 0x38, 0x3a, 0x07, 0xc6, 0x98, 0xcd, 0xd1, 0x11,
+	0xd4, 0x19, 0x95, 0x54, 0x45, 0x50, 0x1a, 0xa3, 0x39, 0x21, 0xfe, 0xaa, 0x78, 0x7b, 0x8d, 0x87,
+	0x43, 0x0f, 0x1d, 0x40, 0x8d, 0x51, 0x0e, 0xab, 0x02, 0x56, 0x19, 0x1d, 0x7a, 0xe8, 0x18, 0x74,
+	0x1a, 0x7a, 0x6e, 0x44, 0x3d, 0x62, 0xd6, 0x44, 0x69, 0x75, 0x1a, 0x7a, 0x23, 0xea, 0x11, 0x4e,
+	0xc5, 0x64, 0x29, 0x29, 0x4d, 0x52, 0x31, 0x59, 0x0a, 0xea, 0x10, 0xb4, 0x49, 0x10, 0xe3, 0xe4,
+	0x2e, 0x7b, 0xc0, 0x2c, 0xe2, 0xd7, 0x4d, 0xf0, 0x32, 0xb3, 0xd8, 0xc3, 0x0c, 0x8b, 0x17, 0x32,
+	0x1c, 0x23, 0xc1, 0x4b, 0xe1, 0xb0, 0x8d, 0x19, 0x46, 0x5d, 0x30, 0x48, 0xec, 0xb9, 0xd4, 0x97,
+	0x42, 0xf1, 0x50, 0xba, 0x03, 0x24, 0xf6, 0xae, 0x7d, 0xa1, 0x42, 0x4f, 0x61, 0x9f, 0xde, 0x90,
+	0xc4, 0x0f, 0xe9, 0xd2, 0x8d, 0x70, 0xf2, 0x03, 0x49, 0xc4, 0x1b, 0xe8, 0x4e, 0x2b, 0x87, 0x47,
+	0x02, 0x45, 0x1f, 0x43, 0x23, 0x6f, 0x31, 0x4f, 0x3c, 0x80, 0xee, 0xac, 0x00, 0x6e, 0x20, 0xa3,
+	0xd4, 0x0d, 0x71, 0x32, 0x23, 0xc2, 0x78, 0xdd, 0xd1, 0x19, 0xa5, 0x57, 0x3c, 0x7e, 0xad, 0xea,
+	0x7a, 0xbb, 0x61, 0xfd, 0xa1, 0x14, 0xd6, 0x93, 0x90, 0xe1, 0x5d, 0x1b, 0xd4, 0x62, 0xdc, 0xd4,
+	0xd2, 0xb8, 0x59, 0xbf, 0x29, 0xd0, 0x2c, 0x15, 0xbd, 0xbb, 0x8d, 0x62, 0x9d, 0xc3, 0xc1, 0x9a,
+	0xbb, 0x59, 0x67, 0x7f, 0x06, 0x9a, 0xc7, 0x81, 0xd4, 0x54, 0xba, 0xd5, 0x5e, 0xf3, 0xec, 0x20,
+	0xb7, 0xb6, 0x2c, 0xce, 0x24, 0xd6, 0x7b, 0x05, 0x5a, 0x0e, 0x5e, 0xee, 0xe0, 0x1e, 0xb5, 0x1e,
+	0xc3, 0x7e, 0x51, 0x59, 0x76, 0x35, 0x04, 0xaa, 0x68, 0x7c, 0xf9, 0x0c, 0xe2, 0xdb, 0xfa, 0x59,
+	0x11, 0x3a, 0xd1, 0xdb, 0xbb, 0x76, 0x85, 0x27, 0xd0, 0x5e, 0x95, 0xf6, 0x1f, 0x77, 0xf8, 0x45,
+	0x81, 0x36, 0xbf, 0xe8, 0x1b, 0x86, 0x59, 0xba, 0x6b, 0x97, 0xb8, 0x81, 0x46, 0x51, 0x1b, 0xaf,
+	0xbe, 0x34, 0x08, 0xe2, 0x9b, 0xef, 0x09, 0xec, 0x79, 0x01, 0x0b, 0x68, 0x9c, 0x8a, 0x93, 0x6a,
+	0xce, 0x0a, 0xe0, 0xac, 0x47, 0x42, 0x22, 0xd9, 0xaa, 0x64, 0x0b, 0x20, 0xef, 0x7c, 0x91, 0x53,
+	0x15, 0x39, 0x79, 0xe7, 0xf3, 0x11, 0xb2, 0xbe, 0x84, 0x07, 0x25, 0x4f, 0x32, 0xf7, 0x9e, 0x42,
+	0x2d, 0xe5, 0x40, 0xd6, 0xdb, 0x0f, 0x72, 0x3f, 0x56, 0x4a, 0xc9, 0x5b, 0x11, 0x1c, 0x5d, 0x06,
+	0xb1, 0x27, 0x7f, 0x59, 0x45, 0xc2, 0xff, 0xc1, 0x58, 0x13, 0xea, 0xd2, 0x2c, 0x7e, 0xcf, 0x6a,
+	0xaf, 0xe1, 0xe4, 0xa1, 0x75, 0x09, 0xe6, 0xe6, 0x71, 0x59, 0xcd, 0x9f, 0xe6, 0x7b, 0x46, 0xd6,
+	0xfc, 0xb0, 0x98, 0xc7, 0xb2, 0x38, 0xdb, 0x3e, 0xbf, 0x2a, 0x60, 0x94, 0xf1, 0xad, 0x86, 0x3f,
+	0x07, 0x8d, 0x5f, 0xf2, 0x9d, 0x74, 0xbb, 0x75, 0x76, 0xb2, 0x2d, 0x63, 0xff, 0x8d, 0x90, 0x38,
+	0x99, 0xd4, 0xfa, 0x1a, 0x34, 0x89, 0xa0, 0x06, 0xd4, 0x5e, 0xda, 0xf6, 0xc0, 0x6e, 0x7f, 0x84,
+	0x0c, 0xd0, 0x47, 0xd7, 0xf6, 0xf0, 0x72, 0x38, 0xb0, 0xdb, 0x0a, 0x6a, 0x42, 0xdd, 0x1e, 0x5c,
+	0x0d, 0xde, 0x0e, 0xec, 0x76, 0x05, 0xed, 0x43, 0xf3, 0xed, 0x77, 0xe3, 0x81, 0x7b, 0xf1, 0xd5,
+	0xcb, 0x6f, 0x5e, 0x0d, 0xda, 0x55, 0x04, 0xa0, 0x5d, 0x5c, 0x8f, 0xb9, 0x52, 0x3d, 0xfb, 0xab,
+	0x0a, 0x4d, 0x61, 0x39, 0x49, 0x6e, 0x82, 0x29, 0x41, 0x23, 0x80, 0xd5, 0x6f, 0x2c, 0x3a, 0xbe,
+	0xb7, 0x71, 0x56, 0xcb, 0xa5, 0xd3, 0xd9, 0x46, 0x49, 0x9f, 0x2c, 0xed, 0x9f, 0x9f, 0x7a, 0x15,
+	0xbd, 0xf2, 0x4c, 0x41, 0xe3, 0xf5, 0x15, 0xdc, 0xd9, 0xb6, 0xc1, 0xb2, 0x84, 0x27, 0x5b, 0xb9,
+	0x8d, 0x8c, 0x36, 0xd4, 0xb3, 0x65, 0x82, 0x0e, 0x8b, 0xa7, 0x5e, 0xdb, 0x7b, 0x9d, 0xa3, 0x0d,
+	0x7c, 0x23, 0xcb, 0x2b, 0xd0, 0xf3, 0x79, 0x46, 0x65, 0x79, 0x79, 0xf9, 0x74, 0xcc, 0x4d, 0x62,
+	0x23, 0xd1, 0xeb, 0xf2, 0x4c, 0x99, 0x9b, 0x4d, 0x9c, 0xa5, 0x3a, 0xde, 0xc2, 0x6c, 0xe4, 0x72,
+	0xa1, 0x7d, 0xbf, 0xf5, 0xd0, 0x27, 0xf9, 0x1f, 0x7e, 0x60, 0x06, 0x3a, 0xdd, 0x0f, 0x0b, 0xee,
+	0x1f, 0x70, 0xfe, 0xec, 0x7b, 0x2e, 0x0e, 0xf1, 0xa4, 0x3f, 0xa5, 0xd1, 0xa9, 0xfc, 0xfc, 0x82,
+	0x26, 0xb3, 0x53, 0x99, 0xe2, 0x54, 0xfc, 0x53, 0x7e, 0x3a, 0xa3, 0x59, 0xbc, 0x98, 0x4c, 0x34,
+	0x01, 0x3d, 0xff, 0x37, 0x00, 0x00, 0xff, 0xff, 0x0b, 0xb2, 0x24, 0xdd, 0xd7, 0x0b, 0x00, 0x00,
 }
 
 // Reference imports to suppress errors if they are not otherwise used.
@@ -930,6 +1115,8 @@ type DiffServiceClient interface {
 	RawDiff(ctx context.Context, in *RawDiffRequest, opts ...grpc.CallOption) (DiffService_RawDiffClient, error)
 	RawPatch(ctx context.Context, in *RawPatchRequest, opts ...grpc.CallOption) (DiffService_RawPatchClient, error)
 	DiffStats(ctx context.Context, in *DiffStatsRequest, opts ...grpc.CallOption) (DiffService_DiffStatsClient, error)
+	// Return a list of files changed along with the status of each file
+	FindChangedPaths(ctx context.Context, in *FindChangedPathsRequest, opts ...grpc.CallOption) (DiffService_FindChangedPathsClient, error)
 }
 
 type diffServiceClient struct {
@@ -1100,6 +1287,38 @@ func (x *diffServiceDiffStatsClient) Recv() (*DiffStatsResponse, error) {
 	return m, nil
 }
 
+func (c *diffServiceClient) FindChangedPaths(ctx context.Context, in *FindChangedPathsRequest, opts ...grpc.CallOption) (DiffService_FindChangedPathsClient, error) {
+	stream, err := c.cc.NewStream(ctx, &_DiffService_serviceDesc.Streams[5], "/gitaly.DiffService/FindChangedPaths", opts...)
+	if err != nil {
+		return nil, err
+	}
+	x := &diffServiceFindChangedPathsClient{stream}
+	if err := x.ClientStream.SendMsg(in); err != nil {
+		return nil, err
+	}
+	if err := x.ClientStream.CloseSend(); err != nil {
+		return nil, err
+	}
+	return x, nil
+}
+
+type DiffService_FindChangedPathsClient interface {
+	Recv() (*FindChangedPathsResponse, error)
+	grpc.ClientStream
+}
+
+type diffServiceFindChangedPathsClient struct {
+	grpc.ClientStream
+}
+
+func (x *diffServiceFindChangedPathsClient) Recv() (*FindChangedPathsResponse, error) {
+	m := new(FindChangedPathsResponse)
+	if err := x.ClientStream.RecvMsg(m); err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
 // DiffServiceServer is the server API for DiffService service.
 type DiffServiceServer interface {
 	// Returns stream of CommitDiffResponse with patches chunked over messages
@@ -1109,6 +1328,8 @@ type DiffServiceServer interface {
 	RawDiff(*RawDiffRequest, DiffService_RawDiffServer) error
 	RawPatch(*RawPatchRequest, DiffService_RawPatchServer) error
 	DiffStats(*DiffStatsRequest, DiffService_DiffStatsServer) error
+	// Return a list of files changed along with the status of each file
+	FindChangedPaths(*FindChangedPathsRequest, DiffService_FindChangedPathsServer) error
 }
 
 // UnimplementedDiffServiceServer can be embedded to have forward compatible implementations.
@@ -1130,6 +1351,9 @@ func (*UnimplementedDiffServiceServer) RawPatch(req *RawPatchRequest, srv DiffSe
 func (*UnimplementedDiffServiceServer) DiffStats(req *DiffStatsRequest, srv DiffService_DiffStatsServer) error {
 	return status.Errorf(codes.Unimplemented, "method DiffStats not implemented")
 }
+func (*UnimplementedDiffServiceServer) FindChangedPaths(req *FindChangedPathsRequest, srv DiffService_FindChangedPathsServer) error {
+	return status.Errorf(codes.Unimplemented, "method FindChangedPaths not implemented")
+}
 
 func RegisterDiffServiceServer(s *grpc.Server, srv DiffServiceServer) {
 	s.RegisterService(&_DiffService_serviceDesc, srv)
@@ -1240,6 +1464,27 @@ func (x *diffServiceDiffStatsServer) Send(m *DiffStatsResponse) error {
 	return x.ServerStream.SendMsg(m)
 }
 
+func _DiffService_FindChangedPaths_Handler(srv interface{}, stream grpc.ServerStream) error {
+	m := new(FindChangedPathsRequest)
+	if err := stream.RecvMsg(m); err != nil {
+		return err
+	}
+	return srv.(DiffServiceServer).FindChangedPaths(m, &diffServiceFindChangedPathsServer{stream})
+}
+
+type DiffService_FindChangedPathsServer interface {
+	Send(*FindChangedPathsResponse) error
+	grpc.ServerStream
+}
+
+type diffServiceFindChangedPathsServer struct {
+	grpc.ServerStream
+}
+
+func (x *diffServiceFindChangedPathsServer) Send(m *FindChangedPathsResponse) error {
+	return x.ServerStream.SendMsg(m)
+}
+
 var _DiffService_serviceDesc = grpc.ServiceDesc{
 	ServiceName: "gitaly.DiffService",
 	HandlerType: (*DiffServiceServer)(nil),
@@ -1270,6 +1515,11 @@ var _DiffService_serviceDesc = grpc.ServiceDesc{
 			Handler:       _DiffService_DiffStats_Handler,
 			ServerStreams: true,
 		},
+		{
+			StreamName:    "FindChangedPaths",
+			Handler:       _DiffService_FindChangedPaths_Handler,
+			ServerStreams: true,
+		},
 	},
 	Metadata: "diff.proto",
 }
diff --git a/ruby/proto/gitaly/diff_pb.rb b/ruby/proto/gitaly/diff_pb.rb
index 3afb4c190..8baa2817f 100644
--- a/ruby/proto/gitaly/diff_pb.rb
+++ b/ruby/proto/gitaly/diff_pb.rb
@@ -84,6 +84,24 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
     add_message "gitaly.DiffStatsResponse" do
       repeated :stats, :message, 1, "gitaly.DiffStats"
     end
+    add_message "gitaly.FindChangedPathsRequest" do
+      optional :repository, :message, 1, "gitaly.Repository"
+      repeated :commits, :string, 2
+    end
+    add_message "gitaly.FindChangedPathsResponse" do
+      repeated :paths, :message, 1, "gitaly.ChangedPaths"
+    end
+    add_message "gitaly.ChangedPaths" do
+      optional :path, :bytes, 1
+      optional :status, :enum, 2, "gitaly.ChangedPaths.Status"
+    end
+    add_enum "gitaly.ChangedPaths.Status" do
+      value :ADDED, 0
+      value :MODIFIED, 1
+      value :DELETED, 2
+      value :TYPE_CHANGE, 3
+      value :COPIED, 4
+    end
   end
 end
 
@@ -100,4 +118,8 @@ module Gitaly
   DiffStatsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.DiffStatsRequest").msgclass
   DiffStats = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.DiffStats").msgclass
   DiffStatsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.DiffStatsResponse").msgclass
+  FindChangedPathsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.FindChangedPathsRequest").msgclass
+  FindChangedPathsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.FindChangedPathsResponse").msgclass
+  ChangedPaths = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ChangedPaths").msgclass
+  ChangedPaths::Status = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ChangedPaths.Status").enummodule
 end
diff --git a/ruby/proto/gitaly/diff_services_pb.rb b/ruby/proto/gitaly/diff_services_pb.rb
index e2e34621d..27fe976e2 100644
--- a/ruby/proto/gitaly/diff_services_pb.rb
+++ b/ruby/proto/gitaly/diff_services_pb.rb
@@ -21,6 +21,8 @@ module Gitaly
       rpc :RawDiff, Gitaly::RawDiffRequest, stream(Gitaly::RawDiffResponse)
       rpc :RawPatch, Gitaly::RawPatchRequest, stream(Gitaly::RawPatchResponse)
       rpc :DiffStats, Gitaly::DiffStatsRequest, stream(Gitaly::DiffStatsResponse)
+      # Return a list of files changed along with the status of each file
+      rpc :FindChangedPaths, Gitaly::FindChangedPathsRequest, stream(Gitaly::FindChangedPathsResponse)
     end
 
     Stub = Service.rpc_stub_class