Sha256: ace3334d3c9fc2570858919b4b7dff8dff45c88f7d2f9bc80f128bfdedec479a
Contents?: true
Size: 1.67 KB
Versions: 5
Compression:
Stored size: 1.67 KB
Contents
# frozen_string_literal: true begin require "sidekiq/web" rescue LoadError # rubocop:disable Lint/HandleExceptions # client-only usage end require_relative "web/helpers" module SidekiqUniqueJobs # Utility module to help manage unique keys in redis. # Useful for deleting keys that for whatever reason wasn't deleted # # @author Mikael Henriksson <mikael@zoolutions.se> module Web def self.registered(app) # rubocop:disable Metrics/MethodLength app.helpers do include Web::Helpers end app.get "/unique_digests" do @filter = params[:filter] || "*" @filter = "*" if @filter == "" @count = (params[:count] || 100).to_i @current_cursor = params[:cursor] @prev_cursor = params[:prev_cursor] @total_size, @next_cursor, @unique_digests = Digests.page(pattern: @filter, cursor: @current_cursor, page_size: @count) erb(unique_template(:unique_digests)) end app.get "/unique_digests/delete_all" do Digests.del(pattern: "*", count: Digests.count) redirect_to :unique_digests end app.get "/unique_digests/:digest" do @digest = params[:digest] @unique_keys = Util.keys("#{@digest}*", 1000) erb(unique_template(:unique_digest)) end app.get "/unique_digests/:digest/delete" do Digests.del(digest: params[:digest]) redirect_to :unique_digests end end end end if defined?(Sidekiq::Web) Sidekiq::Web.register SidekiqUniqueJobs::Web Sidekiq::Web.tabs["Unique Digests"] = "unique_digests" # Sidekiq::Web.settings.locales << File.join(File.dirname(__FILE__), 'locales') end
Version data entries
5 entries across 5 versions & 1 rubygems