4001 add validation for blocklist (#5172)

Closes #4001

packages/twenty-server/src/modules/connected-account/query-hooks/blocklist/blocklist-create-many.pre-query.hook.ts

@@ -0,0 +1,46 @@
+import { Injectable } from '@nestjs/common';
+
+import z from 'zod';
+
+import { WorkspacePreQueryHook } from 'src/engine/api/graphql/workspace-query-runner/workspace-pre-query-hook/interfaces/workspace-pre-query-hook.interface';
+import { CreateManyResolverArgs } from 'src/engine/api/graphql/workspace-resolver-builder/interfaces/workspace-resolvers-builder.interface';
+
+import { isDomain } from 'src/engine/utils/is-domain';
+import { BlocklistObjectMetadata } from 'src/modules/connected-account/standard-objects/blocklist.object-metadata';
+
+@Injectable()
+export class BlocklistCreateManyPreQueryHook implements WorkspacePreQueryHook {
+  constructor() {}
+
+  async execute(
+    userId: string,
+    workspaceId: string,
+    payload: CreateManyResolverArgs<
+      Omit<BlocklistObjectMetadata, 'createdAt' | 'updatedAt'> & {
+        createdAt: string;
+        updatedAt: string;
+      }
+    >,
+  ): Promise<void> {
+    const emailOrDomainSchema = z
+      .string()
+      .trim()
+      .email('Invalid email or domain')
+      .or(
+        z
+          .string()
+          .refine(
+            (value) => value.startsWith('@') && isDomain(value.slice(1)),
+            'Invalid email or domain',
+          ),
+      );
+
+    for (const { handle } of payload.data) {
+      if (!handle) {
+        throw new Error('Handle is required');
+      }
+
+      emailOrDomainSchema.parse(handle);
+    }
+  }
+}

packages/twenty-server/src/modules/connected-account/query-hooks/connected-account-query-hook.module.ts

@@ -0,0 +1,14 @@
+import { Module } from '@nestjs/common';
+
+import { BlocklistCreateManyPreQueryHook } from 'src/modules/connected-account/query-hooks/blocklist/blocklist-create-many.pre-query.hook';
+
+@Module({
+  imports: [],
+  providers: [
+    {
+      provide: BlocklistCreateManyPreQueryHook.name,
+      useClass: BlocklistCreateManyPreQueryHook,
+    },
+  ],
+})
+export class ConnectedAccountQueryHookModule {}