2016-10-04 11:49:59 +00:00
|
|
|
(ns status-im.data-store.messages
|
2019-06-02 02:22:56 +00:00
|
|
|
(:require [clojure.set :as clojure.set]
|
2020-05-05 14:18:23 +00:00
|
|
|
[status-im.ethereum.json-rpc :as json-rpc]
|
2019-08-05 06:17:55 +00:00
|
|
|
[status-im.utils.fx :as fx]
|
2020-05-05 14:18:23 +00:00
|
|
|
[taoensso.timbre :as log]))
|
2018-04-02 16:17:15 +00:00
|
|
|
|
2019-11-26 13:15:19 +00:00
|
|
|
(defn ->rpc [{:keys [content] :as message}]
|
|
|
|
(cond-> message
|
2017-12-05 13:03:25 +00:00
|
|
|
content
|
2019-11-26 13:15:19 +00:00
|
|
|
(assoc :text (:text content)
|
|
|
|
:sticker (:sticker content))
|
|
|
|
:always
|
2021-04-02 14:44:39 +00:00
|
|
|
(clojure.set/rename-keys {:chat-id :chat_id
|
|
|
|
:whisper-timestamp :whisperTimestamp
|
2020-10-20 14:28:52 +00:00
|
|
|
:community-id :communityId
|
2019-11-26 13:15:19 +00:00
|
|
|
:clock-value :clock})))
|
2019-08-05 06:17:55 +00:00
|
|
|
|
|
|
|
(defn <-rpc [message]
|
2019-11-26 13:15:19 +00:00
|
|
|
(-> message
|
|
|
|
(clojure.set/rename-keys {:id :message-id
|
|
|
|
:whisperTimestamp :whisper-timestamp
|
2021-06-17 13:44:34 +00:00
|
|
|
:editedAt :edited-at
|
2021-07-16 21:14:05 +00:00
|
|
|
:contactRequestState :contact-request-state
|
2019-11-25 13:33:43 +00:00
|
|
|
:commandParameters :command-parameters
|
2021-04-22 10:09:25 +00:00
|
|
|
:gapParameters :gap-parameters
|
2019-11-26 13:15:19 +00:00
|
|
|
:messageType :message-type
|
|
|
|
:localChatId :chat-id
|
2020-10-20 14:28:52 +00:00
|
|
|
:communityId :community-id
|
2019-11-26 13:15:19 +00:00
|
|
|
:contentType :content-type
|
|
|
|
:clock :clock-value
|
|
|
|
:quotedMessage :quoted-message
|
2020-07-28 11:06:58 +00:00
|
|
|
:outgoingStatus :outgoing-status
|
2020-11-10 16:12:31 +00:00
|
|
|
:audioDurationMs :audio-duration-ms
|
|
|
|
:new :new?})
|
2019-11-26 13:15:19 +00:00
|
|
|
|
2020-10-20 14:28:52 +00:00
|
|
|
(update :quoted-message clojure.set/rename-keys {:parsedText :parsed-text :communityId :community-id})
|
2019-11-26 13:15:19 +00:00
|
|
|
(update :outgoing-status keyword)
|
2019-11-25 13:33:43 +00:00
|
|
|
(update :command-parameters clojure.set/rename-keys {:transactionHash :transaction-hash
|
|
|
|
:commandState :command-state})
|
2019-11-26 13:15:19 +00:00
|
|
|
(assoc :content {:chat-id (:chatId message)
|
|
|
|
:text (:text message)
|
2020-05-05 15:42:44 +00:00
|
|
|
:image (:image message)
|
2019-11-26 13:15:19 +00:00
|
|
|
:sticker (:sticker message)
|
|
|
|
:ens-name (:ensName message)
|
|
|
|
:line-count (:lineCount message)
|
|
|
|
:parsed-text (:parsedText message)
|
2020-11-02 13:05:33 +00:00
|
|
|
:links (:links message)
|
2020-05-19 14:33:53 +00:00
|
|
|
:rtl? (:rtl message)
|
2019-11-26 13:15:19 +00:00
|
|
|
:response-to (:responseTo message)}
|
|
|
|
:outgoing (boolean (:outgoingStatus message)))
|
2020-11-02 13:05:33 +00:00
|
|
|
(dissoc :ensName :chatId :text :rtl :responseTo :image :sticker :lineCount :parsedText :links)))
|
2019-08-05 06:17:55 +00:00
|
|
|
|
2020-09-14 12:36:14 +00:00
|
|
|
(defn messages-by-chat-id-rpc [chat-id
|
2020-02-06 15:17:30 +00:00
|
|
|
cursor
|
|
|
|
limit
|
|
|
|
on-success
|
2022-05-27 15:39:26 +00:00
|
|
|
on-error]
|
2022-05-11 08:15:47 +00:00
|
|
|
{::json-rpc/call [{:method "wakuext_chatMessages"
|
2021-02-16 14:16:32 +00:00
|
|
|
:params [chat-id cursor limit]
|
2019-08-05 06:17:55 +00:00
|
|
|
:on-success (fn [result]
|
|
|
|
(on-success (update result :messages #(map <-rpc %))))
|
2022-05-27 15:39:26 +00:00
|
|
|
:on-error on-error}]})
|
2019-08-05 06:17:55 +00:00
|
|
|
|
2020-09-14 12:36:14 +00:00
|
|
|
(defn mark-seen-rpc [chat-id ids on-success]
|
2022-05-11 08:15:47 +00:00
|
|
|
{::json-rpc/call [{:method "wakuext_markMessagesSeen"
|
2019-11-26 13:15:19 +00:00
|
|
|
:params [chat-id ids]
|
2020-04-06 15:56:07 +00:00
|
|
|
:on-success #(do
|
|
|
|
(log/debug "successfully marked as seen" %)
|
|
|
|
(when on-success (on-success chat-id ids %)))
|
2022-05-27 15:39:26 +00:00
|
|
|
:on-error #(log/error "failed to get messages" %)}]})
|
2019-08-05 06:17:55 +00:00
|
|
|
|
2020-09-14 12:36:14 +00:00
|
|
|
(defn delete-message-rpc [id]
|
2022-05-11 08:15:47 +00:00
|
|
|
{::json-rpc/call [{:method "wakuext_deleteMessage"
|
2019-08-05 06:17:55 +00:00
|
|
|
:params [id]
|
|
|
|
:on-success #(log/debug "successfully deleted message" id)
|
2022-05-27 15:39:26 +00:00
|
|
|
:on-error #(log/error "failed to delete message" % id)}]})
|
2019-08-05 06:17:55 +00:00
|
|
|
|
2020-09-14 12:36:14 +00:00
|
|
|
(defn delete-messages-from-rpc [author]
|
2022-05-11 08:15:47 +00:00
|
|
|
{::json-rpc/call [{:method "wakuext_deleteMessagesFrom"
|
2019-08-05 06:17:55 +00:00
|
|
|
:params [author]
|
|
|
|
:on-success #(log/debug "successfully deleted messages from" author)
|
2022-05-27 15:39:26 +00:00
|
|
|
:on-error #(log/error "failed to delete messages from" % author)}]})
|
2019-08-05 06:17:55 +00:00
|
|
|
|
2020-09-14 12:36:14 +00:00
|
|
|
(defn delete-messages-by-chat-id-rpc [chat-id]
|
2022-05-11 08:15:47 +00:00
|
|
|
{::json-rpc/call [{:method "wakuext_deleteMessagesByChatID"
|
2019-08-05 06:17:55 +00:00
|
|
|
:params [chat-id]
|
|
|
|
:on-success #(log/debug "successfully deleted messages by chat-id" chat-id)
|
2022-05-27 15:39:26 +00:00
|
|
|
:on-error #(log/error "failed to delete messages by chat-id" % chat-id)}]})
|
2019-08-05 06:17:55 +00:00
|
|
|
|
|
|
|
(fx/defn delete-message [cofx id]
|
2020-09-14 12:36:14 +00:00
|
|
|
(delete-message-rpc id))
|
2019-08-05 06:17:55 +00:00
|
|
|
|
|
|
|
(fx/defn delete-messages-from [cofx author]
|
2020-09-14 12:36:14 +00:00
|
|
|
(delete-messages-from-rpc author))
|
2019-08-05 06:17:55 +00:00
|
|
|
|
2020-04-06 15:56:07 +00:00
|
|
|
(fx/defn mark-messages-seen [cofx chat-id ids on-success]
|
2020-09-14 12:36:14 +00:00
|
|
|
(mark-seen-rpc chat-id ids on-success))
|
2019-08-05 06:17:55 +00:00
|
|
|
|
|
|
|
(fx/defn delete-messages-by-chat-id [cofx chat-id]
|
2020-09-14 12:36:14 +00:00
|
|
|
(delete-messages-by-chat-id-rpc chat-id))
|