Decaf endpoints

README.md

@@ -26,4 +26,11 @@ bundle exec smithy-ruby smith client --gem-name weather --gem-version 1.0.0 --de
 IRB on weather gem
 ```
 irb -I build/smithy/weather/smithy-ruby/lib -I gems/smithy-client/lib -r weather
-```
+```
+
+Build a fixture
+```
+export SMITHY_PLUGIN_DIR=build/smithy/source/smithy-ruby
+bundle exec smithy-ruby smith client --gem-name fixture --gem-version 1.0.0 <<< $(cat gems/smithy/spec/fixtures/endpoints/default-values/model.json)
+
+```

Rakefile

@@ -5,13 +5,42 @@ require 'rspec/core/rake_task'
 
 RuboCop::RakeTask.new
 
+# rubocop:disable Metrics/BlockLength
 namespace :smithy do
-  RSpec::Core::RakeTask.new do |t|
+  RSpec::Core::RakeTask.new('spec:unit') do |t|
     t.pattern = 'gems/smithy/spec/**/*_spec.rb'
     t.ruby_opts = '-I gems/smithy/spec'
     t.rspec_opts = '--format documentation'
   end
+
+  task 'spec:endpoints' do
+    require_relative 'gems/smithy/spec/spec_helper'
+
+    spec_paths = []
+    include_paths = []
+    tmp_dirs = []
+    Dir.glob('gems/smithy/spec/fixtures/endpoints/*/model.json') do |model_path|
+      test_name = model_path.split('/')[-2]
+      test_module = test_name.gsub('-', '').camelize
+      puts "Building SDK for #{test_name} at: #{model_path}"
+      tmpdir = SpecHelper.generate([test_module], :client, { fixture: "endpoints/#{test_name}" })
+      tmp_dirs << [test_module.to_sym, tmpdir]
+      spec_paths << "#{tmpdir}/spec"
+      include_paths << "#{tmpdir}/lib"
+      include_paths << "#{tmpdir}/spec"
+    end
+    specs = spec_paths.join(' ')
+    includes = include_paths.map { |p| "-I #{p}" }.join(' ')
+    sh("bundle exec rspec #{specs} #{includes}")
+  ensure
+    tmp_dirs.each do |name, tmpdir|
+      SpecHelper.cleanup([name], tmpdir)
+    end
+  end
+
+  task 'spec' => %w[spec:unit spec:endpoints]
 end
+# rubocop:enable Metrics/BlockLength
 
 namespace 'smithy-client' do
   RSpec::Core::RakeTask.new do |t|

gems/smithy-client/lib/smithy-client.rb

@@ -1,18 +1,20 @@
 # frozen_string_literal: true
 
+require 'jmespath'
+
 # client
 
 require_relative 'smithy-client/block_io'
 require_relative 'smithy-client/configuration'
 require_relative 'smithy-client/handler'
 require_relative 'smithy-client/handler_builder'
+require_relative 'smithy-client/handler_context'
 require_relative 'smithy-client/handler_list'
 require_relative 'smithy-client/handler_list_entry'
 require_relative 'smithy-client/managed_file'
 require_relative 'smithy-client/networking_error'
 require_relative 'smithy-client/plugin'
 require_relative 'smithy-client/plugin_list'
-require_relative 'smithy-client/handler_context'
 require_relative 'smithy-client/input'
 require_relative 'smithy-client/output'
 
@@ -27,7 +29,6 @@
 
 # plugins
 
-require_relative 'smithy-client/plugins/endpoint'
 require_relative 'smithy-client/plugins/logging'
 require_relative 'smithy-client/plugins/raise_response_errors'
 require_relative 'smithy-client/plugins/net_http'
@@ -41,6 +42,9 @@
 require_relative 'smithy-client/operation'
 require_relative 'smithy-client/structure'
 
+# endpoints
+require_relative 'smithy-client/endpoint_rules'
+
 module Smithy
   # Base module for a generated Smithy gem.
   module Client

gems/smithy-client/lib/smithy-client/base.rb

@@ -9,7 +9,6 @@ class Base
       # @api private
       @plugins = PluginList.new(
         [
-          Plugins::Endpoint,
           # Plugins::NetHTTP
           Plugins::RaiseResponseErrors
           # Plugins::ResponseTarget,

gems/smithy-client/lib/smithy-client/endpoint_rules.rb

@@ -0,0 +1,186 @@
+# frozen_string_literal: true
+
+require 'cgi'
+require 'ipaddr'
+require 'uri'
+
+module Smithy
+  module Client
+    # Functions in the Smithy rules engine are named routines that
+    # operate on a finite set of specified inputs, returning an output.
+    # The rules engine has a set of included functions that can be
+    # invoked without additional dependencies, called the standard library.
+    module EndpointRules
+      # Regex that extracts anything in square brackets
+      BRACKET_REGEX = /\[(.*?)\]/
+
+      # An Endpoint resolved by an EndpointProvider
+      class Endpoint
+        # @param [String] :uri
+        # @param [Array<AuthScheme>] :auth_schemes ([])
+        # @param [Hash] :headers ({})
+        def initialize(uri:, properties: {}, headers: {})
+          @uri = uri
+          @properties = properties
+          @headers = headers
+        end
+
+        # The URI of the endpoint.
+        # @return [String]
+        attr_accessor :uri
+
+        # The authentication schemes supported by the endpoint.
+        # @return [Hash]
+        attr_accessor :properties
+
+        # The headers to include in requests to the endpoint.
+        # @return [Hash]
+        attr_accessor :headers
+      end
+
+      # Evaluates whether the input string is a compliant RFC 1123 host segment.
+      # When allowSubDomains is true, evaluates whether the input string is
+      # composed of values that are each compliant RFC 1123 host segments
+      # joined by dot (.) characters.
+      # @api private
+      def self.valid_host_label?(value, allow_sub_domains)
+        return false if value.empty?
+
+        if allow_sub_domains
+          labels = value.split('.', -1)
+          return labels.all? { |l| valid_host_label?(l, false) }
+        end
+
+        !!(value =~ /\A(?!-)[a-zA-Z0-9-]{1,63}(?<!-)\z/)
+      end
+
+      # Computes a URL structure given an input string.
+      # @api private
+      def self.parse_url(value)
+        URL.new(value).as_json
+      rescue ArgumentError, URI::InvalidURIError
+        nil
+      end
+
+      # Computes a portion of a given string based on
+      # the provided start and end indices.
+      # @api private
+      def self.substring(input, start, stop, reverse)
+        return nil if start >= stop || input.size < stop
+
+        return nil if input.chars.any? { |c| c.ord > 127 }
+
+        return input[start...stop] unless reverse
+
+        r_start = input.size - stop
+        r_stop = input.size - start
+        input[r_start...r_stop]
+      end
+
+      # Performs RFC 3986#section-2.1 defined percent-encoding on the input value.
+      # @api private
+      def self.uri_encode(value)
+        CGI.escape(value.encode('UTF-8')).gsub('+', '%20').gsub('%7E', '~')
+      end
+
+      # isSet(value: Option<T>) bool
+      # @api private
+      def self.set?(value)
+        !value.nil?
+      end
+
+      # not(value: bool) bool
+      # @api private
+      def self.not(bool)
+        !bool
+      end
+
+      # getAttr(value: Object | Array, path: string) Document
+      # @api private
+      def self.attr(value, path)
+        parts = path.split('.')
+
+        val = attr_brackets(parts, value)
+
+        if parts.size == 1
+          val
+        else
+          attr_reader(val, parts.slice(1..-1).join('.'))
+        end
+      end
+
+      # stringEquals(value1: string, value2: string) bool
+      # @api private
+      def self.string_equals?(value1, value2)
+        value1 == value2
+      end
+
+      # booleanEquals(value1: bool, value2: bool) bool
+      # @api private
+      def self.boolean_equals?(value1, value2)
+        value1 == value2
+      end
+
+      # @api private
+      class URL
+        def initialize(url)
+          uri = URI(url)
+          @scheme = uri.scheme
+          # only support http and https schemes
+          raise ArgumentError unless %w[https http].include?(@scheme)
+
+          # do not support query
+          raise ArgumentError if uri.query
+
+          @authority = extract_authority(url, uri)
+          @path = uri.path
+          @normalized_path = uri.path + (uri.path[-1] == '/' ? '' : '/')
+          @is_ip = ip?(uri.host)
+        end
+
+        attr_reader :scheme, :authority, :path, :normalized_path, :is_ip
+
+        def as_json(*)
+          {
+            'scheme' => scheme,
+            'authority' => authority,
+            'path' => path,
+            'normalizedPath' => normalized_path,
+            'isIp' => is_ip
+          }
+        end
+
+        private
+
+        def extract_authority(url, uri)
+          # don't include port if it's default and not parsed originally
+          if uri.default_port == uri.port && !url.include?(":#{uri.port}")
+            uri.host
+          else
+            "#{uri.host}:#{uri.port}"
+          end
+        end
+
+        def ip?(authority)
+          IPAddr.new(authority)
+          true
+        rescue IPAddr::InvalidAddressError
+          false
+        end
+      end
+
+      def self.attr_brackets(parts, value)
+        if (index = parts.first[BRACKET_REGEX, 1])
+          # remove brackets and index from part before indexing
+          if (base = parts.first.gsub(BRACKET_REGEX, '')) && !base.empty?
+            value[base][index.to_i]
+          else
+            value[index.to_i]
+          end
+        else
+          value[parts.first]
+        end
+      end
+    end
+  end
+end

gems/smithy-client/smithy-client.gemspec

@@ -10,5 +10,7 @@ Gem::Specification.new do |spec|
   spec.license      = 'Apache-2.0'
   spec.files        = Dir['CHANGELOG.md', 'VERSION', 'lib/**/*']
 
+  spec.add_dependency('jmespath', '~> 1', '>= 1.6.1') # necessary for secure jmespath JSON parsing
+
   spec.required_ruby_version = '>= 3.0'
 end