feat(affected-users): added chart data

Author: slaveeks

src/models/eventsFactory.js

@@ -18,6 +18,7 @@ const MAX_DB_READ_BATCH_SIZE = Number(process.env.MAX_DB_READ_BATCH_SIZE);
 const ChartType = {
   Accepted: 'accepted',
   RateLimited: 'rate-limited',
+  AffectedUsers: 'affected-users',
 };
 
 /**
@@ -523,15 +524,35 @@ class EventsFactory extends Factory {
     ];
   }
 
+  /**
+   * Get event daily chart data (affected users) from MongoDB only
+   *
+   * @param {string} groupHash - event's group hash
+   * @param {number} days - how many days to fetch
+   * @param {number} timezoneOffset - user's local timezone offset in minutes
+   * @returns {Promise<Array>}
+   */
+  async getEventDailyAffectedUsersChart(groupHash, days, timezoneOffset = 0) {
+    const data = await this.findChartData(days, timezoneOffset, groupHash, 'affectedUsers');
+
+    return [
+      {
+        label: ChartType.AffectedUsers,
+        data,
+      },
+    ];
+  }
+
   /**
    * Fetch timestamps and total count of errors (or target error) for each day since
    *
    * @param {number} days - how many days we need to fetch for displaying in a chart
    * @param {number} timezoneOffset - user's local timezone offset in minutes
    * @param {string} groupHash - event's group hash for showing only target event
+   * @param {'count'|'affectedUsers'} valueField - field to aggregate
    * @return {ProjectChartItem[]}
    */
-  async findChartData(days, timezoneOffset = 0, groupHash = '') {
+  async findChartData(days, timezoneOffset = 0, groupHash = '', valueField = 'count') {
     const today = new Date();
     const since = today.setDate(today.getDate() - days) / 1000;
 
@@ -554,13 +575,15 @@ class EventsFactory extends Factory {
       };
     }
 
+    const projection = {
+      lastRepetitionTime: 1,
+      groupingTimestamp: 1,
+      [valueField]: 1,
+    };
+
     const dailyEventsCursor = await this.getCollection(this.TYPES.DAILY_EVENTS)
       .find(options, {
-        projection: {
-          lastRepetitionTime: 1,
-          groupingTimestamp: 1,
-          count: 1,
-        },
+        projection,
       })
       .batchSize(MAX_DB_READ_BATCH_SIZE);
 
@@ -576,11 +599,13 @@ class EventsFactory extends Factory {
       const key = `groupingTimestamp:${groupingTimestamp}`;
       const current = groupedCounts[key] || 0;
 
-      if (item.count === undefined || item.count === null) {
-        console.warn(`Missing 'count' field for daily event with key ${key}. Defaulting to 0.`);
+      const value = item[valueField];
+
+      if (value === undefined || value === null) {
+        console.warn(`Missing '${valueField}' field for daily event with key ${key}. Defaulting to 0.`);
         groupedCounts[key] = current;
       } else {
-        groupedCounts[key] = current + item.count;
+        groupedCounts[key] = current + value;
       }
     }
 

src/resolvers/event.js

@@ -90,6 +90,21 @@ module.exports = {
       return factory.getEventDailyChart(groupHash, days, timezoneOffset);
     },
 
+    /**
+     * Return chart data for affected users of target event occured in last few days
+     *
+     * @param {string} projectId - event's project
+     * @param {string} groupHash - event's groupHash
+     * @param {number} days - how many days we need to fetch for displaying in a charts
+     * @param {number} timezoneOffset - user's local timezone offset in minutes
+     * @returns {Promise<ProjectChartItem[]>}
+     */
+    async affectedUsersChartData({ projectId, groupHash }, { days, timezoneOffset }, context) {
+      const factory = getEventsFactory(context, projectId);
+
+      return factory.getEventDailyAffectedUsersChart(groupHash, days, timezoneOffset);
+    },
+
     /**
      * Return AI suggestion for the event
      *

src/sso/saml/controller.ts

@@ -154,6 +154,7 @@ export default class SamlController {
       res.redirect(redirectUrl.toString());
     } catch (error) {
       const errorMessage = error instanceof Error ? error.message : 'Unknown error';
+
       this.log(
         'error',
         'SSO initiation error for workspace:',
@@ -271,6 +272,7 @@ export default class SamlController {
 
           if (!isValidRequest) {
             const requestIdShort = samlData.inResponseTo.slice(0, 8);
+
             this.log(
               'error',
               '[ACS] InResponseTo validation failed for workspace:',
@@ -285,6 +287,7 @@ export default class SamlController {
         }
       } catch (error) {
         const errorMessage = error instanceof Error ? error.message : 'Unknown error';
+
         this.log(
           'error',
           '[ACS] SAML validation error for workspace:',
@@ -387,6 +390,7 @@ export default class SamlController {
        */
       if (error instanceof Error && error.message.includes('SAML')) {
         const errorMessage = error.message;
+
         this.log(
           'error',
           '[ACS] SAML processing error for workspace:',
@@ -400,6 +404,7 @@ export default class SamlController {
       }
 
       const errorMessage = error instanceof Error ? error.message : 'Unknown error';
+
       this.log(
         'error',
         '[ACS] ACS callback error for workspace:',

src/typeDefs/event.ts

@@ -296,6 +296,21 @@ type Event {
     """
     timezoneOffset: Int! = 0
   ): [ChartLine!]!
+
+  """
+  Return graph of affected users dynamics for the specified period
+  """
+  affectedUsersChartData(
+    """
+    How many days we need to fetch for displaying in a chart
+    """
+    days: Int! = 0
+
+    """
+    User's local timezone offset in minutes
+    """
+    timezoneOffset: Int! = 0
+  ): [ChartLine!]!
 }
 
 """