summaryrefslogtreecommitdiff
path: root/lib/gitlab/gitaly_client/blob_service.rb
blob: 7ea8e8d0857e4a5307a16b2e7a8d0cb613c99bdc (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
module Gitlab
  module GitalyClient
    class BlobService
      def initialize(repository)
        @gitaly_repo = repository.gitaly_repository
      end

      def get_blob(oid:, limit:)
        request = Gitaly::GetBlobRequest.new(
          repository: @gitaly_repo,
          oid: oid,
          limit: limit
        )
        response = GitalyClient.call(@gitaly_repo.storage_name, :blob_service, :get_blob, request)

        blob = response.first
        return unless blob.oid.present?

        data = response.reduce(blob.data.dup) { |memo, msg| memo << msg.data.dup }

        Gitlab::Git::Blob.new(
          id: blob.oid,
          size: blob.size,
          data: data,
          binary: Gitlab::Git::Blob.binary?(data)
        )
      end
    end
  end
end