feat: Make webhook creation optional

fern/definition/common/types.yml

@@ -105,4 +105,11 @@ types:
  AppConfig:
  properties:
  bot_token: optional<string>
- org_url: optional<string>
+ org_url: optional<string>
+
+ SvixAccount:
+ properties:
+ uid: optional<string>
+ name: string
+ rateLimit: optional<integer>
+ id: string

fern/definition/internal/account.yml

@@ -8,6 +8,15 @@ types:
  GetAccountDetailsResponse:
  properties:
  account: types.Account
+ SvixAccountResponse:
+ properties:
+ account: optional<types.SvixAccount>
+ exist: boolean
+ environment: optional<string>
+ SvixMagicLinkResponse:
+ properties:
+ key: string
+ environment: string
 
 service:
  base-path: /internal/account
@@ -54,16 +63,57 @@ service:
  docs: create Revert App for Account
  method: POST
  path: /apps
- request: 
+ request:
  name: CreateRevertAppForAccount
- body: 
- properties: 
+ body:
+ properties:
  userId: string
  tpId: types.TPID
  environment: string
  response: GetAccountDetailsResponse
- errors: 
+ errors:
+ - errors.UnAuthorizedError
+ - errors.InternalServerError
+ getSvixAccount:
+ docs: Get Svix Account
+ method: GET
+ path: /svix/{id}
+ path-parameters:
+ id: string
+ request:
+ name: getSvixAccount
+ query-parameters:
+ environment: string
+ response: SvixAccountResponse
+ errors:
  - errors.UnAuthorizedError
  - errors.InternalServerError
-  
+ - errors.NotFoundError
 
+ createSvixAccount:
+ docs: Create Svix Account
+ method: POST
+ path: /svix
+ request:
+ name: createSvixAccount
+ body:
+ properties:
+ environment: string
+ accountId: string
+ response: SvixAccountResponse
+ errors:
+ - errors.UnAuthorizedError
+ - errors.InternalServerError
+ createSvixAccountMagicLink:
+ docs: Create Svix Account Consumer Panel MagicLink
+ method: POST
+ path: /svix/panel/link
+ request:
+ name: createSvixAccountPanelMagicLink
+ body:
+ properties:
+ appId: string
+ response: SvixMagicLinkResponse
+ errors:
+ - errors.UnAuthorizedError
+ - errors.InternalServerError

packages/backend/helpers/crm/hubspot.ts

@@ -97,7 +97,7 @@ export const getAssociationObjects = async (
  thirdPartyId: any,
  connection: any,
  account: any,
- invalidAssociations: any
+ invalidAssociations: any,
 ) => {
  const associatedData: any = {};
 
@@ -189,8 +189,8 @@ export const getAssociationObjects = async (
  objType: associatedObjectType,
  tenantSchemaMappingId: connection.schema_mapping_id,
  accountFieldMappingConfig: account.accountFieldMappingConfig,
- })
- )
+ }),
+ ),
  ));
  }
  }

packages/backend/helpers/crm/transform/preprocess.ts

