Chatwoot/app/jobs/send_reply_job.rb

35 lines
1.1 KiB
Ruby
Raw Normal View History

class SendReplyJob < ApplicationJob
queue_as :high
def perform(message_id)
message = Message.find(message_id)
2021-10-05 09:05:32 +00:00
conversation = message.conversation
channel_name = conversation.inbox.channel.class.to_s
2020-09-08 05:54:08 +00:00
case channel_name
when 'Channel::FacebookPage'
send_on_facebook_page(message)
2020-09-08 05:54:08 +00:00
when 'Channel::TwitterProfile'
::Twitter::SendOnTwitterService.new(message: message).perform
2020-09-08 05:54:08 +00:00
when 'Channel::TwilioSms'
::Twilio::SendOnTwilioService.new(message: message).perform
when 'Channel::Line'
::Line::SendOnLineService.new(message: message).perform
when 'Channel::Telegram'
::Telegram::SendOnTelegramService.new(message: message).perform
when 'Channel::Whatsapp'
::Whatsapp::SendOnWhatsappService.new(message: message).perform
end
end
private
def send_on_facebook_page(message)
if message.conversation.additional_attributes['type'] == 'instagram_direct_message'
::Instagram::SendOnInstagramService.new(message: message).perform
else
::Facebook::SendOnFacebookService.new(message: message).perform
end
end
end