Merge 4f8bf2b0cd into 549ab089ee

Add ApplicationWorker base class for workers
2024-08-20 21:08:15 -07:00 · 2024-07-31 11:04:47 +00:00 · 2024-07-18 13:41:56 -04:00
86 changed files with 94 additions and 223 deletions
--- a/app/workers/account_deletion_worker.rb
+++ b/app/workers/account_deletion_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class AccountDeletionWorker
+class AccountDeletionWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i
  def perform(account_id, options = {})
--- a/app/workers/account_merging_worker.rb
+++ b/app/workers/account_merging_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class AccountMergingWorker
+class AccountMergingWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull'
  def perform(account_id)
--- a/app/workers/account_refresh_worker.rb
+++ b/app/workers/account_refresh_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class AccountRefreshWorker
+class AccountRefreshWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', retry: 3, dead: false, lock: :until_executed, lock_ttl: 1.day.to_i
  def perform(account_id)
--- a/app/workers/activitypub/delivery_worker.rb
+++ b/app/workers/activitypub/delivery_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::DeliveryWorker
+class ActivityPub::DeliveryWorker < ApplicationWorker
  include Sidekiq::Worker
  include RoutingHelper
  include JsonLdHelper
--- a/app/workers/activitypub/distribute_poll_update_worker.rb
+++ b/app/workers/activitypub/distribute_poll_update_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::DistributePollUpdateWorker
+class ActivityPub::DistributePollUpdateWorker < ApplicationWorker
  include Sidekiq::Worker
  include Payloadable
  sidekiq_options queue: 'push', lock: :until_executed, retry: 0
--- a/app/workers/activitypub/fetch_replies_worker.rb
+++ b/app/workers/activitypub/fetch_replies_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::FetchRepliesWorker
+class ActivityPub::FetchRepliesWorker < ApplicationWorker
  include Sidekiq::Worker
  include ExponentialBackoff
  sidekiq_options queue: 'pull', retry: 3
--- a/app/workers/activitypub/followers_synchronization_worker.rb
+++ b/app/workers/activitypub/followers_synchronization_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::FollowersSynchronizationWorker
+class ActivityPub::FollowersSynchronizationWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'push', lock: :until_executed
  def perform(account_id, url)
--- a/app/workers/activitypub/move_distribution_worker.rb
+++ b/app/workers/activitypub/move_distribution_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::MoveDistributionWorker
+class ActivityPub::MoveDistributionWorker < ApplicationWorker
  include Sidekiq::Worker
  include Payloadable
  sidekiq_options queue: 'push'
--- a/app/workers/activitypub/post_upgrade_worker.rb
+++ b/app/workers/activitypub/post_upgrade_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::PostUpgradeWorker
+class ActivityPub::PostUpgradeWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull'
  def perform(domain)
--- a/app/workers/activitypub/processing_worker.rb
+++ b/app/workers/activitypub/processing_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::ProcessingWorker
+class ActivityPub::ProcessingWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'ingress', backtrace: true, retry: 8
  def perform(actor_id, body, delivered_to_account_id = nil, actor_type = 'Account')
--- a/app/workers/activitypub/raw_distribution_worker.rb
+++ b/app/workers/activitypub/raw_distribution_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::RawDistributionWorker
+class ActivityPub::RawDistributionWorker < ApplicationWorker
  include Sidekiq::Worker
  include Payloadable
  sidekiq_options queue: 'push'
--- a/app/workers/activitypub/synchronize_featured_collection_worker.rb
+++ b/app/workers/activitypub/synchronize_featured_collection_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::SynchronizeFeaturedCollectionWorker
+class ActivityPub::SynchronizeFeaturedCollectionWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i
  def perform(account_id, options = {})
--- a/app/workers/activitypub/synchronize_featured_tags_collection_worker.rb
+++ b/app/workers/activitypub/synchronize_featured_tags_collection_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class ActivityPub::SynchronizeFeaturedTagsCollectionWorker
+class ActivityPub::SynchronizeFeaturedTagsCollectionWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i
  def perform(account_id, url)