@@ -21,7 +21,8 @@ export const preprocessUnifyObject = <T extends Record<string, any>>({
 }: {
  obj: T;
  tpId: CRM_TP_ID | TICKET_TP_ID;
- objType:StandardObjects
+ objType:
+ | StandardObjects
  | ChatStandardObjects
  | TicketStandardObjects
  | AtsStandardObjects

packages/backend/helpers/crm/transform/transformSchemaMapping.ts

@@ -21,7 +21,8 @@ export const transformFieldMappingToModel = async ({
 }: {
  obj: any;
  tpId: TP_ID;
- objType: StandardObjects
+ objType:
+ | StandardObjects
  | ChatStandardObjects
  | TicketStandardObjects
  | AtsStandardObjects
@@ -64,7 +65,7 @@ export const transformFieldMappingToModel = async ({
  .filter((a: any) => a.objectName === objType)
  .map((a: any) => a.fieldName)
  .includes(field)
- : accountFieldMappingConfig?.allow_connection_override_custom_fields))
+ : accountFieldMappingConfig?.allow_connection_override_custom_fields)),
  ) || rootSchema?.fieldMappings?.find((r) => r?.target_field_name === field);
 
  const transformedKey = fieldMapping?.source_field_name;
@@ -93,7 +94,8 @@ export const transformModelToFieldMapping = async ({
 }: {
  unifiedObj: any;
  tpId: TP_ID;
- objType:StandardObjects
+ objType:
+ | StandardObjects
  | ChatStandardObjects
  | TicketStandardObjects
  | AtsStandardObjects
@@ -123,7 +125,7 @@ export const transformModelToFieldMapping = async ({
  .filter((a: any) => a.objectName === objType)
  .map((a: any) => a.fieldName)
  .includes(key)
- : accountFieldMappingConfig?.allow_connection_override_custom_fields))
+ : accountFieldMappingConfig?.allow_connection_override_custom_fields)),
  );
  const rootFieldMapping = rootSchema?.fieldMappings?.filter((r) => r?.target_field_name === key);
  const crmKey = tenantFieldMapping?.source_field_name;

packages/backend/helpers/crm/transform/unify.ts

@@ -21,7 +21,8 @@ export async function unifyObject<T extends Record<string, any>, K>({
 }: {
  obj: T;
  tpId: CRM_TP_ID;
- objType:StandardObjects
+ objType:
+ | StandardObjects
  | ChatStandardObjects
  | TicketStandardObjects
  | AtsStandardObjects

packages/backend/helpers/webhooks/connection.ts

@@ -1,13 +1,19 @@
 import config from '../../config';
 
-export default function sendConnectionAddedEvent(
+// Warn: svixAppId is now including env that is environmentId -> ie: accoundId_environment (accountId_production)
+export default async function sendConnectionAddedEvent(
  svixAppId: string,
  tenantId: string,
  tp_id: string,
  tp_access_token: string,
  tp_customer_id: string
 ) {
  try {
+ const isSvixAppExist = await getSvixAccount(svixAppId);
+ if (!isSvixAppExist) {
+ return;
+ }
+
  config.svix?.message.create(svixAppId, {
  eventType: 'connection.added',
  payload: {
@@ -26,8 +32,12 @@ export default function sendConnectionAddedEvent(
  }
 }
 
-export function sendConnectionDeletedEvent(svixAppId: string, connection: any) {
+export async function sendConnectionDeletedEvent(svixAppId: string, connection: any) {
  try {
+ const isSvixAppExist = await getSvixAccount(svixAppId);
+ if (!isSvixAppExist) {
+ return;
+ }
  config.svix?.message.create(svixAppId, {
  eventType: 'connection.deleted',
  payload: {
@@ -40,3 +50,13 @@ export function sendConnectionDeletedEvent(svixAppId: string, connection: any) {
  console.error('Error sending webhook event:', error);
  }
 }
+
+export async function getSvixAccount(svixAppId: string) {
+ try {
+ const svixAccount = await config.svix?.application.get(svixAppId);
+ return svixAccount;
+ } catch (error) {
+ // probably svixAccount doesn't exist
+ return undefined;
+ }
+}

packages/backend/index.ts

@@ -80,7 +80,7 @@ app.use(
  skip: (req, _) => {
  return req.originalUrl.startsWith('/health-check');
  },
- })
+ }),
 );
 
 app.use(versionMiddleware());
@@ -121,14 +121,14 @@ app.use(
  manageRouterVersioning({
  v1: indexRouter,
  v2: testv2Router,
- })
+ }),
 );
 app.use(
  '/v1',
  manageRouterVersioning({
  v1: indexRouter,
  v2: testv2Router,
- })
+ }),
 );
 app.use(endpointLogger());
 // The error handler must be before any other error middleware and after all controllers