feat(libsql): introduce libsql service schema and update related tables

- Created a new SQL type for 'libsql' and added it to the serviceType enum. - Established a 'libsql' table with necessary fields and constraints. - Updated existing tables (backup, mount, volume_backup) to include foreign key references to 'libsql'. - Adjusted the mount schema to incorporate 'libsql' as a valid service type, enhancing service management capabilities.
2026-07-10 16:35:26 +02:00 · 2026-03-23 16:14:37 -06:00
parent 116e9d85b7
commit 4b6f2c84ac
10 changed files with 143 additions and 8266 deletions
--- a/packages/server/src/db/schema/mount.ts
+++ b/packages/server/src/db/schema/mount.ts
@@ -12,6 +12,19 @@ import { mysql } from "./mysql";
 import { postgres } from "./postgres";
 import { redis } from "./redis";

+export const serviceType = pgEnum("serviceType", [
+	"application",
+	"postgres",
+	"mysql",
+	"mariadb",
+	"mongo",
+	"redis",
+	"compose",
+	"libsql",
+]);
+
+export type ServiceType = (typeof serviceType.enumValues)[number];
+
 export const mountType = pgEnum("mountType", ["bind", "volume", "file"]);

 export const mounts = pgTable("mount", {
@@ -24,6 +37,7 @@ export const mounts = pgTable("mount", {
 	volumeName: text("volumeName"),
 	filePath: text("filePath"),
 	content: text("content"),
+	serviceType: serviceType("serviceType").notNull().default("application"),
 	mountPath: text("mountPath").notNull(),
 	applicationId: text("applicationId").references(
 		() => applications.applicationId,
@@ -96,6 +110,16 @@ const createSchema = createInsertSchema(mounts, {
 	mountPath: z.string().min(1),
 	mountId: z.string().optional(),
 	filePath: z.string().optional(),
+	serviceType: z.enum([
+		"application",
+		"postgres",
+		"mysql",
+		"mariadb",
+		"mongo",
+		"redis",
+		"compose",
+		"libsql",
+	]),
 });

 export const apiCreateMount = createSchema
@@ -106,19 +130,10 @@ export const apiCreateMount = createSchema
 		content: true,
 		mountPath: true,
 		filePath: true,
+		serviceType: true,
 	})
 	.extend({
 		serviceId: z.string().min(1),
-		serviceType: z.enum([
-			"application",
-			"postgres",
-			"mysql",
-			"mariadb",
-			"mongo",
-			"redis",
-			"compose",
-			"libsql",
-		]),
 	});

 export const apiFindOneMount = z.object({
@@ -134,19 +149,14 @@ export const apiRemoveMount = createSchema
 	// })
 	.required();

-export const apiFindMountByApplicationId = z.object({
-	serviceId: z.string().min(1),
-	serviceType: z.enum([
-		"application",
-		"postgres",
-		"mysql",
-		"mariadb",
-		"mongo",
-		"redis",
-		"compose",
-		"libsql",
-	]),
-});
+export const apiFindMountByApplicationId = createSchema
+	.pick({
+		serviceType: true,
+	})
+	.required()
+	.extend({
+		serviceId: z.string().min(1),
+	});

 export const apiUpdateMount = createSchema.partial().extend({
 	mountId: z.string().min(1),
--- a/packages/server/src/db/schema/volume-backups.ts
+++ b/packages/server/src/db/schema/volume-backups.ts
@@ -1,5 +1,6 @@
 import { relations } from "drizzle-orm";
 import { boolean, integer, pgTable, text } from "drizzle-orm/pg-core";
+import { serviceType } from "./mount";
 import { createInsertSchema } from "drizzle-zod";
 import { nanoid } from "nanoid";
 import { z } from "zod";
@@ -23,6 +24,7 @@ export const volumeBackups = pgTable("volume_backup", {
 	name: text("name").notNull(),
 	volumeName: text("volumeName").notNull(),
 	prefix: text("prefix").notNull(),
+	serviceType: serviceType("serviceType").notNull().default("application"),
 	appName: text("appName")
 		.notNull()
 		.$defaultFn(() => generateAppName("volumeBackup")),
--- a/packages/server/src/services/mount.ts
+++ b/packages/server/src/services/mount.ts
@@ -4,6 +4,7 @@ import { db } from "@dokploy/server/db";
 import {
 	type apiCreateMount,
 	mounts,
+	type ServiceType,
 } from "@dokploy/server/db/schema";
 import {
 	createFile,
@@ -19,16 +20,6 @@ import { TRPCError } from "@trpc/server";
 import { eq, type SQL, sql } from "drizzle-orm";
 import type { z } from "zod";

-export type ServiceType =
-	| "application"
-	| "compose"
-	| "libsql"
-	| "mariadb"
-	| "mongo"
-	| "mysql"
-	| "postgres"
-	| "redis";
-
 export type Mount = typeof mounts.$inferSelect;

 export const createMount = async (input: z.infer<typeof apiCreateMount>) => {
@@ -361,38 +352,38 @@ export const getBaseFilesPath = async (mountId: string) => {
 	let appName = "";
 	let directoryPath = "";

-	if (mount.applicationId && mount.application) {
+	if (mount.serviceType === "application" && mount.application) {
 		const { APPLICATIONS_PATH } = paths(!!mount.application.serverId);
 		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
 		appName = mount.application.appName;
-	} else if (mount.composeId && mount.compose) {
-		const { COMPOSE_PATH } = paths(!!mount.compose.serverId);
-		appName = mount.compose.appName;
-		absoluteBasePath = path.resolve(COMPOSE_PATH);
-	} else if (mount.libsqlId && mount.libsql) {
-		const { APPLICATIONS_PATH } = paths(!!mount.libsql.serverId);
-		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
-		appName = mount.libsql.appName;
-	} else if (mount.mariadbId && mount.mariadb) {
-		const { APPLICATIONS_PATH } = paths(!!mount.mariadb.serverId);
-		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
-		appName = mount.mariadb.appName;
-	} else if (mount.mongoId && mount.mongo) {
-		const { APPLICATIONS_PATH } = paths(!!mount.mongo.serverId);
-		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
-		appName = mount.mongo.appName;
-	} else if (mount.mysqlId && mount.mysql) {
-		const { APPLICATIONS_PATH } = paths(!!mount.mysql.serverId);
-		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
-		appName = mount.mysql.appName;
-	} else if (mount.postgresId && mount.postgres) {
+	} else if (mount.serviceType === "postgres" && mount.postgres) {
 		const { APPLICATIONS_PATH } = paths(!!mount.postgres.serverId);
 		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
 		appName = mount.postgres.appName;
-	} else if (mount.redisId && mount.redis) {
+	} else if (mount.serviceType === "mariadb" && mount.mariadb) {
+		const { APPLICATIONS_PATH } = paths(!!mount.mariadb.serverId);
+		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
+		appName = mount.mariadb.appName;
+	} else if (mount.serviceType === "mongo" && mount.mongo) {
+		const { APPLICATIONS_PATH } = paths(!!mount.mongo.serverId);
+		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
+		appName = mount.mongo.appName;
+	} else if (mount.serviceType === "mysql" && mount.mysql) {
+		const { APPLICATIONS_PATH } = paths(!!mount.mysql.serverId);
+		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
+		appName = mount.mysql.appName;
+	} else if (mount.serviceType === "redis" && mount.redis) {
 		const { APPLICATIONS_PATH } = paths(!!mount.redis.serverId);
 		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
 		appName = mount.redis.appName;
+	} else if (mount.serviceType === "compose" && mount.compose) {
+		const { COMPOSE_PATH } = paths(!!mount.compose.serverId);
+		appName = mount.compose.appName;
+		absoluteBasePath = path.resolve(COMPOSE_PATH);
+	} else if (mount.serviceType === "libsql" && mount.libsql) {
+		const { APPLICATIONS_PATH } = paths(!!mount.libsql.serverId);
+		absoluteBasePath = path.resolve(APPLICATIONS_PATH);
+		appName = mount.libsql.appName;
 	}
 	directoryPath = path.join(absoluteBasePath, appName, "files");

@@ -401,30 +392,30 @@ export const getBaseFilesPath = async (mountId: string) => {

 type MountNested = Awaited<ReturnType<typeof findMountById>>;
 export const getServerId = async (mount: MountNested) => {
-	if (mount.applicationId && mount?.application?.serverId) {
+	if (mount.serviceType === "application" && mount?.application?.serverId) {
 		return mount.application.serverId;
 	}
-	if (mount.composeId && mount?.compose?.serverId) {
-		return mount.compose.serverId;
-	}
-	if (mount.libsqlId && mount?.libsql?.serverId) {
-		return mount.libsql.serverId;
-	}
-	if (mount.mariadbId && mount?.mariadb?.serverId) {
-		return mount.mariadb.serverId;
-	}
-	if (mount.mongoId && mount?.mongo?.serverId) {
-		return mount.mongo.serverId;
-	}
-	if (mount.mysqlId && mount?.mysql?.serverId) {
-		return mount.mysql.serverId;
-	}
-	if (mount.postgresId && mount?.postgres?.serverId) {
+	if (mount.serviceType === "postgres" && mount?.postgres?.serverId) {
 		return mount.postgres.serverId;
 	}
-	if (mount.redisId && mount?.redis?.serverId) {
+	if (mount.serviceType === "mariadb" && mount?.mariadb?.serverId) {
+		return mount.mariadb.serverId;
+	}
+	if (mount.serviceType === "mongo" && mount?.mongo?.serverId) {
+		return mount.mongo.serverId;
+	}
+	if (mount.serviceType === "mysql" && mount?.mysql?.serverId) {
+		return mount.mysql.serverId;
+	}
+	if (mount.serviceType === "redis" && mount?.redis?.serverId) {
 		return mount.redis.serverId;
 	}
+	if (mount.serviceType === "compose" && mount?.compose?.serverId) {
+		return mount.compose.serverId;
+	}
+	if (mount.serviceType === "libsql" && mount?.libsql?.serverId) {
+		return mount.libsql.serverId;
+	}

 	return null;
 };
--- a/packages/server/src/utils/restore/compose.ts
+++ b/packages/server/src/utils/restore/compose.ts
@@ -32,7 +32,7 @@ export const restoreComposeBackup = async (
 			rcloneCommand = `rclone copy ${rcloneFlags.join(" ")} "${backupPath}"`;
 		}

-		let credentials: DatabaseCredentials;
+		let credentials: DatabaseCredentials = {};

 		switch (backupInput.databaseType) {
 			case "postgres":