Fix rubocop violations.

.rubocop.yml

@@ -1,8 +1,18 @@
 inherit_gem:
   gc_ruboconfig: rubocop.yml
 
+require:
+  - rubocop-performance
+  - rubocop-rake
+  - rubocop-rspec
+  - rubocop-sequel
+
 AllCops:
-  Exclude: [legacy_spec/**/*]
+  Exclude:
+    - "vendor/**/*"
+    - "legacy_spec/**/*"
+    - "lib/generators/que/templates/*.rb"
+  NewCops: enable
 
 Metrics/MethodLength:
   Max: 20
@@ -24,3 +34,6 @@ RSpec/DescribeClass:
 
 Metrics/CyclomaticComplexity:
   Max: 10
+
+RSpec/IndexedLet:
+  Enabled: false

Gemfile

@@ -12,6 +12,10 @@ group :development, :test do
   gem 'pg_jruby', require: nil, platform: :jruby
   gem 'pond', require: nil
   gem 'rubocop'
+  gem 'rubocop-performance'
+  gem 'rubocop-rake'
+  gem 'rubocop-rspec'
+  gem 'rubocop-sequel'
   gem 'sequel', require: nil
 end
 

Rakefile

@@ -2,4 +2,4 @@
 
 require "bundler/gem_tasks"
 
-Dir["./tasks/*.rb"].sort.each { |f| require f }
+Dir["./tasks/*.rb"].each { |f| require f }

benchmark/seed-jobs

@@ -19,7 +19,7 @@ unless ARGV.count == 3
 end
 
 def parse_range(token)
-  [*Range.new(*token.split("..").map(&:to_i))]
+  Array(Range.new(*token.split("..").map(&:to_i)))
 rescue StandardError
   [token.to_i]
 end

benchmark/setup.rb

@@ -9,7 +9,7 @@
 Que.connection = ActiveRecord
 Que.migrate!
 
-Que.logger = Logger.new(STDOUT)
+Que.logger = Logger.new($stdout)
 Que.logger.formatter = proc do |severity, datetime, _progname, payload|
   { ts: datetime, tid: Thread.current.object_id, level: severity }.
     merge(payload).to_json + "\n"

bin/que

@@ -13,7 +13,7 @@ $stdout.sync = true
 
 options = OpenStruct.new
 
-# rubocop:disable Metrics/LineLength
+# rubocop:disable Layout/LineLength
 OptionParser.new do |opts|
   opts.banner = "usage: que [options] file/to/require ..."
 
@@ -59,7 +59,7 @@ OptionParser.new do |opts|
 
   opts.on("-v", "--version", "Show Que version") do
     require "que"
-    $stdout.puts "Que version #{Que::Version}"
+    $stdout.puts "Que version #{Que::VERSION}"
     exit 0
   end
 
@@ -68,9 +68,9 @@ OptionParser.new do |opts|
     exit 0
   end
 end.parse!(ARGV)
-# rubocop:enable Metrics/LineLength
+# rubocop:enable Layout/LineLength
 
-if ARGV.length.zero?
+if ARGV.empty?
   $stdout.puts <<~OUTPUT
     You didn't include any Ruby files to require!
     Que needs to be able to load your application before it can process jobs.
@@ -92,9 +92,9 @@ wake_interval    = options.wake_interval || ENV["QUE_WAKE_INTERVAL"]&.to_f || Qu
 cursor_expiry    = options.cursor_expiry || wake_interval
 worker_count     = options.worker_count  || 1
 timeout          = options.timeout
-secondary_queues = options.secondary_queues  || []
+secondary_queues = options.secondary_queues || []
 
-Que.logger ||= Logger.new(STDOUT)
+Que.logger ||= Logger.new($stdout)
 
 begin
   Que.logger.level = Logger.const_get(log_level.upcase) if log_level

lib/que.rb

@@ -42,7 +42,7 @@ module Que
   SYMBOLIZER = proc do |object|
     case object
     when Hash
-      object.keys.each do |key|
+      object.each_key do |key|
         object[key.to_sym] = SYMBOLIZER.call(object.delete(key))
       end
       object
@@ -145,11 +145,11 @@ def transaction
           begin
             execute "BEGIN"
             yield
-          rescue StandardError => error
+          rescue StandardError => e
             raise
           ensure
             # Handle a raised error or a killed thread.
-            if error || Thread.current.status == "aborting"
+            if e || Thread.current.status == "aborting"
               execute "ROLLBACK"
             else
               execute "COMMIT"

lib/que/adapters/base.rb

