mirror of
https://github.com/lingble/chatwoot.git
synced 2025-11-01 19:48:08 +00:00
87313ecc35
- Add 2-second delay to Facebook Messenger echo event processing to prevent race condition - Add 2-second delay to Instagram echo event processing for consistency - Prevent duplicate messages when echo events arrive before send message API completes processing --------- Co-authored-by: Sojan Jose <sojan@pepalo.com>
47 lines
1.4 KiB
Ruby
47 lines
1.4 KiB
Ruby
# ref: https://github.com/jgorset/facebook-messenger#make-a-configuration-provider
|
|
class ChatwootFbProvider < Facebook::Messenger::Configuration::Providers::Base
|
|
def valid_verify_token?(_verify_token)
|
|
GlobalConfigService.load('FB_VERIFY_TOKEN', '')
|
|
end
|
|
|
|
def app_secret_for(_page_id)
|
|
GlobalConfigService.load('FB_APP_SECRET', '')
|
|
end
|
|
|
|
def access_token_for(page_id)
|
|
Channel::FacebookPage.where(page_id: page_id).last.page_access_token
|
|
end
|
|
|
|
private
|
|
|
|
def bot
|
|
Chatwoot::Bot
|
|
end
|
|
end
|
|
|
|
Rails.application.reloader.to_prepare do
|
|
Facebook::Messenger.configure do |config|
|
|
config.provider = ChatwootFbProvider.new
|
|
end
|
|
|
|
Facebook::Messenger::Bot.on :message do |message|
|
|
Webhooks::FacebookEventsJob.perform_later(message.to_json)
|
|
end
|
|
|
|
Facebook::Messenger::Bot.on :delivery do |delivery|
|
|
Rails.logger.info "Recieved delivery status #{delivery.to_json}"
|
|
Webhooks::FacebookDeliveryJob.perform_later(delivery.to_json)
|
|
end
|
|
|
|
Facebook::Messenger::Bot.on :read do |read|
|
|
Rails.logger.info "Recieved read status #{read.to_json}"
|
|
Webhooks::FacebookDeliveryJob.perform_later(read.to_json)
|
|
end
|
|
|
|
Facebook::Messenger::Bot.on :message_echo do |message|
|
|
# Add delay to prevent race condition where echo arrives before send message API completes
|
|
# This avoids duplicate messages when echo comes early during API processing
|
|
Webhooks::FacebookEventsJob.set(wait: 2.seconds).perform_later(message.to_json)
|
|
end
|
|
end
|