|
96 | 96 | ^js event-js (.-event data)
|
97 | 97 | type (.-type data)]
|
98 | 98 | (case type
|
99 |
| - "node.login" (profile.login/login-node-signal cofx (transforms/js->clj event-js)) |
100 |
| - "backup.performed" {:db (assoc-in db |
101 |
| - [:profile/profile :last-backup] |
102 |
| - (.-lastBackup event-js))} |
103 |
| - "envelope.sent" (transport.message/update-envelopes-status cofx |
104 |
| - (:ids |
| 99 | + "node.login" (profile.login/login-node-signal cofx (transforms/js->clj event-js)) |
| 100 | + "backup.performed" {:db (assoc-in db |
| 101 | + [:profile/profile :last-backup] |
| 102 | + (.-lastBackup event-js))} |
| 103 | + "envelope.sent" (transport.message/update-envelopes-status cofx |
| 104 | + (:ids |
| 105 | + (js->clj event-js |
| 106 | + :keywordize-keys |
| 107 | + true)) |
| 108 | + :sent) |
| 109 | + "envelope.expired" (transport.message/update-envelopes-status cofx |
| 110 | + (:ids |
| 111 | + (js->clj event-js |
| 112 | + :keywordize-keys |
| 113 | + true)) |
| 114 | + :not-sent) |
| 115 | + "message.delivered" (let [{:keys [chatID messageID]} (js->clj event-js |
| 116 | + :keywordize-keys |
| 117 | + true)] |
| 118 | + (models.message/update-db-message-status cofx |
| 119 | + chatID |
| 120 | + messageID |
| 121 | + :delivered)) |
| 122 | + "mailserver.changed" (mailserver/handle-mailserver-changed cofx (.-id event-js)) |
| 123 | + "mailserver.available" (mailserver/handle-mailserver-available cofx (.-id event-js)) |
| 124 | + "mailserver.not.working" (mailserver/handle-mailserver-not-working cofx) |
| 125 | + "discovery.summary" (summary cofx (js->clj event-js :keywordize-keys true)) |
| 126 | + "mediaserver.started" {:db (assoc db :mediaserver/port (.-port event-js))} |
| 127 | + "wakuv2.peerstats" (wakuv2-peer-stats cofx (js->clj event-js :keywordize-keys true)) |
| 128 | + "messages.new" (transport.message/sanitize-messages-and-process-response cofx |
| 129 | + event-js |
| 130 | + true) |
| 131 | + "wallet" (ethereum.subscriptions/new-wallet-event cofx |
105 | 132 | (js->clj event-js
|
106 | 133 | :keywordize-keys
|
107 | 134 | true))
|
108 |
| - :sent) |
109 |
| - "envelope.expired" (transport.message/update-envelopes-status cofx |
110 |
| - (:ids |
111 |
| - (js->clj event-js |
112 |
| - :keywordize-keys |
113 |
| - true)) |
114 |
| - :not-sent) |
115 |
| - "message.delivered" (let [{:keys [chatID messageID]} (js->clj event-js |
116 |
| - :keywordize-keys |
117 |
| - true)] |
118 |
| - (models.message/update-db-message-status cofx |
119 |
| - chatID |
120 |
| - messageID |
121 |
| - :delivered)) |
122 |
| - "mailserver.changed" (mailserver/handle-mailserver-changed cofx (.-id event-js)) |
123 |
| - "mailserver.available" (mailserver/handle-mailserver-available cofx (.-id event-js)) |
124 |
| - "mailserver.not.working" (mailserver/handle-mailserver-not-working cofx) |
125 |
| - "discovery.summary" (summary cofx (js->clj event-js :keywordize-keys true)) |
126 |
| - "mediaserver.started" {:db (assoc db :mediaserver/port (.-port event-js))} |
127 |
| - "wakuv2.peerstats" (wakuv2-peer-stats cofx (js->clj event-js :keywordize-keys true)) |
128 |
| - "messages.new" (transport.message/sanitize-messages-and-process-response cofx |
129 |
| - event-js |
130 |
| - true) |
131 |
| - "wallet" (ethereum.subscriptions/new-wallet-event cofx |
132 |
| - (js->clj event-js |
133 |
| - :keywordize-keys |
134 |
| - true)) |
135 |
| - "local-notifications" (local-notifications/process cofx |
136 |
| - (js->clj event-js :keywordize-keys true)) |
137 |
| - "community.found" (link-preview/cache-community-preview-data (js->clj event-js |
138 |
| - :keywordize-keys |
139 |
| - true)) |
140 |
| - "status.updates.timedout" (visibility-status-updates/handle-visibility-status-updates |
141 |
| - cofx |
142 |
| - (js->clj event-js :keywordize-keys true)) |
143 |
| - "localPairing" (handle-local-pairing-signals |
144 |
| - cofx |
145 |
| - (js->clj event-js :keywordize-keys true)) |
| 135 | + "local-notifications" (local-notifications/process cofx |
| 136 | + (js->clj event-js :keywordize-keys true)) |
| 137 | + "community.found" (link-preview/cache-community-preview-data (js->clj event-js |
| 138 | + :keywordize-keys |
| 139 | + true)) |
| 140 | + "status.updates.timedout" (visibility-status-updates/handle-visibility-status-updates |
| 141 | + cofx |
| 142 | + (js->clj event-js :keywordize-keys true)) |
| 143 | + "localPairing" (handle-local-pairing-signals |
| 144 | + cofx |
| 145 | + (js->clj event-js :keywordize-keys true)) |
| 146 | + "curated.communities.update" (rf/dispatch [:fetched-contract-communities |
| 147 | + (js->clj event-js :keywordize-keys true)]) |
146 | 148 |
|
147 | 149 | (log/debug "Event " type " not handled"))))
|
0 commit comments