3pp-mirror/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-07-12 06:18:22 +02:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #2229 from penpot/niwinz-msgbus-improvements

Browse source 
✨ Improve msgbus internal API
This commit is contained in:
Alejandro 2022-09-06 10:50:42 +02:00 • committed by GitHub
commit d41c2388c1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
7 changed files with 131 additions and 103 deletions
Download patch file Download diff file Expand all files Collapse all files

9
backend/src/app/rpc/mutations/files.clj
View file

@ -17,6 +17,7 @@
[app.db :as db]
[app.loggers.audit :as audit]
[app.metrics :as mtx]
[app.msgbus :as mbus]
[app.rpc.permissions :as perms]
[app.rpc.queries.files :as files]
[app.rpc.queries.projects :as proj]
@ -439,12 +440,12 @@
(defn- send-notifications
[{:keys [conn] :as cfg} {:keys [file changes session-id] :as params}]
(let [lchanges (filter library-change? changes)
msgbus-fn (:msgbus cfg)]
(let [lchanges (filter library-change? changes)
msgbus (:msgbus cfg)]
;; Asynchronously publish message to the msgbus
(msgbus-fn :cmd :pub
(mbus/pub! msgbus
:topic (:id file)
:message {:type :file-change
:profile-id (:profile-id params)
@ -456,7 +457,7 @@
(when (and (:is-shared file) (seq lchanges))
(let [team-id (retrieve-team-id conn (:project-id file))]
;; Asynchronously publish message to the msgbus
(msgbus-fn :cmd :pub
(mbus/pub! msgbus
:topic team-id
:message {:type :library-change
:profile-id (:profile-id params)