wehub-resource-sync
38 lines
1.4 KiB
TypeScript
38 lines
1.4 KiB
TypeScript
import { type ActionFunctionArgs, json } from "@remix-run/server-runtime";
|
|
import { z } from "zod";
|
|
import { prisma } from "~/db.server";
|
|
import { requireAdminApiRequest } from "~/services/personalAccessToken.server";
|
|
import { bustBillingLimitCaches } from "~/services/platform.v3.server";
|
|
import { BillingLimitConvergeEnvironmentsService } from "~/v3/services/billingLimit/billingLimitConvergeEnvironmentsService.server";
|
|
import { enqueueBillingLimitConverge } from "~/v3/billingLimitWorker.server";
|
|
|
|
const ParamsSchema = z.object({
|
|
organizationId: z.string(),
|
|
});
|
|
|
|
/** Billing platform webhook: org billing limit grace expired. Idempotent — returns 202. */
|
|
export async function action({ request, params }: ActionFunctionArgs) {
|
|
await requireAdminApiRequest(request);
|
|
|
|
if (request.method.toLowerCase() !== "post") {
|
|
return json({ error: "Method not allowed" }, { status: 405 });
|
|
}
|
|
|
|
const { organizationId } = ParamsSchema.parse(params);
|
|
|
|
const organization = await prisma.organization.findFirst({
|
|
where: { id: organizationId },
|
|
select: { id: true },
|
|
});
|
|
|
|
if (!organization) {
|
|
return json({ error: "Organization not found" }, { status: 404 });
|
|
}
|
|
|
|
bustBillingLimitCaches(organizationId);
|
|
await BillingLimitConvergeEnvironmentsService.seedReconcileQueue(organizationId);
|
|
await enqueueBillingLimitConverge(organizationId, "rejected");
|
|
|
|
return json({ success: true, accepted: true }, { status: 202 });
|
|
}
|