lib/aws-sdk-core/plugins/s3_http_200_errors.rb


module Aws
  module Plugins

    # A handful of Amazon S3 operations will respond with a 200 status
    # code but will send an error in the response body. This plugin
    # injects a handler that will parse 200 response bodies for potential
    # errors, allowing them to be retried.
    # @api private
    class S3Http200Errors < Seahorse::Client::Plugin

      class Handler < Seahorse::Client::Handler

        def call(context)
          @handler.call(context).on(200) do |response|
            if error = check_for_error(context)
              context.http_response.status_code = 500
              response.data = nil
              response.error = error
            end
          end
        end

        def check_for_error(context)
          xml = context.http_response.body_contents
          if xml.match(/<Error>/)
            error_code = xml.match(/<Code>(.+?)<\/Code>/)[1]
            error_message = xml.match(/<Message>(.+?)<\/Message>/)[1]
            S3::Errors.error_class(error_code).new(context, error_message)
          end
        end

      end

      handler(Handler,
        step: :sign,
        operations: [
          :complete_multipart_upload,
          :copy_object,
          :upload_part_copy,
        ]
      )

    end
  end
end