--- a/app/workers/add_to_public_statuses_index_worker.rb
+++ b/app/workers/add_to_public_statuses_index_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class AddToPublicStatusesIndexWorker
+class AddToPublicStatusesIndexWorker < ApplicationWorker
  include Sidekiq::Worker
  include DatabaseHelper
  sidekiq_options queue: 'pull'
--- a/app/workers/admin/account_deletion_worker.rb
+++ b/app/workers/admin/account_deletion_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Admin::AccountDeletionWorker
+class Admin::AccountDeletionWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i
  def perform(account_id)
--- a/app/workers/admin/domain_purge_worker.rb
+++ b/app/workers/admin/domain_purge_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Admin::DomainPurgeWorker
+class Admin::DomainPurgeWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i
  def perform(domain)
--- a/app/workers/admin/suspension_worker.rb
+++ b/app/workers/admin/suspension_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Admin::SuspensionWorker
+class Admin::SuspensionWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull'
  def perform(account_id)
--- a/app/workers/admin/unsuspension_worker.rb
+++ b/app/workers/admin/unsuspension_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Admin::UnsuspensionWorker
+class Admin::UnsuspensionWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull'
  def perform(account_id)
--- a/app/workers/after_account_domain_block_worker.rb
+++ b/app/workers/after_account_domain_block_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class AfterAccountDomainBlockWorker
+class AfterAccountDomainBlockWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id, domain)
    AfterBlockDomainFromAccountService.new.call(Account.find(account_id), domain)
  rescue ActiveRecord::RecordNotFound
--- a/app/workers/after_unallow_domain_worker.rb
+++ b/app/workers/after_unallow_domain_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class AfterUnallowDomainWorker
+class AfterUnallowDomainWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(domain)
    AfterUnallowDomainService.new.call(domain)
  end
--- a/app/workers/application_worker.rb
+++ b/app/workers/application_worker.rb
@ -0,0 +1,9 @@
 # frozen_string_literal: true
 class ApplicationWorker
  include Sidekiq::Worker
  def perform(*)
    raise NotImplementedError
  end
 end
--- a/app/workers/authorize_follow_worker.rb
+++ b/app/workers/authorize_follow_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class AuthorizeFollowWorker
+class AuthorizeFollowWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(source_account_id, target_account_id)
    source_account = Account.find(source_account_id)
    target_account = Account.find(target_account_id)
--- a/app/workers/backup_worker.rb
+++ b/app/workers/backup_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class BackupWorker
+class BackupWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', backtrace: true, retry: 5, dead: false
  sidekiq_retries_exhausted do |msg|
--- a/app/workers/block_worker.rb
+++ b/app/workers/block_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class BlockWorker
+class BlockWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id, target_account_id)
    AfterBlockService.new.call(
      Account.find(account_id),
--- a/app/workers/bootstrap_timeline_worker.rb
+++ b/app/workers/bootstrap_timeline_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class BootstrapTimelineWorker
+class BootstrapTimelineWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id)
    BootstrapTimelineService.new.call(Account.find(account_id))
  end
--- a/app/workers/bulk_import_worker.rb
+++ b/app/workers/bulk_import_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class BulkImportWorker
+class BulkImportWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', retry: false
  def perform(import_id)
--- a/app/workers/cache_buster_worker.rb
+++ b/app/workers/cache_buster_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class CacheBusterWorker
+class CacheBusterWorker < ApplicationWorker
  include Sidekiq::Worker
  include RoutingHelper
  sidekiq_options queue: 'pull'
--- a/app/workers/delete_mute_worker.rb
+++ b/app/workers/delete_mute_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class DeleteMuteWorker
+class DeleteMuteWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(mute_id)
    mute = Mute.find_by(id: mute_id)
    UnmuteService.new.call(mute.account, mute.target_account) if mute&.expired?
--- a/app/workers/distribution_worker.rb
+++ b/app/workers/distribution_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class DistributionWorker
+class DistributionWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  include Lockable
--- a/app/workers/domain_block_worker.rb
+++ b/app/workers/domain_block_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class DomainBlockWorker
+class DomainBlockWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(domain_block_id, update = false)
    domain_block = DomainBlock.find_by(id: domain_block_id)
    return true if domain_block.nil?
