4768aca484
* Add Conversation factory with dependent factories * Include FactoryBot methods in rspec config * Add unit tests for public methods of Conversation model * Move Current model into a separate file in lib folder * Disable Metrics/BlockLength rule for db/migrate and spec folders * Get rid of global $dispatcher variable * Create Message#unread_since scope * Refactor callback methods in Conversation model * Create Conversations::EventDataPresenter * Add translation keys for activity messages * Add pry-rails gem * Refactor Conversation#notify_status_change * Add mock_redis for test env
64 lines
2 KiB
Ruby
64 lines
2 KiB
Ruby
class Message < ApplicationRecord
|
|
include Events::Types
|
|
|
|
validates :account_id, presence: true
|
|
validates :inbox_id, presence: true
|
|
validates :conversation_id, presence: true
|
|
|
|
enum message_type: [ :incoming, :outgoing, :activity ]
|
|
enum status: [ :sent, :delivered, :read, :failed ]
|
|
|
|
# .succ is a hack to avoid https://makandracards.com/makandra/1057-why-two-ruby-time-objects-are-not-equal-although-they-appear-to-be
|
|
scope :unread_since, ->(datetime) { where('EXTRACT(EPOCH FROM created_at) > (?)', datetime.to_i.succ) }
|
|
scope :chat, -> { where.not(message_type: :activity, private: true) }
|
|
default_scope { order(created_at: :asc) }
|
|
|
|
belongs_to :account
|
|
belongs_to :inbox
|
|
belongs_to :conversation
|
|
belongs_to :user, required: false
|
|
|
|
has_one :attachment, dependent: :destroy, autosave: true
|
|
|
|
after_create :reopen_conversation,
|
|
:dispatch_event,
|
|
:send_reply
|
|
|
|
|
|
def channel_token
|
|
@token ||= inbox.channel.try(:page_access_token)
|
|
end
|
|
|
|
|
|
def push_event_data
|
|
data = attributes.merge(
|
|
created_at: created_at.to_i,
|
|
message_type: message_type_before_type_cast,
|
|
conversation_id: conversation.display_id
|
|
)
|
|
data.merge!(attachment: attachment.push_event_data) if self.attachment
|
|
data.merge!(sender: user.push_event_data) if self.user
|
|
data
|
|
end
|
|
|
|
private
|
|
|
|
def dispatch_event
|
|
Rails.configuration.dispatcher.dispatch(MESSAGE_CREATED, Time.zone.now, message: self) unless self.conversation.messages.count == 1
|
|
|
|
if outgoing? && self.conversation.messages.outgoing.count == 1
|
|
Rails.configuration.dispatcher.dispatch(FIRST_REPLY_CREATED, Time.zone.now, message: self)
|
|
end
|
|
end
|
|
|
|
def send_reply
|
|
::Facebook::SendReplyService.new(message: self).perform
|
|
end
|
|
|
|
def reopen_conversation
|
|
if incoming? && self.conversation.resolved?
|
|
self.conversation.toggle_status
|
|
Rails.configuration.dispatcher.dispatch(CONVERSATION_REOPENED, Time.zone.now, conversation: self.conversation)
|
|
end
|
|
end
|
|
end
|