feat(core): add releasesFactory to set releases list

package.json

@@ -1,6 +1,6 @@
 {
   "name": "hawk.api",
-  "version": "1.1.14",
+  "version": "1.1.15",
   "main": "index.ts",
   "license": "UNLICENSED",
   "scripts": {

src/dataLoaders.ts

@@ -1,6 +1,6 @@
 import DataLoader from 'dataloader';
 import { Db, ObjectId } from 'mongodb';
-import { PlanDBScheme, UserDBScheme, WorkspaceDBScheme, ProjectDBScheme } from '@hawk.so/types';
+import { PlanDBScheme, UserDBScheme, WorkspaceDBScheme, ProjectDBScheme, ReleaseDBScheme } from '@hawk.so/types';
 
 /**
  * Class for setting up data loaders
@@ -47,6 +47,11 @@ export default class DataLoaders {
     { cache: false }
   );
 
+  public releaseById = new DataLoader<string, ReleaseDBScheme | null>(
+    (releaseIds) => this.batchByIds<ReleaseDBScheme>('releases', releaseIds),
+    { cache: false }
+  );
+
   /**
    * MongoDB connection to make queries
    */

src/index.ts

@@ -26,6 +26,7 @@ import PlansFactory from './models/plansFactory';
 import BusinessOperationsFactory from './models/businessOperationsFactory';
 import schema from './schema';
 import { graphqlUploadExpress } from 'graphql-upload';
+import ReleasesFactory from './models/releaseFactory';
 
 /**
  * Option to enable playground
@@ -145,12 +146,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!, dataLoaders);
+
     return {
       usersFactory,
       workspacesFactory,
       projectsFactory,
       plansFactory,
       businessOperationsFactory,
+      releasesFactory,
     };
   }
 

src/models/releaseFactory.ts

@@ -0,0 +1,91 @@
+import { Collection, Db } from 'mongodb';
+import { ReleaseDBScheme } from '@hawk.so/types';
+import DataLoaders from '../dataLoaders';
+
+export default class ReleasesFactory {
+  /**
+   * Коллекция релизов
+   */
+  private collection: Collection<ReleaseDBScheme>;
+
+  /**
+   * DataLoader для релизов
+   */
+  private dataLoaders: DataLoaders;
+
+  /**
+   * Создаёт экземпляр фабрики релизов
+   * @param dbConnection - подключение к базе данных
+   * @param dataLoaders - экземпляр DataLoaders для батчинга запросов
+   */
+  constructor(dbConnection: Db, dataLoaders: DataLoaders) {
+    this.collection = dbConnection.collection('releases');
+    this.dataLoaders = dataLoaders;
+    console.log("[ReleasesFactory] Initialized with collection 'releases'");
+  }
+
+  /**
+   * Получить релиз по его идентификатору с использованием DataLoader
+   * @param id - идентификатор релиза
+   */
+  public async getReleaseById(id: string): Promise<ReleaseDBScheme | null> {
+    console.log(`[ReleasesFactory] getReleaseById called with id: ${id}`);
+    try {
+      const release = await this.dataLoaders.releaseById.load(id);
+      console.log(`[ReleasesFactory] getReleaseById result:`, release);
+      return release;
+    } catch (error) {
+      console.error(`[ReleasesFactory] Error in getReleaseById:`, error);
+      throw error;
+    }
+  }
+
+  /**
+   * Получить все релизы
+   */
+  public async getAllReleases(): Promise<ReleaseDBScheme[]> {
+    console.log(`[ReleasesFactory] getAllReleases called`);
+    try {
+      const releases = await this.collection.find({}).toArray();
+      console.log(`[ReleasesFactory] getAllReleases returned ${releases.length} releases`);
+      return releases;
+    } catch (error) {
+      console.error(`[ReleasesFactory] Error in getAllReleases:`, error);
+      throw error;
+    }
+  }
+
+  /**
+   * Получить релизы с пагинацией
+   * @param page - номер страницы (начиная с 1)
+   * @param limit - количество элементов на страницу
+   */
+  public async getReleasesPaginated(page: number, limit: number): Promise<ReleaseDBScheme[]> {
+    const skip = (page - 1) * limit;
+    console.log(`[ReleasesFactory] getReleasesPaginated called with page: ${page}, limit: ${limit}, skip: ${skip}`);
+    try {
+      const releases = await this.collection.find({}).skip(skip).limit(limit).toArray();
+      console.log(`[ReleasesFactory] getReleasesPaginated returned ${releases.length} releases`);
+      return releases;
+    } catch (error) {
+      console.error(`[ReleasesFactory] Error in getReleasesPaginated:`, error);
+      throw error;
+    }
+  }
+
+  /**
+   * Получить релизы по идентификатору проекта
+   * @param projectId - идентификатор проекта
+   */
+  public async getReleasesByProjectId(projectId: string): Promise<ReleaseDBScheme[]> {
+    console.log(`[ReleasesFactory] getReleasesByProjectId called with projectId: ${projectId}`);
+    try {
+      const releases = await this.collection.find({ projectId: projectId }).toArray();
+      console.log(`[ReleasesFactory] getReleasesByProjectId returned ${releases.length} releases`);
+      return releases;
+    } catch (error) {
+      console.error(`[ReleasesFactory] Error in getReleasesByProjectId:`, error);
+      throw error;
+    }
+  }
+}

src/resolvers/index.js

@@ -17,6 +17,7 @@ const userNotifications = require('./userNotifications').default;
 const billing = require('./billingNew').default;
 const EncodedJSON = require('./encodedJSON').default;
 const seed = require('./seed').default;
+const release = require('./release').default;
 
 /**
  * @typedef ResolverObj
@@ -74,6 +75,7 @@ const resolvers = [
   userNotifications,
   plans,
   billing,
+  release,
 ];
 
 if (isE2E) {

src/resolvers/release.ts

@@ -0,0 +1,24 @@
+import ReleasesFactory from '../models/releaseFactory';
+
+export default {
+  Query: {
+    /**
+     * Fetch all releases or releases filtered by projectId
+     * @param {ResolverObj} _ - Parent object, not used
+     * @param {ResolverArgs} args - Query arguments
+     * @param {ContextFactories} context - Global GraphQL context with factories
+     * @returns {Promise<Release[]>}
+     */
+    getReleases: async (_: any, args: { projectId?: string }, { factories }: any) => {
+      try {
+        if (args.projectId) {
+          return await factories.releasesFactory.getReleasesByProjectId(args.projectId);
+        }
+        return await factories.releasesFactory.getAllReleases();
+      } catch (error) {
+        console.error('Error fetching releases:', error);
+        throw new Error('Не удалось получить релизы');
+      }
+    },
+  },
+};

