feat(admin): make dashboard billing operations durable

Author: icecrasher321

apps/sim/app/api/v1/admin/dashboard/enterprise-provisioning/[id]/follow-up-jobs/[jobId]/retry/route.ts

@@ -0,0 +1,50 @@
+import { getErrorMessage } from '@sim/utils/errors'
+import { toDashboardProvisioning } from '@/lib/admin/dashboard'
+import { adminDashboardRetryEnterpriseFollowUpJobContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import {
+  EnterpriseProvisioningError,
+  retryEnterpriseFollowUpJob,
+} from '@/lib/billing/enterprise-provisioning'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { getAdminAuditActor } from '@/app/api/v1/admin/dashboard/actor'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+interface RouteParams {
+  id: string
+  jobId: string
+}
+
+export const POST = withRouteHandler(
+  withAdminAuthParams<RouteParams>(async (request, context) => {
+    const parsed = await parseRequest(
+      adminDashboardRetryEnterpriseFollowUpJobContract,
+      request,
+      context,
+      { validationErrorResponse: adminValidationErrorResponse }
+    )
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(
+        toDashboardProvisioning(
+          await retryEnterpriseFollowUpJob(
+            parsed.data.params.id,
+            parsed.data.params.jobId,
+            await getAdminAuditActor(request)
+          )
+        )
+      )
+    } catch (error) {
+      return badRequestResponse(
+        error instanceof EnterpriseProvisioningError
+          ? error.message
+          : getErrorMessage(error, 'Failed to retry Enterprise follow-up job')
+      )
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/enterprise-provisioning/[id]/invitations/[inviteId]/retry/route.ts

@@ -0,0 +1,50 @@
+import { getErrorMessage } from '@sim/utils/errors'
+import { toDashboardProvisioning } from '@/lib/admin/dashboard'
+import { adminDashboardRetryEnterpriseInvitationContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import {
+  EnterpriseProvisioningError,
+  retryEnterpriseInvitation,
+} from '@/lib/billing/enterprise-provisioning'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { getAdminAuditActor } from '@/app/api/v1/admin/dashboard/actor'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+interface RouteParams {
+  id: string
+  inviteId: string
+}
+
+export const POST = withRouteHandler(
+  withAdminAuthParams<RouteParams>(async (request, context) => {
+    const parsed = await parseRequest(
+      adminDashboardRetryEnterpriseInvitationContract,
+      request,
+      context,
+      { validationErrorResponse: adminValidationErrorResponse }
+    )
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(
+        toDashboardProvisioning(
+          await retryEnterpriseInvitation(
+            parsed.data.params.id,
+            parsed.data.params.inviteId,
+            await getAdminAuditActor(request)
+          )
+        )
+      )
+    } catch (error) {
+      return badRequestResponse(
+        error instanceof EnterpriseProvisioningError
+          ? error.message
+          : getErrorMessage(error, 'Failed to retry Enterprise invitation')
+      )
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/enterprise-provisioning/review/route.ts

@@ -0,0 +1,49 @@
+import { createLogger } from '@sim/logger'
+import { getErrorMessage } from '@sim/utils/errors'
+import { adminDashboardEnterpriseReviewContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import { dollarsToCredits } from '@/lib/billing/credits/conversion'
+import {
+  EnterpriseProvisioningError,
+  reviewEnterpriseProvisioning,
+} from '@/lib/billing/enterprise-provisioning'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { withAdminAuth } from '@/app/api/v1/admin/middleware'
+import {
+  adminInvalidJsonResponse,
+  adminValidationErrorResponse,
+  badRequestResponse,
+  internalErrorResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+const logger = createLogger('AdminEnterpriseProvisioningReviewAPI')
+
+export const POST = withRouteHandler(
+  withAdminAuth(async (request) => {
+    const parsed = await parseRequest(
+      adminDashboardEnterpriseReviewContract,
+      request,
+      {},
+      {
+        validationErrorResponse: adminValidationErrorResponse,
+        invalidJsonResponse: adminInvalidJsonResponse,
+      }
+    )
+    if (!parsed.success) return parsed.response
+    try {
+      const { usageLimitDollars, ...body } = parsed.data.body
+      return singleResponse(
+        await reviewEnterpriseProvisioning({
+          ...body,
+          usageLimitCredits:
+            usageLimitDollars === undefined ? undefined : dollarsToCredits(usageLimitDollars),
+        })
+      )
+    } catch (error) {
+      if (error instanceof EnterpriseProvisioningError) return badRequestResponse(error.message)
+      logger.error('Failed to review Enterprise provisioning', { error })
+      return internalErrorResponse(getErrorMessage(error, 'Failed to review Enterprise plan'))
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/enterprise-provisioning/route.ts

@@ -44,6 +44,7 @@ export const POST = withRouteHandler(
               usageLimitDollars === undefined ? undefined : dollarsToCredits(usageLimitDollars),
             requestedByEmail: actor.email ?? 'admin-api',
             requestedByUserId: actor.id,
+            requestedByName: actor.name,
           })
         )
       )

apps/sim/app/api/v1/admin/dashboard/organizations/[id]/billing-actions/route.ts

@@ -0,0 +1,29 @@
+import { createLogger } from '@sim/logger'
+import { getErrorMessage } from '@sim/utils/errors'
+import { getDashboardSubscriptionBillingActions } from '@/lib/admin/subscription-lifecycle'
+import { adminDashboardBillingActionsContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+const logger = createLogger('AdminDashboardBillingActionsAPI')
+
+export const GET = withRouteHandler(
+  withAdminAuthParams<{ id: string }>(async (request, context) => {
+    const parsed = await parseRequest(adminDashboardBillingActionsContract, request, context, {
+      validationErrorResponse: adminValidationErrorResponse,
+    })
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(await getDashboardSubscriptionBillingActions(parsed.data.params.id))
+    } catch (error) {
+      logger.warn('Could not load organization billing actions', { error })
+      return badRequestResponse(getErrorMessage(error, 'Could not load billing actions'))
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/organizations/[id]/cancellation/route.ts

@@ -0,0 +1,34 @@
+import { getErrorMessage } from '@sim/utils/errors'
+import { requestDashboardSubscriptionCancellation } from '@/lib/admin/subscription-lifecycle'
+import { adminDashboardCancelSubscriptionContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { getAdminAuditActor } from '@/app/api/v1/admin/dashboard/actor'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminInvalidJsonResponse,
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+export const POST = withRouteHandler(
+  withAdminAuthParams<{ id: string }>(async (request, context) => {
+    const parsed = await parseRequest(adminDashboardCancelSubscriptionContract, request, context, {
+      validationErrorResponse: adminValidationErrorResponse,
+      invalidJsonResponse: adminInvalidJsonResponse,
+    })
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(
+        await requestDashboardSubscriptionCancellation({
+          organizationId: parsed.data.params.id,
+          ...parsed.data.body,
+          actor: await getAdminAuditActor(request),
+        })
+      )
+    } catch (error) {
+      return badRequestResponse(getErrorMessage(error, 'Could not cancel subscription'))
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/organizations/[id]/invitation-operations/[operationId]/jobs/[jobId]/retry/route.ts

@@ -0,0 +1,40 @@
+import { getErrorMessage } from '@sim/utils/errors'
+import { retryAdminInvitationOperationJob } from '@/lib/admin/invitation-operation'
+import { adminDashboardRetryInvitationOperationJobContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+interface RouteParams {
+  id: string
+  operationId: string
+  jobId: string
+}
+
+export const POST = withRouteHandler(
+  withAdminAuthParams<RouteParams>(async (request, context) => {
+    const parsed = await parseRequest(
+      adminDashboardRetryInvitationOperationJobContract,
+      request,
+      context,
+      { validationErrorResponse: adminValidationErrorResponse }
+    )
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(
+        await retryAdminInvitationOperationJob(
+          parsed.data.params.id,
+          parsed.data.params.operationId,
+          parsed.data.params.jobId
+        )
+      )
+    } catch (error) {
+      return badRequestResponse(getErrorMessage(error, 'Failed to retry invitation operation job'))
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/organizations/[id]/invitation-operations/[operationId]/route.ts

@@ -0,0 +1,35 @@
+import { getErrorMessage } from '@sim/utils/errors'
+import { getAdminInvitationOperation } from '@/lib/admin/invitation-operation'
+import { adminDashboardGetInvitationOperationContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+interface RouteParams {
+  id: string
+  operationId: string
+}
+
+export const GET = withRouteHandler(
+  withAdminAuthParams<RouteParams>(async (request, context) => {
+    const parsed = await parseRequest(
+      adminDashboardGetInvitationOperationContract,
+      request,
+      context,
+      { validationErrorResponse: adminValidationErrorResponse }
+    )
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(
+        await getAdminInvitationOperation(parsed.data.params.id, parsed.data.params.operationId)
+      )
+    } catch (error) {
+      return badRequestResponse(getErrorMessage(error, 'Failed to load invitation operation'))
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/organizations/[id]/invitations/route.ts

@@ -0,0 +1,38 @@
+import { getErrorMessage } from '@sim/utils/errors'
+import { createAdminInvitationOperation } from '@/lib/admin/invitation-operation'
+import { adminDashboardInvitePeopleContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { getAdminAuditActor } from '@/app/api/v1/admin/dashboard/actor'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminInvalidJsonResponse,
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+export const POST = withRouteHandler(
+  withAdminAuthParams<{ id: string }>(async (request, context) => {
+    const parsed = await parseRequest(adminDashboardInvitePeopleContract, request, context, {
+      validationErrorResponse: adminValidationErrorResponse,
+      invalidJsonResponse: adminInvalidJsonResponse,
+    })
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(
+        await createAdminInvitationOperation({
+          operationId: parsed.data.body.operationId,
+          organizationId: parsed.data.params.id,
+          emails: parsed.data.body.emails,
+          workspaceIds: parsed.data.body.workspaceIds,
+          role: parsed.data.body.role,
+          permission: parsed.data.body.permission,
+          actor: await getAdminAuditActor(request),
+        })
+      )
+    } catch (error) {
+      return badRequestResponse(getErrorMessage(error, 'Failed to invite people'))
+    }
+  })
+)

apps/sim/app/api/v1/admin/dashboard/organizations/[id]/member-operations/[operationId]/follow-up-jobs/[jobId]/retry/route.ts

@@ -0,0 +1,44 @@
+import { getErrorMessage } from '@sim/utils/errors'
+import { retryAdminMemberFollowUpJob } from '@/lib/admin/member-operation'
+import { adminDashboardRetryMemberFollowUpJobContract } from '@/lib/api/contracts/v1/admin/dashboard'
+import { parseRequest } from '@/lib/api/server'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { getAdminAuditActor } from '@/app/api/v1/admin/dashboard/actor'
+import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
+import {
+  adminValidationErrorResponse,
+  badRequestResponse,
+  singleResponse,
+} from '@/app/api/v1/admin/responses'
+
+interface RouteParams {
+  id: string
+  operationId: string
+  jobId: string
+}
+
+export const POST = withRouteHandler(
+  withAdminAuthParams<RouteParams>(async (request, context) => {
+    const parsed = await parseRequest(
+      adminDashboardRetryMemberFollowUpJobContract,
+      request,
+      context,
+      { validationErrorResponse: adminValidationErrorResponse }
+    )
+    if (!parsed.success) return parsed.response
+    try {
+      return singleResponse(
+        await retryAdminMemberFollowUpJob(
+          parsed.data.params.id,
+          parsed.data.params.operationId,
+          parsed.data.params.jobId,
+          await getAdminAuditActor(request)
+        )
+      )
+    } catch (error) {
+      return badRequestResponse(
+        getErrorMessage(error, 'Could not retry member-operation follow-up job')
+      )
+    }
+  })
+)