diff --git a/packages/twenty-server/src/engine/core-modules/billing/listeners/billing-workspace-member.listener.ts b/packages/twenty-server/src/engine/core-modules/billing/listeners/billing-workspace-member.listener.ts index e31a7b592..caad58c7e 100644 --- a/packages/twenty-server/src/engine/core-modules/billing/listeners/billing-workspace-member.listener.ts +++ b/packages/twenty-server/src/engine/core-modules/billing/listeners/billing-workspace-member.listener.ts @@ -9,12 +9,14 @@ import { UpdateSubscriptionJob, UpdateSubscriptionJobData, } from 'src/engine/core-modules/billing/jobs/update-subscription.job'; +import { EnvironmentService } from 'src/engine/integrations/environment/environment.service'; @Injectable() export class BillingWorkspaceMemberListener { constructor( @Inject(MessageQueue.billingQueue) private readonly messageQueueService: MessageQueueService, + private readonly environmentService: EnvironmentService, ) {} @OnEvent('workspaceMember.created') @@ -22,6 +24,10 @@ export class BillingWorkspaceMemberListener { async handleCreateOrDeleteEvent( payload: ObjectRecordCreateEvent, ) { + if (!this.environmentService.get('IS_BILLING_ENABLED')) { + return; + } + await this.messageQueueService.add( UpdateSubscriptionJob.name, { workspaceId: payload.workspaceId },