feat: add a toggle for replica sets to be used or not

This commit is contained in:
Shadow
2024-12-18 11:50:30 -06:00
parent 8505236263
commit 06b8c82484
3 changed files with 60 additions and 22 deletions

View File

@@ -35,6 +35,7 @@ import {
SelectTrigger, SelectTrigger,
SelectValue, SelectValue,
} from "@/components/ui/select"; } from "@/components/ui/select";
import { Switch } from "@/components/ui/switch";
import { Textarea } from "@/components/ui/textarea"; import { Textarea } from "@/components/ui/textarea";
import { slugify } from "@/lib/slug"; import { slugify } from "@/lib/slug";
import { api } from "@/utils/api"; import { api } from "@/utils/api";
@@ -95,6 +96,7 @@ const mySchema = z.discriminatedUnion("type", [
.object({ .object({
type: z.literal("mongo"), type: z.literal("mongo"),
databaseUser: z.string().default("mongo"), databaseUser: z.string().default("mongo"),
replicaSets: z.boolean().default(false),
}) })
.merge(baseDatabaseSchema), .merge(baseDatabaseSchema),
z z
@@ -216,6 +218,7 @@ export const AddDatabase = ({ projectId, projectName }: Props) => {
databaseUser: databaseUser:
data.databaseUser || databasesUserDefaultPlaceholder[data.type], data.databaseUser || databasesUserDefaultPlaceholder[data.type],
serverId: data.serverId, serverId: data.serverId,
replicaSets: data.replicaSets,
}); });
} else if (data.type === "redis") { } else if (data.type === "redis") {
promise = redisMutation.mutateAsync({ promise = redisMutation.mutateAsync({
@@ -540,6 +543,30 @@ export const AddDatabase = ({ projectId, projectName }: Props) => {
); );
}} }}
/> />
{type === "mongo" && (
<FormField
control={form.control}
name="replicaSets"
render={({ field }) => {
return (
<FormItem>
<FormLabel>Use Replica Sets</FormLabel>
<FormControl>
<Switch
checked={field.value}
onCheckedChange={field.onChange}
disabled
aria-readonly
/>
</FormControl>
<FormMessage />
</FormItem>
);
}}
/>
)}
</div> </div>
</div> </div>
</form> </form>

View File

@@ -1,5 +1,5 @@
import { relations } from "drizzle-orm"; import { relations } from "drizzle-orm";
import { integer, pgTable, text } from "drizzle-orm/pg-core"; import { boolean, integer, pgTable, text } from "drizzle-orm/pg-core";
import { createInsertSchema } from "drizzle-zod"; import { createInsertSchema } from "drizzle-zod";
import { nanoid } from "nanoid"; import { nanoid } from "nanoid";
import { z } from "zod"; import { z } from "zod";
@@ -43,6 +43,7 @@ export const mongo = pgTable("mongo", {
serverId: text("serverId").references(() => server.serverId, { serverId: text("serverId").references(() => server.serverId, {
onDelete: "cascade", onDelete: "cascade",
}), }),
replicaSets: boolean("replicaSets").default(false),
}); });
export const mongoRelations = relations(mongo, ({ one, many }) => ({ export const mongoRelations = relations(mongo, ({ one, many }) => ({
@@ -77,6 +78,7 @@ const createSchema = createInsertSchema(mongo, {
externalPort: z.number(), externalPort: z.number(),
description: z.string().optional(), description: z.string().optional(),
serverId: z.string().optional(), serverId: z.string().optional(),
replicaSets: z.boolean().default(false),
}); });
export const apiCreateMongo = createSchema export const apiCreateMongo = createSchema
@@ -89,6 +91,7 @@ export const apiCreateMongo = createSchema
databaseUser: true, databaseUser: true,
databasePassword: true, databasePassword: true,
serverId: true, serverId: true,
replicaSets: true,
}) })
.required(); .required();

View File

@@ -28,48 +28,56 @@ export const buildMongo = async (mongo: MongoNested) => {
databasePassword, databasePassword,
command, command,
mounts, mounts,
replicaSets,
} = mongo; } = mongo;
const initReplicaSet = ` const startupScript = `
#!/bin/bash #!/bin/bash
${
replicaSets
? `
mongod --port 27017 --replSet rs0 --bind_ip_all & mongod --port 27017 --replSet rs0 --bind_ip_all &
MONGOD_PID=$! MONGOD_PID=$!
# Wait for MongoDB to be ready # Wait for MongoDB to be ready
while ! mongosh --eval "db.adminCommand('ping')" > /dev/null 2>&1; do while ! mongosh --eval "db.adminCommand('ping')" > /dev/null 2>&1; do
sleep 2 sleep 2
done done
# Check if replica set is already initialized # Check if replica set is already initialized
REPLICA_STATUS=$(mongosh --quiet --eval "rs.status().ok || 0") REPLICA_STATUS=$(mongosh --quiet --eval "rs.status().ok || 0")
if [ "$REPLICA_STATUS" != "1" ]; then if [ "$REPLICA_STATUS" != "1" ]; then
echo "Initializing replica set..." echo "Initializing replica set..."
mongosh --eval ' mongosh --eval '
rs.initiate({ rs.initiate({
_id: "rs0", _id: "rs0",
members: [{ _id: 0, host: "localhost:27017", priority: 1 }] members: [{ _id: 0, host: "localhost:27017", priority: 1 }]
}); });
// Wait for the replica set to initialize // Wait for the replica set to initialize
while (!rs.isMaster().ismaster) { while (!rs.isMaster().ismaster) {
sleep(1000); sleep(1000);
} }
// Create root user after replica set is initialized and we are primary // Create root user after replica set is initialized and we are primary
db.getSiblingDB("admin").createUser({ db.getSiblingDB("admin").createUser({
user: "${databaseUser}", user: "${databaseUser}",
pwd: "${databasePassword}", pwd: "${databasePassword}",
roles: ["root"] roles: ["root"]
}); });
' '
else else
echo "Replica set already initialized." echo "Replica set already initialized."
fi fi
`
: "mongod --port 27017 --bind_ip_all & MONGOD_PID=$!"
}
wait $MONGOD_PID`; ${command ?? "wait $MONGOD_PID"}`;
const defaultMongoEnv = `MONGO_INITDB_DATABASE=admin\n${env ? `${env}` : ""}`; const defaultMongoEnv = `MONGO_INITDB_ROOT_USERNAME=${databaseUser}\nMONGO_INITDB_ROOT_PASSWORD=${databasePassword}\nMONGO_INITDB_DATABASE=admin\n${env ? `${env}` : ""}`;
const resources = calculateResources({ const resources = calculateResources({
memoryLimit, memoryLimit,
@@ -96,7 +104,7 @@ wait $MONGOD_PID`;
Env: envVariables, Env: envVariables,
Mounts: [...volumesMount, ...bindsMount, ...filesMount], Mounts: [...volumesMount, ...bindsMount, ...filesMount],
Command: ["/bin/bash"], Command: ["/bin/bash"],
Args: ["-c", command ?? initReplicaSet], Args: ["-c", startupScript],
}, },
Networks: [{ Target: "dokploy-network" }], Networks: [{ Target: "dokploy-network" }],
Resources: { Resources: {