Readme and initial changes

3 files changed, 157 insertions, 0 deletions

diff --git a/app/models/discussion.rb b/app/models/discussion.rb
new file mode 100644
index 0000000..474ad00
--- /dev/null
+++ b/app/models/discussion.rb
@@ -0,0 +1,118 @@
+
+class Discussion < ActiveRecord::Base
+  attr_accessor :recipient_tokens, :recipient_ids
+  attr_reader :recipient_ids
+
+  # paginates_per 10
+
+  # создатель
+  has_many :messages, :dependent => :destroy
+
+  # участники
+  has_many :speakers, :dependent => :destroy
+  has_many :users, :through => :speakers
+
+  # отметки о прочтении юзеров
+  # has_many :views, :dependent => :destroy, :class_name => "DiscussionView"
+
+  # жутко неоптимизированная часть, возможны баги
+  # scope :unread_for, lambda { |user_or_user_id| joins(:views, :speakers).where("discussions.updated_at >= discussion_views.updated_at AND speakers.user_id = ?", user_or_user_id.is_a?(User) ? user_or_user_id.id : user_or_user_id ) }
+
+  accepts_nested_attributes_for :messages
+
+  validate :check_that_has_at_least_two_users # не даем создать дискуссию, у которой нет получателей
+
+  # добавляем записи об указанных собеседников
+  after_save(:on => :create) do
+    Rails.logger.info("Repicients ids: #{recipient_ids.inspect}")
+
+    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)
+  end
+
+  def remove_speaker(user)
+    speaker = find_speaker_by_user(user)
+    speaker.destroy if speaker
+  end
+
+  def user_invited_at(user)
+    speaker = find_speaker_by_user(user)
+    speaker.created_at
+  end
+
+  def can_participate?(user)
+    speaker = find_speaker_by_user(user)
+    speaker ? true : false
+  end
+
+  # проверяет, есть ли уже беседа между пользователями
+  # TODO вынести в отдельный метод а в этом возращать true/false, а то неправославно как-то
+  def self.find_between_users(user, user2)
+    res = 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|
+
+      res = discussion if discussion.private? && ((discussion.users.first == user && discussion.users.last == user2) || (discussion.users.first == user2 && discussion.users.last == user))
+      Rails.logger.info "Searching for ids: #{discussion.users.inspect}" if discussion.private?
+    end
+    res
+  end
+
+  # приватная/групповая
+  def private?
+    self.users.size <= 2
+  end
+
+  # дата последнего сообщения в дискуссии
+  def last_message_at
+    self.messages.last ? self.messages.last.created_at : nil
+  end
+
+  # проверка, является ли дискуссия непрочитанной для пользователя
+  # def unread_for?(user)
+  #   flag = self.views.find_by_user_id(user.id)
+  #   if flag
+  #     self.updated_at >= flag.updated_at
+  #   else
+  #     true
+  #   end
+  # end
+
+  # пометить как прочитанная
+  def mark_as_read_for(user)
+    true
+  #   flag = DiscussionView.find_or_create_by_user_id_and_discussion_id(user.id, self.id)
+  #   flag.touch
+  end
+
+  private
+
+  def find_speaker_by_user user
+    Speaker.find_by_discussion_id_and_user_id!(self.id, user.id)
+  end
+
+  def check_that_has_at_least_two_users
+    Rails.logger.info self.recipient_ids
+    errors.add :recipient_tokens, "Укажите хотя бы одного получателя" #if !self.recipient_ids || self.recipient_ids.size < 2
+  end
+
+end
\ No newline at end of file
diff --git a/app/models/message.rb b/app/models/message.rb
new file mode 100644
index 0000000..a38dfb0
--- /dev/null
+++ b/app/models/message.rb
@@ -0,0 +1,22 @@
+class Message < ActiveRecord::Base
+
+  default_scope order(:created_at)
+  
+  belongs_to :discussion, :counter_cache => true
+  belongs_to :user
+  
+  validates :user, :discussion, :body, :presence => true
+  
+  # after_save :touch_discussion_and_mark_as_read
+  
+  # def visible_for? user
+  #   self.created_at.to_i >= self.discussion.user_invited_at(user).to_i
+  # end
+  
+  private
+  
+  def touch_discussion_and_mark_as_read
+    self.discussion.touch
+    # self.discussion.mark_as_read_for(self.user)
+  end
+end
diff --git a/app/models/speaker.rb b/app/models/speaker.rb
new file mode 100644
index 0000000..6105220
--- /dev/null
+++ b/app/models/speaker.rb
@@ -0,0 +1,17 @@
+class Speaker < ActiveRecord::Base
+  belongs_to :user
+  belongs_to :discussion
+  
+  validates_uniqueness_of :user_id, :scope => :discussion_id
+  validates :user, :discussion, :presence => true
+  
+  after_destroy :destroy_discussion_view
+  
+  private
+  
+  def destroy_discussion_view
+    @view = DiscussionView.find_by_user_id_and_discussion_id(self.user_id, self.discussion_id)
+    @view.destroy if @view
+  end
+  
+end