fixes #22951 - support docker v2 api

Author: Tom McKay

app/controllers/katello/api/registry/registry_proxies_controller.rb

@@ -0,0 +1,38 @@
+require 'katello/util/data'
+
+module Katello
+  module Resources
+    require 'rest_client'
+
+    module Registry
+      class Proxy
+        def self.logger
+          ::Foreman::Logging.logger('katello/registry_proxy')
+        end
+
+        def self.get(path, headers = {:accept => :json})
+          logger.debug "Sending GET request to Registry: #{path}"
+          client = RegistryResource.rest_client(Net::HTTP::Get, :get, path)
+          client.get(headers)
+        end
+      end
+
+      class RegistryResource < HttpResource
+        cfg = SETTINGS[:katello][:registry]
+        url = cfg[:url]
+        uri = URI.parse(url)
+        self.prefix = uri.path
+        self.site = "#{uri.scheme}://#{uri.host}:#{uri.port}"
+        self.ca_cert_file = cfg[:ca_cert_file]
+
+        class << self
+          def process_response(response)
+            debug_level = response.code >= 400 ? :error : :debug
+            logger.send(debug_level, "Registry request returned with code #{response.code}")
+            super
+          end
+        end
+      end
+    end
+  end
+end

app/lib/katello/resources/registry.rb

@@ -172,6 +172,7 @@ class Repository < Katello::Model
     scoped_search :on => :distribution_uuid, :complete_value => true
     scoped_search :on => :ignore_global_proxy, :complete_value => true
     scoped_search :on => :redhat, :complete_value => { :true => true, :false => false }, :ext_method => :search_by_redhat
+    scoped_search :on => :container_repository_name, :complete_value => true
 
     def organization
       if self.environment

app/models/katello/repository.rb

@@ -0,0 +1,29 @@
+require 'katello/api/mapper_extensions'
+
+class ActionDispatch::Routing::Mapper
+  include Katello::Routing::MapperExtensions
+end
+
+Katello::Engine.routes.draw do
+  scope :module => :api do
+    scope :module => :registry, :constraints => { :tag => /[0-9a-zA-Z\-_.:]*/, :digest => /[0-9a-zA-Z:]*/ } do
+      match '/v2/token' => 'registry_proxies#token', :via => :get
+      match '/v2/token' => 'registry_proxies#token', :via => :post
+      match '/v2/:repository/manifests/:tag' => 'registry_proxies#pull_manifest', :via => :get
+      match '/v2/:repository/manifests/:tag' => 'registry_proxies#push_manifest', :via => :put
+      match '/v2/:repository/blobs/:digest' => 'registry_proxies#pull_blob', :via => :get
+      match '/v2/:repository/blobs/:digest' => 'registry_proxies#check_blob', :via => :head
+      match '/v2/:repository/blobs/uploads' => 'registry_proxies#start_upload_blob', :via => :post
+      match '/v2/:repository/blobs/uploads/:uuid' => 'registry_proxies#chunk_upload_blob', :via => :post
+      match '/v2/:repository/blobs/uploads/:uuid' => 'registry_proxies#finish_upload_blob', :via => :put
+      match '/v2/:repository/blobs/uploads/:uuid' => 'registry_proxies#upload_blob', :via => :patch
+      match '/v2/:repository/blobs/uploads/:uuid' => 'registry_proxies#status_upload_blob', :via => :get
+      match '/v2/:repository/blobs/uploads/:uuid' => 'registry_proxies#cancel_upload_blob', :via => :delete
+      match '/v2/_catalog' => 'registry_proxies#catalog', :via => :get
+      match '/v2/:repository/tags/list' => 'registry_proxies#tags_list', :via => :get
+      match '/v2' => 'registry_proxies#ping', :via => :get
+      match '/v1/_ping' => 'registry_proxies#v1_ping', :via => :get
+      match '/v1/search' => 'registry_proxies#v1_search', :via => :get
+    end
+  end
+end

config/routes/api/registry.rb

@@ -103,6 +103,7 @@ class Engine < ::Rails::Engine
     initializer "katello.paths", :before => :sooner_routes_load do |app|
       app.routes_reloader.paths << "#{Katello::Engine.root}/config/routes/api/v2.rb"
       app.routes_reloader.paths << "#{Katello::Engine.root}/config/routes/api/rhsm.rb"
+      app.routes_reloader.paths << "#{Katello::Engine.root}/config/routes/api/registry.rb"
       app.routes_reloader.paths.unshift("#{Katello::Engine.root}/config/routes/overrides.rb")
     end
 

lib/katello/engine.rb

@@ -0,0 +1,19 @@
+require 'katello/plugin.rb'
+
+Foreman::AccessControl.permission(:create_personal_access_tokens).actions.concat [
+  'katello/api/registry/registry_proxies/token',
+  'katello/api/registry/registry_proxies/v1_ping',
+  'katello/api/registry/registry_proxies/ping',
+  'katello/api/registry/registry_proxies/v1_search',
+  'katello/api/registry/registry_proxies/catalog',
+  'katello/api/registry/registry_proxies/tags_list',
+  'katello/api/registry/registry_proxies/pull_manifest',
+  'katello/api/registry/registry_proxies/push_manifest',
+  'katello/api/registry/registry_proxies/pull_blob',
+  'katello/api/registry/registry_proxies/check_blob',
+  'katello/api/registry/registry_proxies/start_upload_blob',
+  'katello/api/registry/registry_proxies/chunk_upload_blob',
+  'katello/api/registry/registry_proxies/finish_upload_blob',
+  'katello/api/registry/registry_proxies/status_upload_blob',
+  'katello/api/registry/registry_proxies/cancel_upload_blob'
+]

lib/katello/permissions/registry_permissions.rb

@@ -223,6 +223,7 @@
   logger :cp_proxy, :enabled => true
   logger :action, :enabled => true
   logger :manifest_import_logger, :enabled => true
+  logger :registry_proxy, :enabled => true
 
   widget 'errata_widget', :name => 'Latest Errata', :sizey => 1, :sizex => 6
   widget 'content_views_widget', :name => 'Content Views', :sizey => 1, :sizex => 6