# Copyright, 2018, by Samuel G. D. Williams. # # Permission is hereby granted, free of charge, to any person obtaining a copy # of this software and associated documentation files (the "Software"), to deal # in the Software without restriction, including without limitation the rights # to use, copy, modify, merge, publish, distribute, sublicense, and/or sell # copies of the Software, and to permit persons to whom the Software is # furnished to do so, subject to the following conditions: # # The above copyright notice and this permission notice shall be included in # all copies or substantial portions of the Software. # # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR # IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, # FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE # AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN # THE SOFTWARE. require 'async/io/endpoint' module Falcon class Host def initialize @app = nil @endpoint = nil @ssl_certificate = nil @ssl_key = nil @ssl_context = nil end attr_accessor :app attr_accessor :endpoint attr_accessor :ssl_certificate attr_accessor :ssl_key attr_accessor :ssl_context def freeze return if frozen? ssl_context super end def ssl_certificate_path= path @ssl_certificate = OpenSSL::X509::Certificate.new(File.read(path)) end def ssl_key_path= path @ssl_key = OpenSSL::PKey::RSA.new(File.read(path)) end def ssl_context @ssl_context ||= OpenSSL::SSL::SSLContext.new.tap do |context| context.cert = @ssl_certificate context.key = @ssl_key context.session_id_context = "falcon" context.set_params context.setup end end def start if app = self.app Async::Container::Forked.new do server = Falcon::Server.new(app, self.server_endpoint) server.run end end end end class Hosts DEFAULT_ALPN_PROTOCOLS = ['h2', 'http/1.1'].freeze def initialize @named = {} @server_context = nil @server_endpoint = nil end def each(&block) @named.each(&block) end def endpoint @server_endpoint ||= Async::HTTP::URLEndpoint.parse( 'https://[::]', ssl_context: self.ssl_context, reuse_address: true ) end def ssl_context @server_context ||= OpenSSL::SSL::SSLContext.new.tap do |context| context.servername_cb = Proc.new do |socket, hostname| self.host_context(socket, hostname) end context.session_id_context = "falcon" context.alpn_protocols = DEFAULT_ALPN_PROTOCOLS context.set_params context.setup end end def host_context(socket, hostname) if host = @named[hostname] socket.hostname = hostname return host.ssl_context end end def add(name, host = Host.new, &block) host = Host.new yield host if block_given? @named[name] = host.freeze end def client_endpoints Hash[ @named.collect{|name, host| [name, host.endpoint]} ] end def proxy Proxy.new(Falcon::BadRequest, self.client_endpoints) end end end