zelo72
/
mastodon
mirror of https://github.com/mastodon/mastodon
2
2
Fork 1
Code Issues 9 Releases Wiki Activity

Add `ApplicationWorker` base class for workers

This commit is contained in:
Matt Jankowski 2024-03-25 11:44:39 -04:00
parent d9eee9bf9a
commit a0bcfa0f64
86 changed files with 94 additions and 225 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/workers/account_deletion_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i
def perform(account_id, options = {}) def perform(account_id, options = {})

4
app/workers/account_merging_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class AccountMergingWorker class AccountMergingWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'
def perform(account_id) def perform(account_id)

4
app/workers/account_refresh_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'pull', retry: 3, dead: false, lock: :until_executed, lock_ttl: 1.day.to_i
def perform(account_id) def perform(account_id)

3
app/workers/activitypub/delivery_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::DeliveryWorker class ActivityPub::DeliveryWorker < ApplicationWorker
include Sidekiq::Worker
include RoutingHelper include RoutingHelper
include JsonLdHelper include JsonLdHelper

3
app/workers/activitypub/distribute_poll_update_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::DistributePollUpdateWorker class ActivityPub::DistributePollUpdateWorker < ApplicationWorker
include Sidekiq::Worker
include Payloadable include Payloadable
sidekiq_options queue: 'push', lock: :until_executed, retry: 0 sidekiq_options queue: 'push', lock: :until_executed, retry: 0

3
app/workers/activitypub/fetch_replies_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::FetchRepliesWorker class ActivityPub::FetchRepliesWorker < ApplicationWorker
include Sidekiq::Worker
include ExponentialBackoff include ExponentialBackoff
sidekiq_options queue: 'pull', retry: 3 sidekiq_options queue: 'pull', retry: 3

4
app/workers/activitypub/followers_synchronization_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::FollowersSynchronizationWorker class ActivityPub::FollowersSynchronizationWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'push', lock: :until_executed sidekiq_options queue: 'push', lock: :until_executed
def perform(account_id, url) def perform(account_id, url)

3
app/workers/activitypub/move_distribution_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::MoveDistributionWorker class ActivityPub::MoveDistributionWorker < ApplicationWorker
include Sidekiq::Worker
include Payloadable include Payloadable
sidekiq_options queue: 'push' sidekiq_options queue: 'push'

4
app/workers/activitypub/post_upgrade_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::PostUpgradeWorker class ActivityPub::PostUpgradeWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'
def perform(domain) def perform(domain)

4
app/workers/activitypub/processing_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::ProcessingWorker class ActivityPub::ProcessingWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'ingress', backtrace: true, retry: 8 sidekiq_options queue: 'ingress', backtrace: true, retry: 8
def perform(actor_id, body, delivered_to_account_id = nil, actor_type = 'Account') def perform(actor_id, body, delivered_to_account_id = nil, actor_type = 'Account')

3
app/workers/activitypub/raw_distribution_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::RawDistributionWorker class ActivityPub::RawDistributionWorker < ApplicationWorker
include Sidekiq::Worker
include Payloadable include Payloadable
sidekiq_options queue: 'push' sidekiq_options queue: 'push'

4
app/workers/activitypub/synchronize_featured_collection_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i
def perform(account_id, options = {}) def perform(account_id, options = {})

4
app/workers/activitypub/synchronize_featured_tags_collection_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i
def perform(account_id, url) def perform(account_id, url)

3
app/workers/add_to_public_statuses_index_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class AddToPublicStatusesIndexWorker class AddToPublicStatusesIndexWorker < ApplicationWorker
include Sidekiq::Worker
include DatabaseHelper include DatabaseHelper
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'

4
app/workers/admin/account_deletion_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i
def perform(account_id) def perform(account_id)

4
app/workers/admin/domain_purge_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.week.to_i
def perform(domain) def perform(domain)

4
app/workers/admin/suspension_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Admin::SuspensionWorker class Admin::SuspensionWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'
def perform(account_id) def perform(account_id)

4
app/workers/admin/unsuspension_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Admin::UnsuspensionWorker class Admin::UnsuspensionWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'
def perform(account_id) def perform(account_id)

4
app/workers/after_account_domain_block_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class AfterAccountDomainBlockWorker class AfterAccountDomainBlockWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id, domain) def perform(account_id, domain)
AfterBlockDomainFromAccountService.new.call(Account.find(account_id), domain) AfterBlockDomainFromAccountService.new.call(Account.find(account_id), domain)
rescue ActiveRecord::RecordNotFound rescue ActiveRecord::RecordNotFound

