Merge branch 'master' of github.com:codex-team/hawk.api.nodejs into feat/opt-dupl

Author: slaveeks

README.md

@@ -25,7 +25,8 @@ To execute the request, enter it in the input field on the left and click on the
 On the right side you will see the result of the query.
 
 ## GraphQL Voyager
-You can view API Schema visualization in `/voyager` page in your browser. To see current production schema go to [here](https://api.beta.hawk.so/voyager)
+You can view API Schema visualization in `/voyager` page in your browser.
+To see current production schema go to [here](https://api.beta.hawk.so/voyager)
 
 ## Migrations
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "hawk.api",
-  "version": "1.2.8",
+  "version": "1.2.10",
   "main": "index.ts",
   "license": "BUSL-1.1",
   "scripts": {

src/resolvers/project.js

@@ -177,6 +177,79 @@ module.exports = {
       }
     },
 
+    /**
+     * Update project rate limits settings
+     *
+     * @param {ResolverObj} _obj
+     * @param {string} id - project id
+     * @param {Object | null} rateLimitSettings - rate limit settings (null to remove)
+     * @param {UserInContext} user - current authorized user {@see ../index.js}
+     * @param {ContextFactories} factories - factories for working with models
+     *
+     * @returns {Project}
+     */
+    async updateProjectRateLimits(_obj, { id, rateLimitSettings }, { user, factories }) {
+      const project = await factories.projectsFactory.findById(id);
+
+      if (!project) {
+        throw new ApolloError('There is no project with that id');
+      }
+
+      if (project.workspaceId.toString() === '6213b6a01e6281087467cc7a') {
+        throw new ApolloError('Unable to update demo project');
+      }
+
+      // Validate rate limit settings if provided
+      if (rateLimitSettings) {
+        const { N, T } = rateLimitSettings;
+
+        // Validate that N and T exist
+        if (!N || !T) {
+          throw new UserInputError(
+            'Rate limit settings must contain both N (threshold) and T (period) fields.'
+          );
+        }
+
+        // Validate N (threshold) - must be positive integer > 0
+        if (typeof N !== 'number' || !Number.isInteger(N) || N <= 0) {
+          throw new UserInputError(
+            'Invalid rate limit threshold. Must be a positive integer greater than 0.'
+          );
+        }
+
+        // Validate T (period) - must be positive integer >= 60 (1 minute)
+        if (typeof T !== 'number' || !Number.isInteger(T) || T < 60) {
+          throw new UserInputError(
+            'Invalid rate limit period. Must be a positive integer greater than or equal to 60 seconds.'
+          );
+        }
+
+        // Validate reasonable maximums (prevent extremely large values)
+        const MAX_THRESHOLD = 1000000000; // 1 billion
+        const MAX_PERIOD = 60 * 60 * 24 * 31; // 1 month in seconds
+
+        if (N > MAX_THRESHOLD) {
+          throw new UserInputError(
+            `Rate limit threshold cannot exceed ${MAX_THRESHOLD.toLocaleString()}.`
+          );
+        }
+
+        if (T > MAX_PERIOD) {
+          throw new UserInputError(
+            `Rate limit period cannot exceed ${MAX_PERIOD.toLocaleString()} seconds (1 month).`
+          );
+        }
+      }
+
+      try {
+        return project.updateProject({
+          rateLimitSettings: rateLimitSettings || null,
+        });
+      } catch (err) {
+        throw new ApolloError('Failed to update project rate limit settings', { originalError: err });
+      }
+    },
+
     /**
      * Generates new project integration token by id
      *
@@ -374,5 +447,80 @@ module.exports = {
 
       return factory.findChartData(days, timezoneOffset);
     },
+
+    /**
+     * Returns list of not archived releases with number of events that were introduced in this release
+     * We count events as new, cause payload.release only contain the same release name if the event is original
+     *
+     * @param {ProjectDBScheme} project - result of parent resolver
+     * @returns {Promise<Array<{release: string, timestamp: number, newEventsCount: number, commitsCount: number, filesCount: number}>>}
+     */
+    async releases(project) {
+      const releasesCollection = mongo.databases.events.collection('releases');
+
+      const pipeline = [
+        { $match: { projectId: project._id.toString() } },
+        {
+          $project: {
+            release: {
+              $convert: {
+                input: '$release',
+                to: 'string',
+                onError: '',
+                onNull: '',
+              },
+            },
+            commitsCount: { $size: { $ifNull: ['$commits', [] ] } },
+            filesCount: { $size: { $ifNull: ['$files', [] ] } },
+            _releaseIdSec: { $floor: { $divide: [ { $toLong: { $toDate: '$_id' } }, 1000] } },
+          },
+        },
+        {
+          $lookup: {
+            from: 'events:' + project._id,
+            let: { rel: '$release' },
+            pipeline: [
+              {
+                $match: {
+                  $expr: {
+                    $eq: [ {
+                      $convert: {
+                        input: '$payload.release',
+                        to: 'string',
+                        onError: '',
+                        onNull: '',
+                      },
+                    }, '$$rel'],
+                  },
+                },
+              },
+              {
+                $group: {
+                  _id: null,
+                  count: { $sum: 1 },
+                },
+              },
+            ],
+            as: 'eventAgg',
+          },
+        },
+        {
+          $project: {
+            _id: 0,
+            release: 1,
+            commitsCount: 1,
+            filesCount: 1,
+            newEventsCount: { $ifNull: [ { $arrayElemAt: ['$eventAgg.count', 0] }, 0] },
+            timestamp: '$_releaseIdSec',
+          },
+        },
+        { $sort: { _id: -1 } },
+      ];
+
+      const cursor = releasesCollection.aggregate(pipeline);
+      const result = await cursor.toArray();
+
+      return result;
+    },
   },
 };

