feature: board operations (#1800)
This commit is contained in:
@@ -1,6 +1,7 @@
|
||||
import { TRPCError } from '@trpc/server';
|
||||
import fs from 'fs';
|
||||
import { z } from 'zod';
|
||||
import Consola from 'consola';
|
||||
import { getDefaultBoardAsync } from '~/server/db/queries/userSettings';
|
||||
import { configExists } from '~/tools/config/configExists';
|
||||
import { getConfig } from '~/tools/config/getConfig';
|
||||
@@ -8,7 +9,8 @@ import { getFrontendConfig } from '~/tools/config/getFrontendConfig';
|
||||
import { generateDefaultApp } from '~/tools/shared/app';
|
||||
|
||||
import { adminProcedure, createTRPCRouter, protectedProcedure } from '../trpc';
|
||||
import { configNameSchema } from './config';
|
||||
import { writeConfig } from '~/tools/config/writeConfig';
|
||||
import { configNameSchema } from '~/validations/boards';
|
||||
|
||||
export const boardRouter = createTRPCRouter({
|
||||
all: protectedProcedure.query(async ({ ctx }) => {
|
||||
@@ -31,7 +33,7 @@ export const boardRouter = createTRPCRouter({
|
||||
countCategories: config.categories.length,
|
||||
isDefaultForUser: name === defaultBoard,
|
||||
};
|
||||
})
|
||||
}),
|
||||
);
|
||||
}),
|
||||
addAppsForContainers: adminProcedure
|
||||
@@ -43,18 +45,18 @@ export const boardRouter = createTRPCRouter({
|
||||
name: z.string(),
|
||||
icon: z.string().optional(),
|
||||
port: z.number().optional(),
|
||||
})
|
||||
}),
|
||||
),
|
||||
})
|
||||
}),
|
||||
)
|
||||
.mutation(async ({ input }) => {
|
||||
if (!(await configExists(input.boardName))) {
|
||||
if (!configExists(input.boardName)) {
|
||||
throw new TRPCError({
|
||||
code: 'NOT_FOUND',
|
||||
message: 'Board not found',
|
||||
});
|
||||
}
|
||||
const config = await getConfig(input.boardName);
|
||||
const config = getConfig(input.boardName);
|
||||
const lowestWrapper = config?.wrappers.sort((a, b) => a.position - b.position)[0];
|
||||
|
||||
const newConfig = {
|
||||
@@ -86,4 +88,96 @@ export const boardRouter = createTRPCRouter({
|
||||
const targetPath = `data/configs/${input.boardName}.json`;
|
||||
fs.writeFileSync(targetPath, JSON.stringify(newConfig, null, 2), 'utf8');
|
||||
}),
|
||||
renameBoard: protectedProcedure
|
||||
.input(z.object({
|
||||
oldName: z.string(),
|
||||
newName: z.string().min(1),
|
||||
}))
|
||||
.mutation(async ({ input }) => {
|
||||
if (input.oldName === 'default') {
|
||||
Consola.error(`Attempted to rename default configuration. Aborted deletion.`);
|
||||
throw new TRPCError({
|
||||
code: 'CONFLICT',
|
||||
message: 'Cannot rename default board',
|
||||
});
|
||||
}
|
||||
|
||||
if (!configExists(input.oldName)) {
|
||||
Consola.error(`Specified configuration ${input.oldName} does not exist on file system`);
|
||||
throw new TRPCError({
|
||||
code: 'NOT_FOUND',
|
||||
message: 'Board not found',
|
||||
});
|
||||
}
|
||||
|
||||
if (configExists(input.newName)) {
|
||||
Consola.error(`Target name of rename conflicts with existing board`);
|
||||
throw new TRPCError({
|
||||
code: 'CONFLICT',
|
||||
message: 'Board conflicts with existing board',
|
||||
});
|
||||
}
|
||||
|
||||
const config = getConfig(input.oldName);
|
||||
config.configProperties.name = input.newName;
|
||||
writeConfig(config);
|
||||
Consola.info(`Deleting ${input.oldName} from the file system`);
|
||||
const targetPath = `data/configs/${input.oldName}.json`;
|
||||
fs.unlinkSync(targetPath);
|
||||
Consola.info(`Deleted ${input.oldName} from file system`);
|
||||
}),
|
||||
duplicateBoard: protectedProcedure
|
||||
.input(z.object({
|
||||
boardName: z.string(),
|
||||
}))
|
||||
.mutation(async ({ input }) => {
|
||||
if (!configExists(input.boardName)) {
|
||||
Consola.error(`Tried to duplicate ${input.boardName} but this configuration does not exist.`);
|
||||
throw new TRPCError({
|
||||
code: 'NOT_FOUND',
|
||||
message: 'Board not found',
|
||||
});
|
||||
}
|
||||
|
||||
const targetName = attemptGenerateDuplicateName(input.boardName, 10);
|
||||
|
||||
Consola.info(`Target duplication name ${targetName} does not exist`);
|
||||
|
||||
const config = getConfig(input.boardName);
|
||||
config.configProperties.name = targetName;
|
||||
writeConfig(config);
|
||||
|
||||
Consola.info(`Wrote config to name '${targetName}'`)
|
||||
}),
|
||||
});
|
||||
|
||||
const duplicationName = /^(\w+)\s{1}\(([0-9]+)\)$/;
|
||||
|
||||
const attemptGenerateDuplicateName = (baseName: string, maxAttempts: number) => {
|
||||
for (let i = 0; i < maxAttempts; i++) {
|
||||
const newName = generateDuplicateName(baseName, i);
|
||||
if (configExists(newName)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
return newName;
|
||||
}
|
||||
|
||||
Consola.error(`Duplication name ${baseName} conflicts with an existing configuration`);
|
||||
throw new TRPCError({
|
||||
code: 'CONFLICT',
|
||||
message: 'Board conflicts with an existing board',
|
||||
});
|
||||
}
|
||||
|
||||
const generateDuplicateName = (baseName: string, increment: number) => {
|
||||
const result = duplicationName.exec(baseName);
|
||||
|
||||
if (result && result.length === 3) {
|
||||
const originalName = result.at(1);
|
||||
const counter = Number(result.at(2));
|
||||
return `${originalName} (${counter + 1 + increment})`;
|
||||
}
|
||||
|
||||
return `${baseName} (2)`;
|
||||
}
|
||||
|
||||
@@ -8,15 +8,10 @@ import { configExists } from '~/tools/config/configExists';
|
||||
import { getConfig } from '~/tools/config/getConfig';
|
||||
import { getFrontendConfig } from '~/tools/config/getFrontendConfig';
|
||||
import { BackendConfigType, ConfigType } from '~/types/config';
|
||||
import { boardCustomizationSchema } from '~/validations/boards';
|
||||
import { boardCustomizationSchema, configNameSchema } from '~/validations/boards';
|
||||
import { IRssWidget } from '~/widgets/rss/RssWidgetTile';
|
||||
|
||||
import { adminProcedure, createTRPCRouter, publicProcedure } from '../trpc';
|
||||
import { db } from '~/server/db';
|
||||
import { users } from '~/server/db/schema';
|
||||
import { sql } from 'drizzle-orm';
|
||||
|
||||
export const configNameSchema = z.string().regex(/^[a-zA-Z0-9-_]+$/);
|
||||
|
||||
export const configRouter = createTRPCRouter({
|
||||
delete: adminProcedure
|
||||
|
||||
Reference in New Issue
Block a user