improvement(outbox): source enterprise and document-processing event types from dependency-free modules

Author: waleedlatif1

apps/sim/app/api/v1/admin/outbox/[id]/requeue/route.ts

@@ -6,11 +6,11 @@ import { and, eq, sql } from 'drizzle-orm'
 import { NextResponse } from 'next/server'
 import { adminV1RequeueOutboxEventContract } from '@/lib/api/contracts/v1/admin'
 import { getValidationErrorMessage, parseRequest } from '@/lib/api/server'
+import { enterpriseMetadataSyncPayloadSchema } from '@/lib/billing/enterprise-outbox'
 import {
   ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
   ENTERPRISE_PROVISION_EVENT_TYPE,
-  enterpriseMetadataSyncPayloadSchema,
-} from '@/lib/billing/enterprise-outbox'
+} from '@/lib/billing/enterprise-outbox-events'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
 

apps/sim/lib/admin/dashboard-credit-grant.test.ts

@@ -50,7 +50,6 @@ vi.mock('@/lib/billing/enterprise-provisioning', () => ({
   getLatestEnterpriseProvisionings: vi.fn(async () => new Map()),
 }))
 vi.mock('@/lib/billing/enterprise-outbox', () => ({
-  ENTERPRISE_METADATA_SYNC_EVENT_TYPE: 'stripe.sync-enterprise-metadata',
   resolveEnterpriseMetadataIntent: vi.fn(),
 }))
 vi.mock('@/lib/core/outbox/service', () => outboxServiceMock)

apps/sim/lib/admin/dashboard-organizations.test.ts

@@ -48,7 +48,6 @@ vi.mock('@/lib/billing/enterprise-provisioning', () => ({
   getLatestEnterpriseProvisionings: vi.fn(async () => hoistedMocks.provisionings),
 }))
 vi.mock('@/lib/billing/enterprise-outbox', () => ({
-  ENTERPRISE_METADATA_SYNC_EVENT_TYPE: 'stripe.sync-enterprise-metadata',
   enterpriseMetadataSyncPayloadSchema: { safeParse: vi.fn() },
   resolveEnterpriseMetadataIntent: hoistedMocks.resolveMetadataIntent,
 }))

apps/sim/lib/admin/dashboard.ts

@@ -44,10 +44,10 @@ import {
 } from '@/lib/billing/core/reporting-period'
 import { creditsToDollars, dollarsToCredits } from '@/lib/billing/credits/conversion'
 import {
-  ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
   enterpriseMetadataSyncPayloadSchema,
   resolveEnterpriseMetadataIntent,
 } from '@/lib/billing/enterprise-outbox'
