Contents

require 'sidekiq/web'

module Sidetiq
  module Web
    VIEWS = File.expand_path('views', File.dirname(__FILE__))

    def self.registered(app)
      app.helpers do
        def sidetiq_clock
          Sidetiq::Clock.instance
        end

        def sidetiq_schedules
          sidetiq_clock.schedules
        end
      end

      app.get "/sidetiq" do
        @schedules = sidetiq_schedules
        @time = sidetiq_clock.gettime
        slim File.read(File.join(VIEWS, 'sidetiq.slim'))
      end

      app.get "/sidetiq/:name" do
        halt 404 unless (name = params[:name])

        @time = sidetiq_clock.gettime

        @worker, @schedule = sidetiq_schedules.select do |worker, schedule|
          worker.name == name
        end.flatten

        slim File.read(File.join(VIEWS, 'sidetiq_details.slim'))
      end

      app.post "/sidetiq/:name/trigger" do
        halt 404 unless (name = params[:name])

        worker, _ = sidetiq_schedules.select do |worker, schedule|
          worker.name == name
        end.flatten

        worker.perform_async

        redirect "#{root_path}sidetiq"
      end
    end
  end
end

Sidekiq::Web.register(Sidetiq::Web)

if Sidekiq::Web.tabs.is_a?(Array)
  Sidekiq::Web.tabs << "sidetiq"
else
  Sidekiq::Web.tabs["Sidetiq"] = "sidetiq"
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
sidetiq-0.3.6	lib/sidetiq/web.rb
sidetiq-0.3.5	lib/sidetiq/web.rb
sidetiq-0.3.4	lib/sidetiq/web.rb
sidetiq-0.3.3	lib/sidetiq/web.rb
sidetiq-0.3.2	lib/sidetiq/web.rb
sidetiq-0.3.1	lib/sidetiq/web.rb
sidetiq-0.3.0	lib/sidetiq/web.rb
sidetiq-0.2.0	lib/sidetiq/web.rb
sidetiq-0.1.5	lib/sidetiq/web.rb