Specs: Add specs for Facebook::SendReplyService (#396)
This commit is contained in:
parent
790877c056
commit
e2aeeeca43
4 changed files with 115 additions and 56 deletions
|
@ -1,68 +1,66 @@
|
|||
module Facebook
|
||||
class SendReplyService
|
||||
pattr_initialize [:message!]
|
||||
class Facebook::SendReplyService
|
||||
pattr_initialize [:message!]
|
||||
|
||||
def perform
|
||||
return if message.private
|
||||
return if inbox.channel.class.to_s != 'Channel::FacebookPage'
|
||||
return unless outgoing_message_from_chatwoot?
|
||||
def perform
|
||||
return if message.private
|
||||
return if inbox.channel.class.to_s != 'Channel::FacebookPage'
|
||||
return unless outgoing_message_from_chatwoot?
|
||||
|
||||
Bot.deliver(delivery_params, access_token: message.channel_token)
|
||||
end
|
||||
Bot.deliver(delivery_params, access_token: message.channel_token)
|
||||
end
|
||||
|
||||
private
|
||||
private
|
||||
|
||||
delegate :contact, to: :conversation
|
||||
delegate :contact, to: :conversation
|
||||
|
||||
def inbox
|
||||
@inbox ||= message.inbox
|
||||
end
|
||||
def inbox
|
||||
@inbox ||= message.inbox
|
||||
end
|
||||
|
||||
def conversation
|
||||
@conversation ||= message.conversation
|
||||
end
|
||||
def conversation
|
||||
@conversation ||= message.conversation
|
||||
end
|
||||
|
||||
def outgoing_message_from_chatwoot?
|
||||
# messages sent directly from chatwoot won't have fb_id.
|
||||
message.outgoing? && !message.fb_id
|
||||
end
|
||||
def outgoing_message_from_chatwoot?
|
||||
# messages sent directly from chatwoot won't have fb_id.
|
||||
message.outgoing? && !message.fb_id
|
||||
end
|
||||
|
||||
# def reopen_lock
|
||||
# if message.incoming? && conversation.locked?
|
||||
# conversation.unlock!
|
||||
# end
|
||||
# end
|
||||
# def reopen_lock
|
||||
# if message.incoming? && conversation.locked?
|
||||
# conversation.unlock!
|
||||
# end
|
||||
# end
|
||||
|
||||
def fb_message_params
|
||||
{
|
||||
recipient: { id: contact.get_source_id(inbox.id) },
|
||||
message: { text: message.content }
|
||||
}
|
||||
end
|
||||
def fb_message_params
|
||||
{
|
||||
recipient: { id: contact.get_source_id(inbox.id) },
|
||||
message: { text: message.content }
|
||||
}
|
||||
end
|
||||
|
||||
def delivery_params
|
||||
if twenty_four_hour_window_over?
|
||||
fb_message_params.merge(tag: 'ISSUE_RESOLUTION')
|
||||
else
|
||||
fb_message_params
|
||||
end
|
||||
end
|
||||
|
||||
def twenty_four_hour_window_over?
|
||||
last_incoming_message = conversation.messages.incoming.last
|
||||
|
||||
is_after_24_hours = (Time.current - last_incoming_message.created_at) / 3600 >= 24
|
||||
|
||||
return false unless is_after_24_hours
|
||||
|
||||
return false if last_incoming_message && sent_first_outgoing_message_after_24_hours?(last_incoming_message.id)
|
||||
|
||||
true
|
||||
end
|
||||
|
||||
def sent_first_outgoing_message_after_24_hours?(last_incoming_message_id)
|
||||
# we can send max 1 message after 24 hour window
|
||||
conversation.messages.outgoing.where('id > ?', last_incoming_message_id).count == 1
|
||||
def delivery_params
|
||||
if twenty_four_hour_window_over?
|
||||
fb_message_params.merge(tag: 'ISSUE_RESOLUTION')
|
||||
else
|
||||
fb_message_params
|
||||
end
|
||||
end
|
||||
|
||||
def twenty_four_hour_window_over?
|
||||
last_incoming_message = conversation.messages.incoming.last
|
||||
|
||||
is_after_24_hours = (Time.current - last_incoming_message.created_at) / 3600 >= 24
|
||||
|
||||
return false unless is_after_24_hours
|
||||
|
||||
return false if last_incoming_message && sent_first_outgoing_message_after_24_hours?(last_incoming_message.id)
|
||||
|
||||
true
|
||||
end
|
||||
|
||||
def sent_first_outgoing_message_after_24_hours?(last_incoming_message_id)
|
||||
# we can send max 1 message after 24 hour window
|
||||
conversation.messages.outgoing.where('id > ?', last_incoming_message_id).count == 1
|
||||
end
|
||||
end
|
||||
|
|
11
spec/factories/facebook_page.rb
Normal file
11
spec/factories/facebook_page.rb
Normal file
|
@ -0,0 +1,11 @@
|
|||
# frozen_string_literal: true
|
||||
|
||||
FactoryBot.define do
|
||||
factory :facebook_page, class: 'Channel::FacebookPage' do
|
||||
sequence(:page_id) { |n| n }
|
||||
sequence(:user_access_token) { |n| "random-token-#{n}" }
|
||||
sequence(:name) { |n| "Facebook Page #{n}" }
|
||||
sequence(:page_access_token) { |n| "page-access-token-#{n}" }
|
||||
account
|
||||
end
|
||||
end
|
|
@ -5,7 +5,6 @@ FactoryBot.define do
|
|||
content { 'Message' }
|
||||
status { 'sent' }
|
||||
message_type { 'incoming' }
|
||||
fb_id { SecureRandom.uuid }
|
||||
account
|
||||
inbox
|
||||
conversation
|
||||
|
|
51
spec/services/facebook/send_reply_service_spec.rb
Normal file
51
spec/services/facebook/send_reply_service_spec.rb
Normal file
|
@ -0,0 +1,51 @@
|
|||
require 'rails_helper'
|
||||
|
||||
describe Facebook::SendReplyService do
|
||||
subject(:send_reply_service) { described_class.new(message: message) }
|
||||
|
||||
before do
|
||||
allow(Facebook::Messenger::Subscriptions).to receive(:subscribe).and_return(true)
|
||||
allow(bot).to receive(:deliver)
|
||||
end
|
||||
|
||||
let!(:account) { create(:account) }
|
||||
let(:bot) { class_double('Bot').as_stubbed_const }
|
||||
let!(:widget_inbox) { create(:inbox, account: account) }
|
||||
let!(:facebook_channel) { create(:facebook_page, account: account) }
|
||||
let!(:facebook_inbox) { create(:inbox, channel: facebook_channel, account: account) }
|
||||
let!(:contact) { create(:contact, account: account) }
|
||||
let(:conversation) { create(:conversation, contact: contact, inbox: facebook_inbox) }
|
||||
|
||||
describe '#perform' do
|
||||
context 'without reply' do
|
||||
it 'if message is private' do
|
||||
create(:message, message_type: 'outgoing', private: true, inbox: facebook_inbox, account: account)
|
||||
expect(bot).not_to have_received(:deliver)
|
||||
end
|
||||
|
||||
it 'if inbox channel is not facebook page' do
|
||||
create(:message, message_type: 'outgoing', inbox: widget_inbox, account: account)
|
||||
expect(bot).not_to have_received(:deliver)
|
||||
end
|
||||
|
||||
it 'if message is not outgoing' do
|
||||
create(:message, message_type: 'incoming', inbox: facebook_inbox, account: account)
|
||||
expect(bot).not_to have_received(:deliver)
|
||||
end
|
||||
|
||||
it 'if message has an FB ID' do
|
||||
create(:message, message_type: 'outgoing', inbox: facebook_inbox, account: account, fb_id: SecureRandom.uuid)
|
||||
expect(bot).not_to have_received(:deliver)
|
||||
end
|
||||
end
|
||||
|
||||
context 'with reply' do
|
||||
it 'if message is sent from chatwoot and is outgoing' do
|
||||
create(:contact_inbox, contact: contact, inbox: facebook_inbox)
|
||||
create(:message, message_type: :incoming, inbox: facebook_inbox, account: account, conversation: conversation)
|
||||
create(:message, message_type: 'outgoing', inbox: facebook_inbox, account: account, conversation: conversation)
|
||||
expect(bot).to have_received(:deliver)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
Loading…
Reference in a new issue