4
app/workers/after_unallow_domain_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class AfterUnallowDomainWorker class AfterUnallowDomainWorker < ApplicationWorker
include Sidekiq::Worker
def perform(domain) def perform(domain)
AfterUnallowDomainService.new.call(domain) AfterUnallowDomainService.new.call(domain)
end end

9
app/workers/application_worker.rb Normal file
View File

@ -0,0 +1,9 @@
# frozen_string_literal: true
class ApplicationWorker
include Sidekiq::Worker
def perform(*)
raise NotImplementedError
end
end

4
app/workers/authorize_follow_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class AuthorizeFollowWorker class AuthorizeFollowWorker < ApplicationWorker
include Sidekiq::Worker
def perform(source_account_id, target_account_id) def perform(source_account_id, target_account_id)
source_account = Account.find(source_account_id) source_account = Account.find(source_account_id)
target_account = Account.find(target_account_id) target_account = Account.find(target_account_id)

4
app/workers/backup_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class BackupWorker class BackupWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull', backtrace: true, retry: 5, dead: false sidekiq_options queue: 'pull', backtrace: true, retry: 5, dead: false
sidekiq_retries_exhausted do |msg| sidekiq_retries_exhausted do |msg|

4
app/workers/block_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class BlockWorker class BlockWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id, target_account_id) def perform(account_id, target_account_id)
AfterBlockService.new.call( AfterBlockService.new.call(
Account.find(account_id), Account.find(account_id),

4
app/workers/bootstrap_timeline_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class BootstrapTimelineWorker class BootstrapTimelineWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id) def perform(account_id)
BootstrapTimelineService.new.call(Account.find(account_id)) BootstrapTimelineService.new.call(Account.find(account_id))
end end

4
app/workers/bulk_import_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class BulkImportWorker class BulkImportWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull', retry: false sidekiq_options queue: 'pull', retry: false
def perform(import_id) def perform(import_id)

3
app/workers/cache_buster_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class CacheBusterWorker class CacheBusterWorker < ApplicationWorker
include Sidekiq::Worker
include RoutingHelper include RoutingHelper
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'

4
app/workers/delete_mute_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class DeleteMuteWorker class DeleteMuteWorker < ApplicationWorker
include Sidekiq::Worker
def perform(mute_id) def perform(mute_id)
mute = Mute.find_by(id: mute_id) mute = Mute.find_by(id: mute_id)
UnmuteService.new.call(mute.account, mute.target_account) if mute&.expired? UnmuteService.new.call(mute.account, mute.target_account) if mute&.expired?

3
app/workers/distribution_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class DistributionWorker class DistributionWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
include Lockable include Lockable

4
app/workers/domain_block_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class DomainBlockWorker class DomainBlockWorker < ApplicationWorker
include Sidekiq::Worker
def perform(domain_block_id, update = false) def perform(domain_block_id, update = false)
domain_block = DomainBlock.find_by(id: domain_block_id) domain_block = DomainBlock.find_by(id: domain_block_id)
return true if domain_block.nil? return true if domain_block.nil?

4
app/workers/domain_clear_media_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class DomainClearMediaWorker class DomainClearMediaWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'
def perform(domain_block_id) def perform(domain_block_id)

3
app/workers/feed_insert_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class FeedInsertWorker class FeedInsertWorker < ApplicationWorker
include Sidekiq::Worker
include DatabaseHelper include DatabaseHelper
def perform(status_id, id, type = 'home', options = {}) def perform(status_id, id, type = 'home', options = {})

3
app/workers/fetch_reply_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class FetchReplyWorker class FetchReplyWorker < ApplicationWorker
include Sidekiq::Worker
include ExponentialBackoff include ExponentialBackoff
sidekiq_options queue: 'pull', retry: 3 sidekiq_options queue: 'pull', retry: 3

4
app/workers/generate_annual_report_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class GenerateAnnualReportWorker class GenerateAnnualReportWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id, year) def perform(account_id, year)
AnnualReport.new(Account.find(account_id), year).generate AnnualReport.new(Account.find(account_id), year).generate
rescue ActiveRecord::RecordNotFound, ActiveRecord::RecordNotUnique rescue ActiveRecord::RecordNotFound, ActiveRecord::RecordNotUnique

4
app/workers/import/relationship_worker.rb
View File

