mirror of
https://github.com/discourse/discourse.git
synced 2025-01-02 07:33:50 +08:00
7a9514922b
* Moved the settings cog from thread list to thread and put it in a new header component * Remove thread original message component, no longer needed and the list item and thread indicator styles/content will be quite different * Start adding content (unread indicator etc.) to the thread list item and changing structure to be more like designs * Serialize the last thread reply when opening the thread index, show in list and update with message bus
96 lines
2.8 KiB
Ruby
96 lines
2.8 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module Chat
|
|
# Gets a list of threads for a channel to be shown in an index.
|
|
# In future pagination and filtering will be added -- for now
|
|
# we just want to return N threads ordered by the latest
|
|
# message that the user has sent in a thread.
|
|
#
|
|
# @example
|
|
# Chat::LookupChannelThreads.call(channel_id: 2, guardian: guardian)
|
|
#
|
|
class LookupChannelThreads
|
|
include Service::Base
|
|
|
|
# @!method call(channel_id:, guardian:)
|
|
# @param [Integer] channel_id
|
|
# @param [Guardian] guardian
|
|
# @return [Service::Base::Context]
|
|
|
|
policy :threaded_discussions_enabled
|
|
contract
|
|
model :channel
|
|
policy :threading_enabled_for_channel
|
|
policy :can_view_channel
|
|
model :threads
|
|
step :fetch_tracking
|
|
step :fetch_memberships
|
|
|
|
# @!visibility private
|
|
class Contract
|
|
attribute :channel_id, :integer
|
|
validates :channel_id, presence: true
|
|
end
|
|
|
|
private
|
|
|
|
def threaded_discussions_enabled
|
|
SiteSetting.enable_experimental_chat_threaded_discussions
|
|
end
|
|
|
|
def fetch_channel(contract:, **)
|
|
Chat::Channel.find_by(id: contract.channel_id)
|
|
end
|
|
|
|
def threading_enabled_for_channel(channel:, **)
|
|
channel.threading_enabled
|
|
end
|
|
|
|
def can_view_channel(guardian:, channel:, **)
|
|
guardian.can_preview_chat_channel?(channel)
|
|
end
|
|
|
|
def fetch_threads(guardian:, channel:, **)
|
|
Chat::Thread
|
|
.includes(
|
|
:channel,
|
|
:last_reply,
|
|
original_message_user: :user_status,
|
|
original_message: :chat_webhook_event,
|
|
)
|
|
.select("chat_threads.*, MAX(chat_messages.created_at) AS last_posted_at")
|
|
.joins(
|
|
"LEFT JOIN chat_messages ON chat_threads.id = chat_messages.thread_id AND chat_messages.chat_channel_id = #{channel.id}",
|
|
)
|
|
.joins(
|
|
"LEFT JOIN chat_messages original_messages ON chat_threads.original_message_id = original_messages.id",
|
|
)
|
|
.where("chat_messages.user_id = ? OR chat_messages.user_id IS NULL", guardian.user.id)
|
|
.where(channel_id: channel.id)
|
|
.where(
|
|
"original_messages.deleted_at IS NULL AND chat_messages.deleted_at IS NULL AND original_messages.id IS NOT NULL",
|
|
)
|
|
.group("chat_threads.id")
|
|
.order("last_posted_at DESC NULLS LAST")
|
|
.limit(50)
|
|
end
|
|
|
|
def fetch_tracking(guardian:, threads:, **)
|
|
context.tracking =
|
|
::Chat::TrackingStateReportQuery.call(
|
|
guardian: guardian,
|
|
thread_ids: threads.map(&:id),
|
|
include_threads: true,
|
|
).thread_tracking
|
|
end
|
|
|
|
def fetch_memberships(guardian:, threads:, **)
|
|
context.memberships =
|
|
::Chat::UserChatThreadMembership.where(
|
|
thread_id: threads.map(&:id),
|
|
user_id: guardian.user.id,
|
|
)
|
|
end
|
|
end
|
|
end
|