@@ -82,7 +82,7 @@ def execute_prepared(name, params)
             end
 
             conn.exec_prepared("que_#{name}", params)
-          rescue ::PG::InvalidSqlStatementName => error
+          rescue ::PG::InvalidSqlStatementName => e
             # Reconnections on ActiveRecord can cause the same connection
             # objects to refer to new backends, so recover as well as we can.
 
@@ -92,7 +92,7 @@ def execute_prepared(name, params)
               retry
             end
 
-            raise error
+            raise e
           end
         end
       end
@@ -102,7 +102,7 @@ def execute_prepared(name, params)
         16 => ->(value) {
           case value
           when String then value == "t"
-          else !!value
+          else !value.nil?
           end
         },
         # bigint

lib/que/job.rb

@@ -84,15 +84,17 @@ def self.custom_log_context(custom_proc)
       if custom_proc.is_a?(Proc)
         self.log_context_proc = custom_proc
       else
-        raise ArgumentError.new "Custom log context must be a Proc " \
-                                "which receives the job as an argument and " \
-                                "returns a hash"
+        raise ArgumentError, "Custom log context must be a Proc " \
+                             "which receives the job as an argument and " \
+                             "returns a hash"
       end
     end
 
+    # rubocop:disable Naming/AccessorMethodName
     def get_custom_log_context
       self.class.log_context_proc&.call(@attrs) || {}
     end
+    # rubocop:enable Naming/AccessorMethodName
 
     # This is accepting JOB_OPTIONS and args as keyword parameters. In future we want to
     # set instance variables instead of using a grab bag of parameters, which would allow

lib/que/leaky_bucket.rb

@@ -56,11 +56,11 @@ def refill
 
     private
 
-    def catch_error(&block)
-      result = block.call
+    def catch_error
+      result = yield
       [result, nil]
-    rescue StandardError => err
-      [result, err]
+    rescue StandardError => e
+      [result, e]
     end
   end
 end

lib/que/middleware/queue_collector.rb

@@ -41,7 +41,6 @@ def initialize(app, options = {})
         end
       end
 
-      # rubocop:disable Metrics/AbcSize
       def call(env)
         # Reset all the previously observed values back to zero, ensuring we only ever
         # report metric values that are current in every scrape.
@@ -72,7 +71,6 @@ def call(env)
 
         @app.call(env)
       end
-      # rubocop:enable Metrics/AbcSize
 
       def refresh_materialized_view
         # Ensure generating metrics never take more than 5000ms to execute. If we can't

lib/que/middleware/worker_collector.rb

@@ -28,8 +28,7 @@ def call(env)
 
       private
 
-      # rubocop:disable Lint/HandleExceptions
-      # rubocop:disable Style/RedundantBegin
+      # rubocop:disable Style/RedundantBegin, Lint/SuppressedException
       def register(*metrics)
         begin
           metrics.each do |metric|
@@ -38,8 +37,7 @@ def register(*metrics)
         rescue Prometheus::Client::Registry::AlreadyRegisteredError
         end
       end
-      # rubocop:enable Style/RedundantBegin
-      # rubocop:enable Lint/HandleExceptions
+      # rubocop:enable Style/RedundantBegin, Lint/SuppressedException
     end
   end
 end

lib/que/migrations.rb

@@ -8,7 +8,6 @@ module Migrations
     CURRENT_VERSION = 6
 
     class << self
-      # rubocop:disable Metrics/AbcSize
       def migrate!(options = { version: CURRENT_VERSION })
         Que.transaction do
           version = options[:version]
@@ -32,7 +31,6 @@ def migrate!(options = { version: CURRENT_VERSION })
           self.db_version = version
         end
       end
-      # rubocop:enable Metrics/AbcSize
 
       def db_version
         result = Que.execute <<-SQL

lib/que/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Que
-  Version = "1.0.0"
+  VERSION = "1.0.0"
 end

lib/que/worker.rb

@@ -145,7 +145,7 @@ def work_loop
 
       @tracer.trace(RunningSecondsTotal, queue: @queue, primary_queue: @queue) do
         loop do
-          case event = work
+          case work
           when :postgres_error
             Que.logger&.info(event: "que.postgres_error", wake_interval: @wake_interval)
             @tracer.trace(SleepingSecondsTotal, queue: @queue, primary_queue: @queue) do
@@ -252,7 +252,7 @@ def work
 
             # For compatibility with que-failure, we need to allow failure handlers to be
             # defined on the job class.