@ -3,9 +3,7 @@
# NOTE: This is a deprecated worker, only kept to not break ongoing imports # NOTE: This is a deprecated worker, only kept to not break ongoing imports
# on upgrade. See `Import::RowWorker` for its replacement. # 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 sidekiq_options queue: 'pull', retry: 8, dead: false
def perform(account_id, target_account_uri, relationship, options) def perform(account_id, target_account_uri, relationship, options)

4
app/workers/import/row_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Import::RowWorker class Import::RowWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull', retry: 6, dead: false sidekiq_options queue: 'pull', retry: 6, dead: false
sidekiq_retries_exhausted do |msg, _exception| sidekiq_retries_exhausted do |msg, _exception|

4
app/workers/import_worker.rb
View File

@ -3,9 +3,7 @@
# NOTE: This is a deprecated worker, only kept to not break ongoing imports # NOTE: This is a deprecated worker, only kept to not break ongoing imports
# on upgrade. See `ImportWorker` for its replacement. # on upgrade. See `ImportWorker` for its replacement.
class ImportWorker class ImportWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull', retry: false sidekiq_options queue: 'pull', retry: false
def perform(import_id) def perform(import_id)

4
app/workers/link_crawl_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class LinkCrawlWorker class LinkCrawlWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull', retry: 0 sidekiq_options queue: 'pull', retry: 0
def perform(status_id) def perform(status_id)

4
app/workers/local_notification_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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) def perform(receiver_account_id, activity_id = nil, activity_class_name = nil, type = nil)
if activity_id.nil? && activity_class_name.nil? if activity_id.nil? && activity_class_name.nil?
activity = Mention.find(receiver_account_id) activity = Mention.find(receiver_account_id)

3
app/workers/merge_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class MergeWorker class MergeWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
include DatabaseHelper include DatabaseHelper

4
app/workers/move_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class MoveWorker class MoveWorker < ApplicationWorker
include Sidekiq::Worker
def perform(source_account_id, target_account_id) def perform(source_account_id, target_account_id)
@source_account = Account.find(source_account_id) @source_account = Account.find(source_account_id)
@target_account = Account.find(target_account_id) @target_account = Account.find(target_account_id)

4
app/workers/mute_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class MuteWorker class MuteWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id, target_account_id) def perform(account_id, target_account_id)
FeedManager.instance.clear_from_home(Account.find(account_id), Account.find(target_account_id)) FeedManager.instance.clear_from_home(Account.find(account_id), Account.find(target_account_id))
rescue ActiveRecord::RecordNotFound rescue ActiveRecord::RecordNotFound

4
app/workers/poll_expiration_notify_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PollExpirationNotifyWorker class PollExpirationNotifyWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options lock: :until_executing sidekiq_options lock: :until_executing
def perform(poll_id) def perform(poll_id)

4
app/workers/post_process_media_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PostProcessMediaWorker class PostProcessMediaWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options retry: 1, dead: false sidekiq_options retry: 1, dead: false
sidekiq_retries_exhausted do |msg| sidekiq_retries_exhausted do |msg|

3
app/workers/publish_announcement_reaction_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PublishAnnouncementReactionWorker class PublishAnnouncementReactionWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
def perform(announcement_id, name) def perform(announcement_id, name)

3
app/workers/publish_scheduled_announcement_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PublishScheduledAnnouncementWorker class PublishScheduledAnnouncementWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
def perform(announcement_id) def perform(announcement_id)

4
app/workers/publish_scheduled_status_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PublishScheduledStatusWorker class PublishScheduledStatusWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options lock: :until_executed, lock_ttl: 1.hour.to_i sidekiq_options lock: :until_executed, lock_ttl: 1.hour.to_i
def perform(scheduled_status_id) def perform(scheduled_status_id)

3
app/workers/push_conversation_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PushConversationWorker class PushConversationWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
def perform(conversation_account_id) def perform(conversation_account_id)

3
app/workers/push_encrypted_message_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PushEncryptedMessageWorker class PushEncryptedMessageWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
def perform(encrypted_message_id) def perform(encrypted_message_id)

3
app/workers/push_update_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class PushUpdateWorker class PushUpdateWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
def perform(account_id, status_id, timeline_id = nil, options = {}) def perform(account_id, status_id, timeline_id = nil, options = {})

3
app/workers/redownload_avatar_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RedownloadAvatarWorker class RedownloadAvatarWorker < ApplicationWorker
include Sidekiq::Worker
include ExponentialBackoff include ExponentialBackoff
include JsonLdHelper include JsonLdHelper

