1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
class Discussion < ActiveRecord::Base
attr_accessor :recipient_tokens, :recipient_ids
attr_reader :recipient_ids
# creater
has_many :messages, :dependent => :destroy
belongs_to :discussable, :polymorphic => true
# participants of discussion (speakers)
has_many :speakers, :dependent => :destroy
has_many :users, :through => :speakers
# marks about read/unread
scope :unread_for, (lambda do |user_or_user_id|
user = user_or_user_id.is_a?(User) ? user_or_user_id.id : user_or_user_id
joins(:speakers).where("discussions.updated_at >= speakers.updated_at AND speakers.user_id = ?", user)
end)
default_scope order('updated_at DESC')
accepts_nested_attributes_for :messages
validate :check_that_has_at_least_two_users # don't allow to create discussion, if there is no creator
# mark as read
after_save(:on => :create) do
if recipient_ids.kind_of?(Array)
recipient_ids.uniq!
recipient_ids.each do |id|
recipient = User.find(id)
add_speaker(recipient) if recipient
end
end
end
def recipient_tokens=(ids)
self.recipient_ids = ids
end
def add_recipient_token id
self.recipient_ids << id if self.recipient_ids
end
def add_speaker(user)
raise ArgumentError, "You can add speaker only to existing Discussion. Save your the Discussion object firstly" if new_record?
Speaker.create(:discussion => self, :user => user, :updated_at => self.updated_at)
end
def remove_speaker(user)
speaker = find_speaker_by_user(user)
speaker.destroy if speaker
end
def user_invited_at(user)
find_speaker_by_user(user).created_at
end
def can_participate?(user)
!!find_speaker_by_user(user)
end
# don't allow to create discussion with user, if discussion with this user already exists
# TODO move to separated method and return boolean value
def self.find_between_users(user, user2)
dialog = nil
discussions = self.joins(:speakers).includes(:users).where("speakers.user_id = ?", user.id)
Rails.logger.info "Searching for ids: #{user.id}, #{user2.id}"
discussions.each do |discussion|
dialog = discussion if discussion.private? && ([discussion.users.first, discussion.users.last] - [user, user2]).empty?
end
dialog
end
# private/group discussion
def private?
self.users.size <= 2
end
def unread_for?(user)
speaker = find_speaker_by_user(user)
if speaker
self.updated_at >= speaker.updated_at
else
true
end
end
# return amount of unreaded messages for current discussion
def unread_messages_count_for(user)
speaker = find_speaker_by_user(user)
messages.where("updated_at > ?", speaker.updated_at ).where("user_id != ?", speaker.id ).count
end
def mark_as_read_for(user)
speaker = Speaker.find_or_create_by_user_id_and_discussion_id(user.id, self.id)
speaker.touch
end
def find_speaker_by_user user
Speaker.find_by_discussion_id_and_user_id(self.id, user.id)
end
private
def check_that_has_at_least_two_users
errors.add :recipient_tokens, I18n.t("inboxes.discussions.choose_at_least_one_recipient") if !self.recipient_ids || self.recipient_ids.size < 2
end
end
|
