Build backup new endpoints (#1179)

Merge part 2 PRD

Author: piotrmilcarz

lib/travis/api/app/endpoint.rb

@@ -120,6 +120,7 @@ def endpoint(link, query_values = {})
 require 'travis/api/app/endpoint/branches'
 require 'travis/api/app/endpoint/broadcasts'
 require 'travis/api/app/endpoint/builds'
+require 'travis/api/app/endpoint/build_backups'
 require 'travis/api/app/endpoint/documentation'
 require 'travis/api/app/endpoint/endpoints'
 require 'travis/api/app/endpoint/env_vars'

lib/travis/api/app/endpoint/build_backups.rb

@@ -0,0 +1,18 @@
+require 'travis/api/app'
+require 'travis/api/app/responders/base'
+
+class Travis::Api::App
+  class Endpoint
+    class BuildBackups < Endpoint
+      include Helpers::Accept
+
+      before { authenticate_by_mode! }
+
+      get '/' do
+        prefer_follower do
+          respond_with service(:find_build_backups, params)
+        end
+      end
+    end
+  end
+end

lib/travis/api/v3/model.rb

@@ -8,5 +8,11 @@ class Model < ActiveRecord::Base
     def self.===(other)
       super or (self == Model and other.class.parent == Models)
     end
+
+    def ro_mode?
+      return false unless Travis.config.org? && Travis.config.read_only?
+
+      !Travis::Features.owner_active?(:read_only_disabled, self)
+    end
   end
 end

lib/travis/api/v3/models/build_backup.rb

@@ -0,0 +1,7 @@
+module Travis::API::V3
+  class Models::BuildBackup < Model
+    attr_accessor :content
+
+    belongs_to :repository
+  end
+end

lib/travis/api/v3/queries/build_backup.rb

@@ -0,0 +1,21 @@
+module Travis::API::V3
+  class Queries::BuildBackup < RemoteQuery
+    params :id
+
+    def find
+      raise WrongParams, 'missing build_backup.id'.freeze unless id
+      build_backup = Models::BuildBackup.find_by_id(id)
+      content = get(build_backup.file_name)
+      raise EntityMissing, 'could not retrieve content'.freeze if content.nil?
+      build_backup.content = content.force_encoding('UTF-8') if content.present?
+
+      build_backup
+    end
+
+    private
+
+    def main_type
+      'build_backup'
+    end
+  end
+end

lib/travis/api/v3/queries/build_backups.rb

@@ -0,0 +1,10 @@
+module Travis::API::V3
+  class Queries::BuildBackups < Query
+    params :repository_id
+
+    def all
+      return Models::BuildBackup.where(repository_id: repository_id) if repository_id
+      raise WrongParams, 'missing build_backups.repository_id'.freeze
+    end
+  end
+end

lib/travis/api/v3/remote_query.rb

@@ -18,6 +18,13 @@ def fetch
       storage_objects
     end
 
+    def get(key)
+      io = StringIO.new
+      gcs_connection.get_object(gcs_config[:bucket_name], key, download_dest: io)
+      io.rewind
+      io.read
+    end
+
     def remove(objects)
       objects.each do |object|
         raise SourceUnknown "#{object.source} is an unknown source." unless ['s3', 'gcs'].include? object.source
@@ -91,7 +98,7 @@ def s3_objects
 
     def gcs_connection
       gcs = ::Google::Apis::StorageV1::StorageService.new
-      json_key_io = StringIO.new(gcs_config[:json_key])
+      json_key_io = StringIO.new(JSON.dump(gcs_config[:json_key]))
 
       gcs.authorization = ::Google::Auth::ServiceAccountCredentials.make_creds(
         json_key_io: json_key_io,

lib/travis/api/v3/renderer/build_backup.rb

@@ -0,0 +1,12 @@
+module Travis::API::V3
+  class Renderer::BuildBackup < ModelRenderer
+    representation(:minimal, :file_name, :created_at)
+    representation(:standard, *representations[:minimal])
+
+    def self.render(model, representation = :standard, **options)
+      return super unless options[:accept] == 'text/plain'.freeze
+
+      model.content
+    end
+  end
+end

lib/travis/api/v3/renderer/build_backups.rb

@@ -0,0 +1,6 @@
+module Travis::API::V3
+  class Renderer::BuildBackups < CollectionRenderer
+    type           :build_backups
+    collection_key :build_backups
+  end
+end

lib/travis/api/v3/renderer/owner.rb

@@ -4,9 +4,9 @@ module Travis::API::V3
   class Renderer::Owner < ModelRenderer
     include Renderer::AvatarURL
 
-    representation(:minimal,    :id, :login, :name, :vcs_type)
+    representation(:minimal,    :id, :login, :name, :vcs_type, :ro_mode)
     representation(:standard,   :id, :login, :name, :github_id, :vcs_id, :vcs_type, :avatar_url, :education,
-                   :allow_migration, :allowance)
+                   :allow_migration, :allowance, :ro_mode)
     representation(:additional, :repositories, :installation)
 
     def initialize(*)
@@ -33,12 +33,18 @@ def allow_migration
     def allowance
       return BillingClient.default_allowance_response(id) if Travis.config.org?
       return BillingClient.default_allowance_response(id) unless access_control.user
-      
+
       BillingClient.minimal_allowance_response(id)
     end
 
     def owner_type
       vcs_type.match(/User$/) ? 'User' : 'Organization'
     end
+
+    def ro_mode
+      return false unless Travis.config.org? && Travis.config.read_only?
+
+      !Travis::Features.owner_active?(:read_only_disabled, model)
+    end
   end
 end