wehub-resource-sync
74 lines
2.1 KiB
TypeScript
74 lines
2.1 KiB
TypeScript
import { type LoaderFunctionArgs } from "@remix-run/server-runtime";
|
|
import { z } from "zod";
|
|
import { findProjectBySlug } from "~/models/project.server";
|
|
import { findEnvironmentBySlug } from "~/models/runtimeEnvironment.server";
|
|
import { QueueListPresenter } from "~/presenters/v3/QueueListPresenter.server";
|
|
import { requireUserId } from "~/services/session.server";
|
|
import { EnvironmentParamSchema } from "~/utils/pathBuilder";
|
|
|
|
const SearchParamsSchema = z.object({
|
|
query: z.string().optional(),
|
|
page: z.coerce.number().min(1).default(1),
|
|
per_page: z.coerce.number().min(1).default(20),
|
|
type: z.enum(["task", "custom"]).optional(),
|
|
});
|
|
|
|
export async function loader({ request, params }: LoaderFunctionArgs) {
|
|
const userId = await requireUserId(request);
|
|
const { organizationSlug, projectParam, envParam } = EnvironmentParamSchema.parse(params);
|
|
|
|
const url = new URL(request.url);
|
|
const { page, per_page, query, type } = SearchParamsSchema.parse(
|
|
Object.fromEntries(url.searchParams)
|
|
);
|
|
|
|
const project = await findProjectBySlug(organizationSlug, projectParam, userId);
|
|
if (!project) {
|
|
throw new Response(undefined, {
|
|
status: 404,
|
|
statusText: "Project not found",
|
|
});
|
|
}
|
|
|
|
const environment = await findEnvironmentBySlug(project.id, envParam, userId);
|
|
if (!environment) {
|
|
throw new Response(undefined, {
|
|
status: 404,
|
|
statusText: "Environment not found",
|
|
});
|
|
}
|
|
|
|
const presenter = new QueueListPresenter(per_page);
|
|
|
|
const result = await presenter.call({
|
|
environment: environment,
|
|
query,
|
|
page,
|
|
type,
|
|
});
|
|
|
|
if (!result.success) {
|
|
return {
|
|
queues: [],
|
|
currentPage: 1,
|
|
hasMore: false,
|
|
hasFilters: Boolean(query?.trim()) || Boolean(type),
|
|
};
|
|
}
|
|
|
|
return {
|
|
queues: result.queues.map((queue) => ({
|
|
id: queue.id,
|
|
name: queue.name,
|
|
type: queue.type,
|
|
paused: queue.paused,
|
|
})),
|
|
currentPage: result.pagination.currentPage,
|
|
hasMore:
|
|
result.pagination.mode === "filtered"
|
|
? result.pagination.hasMore
|
|
: result.pagination.currentPage < result.pagination.totalPages,
|
|
hasFilters: result.hasFilters,
|
|
};
|
|
}
|