wehub-resource-sync
78 lines
2.0 KiB
TypeScript
78 lines
2.0 KiB
TypeScript
import type { LoaderFunctionArgs } from "@remix-run/server-runtime";
|
|
import { json } from "@remix-run/server-runtime";
|
|
import { z } from "zod";
|
|
import { $replica, prisma } from "~/db.server";
|
|
import { requireAdminApiRequest } from "~/services/personalAccessToken.server";
|
|
import { determineEngineVersion } from "~/v3/engineVersion.server";
|
|
import { engine } from "~/v3/runEngine.server";
|
|
|
|
const ParamsSchema = z.object({
|
|
environmentId: z.string(),
|
|
});
|
|
|
|
const SearchParamsSchema = z.object({
|
|
verbose: z.string().default("0"),
|
|
page: z.coerce.number().optional(),
|
|
per_page: z.coerce.number().optional(),
|
|
});
|
|
|
|
export async function loader({ request, params }: LoaderFunctionArgs) {
|
|
await requireAdminApiRequest(request);
|
|
|
|
const parsedParams = ParamsSchema.parse(params);
|
|
|
|
const environment = await prisma.runtimeEnvironment.findFirst({
|
|
where: {
|
|
id: parsedParams.environmentId,
|
|
},
|
|
include: {
|
|
organization: true,
|
|
project: true,
|
|
orgMember: true,
|
|
},
|
|
});
|
|
|
|
if (!environment) {
|
|
return json({ error: "Environment not found" }, { status: 404 });
|
|
}
|
|
|
|
const engineVersion = await determineEngineVersion({ environment });
|
|
|
|
if (engineVersion === "V1") {
|
|
return json({ error: "Engine version is V1" }, { status: 400 });
|
|
}
|
|
|
|
const url = new URL(request.url);
|
|
const searchParams = SearchParamsSchema.parse(Object.fromEntries(url.searchParams));
|
|
|
|
const page = searchParams.page ?? 1;
|
|
const perPage = searchParams.per_page ?? 50;
|
|
|
|
const queues = await $replica.taskQueue.findMany({
|
|
where: {
|
|
runtimeEnvironmentId: environment.id,
|
|
version: "V2",
|
|
},
|
|
select: {
|
|
friendlyId: true,
|
|
name: true,
|
|
concurrencyLimit: true,
|
|
type: true,
|
|
paused: true,
|
|
},
|
|
orderBy: {
|
|
orderableName: "asc",
|
|
},
|
|
skip: (page - 1) * perPage,
|
|
take: perPage,
|
|
});
|
|
|
|
const report = await engine.generateEnvironmentReport(
|
|
environment,
|
|
queues,
|
|
searchParams.verbose === "1"
|
|
);
|
|
|
|
return json(report);
|
|
}
|