feat: add releaseDetails resolver

Author: GeekaN2

src/models/eventsFactory.js

@@ -186,6 +186,7 @@ class EventsFactory extends Factory {
    * @param {'BY_DATE' | 'BY_COUNT'} sort - events sort order
    * @param {EventsFilters} filters - marks by which events should be filtered
    * @param {String} search - Search query
+   * @param {String} release - release name
    *
    * @return {DaylyEventsPortionSchema}
    */
@@ -194,7 +195,8 @@ class EventsFactory extends Factory {
     paginationCursor = null,
     sort = 'BY_DATE',
     filters = {},
-    search = ''
+    search = '',
+    release
   ) {
     if (typeof search !== 'string') {
       throw new Error('Search parameter must be a string');
@@ -314,6 +316,25 @@ class EventsFactory extends Factory {
       )
       : {};
 
+    // Filter by release if provided (coerce event payload release to string)
+    const releaseFilter = release
+      ? {
+        $expr: {
+          $eq: [
+            {
+              $convert: {
+                input: '$event.payload.release',
+                to: 'string',
+                onError: '',
+                onNull: '',
+              },
+            },
+            String(release),
+          ],
+        },
+      }
+      : {};
+
     pipeline.push(
       /**
        * Left outer join original event on groupHash field
@@ -350,6 +371,7 @@ class EventsFactory extends Factory {
         $match: {
           ...matchFilter,
           ...searchFilter,
+          ...releaseFilter,
         },
       },
       { $limit: limit + 1 },

src/resolvers/project.js

@@ -454,11 +454,12 @@ module.exports = {
      * @param {DailyEventsCursor} cursor - object with boundary values of the first event in the next portion
      * @param {'BY_DATE' | 'BY_COUNT'} sort - events sort order
      * @param {EventsFilters} filters - marks by which events should be filtered
+     * @param {String} release - release name
      * @param {String} search - search query
      *
      * @return {Promise<RecentEventSchema[]>}
      */
-    async dailyEventsPortion(project, { limit, nextCursor, sort, filters, search }, context) {
+    async dailyEventsPortion(project, { limit, nextCursor, sort, filters, search, release }, context) {
       if (search) {
         if (search.length > MAX_SEARCH_QUERY_LENGTH) {
           search = search.slice(0, MAX_SEARCH_QUERY_LENGTH);
@@ -467,7 +468,7 @@ module.exports = {
 
       const factory = getEventsFactory(context, project._id);
 
-      const dailyEventsPortion = await factory.findDailyEventsPortion(limit, nextCursor, sort, filters, search);
+      const dailyEventsPortion = await factory.findDailyEventsPortion(limit, nextCursor, sort, filters, search, release);
 
       return dailyEventsPortion;
     },
@@ -561,5 +562,44 @@ module.exports = {
 
       return result;
     },
+
+    /**
+     * Return detailed info for a specific release
+     * @param {ProjectDBScheme} project
+     * @param {Object} args
+     * @param {string} args.release - release identifier
+     */
+    async releaseDetails(project, { release }) {
+      const releasesCollection = mongo.databases.events.collection('releases');
+
+      const releaseDoc = await releasesCollection.findOne({
+        projectId: project._id.toString(),
+        release: release,
+      });
+
+      return {
+        release,
+        projectId: project._id,
+        commitsCount: Array.isArray(releaseDoc?.commits) ? releaseDoc.commits.length : 0,
+        filesCount: Array.isArray(releaseDoc?.files) ? releaseDoc.files.length : 0,
+        commits: releaseDoc?.commits || [],
+        files: releaseDoc?.files || [],
+        timestamp: releaseDoc?._id ? dateFromObjectId(releaseDoc._id) : null,
+      };
+    },
+  },
+
+  /**
+   * Field resolvers for ProjectReleaseDetails
+   */
+  ProjectReleaseDetails: {
+
+    /**
+     * Reuse dailyEventsPortion for release details
+     */
+    async dailyEventsPortion(parent, { limit, nextCursor, sort, filters, search }) {
+      const factory = new EventsFactory(parent.projectId);
+      return factory.findDailyEventsPortion(limit, nextCursor, sort, filters, search, parent.release);
+    },
   },
 };

src/typeDefs/project.ts

@@ -155,6 +155,91 @@ type ProjectRelease {
   filesCount: Int!
 }
 
+"""
+Source map file information
+"""
+type SourceMapDataExtended {
+  """
+  Name of source-map file
+  """
+  mapFileName: String!
+
+  """
+  Bundle or chunk name
+  """
+  originFileName: String!
+}
+
+"""
+Detailed info for a specific release
+"""
+type ProjectReleaseDetails {
+  """
+  Release identifier
+  """
+  release: String!
+
+  """
+  Number of commits in this release
+  """
+  commitsCount: Int!
+
+  """
+  Number of files in this release
+  """
+  filesCount: Int!
+
+  """
+  Release creation timestamp
+  """
+  timestamp: Float!
+
+  """
+  Commits (from releases collection)
+  """
+  commits: [Commit!]
+
+  """
+  Changed files (from releases collection)
+  """
+  files: [SourceMapDataExtended!]
+
+  """
+  Portion of daily events for this release (same shape as Project.dailyEventsPortion)
+  """
+  dailyEventsPortion(
+    """
+    Maximum number of results
+    """
+    limit: Int! = 50
+
+    """
+    Pointer to the first event of the portion that would be fetched
+    """
+    nextCursor: DailyEventsCursorInput
+
+    """
+    Events sort order
+    """
+    sort: EventsSortOrder = lastRepetitionTime
+
+    """
+    Event marks by which events should be filtered
+    """
+    filters: EventsFiltersInput
+
+    """
+    Search query (for release label)
+    """
+    search: String
+
+    """
+    Release label to filter events by payload.release
+    """
+    release: String
+  ): DailyEventsPortion!
+}
+
 """
 Respose object with updated project and his id
 """
@@ -282,6 +367,11 @@ type Project {
     Search query
     """
     search: String
+
+    """
+    Release label to filter events by payload.release
+    """
+    release: String
   ): DailyEventsPortion
 
   """