Custom Metrics

index.js

@@ -77,6 +77,23 @@ const messageGroup = new client.Counter({
   help: 'Counts the amount of times group message is used'
 });
 
+const clientActiveUsers = new client.Gauge({
+  name: 'node_active_users',
+  help: 'Active Users'
+});
+
+const successfullLogIns = new client.Counter({
+  name: 'node_successful_logins',
+  help: 'Successfull LogIns total'
+});
+global.SUCCESSFULLLOG = successfullLogIns;
+
+const notSuccessfullLogIns = new client.Counter({
+  name: 'node_not_successful_logins',
+  help: 'Not successfull LogIns total'
+});
+global.NOTSUCCESSFULLLOG = notSuccessfullLogIns;
+
 const histogram = new client.Histogram({
   name: 'node_request_duration_seconds',
   help: 'Own Metric: Histogram for the duration in seconds.',
@@ -89,6 +106,10 @@ register.registerMetric(messageAll);
 register.registerMetric(messagePrivate);
 register.registerMetric(messageGroup);
 register.registerMetric(histogram);
+register.registerMetric(successfullLogIns);
+register.registerMetric(notSuccessfullLogIns);
+register.registerMetric(clientActiveUsers);
+
 
 app.use(bodyParser.json());
 //Routes
@@ -132,12 +153,13 @@ app.get('/login', (req, res) => {
 io.on('connection', (socket) => {
   
   socket.on('userLogin', async function(response) {
-    //clientConnectionCounter.inc(1);
+    clientActiveUsers.inc(1);
     console.log("Connection");
     await addUserToActiveUsers(response, socket);
   });
   
   socket.on('disconnect', async function(response) {
+    clientActiveUsers.dec(1);
     await deleteUserFromActiveUsers(response, socket);
   });
 

prometheus/prometheus.yml

@@ -14,5 +14,5 @@ scrape_configs:
     scrape_interval: 5s
     # scheme: https
     static_configs:
-      - targets: ['192.168.2.34:5000']
+      - targets: ['192.168.0.230:5000']
   
\ No newline at end of file

routes/login.js

@@ -32,21 +32,24 @@ router.post('/', async(req, res) => {
         if(user){
             bcrypt.compare(password, user.password, function (err, result) {
                 if(err){
+                    NOTSUCCESSFULLLOG.inc(1);
                     res.json(err);
                 }
                 if(result){
+                    SUCCESSFULLLOG.inc(1);
                     const user = { name: name }; 
-
                     const accessToken = jwt.sign(user, process.env.ACCESS_TOKEN_SECRET)
                     res.json({
                         statusCode: '200',
                         accessToken: accessToken,
                     })
                 }else{
+                    NOTSUCCESSFULLLOG.inc(1);
                     res.status(401);
                 }
             })
         }else{
+            NOTSUCCESSFULLLOG.inc(1);
             res.status(401);
         }
     })