[fix #2426] prevent sending same command multiple times
This commit is contained in:
parent
91a7dc2cdf
commit
65f2f51632
|
@ -3,7 +3,7 @@
|
||||||
[clojure.string :as str]
|
[clojure.string :as str]
|
||||||
[re-frame.core :as re-frame]
|
[re-frame.core :as re-frame]
|
||||||
[taoensso.timbre :as log]
|
[taoensso.timbre :as log]
|
||||||
[status-im.utils.handlers :as handlers]
|
[status-im.utils.handlers :as handlers]
|
||||||
[status-im.i18n :as i18n]
|
[status-im.i18n :as i18n]
|
||||||
[status-im.utils.platform :as platform]))
|
[status-im.utils.platform :as platform]))
|
||||||
|
|
||||||
|
|
|
@ -1,8 +1,8 @@
|
||||||
(ns status-im.chat.events.input
|
(ns status-im.chat.events.input
|
||||||
(:require [clojure.string :as str]
|
(:require [clojure.string :as string]
|
||||||
[re-frame.core :as re-frame]
|
[re-frame.core :as re-frame]
|
||||||
[taoensso.timbre :as log]
|
[taoensso.timbre :as log]
|
||||||
[status-im.chat.constants :as const]
|
[status-im.chat.constants :as constants]
|
||||||
[status-im.chat.utils :as chat-utils]
|
[status-im.chat.utils :as chat-utils]
|
||||||
[status-im.chat.models :as model]
|
[status-im.chat.models :as model]
|
||||||
[status-im.chat.models.input :as input-model]
|
[status-im.chat.models.input :as input-model]
|
||||||
|
@ -61,7 +61,7 @@
|
||||||
true
|
true
|
||||||
(assoc-in [:chats current-chat-id :input-text] (input-model/text->emoji chat-text))
|
(assoc-in [:chats current-chat-id :input-text] (input-model/text->emoji chat-text))
|
||||||
|
|
||||||
(and dapp? (str/blank? chat-text))
|
(and dapp? (string/blank? chat-text))
|
||||||
(assoc-in [:chats current-chat-id :parameter-boxes :message] nil))))
|
(assoc-in [:chats current-chat-id :parameter-boxes :message] nil))))
|
||||||
|
|
||||||
;; TODO janherich: this is super fragile and won't work at all for group chats with bots.
|
;; TODO janherich: this is super fragile and won't work at all for group chats with bots.
|
||||||
|
@ -70,10 +70,10 @@
|
||||||
(defn call-on-message-input-change
|
(defn call-on-message-input-change
|
||||||
"Calls bot's `on-message-input-change` function"
|
"Calls bot's `on-message-input-change` function"
|
||||||
[{:keys [current-chat-id current-account-id chats local-storage] :as db}]
|
[{:keys [current-chat-id current-account-id chats local-storage] :as db}]
|
||||||
(let [chat-text (str/trim (or (get-in chats [current-chat-id :input-text]) ""))
|
(let [chat-text (string/trim (or (get-in chats [current-chat-id :input-text]) ""))
|
||||||
{:keys [dapp?]} (get-in db [:contacts/contacts current-chat-id])]
|
{:keys [dapp?]} (get-in db [:contacts/contacts current-chat-id])]
|
||||||
(cond-> {:db db}
|
(cond-> {:db db}
|
||||||
(and dapp? (not (str/blank? chat-text)))
|
(and dapp? (not (string/blank? chat-text)))
|
||||||
(assoc :call-jail-function {:chat-id current-chat-id
|
(assoc :call-jail-function {:chat-id current-chat-id
|
||||||
:function :on-message-input-change
|
:function :on-message-input-change
|
||||||
:parameters {:message chat-text}
|
:parameters {:message chat-text}
|
||||||
|
@ -106,18 +106,18 @@
|
||||||
(get-in [:command :sequential-params]))]
|
(get-in [:command :sequential-params]))]
|
||||||
(if seq-params?
|
(if seq-params?
|
||||||
(set-chat-seq-arg-input-text db arg)
|
(set-chat-seq-arg-input-text db arg)
|
||||||
(let [arg (str/replace arg (re-pattern const/arg-wrapping-char) "")
|
(let [arg (string/replace arg (re-pattern constants/arg-wrapping-char) "")
|
||||||
command-name (first command)
|
command-name (first command)
|
||||||
command-args (into [] (rest command))
|
command-args (into [] (rest command))
|
||||||
command-args (if (< index (count command-args))
|
command-args (if (< index (count command-args))
|
||||||
(assoc command-args index arg)
|
(assoc command-args index arg)
|
||||||
(conj command-args arg))
|
(conj command-args arg))
|
||||||
input-text (str command-name
|
input-text (str command-name
|
||||||
const/spacing-char
|
constants/spacing-char
|
||||||
(input-model/join-command-args command-args)
|
(input-model/join-command-args command-args)
|
||||||
(when (and move-to-next?
|
(when (and move-to-next?
|
||||||
(= index (dec (count command-args))))
|
(= index (dec (count command-args))))
|
||||||
const/spacing-char))]
|
constants/spacing-char))]
|
||||||
(set-chat-input-text db input-text)))))
|
(set-chat-input-text db input-text)))))
|
||||||
|
|
||||||
(defn load-chat-parameter-box
|
(defn load-chat-parameter-box
|
||||||
|
@ -173,9 +173,9 @@
|
||||||
chat-parameter-box-fx
|
chat-parameter-box-fx
|
||||||
(merge chat-parameter-box-fx)
|
(merge chat-parameter-box-fx)
|
||||||
|
|
||||||
(and (= selection (+ (count const/command-char)
|
(and (= selection (+ (count constants/command-char)
|
||||||
(count (get-in command [:command :name]))
|
(count (get-in command [:command :name]))
|
||||||
(count const/spacing-char)))
|
(count constants/spacing-char)))
|
||||||
(get-in command [:command :sequential-params]))
|
(get-in command [:command :sequential-params]))
|
||||||
(merge (chat-input-focus new-db :seq-input-ref)))))
|
(merge (chat-input-focus new-db :seq-input-ref)))))
|
||||||
|
|
||||||
|
@ -193,7 +193,7 @@
|
||||||
:prev-command name})
|
:prev-command name})
|
||||||
(set-chat-input-metadata metadata)
|
(set-chat-input-metadata metadata)
|
||||||
(set-chat-input-text (str (chat-utils/command-name command)
|
(set-chat-input-text (str (chat-utils/command-name command)
|
||||||
const/spacing-char
|
constants/spacing-char
|
||||||
(when-not sequential-params
|
(when-not sequential-params
|
||||||
(input-model/join-command-args prefill)))))
|
(input-model/join-command-args prefill)))))
|
||||||
fx (assoc (load-chat-parameter-box db' command) :db db')]
|
fx (assoc (load-chat-parameter-box db' command) :db db')]
|
||||||
|
@ -209,14 +209,14 @@
|
||||||
(as-> fx'
|
(as-> fx'
|
||||||
(cond-> (update fx' :db
|
(cond-> (update fx' :db
|
||||||
set-chat-seq-arg-input-text
|
set-chat-seq-arg-input-text
|
||||||
(str/join const/spacing-char prefill))
|
(string/join constants/spacing-char prefill))
|
||||||
(not prevent-auto-focus?)
|
(not prevent-auto-focus?)
|
||||||
(merge fx' (chat-input-focus (:db fx') :seq-input-ref)))))))
|
(merge fx' (chat-input-focus (:db fx') :seq-input-ref)))))))
|
||||||
|
|
||||||
(defn set-contact-as-command-argument
|
(defn set-contact-as-command-argument
|
||||||
"Sets contact as command argument for active chat"
|
"Sets contact as command argument for active chat"
|
||||||
[db {:keys [bot-db-key contact arg-index]}]
|
[db {:keys [bot-db-key contact arg-index]}]
|
||||||
(let [name (str/replace (:name contact) (re-pattern const/arg-wrapping-char) "")
|
(let [name (string/replace (:name contact) (re-pattern constants/arg-wrapping-char) "")
|
||||||
contact (select-keys contact [:address :whisper-identity :name :photo-path :dapp?])
|
contact (select-keys contact [:address :whisper-identity :name :photo-path :dapp?])
|
||||||
command-owner (get-in (input-model/selected-chat-command db) [:command :owner-id])]
|
command-owner (get-in (input-model/selected-chat-command db) [:command :owner-id])]
|
||||||
(-> db
|
(-> db
|
||||||
|
@ -442,6 +442,37 @@
|
||||||
[::send-command (assoc-in command-message
|
[::send-command (assoc-in command-message
|
||||||
[:command :preview] returned)])})))))
|
[:command :preview] returned)])})))))
|
||||||
|
|
||||||
|
(defn command-complete?
|
||||||
|
[chat-command]
|
||||||
|
(= :complete (input-model/command-completion chat-command)))
|
||||||
|
|
||||||
|
(defn command-complete-fx
|
||||||
|
"command is complete, clear sequential arguments and proceed with command processing"
|
||||||
|
[db chat-command message-id current-time]
|
||||||
|
(-> db
|
||||||
|
clear-seq-arguments
|
||||||
|
(model/set-chat-ui-props {:sending-in-progress? true})
|
||||||
|
(proceed-command chat-command message-id current-time)))
|
||||||
|
|
||||||
|
(defn command-not-complete-fx
|
||||||
|
"command is not complete, just add space after command if necessary"
|
||||||
|
[db input-text]
|
||||||
|
{:db (cond-> db
|
||||||
|
(not (input-model/text-ends-with-space? input-text))
|
||||||
|
(set-chat-input-text constants/spacing-char :append? true))})
|
||||||
|
|
||||||
|
(defn plain-text-message-fx
|
||||||
|
"no command detected, when not empty, proceed by sending text message without command processing"
|
||||||
|
[db cofx input-text current-chat-id current-public-key]
|
||||||
|
(when-not (string/blank? input-text)
|
||||||
|
(send-message-events/prepare-message (assoc cofx :db (-> db
|
||||||
|
(set-chat-input-metadata nil)
|
||||||
|
(set-chat-input-text nil)))
|
||||||
|
{:message-text input-text
|
||||||
|
:chat-id current-chat-id
|
||||||
|
:identity current-public-key
|
||||||
|
:address (:accounts/current-account-id db)})))
|
||||||
|
|
||||||
(handlers/register-handler-fx
|
(handlers/register-handler-fx
|
||||||
:send-current-message
|
:send-current-message
|
||||||
[(re-frame/inject-cofx :random-id)
|
[(re-frame/inject-cofx :random-id)
|
||||||
|
@ -449,35 +480,20 @@
|
||||||
(re-frame/inject-cofx :get-stored-chat)]
|
(re-frame/inject-cofx :get-stored-chat)]
|
||||||
(fn [{{:keys [current-chat-id current-public-key] :as db} :db message-id :random-id current-time :now
|
(fn [{{:keys [current-chat-id current-public-key] :as db} :db message-id :random-id current-time :now
|
||||||
:as cofx} _]
|
:as cofx} _]
|
||||||
(let [input-text (get-in db [:chats current-chat-id :input-text])
|
(when-not (get-in db [:chat-ui-props current-chat-id :sending-in-progress?])
|
||||||
chat-command (-> (input-model/selected-chat-command db)
|
(let [input-text (get-in db [:chats current-chat-id :input-text])
|
||||||
(as-> selected-command
|
chat-command (-> (input-model/selected-chat-command db)
|
||||||
(if (get-in selected-command [:command :sequential-params])
|
(as-> selected-command
|
||||||
(assoc selected-command :args
|
(if (get-in selected-command [:command :sequential-params])
|
||||||
(get-in db [:chats current-chat-id :seq-arguments]))
|
(assoc selected-command :args
|
||||||
(update selected-command :args (partial remove str/blank?)))))]
|
(get-in db [:chats current-chat-id :seq-arguments]))
|
||||||
(if (:command chat-command)
|
(update selected-command :args (partial remove string/blank?)))))]
|
||||||
;; current input contains command
|
(if (:command chat-command)
|
||||||
(if (= :complete (input-model/command-completion chat-command))
|
;; Returns true if current input contains command
|
||||||
;; command is complete, clear sequential arguments and proceed with command processing
|
(if (command-complete? chat-command)
|
||||||
(-> db
|
(command-complete-fx db chat-command message-id current-time)
|
||||||
clear-seq-arguments
|
(command-not-complete-fx db input-text))
|
||||||
(model/set-chat-ui-props {:sending-in-progress? true})
|
(plain-text-message-fx db cofx input-text current-chat-id current-public-key))))))
|
||||||
(proceed-command chat-command message-id current-time))
|
|
||||||
;; command is not complete, just add space after command if necessary
|
|
||||||
{:db (cond-> db
|
|
||||||
(not (input-model/text-ends-with-space? input-text))
|
|
||||||
(set-chat-input-text const/spacing-char :append? true))})
|
|
||||||
;; no command detected, when not empty, proceed by sending text message without command processing
|
|
||||||
(if (str/blank? input-text)
|
|
||||||
{:db db}
|
|
||||||
(send-message-events/prepare-message (assoc cofx :db (-> db
|
|
||||||
(set-chat-input-metadata nil)
|
|
||||||
(set-chat-input-text nil)))
|
|
||||||
{:message-text input-text
|
|
||||||
:chat-id current-chat-id
|
|
||||||
:identity current-public-key
|
|
||||||
:address (:accounts/current-account-id db)}))))))
|
|
||||||
|
|
||||||
;; TODO: remove this handler and leave only helper fn once all invocations are refactored
|
;; TODO: remove this handler and leave only helper fn once all invocations are refactored
|
||||||
(handlers/register-handler-db
|
(handlers/register-handler-db
|
||||||
|
|
Loading…
Reference in New Issue