diff --git a/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.resolver.ts b/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.resolver.ts index 716e798e5..0c8472657 100644 --- a/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.resolver.ts +++ b/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.resolver.ts @@ -57,11 +57,10 @@ export class ServerlessFunctionResolver { try { await this.checkFeatureFlag(workspaceId); - return ( - await this.serverlessFunctionService.findManyServerlessFunctions({ - id, - }) - )?.[0]; + return await this.serverlessFunctionService.findOneOrFail({ + id, + workspaceId, + }); } catch (error) { serverlessFunctionGraphQLApiExceptionHandler(error); } diff --git a/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.service.ts b/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.service.ts index df045e554..d3c03ec83 100644 --- a/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.service.ts +++ b/packages/twenty-server/src/engine/metadata-modules/serverless-function/serverless-function.service.ts @@ -14,9 +14,6 @@ import { AuditService } from 'src/engine/core-modules/audit/services/audit.servi import { SERVERLESS_FUNCTION_EXECUTED_EVENT } from 'src/engine/core-modules/audit/utils/events/workspace-event/serverless-function/serverless-function-executed'; import { FileStorageService } from 'src/engine/core-modules/file-storage/file-storage.service'; import { readFileContent } from 'src/engine/core-modules/file-storage/utils/read-file-content'; -import { InjectMessageQueue } from 'src/engine/core-modules/message-queue/decorators/message-queue.decorator'; -import { MessageQueue } from 'src/engine/core-modules/message-queue/message-queue.constants'; -import { MessageQueueService } from 'src/engine/core-modules/message-queue/services/message-queue.service'; import { ENV_FILE_NAME } from 'src/engine/core-modules/serverless/drivers/constants/env-file-name'; import { INDEX_FILE_NAME } from 'src/engine/core-modules/serverless/drivers/constants/index-file-name'; import { LAST_LAYER_VERSION } from 'src/engine/core-modules/serverless/drivers/layers/last-layer-version'; @@ -47,8 +44,6 @@ export class ServerlessFunctionService { private readonly throttlerService: ThrottlerService, private readonly twentyConfigService: TwentyConfigService, private readonly auditService: AuditService, - @InjectMessageQueue(MessageQueue.serverlessFunctionQueue) - private readonly messageQueueService: MessageQueueService, ) {} // @ts-expect-error legacy noImplicitAny