feat: add factory for releasees

Author: GeekaN2

src/index.ts

@@ -28,6 +28,7 @@ import schema from './schema';
 import { graphqlUploadExpress } from 'graphql-upload';
 import { metricsMiddleware, createMetricsServer, graphqlMetricsPlugin } from './metrics';
 import { requestLogger } from './utils/logger';
+import ReleasesFactory from './models/releasesFactory';
 
 /**
  * Option to enable playground
@@ -164,12 +165,16 @@ class HawkAPI {
     // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
     const businessOperationsFactory = new BusinessOperationsFactory(mongo.databases.hawk!, dataLoaders);
 
+    // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+    const releasesFactory = new ReleasesFactory(mongo.databases.events!);
+
     return {
       usersFactory,
       workspacesFactory,
       projectsFactory,
       plansFactory,
       businessOperationsFactory,
+      releasesFactory,
     };
   }
 

src/models/releasesFactory.ts

@@ -0,0 +1,54 @@
+import type { Collection, Db, ObjectId } from 'mongodb';
+import type { ReleaseDBScheme } from '@hawk.so/types';
+
+/**
+ * ReleasesFactory
+ * Helper for accessing releases collection
+ */
+export default class ReleasesFactory {
+  /**
+   * DataBase collection to work with
+   */
+  private readonly collection: Collection<ReleaseDBScheme>;
+
+  /**
+   * Creates releases factory instance
+   * @param dbConnection - connection to Events DB
+   */
+  constructor(dbConnection: Db) {
+    this.collection = dbConnection.collection<ReleaseDBScheme>('releases');
+  }
+
+  /**
+   * Find one release document by projectId and release label.
+   * Tries both exact string match and numeric fallback (if release can be cast to number).
+   */
+  public async findByProjectAndRelease(
+    projectId: string | ObjectId,
+    release: string
+  ): Promise<ReleaseDBScheme | null> {
+    const projectIdStr = projectId.toString();
+
+    // Try exact match as stored
+    let doc = await this.collection.findOne({
+      projectId: projectIdStr,
+      release: release as ReleaseDBScheme['release'],
+    });
+
+    // Fallback if release stored as number
+    if (!doc) {
+      const asNumber = Number(release);
+
+      if (!Number.isNaN(asNumber)) {
+        doc = await this.collection.findOne({
+          projectId: projectIdStr,
+          release: asNumber as unknown as ReleaseDBScheme['release'],
+        });
+      }
+    }
+
+    return doc;
+  }
+}
+
+

src/resolvers/project.js

@@ -6,6 +6,7 @@ const { ApolloError, UserInputError } = require('apollo-server-express');
 const Validator = require('../utils/validator');
 const EventsFactory = require('../models/eventsFactory');
 const getEventsFactory = require('./helpers/eventsFactory').default;
+const ReleasesFactory = require('../models/releasesFactory').default;
 const ProjectToWorkspace = require('../models/projectToWorkspace');
 const { dateFromObjectId } = require('../utils/dates');
 const ProjectModel = require('../models/project').default;
@@ -570,13 +571,9 @@ module.exports = {
      * @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,
-      });
+    async releaseDetails(project, { release }, { factories }) {
+      const releasesFactory = factories.releasesFactory;
+      const releaseDoc = await releasesFactory.findByProjectAndRelease(project._id, release);
 
       let enrichedFiles = Array.isArray(releaseDoc?.files) ? releaseDoc.files : [];
 

src/types/graphql.ts

@@ -5,6 +5,7 @@ import ProjectsFactory from '../models/projectsFactory';
 // import Accounting from 'codex-accounting-sdk';
 import PlansFactory from '../models/plansFactory';
 import BusinessOperationsFactory from '../models/businessOperationsFactory';
+import ReleasesFactory from '../models/releasesFactory';
 
 /**
  * Resolver's Context argument
@@ -86,6 +87,11 @@ export interface ContextFactories {
    * Allows to work with the Business Operations models
    */
   businessOperationsFactory: BusinessOperationsFactory;
+
+  /**
+   * Releases factory for working with releases
+   */
+  releasesFactory: ReleasesFactory;
 }
 
 /**