147 lines
4.1 KiB
Ruby
147 lines
4.1 KiB
Ruby
class ConversationFinder
|
|
attr_reader :current_user, :current_account, :params
|
|
|
|
DEFAULT_STATUS = 'open'.freeze
|
|
SORT_OPTIONS = {
|
|
latest: 'latest',
|
|
sort_on_created_at: 'sort_on_created_at',
|
|
last_user_message_at: 'last_user_message_at'
|
|
}.with_indifferent_access
|
|
|
|
# assumptions
|
|
# inbox_id if not given, take from all conversations, else specific to inbox
|
|
# assignee_type if not given, take 'all'
|
|
# conversation_status if not given, take 'open'
|
|
|
|
# response of this class will be of type
|
|
# {conversations: [array of conversations], count: {open: count, resolved: count}}
|
|
|
|
# params
|
|
# assignee_type, inbox_id, :status
|
|
|
|
def initialize(current_user, params)
|
|
@current_user = current_user
|
|
@current_account = current_user.account
|
|
@params = params
|
|
end
|
|
|
|
def perform
|
|
set_up
|
|
|
|
mine_count, unassigned_count, all_count, = set_count_for_all_conversations
|
|
assigned_count = all_count - unassigned_count
|
|
|
|
filter_by_assignee_type
|
|
|
|
{
|
|
conversations: conversations,
|
|
count: {
|
|
mine_count: mine_count,
|
|
assigned_count: assigned_count,
|
|
unassigned_count: unassigned_count,
|
|
all_count: all_count
|
|
}
|
|
}
|
|
end
|
|
|
|
private
|
|
|
|
def set_up
|
|
set_inboxes
|
|
set_team
|
|
set_assignee_type
|
|
|
|
find_all_conversations
|
|
filter_by_status unless params[:q]
|
|
filter_by_team if @team
|
|
filter_by_labels if params[:labels]
|
|
filter_by_query if params[:q]
|
|
end
|
|
|
|
def set_inboxes
|
|
@inbox_ids = if params[:inbox_id]
|
|
@current_user.assigned_inboxes.where(id: params[:inbox_id])
|
|
else
|
|
@current_user.assigned_inboxes.pluck(:id)
|
|
end
|
|
end
|
|
|
|
def set_assignee_type
|
|
@assignee_type = params[:assignee_type]
|
|
end
|
|
|
|
def set_team
|
|
@team = current_account.teams.find(params[:team_id]) if params[:team_id]
|
|
end
|
|
|
|
def find_all_conversations
|
|
@conversations = current_account.conversations.where(inbox_id: @inbox_ids)
|
|
filter_by_conversation_type if params[:conversation_type]
|
|
@conversations
|
|
end
|
|
|
|
def filter_by_assignee_type
|
|
case @assignee_type
|
|
when 'me'
|
|
@conversations = @conversations.assigned_to(current_user)
|
|
when 'unassigned'
|
|
@conversations = @conversations.unassigned
|
|
when 'assigned'
|
|
@conversations = @conversations.assigned
|
|
end
|
|
@conversations
|
|
end
|
|
|
|
def filter_by_conversation_type
|
|
case @params[:conversation_type]
|
|
when 'mention'
|
|
conversation_ids = current_account.mentions.where(user: current_user).pluck(:conversation_id)
|
|
@conversations = @conversations.where(id: conversation_ids)
|
|
when 'unattended'
|
|
@conversations = @conversations.where(first_reply_created_at: nil)
|
|
end
|
|
@conversations
|
|
end
|
|
|
|
def filter_by_query
|
|
allowed_message_types = [Message.message_types[:incoming], Message.message_types[:outgoing]]
|
|
@conversations = conversations.joins(:messages).where('messages.content ILIKE :search', search: "%#{params[:q]}%")
|
|
.where(messages: { message_type: allowed_message_types }).includes(:messages)
|
|
.where('messages.content ILIKE :search', search: "%#{params[:q]}%")
|
|
.where(messages: { message_type: allowed_message_types })
|
|
end
|
|
|
|
def filter_by_status
|
|
return if params[:status] == 'all'
|
|
|
|
@conversations = @conversations.where(status: params[:status] || DEFAULT_STATUS)
|
|
end
|
|
|
|
def filter_by_team
|
|
@conversations = @conversations.where(team: @team)
|
|
end
|
|
|
|
def filter_by_labels
|
|
@conversations = @conversations.tagged_with(params[:labels], any: true)
|
|
end
|
|
|
|
def set_count_for_all_conversations
|
|
[
|
|
@conversations.assigned_to(current_user).count,
|
|
@conversations.unassigned.count,
|
|
@conversations.count
|
|
]
|
|
end
|
|
|
|
def current_page
|
|
params[:page] || 1
|
|
end
|
|
|
|
def conversations
|
|
@conversations = @conversations.includes(
|
|
:taggings, :inbox, { assignee: { avatar_attachment: [:blob] } }, { contact: { avatar_attachment: [:blob] } }, :team, :contact_inbox
|
|
)
|
|
sort_by = SORT_OPTIONS[params[:sort_by]] || SORT_OPTIONS['latest']
|
|
@conversations.send(sort_by).page(current_page)
|
|
end
|
|
end
|