Class: Falcon::Hosts

Inherits:
Object
  • Object
show all
Defined in:
lib/falcon/hosts.rb

Constant Summary collapse

DEFAULT_ALPN_PROTOCOLS = 
['h2', 'http/1.1'].freeze

Instance Method Summary collapse

Constructor Details

#initialize(configuration) ⇒ Hosts

Returns a new instance of Hosts.



99
100
101
102
103
104
105
106
107
 
# File 'lib/falcon/hosts.rb', line 99

def initialize(configuration)
	@named = {}
	@server_context = nil
	@server_endpoint = nil
	
	configuration.each do |environment|
		add(Host.new(environment))
	end
end

Instance Method Details

#add(host) ⇒ Object 



149
150
151
 
# File 'lib/falcon/hosts.rb', line 149

def add(host)
	@named[host.authority] = host
end

#each(&block) ⇒ Object 



109
110
111
 
# File 'lib/falcon/hosts.rb', line 109

def each(&block)
	@named.each(&block)
end

#endpoint ⇒ Object 



113
114
115
116
117
118
119
 
# File 'lib/falcon/hosts.rb', line 113

def endpoint
	@server_endpoint ||= Async::HTTP::URLEndpoint.parse(
		'https://[::]',
		ssl_context: self.ssl_context,
		reuse_address: true
	)
end

#host_context(socket, hostname) ⇒ Object 



135
136
137
138
139
140
141
142
143
144
145
146
147
 
# File 'lib/falcon/hosts.rb', line 135

def host_context(socket, hostname)
	if host = @named[hostname]
		Async.logger.debug(self) {"Resolving #{hostname} -> #{host}"}
		
		socket.hostname = hostname
		
		return host.ssl_context
	else
		Async.logger.warn(self) {"Unable to resolve #{hostname}!"}
		
		return nil
	end
end

#proxy ⇒ Object 



153
154
155
 
# File 'lib/falcon/hosts.rb', line 153

def proxy
	Proxy.new(Falcon::BadRequest, @named)
end

#redirection(secure_endpoint) ⇒ Object 



157
158
159
 
# File 'lib/falcon/hosts.rb', line 157

def redirection(secure_endpoint)
	Redirection.new(Falcon::BadRequest, @named, secure_endpoint)
end

#run(container = Async::Container::Forked.new, **options) ⇒ Object 



161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
 
# File 'lib/falcon/hosts.rb', line 161

def run(container = Async::Container::Forked.new, **options)
	@named.each do |name, host|
		host.run(container)
	end
	
	secure_endpoint = Async::HTTP::URLEndpoint.parse(options[:bind_secure], ssl_context: self.ssl_context)
	insecure_endpoint = Async::HTTP::URLEndpoint.parse(options[:bind_insecure])
	
	container.run(count: 1, name: "Falcon Proxy") do |task, instance|
		proxy = self.proxy
		
		proxy_server = Falcon::Server.new(proxy, secure_endpoint)
		
		proxy_server.run
	end
	
	container.run(count: 1, name: "Falcon Redirector") do |task, instance|
		redirection = self.redirection(secure_endpoint)
		
		redirection_server = Falcon::Server.new(redirection, insecure_endpoint)
		
		redirection_server.run
	end
	
	return container
end

#ssl_context ⇒ Object 



121
122
123
124
125
126
127
128
129
130
131
132
133
 
# File 'lib/falcon/hosts.rb', line 121

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