2013-02-26 00:42:20 +08:00
#
2015-09-03 02:25:18 +08:00
# Helps us find topics.
# Returns a TopicList object containing the topics found.
2013-02-06 03:16:51 +08:00
#
2015-09-03 02:25:18 +08:00
2013-02-06 03:16:51 +08:00
require_dependency 'topic_list'
2013-07-13 02:38:20 +08:00
require_dependency 'suggested_topics_builder'
2013-11-14 01:26:32 +08:00
require_dependency 'topic_query_sql'
2016-02-03 15:50:05 +08:00
require_dependency 'avatar_lookup'
2013-02-06 03:16:51 +08:00
class TopicQuery
2013-07-17 03:20:18 +08:00
# Could be rewritten to %i if Ruby 1.9 is no longer supported
2015-09-03 02:25:18 +08:00
VALID_OPTIONS = % i ( except_topic_ids
exclude_category_ids
2013-11-12 08:35:57 +08:00
limit
page
per_page
2014-06-05 21:30:24 +08:00
min_posts
max_posts
2013-11-12 08:35:57 +08:00
topic_ids
visible
category
2014-04-17 00:05:54 +08:00
order
ascending
2013-12-14 06:18:28 +08:00
no_subcategories
2014-02-08 06:01:31 +08:00
no_definitions
2014-05-15 22:31:45 +08:00
status
2014-07-17 07:29:09 +08:00
state
2014-05-15 22:31:45 +08:00
search
2014-12-16 00:54:26 +08:00
slow_platform
2015-01-07 15:20:10 +08:00
filter
2015-12-10 08:39:33 +08:00
group_name
2015-09-03 02:25:18 +08:00
q )
2013-02-06 03:16:51 +08:00
2014-04-17 00:05:54 +08:00
# Maps `order` to a columns in `topics`
2013-11-14 03:17:06 +08:00
SORTABLE_MAPPING = {
'likes' = > 'like_count' ,
2014-10-03 11:16:53 +08:00
'op_likes' = > 'op_likes' ,
2013-11-14 03:17:06 +08:00
'views' = > 'views' ,
'posts' = > 'posts_count' ,
2014-08-19 01:26:12 +08:00
'activity' = > 'bumped_at' ,
2013-11-15 04:50:36 +08:00
'posters' = > 'participant_count' ,
2014-08-28 00:42:54 +08:00
'category' = > 'category_id' ,
'created' = > 'created_at'
2013-11-14 03:17:06 +08:00
}
2015-12-22 00:43:17 +08:00
cattr_accessor :results_filter_callbacks
self . results_filter_callbacks = [ ]
2013-07-17 03:20:18 +08:00
def initialize ( user = nil , options = { } )
options . assert_valid_keys ( VALID_OPTIONS )
2015-09-22 03:14:05 +08:00
@options = options . dup
2013-07-17 03:20:18 +08:00
@user = user
2015-09-23 11:13:34 +08:00
@guardian = Guardian . new ( @user )
2013-02-06 03:16:51 +08:00
end
2014-02-22 03:17:45 +08:00
def joined_topic_user ( list = nil )
( list || Topic ) . joins ( " LEFT OUTER JOIN topic_users AS tu ON (topics.id = tu.topic_id AND tu.user_id = #{ @user . id . to_i } ) " )
end
2013-02-06 03:16:51 +08:00
# Return a list of suggested topics for a topic
2013-02-26 00:42:20 +08:00
def list_suggested_for ( topic )
2016-02-03 15:50:05 +08:00
return if topic . private_message? && ! @user
2013-07-13 02:38:20 +08:00
builder = SuggestedTopicsBuilder . new ( topic )
2013-02-06 03:16:51 +08:00
2016-02-03 15:50:05 +08:00
pm_params =
if topic . private_message?
group_ids = topic . topic_allowed_groups
. where ( 'group_id IN (SELECT group_id FROM group_users WHERE user_id = :user_id)' , user_id : @user . id )
. pluck ( :group_id )
{
topic : topic ,
my_group_ids : group_ids ,
target_group_ids : topic . topic_allowed_groups . pluck ( :group_id ) ,
target_user_ids : topic . topic_allowed_users . pluck ( :user_id ) - [ @user . id ]
}
end
2013-07-13 02:38:20 +08:00
# When logged in we start with different results
2013-07-17 03:20:18 +08:00
if @user
2016-02-03 15:50:05 +08:00
if topic . private_message?
builder . add_results ( new_messages (
pm_params . merge ( count : builder . results_left )
) ) unless builder . full?
builder . add_results ( unread_messages (
pm_params . merge ( count : builder . results_left )
) ) unless builder . full?
else
builder . add_results ( unread_results ( topic : topic , per_page : builder . results_left ) , :high )
builder . add_results ( new_results ( topic : topic , per_page : builder . category_results_left ) ) unless builder . full?
end
2013-02-06 03:16:51 +08:00
end
2016-02-03 15:50:05 +08:00
if topic . private_message?
builder . add_results ( related_messages_group (
pm_params . merge ( count : [ 3 , builder . results_left ] . max ,
exclude : builder . excluded_topic_ids )
) ) if pm_params [ :my_group_ids ] . present?
builder . add_results ( related_messages_user (
pm_params . merge ( count : [ 3 , builder . results_left ] . max ,
exclude : builder . excluded_topic_ids )
) )
else
builder . add_results ( random_suggested ( topic , builder . results_left , builder . excluded_topic_ids ) ) unless builder . full?
end
params = { unordered : true }
if topic . private_message?
params [ :preload_posters ] = true
end
create_list ( :suggested , params , builder . results )
2013-02-06 03:16:51 +08:00
end
2013-03-28 04:17:49 +08:00
# The latest view of topics
def list_latest
2014-10-09 00:44:47 +08:00
create_list ( :latest , { } , latest_results )
2013-02-06 03:16:51 +08:00
end
def list_read
2013-04-03 04:52:51 +08:00
create_list ( :read , unordered : true ) do | topics |
topics . order ( 'COALESCE(tu.last_visited_at, topics.bumped_at) DESC' )
2013-02-06 03:16:51 +08:00
end
end
def list_new
2015-02-23 13:50:52 +08:00
create_list ( :new , { unordered : true } , new_results )
2013-02-06 03:16:51 +08:00
end
def list_unread
2015-02-23 13:50:52 +08:00
create_list ( :unread , { unordered : true } , unread_results )
2013-02-06 03:16:51 +08:00
end
def list_posted
2014-03-30 06:26:13 +08:00
create_list ( :posted ) { | l | l . where ( 'tu.posted' ) }
2013-02-06 03:16:51 +08:00
end
2015-01-25 12:53:11 +08:00
def list_bookmarks
create_list ( :bookmarks ) { | l | l . where ( 'tu.bookmarked' ) }
end
2013-12-28 01:10:35 +08:00
def list_top_for ( period )
score = " #{ period } _score "
2013-12-24 07:50:36 +08:00
create_list ( :top , unordered : true ) do | topics |
2014-01-19 02:03:09 +08:00
topics = topics . joins ( :top_topic ) . where ( " top_topics. #{ score } > 0 " )
2014-09-05 13:20:39 +08:00
if period == :yearly && @user . try ( :trust_level ) == TrustLevel [ 0 ]
2014-01-19 02:03:09 +08:00
topics . order ( TopicQuerySQL . order_top_with_pinned_category_for ( score ) )
else
topics . order ( TopicQuerySQL . order_top_for ( score ) )
end
2013-12-24 07:50:36 +08:00
end
2014-01-14 08:02:14 +08:00
end
2013-07-25 05:15:21 +08:00
def list_topics_by ( user )
2015-03-24 06:12:37 +08:00
@options [ :filtered_to_user ] = user . id
2013-07-25 05:15:21 +08:00
create_list ( :user_topics ) do | topics |
topics . where ( user_id : user . id )
end
end
2015-12-23 08:09:17 +08:00
def not_archived ( list , user )
list . joins ( " LEFT JOIN user_archived_messages um
ON um . user_id = #{user.id.to_i} AND um.topic_id = topics.id")
. where ( 'um.user_id IS NULL' )
end
2013-08-25 04:58:16 +08:00
def list_private_messages ( user )
2015-12-08 01:37:03 +08:00
list = private_messages_for ( user , :user )
2015-12-23 08:09:17 +08:00
list = not_archived ( list , user )
. where ( 'NOT (topics.participant_count = 1 AND topics.user_id = ?)' , user . id )
create_list ( :private_messages , { } , list )
end
def list_private_messages_archive ( user )
list = private_messages_for ( user , :user )
list = list . joins ( :user_archived_messages ) . where ( 'user_archived_messages.user_id = ?' , user . id )
2014-10-09 00:44:47 +08:00
create_list ( :private_messages , { } , list )
2013-08-25 04:58:16 +08:00
end
def list_private_messages_sent ( user )
2015-12-08 01:37:03 +08:00
list = private_messages_for ( user , :user )
2015-12-23 08:09:17 +08:00
list = list . where ( ' EXISTS (
SELECT 1 FROM posts
WHERE posts . topic_id = topics . id AND
posts . user_id = ?
) ' , user . id )
list = not_archived ( list , user )
2014-10-09 00:44:47 +08:00
create_list ( :private_messages , { } , list )
2013-08-25 04:58:16 +08:00
end
2013-08-31 00:32:05 +08:00
def list_private_messages_unread ( user )
2015-12-08 01:37:03 +08:00
list = private_messages_for ( user , :user )
2014-05-03 04:36:52 +08:00
list = list . where ( " tu.last_read_post_number IS NULL OR tu.last_read_post_number < topics.highest_post_number " )
2014-10-09 00:44:47 +08:00
create_list ( :private_messages , { } , list )
2013-08-31 00:32:05 +08:00
end
2013-07-25 05:15:21 +08:00
2015-12-10 08:39:33 +08:00
def list_private_messages_group ( user )
2015-12-08 01:37:03 +08:00
list = private_messages_for ( user , :group )
2015-12-23 08:09:17 +08:00
group_id = Group . where ( 'name ilike ?' , @options [ :group_name ] ) . pluck ( :id ) . first
list = list . joins ( " LEFT JOIN group_archived_messages gm ON gm.topic_id = topics.id AND
gm . group_id = #{group_id.to_i}")
list = list . where ( " gm.id IS NULL " )
create_list ( :private_messages , { } , list )
end
def list_private_messages_group_archive ( user )
list = private_messages_for ( user , :group )
group_id = Group . where ( 'name ilike ?' , @options [ :group_name ] ) . pluck ( :id ) . first
list = list . joins ( " JOIN group_archived_messages gm ON gm.topic_id = topics.id AND
gm . group_id = #{group_id.to_i}")
2015-12-08 01:37:03 +08:00
create_list ( :private_messages , { } , list )
end
2015-02-23 13:50:52 +08:00
def list_category_topic_ids ( category )
2015-02-25 11:24:25 +08:00
query = default_results ( category : category . id )
2015-03-12 07:42:26 +08:00
pinned_ids = query . where ( 'pinned_at IS NOT NULL AND category_id = ?' , category . id )
2015-06-11 02:36:47 +08:00
. limit ( nil )
2015-03-12 07:42:26 +08:00
. order ( 'pinned_at DESC' ) . pluck ( :id )
non_pinned_ids = query . where ( 'pinned_at IS NULL OR category_id <> ?' , category . id ) . pluck ( :id )
2015-06-11 02:36:47 +08:00
( pinned_ids + non_pinned_ids )
2013-02-06 03:16:51 +08:00
end
2013-02-28 11:36:12 +08:00
def list_new_in_category ( category )
2014-02-05 04:55:30 +08:00
create_list ( :new_in_category , unordered : true , category : category . id ) do | list |
list . by_newest . first ( 25 )
2014-01-18 06:52:06 +08:00
end
2013-02-28 11:36:12 +08:00
end
2013-07-17 03:20:18 +08:00
def self . new_filter ( list , treat_as_new_topic_start_date )
2013-05-23 13:21:07 +08:00
list . where ( " topics.created_at >= :created_at " , created_at : treat_as_new_topic_start_date )
. where ( " tu.last_read_post_number IS NULL " )
. where ( " COALESCE(tu.notification_level, :tracking) >= :tracking " , tracking : TopicUser . notification_levels [ :tracking ] )
end
def self . unread_filter ( list )
2014-08-19 04:46:16 +08:00
list . where ( " tu.last_read_post_number < topics.highest_post_number " )
2013-05-23 13:21:07 +08:00
. where ( " COALESCE(tu.notification_level, :regular) >= :tracking " , regular : TopicUser . notification_levels [ :regular ] , tracking : TopicUser . notification_levels [ :tracking ] )
2013-05-21 14:39:51 +08:00
end
2015-02-23 13:50:52 +08:00
def prioritize_pinned_topics ( topics , options )
2015-03-12 07:42:26 +08:00
pinned_clause = options [ :category_id ] ? " topics.category_id = #{ options [ :category_id ] . to_i } AND " : " pinned_globally AND "
2015-02-23 13:50:52 +08:00
pinned_clause << " pinned_at IS NOT NULL "
if @user
pinned_clause << " AND (topics.pinned_at > tu.cleared_pinned_at OR tu.cleared_pinned_at IS NULL) "
end
unpinned_topics = topics . where ( " NOT ( #{ pinned_clause } ) " )
2015-06-26 04:25:50 +08:00
pinned_topics = topics . dup . offset ( nil ) . where ( pinned_clause )
2015-02-23 13:50:52 +08:00
per_page = options [ :per_page ] || per_page_setting
limit = per_page unless options [ :limit ] == false
page = options [ :page ] . to_i
if page == 0
( pinned_topics + unpinned_topics ) [ 0 ... limit ] if limit
else
2015-06-26 04:25:50 +08:00
offset = ( page * per_page ) - pinned_topics . count - 1
2015-02-26 11:48:56 +08:00
offset = 0 unless offset > 0
unpinned_topics . offset ( offset ) . to_a
2015-02-23 13:50:52 +08:00
end
end
2015-01-09 05:44:27 +08:00
def create_list ( filter , options = { } , topics = nil )
topics || = default_results ( options )
topics = yield ( topics ) if block_given?
2015-02-23 13:50:52 +08:00
options = options . merge ( @options )
2015-12-23 08:09:17 +08:00
if [ " activity " , " default " ] . include? ( options [ :order ] || " activity " ) &&
! options [ :unordered ] &&
filter != :private_messages
2015-02-23 13:50:52 +08:00
topics = prioritize_pinned_topics ( topics , options )
end
2016-02-03 15:50:05 +08:00
topics = topics . to_a
if options [ :preload_posters ]
user_ids = [ ]
topics . each do | ft |
user_ids << ft . user_id << ft . last_post_user_id << ft . featured_user_ids << ft . allowed_user_ids
end
avatar_lookup = AvatarLookup . new ( user_ids )
topics . each do | t |
t . posters = t . posters_summary ( avatar_lookup : avatar_lookup )
end
end
topics . each do | t |
2015-04-01 05:29:07 +08:00
t . allowed_user_ids = filter == :private_messages ? t . allowed_users . map { | u | u . id } : [ ]
2015-02-23 13:50:52 +08:00
end
2016-02-03 15:50:05 +08:00
list = TopicList . new ( filter , @user , topics , options . merge ( @options ) )
2015-01-09 05:44:27 +08:00
list . per_page = per_page_setting
list
end
def latest_results ( options = { } )
result = default_results ( options )
2015-11-02 12:05:08 +08:00
result = remove_muted_topics ( result , @user ) unless options && options [ :state ] == " muted " . freeze
2015-01-09 05:44:27 +08:00
result = remove_muted_categories ( result , @user , exclude : options [ :category ] )
2016-04-26 03:55:15 +08:00
result = remove_muted_tags ( result , @user , options )
2015-12-22 00:43:17 +08:00
# plugins can remove topics here:
self . class . results_filter_callbacks . each do | filter_callback |
result = filter_callback . call ( :latest , result , @user , options )
end
2015-01-09 05:44:27 +08:00
result
end
def unread_results ( options = { } )
result = TopicQuery . unread_filter ( default_results ( options . reverse_merge ( :unordered = > true ) ) )
. order ( 'CASE WHEN topics.user_id = tu.user_id THEN 1 ELSE 2 END' )
2015-12-22 00:43:17 +08:00
self . class . results_filter_callbacks . each do | filter_callback |
result = filter_callback . call ( :unread , result , @user , options )
end
2015-01-09 05:44:27 +08:00
suggested_ordering ( result , options )
end
def new_results ( options = { } )
2015-02-23 13:50:52 +08:00
# TODO does this make sense or should it be ordered on created_at
# it is ordering on bumped_at now
2016-02-18 13:57:22 +08:00
result = TopicQuery . new_filter ( default_results ( options . reverse_merge ( :unordered = > true ) ) , @user . user_option . treat_as_new_topic_start_date )
2015-11-02 06:20:22 +08:00
result = remove_muted_topics ( result , @user )
2015-01-09 05:44:27 +08:00
result = remove_muted_categories ( result , @user , exclude : options [ :category ] )
2016-04-26 03:55:15 +08:00
result = remove_muted_tags ( result , @user , options )
2015-12-22 00:43:17 +08:00
self . class . results_filter_callbacks . each do | filter_callback |
result = filter_callback . call ( :new , result , @user , options )
end
2015-01-09 05:44:27 +08:00
suggested_ordering ( result , options )
end
2013-02-06 03:16:51 +08:00
protected
2014-12-16 00:54:26 +08:00
def per_page_setting
2014-12-20 02:18:26 +08:00
@options [ :slow_platform ] ? 15 : 30
2014-12-16 00:54:26 +08:00
end
2015-12-08 01:37:03 +08:00
def private_messages_for ( user , type )
2013-08-25 04:58:16 +08:00
options = @options
2014-12-16 00:54:26 +08:00
options . reverse_merge! ( per_page : per_page_setting )
2013-08-25 04:58:16 +08:00
2015-12-08 01:37:03 +08:00
result = Topic
if type == :group
result = result . includes ( :allowed_groups )
2015-12-10 08:39:33 +08:00
result = result . where ( " topics.id IN (SELECT topic_id FROM topic_allowed_groups
WHERE group_id IN (
SELECT group_id FROM group_users WHERE user_id = #{user.id.to_i}) AND
group_id IN ( SELECT id FROM groups WHERE name ilike ?)
) " , @options[:group_name])
2015-12-08 01:37:03 +08:00
elsif type == :user
result = result . includes ( :allowed_users )
result = result . where ( " topics.id IN (SELECT topic_id FROM topic_allowed_users WHERE user_id = #{ user . id . to_i } ) " )
end
result = result . joins ( " LEFT OUTER JOIN topic_users AS tu ON (topics.id = tu.topic_id AND tu.user_id = #{ user . id . to_i } ) " )
. order ( " topics.bumped_at DESC " )
. private_messages
2013-08-25 04:58:16 +08:00
result = result . limit ( options [ :per_page ] ) unless options [ :limit ] == false
result = result . visible if options [ :visible ] || @user . nil? || @user . regular?
2016-05-10 04:33:55 +08:00
if options [ :page ]
offset = options [ :page ] . to_i * options [ :per_page ]
result = result . offset ( offset ) if offset > 0
end
2013-08-25 04:58:16 +08:00
result
end
2013-11-14 03:17:06 +08:00
def apply_ordering ( result , options )
2014-04-17 00:05:54 +08:00
sort_column = SORTABLE_MAPPING [ options [ :order ] ] || 'default'
sort_dir = ( options [ :ascending ] == " true " ) ? " ASC " : " DESC "
2013-11-14 03:17:06 +08:00
# If we are sorting in the default order desc, we should consider including pinned
# topics. Otherwise, just use bumped_at.
if sort_column == 'default'
2013-11-15 04:50:36 +08:00
if sort_dir == 'DESC'
# If something requires a custom order, for example "unread" which sorts the least read
# to the top, do nothing
return result if options [ :unordered ]
end
2013-11-14 03:17:06 +08:00
sort_column = 'bumped_at'
end
2013-11-15 04:50:36 +08:00
# If we are sorting by category, actually use the name
if sort_column == 'category_id'
2015-02-23 13:50:52 +08:00
# TODO forces a table scan, slow
2013-11-15 04:50:36 +08:00
return result . references ( :categories ) . order ( TopicQuerySQL . order_by_category_sql ( sort_dir ) )
end
2014-10-03 11:16:53 +08:00
if sort_column == 'op_likes'
2015-01-05 14:39:49 +08:00
return result . includes ( :first_post ) . order ( " (SELECT like_count FROM posts p3 WHERE p3.topic_id = topics.id AND p3.post_number = 1) #{ sort_dir } " )
2014-10-03 11:16:53 +08:00
end
2016-02-26 00:22:23 +08:00
if sort_column . start_with? ( 'custom_fields' )
field = sort_column . split ( '.' ) [ 1 ]
return result . order ( " (SELECT CASE WHEN EXISTS (SELECT true FROM topic_custom_fields tcf WHERE tcf.topic_id::integer = topics.id::integer AND tcf.name = ' #{ field } ') THEN (SELECT value::integer FROM topic_custom_fields tcf WHERE tcf.topic_id::integer = topics.id::integer AND tcf.name = ' #{ field } ') ELSE 0 END) #{ sort_dir } " )
end
2013-11-14 03:17:06 +08:00
result . order ( " topics. #{ sort_column } #{ sort_dir } " )
end
2014-06-18 09:23:31 +08:00
def get_category_id ( category_id_or_slug )
return nil unless category_id_or_slug
category_id = category_id_or_slug . to_i
category_id = Category . where ( slug : category_id_or_slug ) . pluck ( :id ) . first if category_id == 0
category_id
end
2014-02-22 03:17:45 +08:00
2013-07-17 03:20:18 +08:00
# Create results based on a bunch of default options
def default_results ( options = { } )
options . reverse_merge! ( @options )
2014-12-16 00:54:26 +08:00
options . reverse_merge! ( per_page : per_page_setting )
2013-02-06 03:16:51 +08:00
2015-03-24 06:12:37 +08:00
# Whether to return visible topics
options [ :visible ] = true if @user . nil? || @user . regular?
options [ :visible ] = false if @user && @user . id == options [ :filtered_to_user ]
2013-03-07 04:17:07 +08:00
# Start with a list of all topics
2014-11-20 06:46:55 +08:00
result = Topic . unscoped
2013-03-07 04:17:07 +08:00
2013-07-17 03:20:18 +08:00
if @user
result = result . joins ( " LEFT OUTER JOIN topic_users AS tu ON (topics.id = tu.topic_id AND tu.user_id = #{ @user . id . to_i } ) " )
2014-02-27 00:09:02 +08:00
. references ( 'tu' )
2013-03-07 04:17:07 +08:00
end
2014-06-18 09:23:31 +08:00
category_id = get_category_id ( options [ :category ] )
2014-10-09 00:44:47 +08:00
@options [ :category_id ] = category_id
2014-06-18 09:23:31 +08:00
if category_id
if options [ :no_subcategories ]
result = result . where ( 'categories.id = ?' , category_id )
else
2015-09-03 02:25:18 +08:00
result = result . where ( 'categories.id = :category_id OR (categories.parent_category_id = :category_id AND categories.topic_id <> topics.id)' , category_id : category_id )
2013-11-09 04:05:14 +08:00
end
2014-06-18 09:23:31 +08:00
result = result . references ( :categories )
2013-11-09 04:05:14 +08:00
end
2013-11-15 04:50:36 +08:00
result = apply_ordering ( result , options )
2014-09-11 10:55:10 +08:00
result = result . listable_topics . includes ( :category )
2015-09-03 02:25:18 +08:00
if options [ :exclude_category_ids ] && options [ :exclude_category_ids ] . is_a? ( Array ) && options [ :exclude_category_ids ] . size > 0
result = result . where ( " categories.id NOT IN (?) " , options [ :exclude_category_ids ] ) . references ( :categories )
end
2013-11-01 04:10:54 +08:00
2014-02-11 07:06:20 +08:00
# Don't include the category topics if excluded
if options [ :no_definitions ]
2014-02-05 04:55:30 +08:00
result = result . where ( 'COALESCE(categories.topic_id, 0) <> topics.id' )
end
2013-07-17 03:20:18 +08:00
result = result . limit ( options [ :per_page ] ) unless options [ :limit ] == false
2015-03-24 06:12:37 +08:00
result = result . visible if options [ :visible ]
2013-12-24 07:50:36 +08:00
result = result . where . not ( topics : { id : options [ :except_topic_ids ] } ) . references ( :topics ) if options [ :except_topic_ids ]
2016-05-10 04:33:55 +08:00
if options [ :page ]
offset = options [ :page ] . to_i * options [ :per_page ]
2016-05-12 01:39:21 +08:00
result = result . offset ( offset ) if offset > 0
2016-05-10 04:33:55 +08:00
end
2013-07-17 03:20:18 +08:00
if options [ :topic_ids ]
2013-08-16 20:53:40 +08:00
result = result . where ( 'topics.id in (?)' , options [ :topic_ids ] ) . references ( :topics )
2013-05-28 15:52:52 +08:00
end
2014-05-15 22:31:45 +08:00
if search = options [ :search ]
result = result . where ( " topics.id in (select pp.topic_id from post_search_data pd join posts pp on pp.id = pd.post_id where pd.search_data @@ #{ Search . ts_query ( search . to_s ) } ) " )
end
2014-07-17 07:29:09 +08:00
# NOTE protect against SYM attack can be removed with Ruby 2.2
#
state = options [ :state ]
if @user && state &&
TopicUser . notification_levels . keys . map ( & :to_s ) . include? ( state )
level = TopicUser . notification_levels [ state . to_sym ]
result = result . where ( ' topics . id IN (
SELECT topic_id
FROM topic_users
WHERE user_id = ? AND
notification_level = ?) ' , @user . id , level )
end
2014-11-20 06:46:55 +08:00
require_deleted_clause = true
2014-01-13 11:40:21 +08:00
if status = options [ :status ]
case status
when 'open'
result = result . where ( 'NOT topics.closed AND NOT topics.archived' )
when 'closed'
result = result . where ( 'topics.closed' )
when 'archived'
result = result . where ( 'topics.archived' )
2015-01-12 17:00:45 +08:00
when 'listed'
2014-09-12 07:17:16 +08:00
result = result . where ( 'topics.visible' )
2015-01-12 17:00:45 +08:00
when 'unlisted'
2014-09-12 07:21:25 +08:00
result = result . where ( 'NOT topics.visible' )
2014-11-20 06:46:55 +08:00
when 'deleted'
2015-09-23 11:13:34 +08:00
guardian = @guardian
2014-11-20 06:46:55 +08:00
if guardian . is_staff?
result = result . where ( 'topics.deleted_at IS NOT NULL' )
require_deleted_clause = false
end
2014-01-13 11:40:21 +08:00
end
end
2015-01-07 15:20:10 +08:00
if ( filter = options [ :filter ] ) && @user
action =
if filter == " bookmarked "
PostActionType . types [ :bookmark ]
elsif filter == " liked "
PostActionType . types [ :like ]
end
if action
result = result . where ( ' topics . id IN ( SELECT pp . topic_id
2015-01-07 10:58:34 +08:00
FROM post_actions pa
JOIN posts pp ON pp . id = pa . post_id
WHERE pa . user_id = :user_id AND
2015-01-07 15:20:10 +08:00
pa . post_action_type_id = :action AND
2015-01-07 10:58:34 +08:00
pa . deleted_at IS NULL
) ' , user_id : @user . id ,
2015-01-07 15:20:10 +08:00
action : action
2015-01-07 10:58:34 +08:00
)
2015-01-07 15:20:10 +08:00
end
2015-01-07 10:58:34 +08:00
end
2014-11-20 06:46:55 +08:00
result = result . where ( 'topics.deleted_at IS NULL' ) if require_deleted_clause
2014-06-05 21:30:24 +08:00
result = result . where ( 'topics.posts_count <= ?' , options [ :max_posts ] ) if options [ :max_posts ] . present?
result = result . where ( 'topics.posts_count >= ?' , options [ :min_posts ] ) if options [ :min_posts ] . present?
2015-09-23 11:13:34 +08:00
@guardian . filter_allowed_categories ( result )
2013-02-06 03:16:51 +08:00
end
2015-11-02 06:20:22 +08:00
def remove_muted_topics ( list , user )
if user
2015-11-02 11:59:10 +08:00
list = list . where ( 'COALESCE(tu.notification_level,1) > :muted' , muted : TopicUser . notification_levels [ :muted ] )
2015-11-02 06:20:22 +08:00
end
list
end
2014-07-29 12:34:54 +08:00
def remove_muted_categories ( list , user , opts = nil )
2014-06-18 09:23:31 +08:00
category_id = get_category_id ( opts [ :exclude ] ) if opts
2015-09-03 02:25:18 +08:00
2014-02-03 13:05:49 +08:00
if user
2015-09-03 02:25:18 +08:00
list = list . references ( " cu " )
. where ( "
NOT EXISTS (
SELECT 1
FROM category_users cu
WHERE cu . user_id = :user_id
AND cu . category_id = topics . category_id
AND cu . notification_level = :muted
AND cu . category_id < > :category_id
2015-10-13 14:54:31 +08:00
AND ( tu . notification_level IS NULL OR tu . notification_level < :tracking )
2015-09-03 02:25:18 +08:00
) " , user_id: user.id,
muted : CategoryUser . notification_levels [ :muted ] ,
2015-10-13 14:54:31 +08:00
tracking : TopicUser . notification_levels [ :tracking ] ,
2015-09-03 02:25:18 +08:00
category_id : category_id || - 1 )
2014-02-03 13:05:49 +08:00
end
list
end
2016-04-26 03:55:15 +08:00
def remove_muted_tags ( list , user , opts = nil )
if user . nil? || ! SiteSetting . tagging_enabled || ! SiteSetting . remove_muted_tags_from_latest
list
else
muted_tags = DiscourseTagging . muted_tags ( user )
if muted_tags . empty?
list
else
showing_tag = if opts [ :filter ]
f = opts [ :filter ] . split ( '/' )
f [ 0 ] == 'tags' ? f [ 1 ] : nil
else
nil
end
if muted_tags . include? ( showing_tag )
list # if viewing the topic list for a muted tag, show all the topics
else
arr = muted_tags . map { | z | " ' #{ z } ' " } . join ( ',' )
list . where ( " EXISTS (
SELECT 1
FROM topic_custom_fields tcf
WHERE tcf . name = 'tags'
AND tcf . value NOT IN ( #{arr})
AND tcf . topic_id = topics . id
) OR NOT EXISTS ( select 1 from topic_custom_fields tcf where tcf . name = 'tags' and tcf . topic_id = topics . id ) " )
end
end
end
end
2014-02-03 13:05:49 +08:00
2016-02-03 15:50:05 +08:00
def new_messages ( params )
TopicQuery . new_filter ( messages_for_groups_or_user ( params [ :my_group_ids ] ) , 10 . years . ago )
. limit ( params [ :count ] )
end
def unread_messages ( params )
TopicQuery . unread_filter ( messages_for_groups_or_user ( params [ :my_group_ids ] ) )
. limit ( params [ :count ] )
end
def related_messages_user ( params )
messages_for_user
. limit ( params [ :count ] )
. where ( ' topics . id IN (
SELECT ta . topic_id
FROM topic_allowed_users ta
WHERE ta . user_id IN ( :user_ids )
) OR
topics . id IN (
SELECT tg . topic_id
FROM topic_allowed_groups tg
WHERE tg . group_id IN ( :group_ids )
)
' , user_ids : ( params [ :target_user_ids ] || [ ] ) + [ - 10 ] ,
group_ids : ( ( params [ :target_group_ids ] - params [ :my_group_ids ] ) || [ ] ) + [ - 10 ] )
end
def related_messages_group ( params )
messages_for_groups_or_user ( params [ :my_group_ids ] )
. limit ( params [ :count ] )
. where ( ' topics . id IN (
SELECT ta . topic_id
FROM topic_allowed_users ta
WHERE ta . user_id IN ( :user_ids )
) OR
topics . id IN (
SELECT tg . topic_id
FROM topic_allowed_groups tg
WHERE tg . group_id IN ( :group_ids )
)
' , user_ids : ( params [ :target_user_ids ] || [ ] ) + [ - 10 ] ,
group_ids : ( ( params [ :target_group_ids ] - params [ :my_group_ids ] ) || [ ] ) + [ - 10 ] )
end
def messages_for_groups_or_user ( group_ids )
if group_ids . present?
base_messages
. where ( ' topics . id IN (
SELECT topic_id
FROM topic_allowed_groups tg
JOIN group_users gu ON gu . user_id = :user_id AND gu . group_id = tg . group_id
WHERE gu . group_id IN ( :group_ids )
) ' , user_id : @user . id , group_ids : group_ids )
else
messages_for_user
end
end
def messages_for_user
base_messages . where ( ' topics . id IN (
SELECT topic_id
FROM topic_allowed_users
WHERE user_id = :user_id
) ' , user_id : @user . id )
end
def base_messages
Topic
. where ( 'topics.archetype = ?' , Archetype . private_message )
. joins ( " LEFT JOIN topic_users tu ON topics.id = tu.topic_id AND tu.user_id = #{ @user . id . to_i } " )
. order ( 'topics.bumped_at DESC' )
end
2014-02-03 13:05:49 +08:00
2014-01-29 07:15:36 +08:00
def random_suggested ( topic , count , excluded_topic_ids = [ ] )
2014-02-05 01:26:38 +08:00
result = default_results ( unordered : true , per_page : count ) . where ( closed : false , archived : false )
2014-01-29 07:15:36 +08:00
excluded_topic_ids += Category . pluck ( :topic_id ) . compact
result = result . where ( " topics.id NOT IN (?) " , excluded_topic_ids ) unless excluded_topic_ids . empty?
2013-02-06 03:16:51 +08:00
2014-07-29 12:34:54 +08:00
result = remove_muted_categories ( result , @user )
2013-07-13 02:38:20 +08:00
# If we are in a category, prefer it for the random results
2013-07-17 03:20:18 +08:00
if topic . category_id
2013-07-19 02:47:59 +08:00
result = result . order ( " CASE WHEN topics.category_id = #{ topic . category_id . to_i } THEN 0 ELSE 1 END " )
2013-02-28 07:30:14 +08:00
end
2015-02-25 14:19:12 +08:00
# Best effort, it over selects, however if you have a high number
# of muted categories there is tiny chance we will not select enough
# in particular this can happen if current category is empty and tons
# of muted, big edge case
#
# we over select in case cache is stale
max = ( count * 1 . 3 ) . to_i
ids = RandomTopicSelector . next ( max ) + RandomTopicSelector . next ( max , topic . category )
2015-03-03 07:20:42 +08:00
result . where ( id : ids . uniq )
2013-02-06 03:16:51 +08:00
end
2013-08-09 01:18:52 +08:00
def suggested_ordering ( result , options )
# Prefer unread in the same category
if options [ :topic ] && options [ :topic ] . category_id
result = result . order ( " CASE WHEN topics.category_id = #{ options [ :topic ] . category_id . to_i } THEN 0 ELSE 1 END " )
end
2015-02-23 13:50:52 +08:00
result . order ( 'topics.bumped_at DESC' )
2013-08-09 01:18:52 +08:00
end
2013-02-06 03:16:51 +08:00
end