refactor(deployment): update cancellation input schemas for applications and composes

- Removed the previous cancellation schemas for deployments.
- Replaced them with a unified input schema for finding applications and composes during cancellation requests.
- Ensured that the cancellation logic now utilizes the new input structure for better consistency.
This commit is contained in:
Mauricio Siu
2025-09-06 22:08:59 -06:00
parent d80ada7c00
commit 63e578f13c
2 changed files with 2 additions and 12 deletions
@@ -62,11 +62,6 @@ import { cleanQueuesByApplication, myQueue } from "@/server/queues/queueSetup";
import { cancelDeployment, deploy } from "@/server/utils/deploy"; import { cancelDeployment, deploy } from "@/server/utils/deploy";
import { uploadFileSchema } from "@/utils/schema"; import { uploadFileSchema } from "@/utils/schema";
// Schema for canceling deployment
const apiCancelDeployment = z.object({
applicationId: z.string().min(1),
});
export const applicationRouter = createTRPCRouter({ export const applicationRouter = createTRPCRouter({
create: protectedProcedure create: protectedProcedure
.input(apiCreateApplication) .input(apiCreateApplication)
@@ -904,7 +899,7 @@ export const applicationRouter = createTRPCRouter({
}), }),
cancelDeployment: protectedProcedure cancelDeployment: protectedProcedure
.input(apiCancelDeployment) .input(apiFindOneApplication)
.mutation(async ({ input, ctx }) => { .mutation(async ({ input, ctx }) => {
const application = await findApplicationById(input.applicationId); const application = await findApplicationById(input.applicationId);
if ( if (
+1 -6
View File
@@ -63,11 +63,6 @@ import { cancelDeployment, deploy } from "@/server/utils/deploy";
import { generatePassword } from "@/templates/utils"; import { generatePassword } from "@/templates/utils";
import { createTRPCRouter, protectedProcedure, publicProcedure } from "../trpc"; import { createTRPCRouter, protectedProcedure, publicProcedure } from "../trpc";
// Schema for canceling deployment
const apiCancelDeployment = z.object({
composeId: z.string().min(1),
});
export const composeRouter = createTRPCRouter({ export const composeRouter = createTRPCRouter({
create: protectedProcedure create: protectedProcedure
.input(apiCreateCompose) .input(apiCreateCompose)
@@ -936,7 +931,7 @@ export const composeRouter = createTRPCRouter({
}), }),
cancelDeployment: protectedProcedure cancelDeployment: protectedProcedure
.input(apiCancelDeployment) .input(apiFindCompose)
.mutation(async ({ input, ctx }) => { .mutation(async ({ input, ctx }) => {
const compose = await findComposeById(input.composeId); const compose = await findComposeById(input.composeId);
if ( if (