3
app/workers/redownload_header_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RedownloadHeaderWorker class RedownloadHeaderWorker < ApplicationWorker
include Sidekiq::Worker
include ExponentialBackoff include ExponentialBackoff
include JsonLdHelper include JsonLdHelper

3
app/workers/redownload_media_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RedownloadMediaWorker class RedownloadMediaWorker < ApplicationWorker
include Sidekiq::Worker
include ExponentialBackoff include ExponentialBackoff
include JsonLdHelper include JsonLdHelper

4
app/workers/refollow_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RefollowWorker class RefollowWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull', retry: false sidekiq_options queue: 'pull', retry: false
def perform(target_account_id) def perform(target_account_id)

3
app/workers/regeneration_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RegenerationWorker class RegenerationWorker < ApplicationWorker
include Sidekiq::Worker
include DatabaseHelper include DatabaseHelper
sidekiq_options lock: :until_executed sidekiq_options lock: :until_executed

3
app/workers/remote_account_refresh_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RemoteAccountRefreshWorker class RemoteAccountRefreshWorker < ApplicationWorker
include Sidekiq::Worker
include ExponentialBackoff include ExponentialBackoff
include JsonLdHelper include JsonLdHelper

4
app/workers/removal_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RemovalWorker class RemovalWorker < ApplicationWorker
include Sidekiq::Worker
def perform(status_id, options = {}) def perform(status_id, options = {})
RemoveStatusService.new.call(Status.with_discarded.find(status_id), **options.symbolize_keys) RemoveStatusService.new.call(Status.with_discarded.find(status_id), **options.symbolize_keys)
rescue ActiveRecord::RecordNotFound rescue ActiveRecord::RecordNotFound

4
app/workers/remove_featured_tag_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RemoveFeaturedTagWorker class RemoveFeaturedTagWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id, featured_tag_id) def perform(account_id, featured_tag_id)
RemoveFeaturedTagService.new.call(Account.find(account_id), FeaturedTag.find(featured_tag_id)) RemoveFeaturedTagService.new.call(Account.find(account_id), FeaturedTag.find(featured_tag_id))
rescue ActiveRecord::RecordNotFound rescue ActiveRecord::RecordNotFound

4
app/workers/remove_from_public_statuses_index_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class RemoveFromPublicStatusesIndexWorker class RemoveFromPublicStatusesIndexWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id) def perform(account_id)
account = Account.find(account_id) account = Account.find(account_id)

4
app/workers/resolve_account_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'pull', lock: :until_executed, lock_ttl: 1.day.to_i
def perform(uri) def perform(uri)

3
app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Scheduler::AccountsStatusesCleanupScheduler class Scheduler::AccountsStatusesCleanupScheduler < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
# This limit is mostly to be nice to the fediverse at large and not # This limit is mostly to be nice to the fediverse at large and not

3
app/workers/scheduler/auto_close_registrations_scheduler.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Scheduler::AutoCloseRegistrationsScheduler class Scheduler::AutoCloseRegistrationsScheduler < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
sidekiq_options retry: 0 sidekiq_options retry: 0

4
app/workers/scheduler/follow_recommendations_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
def perform def perform

3
app/workers/scheduler/indexing_scheduler.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Scheduler::IndexingScheduler class Scheduler::IndexingScheduler < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
include DatabaseHelper include DatabaseHelper

4
app/workers/scheduler/instance_refresh_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
def perform def perform

4
app/workers/scheduler/ip_cleanup_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 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 SESSION_RETENTION_PERIOD = ENV.fetch('SESSION_RETENTION_PERIOD', 1.year).to_i.seconds.freeze

4
app/workers/scheduler/pghero_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
def perform def perform

4
app/workers/scheduler/scheduled_statuses_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.hour.to_i
def perform def perform

3
app/workers/scheduler/self_destruct_scheduler.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Scheduler::SelfDestructScheduler class Scheduler::SelfDestructScheduler < ApplicationWorker
include Sidekiq::Worker
include SelfDestructHelper include SelfDestructHelper
MAX_ENQUEUED = 10_000 MAX_ENQUEUED = 10_000

4
app/workers/scheduler/software_update_check_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.hour.to_i
def perform def perform

