Add DestroyMany to graphql query runner

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/factories/graphql-query-resolver.factory.ts

@@ -8,6 +8,7 @@ import {
 } from 'src/engine/api/graphql/workspace-resolver-builder/interfaces/workspace-resolvers-builder.interface';
 
 import { GraphqlQueryCreateManyResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-create-many-resolver.service';
+import { GraphqlQueryDestroyManyResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-many-resolver.service';
 import { GraphqlQueryDestroyOneResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-one-resolver.service';
 import { GraphqlQueryFindDuplicatesResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-find-duplicates-resolver.service';
 import { GraphqlQueryFindManyResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-find-many-resolver.service';
@@ -37,6 +38,8 @@ export class GraphqlQueryResolverFactory {
         return this.moduleRef.get(GraphqlQueryCreateManyResolverService);
       case 'destroyOne':
         return this.moduleRef.get(GraphqlQueryDestroyOneResolverService);
+      case 'destroyMany':
+        return this.moduleRef.get(GraphqlQueryDestroyManyResolverService);
       case 'updateOne':
       case 'deleteOne':
         return this.moduleRef.get(GraphqlQueryUpdateOneResolverService);

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/graphql-query-runner.module.ts

@@ -3,6 +3,7 @@ import { Module } from '@nestjs/common';
 import { GraphqlQueryResolverFactory } from 'src/engine/api/graphql/graphql-query-runner/factories/graphql-query-resolver.factory';
 import { GraphqlQueryRunnerService } from 'src/engine/api/graphql/graphql-query-runner/graphql-query-runner.service';
 import { GraphqlQueryCreateManyResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-create-many-resolver.service';
+import { GraphqlQueryDestroyManyResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-many-resolver.service';
 import { GraphqlQueryDestroyOneResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-one-resolver.service';
 import { GraphqlQueryFindDuplicatesResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-find-duplicates-resolver.service';
 import { GraphqlQueryFindManyResolverService } from 'src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-find-many-resolver.service';
@@ -16,14 +17,15 @@ import { WorkspaceQueryRunnerModule } from 'src/engine/api/graphql/workspace-que
 import { FeatureFlagModule } from 'src/engine/core-modules/feature-flag/feature-flag.module';
 
 const graphqlQueryResolvers = [
-  GraphqlQueryFindOneResolverService,
-  GraphqlQueryFindManyResolverService,
-  GraphqlQueryFindDuplicatesResolverService,
   GraphqlQueryCreateManyResolverService,
+  GraphqlQueryDestroyManyResolverService,
   GraphqlQueryDestroyOneResolverService,
-  GraphqlQueryUpdateOneResolverService,
-  GraphqlQueryUpdateManyResolverService,
+  GraphqlQueryFindDuplicatesResolverService,
+  GraphqlQueryFindManyResolverService,
+  GraphqlQueryFindOneResolverService,
   GraphqlQuerySearchResolverService,
+  GraphqlQueryUpdateManyResolverService,
+  GraphqlQueryUpdateOneResolverService,
 ];
 
 @Module({

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/graphql-query-runner.service.ts

@@ -13,6 +13,7 @@ import {
   CreateOneResolverArgs,
   DeleteManyResolverArgs,
   DeleteOneResolverArgs,
+  DestroyManyResolverArgs,
   DestroyOneResolverArgs,
   FindDuplicatesResolverArgs,
   FindManyResolverArgs,
@@ -285,6 +286,25 @@ export class GraphqlQueryRunnerService {
     return result;
   }
 
+  @LogExecutionTime()
+  async destroyMany<ObjectRecord extends IRecord>(
+    args: DestroyManyResolverArgs,
+    options: WorkspaceQueryRunnerOptions,
+  ): Promise<ObjectRecord[]> {
+    const result = await this.executeQuery<
+      DestroyManyResolverArgs,
+      ObjectRecord[]
+    >('destroyMany', args, options);
+
+    this.apiEventEmitterService.emitDestroyEvents(
+      result,
+      options.authContext,
+      options.objectMetadataItem,
+    );
+
+    return result;
+  }
+
   @LogExecutionTime()
   public async restoreMany<ObjectRecord extends IRecord>(
     args: RestoreManyResolverArgs,

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-many-resolver.service.ts

@@ -0,0 +1,108 @@
+import { Injectable } from '@nestjs/common';
+
+import graphqlFields from 'graphql-fields';
+
+import { ResolverService } from 'src/engine/api/graphql/graphql-query-runner/interfaces/resolver-service.interface';
+import { Record as IRecord } from 'src/engine/api/graphql/workspace-query-builder/interfaces/record.interface';
+import { WorkspaceQueryRunnerOptions } from 'src/engine/api/graphql/workspace-query-runner/interfaces/query-runner-option.interface';
+import { DestroyManyResolverArgs } from 'src/engine/api/graphql/workspace-resolver-builder/interfaces/workspace-resolvers-builder.interface';
+
+import { QUERY_MAX_RECORDS } from 'src/engine/api/graphql/graphql-query-runner/constants/query-max-records.constant';
+import { GraphqlQueryParser } from 'src/engine/api/graphql/graphql-query-runner/graphql-query-parsers/graphql-query.parser';
+import { ObjectRecordsToGraphqlConnectionHelper } from 'src/engine/api/graphql/graphql-query-runner/helpers/object-records-to-graphql-connection.helper';
+import { ProcessNestedRelationsHelper } from 'src/engine/api/graphql/graphql-query-runner/helpers/process-nested-relations.helper';
+import { TwentyORMGlobalManager } from 'src/engine/twenty-orm/twenty-orm-global.manager';
+import { formatResult } from 'src/engine/twenty-orm/utils/format-result.util';
+
+@Injectable()
+export class GraphqlQueryDestroyManyResolverService
+  implements ResolverService<DestroyManyResolverArgs, IRecord[]>
+{
+  constructor(
+    private readonly twentyORMGlobalManager: TwentyORMGlobalManager,
+  ) {}
+
+  async resolve<ObjectRecord extends IRecord = IRecord>(
+    args: DestroyManyResolverArgs,
+    options: WorkspaceQueryRunnerOptions,
+  ): Promise<ObjectRecord[]> {
+    const { authContext, objectMetadataMapItem, objectMetadataMap, info } =
+      options;
+    const dataSource =
+      await this.twentyORMGlobalManager.getDataSourceForWorkspace(
+        authContext.workspace.id,
+      );
+
+    const repository = dataSource.getRepository(
+      objectMetadataMapItem.nameSingular,
+    );
+
+    const graphqlQueryParser = new GraphqlQueryParser(
+      objectMetadataMapItem.fields,
+      objectMetadataMap,
+    );
+
+    const selectedFields = graphqlFields(info);
+
+    const { relations } = graphqlQueryParser.parseSelectedFields(
+      objectMetadataMapItem,
+      selectedFields,
+    );
+
+    const queryBuilder = repository.createQueryBuilder(
+      objectMetadataMapItem.nameSingular,
+    );
+
+    const withFilterQueryBuilder = graphqlQueryParser.applyFilterToBuilder(
+      queryBuilder,
+      objectMetadataMapItem.nameSingular,
+      args.filter,
+    );
+
+    const nonFormattedDeletedObjectRecords = await withFilterQueryBuilder
+      .delete()
+      .returning('*')
+      .execute();
+
+    const deletedRecords = formatResult(
+      nonFormattedDeletedObjectRecords.raw,
+      objectMetadataMapItem,
+      objectMetadataMap,
+    );
+
+    const processNestedRelationsHelper = new ProcessNestedRelationsHelper();
+
+    if (relations) {
+      await processNestedRelationsHelper.processNestedRelations(
+        objectMetadataMap,
+        objectMetadataMapItem,
+        deletedRecords,
+        relations,
+        QUERY_MAX_RECORDS,
+        authContext,
+        dataSource,
+      );
+    }
+
+    const typeORMObjectRecordsParser =
+      new ObjectRecordsToGraphqlConnectionHelper(objectMetadataMap);
+
+    return deletedRecords.map((record: ObjectRecord) =>
+      typeORMObjectRecordsParser.processRecord(
+        record,
+        objectMetadataMapItem.nameSingular,
+        1,
+        1,
+      ),
+    );
+  }
+
+  async validate(
+    args: DestroyManyResolverArgs,
+    _options: WorkspaceQueryRunnerOptions,
+  ): Promise<void> {
+    if (!args.filter) {
+      throw new Error('Filter is required');
+    }
+  }
+}

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-one-resolver.service.ts

@@ -1,14 +1,20 @@
 import { Injectable } from '@nestjs/common';
 
+import graphqlFields from 'graphql-fields';
+
 import { ResolverService } from 'src/engine/api/graphql/graphql-query-runner/interfaces/resolver-service.interface';
 import { Record as IRecord } from 'src/engine/api/graphql/workspace-query-builder/interfaces/record.interface';
 import { WorkspaceQueryRunnerOptions } from 'src/engine/api/graphql/workspace-query-runner/interfaces/query-runner-option.interface';
 import { DestroyOneResolverArgs } from 'src/engine/api/graphql/workspace-resolver-builder/interfaces/workspace-resolvers-builder.interface';
 
+import { QUERY_MAX_RECORDS } from 'src/engine/api/graphql/graphql-query-runner/constants/query-max-records.constant';
 import {
   GraphqlQueryRunnerException,
   GraphqlQueryRunnerExceptionCode,
 } from 'src/engine/api/graphql/graphql-query-runner/errors/graphql-query-runner.exception';
+import { GraphqlQueryParser } from 'src/engine/api/graphql/graphql-query-runner/graphql-query-parsers/graphql-query.parser';
+import { ObjectRecordsToGraphqlConnectionHelper } from 'src/engine/api/graphql/graphql-query-runner/helpers/object-records-to-graphql-connection.helper';
+import { ProcessNestedRelationsHelper } from 'src/engine/api/graphql/graphql-query-runner/helpers/process-nested-relations.helper';
 import { TwentyORMGlobalManager } from 'src/engine/twenty-orm/twenty-orm-global.manager';
 import { formatResult } from 'src/engine/twenty-orm/utils/format-result.util';
 
@@ -24,34 +30,78 @@ export class GraphqlQueryDestroyOneResolverService
     args: DestroyOneResolverArgs,
     options: WorkspaceQueryRunnerOptions,
   ): Promise<ObjectRecord> {
-    const { authContext, objectMetadataMapItem, objectMetadataMap } = options;
-    const repository =
-      await this.twentyORMGlobalManager.getRepositoryForWorkspace(
+    const { authContext, objectMetadataMapItem, objectMetadataMap, info } =
+      options;
+    const dataSource =
+      await this.twentyORMGlobalManager.getDataSourceForWorkspace(
         authContext.workspace.id,
-        objectMetadataMapItem.nameSingular,
       );
 
-    const nonFormattedRecordBeforeDeletion = await repository.findOne({
-      where: { id: args.id },
-      withDeleted: true,
-    });
+    const repository = dataSource.getRepository(
+      objectMetadataMapItem.nameSingular,
+    );
+
+    const graphqlQueryParser = new GraphqlQueryParser(
+      objectMetadataMapItem.fields,
+      objectMetadataMap,
+    );
+
+    const selectedFields = graphqlFields(info);
+
+    const { relations } = graphqlQueryParser.parseSelectedFields(
+      objectMetadataMapItem,
+      selectedFields,
+    );
+
+    const queryBuilder = repository.createQueryBuilder(
+      objectMetadataMapItem.nameSingular,
+    );
+
+    const nonFormattedDeletedObjectRecords = await queryBuilder
+      .where({
+        id: args.id,
+      })
+      .take(1)
+      .delete()
+      .returning('*')
+      .execute();
 
-    if (!nonFormattedRecordBeforeDeletion) {
+    if (!nonFormattedDeletedObjectRecords.affected) {
       throw new GraphqlQueryRunnerException(
         'Record not found',
         GraphqlQueryRunnerExceptionCode.RECORD_NOT_FOUND,
       );
     }
 
     const recordBeforeDeletion = formatResult(
-      [nonFormattedRecordBeforeDeletion],
+      nonFormattedDeletedObjectRecords.raw,
       objectMetadataMapItem,
       objectMetadataMap,
     )[0];
 
-    await repository.delete(args.id);
+    const processNestedRelationsHelper = new ProcessNestedRelationsHelper();
+
+    if (relations) {
+      await processNestedRelationsHelper.processNestedRelations(
+        objectMetadataMap,
+        objectMetadataMapItem,
+        [recordBeforeDeletion],
+        relations,
+        QUERY_MAX_RECORDS,
+        authContext,
+        dataSource,
+      );
+    }
+
+    const typeORMObjectRecordsParser =
+      new ObjectRecordsToGraphqlConnectionHelper(objectMetadataMap);
 
-    return recordBeforeDeletion as ObjectRecord;
+    return typeORMObjectRecordsParser.processRecord(
+      recordBeforeDeletion,
+      objectMetadataMapItem.nameSingular,
+      1,
+      1,
+    );
   }
 
   async validate(

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-update-many-resolver.service.ts

@@ -65,15 +65,13 @@ export class GraphqlQueryUpdateManyResolverService
 
     const data = formatData(args.data, objectMetadataMapItem);
 
-    const result = await withFilterQueryBuilder
+    const nonFormattedUpdatedObjectRecords = await withFilterQueryBuilder
       .update(data)
       .returning('*')
       .execute();
 
-    const nonFormattedUpdatedObjectRecords = result.raw;
-
     const updatedRecords = formatResult(
-      nonFormattedUpdatedObjectRecords,
+      nonFormattedUpdatedObjectRecords.raw,
       objectMetadataMapItem,
       objectMetadataMap,
     );

packages/twenty-server/src/engine/api/graphql/workspace-resolver-builder/factories/destroy-many-resolver.factory.ts

@@ -8,8 +8,11 @@ import {
 } from 'src/engine/api/graphql/workspace-resolver-builder/interfaces/workspace-resolvers-builder.interface';
 import { WorkspaceSchemaBuilderContext } from 'src/engine/api/graphql/workspace-schema-builder/interfaces/workspace-schema-builder-context.interface';
 
+import { GraphqlQueryRunnerService } from 'src/engine/api/graphql/graphql-query-runner/graphql-query-runner.service';
 import { workspaceQueryRunnerGraphqlApiExceptionHandler } from 'src/engine/api/graphql/workspace-query-runner/utils/workspace-query-runner-graphql-api-exception-handler.util';
 import { WorkspaceQueryRunnerService } from 'src/engine/api/graphql/workspace-query-runner/workspace-query-runner.service';
+import { FeatureFlagKey } from 'src/engine/core-modules/feature-flag/enums/feature-flag-key.enum';
+import { FeatureFlagService } from 'src/engine/core-modules/feature-flag/services/feature-flag.service';
 
 @Injectable()
 export class DestroyManyResolverFactory
@@ -19,6 +22,8 @@ export class DestroyManyResolverFactory
 
   constructor(
     private readonly workspaceQueryRunnerService: WorkspaceQueryRunnerService,
+    private readonly featureFlagService: FeatureFlagService,
+    private readonly graphqlQueryRunnerService: GraphqlQueryRunnerService,
   ) {}
 
   create(
@@ -38,6 +43,19 @@ export class DestroyManyResolverFactory
           objectMetadataMapItem: internalContext.objectMetadataMapItem,
         };
 
+        const isQueryRunnerTwentyORMEnabled =
+          await this.featureFlagService.isFeatureEnabled(
+            FeatureFlagKey.IsQueryRunnerTwentyORMEnabled,
+            internalContext.authContext.workspace.id,
+          );
+
+        if (isQueryRunnerTwentyORMEnabled) {
+          return await this.graphqlQueryRunnerService.destroyMany(
+            args,
+            options,
+          );
+        }
+
         return await this.workspaceQueryRunnerService.destroyMany(
           args,
           options,