Module: Umbra

Defined in:
lib/umbra.rb,
lib/umbra/config.rb,
lib/umbra/encoder.rb,
lib/umbra/version.rb,
lib/umbra/publisher.rb,
lib/umbra/middleware.rb,
lib/umbra/pb/umbra_pb.rb

Defined Under Namespace

Modules: Pb Classes: Config, Encoder, Middleware, Publisher

Constant Summary collapse

CHANNEL = 
"umbra_channel"
HEADER_KEY = 
"HTTP_X_UMBRA_REQUEST"
HEADER_VALUE = 
"true"
RequestSelector = 
proc { true }
SuppressErrorHandler = 
proc {}
VERSION = 
"0.4.0"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.config ⇒ Object (readonly)

Returns the value of attribute config.



22
23
24
 
# File 'lib/umbra.rb', line 22

def config
  @config
end

Class Method Details

.configure(&block) ⇒ Object 



24
25
26
27
28
 
# File 'lib/umbra.rb', line 24

def configure(&block)
  @config = Config.default(&block)

  test_redis_connection!
end

.encoder ⇒ Object 



47
48
49
 
# File 'lib/umbra.rb', line 47

def encoder
  @config.encoder
end

.logger ⇒ Object 



51
52
53
 
# File 'lib/umbra.rb', line 51

def logger
  @config.logger
end

.publish(env) ⇒ Object 



30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/umbra.rb', line 30

def publish(env)
  return if umbra_request?(env)

  return unless @config
  return unless @config.request_selector.call(env)

  env["umbra.request_body"] = request_body(env)

  @config.publisher.call(env)
rescue => e
  @config.error_handler.call(e, env)
end

.redis ⇒ Object 



43
44
45
 
# File 'lib/umbra.rb', line 43

def redis
  @redis ||= Redis.new(@config.redis_options)
end

.reset! ⇒ Object 



55
56
57
58
 
# File 'lib/umbra.rb', line 55

def reset!
  @config = nil
  @redis = nil
end