02f70ff611
Rename consolidate_contact to consolidate_presence_contact in PresenceUpdate to avoid overriding the 3-arg version from GroupContactMessageHandler when both modules are mixed into IncomingMessageBaileysService. Fix CSAT spec side effects where conversation callbacks triggered ActivityMessageJob unexpectedly during test setup.
73 lines
2.2 KiB
Ruby
73 lines
2.2 KiB
Ruby
module Whatsapp::BaileysHandlers::PresenceUpdate
|
|
include Events::Types
|
|
|
|
private
|
|
|
|
def process_presence_update
|
|
data = processed_params[:data]
|
|
return if data[:id].blank? || data[:id].include?('@g.us')
|
|
|
|
lid, phone = extract_presence_identifiers(data)
|
|
consolidate_presence_contact(lid, phone) if lid && phone
|
|
|
|
data[:presences]&.each_value do |presence_data|
|
|
handle_presence(lid, phone, presence_data)
|
|
end
|
|
end
|
|
|
|
def extract_presence_identifiers(data)
|
|
jid = data[:id]
|
|
lid = extract_jid_user(jid) if jid&.include?('@lid')
|
|
phone = extract_jid_user(jid) if jid&.include?('@s.whatsapp.net')
|
|
phone ||= extract_jid_user(data[:jidAlt]) if data[:jidAlt].present?
|
|
[lid, phone]
|
|
end
|
|
|
|
def handle_presence(lid, phone, presence_data)
|
|
event = presence_event(presence_data[:lastKnownPresence])
|
|
return unless event
|
|
|
|
contact_inbox = find_presence_contact_inbox(lid, phone)
|
|
return unless contact_inbox
|
|
|
|
conversation = inbox.conversations.where(contact_id: contact_inbox.contact_id).where.not(status: :resolved).last
|
|
return unless conversation
|
|
|
|
Rails.configuration.dispatcher.dispatch(event, Time.zone.now, conversation: conversation, user: contact_inbox.contact, is_private: false)
|
|
end
|
|
|
|
def find_presence_contact_inbox(lid, phone)
|
|
contact_inbox = inbox.contact_inboxes.find_by(source_id: lid) if lid
|
|
contact_inbox ||= inbox.contact_inboxes.find_by(source_id: phone) if phone
|
|
contact_inbox ||= find_contact_inbox_by_phone(phone) if phone
|
|
contact_inbox
|
|
end
|
|
|
|
def find_contact_inbox_by_phone(phone)
|
|
contact = inbox.contacts.find_by(phone_number: "+#{phone}")
|
|
return unless contact
|
|
|
|
inbox.contact_inboxes.find_by(contact_id: contact.id)
|
|
end
|
|
|
|
def consolidate_presence_contact(lid, phone)
|
|
Whatsapp::ContactInboxConsolidationService.new(
|
|
inbox: inbox, phone: phone, lid: lid, identifier: "#{lid}@lid"
|
|
).perform
|
|
end
|
|
|
|
def extract_jid_user(jid)
|
|
return unless jid
|
|
|
|
jid.split('@').first.split(':').first
|
|
end
|
|
|
|
def presence_event(status)
|
|
case status
|
|
when 'composing' then CONVERSATION_TYPING_ON
|
|
when 'recording' then CONVERSATION_RECORDING
|
|
when 'paused', 'unavailable', 'available' then CONVERSATION_TYPING_OFF
|
|
end
|
|
end
|
|
end
|