wekan/models/server/metrics.js

import { Meteor } from 'meteor/meteor';
import Users from '../users';

function acceptedIpAdress(ipAdress) {
  //return true if a given ipAdress was setted by an admin user
  // console.log('idpAdress', ipAdress);

  //Check if ipAdress is accepted
  // console.log(
  //   'process.env.WEKAN_METRICS_ACCEPTED_IP_ADRESS',
  //   process.env.WEKAN_METRICS_ACCEPTED_IP_ADRESS,
  // );
  //console.log("process.env", process.env);
  const trustedIpAdress = process.env.WEKAN_METRICS_ACCEPTED_IP_ADRESS;
  //console.log("trustedIpAdress", trustedIpAdress);
  //console.log("trustedIpAdress !== undefined && trustedIpAdress.split(",").includes(ipAdress)", trustedIpAdress !== undefined && trustedIpAdress.split(",").includes(ipAdress));
  return (
    trustedIpAdress !== undefined &&
    trustedIpAdress.split(',').includes(ipAdress)
  );
}

Meteor.startup(() => {
  WebApp.connectHandlers.use('/metrics', (req, res, next) => {
    try {
      const ipAdress =
        req.headers['x-forwarded-for'] || req.socket.remoteAddress;
      // if(process.env.TRUST_PROXY_FORXARD)
      // {
      //   const ipAdress = req.headers['x-forwarded-for'] || req.socket.remoteAddress
      // }else{
      //   const ipAdress = req.socket.remoteAddress
      // }

      // List of trusted ip adress will be found in environment variable "WEKAN_METRICS_ACCEPTED_IP_ADRESS" (separeted with commas)
      if (acceptedIpAdress(ipAdress)) {
        let metricsRes = '';
        let resCount = 0;
        //connected users
        metricsRes += '# Number of connected users\n';

        // To Do: Get number of connected user by using meteor socketJs
        const allOpenedSockets = Meteor.server.stream_server.open_sockets;
        let connectedUserIds = [];
        allOpenedSockets.forEach(
          (socket) =>
            //console.log('meteor session', socket._meteorSession.userId)
            socket._meteorSession.userId !== null &&
            connectedUserIds.push(socket._meteorSession.userId),
        );
        resCount = connectedUserIds.length; // KPI 1
        metricsRes += 'connectedUsers ' + resCount + '\n';

        //registered users
        metricsRes += '# Number of registered users\n';

        // To Do: Get number of registered user
        resCount = Users.find({}).count(); // KPI 2
        metricsRes += 'registeredUsers ' + resCount + '\n';
        resCount = 0;

        //board numbers
        metricsRes += '# Number of registered boards\n';

        // To Do: Get number of registered boards
        resCount = Boards.find({ archived: false, type: 'board' }).count(); // KPI 3
        metricsRes += 'registeredboards ' + resCount + '\n';
        resCount = 0;

        //board numbers by registered users
        metricsRes += '# Number of registered boards by registered users\n';

        // To Do: Get number of registered boards by registered users
        resCount =
          Boards.find({ archived: false, type: 'board' }).count() /
          Users.find({}).count(); // KPI 4
        metricsRes += 'registeredboardsBysRegisteredUsers ' + resCount + '\n';
        resCount = 0;

        //board numbers with only one member
        metricsRes += '# Number of registered boards\n';

        // To Do: Get board numbers with only one member
        resCount = Boards.find({
          archived: false,
          type: 'board',
          members: { $size: 1 },
        }).count(); // KPI 5
        metricsRes += 'registeredboardsWithOnlyOneMember ' + resCount + '\n';
        resCount = 0;

        // KPI 6 : - stocker la date de dernière connexion
        //         KPI 6 = count where date de dernière connexion > x jours
        // Découpe en label since 5 jours / 10 jours / 20 Jours / 30 jours

        //Number of users with last connection dated 5 days ago
        metricsRes +=
          '# Number of users with last connection dated 5 days ago\n';

        // To Do: Get number of users with last connection dated 5 days ago
        let xdays = 5;
        let dateWithXdaysAgo = new Date(
          new Date() - xdays * 24 * 60 * 60 * 1000,
        );
        //console.log({ dateWithXdaysAgo });
        resCount = Users.find({
          lastConnectionDate: { $gte: dateWithXdaysAgo },
        }).count(); // KPI 5
        metricsRes += 'usersWithLastConnectionDated5DaysAgo ' + resCount + '\n';
        resCount = 0;

        metricsRes +=
          '# Number of users with last connection dated 10 days ago\n';

        // To Do: Get number of users with last connection dated 10 days ago
        xdays = 10;
        dateWithXdaysAgo = new Date(new Date() - xdays * 24 * 60 * 60 * 1000);
        //console.log({ dateWithXdaysAgo });
        resCount = Users.find({
          lastConnectionDate: { $gte: dateWithXdaysAgo },
        }).count(); // KPI 5
        metricsRes +=
          'usersWithLastConnectionDated10DaysAgo ' + resCount + '\n';
        resCount = 0;

        metricsRes +=
          '# Number of users with last connection dated 20 days ago\n';

        // To Do: Get number of users with last connection dated 20 days ago
        xdays = 20;
        dateWithXdaysAgo = new Date(new Date() - xdays * 24 * 60 * 60 * 1000);
        //console.log({ dateWithXdaysAgo });
        resCount = Users.find({
          lastConnectionDate: { $gte: dateWithXdaysAgo },
        }).count(); // KPI 5
        metricsRes +=
          'usersWithLastConnectionDated20DaysAgo ' + resCount + '\n';
        resCount = 0;

        metricsRes +=
          '# Number of users with last connection dated 30 days ago\n';

        // To Do: Get number of users with last connection dated 20 days ago
        xdays = 30;
        dateWithXdaysAgo = new Date(new Date() - xdays * 24 * 60 * 60 * 1000);
        //console.log({ dateWithXdaysAgo });
        resCount = Users.find({
          lastConnectionDate: { $gte: dateWithXdaysAgo },
        }).count(); // KPI 5
        metricsRes +=
          'usersWithLastConnectionDated30DaysAgo ' + resCount + '\n';
        resCount = 0;
        // TO DO:
        // moyenne de connexion : ((date de déconnexion - date de dernière connexion) + (dernière moyenne)) / 2
        // KPI 7 : somme des moyenne de connexion / nombre d'utilisateur (à ignore les utilisateur avec 0 moyenne)

        res.writeHead(200); // HTTP status
        res.end(metricsRes);
      } else {
        res.writeHead(401); // HTTP status
        res.end(
          'IpAdress: ' +
            ipAdress +
            ' is not authorized to perform this action !!\n',
        );
      }
    } catch (e) {
      res.writeHead(500); // HTTP status
      res.end(e.toString());
    }
  });
});