4
app/workers/scheduler/suspended_user_cleanup_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Scheduler::SuspendedUserCleanupScheduler class Scheduler::SuspendedUserCleanupScheduler < ApplicationWorker
include Sidekiq::Worker
# Each processed deletion request may enqueue an enormous # Each processed deletion request may enqueue an enormous
# amount of jobs in the `pull` queue, so only enqueue when # amount of jobs in the `pull` queue, so only enqueue when
# the queue is empty or close to being so. # the queue is empty or close to being so.

4
app/workers/scheduler/trends/refresh_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 30.minutes.to_i
def perform def perform

4
app/workers/scheduler/trends/review_notifications_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Scheduler::Trends::ReviewNotificationsScheduler class Scheduler::Trends::ReviewNotificationsScheduler < ApplicationWorker
include Sidekiq::Worker
sidekiq_options retry: 0 sidekiq_options retry: 0
def perform def perform

4
app/workers/scheduler/user_cleanup_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Scheduler::UserCleanupScheduler class Scheduler::UserCleanupScheduler < ApplicationWorker
include Sidekiq::Worker
sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
def perform def perform

4
app/workers/scheduler/vacuum_scheduler.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
def perform def perform

3
app/workers/tag_unmerge_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class TagUnmergeWorker class TagUnmergeWorker < ApplicationWorker
include Sidekiq::Worker
include DatabaseHelper include DatabaseHelper
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'

3
app/workers/thread_resolve_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class ThreadResolveWorker class ThreadResolveWorker < ApplicationWorker
include Sidekiq::Worker
include ExponentialBackoff include ExponentialBackoff
sidekiq_options queue: 'pull', retry: 3 sidekiq_options queue: 'pull', retry: 3

4
app/workers/trigger_webhook_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class TriggerWebhookWorker class TriggerWebhookWorker < ApplicationWorker
include Sidekiq::Worker
def perform(event, class_name, id) def perform(event, class_name, id)
object = class_name.constantize.find(id) object = class_name.constantize.find(id)
WebhookService.new.call(event, object) WebhookService.new.call(event, object)

4
app/workers/unfavourite_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class UnfavouriteWorker class UnfavouriteWorker < ApplicationWorker
include Sidekiq::Worker
def perform(account_id, status_id) def perform(account_id, status_id)
UnfavouriteService.new.call(Account.find(account_id), Status.find(status_id)) UnfavouriteService.new.call(Account.find(account_id), Status.find(status_id))
rescue ActiveRecord::RecordNotFound rescue ActiveRecord::RecordNotFound

4
app/workers/unfilter_notifications_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class UnfilterNotificationsWorker class UnfilterNotificationsWorker < ApplicationWorker
include Sidekiq::Worker
def perform(notification_request_id) def perform(notification_request_id)
@notification_request = NotificationRequest.find(notification_request_id) @notification_request = NotificationRequest.find(notification_request_id)

4
app/workers/unfollow_follow_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class UnfollowFollowWorker class UnfollowFollowWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'
def perform(follower_account_id, old_target_account_id, new_target_account_id, bypass_locked = false) def perform(follower_account_id, old_target_account_id, new_target_account_id, bypass_locked = false)

3
app/workers/unmerge_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class UnmergeWorker class UnmergeWorker < ApplicationWorker
include Sidekiq::Worker
include DatabaseHelper include DatabaseHelper
sidekiq_options queue: 'pull' sidekiq_options queue: 'pull'

3
app/workers/unpublish_announcement_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class UnpublishAnnouncementWorker class UnpublishAnnouncementWorker < ApplicationWorker
include Sidekiq::Worker
include Redisable include Redisable
def perform(announcement_id) def perform(announcement_id)

4
app/workers/verify_account_links_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # 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 sidekiq_options queue: 'default', retry: false, lock: :until_executed, lock_ttl: 1.hour.to_i
def perform(account_id) def perform(account_id)

4
app/workers/web/push_notification_worker.rb
View File

@ -1,8 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Web::PushNotificationWorker class Web::PushNotificationWorker < ApplicationWorker
include Sidekiq::Worker
sidekiq_options queue: 'push', retry: 5 sidekiq_options queue: 'push', retry: 5
TTL = 48.hours.to_s TTL = 48.hours.to_s

3
app/workers/webhooks/delivery_worker.rb
View File

@ -1,7 +1,6 @@
# frozen_string_literal: true # frozen_string_literal: true
class Webhooks::DeliveryWorker class Webhooks::DeliveryWorker < ApplicationWorker
include Sidekiq::Worker
include JsonLdHelper include JsonLdHelper
sidekiq_options queue: 'push', retry: 16, dead: false sidekiq_options queue: 'push', retry: 16, dead: false