--- a/app/workers/domain_clear_media_worker.rb
+++ b/app/workers/domain_clear_media_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class DomainClearMediaWorker
+class DomainClearMediaWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull'
  def perform(domain_block_id)
--- a/app/workers/feed_insert_worker.rb
+++ b/app/workers/feed_insert_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class FeedInsertWorker
+class FeedInsertWorker < ApplicationWorker
  include Sidekiq::Worker
  include DatabaseHelper
  def perform(status_id, id, type = 'home', options = {})
--- a/app/workers/fetch_reply_worker.rb
+++ b/app/workers/fetch_reply_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class FetchReplyWorker
+class FetchReplyWorker < ApplicationWorker
  include Sidekiq::Worker
  include ExponentialBackoff
  sidekiq_options queue: 'pull', retry: 3
--- a/app/workers/generate_annual_report_worker.rb
+++ b/app/workers/generate_annual_report_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class GenerateAnnualReportWorker
+class GenerateAnnualReportWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id, year)
    AnnualReport.new(Account.find(account_id), year).generate
  rescue ActiveRecord::RecordNotFound, ActiveRecord::RecordNotUnique
--- a/app/workers/import/relationship_worker.rb
+++ b/app/workers/import/relationship_worker.rb
@ -3,9 +3,7 @@
 # NOTE: This is a deprecated worker, only kept to not break ongoing imports
 # on upgrade. See `Import::RowWorker` for its replacement.
-class Import::RelationshipWorker
+class Import::RelationshipWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', retry: 8, dead: false
  def perform(account_id, target_account_uri, relationship, options)
--- a/app/workers/import/row_worker.rb
+++ b/app/workers/import/row_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Import::RowWorker
+class Import::RowWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', retry: 6, dead: false
  sidekiq_retries_exhausted do |msg, _exception|
--- a/app/workers/import_worker.rb
+++ b/app/workers/import_worker.rb
@ -3,9 +3,7 @@
 # NOTE: This is a deprecated worker, only kept to not break ongoing imports
 # on upgrade. See `ImportWorker` for its replacement.
-class ImportWorker
+class ImportWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', retry: false
  def perform(import_id)
--- a/app/workers/link_crawl_worker.rb
+++ b/app/workers/link_crawl_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class LinkCrawlWorker
+class LinkCrawlWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', retry: 0
  def perform(status_id)
--- a/app/workers/local_notification_worker.rb
+++ b/app/workers/local_notification_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class LocalNotificationWorker
+class LocalNotificationWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(receiver_account_id, activity_id = nil, activity_class_name = nil, type = nil)
    if activity_id.nil? && activity_class_name.nil?
      activity = Mention.find(receiver_account_id)
--- a/app/workers/merge_worker.rb
+++ b/app/workers/merge_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class MergeWorker
+class MergeWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  include DatabaseHelper
--- a/app/workers/move_worker.rb
+++ b/app/workers/move_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class MoveWorker
+class MoveWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(source_account_id, target_account_id)
    @source_account = Account.find(source_account_id)
    @target_account = Account.find(target_account_id)
--- a/app/workers/mute_worker.rb
+++ b/app/workers/mute_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class MuteWorker
+class MuteWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id, target_account_id)
    FeedManager.instance.clear_from_home(Account.find(account_id), Account.find(target_account_id))
  rescue ActiveRecord::RecordNotFound
--- a/app/workers/poll_expiration_notify_worker.rb
+++ b/app/workers/poll_expiration_notify_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class PollExpirationNotifyWorker
+class PollExpirationNotifyWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options lock: :until_executing
  def perform(poll_id)
--- a/app/workers/post_process_media_worker.rb
+++ b/app/workers/post_process_media_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class PostProcessMediaWorker
+class PostProcessMediaWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 1, dead: false
  sidekiq_retries_exhausted do |msg|
