Sha256: d5d231ce7681d6e213b57ffbd43d6ec99336055c5f789d93735d83fa956b44ff

Contents?: true

Size: 1.92 KB

Versions: 10

Compression:

Stored size: 1.92 KB

Contents

# frozen_string_literal: true

module Sidekiq
  class WebAction
    RACK_SESSION = 'rack.session'.freeze

    attr_accessor :env, :block, :type

    def settings
      Web.settings
    end

    def request
      @request ||= ::Rack::Request.new(env)
    end

    def halt(res)
      throw :halt, res
    end

    def redirect(location)
      throw :halt, [302, { "Location" => "#{request.base_url}#{location}" }, []]
    end

    def params
      indifferent_hash = Hash.new {|hash,key| hash[key.to_s] if Symbol === key }

      indifferent_hash.merge! request.params
      route_params.each {|k,v| indifferent_hash[k.to_s] = v }

      indifferent_hash
    end

    def route_params
      env[WebRouter::ROUTE_PARAMS]
    end

    def session
      env[RACK_SESSION]
    end

    def content_type(type)
      @type = type
    end

    def erb(content, options = {})
      if content.kind_of? Symbol
        unless respond_to?(:"_erb_#{content}")
          src = ERB.new(File.read("#{Web.settings.views}/#{content}.erb")).src
          WebAction.class_eval("def _erb_#{content}\n#{src}\n end")
        end
      end

      if @_erb
        _erb(content, options[:locals])
      else
        @_erb = true
        content = _erb(content, options[:locals])

        _render { content }
      end
    end

    def render(engine, content, options = {})
      raise "Only erb templates are supported" if engine != :erb

      erb(content, options)
    end

    def json(payload)
      [200, { "Content-Type" => "application/json", "Cache-Control" => "no-cache" }, [Sidekiq.dump_json(payload)]]
    end

    def initialize(env, block)
      @_erb = false
      @env = env
      @block = block
      @@files ||= {}
    end

    private

    def _erb(file, locals)
      locals.each {|k, v| define_singleton_method(k){ v } } if locals

      if file.kind_of?(String)
        ERB.new(file).result(binding)
      else
        send(:"_erb_#{file}")
      end
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
sidekiq-4.2.10 lib/sidekiq/web/action.rb
sidekiq-5.0.0.beta2 lib/sidekiq/web/action.rb
sidekiq-5.0.0.beta1 lib/sidekiq/web/action.rb
sidekiq-4.2.9 lib/sidekiq/web/action.rb
sidekiq-4.2.8 lib/sidekiq/web/action.rb
sidekiq-4.2.7 lib/sidekiq/web/action.rb
sidekiq-4.2.6 lib/sidekiq/web/action.rb
sidekiq-4.2.5 lib/sidekiq/web/action.rb
sidekiq-4.2.4 lib/sidekiq/web/action.rb
sidekiq-4.2.3 lib/sidekiq/web/action.rb