Class: Sidekiq::WebApplication

Inherits:
Object
  • Object
show all
Extended by:
WebRouter
Defined in:
lib/sidekiq/web/application.rb

Constant Summary collapse

CONTENT_LENGTH = 
"Content-Length".freeze
CONTENT_TYPE = 
"Content-Type".freeze
REDIS_KEYS = 
%w(redis_version uptime_in_days connected_clients used_memory_human used_memory_peak_human)
NOT_FOUND = 
[404, {"Content-Type" => "text/plain", "X-Cascade" => "pass" }, ["Not Found"]]

Constants included from WebRouter

Sidekiq::WebRouter::DELETE, Sidekiq::WebRouter::GET, Sidekiq::WebRouter::HEAD, Sidekiq::WebRouter::PATCH, Sidekiq::WebRouter::PATH_INFO, Sidekiq::WebRouter::POST, Sidekiq::WebRouter::PUT, Sidekiq::WebRouter::REQUEST_METHOD, Sidekiq::WebRouter::ROUTE_PARAMS

Class Method Summary collapse

Instance Method Summary collapse

Methods included from WebRouter

delete, get, match, patch, post, put, route

Constructor Details

#initialize(klass) ⇒ WebApplication

Returns a new instance of WebApplication.



12
13
14
 
# File 'lib/sidekiq/web/application.rb', line 12

def initialize(klass)
  @klass = klass
end

Class Method Details

.after(path = nil, &block) ⇒ Object 



310
311
312
 
# File 'lib/sidekiq/web/application.rb', line 310

def self.after(path=nil, &block)
  afters << [path && Regexp.new("\\A#{path.gsub("*", ".*")}\\z"), block]
end

.afters ⇒ Object 



331
332
333
 
# File 'lib/sidekiq/web/application.rb', line 331

def self.afters
  @afters ||= []
end

.before(path = nil, &block) ⇒ Object 



306
307
308
 
# File 'lib/sidekiq/web/application.rb', line 306

def self.before(path=nil, &block)
  befores << [path && Regexp.new("\\A#{path.gsub("*", ".*")}\\z"), block]
end

.befores ⇒ Object 



327
328
329
 
# File 'lib/sidekiq/web/application.rb', line 327

def self.befores
  @befores ||= []
end

.helpers(mod = nil, &block) ⇒ Object 



298
299
300
301
302
303
304
 
# File 'lib/sidekiq/web/application.rb', line 298

def self.helpers(mod=nil, &block)
  if block_given?
    WebAction.class_eval(&block)
  else
    WebAction.send(:include, mod)
  end
end

.run_afters(app, action) ⇒ Object 



318
319
320
 
# File 'lib/sidekiq/web/application.rb', line 318

def self.run_afters(app, action)
  run_hooks(afters, app, action)
end

.run_befores(app, action) ⇒ Object 



314
315
316
 
# File 'lib/sidekiq/web/application.rb', line 314

def self.run_befores(app, action)
  run_hooks(befores, app, action)
end

.run_hooks(hooks, app, action) ⇒ Object 



322
323
324
325
 
# File 'lib/sidekiq/web/application.rb', line 322

def self.run_hooks(hooks, app, action)
  hooks.select { |p,_| !p || p =~ action.env[WebRouter::PATH_INFO] }.
        each {|_,b| action.instance_exec(action.env, app, &b) }
end

.set(key, val) ⇒ Object 



28
29
30
 
# File 'lib/sidekiq/web/application.rb', line 28

def self.set(key, val)
  # nothing, backwards compatibility
end

.settings ⇒ Object 



20
21
22
 
# File 'lib/sidekiq/web/application.rb', line 20

def self.settings
  Sidekiq::Web.settings
end

.tabs ⇒ Object 



24
25
26
 
# File 'lib/sidekiq/web/application.rb', line 24

def self.tabs
  Sidekiq::Web.tabs
end

Instance Method Details

#call(env) ⇒ Object 



259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
 
# File 'lib/sidekiq/web/application.rb', line 259

def call(env)
  action = self.class.match(env)
  return NOT_FOUND unless action

  resp = catch(:halt) do
    app = @klass
    self.class.run_befores(app, action)
    begin
      resp = action.instance_exec env, &action.block
    ensure
      self.class.run_afters(app, action)
    end

    resp
  end

  resp = case resp
  when Array
    resp
  when Fixnum
    [resp, {}, []]
  else
    type_header = case action.type
    when :json
      WebAction::APPLICATION_JSON
    when String
      { WebAction::CONTENT_TYPE => action.type, "Cache-Control" => "no-cache" }
    else
      WebAction::TEXT_HTML
    end

    [200, type_header, [resp]]
  end

  resp[1][CONTENT_LENGTH] = resp[2].inject(0) { |l, p| l + p.bytesize }.to_s

  resp
end

#settings ⇒ Object 



16
17
18
 
# File 'lib/sidekiq/web/application.rb', line 16

def settings
  @klass.settings
end