--- a/app/workers/publish_announcement_reaction_worker.rb
+++ b/app/workers/publish_announcement_reaction_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class PublishAnnouncementReactionWorker
+class PublishAnnouncementReactionWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  def perform(announcement_id, name)
--- a/app/workers/publish_scheduled_announcement_worker.rb
+++ b/app/workers/publish_scheduled_announcement_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class PublishScheduledAnnouncementWorker
+class PublishScheduledAnnouncementWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  def perform(announcement_id)
--- a/app/workers/publish_scheduled_status_worker.rb
+++ b/app/workers/publish_scheduled_status_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class PublishScheduledStatusWorker
+class PublishScheduledStatusWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options lock: :until_executed, lock_ttl: 1.hour.to_i
  def perform(scheduled_status_id)
--- a/app/workers/push_conversation_worker.rb
+++ b/app/workers/push_conversation_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class PushConversationWorker
+class PushConversationWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  def perform(conversation_account_id)
--- a/app/workers/push_encrypted_message_worker.rb
+++ b/app/workers/push_encrypted_message_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class PushEncryptedMessageWorker
+class PushEncryptedMessageWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  def perform(encrypted_message_id)
--- a/app/workers/push_update_worker.rb
+++ b/app/workers/push_update_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class PushUpdateWorker
+class PushUpdateWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  def perform(account_id, status_id, timeline_id = nil, options = {})
--- a/app/workers/redownload_avatar_worker.rb
+++ b/app/workers/redownload_avatar_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class RedownloadAvatarWorker
+class RedownloadAvatarWorker < ApplicationWorker
  include Sidekiq::Worker
  include ExponentialBackoff
  include JsonLdHelper
--- a/app/workers/redownload_header_worker.rb
+++ b/app/workers/redownload_header_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class RedownloadHeaderWorker
+class RedownloadHeaderWorker < ApplicationWorker
  include Sidekiq::Worker
  include ExponentialBackoff
  include JsonLdHelper
--- a/app/workers/redownload_media_worker.rb
+++ b/app/workers/redownload_media_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class RedownloadMediaWorker
+class RedownloadMediaWorker < ApplicationWorker
  include Sidekiq::Worker
  include ExponentialBackoff
  include JsonLdHelper
--- a/app/workers/refollow_worker.rb
+++ b/app/workers/refollow_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class RefollowWorker
+class RefollowWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', retry: false
  def perform(target_account_id)
--- a/app/workers/regeneration_worker.rb
+++ b/app/workers/regeneration_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class RegenerationWorker
+class RegenerationWorker < ApplicationWorker
  include Sidekiq::Worker
  include DatabaseHelper
  sidekiq_options lock: :until_executed
--- a/app/workers/remote_account_refresh_worker.rb
+++ b/app/workers/remote_account_refresh_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class RemoteAccountRefreshWorker
+class RemoteAccountRefreshWorker < ApplicationWorker
  include Sidekiq::Worker
  include ExponentialBackoff
  include JsonLdHelper
--- a/app/workers/removal_worker.rb
+++ b/app/workers/removal_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class RemovalWorker
+class RemovalWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(status_id, options = {})
    RemoveStatusService.new.call(Status.with_discarded.find(status_id), **options.symbolize_keys)
  rescue ActiveRecord::RecordNotFound
--- a/app/workers/remove_featured_tag_worker.rb
+++ b/app/workers/remove_featured_tag_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class RemoveFeaturedTagWorker
+class RemoveFeaturedTagWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id, featured_tag_id)
    RemoveFeaturedTagService.new.call(Account.find(account_id), FeaturedTag.find(featured_tag_id))
  rescue ActiveRecord::RecordNotFound
--- a/app/workers/remove_from_public_statuses_index_worker.rb
+++ b/app/workers/remove_from_public_statuses_index_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class RemoveFromPublicStatusesIndexWorker
+class RemoveFromPublicStatusesIndexWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id)
    account = Account.find(account_id)
--- a/app/workers/resolve_account_worker.rb
+++ b/app/workers/resolve_account_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class ResolveAccountWorker
+class ResolveAccountWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i
  def perform(uri)
