refactor: make protected instead of admin

This commit is contained in:
Mauricio Siu
2025-01-22 00:13:22 -06:00
parent f5d81f434c
commit 53df7d969e

View File

@@ -77,7 +77,7 @@ export const settingsRouter = createTRPCRouter({
return true; return true;
} }
const { stdout } = await execAsync( const { stdout } = await execAsync(
"docker service inspect dokploy --format '{{.ID}}'", "docker service inspect dokploy --format '{{.ID}}'"
); );
await execAsync(`docker service update --force ${stdout.trim()}`); await execAsync(`docker service update --force ${stdout.trim()}`);
return true; return true;
@@ -241,7 +241,7 @@ export const settingsRouter = createTRPCRouter({
} else { } else {
scheduleJob(server.serverId, "0 0 * * *", async () => { scheduleJob(server.serverId, "0 0 * * *", async () => {
console.log( console.log(
`Docker Cleanup ${new Date().toLocaleString()}] Running...`, `Docker Cleanup ${new Date().toLocaleString()}] Running...`
); );
await cleanUpUnusedImages(server.serverId); await cleanUpUnusedImages(server.serverId);
await cleanUpDockerBuilder(server.serverId); await cleanUpDockerBuilder(server.serverId);
@@ -277,7 +277,7 @@ export const settingsRouter = createTRPCRouter({
if (adminUpdated?.enableDockerCleanup) { if (adminUpdated?.enableDockerCleanup) {
scheduleJob("docker-cleanup", "0 0 * * *", async () => { scheduleJob("docker-cleanup", "0 0 * * *", async () => {
console.log( console.log(
`Docker Cleanup ${new Date().toLocaleString()}] Running...`, `Docker Cleanup ${new Date().toLocaleString()}] Running...`
); );
await cleanUpUnusedImages(); await cleanUpUnusedImages();
await cleanUpDockerBuilder(); await cleanUpDockerBuilder();
@@ -345,7 +345,7 @@ export const settingsRouter = createTRPCRouter({
writeConfig("middlewares", input.traefikConfig); writeConfig("middlewares", input.traefikConfig);
return true; return true;
}), }),
getUpdateData: adminProcedure.mutation(async () => { getUpdateData: protectedProcedure.mutation(async () => {
if (IS_CLOUD) { if (IS_CLOUD) {
return DEFAULT_UPDATE_DATA; return DEFAULT_UPDATE_DATA;
} }
@@ -373,10 +373,10 @@ export const settingsRouter = createTRPCRouter({
return true; return true;
}), }),
getDokployVersion: adminProcedure.query(() => { getDokployVersion: protectedProcedure.query(() => {
return packageInfo.version; return packageInfo.version;
}), }),
getReleaseTag: adminProcedure.query(() => { getReleaseTag: protectedProcedure.query(() => {
return getDokployImageTag(); return getDokployImageTag();
}), }),
readDirectories: protectedProcedure readDirectories: protectedProcedure
@@ -411,7 +411,7 @@ export const settingsRouter = createTRPCRouter({
await writeTraefikConfigInPath( await writeTraefikConfigInPath(
input.path, input.path,
input.traefikConfig, input.traefikConfig,
input?.serverId, input?.serverId
); );
return true; return true;
}), }),
@@ -485,7 +485,7 @@ export const settingsRouter = createTRPCRouter({
}; };
return openApiDocument; return openApiDocument;
}, }
), ),
readTraefikEnv: adminProcedure readTraefikEnv: adminProcedure
.input(apiServerSchema) .input(apiServerSchema)
@@ -525,7 +525,7 @@ export const settingsRouter = createTRPCRouter({
stdout = result.stdout; stdout = result.stdout;
} else if (!IS_CLOUD) { } else if (!IS_CLOUD) {
const result = await execAsync( const result = await execAsync(
"docker service inspect --format='{{json .Endpoint.Ports}}' dokploy-traefik", "docker service inspect --format='{{json .Endpoint.Ports}}' dokploy-traefik"
); );
stdout = result.stdout; stdout = result.stdout;
} }
@@ -563,7 +563,7 @@ export const settingsRouter = createTRPCRouter({
input.page, input.page,
input.sort, input.sort,
input.search, input.search,
input.status, input.status
); );
return parsedConfig; return parsedConfig;
@@ -586,7 +586,7 @@ export const settingsRouter = createTRPCRouter({
.input( .input(
z.object({ z.object({
enable: z.boolean(), enable: z.boolean(),
}), })
) )
.mutation(async ({ input }) => { .mutation(async ({ input }) => {
if (IS_CLOUD) { if (IS_CLOUD) {
@@ -619,7 +619,7 @@ export const settingsRouter = createTRPCRouter({
.input( .input(
z.object({ z.object({
enable: z.boolean(), enable: z.boolean(),
}), })
) )
.mutation(async ({ input }) => { .mutation(async ({ input }) => {
if (IS_CLOUD) { if (IS_CLOUD) {
@@ -674,7 +674,7 @@ export const settingsRouter = createTRPCRouter({
.input( .input(
z.object({ z.object({
serverId: z.string().optional(), serverId: z.string().optional(),
}), })
) )
.mutation(async ({ input }) => { .mutation(async ({ input }) => {
if (IS_CLOUD && !input.serverId) { if (IS_CLOUD && !input.serverId) {
@@ -693,7 +693,7 @@ export const settingsRouter = createTRPCRouter({
.input( .input(
z.object({ z.object({
serverId: z.string().optional(), serverId: z.string().optional(),
}), })
) )
.query(async ({ input }) => { .query(async ({ input }) => {
if (IS_CLOUD && !input.serverId) { if (IS_CLOUD && !input.serverId) {
@@ -727,9 +727,9 @@ export const settingsRouter = createTRPCRouter({
targetPort: z.number(), targetPort: z.number(),
publishedPort: z.number(), publishedPort: z.number(),
publishMode: z.enum(["ingress", "host"]).default("host"), publishMode: z.enum(["ingress", "host"]).default("host"),
}), })
), ),
}), })
) )
.mutation(async ({ input }) => { .mutation(async ({ input }) => {
try { try {