Sha256: dc96268b39f1df9d1122374c8b159ea6065aec9a57b7dff42810f5a681a7526a
Contents?: true
Size: 1.86 KB
Versions: 5
Compression:
Stored size: 1.86 KB
Contents
require 'restpack-core-client' module RestPack module Web class App def initialize(app, options = {}) p "RestPack::Web::App.initialize" @app = app options[:core_domain] ||= ENV['RESTPACK_CORE_SERVICE'] options[:access_key] ||= ENV['RESTPACK_ACCESS_KEY'] raise "missing configuration" unless options[:core_domain] || options[:access_key] @core_cache = RestPack::Core::Client::Cache.create(options[:core_domain], options[:access_key]) end def call(env) env[:restpack] ||= {} begin #TODO: GJ: cache should handle errors gracefully request = Rack::Request.new(env) channel = @core_cache.get_channel(request.host) domain = channel.get_domain_by_host(request.host) env[:restpack][:request] = request env[:restpack][:host] = request.host env[:restpack][:channel] = channel env[:restpack][:application] = domain.application env[:restpack][:domain] = domain env[:restpack][:configurations] = @core_cache.configurations env[:restpack][:services] = @core_cache.get_configuration_value('services', []) add_user env rescue Exception => e p "---" p e.message p "====" p e.backtrace.inspect p "---" end @app.call(env) end private def add_user(env) user_id = env['rack.session'][:user_id] if user_id url = "http://:1234@localhost:1112/api/v1/users/#{user_id}.json" #TODO: GJ: build from config p url json = RestClient.get(url) user = JSON.parse(json)['user'] env[:restpack][:user] = user end env[:restpack][:user_id] = user_id end end end end
Version data entries
5 entries across 5 versions & 1 rubygems