mirror of
https://github.com/discourse/discourse.git
synced 2024-11-24 11:12:23 +08:00
6ddd8d9166
There was a timing issue when subscribing to messages for topics. Old flow: - We generate JSON for topic - We subscribe to messages for topic New flow: - We keep track of last id in the topic message bus channel - We generate JSON - We subscribe to messages for topic starting at saved message id This ensures that there is complete overlap for message consumption and that there are no cases where an update may go missing due to timing
294 lines
7.5 KiB
Ruby
294 lines
7.5 KiB
Ruby
require_dependency 'pinned_check'
|
|
require_dependency 'new_post_manager'
|
|
|
|
class TopicViewSerializer < ApplicationSerializer
|
|
include PostStreamSerializerMixin
|
|
include ApplicationHelper
|
|
|
|
def self.attributes_from_topic(*list)
|
|
[list].flatten.each do |attribute|
|
|
attributes(attribute)
|
|
class_eval %{def #{attribute}
|
|
object.topic.#{attribute}
|
|
end}
|
|
end
|
|
end
|
|
|
|
attributes_from_topic :id,
|
|
:title,
|
|
:fancy_title,
|
|
:posts_count,
|
|
:created_at,
|
|
:views,
|
|
:reply_count,
|
|
:participant_count,
|
|
:like_count,
|
|
:last_posted_at,
|
|
:visible,
|
|
:closed,
|
|
:archived,
|
|
:has_summary,
|
|
:archetype,
|
|
:slug,
|
|
:category_id,
|
|
:word_count,
|
|
:deleted_at,
|
|
:pending_posts_count,
|
|
:user_id,
|
|
:pm_with_non_human_user?
|
|
|
|
attributes :draft,
|
|
:draft_key,
|
|
:draft_sequence,
|
|
:posted,
|
|
:unpinned,
|
|
:pinned_globally,
|
|
:pinned, # Is topic pinned and viewer hasn't cleared the pin?
|
|
:pinned_at, # Ignores clear pin
|
|
:pinned_until,
|
|
:details,
|
|
:highest_post_number,
|
|
:last_read_post_number,
|
|
:last_read_post_id,
|
|
:deleted_by,
|
|
:has_deleted,
|
|
:actions_summary,
|
|
:expandable_first_post,
|
|
:is_warning,
|
|
:chunk_size,
|
|
:bookmarked,
|
|
:message_archived,
|
|
:tags,
|
|
:featured_link,
|
|
:topic_timer,
|
|
:unicode_title,
|
|
:message_bus_last_id
|
|
|
|
# TODO: Split off into proper object / serializer
|
|
def details
|
|
topic = object.topic
|
|
|
|
result = {
|
|
created_by: BasicUserSerializer.new(topic.user, scope: scope, root: false),
|
|
last_poster: BasicUserSerializer.new(topic.last_poster, scope: scope, root: false)
|
|
}
|
|
|
|
if private_message?(topic)
|
|
allowed_user_ids = Set.new
|
|
|
|
result[:allowed_groups] = object.topic.allowed_groups.map do |group|
|
|
allowed_user_ids.merge(GroupUser.where(group: group).pluck(:user_id))
|
|
BasicGroupSerializer.new(group, scope: scope, root: false)
|
|
end
|
|
|
|
result[:allowed_users] = object.topic.allowed_users.select do |user|
|
|
!allowed_user_ids.include?(user.id)
|
|
end.map do |user|
|
|
BasicUserSerializer.new(user, scope: scope, root: false)
|
|
end
|
|
end
|
|
|
|
if object.post_counts_by_user.present?
|
|
result[:participants] = object.post_counts_by_user.map do |pc|
|
|
TopicPostCountSerializer.new({user: object.participants[pc[0]], post_count: pc[1]}, scope: scope, root: false)
|
|
end
|
|
end
|
|
|
|
if object.suggested_topics.try(:topics).present?
|
|
result[:suggested_topics] = object.suggested_topics.topics.map do |topic|
|
|
SuggestedTopicSerializer.new(topic, scope: scope, root: false)
|
|
end
|
|
end
|
|
|
|
if object.links.present?
|
|
result[:links] = object.links.map do |user|
|
|
TopicLinkSerializer.new(user, scope: scope, root: false)
|
|
end
|
|
end
|
|
|
|
if has_topic_user?
|
|
result[:notification_level] = object.topic_user.notification_level
|
|
result[:notifications_reason_id] = object.topic_user.notifications_reason_id
|
|
else
|
|
result[:notification_level] = TopicUser.notification_levels[:regular]
|
|
end
|
|
|
|
result[:can_move_posts] = true if scope.can_move_posts?(object.topic)
|
|
result[:can_edit] = true if scope.can_edit?(object.topic)
|
|
result[:can_delete] = true if scope.can_delete?(object.topic)
|
|
result[:can_recover] = true if scope.can_recover_topic?(object.topic)
|
|
result[:can_remove_allowed_users] = true if scope.can_remove_allowed_users?(object.topic)
|
|
result[:can_invite_to] = true if scope.can_invite_to?(object.topic)
|
|
result[:can_invite_via_email] = true if scope.can_invite_via_email?(object.topic)
|
|
result[:can_create_post] = true if scope.can_create?(Post, object.topic)
|
|
result[:can_reply_as_new_topic] = true if scope.can_reply_as_new_topic?(object.topic)
|
|
result[:can_flag_topic] = actions_summary.any? { |a| a[:can_act] }
|
|
result
|
|
end
|
|
|
|
def message_bus_last_id
|
|
object.message_bus_last_id
|
|
end
|
|
|
|
def chunk_size
|
|
object.chunk_size
|
|
end
|
|
|
|
def is_warning
|
|
private_message?(object.topic) && object.topic.subtype == TopicSubtype.moderator_warning
|
|
end
|
|
|
|
def include_is_warning?
|
|
is_warning
|
|
end
|
|
|
|
def draft
|
|
object.draft
|
|
end
|
|
|
|
def draft_key
|
|
object.draft_key
|
|
end
|
|
|
|
def draft_sequence
|
|
object.draft_sequence
|
|
end
|
|
|
|
def include_message_archived?
|
|
private_message?(object.topic)
|
|
end
|
|
|
|
def message_archived
|
|
object.topic.message_archived?(scope.user)
|
|
end
|
|
|
|
def deleted_by
|
|
BasicUserSerializer.new(object.topic.deleted_by, root: false).as_json
|
|
end
|
|
|
|
# Topic user stuff
|
|
def has_topic_user?
|
|
object.topic_user.present?
|
|
end
|
|
|
|
def highest_post_number
|
|
object.highest_post_number
|
|
end
|
|
|
|
def last_read_post_id
|
|
return nil unless object.filtered_post_stream && last_read_post_number
|
|
object.filtered_post_stream.each do |ps|
|
|
return ps[0] if ps[1] === last_read_post_number
|
|
end
|
|
end
|
|
alias_method :include_last_read_post_id?, :has_topic_user?
|
|
|
|
def last_read_post_number
|
|
@last_read_post_number ||= object.topic_user.last_read_post_number
|
|
end
|
|
alias_method :include_last_read_post_number?, :has_topic_user?
|
|
|
|
def posted
|
|
object.topic_user.posted?
|
|
end
|
|
alias_method :include_posted?, :has_topic_user?
|
|
|
|
def pinned_globally
|
|
object.topic.pinned_globally
|
|
end
|
|
|
|
def pinned
|
|
PinnedCheck.pinned?(object.topic, object.topic_user)
|
|
end
|
|
|
|
def unpinned
|
|
PinnedCheck.unpinned?(object.topic, object.topic_user)
|
|
end
|
|
|
|
def pinned_at
|
|
object.topic.pinned_at
|
|
end
|
|
|
|
def pinned_until
|
|
object.topic.pinned_until
|
|
end
|
|
|
|
def actions_summary
|
|
result = []
|
|
return [] unless post = object.posts.try(:first)
|
|
PostActionType.topic_flag_types.each do |sym, id|
|
|
result << { id: id,
|
|
count: 0,
|
|
hidden: false,
|
|
can_act: scope.post_can_act?(post, sym)}
|
|
# TODO: other keys? :can_defer_flags, :acted, :can_undo
|
|
end
|
|
result
|
|
end
|
|
|
|
def has_deleted
|
|
object.has_deleted?
|
|
end
|
|
|
|
def include_has_deleted?
|
|
object.guardian.can_see_deleted_posts?
|
|
end
|
|
|
|
def expandable_first_post
|
|
true
|
|
end
|
|
|
|
def include_expandable_first_post?
|
|
object.topic.expandable_first_post?
|
|
end
|
|
|
|
def bookmarked
|
|
object.topic_user.try(:bookmarked)
|
|
end
|
|
|
|
def include_pending_posts_count?
|
|
scope.is_staff? && NewPostManager.queue_enabled?
|
|
end
|
|
|
|
def include_tags?
|
|
SiteSetting.tagging_enabled
|
|
end
|
|
|
|
def topic_timer
|
|
TopicTimerSerializer.new(
|
|
object.topic.public_topic_timer, root: false
|
|
)
|
|
end
|
|
|
|
def tags
|
|
object.topic.tags.map(&:name)
|
|
end
|
|
|
|
def include_featured_link?
|
|
SiteSetting.topic_featured_link_enabled
|
|
end
|
|
|
|
def featured_link
|
|
object.topic.featured_link
|
|
end
|
|
|
|
def include_unicode_title?
|
|
!!(object.topic.title =~ /:([\w\-+]*):/)
|
|
end
|
|
|
|
def unicode_title
|
|
gsub_emoji_to_unicode(object.topic.title)
|
|
end
|
|
|
|
def include_pm_with_non_human_user?
|
|
private_message?(object.topic)
|
|
end
|
|
|
|
private
|
|
|
|
def private_message?(topic)
|
|
@private_message ||= topic.private_message?
|
|
end
|
|
|
|
end
|