src/typeDefs/index.ts

@@ -15,6 +15,7 @@ import workspaceMutations from './workspaceMutations';
 import chart from './chart';
 import plans from './plans';
 import seed from './seed';
+import release from './release';
 import isE2E from '../utils/isE2E';
 
 const rootSchema = gql`
@@ -98,6 +99,7 @@ const typeDefinitions = [
   workspaceMutations,
   chart,
   plans,
+  release,
 ];
 
 if (isE2E) {

src/typeDefs/release.ts

@@ -0,0 +1,76 @@
+import { gql } from 'apollo-server-express';
+
+export default gql`
+  """
+  Release commit
+  """
+  type Commit {
+    """
+    Hash of the commit
+    """
+    hash: String!
+
+    """
+    Commit author
+    """
+    author: String!
+
+    """
+    Commit title
+    """
+    title: String!
+
+    """
+    Commit creation date
+    """
+    date: DateTime!
+  }
+
+  """
+  Source map file details
+  """
+  type SourceMapData {
+    """
+    Source map filename
+    """
+    mapFileName: String!
+
+    """
+    Original source filename
+    """
+    originFileName: String!
+  }
+
+  """
+  Release data
+  """
+  type Release {
+    """
+    Release name
+    """
+    releaseName: String! @renameFrom(name: "release")
+
+    """
+    Project ID associated with the release
+    """
+    projectId: ID!
+
+    """
+    Release commits
+    """
+    commits: [Commit!]!
+
+    """
+    Source maps associated with the release
+    """
+    files: [SourceMapData!]!
+  }
+
+  extend type Query {
+    """
+    Fetch list of releases.
+    If projectId is provided, fetch releases for the given project.
+    """
+    getReleases(projectId: ID): [Release]!
+  }
+`;

src/types/graphql.ts

@@ -2,9 +2,9 @@ import UsersFactory from '../models/usersFactory';
 import WorkspacesFactory from '../models/workspacesFactory';
 import { GraphQLField } from 'graphql';
 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/releaseFactory";
 
 /**
  * Resolver's Context argument
@@ -19,11 +19,6 @@ export interface ResolverContextBase {
    * Factories for working with models
    */
   factories: ContextFactories;
-
-  // /**
-  //  * SDK for working with CodeX Accounting API
-  //  */
-  // accounting: Accounting;
 }
 
 /**
@@ -79,6 +74,11 @@ export interface ContextFactories {
    * Allows to work with the Business Operations models
    */
   businessOperationsFactory: BusinessOperationsFactory;
+
+  /**
+   * Allows to work with releases
+   */
+  releasesFactory: ReleasesFactory;
 }
 
 /**