From 13d83cb0d1755606c1794f921936e2c345af9ccd Mon Sep 17 00:00:00 2001
From: Andrey Antukh <niwi@niwi.nz>
Date: Tue, 14 Sep 2021 10:45:06 +0200
Subject: [PATCH] :bug: Fix incorrect handling of metrics on notifications
 module.

---
 backend/src/app/notifications.clj | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/backend/src/app/notifications.clj b/backend/src/app/notifications.clj
index 9c6b51dab..f7efa6f3f 100644
--- a/backend/src/app/notifications.clj
+++ b/backend/src/app/notifications.clj
@@ -135,7 +135,7 @@
         ws-send      (mtx/wrap-counter ws-send mtx-messages ["send"])]
 
     (letfn [(on-connect [conn]
-              ((::mtx/fn mtx-aconn) {})
+              ((::mtx/fn mtx-aconn) {:cmd :inc :by 1})
               ;; A subscription channel should use a lossy buffer
               ;; because we can't penalize normal clients when one
               ;; slow client is connected to the room.
@@ -162,8 +162,8 @@
                   (a/<! (handle-connect cfg))
 
                   ;; when connection is closed
-                  ((:mtx/fn mtx-aconn) {})
-                  ((:mtx/fn mtx-sessions) {:val (/ (inst-ms (dt/diff created-at (dt/now))) 1000.0)})
+                  ((::mtx/fn mtx-aconn) {:cmd :dec :by 1})
+                  ((::mtx/fn mtx-sessions) {:val (/ (inst-ms (dt/diff created-at (dt/now))) 1000.0)})
 
                   ;; close subscription
                   (a/close! sub-ch))))