mirror of
https://github.com/discourse/discourse.git
synced 2025-04-19 16:59:04 +08:00

- fetch models inside services - validate `user_id` in contracts - use policy objects - extract more logic to actions - write specs for services and action
52 lines
1.2 KiB
Ruby
52 lines
1.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module Action
|
|
module User
|
|
class SilenceAll
|
|
attr_reader :users, :actor, :contract
|
|
|
|
delegate :message, :post_id, :silenced_till, :reason, to: :contract, private: true
|
|
|
|
def initialize(users:, actor:, contract:)
|
|
@users, @actor, @contract = users, actor, contract
|
|
end
|
|
|
|
def self.call(...)
|
|
new(...).call
|
|
end
|
|
|
|
def call
|
|
silenced_users.first.try(:user_history).try(:details)
|
|
end
|
|
|
|
private
|
|
|
|
def silenced_users
|
|
users.map do |user|
|
|
UserSilencer
|
|
.new(
|
|
user,
|
|
actor,
|
|
message_body: message,
|
|
keep_posts: true,
|
|
silenced_till:,
|
|
reason:,
|
|
post_id:,
|
|
)
|
|
.tap do |silencer|
|
|
next unless silencer.silence
|
|
Jobs.enqueue(
|
|
:critical_user_email,
|
|
type: "account_silenced",
|
|
user_id: user.id,
|
|
user_history_id: silencer.user_history.id,
|
|
)
|
|
end
|
|
rescue => err
|
|
Discourse.warn_exception(err, message: "failed to silence user with ID #{user.id}")
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|