diff --git a/app/workers/account_deletion_worker.rb b/app/workers/account_deletion_worker.rb index 070352f957..9bce960be6 100644 --- a/app/workers/account_deletion_worker.rb +++ b/app/workers/account_deletion_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class AccountDeletionWorker - include Sidekiq::Worker - +class AccountDeletionWorker < ApplicationWorker sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i def perform(account_id, options = {}) diff --git a/app/workers/account_merging_worker.rb b/app/workers/account_merging_worker.rb index 8c234e7acf..915f6cdf65 100644 --- a/app/workers/account_merging_worker.rb +++ b/app/workers/account_merging_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class AccountMergingWorker - include Sidekiq::Worker - +class AccountMergingWorker < ApplicationWorker sidekiq_options queue: 'pull' def perform(account_id) diff --git a/app/workers/account_refresh_worker.rb b/app/workers/account_refresh_worker.rb index 08b5bab8da..f38eb465a0 100644 --- a/app/workers/account_refresh_worker.rb +++ b/app/workers/account_refresh_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class AccountRefreshWorker - include Sidekiq::Worker - +class AccountRefreshWorker < ApplicationWorker sidekiq_options queue: 'pull', retry: 3, dead: false, lock: :until_executed, lock_ttl: 1.day.to_i def perform(account_id) diff --git a/app/workers/activitypub/delivery_worker.rb b/app/workers/activitypub/delivery_worker.rb index 0c6ca026bb..d70479cb71 100644 --- 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 - include Sidekiq::Worker +class ActivityPub::DeliveryWorker < ApplicationWorker include RoutingHelper include JsonLdHelper diff --git a/app/workers/activitypub/distribute_poll_update_worker.rb b/app/workers/activitypub/distribute_poll_update_worker.rb index 8c1eefd93d..9174d5876f 100644 --- 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 - include Sidekiq::Worker +class ActivityPub::DistributePollUpdateWorker < ApplicationWorker include Payloadable sidekiq_options queue: 'push', lock: :until_executed, retry: 0 diff --git a/app/workers/activitypub/fetch_replies_worker.rb b/app/workers/activitypub/fetch_replies_worker.rb index d72bad7452..8f8c0eadfc 100644 --- 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 - include Sidekiq::Worker +class ActivityPub::FetchRepliesWorker < ApplicationWorker include ExponentialBackoff sidekiq_options queue: 'pull', retry: 3 diff --git a/app/workers/activitypub/followers_synchronization_worker.rb b/app/workers/activitypub/followers_synchronization_worker.rb index 35a3ef0b96..4665e251e4 100644 --- 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 - include Sidekiq::Worker - +class ActivityPub::FollowersSynchronizationWorker < ApplicationWorker sidekiq_options queue: 'push', lock: :until_executed def perform(account_id, url) diff --git a/app/workers/activitypub/move_distribution_worker.rb b/app/workers/activitypub/move_distribution_worker.rb index 1680fcc76e..9343321eae 100644 --- 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 - include Sidekiq::Worker +class ActivityPub::MoveDistributionWorker < ApplicationWorker include Payloadable sidekiq_options queue: 'push' diff --git a/app/workers/activitypub/post_upgrade_worker.rb b/app/workers/activitypub/post_upgrade_worker.rb index 4154b8582b..7475a7c3b4 100644 --- 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 - include Sidekiq::Worker - +class ActivityPub::PostUpgradeWorker < ApplicationWorker sidekiq_options queue: 'pull' def perform(domain) diff --git a/app/workers/activitypub/processing_worker.rb b/app/workers/activitypub/processing_worker.rb index 1bb94b7f26..ed328e3d05 100644 --- 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 - include Sidekiq::Worker - +class ActivityPub::ProcessingWorker < ApplicationWorker sidekiq_options queue: 'ingress', backtrace: true, retry: 8 def perform(actor_id, body, delivered_to_account_id = nil, actor_type = 'Account') diff --git a/app/workers/activitypub/raw_distribution_worker.rb b/app/workers/activitypub/raw_distribution_worker.rb index c77821e0f1..15450e5b0d 100644 --- 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 - include Sidekiq::Worker +class ActivityPub::RawDistributionWorker < ApplicationWorker include Payloadable sidekiq_options queue: 'push' diff --git a/app/workers/activitypub/synchronize_featured_collection_worker.rb b/app/workers/activitypub/synchronize_featured_collection_worker.rb index 7a187d7f53..9f4c877552 100644 --- 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 - include Sidekiq::Worker - +class ActivityPub::SynchronizeFeaturedCollectionWorker < ApplicationWorker sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i def perform(account_id, options = {}) diff --git a/app/workers/activitypub/synchronize_featured_tags_collection_worker.rb b/app/workers/activitypub/synchronize_featured_tags_collection_worker.rb index 570415c821..9a0e19f858 100644 --- 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 - include Sidekiq::Worker - +class ActivityPub::SynchronizeFeaturedTagsCollectionWorker < ApplicationWorker sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i def perform(account_id, url) diff --git a/app/workers/add_to_public_statuses_index_worker.rb b/app/workers/add_to_public_statuses_index_worker.rb index 80d921eab0..d32637217e 100644 --- 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 - include Sidekiq::Worker +class AddToPublicStatusesIndexWorker < ApplicationWorker include DatabaseHelper sidekiq_options queue: 'pull' diff --git a/app/workers/admin/account_deletion_worker.rb b/app/workers/admin/account_deletion_worker.rb index 5dfdfb6e73..a3a6f8bf83 100644 --- 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 - include Sidekiq::Worker - +class Admin::AccountDeletionWorker < ApplicationWorker sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i def perform(account_id) diff --git a/app/workers/admin/domain_purge_worker.rb b/app/workers/admin/domain_purge_worker.rb index 6c5250b660..f54558aa40 100644 --- 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 - include Sidekiq::Worker - +class Admin::DomainPurgeWorker < ApplicationWorker sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i def perform(domain) diff --git a/app/workers/admin/suspension_worker.rb b/app/workers/admin/suspension_worker.rb index 35c5703360..8065b0128f 100644 --- 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 - include Sidekiq::Worker - +class Admin::SuspensionWorker < ApplicationWorker sidekiq_options queue: 'pull' def perform(account_id) diff --git a/app/workers/admin/unsuspension_worker.rb b/app/workers/admin/unsuspension_worker.rb index 7cb2349b16..7949ad585f 100644 --- 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 - include Sidekiq::Worker - +class Admin::UnsuspensionWorker < ApplicationWorker sidekiq_options queue: 'pull' def perform(account_id) diff --git a/app/workers/after_account_domain_block_worker.rb b/app/workers/after_account_domain_block_worker.rb index 043c333117..e16fc758cf 100644 --- 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 - include Sidekiq::Worker - +class AfterAccountDomainBlockWorker < ApplicationWorker def perform(account_id, domain) AfterBlockDomainFromAccountService.new.call(Account.find(account_id), domain) rescue ActiveRecord::RecordNotFound diff --git a/app/workers/after_unallow_domain_worker.rb b/app/workers/after_unallow_domain_worker.rb index 46049cbb2e..307e30a2b1 100644 --- 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 - include Sidekiq::Worker - +class AfterUnallowDomainWorker < ApplicationWorker def perform(domain) AfterUnallowDomainService.new.call(domain) end diff --git a/app/workers/application_worker.rb b/app/workers/application_worker.rb new file mode 100644 index 0000000000..8cec73b792 --- /dev/null +++ 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 diff --git a/app/workers/authorize_follow_worker.rb b/app/workers/authorize_follow_worker.rb index f57900fa59..fcd52a4c23 100644 --- a/app/workers/authorize_follow_worker.rb +++ b/app/workers/authorize_follow_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class AuthorizeFollowWorker - include Sidekiq::Worker - +class AuthorizeFollowWorker < ApplicationWorker def perform(source_account_id, target_account_id) source_account = Account.find(source_account_id) target_account = Account.find(target_account_id) diff --git a/app/workers/backup_worker.rb b/app/workers/backup_worker.rb index df933142ae..06cbf8fab5 100644 --- a/app/workers/backup_worker.rb +++ b/app/workers/backup_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class BackupWorker - include Sidekiq::Worker - +class BackupWorker < ApplicationWorker sidekiq_options queue: 'pull', backtrace: true, retry: 5, dead: false sidekiq_retries_exhausted do |msg| diff --git a/app/workers/block_worker.rb b/app/workers/block_worker.rb index 25f5dd808f..e33fc703a4 100644 --- a/app/workers/block_worker.rb +++ b/app/workers/block_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class BlockWorker - include Sidekiq::Worker - +class BlockWorker < ApplicationWorker def perform(account_id, target_account_id) AfterBlockService.new.call( Account.find(account_id), diff --git a/app/workers/bootstrap_timeline_worker.rb b/app/workers/bootstrap_timeline_worker.rb index 89cfb4c3ae..307f38662c 100644 --- a/app/workers/bootstrap_timeline_worker.rb +++ b/app/workers/bootstrap_timeline_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class BootstrapTimelineWorker - include Sidekiq::Worker - +class BootstrapTimelineWorker < ApplicationWorker def perform(account_id) BootstrapTimelineService.new.call(Account.find(account_id)) end diff --git a/app/workers/bulk_import_worker.rb b/app/workers/bulk_import_worker.rb index 54571a95c0..f8e6a2cb99 100644 --- a/app/workers/bulk_import_worker.rb +++ b/app/workers/bulk_import_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class BulkImportWorker - include Sidekiq::Worker - +class BulkImportWorker < ApplicationWorker sidekiq_options queue: 'pull', retry: false def perform(import_id) diff --git a/app/workers/cache_buster_worker.rb b/app/workers/cache_buster_worker.rb index 5ad0a44cb7..5de031e754 100644 --- a/app/workers/cache_buster_worker.rb +++ b/app/workers/cache_buster_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class CacheBusterWorker - include Sidekiq::Worker +class CacheBusterWorker < ApplicationWorker include RoutingHelper sidekiq_options queue: 'pull' diff --git a/app/workers/delete_mute_worker.rb b/app/workers/delete_mute_worker.rb index eb031020e1..e76951ed31 100644 --- a/app/workers/delete_mute_worker.rb +++ b/app/workers/delete_mute_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class DeleteMuteWorker - include Sidekiq::Worker - +class DeleteMuteWorker < ApplicationWorker def perform(mute_id) mute = Mute.find_by(id: mute_id) UnmuteService.new.call(mute.account, mute.target_account) if mute&.expired? diff --git a/app/workers/distribution_worker.rb b/app/workers/distribution_worker.rb index 1d58e53e94..2b39ba1c51 100644 --- a/app/workers/distribution_worker.rb +++ b/app/workers/distribution_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class DistributionWorker - include Sidekiq::Worker +class DistributionWorker < ApplicationWorker include Redisable include Lockable diff --git a/app/workers/domain_block_worker.rb b/app/workers/domain_block_worker.rb index 3c601cd832..d1e18cea3f 100644 --- a/app/workers/domain_block_worker.rb +++ b/app/workers/domain_block_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class DomainBlockWorker - include Sidekiq::Worker - +class DomainBlockWorker < ApplicationWorker def perform(domain_block_id, update = false) domain_block = DomainBlock.find_by(id: domain_block_id) return true if domain_block.nil? diff --git a/app/workers/domain_clear_media_worker.rb b/app/workers/domain_clear_media_worker.rb index 971934a088..ba63f5c4fb 100644 --- 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 - include Sidekiq::Worker - +class DomainClearMediaWorker < ApplicationWorker sidekiq_options queue: 'pull' def perform(domain_block_id) diff --git a/app/workers/feed_insert_worker.rb b/app/workers/feed_insert_worker.rb index fd7dbd30da..4f07bcfa74 100644 --- a/app/workers/feed_insert_worker.rb +++ b/app/workers/feed_insert_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class FeedInsertWorker - include Sidekiq::Worker +class FeedInsertWorker < ApplicationWorker include DatabaseHelper def perform(status_id, id, type = 'home', options = {}) diff --git a/app/workers/fetch_reply_worker.rb b/app/workers/fetch_reply_worker.rb index 68a7414beb..5ae2704916 100644 --- a/app/workers/fetch_reply_worker.rb +++ b/app/workers/fetch_reply_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class FetchReplyWorker - include Sidekiq::Worker +class FetchReplyWorker < ApplicationWorker include ExponentialBackoff sidekiq_options queue: 'pull', retry: 3 diff --git a/app/workers/generate_annual_report_worker.rb b/app/workers/generate_annual_report_worker.rb index 7094c1ab9c..d259ef47c5 100644 --- 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 - include Sidekiq::Worker - +class GenerateAnnualReportWorker < ApplicationWorker def perform(account_id, year) AnnualReport.new(Account.find(account_id), year).generate rescue ActiveRecord::RecordNotFound, ActiveRecord::RecordNotUnique diff --git a/app/workers/import/relationship_worker.rb b/app/workers/import/relationship_worker.rb index 2298b095a7..7c064f3ef6 100644 --- 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 - include Sidekiq::Worker - +class Import::RelationshipWorker < ApplicationWorker sidekiq_options queue: 'pull', retry: 8, dead: false def perform(account_id, target_account_uri, relationship, options) diff --git a/app/workers/import/row_worker.rb b/app/workers/import/row_worker.rb index c86900e6ad..15c0b06a65 100644 --- 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 - include Sidekiq::Worker - +class Import::RowWorker < ApplicationWorker sidekiq_options queue: 'pull', retry: 6, dead: false sidekiq_retries_exhausted do |msg, _exception| diff --git a/app/workers/import_worker.rb b/app/workers/import_worker.rb index b6afb972a9..7200d2be80 100644 --- 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 - include Sidekiq::Worker - +class ImportWorker < ApplicationWorker sidekiq_options queue: 'pull', retry: false def perform(import_id) diff --git a/app/workers/link_crawl_worker.rb b/app/workers/link_crawl_worker.rb index c63af1e43a..37b3cf1382 100644 --- a/app/workers/link_crawl_worker.rb +++ b/app/workers/link_crawl_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class LinkCrawlWorker - include Sidekiq::Worker - +class LinkCrawlWorker < ApplicationWorker sidekiq_options queue: 'pull', retry: 0 def perform(status_id) diff --git a/app/workers/local_notification_worker.rb b/app/workers/local_notification_worker.rb index 749a54b73b..4da3a5301a 100644 --- a/app/workers/local_notification_worker.rb +++ b/app/workers/local_notification_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class LocalNotificationWorker - include Sidekiq::Worker - +class LocalNotificationWorker < ApplicationWorker 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) diff --git a/app/workers/merge_worker.rb b/app/workers/merge_worker.rb index 8e1614ad21..38adf0f09b 100644 --- a/app/workers/merge_worker.rb +++ b/app/workers/merge_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class MergeWorker - include Sidekiq::Worker +class MergeWorker < ApplicationWorker include Redisable include DatabaseHelper diff --git a/app/workers/move_worker.rb b/app/workers/move_worker.rb index a18f38556b..83b093289c 100644 --- a/app/workers/move_worker.rb +++ b/app/workers/move_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class MoveWorker - include Sidekiq::Worker - +class MoveWorker < ApplicationWorker def perform(source_account_id, target_account_id) @source_account = Account.find(source_account_id) @target_account = Account.find(target_account_id) diff --git a/app/workers/mute_worker.rb b/app/workers/mute_worker.rb index c74f657cba..7f7f67fc4a 100644 --- a/app/workers/mute_worker.rb +++ b/app/workers/mute_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class MuteWorker - include Sidekiq::Worker - +class MuteWorker < ApplicationWorker def perform(account_id, target_account_id) FeedManager.instance.clear_from_home(Account.find(account_id), Account.find(target_account_id)) rescue ActiveRecord::RecordNotFound diff --git a/app/workers/poll_expiration_notify_worker.rb b/app/workers/poll_expiration_notify_worker.rb index b7a60fab84..a5fc309191 100644 --- 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 - include Sidekiq::Worker - +class PollExpirationNotifyWorker < ApplicationWorker sidekiq_options lock: :until_executing def perform(poll_id) diff --git a/app/workers/post_process_media_worker.rb b/app/workers/post_process_media_worker.rb index 2d11b00c20..bdb04f807c 100644 --- 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 - include Sidekiq::Worker - +class PostProcessMediaWorker < ApplicationWorker sidekiq_options retry: 1, dead: false sidekiq_retries_exhausted do |msg| diff --git a/app/workers/publish_announcement_reaction_worker.rb b/app/workers/publish_announcement_reaction_worker.rb index 03da56550a..4b8376fa87 100644 --- 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 - include Sidekiq::Worker +class PublishAnnouncementReactionWorker < ApplicationWorker include Redisable def perform(announcement_id, name) diff --git a/app/workers/publish_scheduled_announcement_worker.rb b/app/workers/publish_scheduled_announcement_worker.rb index c23eae6af7..0ee585468f 100644 --- 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 - include Sidekiq::Worker +class PublishScheduledAnnouncementWorker < ApplicationWorker include Redisable def perform(announcement_id) diff --git a/app/workers/publish_scheduled_status_worker.rb b/app/workers/publish_scheduled_status_worker.rb index aa5c4a834a..247e6b1284 100644 --- 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 - include Sidekiq::Worker - +class PublishScheduledStatusWorker < ApplicationWorker sidekiq_options lock: :until_executed, lock_ttl: 1.hour.to_i def perform(scheduled_status_id) diff --git a/app/workers/push_conversation_worker.rb b/app/workers/push_conversation_worker.rb index 23b1469f11..a5153b105e 100644 --- a/app/workers/push_conversation_worker.rb +++ b/app/workers/push_conversation_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class PushConversationWorker - include Sidekiq::Worker +class PushConversationWorker < ApplicationWorker include Redisable def perform(conversation_account_id) diff --git a/app/workers/push_encrypted_message_worker.rb b/app/workers/push_encrypted_message_worker.rb index 6bee12675b..eafea32cd1 100644 --- 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 - include Sidekiq::Worker +class PushEncryptedMessageWorker < ApplicationWorker include Redisable def perform(encrypted_message_id) diff --git a/app/workers/push_update_worker.rb b/app/workers/push_update_worker.rb index c32975a986..6850dce6fa 100644 --- a/app/workers/push_update_worker.rb +++ b/app/workers/push_update_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class PushUpdateWorker - include Sidekiq::Worker +class PushUpdateWorker < ApplicationWorker include Redisable def perform(account_id, status_id, timeline_id = nil, options = {}) diff --git a/app/workers/redownload_avatar_worker.rb b/app/workers/redownload_avatar_worker.rb index df17b7718d..9384cbb7a3 100644 --- a/app/workers/redownload_avatar_worker.rb +++ b/app/workers/redownload_avatar_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class RedownloadAvatarWorker - include Sidekiq::Worker +class RedownloadAvatarWorker < ApplicationWorker include ExponentialBackoff include JsonLdHelper diff --git a/app/workers/redownload_header_worker.rb b/app/workers/redownload_header_worker.rb index 3b142ec5f9..b73ac968fa 100644 --- a/app/workers/redownload_header_worker.rb +++ b/app/workers/redownload_header_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class RedownloadHeaderWorker - include Sidekiq::Worker +class RedownloadHeaderWorker < ApplicationWorker include ExponentialBackoff include JsonLdHelper diff --git a/app/workers/redownload_media_worker.rb b/app/workers/redownload_media_worker.rb index 343caa32c2..57219bfe6d 100644 --- a/app/workers/redownload_media_worker.rb +++ b/app/workers/redownload_media_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class RedownloadMediaWorker - include Sidekiq::Worker +class RedownloadMediaWorker < ApplicationWorker include ExponentialBackoff include JsonLdHelper diff --git a/app/workers/refollow_worker.rb b/app/workers/refollow_worker.rb index 4b712d3aae..cef9d64675 100644 --- a/app/workers/refollow_worker.rb +++ b/app/workers/refollow_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class RefollowWorker - include Sidekiq::Worker - +class RefollowWorker < ApplicationWorker sidekiq_options queue: 'pull', retry: false def perform(target_account_id) diff --git a/app/workers/regeneration_worker.rb b/app/workers/regeneration_worker.rb index 4228f897d3..5f63bcdbdb 100644 --- a/app/workers/regeneration_worker.rb +++ b/app/workers/regeneration_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class RegenerationWorker - include Sidekiq::Worker +class RegenerationWorker < ApplicationWorker include DatabaseHelper sidekiq_options lock: :until_executed diff --git a/app/workers/remote_account_refresh_worker.rb b/app/workers/remote_account_refresh_worker.rb index 9632936b54..052cc823a9 100644 --- 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 - include Sidekiq::Worker +class RemoteAccountRefreshWorker < ApplicationWorker include ExponentialBackoff include JsonLdHelper diff --git a/app/workers/removal_worker.rb b/app/workers/removal_worker.rb index 2a1eaa89b0..a4ff97aa92 100644 --- a/app/workers/removal_worker.rb +++ b/app/workers/removal_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class RemovalWorker - include Sidekiq::Worker - +class RemovalWorker < ApplicationWorker def perform(status_id, options = {}) RemoveStatusService.new.call(Status.with_discarded.find(status_id), **options.symbolize_keys) rescue ActiveRecord::RecordNotFound diff --git a/app/workers/remove_featured_tag_worker.rb b/app/workers/remove_featured_tag_worker.rb index 065ec79d81..bcc24feb40 100644 --- 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 - include Sidekiq::Worker - +class RemoveFeaturedTagWorker < ApplicationWorker def perform(account_id, featured_tag_id) RemoveFeaturedTagService.new.call(Account.find(account_id), FeaturedTag.find(featured_tag_id)) rescue ActiveRecord::RecordNotFound diff --git a/app/workers/remove_from_public_statuses_index_worker.rb b/app/workers/remove_from_public_statuses_index_worker.rb index e108a5c209..22fc51de59 100644 --- 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 - include Sidekiq::Worker - +class RemoveFromPublicStatusesIndexWorker < ApplicationWorker def perform(account_id) account = Account.find(account_id) diff --git a/app/workers/resolve_account_worker.rb b/app/workers/resolve_account_worker.rb index 4ae2442af5..2661feddf0 100644 --- a/app/workers/resolve_account_worker.rb +++ b/app/workers/resolve_account_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class ResolveAccountWorker - include Sidekiq::Worker - +class ResolveAccountWorker < ApplicationWorker sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i def perform(uri) diff --git a/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb b/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb index a2ab31cc5d..48246d6513 100644 --- 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 - include Sidekiq::Worker +class Scheduler::AccountsStatusesCleanupScheduler < ApplicationWorker include Redisable # This limit is mostly to be nice to the fediverse at large and not diff --git a/app/workers/scheduler/auto_close_registrations_scheduler.rb b/app/workers/scheduler/auto_close_registrations_scheduler.rb index 6874502915..929af5661f 100644 --- 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 - include Sidekiq::Worker +class Scheduler::AutoCloseRegistrationsScheduler < ApplicationWorker include Redisable sidekiq_options retry: 0 diff --git a/app/workers/scheduler/follow_recommendations_scheduler.rb b/app/workers/scheduler/follow_recommendations_scheduler.rb index ea5aa8b539..dde1e92c88 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::FollowRecommendationsScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i def perform diff --git a/app/workers/scheduler/indexing_scheduler.rb b/app/workers/scheduler/indexing_scheduler.rb index f52d0141d4..ae174ce1d9 100644 --- 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 - include Sidekiq::Worker +class Scheduler::IndexingScheduler < ApplicationWorker include Redisable include DatabaseHelper diff --git a/app/workers/scheduler/instance_refresh_scheduler.rb b/app/workers/scheduler/instance_refresh_scheduler.rb index 818682a5d2..0e808c4178 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::InstanceRefreshScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i def perform diff --git a/app/workers/scheduler/ip_cleanup_scheduler.rb b/app/workers/scheduler/ip_cleanup_scheduler.rb index f78c0584d7..37f8f3fdd3 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::IpCleanupScheduler < ApplicationWorker 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 diff --git a/app/workers/scheduler/pghero_scheduler.rb b/app/workers/scheduler/pghero_scheduler.rb index 49bf2db7a6..3483e9b314 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::PgheroScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i def perform diff --git a/app/workers/scheduler/scheduled_statuses_scheduler.rb b/app/workers/scheduler/scheduled_statuses_scheduler.rb index fe60d5524e..df14681bba 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::ScheduledStatusesScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.hour.to_i def perform diff --git a/app/workers/scheduler/self_destruct_scheduler.rb b/app/workers/scheduler/self_destruct_scheduler.rb index d0b6ce8a07..b985b7a3ba 100644 --- 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 - include Sidekiq::Worker +class Scheduler::SelfDestructScheduler < ApplicationWorker include SelfDestructHelper MAX_ENQUEUED = 10_000 diff --git a/app/workers/scheduler/software_update_check_scheduler.rb b/app/workers/scheduler/software_update_check_scheduler.rb index c732bdedc0..250d4201a3 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::SoftwareUpdateCheckScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.hour.to_i def perform diff --git a/app/workers/scheduler/suspended_user_cleanup_scheduler.rb b/app/workers/scheduler/suspended_user_cleanup_scheduler.rb index 4ea81c785b..0db89e48bc 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::SuspendedUserCleanupScheduler < ApplicationWorker # 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. diff --git a/app/workers/scheduler/trends/refresh_scheduler.rb b/app/workers/scheduler/trends/refresh_scheduler.rb index 85c000deea..01790d697a 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::Trends::RefreshScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 30.minutes.to_i def perform diff --git a/app/workers/scheduler/trends/review_notifications_scheduler.rb b/app/workers/scheduler/trends/review_notifications_scheduler.rb index f334261bd7..5c9f423eb7 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::Trends::ReviewNotificationsScheduler < ApplicationWorker sidekiq_options retry: 0 def perform diff --git a/app/workers/scheduler/user_cleanup_scheduler.rb b/app/workers/scheduler/user_cleanup_scheduler.rb index 2d2efc731a..773a30f5ac 100644 --- a/app/workers/scheduler/user_cleanup_scheduler.rb +++ b/app/workers/scheduler/user_cleanup_scheduler.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class Scheduler::UserCleanupScheduler - include Sidekiq::Worker - +class Scheduler::UserCleanupScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i def perform diff --git a/app/workers/scheduler/vacuum_scheduler.rb b/app/workers/scheduler/vacuum_scheduler.rb index 1c9a2aabe3..1c5e0b6ea0 100644 --- 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 - include Sidekiq::Worker - +class Scheduler::VacuumScheduler < ApplicationWorker sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i def perform diff --git a/app/workers/tag_unmerge_worker.rb b/app/workers/tag_unmerge_worker.rb index 1c2a6d1e76..809aed1156 100644 --- a/app/workers/tag_unmerge_worker.rb +++ b/app/workers/tag_unmerge_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class TagUnmergeWorker - include Sidekiq::Worker +class TagUnmergeWorker < ApplicationWorker include DatabaseHelper sidekiq_options queue: 'pull' diff --git a/app/workers/thread_resolve_worker.rb b/app/workers/thread_resolve_worker.rb index d4cefb3fdc..79b12e453b 100644 --- a/app/workers/thread_resolve_worker.rb +++ b/app/workers/thread_resolve_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class ThreadResolveWorker - include Sidekiq::Worker +class ThreadResolveWorker < ApplicationWorker include ExponentialBackoff sidekiq_options queue: 'pull', retry: 3 diff --git a/app/workers/trigger_webhook_worker.rb b/app/workers/trigger_webhook_worker.rb index 2ffb6246f1..262e60a67f 100644 --- a/app/workers/trigger_webhook_worker.rb +++ b/app/workers/trigger_webhook_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class TriggerWebhookWorker - include Sidekiq::Worker - +class TriggerWebhookWorker < ApplicationWorker def perform(event, class_name, id) object = class_name.constantize.find(id) WebhookService.new.call(event, object) diff --git a/app/workers/unfavourite_worker.rb b/app/workers/unfavourite_worker.rb index cce07e486c..62fdad3c0f 100644 --- a/app/workers/unfavourite_worker.rb +++ b/app/workers/unfavourite_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class UnfavouriteWorker - include Sidekiq::Worker - +class UnfavouriteWorker < ApplicationWorker def perform(account_id, status_id) UnfavouriteService.new.call(Account.find(account_id), Status.find(status_id)) rescue ActiveRecord::RecordNotFound diff --git a/app/workers/unfilter_notifications_worker.rb b/app/workers/unfilter_notifications_worker.rb index 223654aa16..3f05e2d84e 100644 --- a/app/workers/unfilter_notifications_worker.rb +++ b/app/workers/unfilter_notifications_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class UnfilterNotificationsWorker - include Sidekiq::Worker - +class UnfilterNotificationsWorker < ApplicationWorker def perform(notification_request_id) @notification_request = NotificationRequest.find(notification_request_id) diff --git a/app/workers/unfollow_follow_worker.rb b/app/workers/unfollow_follow_worker.rb index a4d57839de..b82b7c6c90 100644 --- a/app/workers/unfollow_follow_worker.rb +++ b/app/workers/unfollow_follow_worker.rb @@ -1,8 +1,6 @@ # frozen_string_literal: true -class UnfollowFollowWorker - include Sidekiq::Worker - +class UnfollowFollowWorker < ApplicationWorker sidekiq_options queue: 'pull' def perform(follower_account_id, old_target_account_id, new_target_account_id, bypass_locked = false) diff --git a/app/workers/unmerge_worker.rb b/app/workers/unmerge_worker.rb index e8ac535dfe..a7d1d34a09 100644 --- a/app/workers/unmerge_worker.rb +++ b/app/workers/unmerge_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class UnmergeWorker - include Sidekiq::Worker +class UnmergeWorker < ApplicationWorker include DatabaseHelper sidekiq_options queue: 'pull' diff --git a/app/workers/unpublish_announcement_worker.rb b/app/workers/unpublish_announcement_worker.rb index e58c07554a..288ce446b4 100644 --- a/app/workers/unpublish_announcement_worker.rb +++ b/app/workers/unpublish_announcement_worker.rb @@ -1,7 +1,6 @@ # frozen_string_literal: true -class UnpublishAnnouncementWorker - include Sidekiq::Worker +class UnpublishAnnouncementWorker < ApplicationWorker include Redisable def perform(announcement_id) diff --git a/app/workers/verify_account_links_worker.rb b/app/workers/verify_account_links_worker.rb index ad27f450b7..985c6433fd 100644 --- 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 - include Sidekiq::Worker - +class VerifyAccountLinksWorker < ApplicationWorker sidekiq_options queue: 'default', retry: false, lock: :until_executed, lock_ttl: 1.hour.to_i def perform(account_id) diff --git a/app/workers/web/push_notification_worker.rb b/app/workers/web/push_notification_worker.rb index 7e9691aaba..f1d1d1d81d 100644 --- 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 - include Sidekiq::Worker - +class Web::PushNotificationWorker < ApplicationWorker sidekiq_options queue: 'push', retry: 5 TTL = 48.hours.to_s diff --git a/app/workers/webhooks/delivery_worker.rb b/app/workers/webhooks/delivery_worker.rb index 3bbc8e2255..254b486726 100644 --- 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 - include Sidekiq::Worker +class Webhooks::DeliveryWorker < ApplicationWorker include JsonLdHelper sidekiq_options queue: 'push', retry: 16, dead: false