Use Sidekiq::Component for Enqueuer (#18)

* Use Sidekiq::Component for Enqueuer

Fixes #17

* Initialize earlier

lib/sidekiq/staged_push.rb

@@ -12,8 +12,9 @@ def self.enable!
       Sidekiq.default_job_options["client_class"] = Sidekiq::StagedPush::Client
       Sidekiq::JobUtil::TRANSIENT_ATTRIBUTES << "client_class"
 
-      enqueuer = Enqueuer.new
       Sidekiq.configure_server do |config|
+        enqueuer = Enqueuer.new(config)
+
         config.on(:startup) do
           enqueuer.start
         end

lib/sidekiq/staged_push/enqueuer.rb

@@ -1,12 +1,16 @@
 # frozen_string_literal: true
 
+require "sidekiq/component"
 require "sidekiq/staged_push/enqueuer/process_batch"
 
 module Sidekiq
   module StagedPush
     class Enqueuer
-      def initialize
+      include Sidekiq::Component
+
+      def initialize(config)
         @done = false
+        @config = config
       end
 
       def start
@@ -33,7 +37,7 @@ def process
       def primary_process?
         return true unless defined?(Sidekiq::Enterprise)
 
-        Sidekiq::Senate.leader?
+        leader?
       end
     end
   end

spec/sidekiq/staged_push/enqueuer_spec.rb

@@ -4,7 +4,7 @@
   it "can be started and stopped" do
     allow(Sidekiq::Client).to receive_message_chain(:new, :push)
 
-    enqueuer = described_class.new
+    enqueuer = described_class.new("config")
     enqueuer.start
 
     job = Sidekiq::StagedPush::StagedJob.create!(payload: { args: [1] })