close #2187 separate UniqueJob and ApplicationJob

app/jobs/application_unique_job.rb

@@ -0,0 +1,3 @@
+# Add any logics inside app/jobs/spree_cm_commissioner/application_job.rb instead.
+# Let application override this.
+class ApplicationUniqueJob < ActiveJob::Base; end # rubocop:disable Rails/ApplicationJob

app/jobs/spree_cm_commissioner/application_unique_job.rb

@@ -0,0 +1,6 @@
+# override this on your server.
+module SpreeCmCommissioner
+  class ApplicationUniqueJob < ::ApplicationUniqueJob
+    queue_as :default
+  end
+end

app/jobs/spree_cm_commissioner/chatrace_order_creator_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class ChatraceOrderCreatorJob < ApplicationJob
+  class ChatraceOrderCreatorJob < ApplicationUniqueJob
     # :chatrace_user_id, :chatrace_return_flow_id, :chatrace_api_host, :chatrace_access_token
     # :guest_token, :order_params
     def perform(options)

app/jobs/spree_cm_commissioner/conversion_pre_calculator_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class ConversionPreCalculatorJob < ApplicationJob
+  class ConversionPreCalculatorJob < ApplicationUniqueJob
     queue_as :default
 
     def perform(product_id)

app/jobs/spree_cm_commissioner/customer_content_notification_creator_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class CustomerContentNotificationCreatorJob < ApplicationJob
+  class CustomerContentNotificationCreatorJob < ApplicationUniqueJob
     def perform(options)
       SpreeCmCommissioner::CustomerContentNotificationCreator.new(options).call
     end

app/jobs/spree_cm_commissioner/customer_notification_sender_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class CustomerNotificationSenderJob < ApplicationJob
+  class CustomerNotificationSenderJob < ApplicationUniqueJob
     def perform(customer_notification_id, user_ids = nil)
       customer_notification = SpreeCmCommissioner::CustomerNotification.find(customer_notification_id)
       SpreeCmCommissioner::CustomerNotificationSender.call(customer_notification: customer_notification, user_ids: user_ids)

app/jobs/spree_cm_commissioner/enqueue_cart/add_item_job.rb

@@ -1,6 +1,6 @@
 module SpreeCmCommissioner
   module EnqueueCart
-    class AddItemJob < ApplicationJob
+    class AddItemJob < ApplicationUniqueJob
       def perform(order_id, variant_id, quantity, public_metadata, private_metadata, options) # rubocop:disable Metrics/ParameterLists
         SpreeCmCommissioner::EnqueueCart::AddItem.call(
           order_id: order_id,

app/jobs/spree_cm_commissioner/export_csv_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class ExportCsvJob < ApplicationJob
+  class ExportCsvJob < ApplicationUniqueJob
     def perform(id)
       Exports::ExportGuestCsvService.new(id).call
     end

app/jobs/spree_cm_commissioner/import_order_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class ImportOrderJob < ApplicationJob
+  class ImportOrderJob < ApplicationUniqueJob
     def perform(import_order_id, import_by_user_id, import_type)
       if import_type == 'new_order'
         SpreeCmCommissioner::Imports::CreateOrderService.new(

app/jobs/spree_cm_commissioner/invalidate_cache_request_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class InvalidateCacheRequestJob < ApplicationJob
+  class InvalidateCacheRequestJob < ApplicationUniqueJob
     def perform(pattern)
       SpreeCmCommissioner::InvalidateCacheRequest.call(pattern: pattern)
     end

app/jobs/spree_cm_commissioner/option_type_variants_public_metadata_updater_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class OptionTypeVariantsPublicMetadataUpdaterJob < ApplicationJob
+  class OptionTypeVariantsPublicMetadataUpdaterJob < ApplicationUniqueJob
     def perform(option_type_id)
       optino_type = ::Spree::OptionType.find(option_type_id)
       optino_type.variants.find_each(&:set_options_to_public_metadata!)

app/jobs/spree_cm_commissioner/option_value_variants_public_metadata_updater_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class OptionValueVariantsPublicMetadataUpdaterJob < ApplicationJob
+  class OptionValueVariantsPublicMetadataUpdaterJob < ApplicationUniqueJob
     def perform(option_value_id)
       option_value = ::Spree::OptionValue.find(option_value_id)
       option_value.variants.find_each(&:set_options_to_public_metadata!)

app/jobs/spree_cm_commissioner/order_complete_telegram_sender_job.rb

@@ -1,7 +1,7 @@
 # queue_webhooks_requests! already contains queue job, but before it prepare to call queue_webhooks_requests!,
 # it could raise serializer error which needed to be recorded in queue dashboard.
 module SpreeCmCommissioner
-  class OrderCompleteTelegramSenderJob < ApplicationJob
+  class OrderCompleteTelegramSenderJob < ApplicationUniqueJob
     queue_as :telegram_bot
 
     def perform(order_id)

app/jobs/spree_cm_commissioner/queue_order_webhooks_requests_job.rb

@@ -1,7 +1,7 @@
 # queue_webhooks_requests! already contains queue job, but before it prepare to call queue_webhooks_requests!,
 # it could raise serializer error which needed to be recorded in queue dashboard.
 module SpreeCmCommissioner
-  class QueueOrderWebhooksRequestsJob < ApplicationJob
+  class QueueOrderWebhooksRequestsJob < ApplicationUniqueJob
     def perform(options)
       order_id = options[:order_id]
       event = options[:event]

app/jobs/spree_cm_commissioner/sms_job.rb

@@ -1,4 +1,4 @@
 module SpreeCmCommissioner
-  class SmsJob < ApplicationJob
+  class SmsJob < ApplicationUniqueJob
   end
 end

app/jobs/spree_cm_commissioner/state_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class StateJob < ApplicationJob
+  class StateJob < ApplicationUniqueJob
     def perform(state_id)
       state = ::Spree::State.find_by(id: state_id)
       StateUpdater.call(state: state)

app/jobs/spree_cm_commissioner/telegram_debug_pin_code_sender_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class TelegramDebugPinCodeSenderJob < ApplicationJob
+  class TelegramDebugPinCodeSenderJob < ApplicationUniqueJob
     def perform(pin_code_id)
       pin_code = SpreeCmCommissioner::PinCode.find(pin_code_id)
 

app/jobs/spree_cm_commissioner/telegram_notification_sender_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class TelegramNotificationSenderJob < ApplicationJob
+  class TelegramNotificationSenderJob < ApplicationUniqueJob
     def perform(options)
       return if options[:chat_id].nil?
 

app/jobs/spree_cm_commissioner/telegram_start_message_sender_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class TelegramStartMessageSenderJob < ApplicationJob
+  class TelegramStartMessageSenderJob < ApplicationUniqueJob
     queue_as :telegram_bot
 
     # :chat_id, :telegram_bot_id

app/jobs/spree_cm_commissioner/vendor_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class VendorJob < ApplicationJob
+  class VendorJob < ApplicationUniqueJob
     def perform(vendor_id)
       vendor = ::Spree::Vendor.find(vendor_id)
       VendorUpdater.call(vendor: vendor)

app/jobs/spree_cm_commissioner/webhook_subscriber_orders_sender_job.rb

@@ -1,5 +1,5 @@
 module SpreeCmCommissioner
-  class WebhookSubscriberOrdersSenderJob < ApplicationJob
+  class WebhookSubscriberOrdersSenderJob < ApplicationUniqueJob
     def perform(options)
       order_state = options[:order_state]
       webhooks_subscriber_id = options[:webhooks_subscriber_id]