wehub-resource-sync
71 lines
2.3 KiB
TypeScript
71 lines
2.3 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 { logger } from "~/services/logger.server";
|
|
import { enqueueBillingLimitResolve } from "~/v3/billingLimitWorker.server";
|
|
import { processBillingLimitResolve } from "~/v3/services/billingLimit/billingLimitResolve.server";
|
|
import type { PendingBillingLimitResolve } from "~/v3/services/billingLimit/billingLimitPendingResolve.types";
|
|
|
|
const ParamsSchema = z.object({
|
|
organizationId: z.string(),
|
|
});
|
|
|
|
const BodySchema = z.object({
|
|
resumeMode: z.enum(["queue", "new_only"]),
|
|
resolvedAt: z.string(),
|
|
});
|
|
|
|
/** Billing platform webhook: org resolved billing limit to ok. 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 });
|
|
}
|
|
|
|
let pending: PendingBillingLimitResolve;
|
|
try {
|
|
const body = await request.json();
|
|
pending = {
|
|
organizationId,
|
|
...BodySchema.parse(body),
|
|
};
|
|
} catch (error) {
|
|
logger.error("Invalid billing limit resolve webhook payload", {
|
|
error,
|
|
organizationId,
|
|
});
|
|
return json({ error: "Invalid request body" }, { status: 400 });
|
|
}
|
|
|
|
try {
|
|
await processBillingLimitResolve(pending, {
|
|
bustCaches: bustBillingLimitCaches,
|
|
enqueueResolve: enqueueBillingLimitResolve,
|
|
});
|
|
} catch (error) {
|
|
logger.error("Billing limit resolve webhook failed", {
|
|
error,
|
|
organizationId,
|
|
resumeMode: pending.resumeMode,
|
|
resolvedAt: pending.resolvedAt,
|
|
});
|
|
return json({ error: "Failed to process billing limit resolve" }, { status: 500 });
|
|
}
|
|
|
|
return json({ success: true, accepted: true }, { status: 202 });
|
|
}
|