feat: buildkit tools limit (#58)

Author: krish221997

apps/event-system/services/stripe/stripe-webhook.service.ts

@@ -23,6 +23,7 @@ export default {
 
   actions: {
     async handleWebhook(ctx: any) {
+
       try {
         const rawBody = ctx?.options?.parentCtx?.params?.req?.rawBody;
         const signature = ctx?.meta?.request?.headers['stripe-signature'];
@@ -63,6 +64,7 @@ export default {
           if (key && subscriptionCreated?.status === 'active') {
             const billing = {
               throughput: parseInt(process.env.DEFAULT_CLIENT_THROUGHPUT) || 500,
+              buildKitIntegrationLimit: parseInt(process.env.DEFAULT_CLIENT_BUILDKIT_INTEGRATION_LIMIT) || 3,
               provider: 'stripe',
               customerId: subscriptionCreated?.customer,
               subscription: {
@@ -105,6 +107,7 @@ export default {
 
             const billing = {
               throughput: parseInt(process.env.DEFAULT_CLIENT_THROUGHPUT) || 500,
+              buildKitIntegrationLimit: parseInt(process.env.DEFAULT_CLIENT_BUILDKIT_INTEGRATION_LIMIT) || 3,
               provider: 'stripe',
               customerId: subscriptionUpdated?.customer,
               subscription: {
@@ -162,6 +165,7 @@ export default {
 
               const updatedBilling = {
                 throughput: parseInt(process.env.DEFAULT_CLIENT_THROUGHPUT) || 500,
+                buildKitIntegrationLimit: parseInt(process.env.DEFAULT_CLIENT_BUILDKIT_INTEGRATION_LIMIT) || 3,
                 provider: 'stripe',
                 customerId: subscriptionCreated?.customer,
                 subscription: {

libs-private/service-logic/generators/settings/linkSettings.ts

@@ -9,10 +9,16 @@ export const generateSettingsRecord = ({
   ownership,
   features,
   platforms,
+  buildKitIntegrations,
 }: {
   ownership: Ownership;
   features?: Feature[];
   platforms: Platform[];
+  buildKitIntegrations?: {
+    connectionDefinitionId: string;
+    platformName: string;
+    environment: 'test' | 'live';
+  }[]
 }): Settings => {
   return {
     createdAt: Date.now(),
@@ -22,5 +28,6 @@ export const generateSettingsRecord = ({
     updatedDate: new Date(),
     connectedPlatforms: platforms,
     features,
+    buildKitIntegrations,
   };
 };

libs-private/service-logic/services/onboarding/useOnboardingService.ts

@@ -38,6 +38,7 @@ export const useOnboardingService = (ctx: Context, ownership: Ownership) => {
         const billing = {
           throughput: parseInt(process.env.DEFAULT_CLIENT_THROUGHPUT) || 500,
           customerId: response?.customer?.id,
+          buildKitIntegrationLimit: parseInt(process.env.DEFAULT_CLIENT_BUILDKIT_INTEGRATION_LIMIT) || 3,
           subscription: {
             id: response?.subscription?.id,
             endDate: response?.subscription?.current_period_end,

libs-private/service-logic/services/settings/useSettingsService.ts

@@ -9,6 +9,7 @@ import {
   Platform,
   LinkSettings as Settings,
   Feature,
+  BuildKitIntegration,
 } from '@event-inc/types/settings';
 import EventAccess from '@apps/event-system/services/events/event-access.service';
 import { BResult, ConnectionDefinitions } from '@event-inc/types';
@@ -58,13 +59,15 @@ export const useSettingsService = (ctx: Context, ownership: Ownership) => {
       platform,
       configuration,
       features,
+      buildKitIntegration,
     }: {
       platform?: Platform;
       configuration?: {
         CLIENT_ID: string;
         CLIENT_SECRET: string;
       };
       features?: Feature[];
+      buildKitIntegration?: BuildKitIntegration;
     }): Promise<BResult<boolean, 'service', unknown>> {
       try {
         const settingsRecord = (await _list()).unwrap().rows[0] as Settings;
@@ -112,11 +115,32 @@ export const useSettingsService = (ctx: Context, ownership: Ownership) => {
             }
           }
 
+          if (buildKitIntegration) {
+             if (!settingsRecord.buildKitIntegrations) {
+              settingsRecord.buildKitIntegrations = [];
+            }
+
+            if (buildKitIntegration.active) {
+              settingsRecord.buildKitIntegrations.push({
+                connectionDefinitionId: buildKitIntegration.connectionDefinitionId,
+                environment: buildKitIntegration.environment,
+                platformName: buildKitIntegration.platformName,
+              });
+            } else {
+              settingsRecord.buildKitIntegrations = settingsRecord.buildKitIntegrations.filter(
+                integration => 
+                  !(integration.connectionDefinitionId === buildKitIntegration.connectionDefinitionId && 
+                    integration.environment === buildKitIntegration.environment)
+              );
+            }
+          }
+
           await updateById(settingsRecord._id, {
             connectedPlatforms: settingsRecord.connectedPlatforms,
             updatedAt: new Date().getTime(),
             updatedDate: new Date().toISOString(),
             features: features?.length ? features : settingsRecord.features,
+            buildKitIntegrations: settingsRecord.buildKitIntegrations || [],
           });
 
           return resultOk(true);
@@ -126,6 +150,7 @@ export const useSettingsService = (ctx: Context, ownership: Ownership) => {
           ownership,
           platforms: [platform],
           features: [],
+          buildKitIntegrations: []
         });
 
         await _create<Settings>('st', settings);
@@ -177,6 +202,7 @@ export const useSettingsService = (ctx: Context, ownership: Ownership) => {
           ownership,
           platforms,
           features: [],
+          buildKitIntegrations: [],
         });
 
         await _create<Settings>('st', settings);

packages/types/settings.ts

@@ -17,6 +17,13 @@ export interface Platform {
   environment?: 'test' | 'live';
 }
 
+export interface BuildKitIntegration {
+  connectionDefinitionId: string;
+  active: boolean;
+  environment: 'test' | 'live';
+  platformName: string;
+}
+
 export interface Feature {
   key: string;
   value: 'enabled' | 'disabled';
@@ -32,6 +39,11 @@ export interface LinkSettings {
   createdDate: Date;
   updatedDate: Date;
   features?: Feature[];
+  buildKitIntegrations?: {
+    connectionDefinitionId: string;
+    environment: 'test' | 'live';
+    platformName: string;
+  }[]
 }
 
 export interface ListLinkSettings {
@@ -49,4 +61,9 @@ export interface CreateSettingPayload {
     CLIENT_SECRET: string;
   };
   features?: Feature[];
+  buildKitIntegrations?: {
+    connectionDefinitionId: string;
+    environment: 'test' | 'live';
+    platformName: string;
+  }[];
 }