diff options
Diffstat (limited to 'lib/container_registry/client.rb')
-rw-r--r-- | lib/container_registry/client.rb | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/lib/container_registry/client.rb b/lib/container_registry/client.rb index c80f49f5ae0..52c92bc694b 100644 --- a/lib/container_registry/client.rb +++ b/lib/container_registry/client.rb @@ -1,13 +1,13 @@ # frozen_string_literal: true -require 'faraday' -require 'faraday_middleware' +require "faraday" +require "faraday_middleware" module ContainerRegistry class Client attr_accessor :uri - MANIFEST_VERSION = 'application/vnd.docker.distribution.manifest.v2+json'.freeze + MANIFEST_VERSION = "application/vnd.docker.distribution.manifest.v2+json" # Taken from: FaradayMiddleware::FollowRedirects REDIRECT_CODES = Set.new [301, 302, 303, 307] @@ -27,7 +27,7 @@ module ContainerRegistry def repository_tag_digest(name, reference) response = faraday.head("/v2/#{name}/manifests/#{reference}") - response.headers['docker-content-digest'] if response.success? + response.headers["docker-content-digest"] if response.success? end def delete_repository_tag(name, reference) @@ -35,8 +35,8 @@ module ContainerRegistry end def blob(name, digest, type = nil) - type ||= 'application/octet-stream' - response_body faraday_blob.get("/v2/#{name}/blobs/#{digest}", nil, 'Accept' => type), allow_redirect: true + type ||= "application/octet-stream" + response_body faraday_blob.get("/v2/#{name}/blobs/#{digest}", nil, "Accept" => type), allow_redirect: true end def delete_blob(name, digest) @@ -60,20 +60,20 @@ module ContainerRegistry end def accept_manifest(conn) - conn.headers['Accept'] = MANIFEST_VERSION + conn.headers["Accept"] = MANIFEST_VERSION - conn.response :json, content_type: 'application/json' - conn.response :json, content_type: 'application/vnd.docker.distribution.manifest.v1+prettyjws' - conn.response :json, content_type: 'application/vnd.docker.distribution.manifest.v1+json' - conn.response :json, content_type: 'application/vnd.docker.distribution.manifest.v2+json' + conn.response :json, content_type: "application/json" + conn.response :json, content_type: "application/vnd.docker.distribution.manifest.v1+prettyjws" + conn.response :json, content_type: "application/vnd.docker.distribution.manifest.v1+json" + conn.response :json, content_type: "application/vnd.docker.distribution.manifest.v2+json" end def response_body(response, allow_redirect: false) if allow_redirect && REDIRECT_CODES.include?(response.status) - response = redirect_response(response.headers['location']) + response = redirect_response(response.headers["location"]) end - response.body if response && response.success? + response.body if response&.success? end def redirect_response(location) @@ -83,24 +83,24 @@ module ContainerRegistry end def faraday - @faraday ||= Faraday.new(@base_uri) do |conn| + @faraday ||= Faraday.new(@base_uri) { |conn| initialize_connection(conn, @options, &method(:accept_manifest)) - end + } end def faraday_blob - @faraday_blob ||= Faraday.new(@base_uri) do |conn| + @faraday_blob ||= Faraday.new(@base_uri) { |conn| initialize_connection(conn, @options) - end + } end # Create a new request to make sure the Authorization header is not inserted # via the Faraday middleware def faraday_redirect - @faraday_redirect ||= Faraday.new(@base_uri) do |conn| + @faraday_redirect ||= Faraday.new(@base_uri) { |conn| conn.request :json conn.adapter :net_http - end + } end end end |