mirror of
https://github.com/discourse/discourse.git
synced 2025-02-25 18:55:32 -06:00
5fec841c19
We were incorrectly generating URLs with message id even when it was not provided, resulting in a route ending with "undefined", which was causing an error. This commit also uses this opportunity to: - move `invite_users` into a proper controller inside the API namespace - refactors the code into a service: `Chat::InviteUsersToChannel`
89 lines
2.5 KiB
Ruby
89 lines
2.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module Chat
|
|
# Creates a thread.
|
|
#
|
|
# @example
|
|
# Chat::CreateThread.call(channel_id: 2, original_message_id: 3, guardian: guardian, title: "Restaurant for Saturday")
|
|
#
|
|
class CreateThread
|
|
include Service::Base
|
|
|
|
# @!method call(thread_id:, channel_id:, guardian:, **params_to_create)
|
|
# @param [Integer] original_message_id
|
|
# @param [Integer] channel_id
|
|
# @param [Guardian] guardian
|
|
# @option params_to_create [String,nil] title
|
|
# @return [Service::Base::Context]
|
|
|
|
contract
|
|
model :channel
|
|
policy :can_view_channel
|
|
policy :threading_enabled_for_channel
|
|
model :original_message
|
|
transaction do
|
|
step :find_or_create_thread
|
|
step :associate_thread_to_message
|
|
step :fetch_membership
|
|
step :publish_new_thread
|
|
end
|
|
|
|
# @!visibility private
|
|
class Contract
|
|
attribute :original_message_id, :integer
|
|
attribute :channel_id, :integer
|
|
attribute :title, :string
|
|
|
|
validates :original_message_id, :channel_id, presence: true
|
|
validates :title, length: { maximum: Chat::Thread::MAX_TITLE_LENGTH }
|
|
end
|
|
|
|
private
|
|
|
|
def fetch_channel(contract:, **)
|
|
::Chat::Channel.find_by(id: contract.channel_id)
|
|
end
|
|
|
|
def fetch_original_message(channel:, contract:, **)
|
|
::Chat::Message.find_by(
|
|
id: contract.original_message_id,
|
|
chat_channel_id: contract.channel_id,
|
|
)
|
|
end
|
|
|
|
def can_view_channel(guardian:, channel:, **)
|
|
guardian.can_preview_chat_channel?(channel)
|
|
end
|
|
|
|
def threading_enabled_for_channel(channel:, **)
|
|
channel.threading_enabled
|
|
end
|
|
|
|
def find_or_create_thread(channel:, original_message:, contract:, **)
|
|
if original_message.thread_id.present?
|
|
return context.thread = ::Chat::Thread.find_by(id: original_message.thread_id)
|
|
end
|
|
|
|
context.thread =
|
|
channel.threads.create(
|
|
title: contract.title,
|
|
original_message: original_message,
|
|
original_message_user: original_message.user,
|
|
)
|
|
fail!(context.thread.errors.full_messages.join(", ")) if context.thread.invalid?
|
|
end
|
|
|
|
def associate_thread_to_message(original_message:, **)
|
|
original_message.update(thread: context.thread)
|
|
end
|
|
|
|
def fetch_membership(guardian:, **)
|
|
context.membership = context.thread.membership_for(guardian.user)
|
|
end
|
|
|
|
def publish_new_thread(channel:, original_message:, **)
|
|
::Chat::Publisher.publish_thread_created!(channel, original_message, context.thread.id)
|
|
end
|
|
end
|
|
end
|