releaser logic

Author: 3388ShubinPavel

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.hawk!, dataLoaders);
+
     return {
       usersFactory,
       workspacesFactory,
       projectsFactory,
       plansFactory,
       businessOperationsFactory,
+      releasesFactory,
     };
   }
 

src/models/releaseFactory.ts

@@ -0,0 +1,58 @@
+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;
+  }
+
+  /**
+   * Получить релиз по его идентификатору с использованием DataLoader
+   * @param id - идентификатор релиза
+   */
+  public async getReleaseById(id: string): Promise<ReleaseDBScheme | null> {
+    return this.dataLoaders.releaseById.load(id);
+  }
+
+  /**
+   * Получить все релизы
+   */
+  public async getAllReleases(): Promise<ReleaseDBScheme[]> {
+    return this.collection.find({}).toArray();
+  }
+
+  /**
+   * Получить релизы с пагинацией
+   * @param page - номер страницы (начиная с 1)
+   * @param limit - количество элементов на страницу
+   */
+  public async getReleasesPaginated(page: number, limit: number): Promise<ReleaseDBScheme[]> {
+    const skip = (page - 1) * limit;
+    return this.collection.find({}).skip(skip).limit(limit).toArray();
+  }
+
+  /**
+   * Получить релизы по идентификатору проекта
+   * @param projectId - идентификатор проекта
+   */
+  public async getReleasesByProjectId(projectId: string): Promise<ReleaseDBScheme[]> {
+    return this.collection.find({ projectId }).toArray();
+  }
+}

src/typeDefs/release.ts

@@ -0,0 +1,79 @@
+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!]!
+  }
+
+  """
+  Queries related to releases
+  """
+  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;
 }
 
 /**