4fc80ba4ee
* feat(zapi): connect flow and UI updates * fix(zapi): re-add manage connection section * feat(zapi): reply * feat: send message * fix: qrcode job logic * test: qr code job specs * chore: concurrent index * chore: whatsapp model minor * test: message window service specs * chore: service refactor * test: zapi service * chore: zapi beta * chore: minor fixes * test: incoming message specs * chore: minor fixes * feat: handle status transitions * test: refactor spec * test: refactor spec * chore(z-api): use feature flag * chore: fix migration name
29 lines
721 B
Ruby
29 lines
721 B
Ruby
module Whatsapp::ZapiHandlers::Helpers
|
|
include Whatsapp::IncomingMessageServiceHelpers
|
|
|
|
private
|
|
|
|
def raw_message_id
|
|
@raw_message[:isEdit] ? @raw_message[:editMessageId] : @raw_message[:messageId]
|
|
end
|
|
|
|
def incoming_message?
|
|
!@raw_message[:fromMe]
|
|
end
|
|
|
|
def cache_message_source_id_in_redis
|
|
key = format(Redis::RedisKeys::MESSAGE_SOURCE_KEY, id: raw_message_id)
|
|
Redis::Alfred.setex(key, true)
|
|
end
|
|
|
|
def clear_message_source_id_from_redis
|
|
key = format(Redis::RedisKeys::MESSAGE_SOURCE_KEY, id: raw_message_id)
|
|
Redis::Alfred.delete(key)
|
|
end
|
|
|
|
def message_under_process?
|
|
key = format(Redis::RedisKeys::MESSAGE_SOURCE_KEY, id: raw_message_id)
|
|
Redis::Alfred.get(key)
|
|
end
|
|
end
|