+import { ENTERPRISE_METADATA_SYNC_EVENT_TYPE } from '@/lib/billing/enterprise-outbox-events'
 import {
   type EnterpriseProvisioningView,
   getLatestEnterpriseProvisionings,

apps/sim/lib/admin/invitation-operation.ts

@@ -5,10 +5,8 @@ import { normalizeEmail } from '@sim/utils/string'
 import { and, count, eq, inArray, sql } from 'drizzle-orm'
 import { z } from 'zod'
 import { ADMIN_INVITATION_OPERATION_EVENT_TYPE } from '@/lib/admin/invitation-operation-event'
-import {
-  ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE,
-  enterpriseInvitePeoplePayloadSchema,
-} from '@/lib/billing/enterprise-outbox'
+import { enterpriseInvitePeoplePayloadSchema } from '@/lib/billing/enterprise-outbox'
+import { ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE } from '@/lib/billing/enterprise-outbox-events'
 import { acquireOrganizationMutationLock } from '@/lib/billing/organizations/membership'
 import {
   deferOutboxHandler,

apps/sim/lib/billing/enterprise-outbox-events.ts

@@ -0,0 +1,5 @@
+export const ENTERPRISE_PROVISION_EVENT_TYPE = 'stripe.provision-enterprise'
+export const ENTERPRISE_METADATA_SYNC_EVENT_TYPE = 'stripe.sync-enterprise-metadata'
+export const ENTERPRISE_WORKSPACE_MOVE_EVENT_TYPE = 'enterprise.move-workspace'
+export const ENTERPRISE_MEMBER_RECONCILIATION_EVENT_TYPE = 'enterprise.reconcile-members'
+export const ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE = 'enterprise.invite-people'

apps/sim/lib/billing/enterprise-outbox.ts

@@ -4,16 +4,14 @@ import { and, desc, eq, sql } from 'drizzle-orm'
 import type Stripe from 'stripe'
 import { z } from 'zod'
 import { MAX_BILLING_CONCURRENCY_LIMIT } from '@/lib/billing/concurrency-defaults'
+import {
+  ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
+  ENTERPRISE_PROVISION_EVENT_TYPE,
+} from '@/lib/billing/enterprise-outbox-events'
 import { MAX_WORKFLOW_EXECUTION_TIMEOUT_SECONDS } from '@/lib/billing/execution-timeout-defaults'
 import type { DbOrTx } from '@/lib/db/types'
 import { MAX_INVITE_EMAILS } from '@/lib/invitations/limits'
 
-export const ENTERPRISE_PROVISION_EVENT_TYPE = 'stripe.provision-enterprise'
-export const ENTERPRISE_METADATA_SYNC_EVENT_TYPE = 'stripe.sync-enterprise-metadata'
-export const ENTERPRISE_WORKSPACE_MOVE_EVENT_TYPE = 'enterprise.move-workspace'
-export const ENTERPRISE_MEMBER_RECONCILIATION_EVENT_TYPE = 'enterprise.reconcile-members'
-export const ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE = 'enterprise.invite-people'
-
 const nonnegativeInteger = z.number().int().nonnegative().max(Number.MAX_SAFE_INTEGER)
 
 export const enterpriseProvisionRequestSchema = z.object({

apps/sim/lib/billing/enterprise-provisioning.ts

@@ -42,11 +42,6 @@ import {
 import { creditsToDollars, dollarsToCredits } from '@/lib/billing/credits/conversion'
 import {
   deriveEnterpriseOperationStatus,
-  ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE,
-  ENTERPRISE_MEMBER_RECONCILIATION_EVENT_TYPE,
-  ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
-  ENTERPRISE_PROVISION_EVENT_TYPE,
-  ENTERPRISE_WORKSPACE_MOVE_EVENT_TYPE,
   type EnterpriseInvitePeoplePayload,
   type EnterpriseMetadataSyncPayload,
   type EnterpriseOperationStatus,
@@ -61,6 +56,13 @@ import {
   enterpriseWorkspaceMovePayloadSchema,
   parseEnterpriseProvisionPayload,
 } from '@/lib/billing/enterprise-outbox'
+import {
+  ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE,
+  ENTERPRISE_MEMBER_RECONCILIATION_EVENT_TYPE,
+  ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
+  ENTERPRISE_PROVISION_EVENT_TYPE,
+  ENTERPRISE_WORKSPACE_MOVE_EVENT_TYPE,
+} from '@/lib/billing/enterprise-outbox-events'
 import {
   parseWorkflowExecutionTimeoutSeconds,
   resolveEnterpriseWorkflowExecutionTimeoutFallbackSeconds,
@@ -3211,5 +3213,3 @@ export async function getLatestEnterpriseProvisionings(
   }
   return result
 }
-
-export { ENTERPRISE_METADATA_SYNC_EVENT_TYPE, ENTERPRISE_PROVISION_EVENT_TYPE }

apps/sim/lib/billing/webhooks/enterprise.ts

@@ -14,18 +14,20 @@ import {
 } from '@/lib/auth/security-policy'
 import { deriveEnterpriseCreditLimits } from '@/lib/billing/enterprise-credit-limits'
 import {
-  ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE,
-  ENTERPRISE_MEMBER_RECONCILIATION_EVENT_TYPE,
-  ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
-  ENTERPRISE_PROVISION_EVENT_TYPE,
-  ENTERPRISE_WORKSPACE_MOVE_EVENT_TYPE,
   type EnterpriseProvisionPayload,
   enterpriseMetadataDeliveryIsVerified,
   enterpriseMetadataIntentMatchesStripeSubscription,
   enterpriseMetadataSyncPayloadSchema,
   enterpriseOperationMatchesStripeSubscription,
   parseEnterpriseProvisionPayload,
 } from '@/lib/billing/enterprise-outbox'
+import {
+  ENTERPRISE_INVITE_PEOPLE_EVENT_TYPE,
+  ENTERPRISE_MEMBER_RECONCILIATION_EVENT_TYPE,
+  ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
+  ENTERPRISE_PROVISION_EVENT_TYPE,
+  ENTERPRISE_WORKSPACE_MOVE_EVENT_TYPE,
+} from '@/lib/billing/enterprise-outbox-events'
 import { getEnterpriseIssuanceSeatRequirement } from '@/lib/billing/enterprise-provisioning'
 import { acquireOrganizationMutationLock } from '@/lib/billing/organizations/membership'
 import { requireStripeClient } from '@/lib/billing/stripe-client'

apps/sim/lib/core/outbox/handlers.ts

@@ -6,7 +6,7 @@ import {
   ENTERPRISE_METADATA_SYNC_EVENT_TYPE,
   ENTERPRISE_PROVISION_EVENT_TYPE,
   ENTERPRISE_WORKSPACE_MOVE_EVENT_TYPE,
-} from '@/lib/billing/enterprise-outbox'
+} from '@/lib/billing/enterprise-outbox-events'
 import {
   ENTERPRISE_OWNER_ACTIVATION_EVENT_TYPE,
   ENTERPRISE_OWNER_CLAIM_EVENT_TYPE,
@@ -28,7 +28,7 @@ import { KNOWLEDGE_DOCUMENT_CONTINUATION_OUTBOX_EVENT } from '@/lib/knowledge/do
 import {
   KNOWLEDGE_DOCUMENT_DEFERRED_RETRY_CHECK_EVENT,
   KNOWLEDGE_DOCUMENT_PROCESSING_OUTBOX_EVENT,
-} from '@/lib/knowledge/documents/processing-outbox-event'
+} from '@/lib/knowledge/documents/processing-events'
 import { KNOWLEDGE_DOCUMENT_RECOVERY_OUTBOX_EVENT } from '@/lib/knowledge/documents/processing-recovery-event'
 import { KNOWLEDGE_STORAGE_CLEANUP_EVENT } from '@/lib/knowledge/documents/storage-cleanup-event'
 import { INBOX_CLEANUP_EVENT } from '@/lib/mothership/inbox/cleanup-event'