d355801555
In this PR https://github.com/chatwoot/chatwoot/pull/11139, if there is an attempt to create a duplication session for the contact in the same inbox, we will anonymize the old session. This PR would prevent sending messages to the older sessions. The support agents will have to create a new conversation to continue messages with customer.
113 lines
5.4 KiB
Ruby
113 lines
5.4 KiB
Ruby
require 'rails_helper'
|
|
|
|
describe Twilio::SendOnTwilioService do
|
|
subject(:outgoing_message_service) { described_class.new(message: message) }
|
|
|
|
let(:twilio_client) { instance_double(Twilio::REST::Client) }
|
|
let(:messages_double) { double }
|
|
let(:message_record_double) { double }
|
|
|
|
let!(:account) { create(:account) }
|
|
let!(:widget_inbox) { create(:inbox, account: account) }
|
|
let!(:twilio_sms) { create(:channel_twilio_sms, account: account) }
|
|
let!(:twilio_whatsapp) { create(:channel_twilio_sms, medium: :whatsapp, account: account) }
|
|
let!(:twilio_inbox) { create(:inbox, channel: twilio_sms, account: account) }
|
|
let!(:twilio_whatsapp_inbox) { create(:inbox, channel: twilio_whatsapp, account: account) }
|
|
let!(:contact) { create(:contact, account: account, phone_number: '+123456789') }
|
|
let(:contact_inbox) { create(:contact_inbox, contact: contact, inbox: twilio_inbox, source_id: '+123456789') }
|
|
let(:whatsapp_contact_inbox) { create(:contact_inbox, contact: contact, inbox: twilio_whatsapp_inbox, source_id: 'whatsapp:+123456789') }
|
|
let(:conversation) { create(:conversation, contact: contact, inbox: twilio_inbox, contact_inbox: contact_inbox) }
|
|
let(:whatsapp_conversation) { create(:conversation, contact: contact, inbox: twilio_whatsapp_inbox, contact_inbox: whatsapp_contact_inbox) }
|
|
|
|
before do
|
|
allow(Twilio::REST::Client).to receive(:new).and_return(twilio_client)
|
|
allow(twilio_client).to receive(:messages).and_return(messages_double)
|
|
end
|
|
|
|
describe '#perform' do
|
|
context 'without reply' do
|
|
it 'if message is private' do
|
|
message = create(:message, message_type: 'outgoing', private: true, inbox: twilio_inbox, account: account)
|
|
described_class.new(message: message).perform
|
|
expect(twilio_client).not_to have_received(:messages)
|
|
expect(message.reload.source_id).to be_nil
|
|
end
|
|
|
|
it 'if inbox channel is not twilio' do
|
|
message = create(:message, message_type: 'outgoing', inbox: widget_inbox, account: account)
|
|
expect { described_class.new(message: message).perform }.to raise_error 'Invalid channel service was called'
|
|
expect(twilio_client).not_to have_received(:messages)
|
|
end
|
|
|
|
it 'if message is not outgoing' do
|
|
message = create(:message, message_type: 'incoming', inbox: twilio_inbox, account: account)
|
|
described_class.new(message: message).perform
|
|
expect(twilio_client).not_to have_received(:messages)
|
|
expect(message.reload.source_id).to be_nil
|
|
end
|
|
|
|
it 'if message has an source id' do
|
|
message = create(:message, message_type: 'outgoing', inbox: twilio_inbox, account: account, source_id: SecureRandom.uuid)
|
|
described_class.new(message: message).perform
|
|
expect(twilio_client).not_to have_received(:messages)
|
|
end
|
|
end
|
|
|
|
context 'with reply' do
|
|
it 'if message is sent from chatwoot and is outgoing' do
|
|
allow(messages_double).to receive(:create).and_return(message_record_double)
|
|
allow(message_record_double).to receive(:sid).and_return('1234')
|
|
|
|
outgoing_message = create(
|
|
:message, message_type: 'outgoing', inbox: twilio_inbox, account: account, conversation: conversation
|
|
)
|
|
described_class.new(message: outgoing_message).perform
|
|
|
|
expect(outgoing_message.reload.source_id).to eq('1234')
|
|
end
|
|
end
|
|
|
|
it 'if outgoing message has attachment and is for whatsapp' do
|
|
# check for message attachment url
|
|
allow(messages_double).to receive(:create).with(hash_including(media_url: [anything])).and_return(message_record_double)
|
|
allow(message_record_double).to receive(:sid).and_return('1234')
|
|
|
|
message = build(
|
|
:message, message_type: 'outgoing', inbox: twilio_whatsapp_inbox, account: account, conversation: whatsapp_conversation
|
|
)
|
|
attachment = message.attachments.new(account_id: message.account_id, file_type: :image)
|
|
attachment.file.attach(io: Rails.root.join('spec/assets/avatar.png').open, filename: 'avatar.png', content_type: 'image/png')
|
|
message.save!
|
|
|
|
described_class.new(message: message).perform
|
|
expect(messages_double).to have_received(:create).with(hash_including(media_url: [anything]))
|
|
end
|
|
|
|
it 'if outgoing message has attachment and is for sms' do
|
|
# check for message attachment url
|
|
allow(messages_double).to receive(:create).with(hash_including(media_url: [anything])).and_return(message_record_double)
|
|
allow(message_record_double).to receive(:sid).and_return('1234')
|
|
|
|
message = build(
|
|
:message, message_type: 'outgoing', inbox: twilio_inbox, account: account, conversation: conversation
|
|
)
|
|
attachment = message.attachments.new(account_id: message.account_id, file_type: :image)
|
|
attachment.file.attach(io: Rails.root.join('spec/assets/avatar.png').open, filename: 'avatar.png', content_type: 'image/png')
|
|
message.save!
|
|
|
|
described_class.new(message: message).perform
|
|
expect(messages_double).to have_received(:create).with(hash_including(media_url: [anything]))
|
|
end
|
|
|
|
it 'if message is sent from chatwoot fails' do
|
|
allow(messages_double).to receive(:create).and_raise(Twilio::REST::TwilioError)
|
|
|
|
outgoing_message = create(
|
|
:message, message_type: 'outgoing', inbox: twilio_inbox, account: account, conversation: conversation
|
|
)
|
|
described_class.new(message: outgoing_message).perform
|
|
expect(outgoing_message.reload.status).to eq('failed')
|
|
end
|
|
end
|
|
end
|