--- a/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb
+++ b/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::AccountsStatusesCleanupScheduler
+class Scheduler::AccountsStatusesCleanupScheduler < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  # This limit is mostly to be nice to the fediverse at large and not
--- a/app/workers/scheduler/auto_close_registrations_scheduler.rb
+++ b/app/workers/scheduler/auto_close_registrations_scheduler.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::AutoCloseRegistrationsScheduler
+class Scheduler::AutoCloseRegistrationsScheduler < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  sidekiq_options retry: 0
--- a/app/workers/scheduler/follow_recommendations_scheduler.rb
+++ b/app/workers/scheduler/follow_recommendations_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::FollowRecommendationsScheduler
+class Scheduler::FollowRecommendationsScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
  def perform
--- a/app/workers/scheduler/indexing_scheduler.rb
+++ b/app/workers/scheduler/indexing_scheduler.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::IndexingScheduler
+class Scheduler::IndexingScheduler < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  include DatabaseHelper
--- a/app/workers/scheduler/instance_refresh_scheduler.rb
+++ b/app/workers/scheduler/instance_refresh_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::InstanceRefreshScheduler
+class Scheduler::InstanceRefreshScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
  def perform
--- a/app/workers/scheduler/ip_cleanup_scheduler.rb
+++ b/app/workers/scheduler/ip_cleanup_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::IpCleanupScheduler
+class Scheduler::IpCleanupScheduler < ApplicationWorker
  include Sidekiq::Worker
  IP_RETENTION_PERIOD = ENV.fetch('IP_RETENTION_PERIOD', 1.year).to_i.seconds.freeze
  SESSION_RETENTION_PERIOD = ENV.fetch('SESSION_RETENTION_PERIOD', 1.year).to_i.seconds.freeze
--- a/app/workers/scheduler/pghero_scheduler.rb
+++ b/app/workers/scheduler/pghero_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::PgheroScheduler
+class Scheduler::PgheroScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
  def perform
--- a/app/workers/scheduler/scheduled_statuses_scheduler.rb
+++ b/app/workers/scheduler/scheduled_statuses_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::ScheduledStatusesScheduler
+class Scheduler::ScheduledStatusesScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.hour.to_i
  def perform
--- a/app/workers/scheduler/self_destruct_scheduler.rb
+++ b/app/workers/scheduler/self_destruct_scheduler.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::SelfDestructScheduler
+class Scheduler::SelfDestructScheduler < ApplicationWorker
  include Sidekiq::Worker
  include SelfDestructHelper
  MAX_ENQUEUED = 10_000
--- a/app/workers/scheduler/software_update_check_scheduler.rb
+++ b/app/workers/scheduler/software_update_check_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::SoftwareUpdateCheckScheduler
+class Scheduler::SoftwareUpdateCheckScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.hour.to_i
  def perform
--- a/app/workers/scheduler/suspended_user_cleanup_scheduler.rb
+++ b/app/workers/scheduler/suspended_user_cleanup_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::SuspendedUserCleanupScheduler
+class Scheduler::SuspendedUserCleanupScheduler < ApplicationWorker
  include Sidekiq::Worker
  # Each processed deletion request may enqueue an enormous
  # amount of jobs in the `pull` queue, so only enqueue when
  # the queue is empty or close to being so.
--- a/app/workers/scheduler/trends/refresh_scheduler.rb
+++ b/app/workers/scheduler/trends/refresh_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::Trends::RefreshScheduler
+class Scheduler::Trends::RefreshScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 30.minutes.to_i
  def perform
--- a/app/workers/scheduler/trends/review_notifications_scheduler.rb
+++ b/app/workers/scheduler/trends/review_notifications_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::Trends::ReviewNotificationsScheduler
+class Scheduler::Trends::ReviewNotificationsScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0
  def perform
--- a/app/workers/scheduler/user_cleanup_scheduler.rb
+++ b/app/workers/scheduler/user_cleanup_scheduler.rb
@ -1,6 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::UserCleanupScheduler
+class Scheduler::UserCleanupScheduler < ApplicationWorker
  include Sidekiq::Worker
  UNCONFIRMED_ACCOUNTS_MAX_AGE_DAYS = 7
