github/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2026-08-01 10:56:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

🐛 Fix topic encoding on msg publication.

Browse Source
This commit is contained in:
Andrey Antukh 2021-03-01 16:37:58 +01:00
parent f12f46981b
commit 9b8d73ef86
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
backend/src/app/msgbus.clj
View File

@ -219,7 +219,7 @@
(defn- impl-redis-pub (defn- impl-redis-pub
[rac {:keys [topic message]}] [rac {:keys [topic message]}]
(let [topic (str topic) (let [topic (str (cfg/get :tenant) "." topic)
message (blob/encode message) message (blob/encode message)
res (a/chan 1)] res (a/chan 1)]
(-> (.publish ^RedisAsyncCommands rac ^String topic ^bytes message) (-> (.publish ^RedisAsyncCommands rac ^String topic ^bytes message)

4
backend/src/app/rpc/mutations/files.clj
View File

@ -313,7 +313,7 @@
(let [lchanges (filter library-change? changes)] (let [lchanges (filter library-change? changes)]
;; Asynchronously publish message to the msgbus ;; Asynchronously publish message to the msgbus
(msgbus :pub {:topic (str (:id file)) (msgbus :pub {:topic (:id file)
:message :message
{:type :file-change {:type :file-change
:profile-id (:profile-id params) :profile-id (:profile-id params)
@ -325,7 +325,7 @@
(when (and (:is-shared file) (seq lchanges)) (when (and (:is-shared file) (seq lchanges))
(let [team-id (retrieve-team-id conn (:project-id file))] (let [team-id (retrieve-team-id conn (:project-id file))]
;; Asynchronously publish message to the msgbus ;; Asynchronously publish message to the msgbus
(msgbus :pub {:topic (str team-id) (msgbus :pub {:topic team-id
:message :message
{:type :library-change {:type :library-change
:profile-id (:profile-id params) :profile-id (:profile-id params)