perf(ama): drain durable operations inline, relax cron cadence

app/api/admin/ama/bookings/[bookingId]/route.ts

@@ -3,17 +3,22 @@ import {
   getAmaAdminServices,
   ownerRequestAuthenticator,
 } from '~/lib/ama/admin/server'
+import { kickAmaOperations } from '~/lib/ama/booking/server'
+
+export const maxDuration = 60
 
 export async function POST(
   request: Request,
   { params }: { params: Promise<{ bookingId: string }> },
 ) {
   const { bookingId } = await params
   const { bookingAdmin, security, baseUrl } = getAmaAdminServices()
-  return createAdminBookingActionHandler({
+  const response = await createAdminBookingActionHandler({
     authenticator: ownerRequestAuthenticator,
     service: bookingAdmin,
     security,
     baseUrl,
   })(request, bookingId)
+  if (response.ok) kickAmaOperations()
+  return response
 }

app/api/admin/ama/operations/[operationId]/route.ts

@@ -3,17 +3,22 @@ import {
   getAmaAdminServices,
   ownerRequestAuthenticator,
 } from '~/lib/ama/admin/server'
+import { kickAmaOperations } from '~/lib/ama/booking/server'
+
+export const maxDuration = 60
 
 export async function POST(
   request: Request,
   { params }: { params: Promise<{ operationId: string }> },
 ) {
   const { operationId } = await params
   const { bookingAdmin, security, baseUrl } = getAmaAdminServices()
-  return createAdminOperationActionHandler({
+  const response = await createAdminOperationActionHandler({
     authenticator: ownerRequestAuthenticator,
     service: bookingAdmin,
     security,
     baseUrl,
   })(request, operationId)
+  if (response.ok) kickAmaOperations()
+  return response
 }

app/api/ama/manage/[token]/cancel/route.ts

@@ -1,7 +1,12 @@
 import { createManageCancelHandler } from '~/lib/ama/booking/http'
-import { getAmaBookingServices } from '~/lib/ama/booking/server'
+import {
+  getAmaBookingServices,
+  kickAmaOperations,
+} from '~/lib/ama/booking/server'
 import { protectAmaLaunchBoundary } from '~/lib/ama/security/launch-boundary-server'
 
+export const maxDuration = 60
+
 export async function POST(
   request: Request,
   { params }: { params: Promise<{ token: string }> },
@@ -13,5 +18,10 @@ export async function POST(
   if (blocked) return blocked
   const { token } = await params
   const { manage, guard } = getAmaBookingServices()
-  return createManageCancelHandler({ manage, guard })(request, token)
+  const response = await createManageCancelHandler({ manage, guard })(
+    request,
+    token,
+  )
+  if (response.ok) kickAmaOperations()
+  return response
 }

app/api/ama/manage/[token]/reschedule/route.ts

@@ -1,7 +1,12 @@
 import { createManageRescheduleHandler } from '~/lib/ama/booking/http'
-import { getAmaBookingServices } from '~/lib/ama/booking/server'
+import {
+  getAmaBookingServices,
+  kickAmaOperations,
+} from '~/lib/ama/booking/server'
 import { protectAmaLaunchBoundary } from '~/lib/ama/security/launch-boundary-server'
 
+export const maxDuration = 60
+
 export async function POST(
   request: Request,
   { params }: { params: Promise<{ token: string }> },
@@ -13,5 +18,10 @@ export async function POST(
   if (blocked) return blocked
   const { token } = await params
   const { manage, guard } = getAmaBookingServices()
-  return createManageRescheduleHandler({ manage, guard })(request, token)
+  const response = await createManageRescheduleHandler({ manage, guard })(
+    request,
+    token,
+  )
+  if (response.ok) kickAmaOperations()
+  return response
 }

app/api/ama/stripe/webhook/route.ts

@@ -1,14 +1,21 @@
 import { createStripeWebhookHandler, json } from '~/lib/ama/booking/http'
-import { getAmaBookingServices } from '~/lib/ama/booking/server'
+import {
+  getAmaBookingServices,
+  kickAmaOperations,
+} from '~/lib/ama/booking/server'
 import { protectAmaLaunchBoundary } from '~/lib/ama/security/launch-boundary-server'
 
+export const maxDuration = 60
+
 export async function POST(request: Request) {
   const blocked = protectAmaLaunchBoundary(request, ['payments'])
   if (blocked) return blocked
   const { booking, stripeWebhookSecret } = getAmaBookingServices()
   if (!stripeWebhookSecret) return json(503, { error: 'feature_disabled' })
-  return createStripeWebhookHandler({
+  const response = await createStripeWebhookHandler({
     service: booking,
     signingSecret: stripeWebhookSecret,
   })(request)
+  if (response.ok) kickAmaOperations()
+  return response
 }

lib/ama/booking/server.ts

@@ -1,5 +1,7 @@
 import 'server-only'
 
+import { waitUntil } from '@vercel/functions'
+
 import { createRateLimiter } from '~/lib/rate-limit/server'
 
 import { availabilityRepository } from '../availability/repository'
@@ -227,3 +229,19 @@ export function getAmaBookingServices() {
   services ??= createServices()
   return services
 }
+
+/**
+ * Starts a background drain of due durable operations inside the current
+ * invocation, so work enqueued by a mutation (booking emails, Finalizing
+ * Booking recovery, refunds) begins immediately instead of waiting for the
+ * next scheduled sweep. The scheduled endpoint remains the sole driver for
+ * reminders, retry backoff, and expired Slot Hold release.
+ */
+export function kickAmaOperations() {
+  const { runner } = getAmaBookingServices()
+  waitUntil(
+    runner.run().catch((error) => {
+      console.error('ama: inline operations drain failed', error)
+    }),
+  )
+}

vercel.json

@@ -6,11 +6,11 @@
   "crons": [
     {
       "path": "/api/internal/media/reconcile",
-      "schedule": "*/15 * * * *"
+      "schedule": "0 * * * *"
     },
     {
       "path": "/api/internal/ama/work",
-      "schedule": "*/5 * * * *"
+      "schedule": "*/30 * * * *"
     }
   ]
 }