src/typeDefs/project.ts

@@ -1,6 +1,35 @@
 import { gql } from 'apollo-server-express';
 
 export default gql`
+  """
+  Rate limits configuration input
+  """
+  input RateLimitSettingsInput {
+    """
+    Rate limit threshold (N events)
+    """
+    N: Int!
+
+    """
+    Rate limit period in seconds (T seconds)
+    """
+    T: Int!
+  }
+
+  """
+  Rate limits configuration
+  """
+  type RateLimitSettings {
+    """
+    Rate limit threshold (N events)
+    """
+    N: Int!
+
+    """
+    Rate limit period in seconds (T seconds)
+    """
+    T: Int!
+  }
 
 """
 Possible events order
@@ -96,6 +125,36 @@ input EventsFiltersInput {
   ignored: Boolean
 }
 
+"""
+Aggregated release info for project events
+"""
+type ProjectRelease {
+  """
+  Release identifier
+  """
+  release: String!
+
+  """
+  First occurrence timestamp
+  """
+  timestamp: Float!
+
+  """
+  Number of new events introduced in this release
+  """
+  newEventsCount: Int!
+
+  """
+  Number of commits in this release
+  """
+  commitsCount: Int!
+
+  """
+  Number of files in this release
+  """
+  filesCount: Int!
+}
+
 """
 Respose object with updated project and his id
 """
@@ -253,6 +312,16 @@ type Project {
   Event grouping patterns
   """
   eventGroupingPatterns: [ProjectEventGroupingPattern]
+
+  """
+  Rate limits configuration
+  """
+  rateLimitSettings: RateLimitSettings
+
+  """
+  List of releases with unique events count, commits count and files count
+  """
+  releases: [ProjectRelease!]!
 }
 
 extend type Query {
@@ -305,6 +374,26 @@ extend type Mutation {
     Project image
     """
     image: Upload @uploadImage
+
+    """
+    Rate limits configuration
+    """
+    rateLimitSettings: RateLimitSettingsInput
+  ): Project! @requireAdmin
+
+  """
+  Update project rate limits settings
+  """
+  updateProjectRateLimits(
+    """
+    What project to update
+    """
+    id: ID!
+
+    """
+    Rate limits configuration. Pass null to remove rate limits.
+    """
+    rateLimitSettings: RateLimitSettingsInput
   ): Project! @requireAdmin
 
   """