Sha256: 554a9dd18332d22492eaa8fee3ee946f99c70357342f6918a9eb05e5893745fa
Contents?: true
Size: 2 KB
Versions: 24
Compression:
Stored size: 2 KB
Contents
# frozen_string_literal: true
module Aws
module S3
module Plugins
class IADRegionalEndpoint < Seahorse::Client::Plugin
option(:s3_us_east_1_regional_endpoint,
default: 'legacy',
doc_type: String,
docstring: <<-DOCS) do |cfg|
Pass in `regional` to enable the `us-east-1` regional endpoint.
Defaults to `legacy` mode which uses the global endpoint.
DOCS
resolve_iad_regional_endpoint(cfg)
end
def add_handlers(handlers, config)
# only modify non-custom endpoints
if config.regional_endpoint && config.region == 'us-east-1'
handlers.add(Handler)
end
end
# @api private
class Handler < Seahorse::Client::Handler
def call(context)
# WriteGetObjectResponse does not have a global endpoint
# ARNs are regionalized, so don't touch those either.
if context.operation.name != 'WriteGetObjectResponse' &&
context.config.s3_us_east_1_regional_endpoint == 'legacy' &&
!context.metadata[:s3_arn]
host = context.http_request.endpoint.host
legacy_host = IADRegionalEndpoint.legacy_host(host)
context.http_request.endpoint.host = legacy_host
end
@handler.call(context)
end
end
def self.legacy_host(host)
host.sub(".us-east-1", '')
end
private
def self.resolve_iad_regional_endpoint(cfg)
mode = ENV['AWS_S3_US_EAST_1_REGIONAL_ENDPOINT'] ||
Aws.shared_config.s3_us_east_1_regional_endpoint(profile: cfg.profile) ||
'legacy'
mode = mode.downcase
unless %w(legacy regional).include?(mode)
raise ArgumentError, "expected :s3_us_east_1_regional_endpoint or"\
" ENV['AWS_S3_US_EAST_1_REGIONAL_ENDPOINT'] to be `legacy` or"\
" `regional`."
end
mode
end
end
end
end
end
Version data entries
24 entries across 24 versions & 1 rubygems