mirror of
https://github.com/discourse/discourse.git
synced 2024-11-28 07:33:40 +08:00
227873df78
once enable_mailing_list_mode is enabled any user can elect to get every post via email unless they opt out of category or topic
133 lines
3.4 KiB
Ruby
133 lines
3.4 KiB
Ruby
class TopicCreator
|
|
|
|
attr_accessor :errors
|
|
|
|
def self.create(user, guardian, opts)
|
|
self.new(user, guardian, opts).create
|
|
end
|
|
|
|
def initialize(user, guardian, opts)
|
|
@user = user
|
|
@guardian = guardian
|
|
@opts = opts
|
|
end
|
|
|
|
def create
|
|
@topic = Topic.new(setup_topic_params)
|
|
|
|
setup_auto_close_time
|
|
process_private_message
|
|
save_topic
|
|
watch_topic
|
|
auto_mute_topic
|
|
|
|
@topic
|
|
end
|
|
|
|
private
|
|
|
|
def auto_mute_topic
|
|
CategoryUser.auto_mute_new_topic(@topic)
|
|
end
|
|
|
|
def watch_topic
|
|
unless @opts[:auto_track] == false
|
|
@topic.notifier.watch_topic!(@topic.user_id)
|
|
end
|
|
|
|
@topic.topic_allowed_users.pluck(:user_id).reject{|id| id == @topic.user_id}.each do |id|
|
|
@topic.notifier.watch_topic!(id, nil)
|
|
end
|
|
|
|
CategoryUser.auto_watch_new_topic(@topic)
|
|
end
|
|
|
|
def setup_topic_params
|
|
topic_params = {
|
|
title: @opts[:title],
|
|
user_id: @user.id,
|
|
last_post_user_id: @user.id
|
|
}
|
|
|
|
[:subtype, :archetype, :meta_data].each do |key|
|
|
topic_params[key] = @opts[key] if @opts[key].present?
|
|
end
|
|
|
|
category = find_category
|
|
|
|
@guardian.ensure_can_create!(Topic,category)
|
|
|
|
topic_params[:category_id] = category.id if category.present?
|
|
|
|
topic_params[:created_at] = Time.zone.parse(@opts[:created_at].to_s) if @opts[:created_at].present?
|
|
|
|
topic_params
|
|
end
|
|
|
|
def find_category
|
|
# PM can't have a category
|
|
@opts.delete(:category) if @opts[:archetype].present? && @opts[:archetype] == Archetype.private_message
|
|
|
|
# Temporary fix to allow older clients to create topics.
|
|
# When all clients are updated the category variable should
|
|
# be set directly to the contents of the if statement.
|
|
if (@opts[:category].is_a? Integer) || (@opts[:category] =~ /^\d+$/)
|
|
Category.where(id: @opts[:category]).first
|
|
else
|
|
Category.where(name: @opts[:category]).first
|
|
end
|
|
end
|
|
|
|
def setup_auto_close_time
|
|
return unless @opts[:auto_close_time].present?
|
|
return unless @guardian.can_moderate?(@topic)
|
|
@topic.set_auto_close(@opts[:auto_close_time], @user)
|
|
end
|
|
|
|
def process_private_message
|
|
return unless @opts[:archetype] == Archetype.private_message
|
|
@topic.subtype = TopicSubtype.user_to_user unless @topic.subtype
|
|
|
|
unless @opts[:target_usernames].present? || @opts[:target_group_names].present?
|
|
@topic.errors.add(:archetype, :cant_send_pm)
|
|
@errors = @topic.errors
|
|
raise ActiveRecord::Rollback.new
|
|
end
|
|
|
|
add_users(@topic,@opts[:target_usernames])
|
|
add_groups(@topic,@opts[:target_group_names])
|
|
@topic.topic_allowed_users.build(user_id: @user.id)
|
|
end
|
|
|
|
def save_topic
|
|
unless @topic.save(validate: !@opts[:skip_validations])
|
|
@errors = @topic.errors
|
|
raise ActiveRecord::Rollback.new
|
|
end
|
|
end
|
|
|
|
def add_users(topic, usernames)
|
|
return unless usernames
|
|
User.where(username: usernames.split(',')).each do |user|
|
|
check_can_send_permission!(topic,user)
|
|
topic.topic_allowed_users.build(user_id: user.id)
|
|
end
|
|
end
|
|
|
|
def add_groups(topic, groups)
|
|
return unless groups
|
|
Group.where(name: groups.split(',')).each do |group|
|
|
check_can_send_permission!(topic,group)
|
|
topic.topic_allowed_groups.build(group_id: group.id)
|
|
end
|
|
end
|
|
|
|
def check_can_send_permission!(topic,item)
|
|
unless @guardian.can_send_private_message?(item)
|
|
topic.errors.add(:archetype, :cant_send_pm)
|
|
@errors = topic.errors
|
|
raise ActiveRecord::Rollback.new
|
|
end
|
|
end
|
|
end
|