KumiSystems/Chatwoot
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix: whatsapp cloud to consider multiple attachments

Browse source
This commit is contained in:
Tejaswini Chile 2022-12-22 18:43:49 +05:30
parent 34f7405689
commit a356c824d0
1 changed files with 22 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
app/services/whatsapp/providers/whatsapp_cloud_service.rb
View file

@ -1,4 +1,7 @@
class Whatsapp::Providers::WhatsappCloudService < Whatsapp::Providers::BaseService
ATTACHMENT_TYPE = [image, audio, video].freeze
MESSAGE_CONTENT = [audio, sticker].freeze
def send_message(phone_number, message)
if message.attachments.present?
send_attachment_message(phone_number, message)
@ -67,25 +70,26 @@ class Whatsapp::Providers::WhatsappCloudService < Whatsapp::Providers::BaseServi
end
def send_attachment_message(phone_number, message)
attachment = message.attachments.first
type = %w[image audio video].include?(attachment.file_type) ? attachment.file_type : 'document'
type_content = {
'link': attachment.download_url
}
type_content['caption'] = message.content unless %w[audio sticker].include?(type)
type_content['filename'] = attachment.file.filename if type == 'document'
response = HTTParty.post(
"#{phone_id_path}/messages",
headers: api_headers,
body: {
messaging_product: 'whatsapp',
'to' => phone_number,
'type' => type,
type.to_s => type_content
}.to_json
)
message.attachments.each do |attachment|
type = ATTACHMENT_TYPE.include?(attachment.file_type) ? attachment.file_type : 'document'
type_content = {
'link': attachment.download_url
}
type_content['caption'] = message.content unless MESSAGE_CONTENT.include?(type)
type_content['filename'] = attachment.file.filename if type == 'document'
response = HTTParty.post(
"#{phone_id_path}/messages",
headers: api_headers,
body: {
messaging_product: 'whatsapp',
'to' => phone_number,
'type' => type,
type.to_s => type_content
}.to_json
)
process_response(response)
process_response(response)
end
end
def process_response(response)