140 lines
5.3 KiB
Clojure
140 lines
5.3 KiB
Clojure
(ns legacy.status-im.data-store.messages
|
|
(:require
|
|
[clojure.set :as set]
|
|
[taoensso.timbre :as log]
|
|
[utils.re-frame :as rf]))
|
|
|
|
(defn ->rpc
|
|
[{:keys [content] :as message}]
|
|
(cond-> message
|
|
content
|
|
(assoc :text (:text content)
|
|
:sticker (:sticker content))
|
|
:always
|
|
(set/rename-keys {:chat-id :chat_id
|
|
:whisper-timestamp :whisperTimestamp
|
|
:community-id :communityId
|
|
:clock-value :clock})))
|
|
|
|
(defn- <-link-preview-rpc
|
|
[preview]
|
|
(update preview :thumbnail set/rename-keys {:dataUri :data-uri}))
|
|
|
|
(defn ->link-preview-rpc
|
|
[preview]
|
|
(update preview :thumbnail set/rename-keys {:data-uri :dataUri}))
|
|
|
|
(defn <-rpc
|
|
[message]
|
|
(-> message
|
|
(set/rename-keys
|
|
{:id :message-id
|
|
:whisperTimestamp :whisper-timestamp
|
|
:compressedKey :compressed-key
|
|
:editedAt :edited-at
|
|
:contactVerificationState :contact-verification-state
|
|
:contactRequestState :contact-request-state
|
|
:commandParameters :command-parameters
|
|
:gapParameters :gap-parameters
|
|
:messageType :message-type
|
|
:localChatId :chat-id
|
|
:communityId :community-id
|
|
:contentType :content-type
|
|
:clock :clock-value
|
|
:quotedMessage :quoted-message
|
|
:outgoingStatus :outgoing-status
|
|
:audioDurationMs :audio-duration-ms
|
|
:deleted :deleted?
|
|
:deletedForMe :deleted-for-me?
|
|
:deletedBy :deleted-by
|
|
:albumId :album-id
|
|
:imageWidth :image-width
|
|
:imageHeight :image-height
|
|
:new :new?
|
|
:albumImagesCount :album-images-count
|
|
:displayName :display-name
|
|
:linkPreviews :link-previews})
|
|
(update :link-previews #(map <-link-preview-rpc %))
|
|
(update :quoted-message
|
|
set/rename-keys
|
|
{:parsedText :parsed-text
|
|
:deleted :deleted?
|
|
:deletedForMe :deleted-for-me?
|
|
:communityId :community-id
|
|
:albumImagesCount :album-images-count})
|
|
(update :outgoing-status keyword)
|
|
(update :command-parameters
|
|
set/rename-keys
|
|
{:transactionHash :transaction-hash
|
|
:commandState :command-state})
|
|
(assoc :content {:chat-id (:chatId message)
|
|
:text (:text message)
|
|
:image (:image message)
|
|
:sticker (:sticker message)
|
|
:ens-name (:ensName message)
|
|
:line-count (:lineCount message)
|
|
:parsed-text (:parsedText message)
|
|
:links (:links message)
|
|
:rtl? (:rtl message)
|
|
:response-to (:responseTo message)}
|
|
:outgoing (boolean (:outgoingStatus message)))
|
|
(dissoc :ensName :chatId :text :rtl :responseTo :image :sticker :lineCount :parsedText :links)))
|
|
|
|
(defn messages-by-chat-id-rpc
|
|
[chat-id
|
|
cursor
|
|
limit
|
|
on-success
|
|
on-error]
|
|
{:json-rpc/call [{:method "wakuext_chatMessages"
|
|
:params [chat-id cursor limit]
|
|
:on-success (fn [result]
|
|
(on-success (update result :messages #(map <-rpc %))))
|
|
:on-error on-error}]})
|
|
|
|
(defn mark-seen-rpc
|
|
[chat-id ids on-success]
|
|
{:json-rpc/call [{:method "wakuext_markMessagesSeen"
|
|
:params [chat-id ids]
|
|
:on-success #(do
|
|
(log/debug "successfully marked as seen" %)
|
|
(when on-success (on-success chat-id ids %)))
|
|
:on-error #(log/error "failed to get messages" %)}]})
|
|
|
|
(defn delete-message-rpc
|
|
[id]
|
|
{:json-rpc/call [{:method "wakuext_deleteMessage"
|
|
:params [id]
|
|
:on-success #(log/debug "successfully deleted message" id)
|
|
:on-error #(log/error "failed to delete message" % id)}]})
|
|
|
|
(defn delete-messages-from-rpc
|
|
[author]
|
|
{:json-rpc/call [{:method "wakuext_deleteMessagesFrom"
|
|
:params [author]
|
|
:on-success #(log/debug "successfully deleted messages from" author)
|
|
:on-error #(log/error "failed to delete messages from" % author)}]})
|
|
|
|
(defn delete-messages-by-chat-id-rpc
|
|
[chat-id]
|
|
{:json-rpc/call [{:method "wakuext_deleteMessagesByChatID"
|
|
:params [chat-id]
|
|
:on-success #(log/debug "successfully deleted messages by chat-id" chat-id)
|
|
:on-error #(log/error "failed to delete messages by chat-id" % chat-id)}]})
|
|
|
|
(rf/defn delete-message
|
|
[cofx id]
|
|
(delete-message-rpc id))
|
|
|
|
(rf/defn delete-messages-from
|
|
[cofx author]
|
|
(delete-messages-from-rpc author))
|
|
|
|
(rf/defn mark-messages-seen
|
|
[cofx chat-id ids on-success]
|
|
(mark-seen-rpc chat-id ids on-success))
|
|
|
|
(rf/defn delete-messages-by-chat-id
|
|
[cofx chat-id]
|
|
(delete-messages-by-chat-id-rpc chat-id))
|