-            if klass&.respond_to?(:handle_job_failure)
+            if klass.respond_to?(:handle_job_failure)
               klass.handle_job_failure(e, job)
             else
               handle_job_failure(e, job)
@@ -302,7 +302,7 @@ def class_for(string)
     end
 
     def actual_job_class_name(class_name, args)
-      return args.first["job_class"] if /ActiveJob::QueueAdapters/.match?(class_name)
+      return args.first["job_class"] if class_name.include?("ActiveJob::QueueAdapters")
 
       class_name
     end

que.gemspec

@@ -6,7 +6,7 @@ require "que/version"
 
 Gem::Specification.new do |spec|
   spec.name          = "que"
-  spec.version       = Que::Version
+  spec.version       = Que::VERSION
   spec.authors       = ["Chris Hanks"]
   spec.email         = ["[email protected]"]
   spec.description   =
@@ -15,9 +15,9 @@ Gem::Specification.new do |spec|
   spec.homepage      = "https://github.com/chanks/que"
   spec.license       = "MIT"
 
+  spec.required_ruby_version = ">= 3.0"
   spec.files         = `git ls-files`.split($INPUT_RECORD_SEPARATOR)
   spec.executables   = ["que"]
-  spec.test_files    = spec.files.grep(%r{^(test|spec|features)/})
   spec.require_paths = ["lib"]
 
   # We're pointing to our own branch of the Prometheus Client.
@@ -31,4 +31,5 @@ Gem::Specification.new do |spec|
   spec.add_dependency "webrick", "~> 1.7"
 
   spec.add_runtime_dependency "activesupport"
+  spec.metadata["rubygems_mfa_required"] = "true"
 end

spec/lib/que/job_spec.rb

@@ -56,7 +56,7 @@
           custom_log_2: "test-log",
         }
       }
-      job_class.enqueue(500, :gbp, :testing,  run_at: run_at)
+      job_class.enqueue(500, :gbp, :testing, run_at: run_at)
     end
 
     context "with a custom adapter specified" do
@@ -97,10 +97,11 @@
     (1..fake_args.keys.count).
       flat_map { |n| fake_args.keys.combination(n).to_a }.each do |arg_keys|
       context "with #{arg_keys.inspect}" do
-        let(:args) { Hash[arg_keys.zip(fake_args.values_at(*arg_keys))] }
+        let(:job_args) { { a_real_arg: true } }
+        let(:args) { arg_keys.zip(fake_args.values_at(*arg_keys)).to_h }
 
         it "handles them properly" do
-          described_class.enqueue(1, true, "foo", **{ a_real_arg: true }.merge(args))
+          described_class.enqueue(1, true, "foo", **job_args.merge(args))
           job = QueJob.last
 
           arg_keys.each do |key|
@@ -131,7 +132,7 @@
 
   describe ".adapter" do
     context "with an adapter specified" do
-      let(:custom_adapter) { double(Que::Adapters::Base) }
+      let(:custom_adapter) { instance_double(Que::Adapters::Base) }
       let(:job_with_adapter) { Class.new(described_class) }
 
       it "uses the correct adapter" do
@@ -211,7 +212,7 @@
     end
 
     it "returns a hash of keys constructed from the job attrs" do
-      job_class.custom_log_context -> (attrs) {
+      job_class.custom_log_context ->(attrs) {
         {
           first_argument: attrs[:args][0],
           second_argument: attrs[:args][1],

spec/lib/que/leaky_bucket_spec.rb

@@ -7,23 +7,25 @@
 
   let(:window) { 5.0 }
   let(:budget) { 1.0 }
-  let(:clock)  { FakeClock.new }
+  let(:clock)  { fake_clock.new }
 
   # Provide a test clock interface, allowing the observations and sleeps made by the
   # bucket to advance test time.
-  FakeClock = Class.new do
-    def initialize
-      @now = 0.0
-    end
+  let(:fake_clock) do
+    Class.new do
+      def initialize
+        @now = 0.0
+      end
 
-    attr_reader :now
+      attr_reader :now
 
-    def sleep(duration)
-      @now += duration
-    end
+      def sleep(duration)
+        @now += duration
+      end
 
-    def advance(duration)
-      @now += duration
+      def advance(duration)
+        @now += duration
+      end
     end
   end
 
@@ -38,8 +40,8 @@ def measure_total_work(clock, bucket, runtime:, work_duration: 0.05, error: fals
           total_work += duration
           raise StandardError, "throwing" if error
         end
-      rescue StandardError => err
-        fail(err) unless error
+      rescue StandardError => e
+        raise(e) unless error
       end
     end