--- a/app/workers/scheduler/vacuum_scheduler.rb
+++ b/app/workers/scheduler/vacuum_scheduler.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Scheduler::VacuumScheduler
+class Scheduler::VacuumScheduler < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
  def perform
--- a/app/workers/tag_unmerge_worker.rb
+++ b/app/workers/tag_unmerge_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class TagUnmergeWorker
+class TagUnmergeWorker < ApplicationWorker
  include Sidekiq::Worker
  include DatabaseHelper
  sidekiq_options queue: 'pull'
--- a/app/workers/thread_resolve_worker.rb
+++ b/app/workers/thread_resolve_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class ThreadResolveWorker
+class ThreadResolveWorker < ApplicationWorker
  include Sidekiq::Worker
  include ExponentialBackoff
  sidekiq_options queue: 'pull', retry: 3
--- a/app/workers/trigger_webhook_worker.rb
+++ b/app/workers/trigger_webhook_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class TriggerWebhookWorker
+class TriggerWebhookWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(event, class_name, id)
    object = class_name.constantize.find(id)
    WebhookService.new.call(event, object)
--- a/app/workers/unfavourite_worker.rb
+++ b/app/workers/unfavourite_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class UnfavouriteWorker
+class UnfavouriteWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(account_id, status_id)
    UnfavouriteService.new.call(Account.find(account_id), Status.find(status_id))
  rescue ActiveRecord::RecordNotFound
--- a/app/workers/unfilter_notifications_worker.rb
+++ b/app/workers/unfilter_notifications_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class UnfilterNotificationsWorker
+class UnfilterNotificationsWorker < ApplicationWorker
  include Sidekiq::Worker
  def perform(notification_request_id)
    @notification_request = NotificationRequest.find(notification_request_id)
--- a/app/workers/unfollow_follow_worker.rb
+++ b/app/workers/unfollow_follow_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class UnfollowFollowWorker
+class UnfollowFollowWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'pull'
  def perform(follower_account_id, old_target_account_id, new_target_account_id, bypass_locked = false)
--- a/app/workers/unmerge_worker.rb
+++ b/app/workers/unmerge_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class UnmergeWorker
+class UnmergeWorker < ApplicationWorker
  include Sidekiq::Worker
  include DatabaseHelper
  sidekiq_options queue: 'pull'
--- a/app/workers/unpublish_announcement_worker.rb
+++ b/app/workers/unpublish_announcement_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class UnpublishAnnouncementWorker
+class UnpublishAnnouncementWorker < ApplicationWorker
  include Sidekiq::Worker
  include Redisable
  def perform(announcement_id)
--- a/app/workers/verify_account_links_worker.rb
+++ b/app/workers/verify_account_links_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class VerifyAccountLinksWorker
+class VerifyAccountLinksWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'default', retry: false, lock: :until_executed, lock_ttl: 1.hour.to_i
  def perform(account_id)
--- a/app/workers/web/push_notification_worker.rb
+++ b/app/workers/web/push_notification_worker.rb
@ -1,8 +1,6 @@
 # frozen_string_literal: true
-class Web::PushNotificationWorker
+class Web::PushNotificationWorker < ApplicationWorker
  include Sidekiq::Worker
  sidekiq_options queue: 'push', retry: 5
  TTL     = 48.hours.to_s
--- a/app/workers/webhooks/delivery_worker.rb
+++ b/app/workers/webhooks/delivery_worker.rb
@ -1,7 +1,6 @@
 # frozen_string_literal: true
-class Webhooks::DeliveryWorker
+class Webhooks::DeliveryWorker < ApplicationWorker
  include Sidekiq::Worker
  include JsonLdHelper
  sidekiq_options queue: 'push', retry: 16, dead: false
Author	SHA1	Message	Date
Matt Jankowski	662c885e7d	Merge `4f8bf2b0cd` into `549ab089ee`	2024-07-31 11:04:47 +00:00
Matt Jankowski	4f8bf2b0cd	Add `ApplicationWorker` base class for workers	2024-07-18 13:41:56 -04:00