require "base32" class Message < ApplicationRecord belongs_to :sender, class_name: 'User', foreign_key: 'sender_id' belongs_to :group, optional: true, class_name: 'Group', foreign_key: 'group_id' belongs_to :reply_to_message, optional: true, class_name: 'Message', foreign_key: 'reply_to' has_many :message_recipients, dependent: :destroy has_many :recipients, through: :message_recipients, source: :user attr_accessor :send_method, :recipient_tokens, :order_id scope :threads, -> { where(:reply_to => nil) } scope :thread, ->(id) { where("id = ? OR reply_to = ?", id, id) } scope :readable_for, ->(user) { user_id = user.try(&:id) joins(:message_recipients) .where('private = ? OR sender_id = ? OR message_recipients.user_id = ?', false, user_id, user_id) .distinct } validates_presence_of :message_recipients, :subject, :body validates_length_of :subject, :in => 1..255 after_initialize do @recipients_ids ||= [] @send_method ||= 'recipients' end before_create :create_salt before_validation :create_message_recipients, on: :create def create_message_recipients user_ids = @recipients_ids user_ids += User.undeleted.pluck(:id) if send_method == 'all' user_ids += Group.find(group_id).users.pluck(:id) unless group_id.blank? user_ids += Order.find(order_id).users_ordered.pluck(:id) if send_method == 'order' user_ids.uniq.each do |user_id| recipient = MessageRecipient.new message: self, user_id: user_id message_recipients << recipient end end def add_recipients(users) @recipients_ids += users end def group_id=(group_id) group = Group.find(group_id) unless group_id.blank? if group @send_method = 'workgroup' if group.type == 'Workgroup' @send_method = 'ordergroup' if group.type == 'Ordergroup' @send_method = 'messagegroup' if group.type == 'Messagegroup' end super end def workgroup_id group_id if send_method == 'workgroup' end def ordergroup_id group_id if send_method == 'ordergroup' end def messagegroup_id group_id if send_method == 'messagegroup' end def workgroup_id=(workgroup_id) self.group_id = workgroup_id if send_method == 'workgroup' end def ordergroup_id=(ordergroup_id) self.group_id = ordergroup_id if send_method == 'ordergroup' end def messagegroup_id=(messagegroup_id) self.group_id = messagegroup_id if send_method == 'messagegroup' end def order_id=(order_id) @order_id = order_id @send_method ||= 'order' end def recipient_tokens=(ids) @recipient_tokens = ids @recipients_ids = ids.split(',').map(&:to_i) end def mail_to=(user_id) @recipients_ids = [user_id] end def mail_hash_for_user(user) digest = Digest::SHA1.new digest.update self.id.to_s digest.update ":" digest.update salt digest.update ":" digest.update user.id.to_s Base32.encode digest.digest end # Returns true if this message is a system message, i.e. was sent automatically by Foodsoft itself. def system_message? self.sender_id.nil? end def sender_name system_message? ? I18n.t('layouts.foodsoft') : sender.display rescue "?" end def recipients_ids @recipients_ids end def last_reply Message.where(reply_to: self.id).order(:created_at).last end def is_readable_for?(user) !private || sender == user || message_recipients.where(user: user).any? end def can_toggle_private?(user) return true if sender == user return false if private? user.role_admin? end def render_markdown markdown = Redcarpet::Markdown.new(Redcarpet::Render::HTML, autolink: true, tables: true, strikethrough: true, footnotes: true) return markdown.render(body) end private def create_salt self.salt = [Array.new(6) { rand(256).chr }.join].pack("m").chomp end end