mirror of
https://github.com/Dokploy/dokploy.git
synced 2026-07-23 23:05:25 +02:00
Compare commits
20 Commits
v0.29.13
...
feat/add-n
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8a37626636 | ||
|
|
adcbd6fd8e | ||
|
|
c578c18500 | ||
|
|
94ddbf8ba5 | ||
|
|
61c2b73f08 | ||
|
|
736a77e112 | ||
|
|
f4bcc2e8a8 | ||
|
|
99e483c1a1 | ||
|
|
22c8a1658a | ||
|
|
f0f0db4c7f | ||
|
|
5f508163e5 | ||
|
|
fc75b847b5 | ||
|
|
b1abcb9e06 | ||
|
|
d542972522 | ||
|
|
e7c38d4c54 | ||
|
|
a8f941b5d9 | ||
|
|
c68fac55fd | ||
|
|
efcad7bbf5 | ||
|
|
a0566cdbd7 | ||
|
|
69598821ed |
4
.gitignore
vendored
4
.gitignore
vendored
@@ -43,4 +43,6 @@ yarn-error.log*
|
|||||||
*.pem
|
*.pem
|
||||||
|
|
||||||
|
|
||||||
.db
|
.db
|
||||||
|
|
||||||
|
.playwright-*
|
||||||
373
apps/dokploy/components/dashboard/networks/handle-network.tsx
Normal file
373
apps/dokploy/components/dashboard/networks/handle-network.tsx
Normal file
@@ -0,0 +1,373 @@
|
|||||||
|
"use client";
|
||||||
|
|
||||||
|
import { standardSchemaResolver as zodResolver } from "@hookform/resolvers/standard-schema";
|
||||||
|
import { Network, Plus, Trash2 } from "lucide-react";
|
||||||
|
import { useState } from "react";
|
||||||
|
import { useFieldArray, useForm } from "react-hook-form";
|
||||||
|
import { toast } from "sonner";
|
||||||
|
import { z } from "zod";
|
||||||
|
import { Button } from "@/components/ui/button";
|
||||||
|
import {
|
||||||
|
Dialog,
|
||||||
|
DialogContent,
|
||||||
|
DialogDescription,
|
||||||
|
DialogFooter,
|
||||||
|
DialogHeader,
|
||||||
|
DialogTitle,
|
||||||
|
DialogTrigger,
|
||||||
|
} from "@/components/ui/dialog";
|
||||||
|
import {
|
||||||
|
Form,
|
||||||
|
FormControl,
|
||||||
|
FormDescription,
|
||||||
|
FormField,
|
||||||
|
FormItem,
|
||||||
|
FormLabel,
|
||||||
|
FormMessage,
|
||||||
|
} from "@/components/ui/form";
|
||||||
|
import { Input } from "@/components/ui/input";
|
||||||
|
import {
|
||||||
|
Select,
|
||||||
|
SelectContent,
|
||||||
|
SelectItem,
|
||||||
|
SelectTrigger,
|
||||||
|
SelectValue,
|
||||||
|
} from "@/components/ui/select";
|
||||||
|
import { Switch } from "@/components/ui/switch";
|
||||||
|
import { api } from "@/utils/api";
|
||||||
|
|
||||||
|
// Only bridge and overlay can be created: "host"/"none" are Docker
|
||||||
|
// singletons and macvlan/ipvlan need driver options we don't expose.
|
||||||
|
const networkDriverEnum = ["bridge", "overlay"] as const;
|
||||||
|
|
||||||
|
const ipamConfigEntrySchema = z.object({
|
||||||
|
subnet: z.string().optional(),
|
||||||
|
ipRange: z.string().optional(),
|
||||||
|
gateway: z.string().optional(),
|
||||||
|
});
|
||||||
|
|
||||||
|
const networkFormSchema = z
|
||||||
|
.object({
|
||||||
|
name: z.string().min(1, "Name is required"),
|
||||||
|
driver: z.enum(networkDriverEnum),
|
||||||
|
internal: z.boolean(),
|
||||||
|
attachable: z.boolean(),
|
||||||
|
enableIPv4: z.boolean(),
|
||||||
|
enableIPv6: z.boolean(),
|
||||||
|
ipamDriver: z.string().optional(),
|
||||||
|
ipamConfig: z.array(ipamConfigEntrySchema),
|
||||||
|
})
|
||||||
|
.superRefine((input, ctx) => {
|
||||||
|
if (!input.enableIPv4 && !input.enableIPv6) {
|
||||||
|
ctx.addIssue({
|
||||||
|
code: z.ZodIssueCode.custom,
|
||||||
|
path: ["enableIPv4"],
|
||||||
|
message: "IPv4 or IPv6 must be enabled",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
for (const [index, entry] of input.ipamConfig.entries()) {
|
||||||
|
if (!entry.subnet && (entry.gateway || entry.ipRange)) {
|
||||||
|
ctx.addIssue({
|
||||||
|
code: z.ZodIssueCode.custom,
|
||||||
|
path: ["ipamConfig", index, "subnet"],
|
||||||
|
message: "Gateway and IP range require a subnet",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
type NetworkFormValues = z.infer<typeof networkFormSchema>;
|
||||||
|
|
||||||
|
const defaultValues: NetworkFormValues = {
|
||||||
|
name: "",
|
||||||
|
driver: "bridge",
|
||||||
|
internal: false,
|
||||||
|
attachable: false,
|
||||||
|
enableIPv4: true,
|
||||||
|
enableIPv6: false,
|
||||||
|
ipamDriver: "",
|
||||||
|
ipamConfig: [],
|
||||||
|
};
|
||||||
|
|
||||||
|
const toggleOptions = [
|
||||||
|
{
|
||||||
|
name: "internal",
|
||||||
|
label: "Internal",
|
||||||
|
description: "Containers on this network cannot reach external networks.",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "attachable",
|
||||||
|
label: "Attachable",
|
||||||
|
description:
|
||||||
|
"Allow standalone containers to attach (overlay networks only).",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "enableIPv4",
|
||||||
|
label: "Enable IPv4",
|
||||||
|
description: "Enable IPv4 addressing on the network.",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "enableIPv6",
|
||||||
|
label: "Enable IPv6",
|
||||||
|
description: "Enable IPv6 addressing on the network.",
|
||||||
|
},
|
||||||
|
] as const;
|
||||||
|
|
||||||
|
interface HandleNetworkProps {
|
||||||
|
/** Target server; undefined creates on the local Dokploy server */
|
||||||
|
serverId?: string;
|
||||||
|
children?: React.ReactNode;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Docker networks are immutable, so this dialog only creates them;
|
||||||
|
// changing a network means deleting and recreating it.
|
||||||
|
export const HandleNetwork = ({ serverId, children }: HandleNetworkProps) => {
|
||||||
|
const [isOpen, setIsOpen] = useState(false);
|
||||||
|
const utils = api.useUtils();
|
||||||
|
|
||||||
|
const { mutateAsync, isPending } = api.network.create.useMutation();
|
||||||
|
|
||||||
|
const form = useForm<NetworkFormValues>({
|
||||||
|
resolver: zodResolver(networkFormSchema),
|
||||||
|
defaultValues,
|
||||||
|
});
|
||||||
|
|
||||||
|
const ipamConfigFieldArray = useFieldArray({
|
||||||
|
control: form.control,
|
||||||
|
name: "ipamConfig",
|
||||||
|
});
|
||||||
|
|
||||||
|
const onSubmit = async (data: NetworkFormValues) => {
|
||||||
|
try {
|
||||||
|
await mutateAsync({
|
||||||
|
name: data.name,
|
||||||
|
driver: data.driver,
|
||||||
|
serverId,
|
||||||
|
internal: data.internal,
|
||||||
|
attachable: data.attachable,
|
||||||
|
enableIPv4: data.enableIPv4,
|
||||||
|
enableIPv6: data.enableIPv6,
|
||||||
|
ipam: {
|
||||||
|
driver: data.ipamDriver || undefined,
|
||||||
|
config: data.ipamConfig,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
toast.success("Network created");
|
||||||
|
await utils.network.all.invalidate();
|
||||||
|
setIsOpen(false);
|
||||||
|
form.reset(defaultValues);
|
||||||
|
} catch (error) {
|
||||||
|
toast.error("Error creating network", {
|
||||||
|
description: error instanceof Error ? error.message : "Unknown error",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
const trigger = children ?? (
|
||||||
|
<Button>
|
||||||
|
<Plus className=" size-4" />
|
||||||
|
Add network
|
||||||
|
</Button>
|
||||||
|
);
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Dialog open={isOpen} onOpenChange={setIsOpen}>
|
||||||
|
<DialogTrigger asChild>{trigger}</DialogTrigger>
|
||||||
|
<DialogContent className="sm:max-w-2xl max-h-[90vh] overflow-y-auto">
|
||||||
|
<DialogHeader>
|
||||||
|
<DialogTitle className="flex items-center gap-2">
|
||||||
|
<Network className="size-5 text-muted-foreground" />
|
||||||
|
Add network
|
||||||
|
</DialogTitle>
|
||||||
|
<DialogDescription>
|
||||||
|
Create a new Docker network for your organization. Networks are
|
||||||
|
immutable: to change one, delete it and create it again.
|
||||||
|
</DialogDescription>
|
||||||
|
</DialogHeader>
|
||||||
|
<Form {...form}>
|
||||||
|
<form
|
||||||
|
onSubmit={form.handleSubmit(onSubmit)}
|
||||||
|
className="flex w-full flex-col gap-6"
|
||||||
|
>
|
||||||
|
<div className="grid grid-cols-1 gap-4 sm:grid-cols-2">
|
||||||
|
<FormField
|
||||||
|
control={form.control}
|
||||||
|
name="name"
|
||||||
|
render={({ field }) => (
|
||||||
|
<FormItem>
|
||||||
|
<FormLabel>Name</FormLabel>
|
||||||
|
<FormControl>
|
||||||
|
<Input placeholder="my-network" {...field} />
|
||||||
|
</FormControl>
|
||||||
|
<FormMessage />
|
||||||
|
</FormItem>
|
||||||
|
)}
|
||||||
|
/>
|
||||||
|
<FormField
|
||||||
|
control={form.control}
|
||||||
|
name="driver"
|
||||||
|
render={({ field }) => (
|
||||||
|
<FormItem>
|
||||||
|
<FormLabel>Driver</FormLabel>
|
||||||
|
<Select onValueChange={field.onChange} value={field.value}>
|
||||||
|
<FormControl>
|
||||||
|
<SelectTrigger>
|
||||||
|
<SelectValue placeholder="Select driver" />
|
||||||
|
</SelectTrigger>
|
||||||
|
</FormControl>
|
||||||
|
<SelectContent>
|
||||||
|
{networkDriverEnum.map((d) => (
|
||||||
|
<SelectItem key={d} value={d}>
|
||||||
|
{d}
|
||||||
|
</SelectItem>
|
||||||
|
))}
|
||||||
|
</SelectContent>
|
||||||
|
</Select>
|
||||||
|
<FormDescription className="text-muted-foreground">
|
||||||
|
bridge for single-server containers; overlay for Swarm
|
||||||
|
services.
|
||||||
|
</FormDescription>
|
||||||
|
<FormMessage />
|
||||||
|
</FormItem>
|
||||||
|
)}
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
<div className="grid grid-cols-1 gap-4 sm:grid-cols-2">
|
||||||
|
{toggleOptions.map((option) => (
|
||||||
|
<FormField
|
||||||
|
key={option.name}
|
||||||
|
control={form.control}
|
||||||
|
name={option.name}
|
||||||
|
render={({ field }) => (
|
||||||
|
<FormItem className="flex flex-row items-start justify-between gap-3 space-y-0 rounded-lg border p-4">
|
||||||
|
<div className="space-y-1 pr-1">
|
||||||
|
<FormLabel>{option.label}</FormLabel>
|
||||||
|
<FormDescription className="text-muted-foreground">
|
||||||
|
{option.description}
|
||||||
|
</FormDescription>
|
||||||
|
</div>
|
||||||
|
<FormControl>
|
||||||
|
<Switch
|
||||||
|
checked={field.value}
|
||||||
|
onCheckedChange={field.onChange}
|
||||||
|
/>
|
||||||
|
</FormControl>
|
||||||
|
</FormItem>
|
||||||
|
)}
|
||||||
|
/>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
<div className="space-y-4 rounded-lg border p-4">
|
||||||
|
<div className="space-y-1">
|
||||||
|
<FormLabel>IPAM</FormLabel>
|
||||||
|
<p className="text-sm text-muted-foreground">
|
||||||
|
IP address management settings for this network.
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
<FormField
|
||||||
|
control={form.control}
|
||||||
|
name="ipamDriver"
|
||||||
|
render={({ field }) => (
|
||||||
|
<FormItem>
|
||||||
|
<FormLabel className="text-muted-foreground">
|
||||||
|
Driver (optional)
|
||||||
|
</FormLabel>
|
||||||
|
<FormControl>
|
||||||
|
<Input {...field} placeholder="default" />
|
||||||
|
</FormControl>
|
||||||
|
<FormMessage />
|
||||||
|
</FormItem>
|
||||||
|
)}
|
||||||
|
/>
|
||||||
|
<div className="space-y-2">
|
||||||
|
<FormLabel className="text-muted-foreground">
|
||||||
|
Config (subnet / gateway / IP range)
|
||||||
|
</FormLabel>
|
||||||
|
{ipamConfigFieldArray.fields.map((field, index) => (
|
||||||
|
<div key={field.id} className="flex flex-wrap gap-2">
|
||||||
|
<FormField
|
||||||
|
control={form.control}
|
||||||
|
name={`ipamConfig.${index}.subnet`}
|
||||||
|
render={({ field: f }) => (
|
||||||
|
<FormItem className="min-w-[140px] flex-1">
|
||||||
|
<FormControl>
|
||||||
|
<Input
|
||||||
|
{...f}
|
||||||
|
placeholder="Subnet (e.g. 172.20.0.0/16)"
|
||||||
|
/>
|
||||||
|
</FormControl>
|
||||||
|
<FormMessage />
|
||||||
|
</FormItem>
|
||||||
|
)}
|
||||||
|
/>
|
||||||
|
<FormField
|
||||||
|
control={form.control}
|
||||||
|
name={`ipamConfig.${index}.ipRange`}
|
||||||
|
render={({ field: f }) => (
|
||||||
|
<FormItem className="min-w-[120px] flex-1">
|
||||||
|
<FormControl>
|
||||||
|
<Input {...f} placeholder="IP range" />
|
||||||
|
</FormControl>
|
||||||
|
<FormMessage />
|
||||||
|
</FormItem>
|
||||||
|
)}
|
||||||
|
/>
|
||||||
|
<FormField
|
||||||
|
control={form.control}
|
||||||
|
name={`ipamConfig.${index}.gateway`}
|
||||||
|
render={({ field: f }) => (
|
||||||
|
<FormItem className="min-w-[120px] flex-1">
|
||||||
|
<FormControl>
|
||||||
|
<Input {...f} placeholder="Gateway" />
|
||||||
|
</FormControl>
|
||||||
|
<FormMessage />
|
||||||
|
</FormItem>
|
||||||
|
)}
|
||||||
|
/>
|
||||||
|
<Button
|
||||||
|
type="button"
|
||||||
|
variant="outline"
|
||||||
|
size="icon"
|
||||||
|
aria-label="Remove IPAM config"
|
||||||
|
onClick={() => ipamConfigFieldArray.remove(index)}
|
||||||
|
>
|
||||||
|
<Trash2 className="size-4" />
|
||||||
|
</Button>
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
<Button
|
||||||
|
type="button"
|
||||||
|
variant="outline"
|
||||||
|
size="sm"
|
||||||
|
onClick={() =>
|
||||||
|
ipamConfigFieldArray.append({
|
||||||
|
subnet: "",
|
||||||
|
ipRange: "",
|
||||||
|
gateway: "",
|
||||||
|
})
|
||||||
|
}
|
||||||
|
>
|
||||||
|
<Plus className="size-4" />
|
||||||
|
Add IPAM config
|
||||||
|
</Button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<DialogFooter>
|
||||||
|
<Button
|
||||||
|
type="button"
|
||||||
|
variant="outline"
|
||||||
|
onClick={() => setIsOpen(false)}
|
||||||
|
>
|
||||||
|
Cancel
|
||||||
|
</Button>
|
||||||
|
<Button type="submit" isLoading={isPending}>
|
||||||
|
Create network
|
||||||
|
</Button>
|
||||||
|
</DialogFooter>
|
||||||
|
</form>
|
||||||
|
</Form>
|
||||||
|
</DialogContent>
|
||||||
|
</Dialog>
|
||||||
|
);
|
||||||
|
};
|
||||||
@@ -0,0 +1,69 @@
|
|||||||
|
"use client";
|
||||||
|
|
||||||
|
import { Eye, Loader2 } from "lucide-react";
|
||||||
|
import { useState } from "react";
|
||||||
|
import { AlertBlock } from "@/components/shared/alert-block";
|
||||||
|
import { CodeEditor } from "@/components/shared/code-editor";
|
||||||
|
import { Button } from "@/components/ui/button";
|
||||||
|
import {
|
||||||
|
Dialog,
|
||||||
|
DialogContent,
|
||||||
|
DialogDescription,
|
||||||
|
DialogHeader,
|
||||||
|
DialogTitle,
|
||||||
|
DialogTrigger,
|
||||||
|
} from "@/components/ui/dialog";
|
||||||
|
import { api } from "@/utils/api";
|
||||||
|
|
||||||
|
interface Props {
|
||||||
|
networkId: string;
|
||||||
|
networkName: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export const ShowNetworkConfig = ({ networkId, networkName }: Props) => {
|
||||||
|
const [open, setOpen] = useState(false);
|
||||||
|
const { data, isLoading, error } = api.network.inspect.useQuery(
|
||||||
|
{ networkId },
|
||||||
|
{ enabled: open },
|
||||||
|
);
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Dialog open={open} onOpenChange={setOpen}>
|
||||||
|
<DialogTrigger asChild>
|
||||||
|
<Button variant="ghost" size="icon-sm" aria-label="View network config">
|
||||||
|
<Eye className="size-4" />
|
||||||
|
</Button>
|
||||||
|
</DialogTrigger>
|
||||||
|
<DialogContent className="w-full md:w-[70vw] min-w-[70vw]">
|
||||||
|
<DialogHeader>
|
||||||
|
<DialogTitle>Network Config</DialogTitle>
|
||||||
|
<DialogDescription>
|
||||||
|
docker network inspect output for "{networkName}"
|
||||||
|
</DialogDescription>
|
||||||
|
</DialogHeader>
|
||||||
|
{error ? (
|
||||||
|
<AlertBlock type="error">{error.message}</AlertBlock>
|
||||||
|
) : isLoading ? (
|
||||||
|
<div className="flex flex-row gap-2 items-center justify-center py-10 text-sm text-muted-foreground">
|
||||||
|
<span>Loading...</span>
|
||||||
|
<Loader2 className="animate-spin size-4" />
|
||||||
|
</div>
|
||||||
|
) : (
|
||||||
|
<div className="text-wrap rounded-lg border p-4 overflow-y-auto text-sm bg-card max-h-[80vh]">
|
||||||
|
<code>
|
||||||
|
<pre className="whitespace-pre-wrap wrap-break-word">
|
||||||
|
<CodeEditor
|
||||||
|
language="json"
|
||||||
|
lineWrapping
|
||||||
|
lineNumbers={false}
|
||||||
|
readOnly
|
||||||
|
value={JSON.stringify(data, null, 2)}
|
||||||
|
/>
|
||||||
|
</pre>
|
||||||
|
</code>
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
</DialogContent>
|
||||||
|
</Dialog>
|
||||||
|
);
|
||||||
|
};
|
||||||
494
apps/dokploy/components/dashboard/networks/show-networks.tsx
Normal file
494
apps/dokploy/components/dashboard/networks/show-networks.tsx
Normal file
@@ -0,0 +1,494 @@
|
|||||||
|
"use client";
|
||||||
|
|
||||||
|
import {
|
||||||
|
type ColumnDef,
|
||||||
|
flexRender,
|
||||||
|
getCoreRowModel,
|
||||||
|
getPaginationRowModel,
|
||||||
|
getSortedRowModel,
|
||||||
|
type PaginationState,
|
||||||
|
type SortingState,
|
||||||
|
useReactTable,
|
||||||
|
} from "@tanstack/react-table";
|
||||||
|
import type { inferRouterOutputs } from "@trpc/server";
|
||||||
|
import {
|
||||||
|
ArrowUpDown,
|
||||||
|
Loader2,
|
||||||
|
Network,
|
||||||
|
RotateCcw,
|
||||||
|
ShieldCheck,
|
||||||
|
Trash2,
|
||||||
|
} from "lucide-react";
|
||||||
|
import { useMemo, useState } from "react";
|
||||||
|
import { toast } from "sonner";
|
||||||
|
import { HandleNetwork } from "@/components/dashboard/networks/handle-network";
|
||||||
|
import { ShowNetworkConfig } from "@/components/dashboard/networks/show-network-config";
|
||||||
|
import { SyncNetworks } from "@/components/dashboard/networks/sync-networks";
|
||||||
|
import { DialogAction } from "@/components/shared/dialog-action";
|
||||||
|
import { Badge } from "@/components/ui/badge";
|
||||||
|
import { Button } from "@/components/ui/button";
|
||||||
|
import {
|
||||||
|
Card,
|
||||||
|
CardAction,
|
||||||
|
CardContent,
|
||||||
|
CardDescription,
|
||||||
|
CardHeader,
|
||||||
|
CardTitle,
|
||||||
|
} from "@/components/ui/card";
|
||||||
|
import { Input } from "@/components/ui/input";
|
||||||
|
import {
|
||||||
|
Select,
|
||||||
|
SelectContent,
|
||||||
|
SelectItem,
|
||||||
|
SelectTrigger,
|
||||||
|
SelectValue,
|
||||||
|
} from "@/components/ui/select";
|
||||||
|
import {
|
||||||
|
Table,
|
||||||
|
TableBody,
|
||||||
|
TableCell,
|
||||||
|
TableHead,
|
||||||
|
TableHeader,
|
||||||
|
TableRow,
|
||||||
|
} from "@/components/ui/table";
|
||||||
|
import type { AppRouter } from "@/server/api/root";
|
||||||
|
import { api } from "@/utils/api";
|
||||||
|
|
||||||
|
type NetworkRow = inferRouterOutputs<AppRouter>["network"]["all"][number];
|
||||||
|
|
||||||
|
interface Props {
|
||||||
|
/** Selected server; undefined shows the local Dokploy server */
|
||||||
|
serverId?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
const getIpamEntries = (row: NetworkRow) =>
|
||||||
|
(row.ipam?.config ?? []).filter((c) => c.subnet || c.gateway || c.ipRange);
|
||||||
|
|
||||||
|
const SortableHeader = ({
|
||||||
|
column,
|
||||||
|
title,
|
||||||
|
}: {
|
||||||
|
column: {
|
||||||
|
getIsSorted: () => false | "asc" | "desc";
|
||||||
|
toggleSorting: (asc: boolean) => void;
|
||||||
|
};
|
||||||
|
title: string;
|
||||||
|
}) => (
|
||||||
|
<Button
|
||||||
|
variant="ghost"
|
||||||
|
className="-ml-3 h-8"
|
||||||
|
onClick={() => column.toggleSorting(column.getIsSorted() === "asc")}
|
||||||
|
>
|
||||||
|
{title}
|
||||||
|
<ArrowUpDown className="ml-2 size-4" />
|
||||||
|
</Button>
|
||||||
|
);
|
||||||
|
|
||||||
|
export const ShowNetworks = ({ serverId }: Props) => {
|
||||||
|
const utils = api.useUtils();
|
||||||
|
const [verified, setVerified] = useState(false);
|
||||||
|
const [sorting, setSorting] = useState<SortingState>([
|
||||||
|
{ id: "createdAt", desc: true },
|
||||||
|
]);
|
||||||
|
const [globalFilter, setGlobalFilter] = useState("");
|
||||||
|
const [driverFilter, setDriverFilter] = useState<string>("all");
|
||||||
|
const [pagination, setPagination] = useState<PaginationState>({
|
||||||
|
pageIndex: 0,
|
||||||
|
pageSize: 10,
|
||||||
|
});
|
||||||
|
|
||||||
|
const { data: networks, isLoading } = api.network.all.useQuery({ serverId });
|
||||||
|
const { mutateAsync: removeNetwork } = api.network.remove.useMutation();
|
||||||
|
const recreateMutation = api.network.recreate.useMutation();
|
||||||
|
|
||||||
|
// Same query the Sync dialog uses; "missing" tells us which records
|
||||||
|
// no longer have a real network in Docker
|
||||||
|
const {
|
||||||
|
data: syncStatus,
|
||||||
|
isFetching: isVerifying,
|
||||||
|
refetch: refetchVerify,
|
||||||
|
} = api.network.networksToSync.useQuery({ serverId }, { enabled: verified });
|
||||||
|
|
||||||
|
const missingIds = useMemo(
|
||||||
|
() => new Set(syncStatus?.missing.map((m) => m.networkId) ?? []),
|
||||||
|
[syncStatus],
|
||||||
|
);
|
||||||
|
|
||||||
|
const onVerify = async () => {
|
||||||
|
setVerified(true);
|
||||||
|
const { data: result, error } = await refetchVerify();
|
||||||
|
if (error) {
|
||||||
|
toast.error("Error verifying networks", {
|
||||||
|
description: error.message,
|
||||||
|
});
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if (!result) return;
|
||||||
|
if (result.missing.length === 0) {
|
||||||
|
toast.success("All networks exist in Docker");
|
||||||
|
} else {
|
||||||
|
toast.warning(
|
||||||
|
`${result.missing.length} network(s) no longer exist in Docker`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
const filteredData = useMemo(() => {
|
||||||
|
let list = networks ?? [];
|
||||||
|
if (driverFilter !== "all") {
|
||||||
|
list = list.filter((n) => n.driver === driverFilter);
|
||||||
|
}
|
||||||
|
if (globalFilter.trim()) {
|
||||||
|
const query = globalFilter.toLowerCase();
|
||||||
|
list = list.filter(
|
||||||
|
(n) =>
|
||||||
|
n.name.toLowerCase().includes(query) ||
|
||||||
|
(n.ipam?.config ?? []).some(
|
||||||
|
(c) =>
|
||||||
|
c.subnet?.toLowerCase().includes(query) ||
|
||||||
|
c.gateway?.toLowerCase().includes(query) ||
|
||||||
|
c.ipRange?.toLowerCase().includes(query),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
return list;
|
||||||
|
}, [networks, driverFilter, globalFilter]);
|
||||||
|
|
||||||
|
const columns = useMemo<ColumnDef<NetworkRow>[]>(
|
||||||
|
() => [
|
||||||
|
{
|
||||||
|
accessorKey: "name",
|
||||||
|
header: ({ column }) => <SortableHeader column={column} title="Name" />,
|
||||||
|
cell: ({ row }) => (
|
||||||
|
<div className="flex items-center gap-2 font-medium">
|
||||||
|
{row.original.name}
|
||||||
|
{verified &&
|
||||||
|
syncStatus &&
|
||||||
|
(missingIds.has(row.original.networkId) ? (
|
||||||
|
<>
|
||||||
|
<Badge variant="red">Missing in Docker</Badge>
|
||||||
|
<Button
|
||||||
|
variant="outline"
|
||||||
|
size="xs"
|
||||||
|
isLoading={recreateMutation.isPending}
|
||||||
|
onClick={async () => {
|
||||||
|
try {
|
||||||
|
await recreateMutation.mutateAsync({
|
||||||
|
networkId: row.original.networkId,
|
||||||
|
});
|
||||||
|
toast.success(
|
||||||
|
`Network "${row.original.name}" recreated in Docker`,
|
||||||
|
);
|
||||||
|
await utils.network.networksToSync.invalidate();
|
||||||
|
} catch (error) {
|
||||||
|
toast.error("Error recreating network", {
|
||||||
|
description:
|
||||||
|
error instanceof Error
|
||||||
|
? error.message
|
||||||
|
: "Unknown error",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
<RotateCcw className="size-3.5" />
|
||||||
|
Recreate
|
||||||
|
</Button>
|
||||||
|
</>
|
||||||
|
) : (
|
||||||
|
<Badge variant="green">In sync</Badge>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
accessorKey: "driver",
|
||||||
|
header: ({ column }) => (
|
||||||
|
<SortableHeader column={column} title="Driver" />
|
||||||
|
),
|
||||||
|
cell: ({ row }) => (
|
||||||
|
<div className="flex items-center gap-2">
|
||||||
|
<Badge variant="outline">{row.original.driver}</Badge>
|
||||||
|
<span className="text-xs text-muted-foreground">
|
||||||
|
{row.original.driver === "overlay" ? "swarm" : "local"}
|
||||||
|
</span>
|
||||||
|
</div>
|
||||||
|
),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: "subnet",
|
||||||
|
accessorFn: (row) => getIpamEntries(row)[0]?.subnet ?? "",
|
||||||
|
header: ({ column }) => (
|
||||||
|
<SortableHeader column={column} title="Subnet" />
|
||||||
|
),
|
||||||
|
cell: ({ row }) => {
|
||||||
|
const ipamEntries = getIpamEntries(row.original);
|
||||||
|
if (ipamEntries.length === 0) {
|
||||||
|
return <span className="text-muted-foreground">Auto</span>;
|
||||||
|
}
|
||||||
|
return (
|
||||||
|
<div className="flex flex-col gap-1">
|
||||||
|
{ipamEntries.map((c, index) => (
|
||||||
|
<div
|
||||||
|
key={`${row.original.networkId}-ipam-${index}`}
|
||||||
|
className="flex flex-col"
|
||||||
|
>
|
||||||
|
<span>{c.subnet ?? "—"}</span>
|
||||||
|
{(c.gateway || c.ipRange) && (
|
||||||
|
<span className="text-xs text-muted-foreground">
|
||||||
|
{[
|
||||||
|
c.gateway && `gw ${c.gateway}`,
|
||||||
|
c.ipRange && `range ${c.ipRange}`,
|
||||||
|
]
|
||||||
|
.filter(Boolean)
|
||||||
|
.join(" · ")}
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
accessorKey: "internal",
|
||||||
|
header: ({ column }) => (
|
||||||
|
<SortableHeader column={column} title="Internal" />
|
||||||
|
),
|
||||||
|
cell: ({ row }) => (
|
||||||
|
<span className="text-muted-foreground">
|
||||||
|
{row.original.internal ? "Yes" : "No"}
|
||||||
|
</span>
|
||||||
|
),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
accessorKey: "attachable",
|
||||||
|
header: ({ column }) => (
|
||||||
|
<SortableHeader column={column} title="Attachable" />
|
||||||
|
),
|
||||||
|
cell: ({ row }) => (
|
||||||
|
<span className="text-muted-foreground">
|
||||||
|
{row.original.attachable ? "Yes" : "No"}
|
||||||
|
</span>
|
||||||
|
),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
accessorKey: "createdAt",
|
||||||
|
header: ({ column }) => (
|
||||||
|
<SortableHeader column={column} title="Created" />
|
||||||
|
),
|
||||||
|
cell: ({ row }) => (
|
||||||
|
<span className="text-muted-foreground whitespace-nowrap">
|
||||||
|
{new Date(row.original.createdAt).toLocaleDateString()}
|
||||||
|
</span>
|
||||||
|
),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: "actions",
|
||||||
|
enableSorting: false,
|
||||||
|
header: () => <div className="text-right">Actions</div>,
|
||||||
|
cell: ({ row }) => (
|
||||||
|
<div className="flex items-center justify-end gap-3">
|
||||||
|
<ShowNetworkConfig
|
||||||
|
networkId={row.original.networkId}
|
||||||
|
networkName={row.original.name}
|
||||||
|
/>
|
||||||
|
<DialogAction
|
||||||
|
title="Delete network"
|
||||||
|
description={`The network "${row.original.name}" will be removed from Docker and Dokploy. This action cannot be undone.`}
|
||||||
|
onClick={async () => {
|
||||||
|
try {
|
||||||
|
await removeNetwork({
|
||||||
|
networkId: row.original.networkId,
|
||||||
|
});
|
||||||
|
toast.success("Network deleted");
|
||||||
|
await utils.network.all.invalidate();
|
||||||
|
await utils.network.networksToSync.invalidate();
|
||||||
|
} catch (error) {
|
||||||
|
toast.error("Error deleting network", {
|
||||||
|
description:
|
||||||
|
error instanceof Error ? error.message : "Unknown error",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
<Button
|
||||||
|
variant="ghost"
|
||||||
|
size="icon-sm"
|
||||||
|
aria-label="Delete network"
|
||||||
|
>
|
||||||
|
<Trash2 className="size-4 text-destructive" />
|
||||||
|
</Button>
|
||||||
|
</DialogAction>
|
||||||
|
</div>
|
||||||
|
),
|
||||||
|
},
|
||||||
|
],
|
||||||
|
[verified, syncStatus, missingIds, removeNetwork, recreateMutation, utils],
|
||||||
|
);
|
||||||
|
|
||||||
|
const table = useReactTable({
|
||||||
|
data: filteredData,
|
||||||
|
columns,
|
||||||
|
state: {
|
||||||
|
sorting,
|
||||||
|
pagination,
|
||||||
|
},
|
||||||
|
onSortingChange: setSorting,
|
||||||
|
onPaginationChange: setPagination,
|
||||||
|
getCoreRowModel: getCoreRowModel(),
|
||||||
|
getSortedRowModel: getSortedRowModel(),
|
||||||
|
getPaginationRowModel: getPaginationRowModel(),
|
||||||
|
});
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className="w-full">
|
||||||
|
<Card className="h-full bg-sidebar p-2.5 rounded-xl">
|
||||||
|
<div className="rounded-xl bg-background shadow-md ">
|
||||||
|
<CardHeader className="">
|
||||||
|
<CardTitle className="text-xl flex flex-row gap-2">
|
||||||
|
<Network className="size-6 text-muted-foreground self-center" />
|
||||||
|
Networks
|
||||||
|
</CardTitle>
|
||||||
|
<CardDescription>
|
||||||
|
Manage the Docker networks of the selected server.
|
||||||
|
</CardDescription>
|
||||||
|
<CardAction className="self-center">
|
||||||
|
<div className="flex items-center gap-2">
|
||||||
|
{networks && networks.length > 0 && (
|
||||||
|
<Button
|
||||||
|
variant="outline"
|
||||||
|
isLoading={isVerifying}
|
||||||
|
onClick={onVerify}
|
||||||
|
>
|
||||||
|
<ShieldCheck className="size-4" />
|
||||||
|
Verify
|
||||||
|
</Button>
|
||||||
|
)}
|
||||||
|
<SyncNetworks serverId={serverId} />
|
||||||
|
{networks && networks.length > 0 && (
|
||||||
|
<HandleNetwork serverId={serverId} />
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
</CardAction>
|
||||||
|
</CardHeader>
|
||||||
|
|
||||||
|
<CardContent className="space-y-4 py-8 border-t">
|
||||||
|
{isLoading ? (
|
||||||
|
<div className="flex flex-row gap-2 items-center justify-center text-sm text-muted-foreground min-h-[45vh]">
|
||||||
|
<span>Loading...</span>
|
||||||
|
<Loader2 className="animate-spin size-4" />
|
||||||
|
</div>
|
||||||
|
) : !networks?.length ? (
|
||||||
|
<div className="flex min-h-[45vh] w-full flex-col items-center justify-center gap-4 rounded-lg border border-dashed p-8">
|
||||||
|
<div className="rounded-full bg-muted p-4">
|
||||||
|
<Network className="size-10 text-muted-foreground" />
|
||||||
|
</div>
|
||||||
|
<div className="space-y-1 text-center">
|
||||||
|
<p className="text-sm font-medium">No networks yet</p>
|
||||||
|
<p className="max-w-sm text-sm text-muted-foreground">
|
||||||
|
Create Docker networks for your organization and optionally
|
||||||
|
attach them to a server. Add your first network to get
|
||||||
|
started.
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
<HandleNetwork serverId={serverId} />
|
||||||
|
</div>
|
||||||
|
) : (
|
||||||
|
<>
|
||||||
|
<div className="flex flex-wrap items-center gap-2">
|
||||||
|
<Input
|
||||||
|
placeholder="Search by name, subnet, gateway..."
|
||||||
|
value={globalFilter}
|
||||||
|
onChange={(e) => setGlobalFilter(e.target.value)}
|
||||||
|
className="max-w-xs"
|
||||||
|
/>
|
||||||
|
<Select value={driverFilter} onValueChange={setDriverFilter}>
|
||||||
|
<SelectTrigger className="w-[150px]">
|
||||||
|
<SelectValue placeholder="Driver" />
|
||||||
|
</SelectTrigger>
|
||||||
|
<SelectContent>
|
||||||
|
<SelectItem value="all">All drivers</SelectItem>
|
||||||
|
<SelectItem value="bridge">bridge</SelectItem>
|
||||||
|
<SelectItem value="overlay">overlay</SelectItem>
|
||||||
|
</SelectContent>
|
||||||
|
</Select>
|
||||||
|
</div>
|
||||||
|
<div className="rounded-md border overflow-x-auto">
|
||||||
|
<Table>
|
||||||
|
<TableHeader>
|
||||||
|
{table.getHeaderGroups().map((headerGroup) => (
|
||||||
|
<TableRow key={headerGroup.id}>
|
||||||
|
{headerGroup.headers.map((header) => (
|
||||||
|
<TableHead key={header.id}>
|
||||||
|
{header.isPlaceholder
|
||||||
|
? null
|
||||||
|
: flexRender(
|
||||||
|
header.column.columnDef.header,
|
||||||
|
header.getContext(),
|
||||||
|
)}
|
||||||
|
</TableHead>
|
||||||
|
))}
|
||||||
|
</TableRow>
|
||||||
|
))}
|
||||||
|
</TableHeader>
|
||||||
|
<TableBody>
|
||||||
|
{table.getRowModel().rows?.length ? (
|
||||||
|
table.getRowModel().rows.map((row) => (
|
||||||
|
<TableRow key={row.id}>
|
||||||
|
{row.getVisibleCells().map((cell) => (
|
||||||
|
<TableCell key={cell.id}>
|
||||||
|
{flexRender(
|
||||||
|
cell.column.columnDef.cell,
|
||||||
|
cell.getContext(),
|
||||||
|
)}
|
||||||
|
</TableCell>
|
||||||
|
))}
|
||||||
|
</TableRow>
|
||||||
|
))
|
||||||
|
) : (
|
||||||
|
<TableRow>
|
||||||
|
<TableCell
|
||||||
|
colSpan={columns.length}
|
||||||
|
className="h-24 text-center text-muted-foreground"
|
||||||
|
>
|
||||||
|
No networks match your filters.
|
||||||
|
</TableCell>
|
||||||
|
</TableRow>
|
||||||
|
)}
|
||||||
|
</TableBody>
|
||||||
|
</Table>
|
||||||
|
</div>
|
||||||
|
{table.getPageCount() > 1 && (
|
||||||
|
<div className="flex items-center justify-end gap-4">
|
||||||
|
<span className="text-sm text-muted-foreground">
|
||||||
|
Page {table.getState().pagination.pageIndex + 1} of{" "}
|
||||||
|
{table.getPageCount()}
|
||||||
|
</span>
|
||||||
|
<div className="flex gap-2">
|
||||||
|
<Button
|
||||||
|
variant="outline"
|
||||||
|
size="sm"
|
||||||
|
onClick={() => table.previousPage()}
|
||||||
|
disabled={!table.getCanPreviousPage()}
|
||||||
|
>
|
||||||
|
Previous
|
||||||
|
</Button>
|
||||||
|
<Button
|
||||||
|
variant="outline"
|
||||||
|
size="sm"
|
||||||
|
onClick={() => table.nextPage()}
|
||||||
|
disabled={!table.getCanNextPage()}
|
||||||
|
>
|
||||||
|
Next
|
||||||
|
</Button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
</>
|
||||||
|
)}
|
||||||
|
</CardContent>
|
||||||
|
</div>
|
||||||
|
</Card>
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
};
|
||||||
249
apps/dokploy/components/dashboard/networks/sync-networks.tsx
Normal file
249
apps/dokploy/components/dashboard/networks/sync-networks.tsx
Normal file
@@ -0,0 +1,249 @@
|
|||||||
|
"use client";
|
||||||
|
|
||||||
|
import { Loader2, RefreshCw, RotateCcw, Trash2 } from "lucide-react";
|
||||||
|
import { useState } from "react";
|
||||||
|
import { toast } from "sonner";
|
||||||
|
import { AlertBlock } from "@/components/shared/alert-block";
|
||||||
|
import { Badge } from "@/components/ui/badge";
|
||||||
|
import { Button } from "@/components/ui/button";
|
||||||
|
import { Checkbox } from "@/components/ui/checkbox";
|
||||||
|
import {
|
||||||
|
Dialog,
|
||||||
|
DialogContent,
|
||||||
|
DialogDescription,
|
||||||
|
DialogFooter,
|
||||||
|
DialogHeader,
|
||||||
|
DialogTitle,
|
||||||
|
DialogTrigger,
|
||||||
|
} from "@/components/ui/dialog";
|
||||||
|
import { Separator } from "@/components/ui/separator";
|
||||||
|
import { api } from "@/utils/api";
|
||||||
|
|
||||||
|
interface Props {
|
||||||
|
serverId?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export const SyncNetworks = ({ serverId }: Props) => {
|
||||||
|
const [open, setOpen] = useState(false);
|
||||||
|
const [selected, setSelected] = useState<Set<string>>(new Set());
|
||||||
|
const utils = api.useUtils();
|
||||||
|
|
||||||
|
const { data, isLoading, error, refetch } =
|
||||||
|
api.network.networksToSync.useQuery({ serverId }, { enabled: open });
|
||||||
|
|
||||||
|
const importMutation = api.network.import.useMutation();
|
||||||
|
const removeMutation = api.network.remove.useMutation();
|
||||||
|
const recreateMutation = api.network.recreate.useMutation();
|
||||||
|
|
||||||
|
const toggleSelected = (name: string) => {
|
||||||
|
setSelected((prev) => {
|
||||||
|
const next = new Set(prev);
|
||||||
|
if (next.has(name)) {
|
||||||
|
next.delete(name);
|
||||||
|
} else {
|
||||||
|
next.add(name);
|
||||||
|
}
|
||||||
|
return next;
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
const onImport = async () => {
|
||||||
|
try {
|
||||||
|
const result = await importMutation.mutateAsync({
|
||||||
|
serverId,
|
||||||
|
names: Array.from(selected),
|
||||||
|
});
|
||||||
|
|
||||||
|
if (result.imported.length > 0) {
|
||||||
|
toast.success(`Imported ${result.imported.length} network(s)`);
|
||||||
|
}
|
||||||
|
for (const failure of result.errors) {
|
||||||
|
toast.error(`Could not import "${failure.name}"`, {
|
||||||
|
description: failure.error,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
setSelected(new Set());
|
||||||
|
await utils.network.all.invalidate();
|
||||||
|
|
||||||
|
setOpen(false);
|
||||||
|
await refetch();
|
||||||
|
} catch (error) {
|
||||||
|
toast.error("Error importing networks", {
|
||||||
|
description: error instanceof Error ? error.message : "Unknown error",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
const onRemoveStale = async (networkId: string, name: string) => {
|
||||||
|
try {
|
||||||
|
await removeMutation.mutateAsync({ networkId });
|
||||||
|
toast.success(`Removed stale record "${name}"`);
|
||||||
|
await utils.network.all.invalidate();
|
||||||
|
await refetch();
|
||||||
|
} catch (error) {
|
||||||
|
toast.error("Error removing record", {
|
||||||
|
description: error instanceof Error ? error.message : "Unknown error",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
const onRecreate = async (networkId: string, name: string) => {
|
||||||
|
try {
|
||||||
|
await recreateMutation.mutateAsync({ networkId });
|
||||||
|
toast.success(`Network "${name}" recreated in Docker`);
|
||||||
|
await utils.network.all.invalidate();
|
||||||
|
await utils.network.networksToSync.invalidate();
|
||||||
|
await refetch();
|
||||||
|
} catch (error) {
|
||||||
|
toast.error("Error recreating network", {
|
||||||
|
description: error instanceof Error ? error.message : "Unknown error",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Dialog
|
||||||
|
open={open}
|
||||||
|
onOpenChange={(value) => {
|
||||||
|
setOpen(value);
|
||||||
|
if (!value) setSelected(new Set());
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
<DialogTrigger asChild>
|
||||||
|
<Button variant="outline">
|
||||||
|
<RefreshCw className="size-4" />
|
||||||
|
Sync
|
||||||
|
</Button>
|
||||||
|
</DialogTrigger>
|
||||||
|
<DialogContent className="sm:max-w-xl max-h-[90vh] overflow-y-auto">
|
||||||
|
<DialogHeader>
|
||||||
|
<DialogTitle className="flex items-center gap-2">
|
||||||
|
<RefreshCw className="size-5 text-muted-foreground" />
|
||||||
|
Sync networks
|
||||||
|
</DialogTitle>
|
||||||
|
<DialogDescription>
|
||||||
|
Import networks that exist in Docker but not in Dokploy, and clean
|
||||||
|
up records whose network no longer exists.
|
||||||
|
</DialogDescription>
|
||||||
|
</DialogHeader>
|
||||||
|
|
||||||
|
{error ? (
|
||||||
|
<AlertBlock type="error">{error.message}</AlertBlock>
|
||||||
|
) : isLoading ? (
|
||||||
|
<div className="flex flex-row gap-2 items-center justify-center py-10 text-sm text-muted-foreground">
|
||||||
|
<span>Scanning Docker networks...</span>
|
||||||
|
<Loader2 className="animate-spin size-4" />
|
||||||
|
</div>
|
||||||
|
) : (
|
||||||
|
<div className="flex flex-col gap-4">
|
||||||
|
<div className="flex flex-col gap-2">
|
||||||
|
<span className="text-sm font-medium">
|
||||||
|
Found in Docker ({data?.importable.length ?? 0})
|
||||||
|
</span>
|
||||||
|
{data?.importable.length ? (
|
||||||
|
data.importable.map((dockerNetwork) => (
|
||||||
|
<label
|
||||||
|
key={dockerNetwork.name}
|
||||||
|
htmlFor={`import-network-${dockerNetwork.name}`}
|
||||||
|
className="flex cursor-pointer items-center justify-between gap-3 rounded-lg border p-3"
|
||||||
|
>
|
||||||
|
<div className="flex items-center gap-3">
|
||||||
|
<Checkbox
|
||||||
|
id={`import-network-${dockerNetwork.name}`}
|
||||||
|
checked={selected.has(dockerNetwork.name)}
|
||||||
|
onCheckedChange={() =>
|
||||||
|
toggleSelected(dockerNetwork.name)
|
||||||
|
}
|
||||||
|
/>
|
||||||
|
<div className="flex flex-col">
|
||||||
|
<span className="text-sm font-medium">
|
||||||
|
{dockerNetwork.name}
|
||||||
|
</span>
|
||||||
|
{dockerNetwork.subnets.length > 0 && (
|
||||||
|
<span className="text-xs text-muted-foreground">
|
||||||
|
{dockerNetwork.subnets.join(" · ")}
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<Badge variant="outline">{dockerNetwork.driver}</Badge>
|
||||||
|
</label>
|
||||||
|
))
|
||||||
|
) : (
|
||||||
|
<span className="text-sm text-muted-foreground">
|
||||||
|
Nothing to import — everything is in sync.
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{!!data?.missing.length && (
|
||||||
|
<>
|
||||||
|
<Separator />
|
||||||
|
<div className="flex flex-col gap-2">
|
||||||
|
<span className="text-sm font-medium">
|
||||||
|
Missing in Docker ({data.missing.length})
|
||||||
|
</span>
|
||||||
|
<span className="text-xs text-muted-foreground">
|
||||||
|
These records exist in Dokploy but their network is gone
|
||||||
|
from Docker.
|
||||||
|
</span>
|
||||||
|
{data.missing.map((stale) => (
|
||||||
|
<div
|
||||||
|
key={stale.networkId}
|
||||||
|
className="flex items-center justify-between gap-3 rounded-lg border border-dashed p-3"
|
||||||
|
>
|
||||||
|
<span className="text-sm">{stale.name}</span>
|
||||||
|
<div className="flex items-center gap-2">
|
||||||
|
<Button
|
||||||
|
variant="outline"
|
||||||
|
size="xs"
|
||||||
|
isLoading={recreateMutation.isPending}
|
||||||
|
onClick={() =>
|
||||||
|
onRecreate(stale.networkId, stale.name)
|
||||||
|
}
|
||||||
|
>
|
||||||
|
<RotateCcw className="size-3.5" />
|
||||||
|
Recreate
|
||||||
|
</Button>
|
||||||
|
<Button
|
||||||
|
variant="ghost"
|
||||||
|
size="icon-sm"
|
||||||
|
aria-label={`Remove stale record ${stale.name}`}
|
||||||
|
isLoading={removeMutation.isPending}
|
||||||
|
onClick={() =>
|
||||||
|
onRemoveStale(stale.networkId, stale.name)
|
||||||
|
}
|
||||||
|
>
|
||||||
|
<Trash2 className="size-4 text-destructive" />
|
||||||
|
</Button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
</>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
|
||||||
|
<DialogFooter>
|
||||||
|
<Button
|
||||||
|
type="button"
|
||||||
|
variant="outline"
|
||||||
|
onClick={() => setOpen(false)}
|
||||||
|
>
|
||||||
|
Close
|
||||||
|
</Button>
|
||||||
|
<Button
|
||||||
|
type="button"
|
||||||
|
disabled={selected.size === 0}
|
||||||
|
isLoading={importMutation.isPending}
|
||||||
|
onClick={onImport}
|
||||||
|
>
|
||||||
|
Import selected ({selected.size})
|
||||||
|
</Button>
|
||||||
|
</DialogFooter>
|
||||||
|
</DialogContent>
|
||||||
|
</Dialog>
|
||||||
|
);
|
||||||
|
};
|
||||||
@@ -25,6 +25,7 @@ import {
|
|||||||
Loader2,
|
Loader2,
|
||||||
LogIn,
|
LogIn,
|
||||||
type LucideIcon,
|
type LucideIcon,
|
||||||
|
Network,
|
||||||
Package,
|
Package,
|
||||||
Palette,
|
Palette,
|
||||||
PieChart,
|
PieChart,
|
||||||
@@ -209,6 +210,20 @@ const MENU: Menu = {
|
|||||||
// Only enabled for users with access to Docker
|
// Only enabled for users with access to Docker
|
||||||
isEnabled: ({ permissions }) => !!permissions?.docker.read,
|
isEnabled: ({ permissions }) => !!permissions?.docker.read,
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
isSingle: true,
|
||||||
|
title: "Networks",
|
||||||
|
url: "/dashboard/networks",
|
||||||
|
icon: Network,
|
||||||
|
// Only enabled for admins and users with access to Docker in non-cloud environments
|
||||||
|
isEnabled: ({ auth, isCloud }) =>
|
||||||
|
!!(
|
||||||
|
(auth?.role === "owner" ||
|
||||||
|
auth?.role === "admin" ||
|
||||||
|
auth?.canAccessToDocker) &&
|
||||||
|
!isCloud
|
||||||
|
),
|
||||||
|
},
|
||||||
{
|
{
|
||||||
isSingle: true,
|
isSingle: true,
|
||||||
title: "Requests",
|
title: "Requests",
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ import type * as React from "react";
|
|||||||
import { cn } from "@/lib/utils";
|
import { cn } from "@/lib/utils";
|
||||||
|
|
||||||
const buttonVariants = cva(
|
const buttonVariants = cva(
|
||||||
"group/button inline-flex shrink-0 items-center justify-center rounded-lg border border-transparent bg-clip-padding text-sm font-medium whitespace-nowrap transition-all outline-none select-none focus-visible:border-ring focus-visible:ring-3 focus-visible:ring-ring/50 active:not-aria-[haspopup]:translate-y-px disabled:pointer-events-none disabled:opacity-50 aria-invalid:border-destructive aria-invalid:ring-3 aria-invalid:ring-destructive/20 dark:aria-invalid:border-destructive/50 dark:aria-invalid:ring-destructive/40 [&_svg]:pointer-events-none [&_svg]:shrink-0 [&_svg:not([class*='size-'])]:size-4",
|
"group/button inline-flex shrink-0 cursor-pointer items-center justify-center rounded-lg border border-transparent bg-clip-padding text-sm font-medium whitespace-nowrap transition-all outline-none select-none focus-visible:border-ring focus-visible:ring-3 focus-visible:ring-ring/50 active:not-aria-[haspopup]:translate-y-px disabled:pointer-events-none disabled:opacity-50 aria-invalid:border-destructive aria-invalid:ring-3 aria-invalid:ring-destructive/20 dark:aria-invalid:border-destructive/50 dark:aria-invalid:ring-destructive/40 [&_svg]:pointer-events-none [&_svg]:shrink-0 [&_svg:not([class*='size-'])]:size-4",
|
||||||
{
|
{
|
||||||
variants: {
|
variants: {
|
||||||
variant: {
|
variant: {
|
||||||
|
|||||||
24
apps/dokploy/drizzle/0175_gray_dreaming_celestial.sql
Normal file
24
apps/dokploy/drizzle/0175_gray_dreaming_celestial.sql
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
CREATE TYPE "public"."networkDriver" AS ENUM('bridge', 'overlay');--> statement-breakpoint
|
||||||
|
CREATE TABLE "network" (
|
||||||
|
"networkId" text PRIMARY KEY NOT NULL,
|
||||||
|
"name" text NOT NULL,
|
||||||
|
"driver" "networkDriver" DEFAULT 'bridge' NOT NULL,
|
||||||
|
"internal" boolean DEFAULT false NOT NULL,
|
||||||
|
"attachable" boolean DEFAULT false NOT NULL,
|
||||||
|
"enableIPv4" boolean DEFAULT true NOT NULL,
|
||||||
|
"enableIPv6" boolean DEFAULT false NOT NULL,
|
||||||
|
"ipam" jsonb DEFAULT '{}'::jsonb,
|
||||||
|
"createdAt" text NOT NULL,
|
||||||
|
"organizationId" text NOT NULL,
|
||||||
|
"serverId" text
|
||||||
|
);
|
||||||
|
--> statement-breakpoint
|
||||||
|
ALTER TABLE "application" ADD COLUMN "networkIds" text[] DEFAULT '{}';--> statement-breakpoint
|
||||||
|
ALTER TABLE "compose" ADD COLUMN "networkIds" text[] DEFAULT '{}';--> statement-breakpoint
|
||||||
|
ALTER TABLE "mariadb" ADD COLUMN "networkIds" text[] DEFAULT '{}';--> statement-breakpoint
|
||||||
|
ALTER TABLE "mongo" ADD COLUMN "networkIds" text[] DEFAULT '{}';--> statement-breakpoint
|
||||||
|
ALTER TABLE "mysql" ADD COLUMN "networkIds" text[] DEFAULT '{}';--> statement-breakpoint
|
||||||
|
ALTER TABLE "postgres" ADD COLUMN "networkIds" text[] DEFAULT '{}';--> statement-breakpoint
|
||||||
|
ALTER TABLE "redis" ADD COLUMN "networkIds" text[] DEFAULT '{}';--> statement-breakpoint
|
||||||
|
ALTER TABLE "network" ADD CONSTRAINT "network_organizationId_organization_id_fk" FOREIGN KEY ("organizationId") REFERENCES "public"."organization"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
|
||||||
|
ALTER TABLE "network" ADD CONSTRAINT "network_serverId_server_serverId_fk" FOREIGN KEY ("serverId") REFERENCES "public"."server"("serverId") ON DELETE cascade ON UPDATE no action;
|
||||||
8721
apps/dokploy/drizzle/meta/0175_snapshot.json
Normal file
8721
apps/dokploy/drizzle/meta/0175_snapshot.json
Normal file
File diff suppressed because it is too large
Load Diff
@@ -1226,6 +1226,13 @@
|
|||||||
"when": 1783674181297,
|
"when": 1783674181297,
|
||||||
"tag": "0174_great_naoko",
|
"tag": "0174_great_naoko",
|
||||||
"breakpoints": true
|
"breakpoints": true
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"idx": 175,
|
||||||
|
"version": "7",
|
||||||
|
"when": 1784692797270,
|
||||||
|
"tag": "0175_gray_dreaming_celestial",
|
||||||
|
"breakpoints": true
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
89
apps/dokploy/pages/dashboard/networks.tsx
Normal file
89
apps/dokploy/pages/dashboard/networks.tsx
Normal file
@@ -0,0 +1,89 @@
|
|||||||
|
import { IS_CLOUD } from "@dokploy/server/constants";
|
||||||
|
import { validateRequest } from "@dokploy/server/lib/auth";
|
||||||
|
import { createServerSideHelpers } from "@trpc/react-query/server";
|
||||||
|
import type { GetServerSidePropsContext } from "next";
|
||||||
|
import type { ReactElement } from "react";
|
||||||
|
import superjson from "superjson";
|
||||||
|
import { ShowNetworks } from "@/components/dashboard/networks/show-networks";
|
||||||
|
import { DashboardLayout } from "@/components/layouts/dashboard-layout";
|
||||||
|
import { ServerFilter } from "@/components/shared/server-filter";
|
||||||
|
import { appRouter } from "@/server/api/root";
|
||||||
|
|
||||||
|
const Dashboard = () => {
|
||||||
|
return (
|
||||||
|
<ServerFilter>
|
||||||
|
{(serverId) => <ShowNetworks serverId={serverId} />}
|
||||||
|
</ServerFilter>
|
||||||
|
);
|
||||||
|
};
|
||||||
|
|
||||||
|
export default Dashboard;
|
||||||
|
|
||||||
|
Dashboard.getLayout = (page: ReactElement) => {
|
||||||
|
return <DashboardLayout>{page}</DashboardLayout>;
|
||||||
|
};
|
||||||
|
|
||||||
|
export async function getServerSideProps(
|
||||||
|
ctx: GetServerSidePropsContext<{ serviceId: string }>,
|
||||||
|
) {
|
||||||
|
if (IS_CLOUD) {
|
||||||
|
return {
|
||||||
|
redirect: {
|
||||||
|
permanent: true,
|
||||||
|
destination: "/dashboard/projects",
|
||||||
|
},
|
||||||
|
};
|
||||||
|
}
|
||||||
|
const { user, session } = await validateRequest(ctx.req);
|
||||||
|
if (!user) {
|
||||||
|
return {
|
||||||
|
redirect: {
|
||||||
|
permanent: true,
|
||||||
|
destination: "/",
|
||||||
|
},
|
||||||
|
};
|
||||||
|
}
|
||||||
|
const { req } = ctx;
|
||||||
|
|
||||||
|
const helpers = createServerSideHelpers({
|
||||||
|
router: appRouter,
|
||||||
|
ctx: {
|
||||||
|
req: req as any,
|
||||||
|
res: ctx.res as any,
|
||||||
|
db: null as any,
|
||||||
|
session: session as any,
|
||||||
|
user: user as any,
|
||||||
|
},
|
||||||
|
transformer: superjson,
|
||||||
|
});
|
||||||
|
try {
|
||||||
|
await helpers.project.all.prefetch();
|
||||||
|
|
||||||
|
if (user.role === "member") {
|
||||||
|
const userR = await helpers.user.one.fetch({
|
||||||
|
userId: user.id,
|
||||||
|
});
|
||||||
|
|
||||||
|
if (!userR?.canAccessToDocker) {
|
||||||
|
return {
|
||||||
|
redirect: {
|
||||||
|
permanent: true,
|
||||||
|
destination: "/",
|
||||||
|
},
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
await helpers.network.all.prefetch({});
|
||||||
|
|
||||||
|
return {
|
||||||
|
props: {
|
||||||
|
trpcState: helpers.dehydrate(),
|
||||||
|
},
|
||||||
|
};
|
||||||
|
} catch {
|
||||||
|
return {
|
||||||
|
props: {},
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -21,6 +21,7 @@ import { mariadbRouter } from "./routers/mariadb";
|
|||||||
import { mongoRouter } from "./routers/mongo";
|
import { mongoRouter } from "./routers/mongo";
|
||||||
import { mountRouter } from "./routers/mount";
|
import { mountRouter } from "./routers/mount";
|
||||||
import { mysqlRouter } from "./routers/mysql";
|
import { mysqlRouter } from "./routers/mysql";
|
||||||
|
import { networkRouter } from "./routers/network";
|
||||||
import { notificationRouter } from "./routers/notification";
|
import { notificationRouter } from "./routers/notification";
|
||||||
import { organizationRouter } from "./routers/organization";
|
import { organizationRouter } from "./routers/organization";
|
||||||
import { patchRouter } from "./routers/patch";
|
import { patchRouter } from "./routers/patch";
|
||||||
@@ -60,6 +61,7 @@ export const appRouter = createTRPCRouter({
|
|||||||
application: applicationRouter,
|
application: applicationRouter,
|
||||||
backup: backupRouter,
|
backup: backupRouter,
|
||||||
bitbucket: bitbucketRouter,
|
bitbucket: bitbucketRouter,
|
||||||
|
network: networkRouter,
|
||||||
certificates: certificateRouter,
|
certificates: certificateRouter,
|
||||||
cluster: clusterRouter,
|
cluster: clusterRouter,
|
||||||
compose: composeRouter,
|
compose: composeRouter,
|
||||||
|
|||||||
117
apps/dokploy/server/api/routers/network.ts
Normal file
117
apps/dokploy/server/api/routers/network.ts
Normal file
@@ -0,0 +1,117 @@
|
|||||||
|
import {
|
||||||
|
createNetwork,
|
||||||
|
findNetworkById,
|
||||||
|
findNetworksToSync,
|
||||||
|
importDockerNetworks,
|
||||||
|
inspectNetwork,
|
||||||
|
recreateNetwork,
|
||||||
|
removeNetwork,
|
||||||
|
} from "@dokploy/server";
|
||||||
|
import { TRPCError } from "@trpc/server";
|
||||||
|
import { and, desc, eq, isNull } from "drizzle-orm";
|
||||||
|
import { z } from "zod";
|
||||||
|
import { createTRPCRouter, protectedProcedure } from "@/server/api/trpc";
|
||||||
|
import { db } from "@/server/db";
|
||||||
|
import {
|
||||||
|
apiCreateNetwork,
|
||||||
|
apiFindOneNetwork,
|
||||||
|
apiRemoveNetwork,
|
||||||
|
network as networkTable,
|
||||||
|
} from "@/server/db/schema";
|
||||||
|
|
||||||
|
export const networkRouter = createTRPCRouter({
|
||||||
|
all: protectedProcedure
|
||||||
|
.input(z.object({ serverId: z.string().optional() }))
|
||||||
|
.query(async ({ ctx, input }) => {
|
||||||
|
const rows = await db.query.network.findMany({
|
||||||
|
where: and(
|
||||||
|
eq(networkTable.organizationId, ctx.session.activeOrganizationId),
|
||||||
|
input.serverId
|
||||||
|
? eq(networkTable.serverId, input.serverId)
|
||||||
|
: isNull(networkTable.serverId),
|
||||||
|
),
|
||||||
|
orderBy: desc(networkTable.createdAt),
|
||||||
|
});
|
||||||
|
return rows;
|
||||||
|
}),
|
||||||
|
|
||||||
|
one: protectedProcedure
|
||||||
|
.input(apiFindOneNetwork)
|
||||||
|
.query(async ({ ctx, input }) => {
|
||||||
|
const row = await findNetworkById(input.networkId);
|
||||||
|
if (row.organizationId !== ctx.session.activeOrganizationId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "NOT_FOUND",
|
||||||
|
message: "Network not found",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
return row;
|
||||||
|
}),
|
||||||
|
create: protectedProcedure
|
||||||
|
.input(apiCreateNetwork)
|
||||||
|
.mutation(async ({ ctx, input }) => {
|
||||||
|
return createNetwork(input, ctx.session.activeOrganizationId);
|
||||||
|
}),
|
||||||
|
networksToSync: protectedProcedure
|
||||||
|
.input(z.object({ serverId: z.string().optional() }))
|
||||||
|
.query(async ({ ctx, input }) => {
|
||||||
|
return findNetworksToSync(
|
||||||
|
ctx.session.activeOrganizationId,
|
||||||
|
input.serverId ?? null,
|
||||||
|
);
|
||||||
|
}),
|
||||||
|
|
||||||
|
import: protectedProcedure
|
||||||
|
.input(
|
||||||
|
z.object({
|
||||||
|
serverId: z.string().optional(),
|
||||||
|
names: z.array(z.string().min(1)).min(1),
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
.mutation(async ({ ctx, input }) => {
|
||||||
|
return importDockerNetworks(
|
||||||
|
ctx.session.activeOrganizationId,
|
||||||
|
input.serverId ?? null,
|
||||||
|
input.names,
|
||||||
|
);
|
||||||
|
}),
|
||||||
|
|
||||||
|
inspect: protectedProcedure
|
||||||
|
.input(apiFindOneNetwork)
|
||||||
|
.query(async ({ ctx, input }) => {
|
||||||
|
const network = await findNetworkById(input.networkId);
|
||||||
|
if (network.organizationId !== ctx.session.activeOrganizationId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "NOT_FOUND",
|
||||||
|
message: "Network not found",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
return inspectNetwork(input.networkId);
|
||||||
|
}),
|
||||||
|
|
||||||
|
recreate: protectedProcedure
|
||||||
|
.input(apiFindOneNetwork)
|
||||||
|
.mutation(async ({ ctx, input }) => {
|
||||||
|
const network = await findNetworkById(input.networkId);
|
||||||
|
if (network.organizationId !== ctx.session.activeOrganizationId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "NOT_FOUND",
|
||||||
|
message: "Network not found",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
return recreateNetwork(input.networkId);
|
||||||
|
}),
|
||||||
|
|
||||||
|
remove: protectedProcedure
|
||||||
|
.input(apiRemoveNetwork)
|
||||||
|
.mutation(async ({ ctx, input }) => {
|
||||||
|
const network = await findNetworkById(input.networkId);
|
||||||
|
if (network.organizationId !== ctx.session.activeOrganizationId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "UNAUTHORIZED",
|
||||||
|
message: "Not authorized to delete this network",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
return removeNetwork(input.networkId);
|
||||||
|
}),
|
||||||
|
});
|
||||||
@@ -8,6 +8,7 @@ import {
|
|||||||
timestamp,
|
timestamp,
|
||||||
} from "drizzle-orm/pg-core";
|
} from "drizzle-orm/pg-core";
|
||||||
import { nanoid } from "nanoid";
|
import { nanoid } from "nanoid";
|
||||||
|
import { network } from "./network";
|
||||||
import { projects } from "./project";
|
import { projects } from "./project";
|
||||||
import { server } from "./server";
|
import { server } from "./server";
|
||||||
import { ssoProvider } from "./sso";
|
import { ssoProvider } from "./sso";
|
||||||
@@ -108,6 +109,7 @@ export const organizationRelations = relations(
|
|||||||
references: [user.id],
|
references: [user.id],
|
||||||
}),
|
}),
|
||||||
servers: many(server),
|
servers: many(server),
|
||||||
|
networks: many(network),
|
||||||
projects: many(projects),
|
projects: many(projects),
|
||||||
members: many(member),
|
members: many(member),
|
||||||
ssoProviders: many(ssoProvider),
|
ssoProviders: many(ssoProvider),
|
||||||
|
|||||||
@@ -233,6 +233,7 @@ export const applications = pgTable("application", {
|
|||||||
onDelete: "set null",
|
onDelete: "set null",
|
||||||
},
|
},
|
||||||
),
|
),
|
||||||
|
networkIds: text("networkIds").array().default([]),
|
||||||
});
|
});
|
||||||
|
|
||||||
export const applicationsRelations = relations(
|
export const applicationsRelations = relations(
|
||||||
@@ -374,6 +375,7 @@ const createSchema = createInsertSchema(applications, {
|
|||||||
previewRequireCollaboratorPermissions: z.boolean().optional(),
|
previewRequireCollaboratorPermissions: z.boolean().optional(),
|
||||||
watchPaths: z.array(z.string()).optional().optional(),
|
watchPaths: z.array(z.string()).optional().optional(),
|
||||||
previewLabels: z.array(z.string()).optional(),
|
previewLabels: z.array(z.string()).optional(),
|
||||||
|
networkIds: z.array(z.string()).optional(),
|
||||||
cleanCache: z.boolean().optional(),
|
cleanCache: z.boolean().optional(),
|
||||||
stopGracePeriodSwarm: z.number().nullable(),
|
stopGracePeriodSwarm: z.number().nullable(),
|
||||||
endpointSpecSwarm: EndpointSpecSwarmSchema.nullable(),
|
endpointSpecSwarm: EndpointSpecSwarmSchema.nullable(),
|
||||||
|
|||||||
@@ -113,6 +113,7 @@ export const compose = pgTable("compose", {
|
|||||||
serverId: text("serverId").references(() => server.serverId, {
|
serverId: text("serverId").references(() => server.serverId, {
|
||||||
onDelete: "cascade",
|
onDelete: "cascade",
|
||||||
}),
|
}),
|
||||||
|
networkIds: text("networkIds").array().default([]),
|
||||||
});
|
});
|
||||||
|
|
||||||
export const composeRelations = relations(compose, ({ one, many }) => ({
|
export const composeRelations = relations(compose, ({ one, many }) => ({
|
||||||
|
|||||||
@@ -19,6 +19,7 @@ export * from "./libsql";
|
|||||||
export * from "./mariadb";
|
export * from "./mariadb";
|
||||||
export * from "./mongo";
|
export * from "./mongo";
|
||||||
export * from "./mount";
|
export * from "./mount";
|
||||||
|
export * from "./network";
|
||||||
export * from "./mysql";
|
export * from "./mysql";
|
||||||
export * from "./notification";
|
export * from "./notification";
|
||||||
export * from "./patch";
|
export * from "./patch";
|
||||||
|
|||||||
@@ -88,6 +88,7 @@ export const mariadb = pgTable("mariadb", {
|
|||||||
serverId: text("serverId").references(() => server.serverId, {
|
serverId: text("serverId").references(() => server.serverId, {
|
||||||
onDelete: "cascade",
|
onDelete: "cascade",
|
||||||
}),
|
}),
|
||||||
|
networkIds: text("networkIds").array().default([]),
|
||||||
});
|
});
|
||||||
|
|
||||||
export const mariadbRelations = relations(mariadb, ({ one, many }) => ({
|
export const mariadbRelations = relations(mariadb, ({ one, many }) => ({
|
||||||
|
|||||||
@@ -92,6 +92,7 @@ export const mongo = pgTable("mongo", {
|
|||||||
onDelete: "cascade",
|
onDelete: "cascade",
|
||||||
}),
|
}),
|
||||||
replicaSets: boolean("replicaSets").default(false),
|
replicaSets: boolean("replicaSets").default(false),
|
||||||
|
networkIds: text("networkIds").array().default([]),
|
||||||
});
|
});
|
||||||
|
|
||||||
export const mongoRelations = relations(mongo, ({ one, many }) => ({
|
export const mongoRelations = relations(mongo, ({ one, many }) => ({
|
||||||
|
|||||||
@@ -86,6 +86,7 @@ export const mysql = pgTable("mysql", {
|
|||||||
serverId: text("serverId").references(() => server.serverId, {
|
serverId: text("serverId").references(() => server.serverId, {
|
||||||
onDelete: "cascade",
|
onDelete: "cascade",
|
||||||
}),
|
}),
|
||||||
|
networkIds: text("networkIds").array().default([]),
|
||||||
});
|
});
|
||||||
|
|
||||||
export const mysqlRelations = relations(mysql, ({ one, many }) => ({
|
export const mysqlRelations = relations(mysql, ({ one, many }) => ({
|
||||||
|
|||||||
136
packages/server/src/db/schema/network.ts
Normal file
136
packages/server/src/db/schema/network.ts
Normal file
@@ -0,0 +1,136 @@
|
|||||||
|
import { relations } from "drizzle-orm";
|
||||||
|
import { boolean, jsonb, pgEnum, pgTable, text } from "drizzle-orm/pg-core";
|
||||||
|
import { createInsertSchema } from "drizzle-zod";
|
||||||
|
import { nanoid } from "nanoid";
|
||||||
|
import { z } from "zod";
|
||||||
|
import { organization } from "./account";
|
||||||
|
import { server } from "./server";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Docker network driver types. Only bridge and overlay are supported:
|
||||||
|
* "host"/"none" are Docker singletons that cannot be created, and
|
||||||
|
* macvlan/ipvlan require driver options (parent interface) we don't expose.
|
||||||
|
* Scope is derived from the driver (bridge = local, overlay = swarm), and
|
||||||
|
* ingress/config-only networks are not manageable from Dokploy.
|
||||||
|
*/
|
||||||
|
export const networkDriver = pgEnum("networkDriver", ["bridge", "overlay"]);
|
||||||
|
|
||||||
|
export const network = pgTable("network", {
|
||||||
|
networkId: text("networkId")
|
||||||
|
.notNull()
|
||||||
|
.primaryKey()
|
||||||
|
.$defaultFn(() => nanoid()),
|
||||||
|
name: text("name").notNull(),
|
||||||
|
driver: networkDriver("driver").notNull().default("bridge"),
|
||||||
|
internal: boolean("internal").notNull().default(false),
|
||||||
|
attachable: boolean("attachable").notNull().default(false),
|
||||||
|
enableIPv4: boolean("enableIPv4").notNull().default(true),
|
||||||
|
enableIPv6: boolean("enableIPv6").notNull().default(false),
|
||||||
|
ipam: jsonb("ipam")
|
||||||
|
.$type<{
|
||||||
|
driver?: string;
|
||||||
|
config?: Array<{ subnet?: string; gateway?: string; ipRange?: string }>;
|
||||||
|
}>()
|
||||||
|
.default({}),
|
||||||
|
createdAt: text("createdAt")
|
||||||
|
.notNull()
|
||||||
|
.$defaultFn(() => new Date().toISOString()),
|
||||||
|
organizationId: text("organizationId")
|
||||||
|
.notNull()
|
||||||
|
.references(() => organization.id, { onDelete: "cascade" }),
|
||||||
|
serverId: text("serverId").references(() => server.serverId, {
|
||||||
|
onDelete: "cascade",
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
|
||||||
|
export const networkRelations = relations(network, ({ one }) => ({
|
||||||
|
organization: one(organization, {
|
||||||
|
fields: [network.organizationId],
|
||||||
|
references: [organization.id],
|
||||||
|
}),
|
||||||
|
server: one(server, {
|
||||||
|
fields: [network.serverId],
|
||||||
|
references: [server.serverId],
|
||||||
|
}),
|
||||||
|
}));
|
||||||
|
|
||||||
|
const createSchema = createInsertSchema(network, {
|
||||||
|
networkId: z.string().min(1),
|
||||||
|
name: z.string().min(1),
|
||||||
|
driver: z.enum(["bridge", "overlay"]).optional(),
|
||||||
|
internal: z.boolean().optional(),
|
||||||
|
attachable: z.boolean().optional(),
|
||||||
|
enableIPv4: z.boolean().optional(),
|
||||||
|
enableIPv6: z.boolean().optional(),
|
||||||
|
ipam: z
|
||||||
|
.object({
|
||||||
|
driver: z.string().optional(),
|
||||||
|
config: z
|
||||||
|
.array(
|
||||||
|
z.object({
|
||||||
|
subnet: z.string().optional(),
|
||||||
|
gateway: z.string().optional(),
|
||||||
|
ipRange: z.string().optional(),
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
.optional(),
|
||||||
|
})
|
||||||
|
.optional(),
|
||||||
|
organizationId: z.string().min(1),
|
||||||
|
serverId: z.string().optional().nullable(),
|
||||||
|
});
|
||||||
|
|
||||||
|
const validateNetworkInput = (
|
||||||
|
input: {
|
||||||
|
enableIPv4?: boolean;
|
||||||
|
enableIPv6?: boolean;
|
||||||
|
ipam?: {
|
||||||
|
config?: Array<{ subnet?: string; gateway?: string; ipRange?: string }>;
|
||||||
|
} | null;
|
||||||
|
},
|
||||||
|
ctx: z.RefinementCtx,
|
||||||
|
) => {
|
||||||
|
if (input.enableIPv4 === false && input.enableIPv6 !== true) {
|
||||||
|
ctx.addIssue({
|
||||||
|
code: z.ZodIssueCode.custom,
|
||||||
|
path: ["enableIPv4"],
|
||||||
|
message: "IPv4 or IPv6 must be enabled",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
for (const [index, entry] of (input.ipam?.config ?? []).entries()) {
|
||||||
|
if (!entry.subnet && (entry.gateway || entry.ipRange)) {
|
||||||
|
ctx.addIssue({
|
||||||
|
code: z.ZodIssueCode.custom,
|
||||||
|
path: ["ipam", "config", index, "subnet"],
|
||||||
|
message: "Gateway and IP range require a subnet",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const apiCreateNetwork = createSchema
|
||||||
|
.pick({
|
||||||
|
name: true,
|
||||||
|
driver: true,
|
||||||
|
internal: true,
|
||||||
|
attachable: true,
|
||||||
|
enableIPv4: true,
|
||||||
|
enableIPv6: true,
|
||||||
|
ipam: true,
|
||||||
|
serverId: true,
|
||||||
|
})
|
||||||
|
.partial()
|
||||||
|
.required({ name: true })
|
||||||
|
.superRefine(validateNetworkInput);
|
||||||
|
|
||||||
|
export const apiFindOneNetwork = createSchema
|
||||||
|
.pick({
|
||||||
|
networkId: true,
|
||||||
|
})
|
||||||
|
.required();
|
||||||
|
|
||||||
|
export const apiRemoveNetwork = createSchema
|
||||||
|
.pick({
|
||||||
|
networkId: true,
|
||||||
|
})
|
||||||
|
.required();
|
||||||
@@ -86,6 +86,7 @@ export const postgres = pgTable("postgres", {
|
|||||||
serverId: text("serverId").references(() => server.serverId, {
|
serverId: text("serverId").references(() => server.serverId, {
|
||||||
onDelete: "cascade",
|
onDelete: "cascade",
|
||||||
}),
|
}),
|
||||||
|
networkIds: text("networkIds").array().default([]),
|
||||||
});
|
});
|
||||||
|
|
||||||
export const postgresRelations = relations(postgres, ({ one, many }) => ({
|
export const postgresRelations = relations(postgres, ({ one, many }) => ({
|
||||||
|
|||||||
@@ -80,6 +80,7 @@ export const redis = pgTable("redis", {
|
|||||||
serverId: text("serverId").references(() => server.serverId, {
|
serverId: text("serverId").references(() => server.serverId, {
|
||||||
onDelete: "cascade",
|
onDelete: "cascade",
|
||||||
}),
|
}),
|
||||||
|
networkIds: text("networkIds").array().default([]),
|
||||||
});
|
});
|
||||||
|
|
||||||
export const redisRelations = relations(redis, ({ one, many }) => ({
|
export const redisRelations = relations(redis, ({ one, many }) => ({
|
||||||
|
|||||||
@@ -19,6 +19,7 @@ import { libsql } from "./libsql";
|
|||||||
import { mariadb } from "./mariadb";
|
import { mariadb } from "./mariadb";
|
||||||
import { mongo } from "./mongo";
|
import { mongo } from "./mongo";
|
||||||
import { mysql } from "./mysql";
|
import { mysql } from "./mysql";
|
||||||
|
import { network } from "./network";
|
||||||
import { postgres } from "./postgres";
|
import { postgres } from "./postgres";
|
||||||
import { redis } from "./redis";
|
import { redis } from "./redis";
|
||||||
import { schedules } from "./schedule";
|
import { schedules } from "./schedule";
|
||||||
@@ -125,6 +126,7 @@ export const serverRelations = relations(server, ({ one, many }) => ({
|
|||||||
mysql: many(mysql),
|
mysql: many(mysql),
|
||||||
postgres: many(postgres),
|
postgres: many(postgres),
|
||||||
certificates: many(certificates),
|
certificates: many(certificates),
|
||||||
|
networks: many(network),
|
||||||
organization: one(organization, {
|
organization: one(organization, {
|
||||||
fields: [server.organizationId],
|
fields: [server.organizationId],
|
||||||
references: [organization.id],
|
references: [organization.id],
|
||||||
|
|||||||
@@ -28,6 +28,7 @@ export * from "./services/mariadb";
|
|||||||
export * from "./services/mongo";
|
export * from "./services/mongo";
|
||||||
export * from "./services/mount";
|
export * from "./services/mount";
|
||||||
export * from "./services/mysql";
|
export * from "./services/mysql";
|
||||||
|
export * from "./services/network";
|
||||||
export * from "./services/notification";
|
export * from "./services/notification";
|
||||||
export * from "./services/patch";
|
export * from "./services/patch";
|
||||||
export * from "./services/patch-repo";
|
export * from "./services/patch-repo";
|
||||||
|
|||||||
337
packages/server/src/services/network.ts
Normal file
337
packages/server/src/services/network.ts
Normal file
@@ -0,0 +1,337 @@
|
|||||||
|
import { db } from "@dokploy/server/db";
|
||||||
|
import { type apiCreateNetwork, network } from "@dokploy/server/db/schema";
|
||||||
|
import { TRPCError } from "@trpc/server";
|
||||||
|
import { and, eq, isNull } from "drizzle-orm";
|
||||||
|
import type { z } from "zod";
|
||||||
|
import { IS_CLOUD } from "../constants";
|
||||||
|
import { getRemoteDocker } from "../utils/servers/remote-docker";
|
||||||
|
|
||||||
|
// Networks managed by Docker/Dokploy itself that must never be imported
|
||||||
|
// or deleted through the networks UI
|
||||||
|
const RESERVED_NETWORKS = [
|
||||||
|
"bridge",
|
||||||
|
"host",
|
||||||
|
"none",
|
||||||
|
"ingress",
|
||||||
|
"docker_gwbridge",
|
||||||
|
"dokploy-network",
|
||||||
|
];
|
||||||
|
|
||||||
|
type DockerNetworkInfo = {
|
||||||
|
Name: string;
|
||||||
|
Driver: string;
|
||||||
|
Internal?: boolean;
|
||||||
|
Attachable?: boolean;
|
||||||
|
Ingress?: boolean;
|
||||||
|
EnableIPv4?: boolean;
|
||||||
|
EnableIPv6?: boolean;
|
||||||
|
IPAM?: {
|
||||||
|
Driver?: string;
|
||||||
|
Config?: Array<{
|
||||||
|
Subnet?: string;
|
||||||
|
Gateway?: string;
|
||||||
|
IPRange?: string;
|
||||||
|
}> | null;
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
const isImportableDockerNetwork = (dockerNetwork: DockerNetworkInfo) =>
|
||||||
|
!RESERVED_NETWORKS.includes(dockerNetwork.Name) &&
|
||||||
|
!dockerNetwork.Ingress &&
|
||||||
|
(dockerNetwork.Driver === "bridge" || dockerNetwork.Driver === "overlay");
|
||||||
|
|
||||||
|
const mapDockerNetworkToRow = (
|
||||||
|
dockerNetwork: DockerNetworkInfo,
|
||||||
|
organizationId: string,
|
||||||
|
serverId: string | null,
|
||||||
|
) => ({
|
||||||
|
name: dockerNetwork.Name,
|
||||||
|
driver: dockerNetwork.Driver as "bridge" | "overlay",
|
||||||
|
internal: dockerNetwork.Internal ?? false,
|
||||||
|
attachable: dockerNetwork.Attachable ?? false,
|
||||||
|
// Older daemons don't report EnableIPv4; IPv4 is always on there
|
||||||
|
enableIPv4: dockerNetwork.EnableIPv4 ?? true,
|
||||||
|
enableIPv6: dockerNetwork.EnableIPv6 ?? false,
|
||||||
|
ipam: {
|
||||||
|
driver: dockerNetwork.IPAM?.Driver,
|
||||||
|
config: (dockerNetwork.IPAM?.Config ?? []).map((c) => ({
|
||||||
|
subnet: c.Subnet,
|
||||||
|
gateway: c.Gateway,
|
||||||
|
ipRange: c.IPRange,
|
||||||
|
})),
|
||||||
|
},
|
||||||
|
organizationId,
|
||||||
|
serverId,
|
||||||
|
});
|
||||||
|
|
||||||
|
const findNetworksByServer = async (
|
||||||
|
organizationId: string,
|
||||||
|
serverId: string | null,
|
||||||
|
) => {
|
||||||
|
return await db.query.network.findMany({
|
||||||
|
where: and(
|
||||||
|
eq(network.organizationId, organizationId),
|
||||||
|
serverId ? eq(network.serverId, serverId) : isNull(network.serverId),
|
||||||
|
),
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
export const findNetworksToSync = async (
|
||||||
|
organizationId: string,
|
||||||
|
serverId: string | null,
|
||||||
|
) => {
|
||||||
|
if (IS_CLOUD && !serverId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "BAD_REQUEST",
|
||||||
|
message: "Server is required",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const docker = await getRemoteDocker(serverId);
|
||||||
|
let dockerNetworks: DockerNetworkInfo[] = [];
|
||||||
|
try {
|
||||||
|
dockerNetworks = (await docker.listNetworks()) as DockerNetworkInfo[];
|
||||||
|
} catch (error) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "BAD_REQUEST",
|
||||||
|
message:
|
||||||
|
error instanceof Error
|
||||||
|
? error.message
|
||||||
|
: "Failed to list Docker networks",
|
||||||
|
cause: error,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const existing = await findNetworksByServer(organizationId, serverId);
|
||||||
|
const existingNames = new Set(existing.map((row) => row.name));
|
||||||
|
const dockerNames = new Set(dockerNetworks.map((d) => d.Name));
|
||||||
|
|
||||||
|
const importable = dockerNetworks
|
||||||
|
.filter(
|
||||||
|
(dockerNetwork) =>
|
||||||
|
isImportableDockerNetwork(dockerNetwork) &&
|
||||||
|
!existingNames.has(dockerNetwork.Name),
|
||||||
|
)
|
||||||
|
.map((dockerNetwork) => ({
|
||||||
|
name: dockerNetwork.Name,
|
||||||
|
driver: dockerNetwork.Driver,
|
||||||
|
internal: dockerNetwork.Internal ?? false,
|
||||||
|
attachable: dockerNetwork.Attachable ?? false,
|
||||||
|
subnets: (dockerNetwork.IPAM?.Config ?? [])
|
||||||
|
.map((c) => c.Subnet)
|
||||||
|
.filter((s): s is string => !!s),
|
||||||
|
}));
|
||||||
|
|
||||||
|
// Rows in Dokploy whose network no longer exists in Docker
|
||||||
|
const missing = existing
|
||||||
|
.filter((row) => !dockerNames.has(row.name))
|
||||||
|
.map((row) => ({ networkId: row.networkId, name: row.name }));
|
||||||
|
|
||||||
|
return { importable, missing };
|
||||||
|
};
|
||||||
|
|
||||||
|
export const importDockerNetworks = async (
|
||||||
|
organizationId: string,
|
||||||
|
serverId: string | null,
|
||||||
|
names: string[],
|
||||||
|
) => {
|
||||||
|
if (IS_CLOUD && !serverId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "BAD_REQUEST",
|
||||||
|
message: "Server is required",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const docker = await getRemoteDocker(serverId);
|
||||||
|
const existing = await findNetworksByServer(organizationId, serverId);
|
||||||
|
const existingNames = new Set(existing.map((row) => row.name));
|
||||||
|
|
||||||
|
const imported: string[] = [];
|
||||||
|
const errors: { name: string; error: string }[] = [];
|
||||||
|
|
||||||
|
for (const name of names) {
|
||||||
|
if (existingNames.has(name)) {
|
||||||
|
errors.push({ name, error: "Already imported" });
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
try {
|
||||||
|
const info = (await docker
|
||||||
|
.getNetwork(name)
|
||||||
|
.inspect()) as DockerNetworkInfo;
|
||||||
|
if (!isImportableDockerNetwork(info)) {
|
||||||
|
errors.push({ name, error: "Network is reserved or not supported" });
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
await db
|
||||||
|
.insert(network)
|
||||||
|
.values(mapDockerNetworkToRow(info, organizationId, serverId));
|
||||||
|
imported.push(name);
|
||||||
|
} catch (error) {
|
||||||
|
errors.push({
|
||||||
|
name,
|
||||||
|
error:
|
||||||
|
error instanceof Error ? error.message : "Failed to inspect network",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return { imported, errors };
|
||||||
|
};
|
||||||
|
|
||||||
|
export const findNetworkById = async (networkId: string) => {
|
||||||
|
const [row] = await db
|
||||||
|
.select()
|
||||||
|
.from(network)
|
||||||
|
.where(eq(network.networkId, networkId))
|
||||||
|
.limit(1);
|
||||||
|
|
||||||
|
if (!row) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "NOT_FOUND",
|
||||||
|
message: "Network not found",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
return row;
|
||||||
|
};
|
||||||
|
|
||||||
|
export const createNetwork = async (
|
||||||
|
input: z.infer<typeof apiCreateNetwork>,
|
||||||
|
organizationId: string,
|
||||||
|
) => {
|
||||||
|
if (IS_CLOUD) {
|
||||||
|
if (!input.serverId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "BAD_REQUEST",
|
||||||
|
message: "Server is required",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const created = await db.transaction(async (tx) => {
|
||||||
|
const [row] = await tx
|
||||||
|
.insert(network)
|
||||||
|
.values({
|
||||||
|
...input,
|
||||||
|
organizationId,
|
||||||
|
})
|
||||||
|
.returning();
|
||||||
|
|
||||||
|
if (!row) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "INTERNAL_SERVER_ERROR",
|
||||||
|
message: "Failed to create network",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
await createDockerNetworkFromRow(row);
|
||||||
|
|
||||||
|
return row;
|
||||||
|
});
|
||||||
|
|
||||||
|
return created;
|
||||||
|
};
|
||||||
|
|
||||||
|
const createDockerNetworkFromRow = async (row: typeof network.$inferSelect) => {
|
||||||
|
const ipam = row.ipam ?? {};
|
||||||
|
const ipamConfig = (ipam.config ?? [])
|
||||||
|
.map((c) => {
|
||||||
|
const entry: Record<string, string> = {};
|
||||||
|
if (c.subnet) entry.Subnet = c.subnet;
|
||||||
|
if (c.gateway) entry.Gateway = c.gateway;
|
||||||
|
if (c.ipRange) entry.IPRange = c.ipRange;
|
||||||
|
return entry;
|
||||||
|
})
|
||||||
|
.filter((e) => Object.keys(e).length > 0);
|
||||||
|
|
||||||
|
const docker = await getRemoteDocker(row.serverId ?? null);
|
||||||
|
try {
|
||||||
|
await docker.createNetwork({
|
||||||
|
Name: row.name,
|
||||||
|
Driver: row.driver,
|
||||||
|
CheckDuplicate: true,
|
||||||
|
Internal: row.internal,
|
||||||
|
Attachable: row.attachable,
|
||||||
|
// EnableIPv4 is missing from dockerode's types but supported by
|
||||||
|
// the daemon (API >= 1.47); the body is sent as-is
|
||||||
|
EnableIPv4: row.enableIPv4,
|
||||||
|
EnableIPv6: row.enableIPv6,
|
||||||
|
IPAM: {
|
||||||
|
Driver: ipam.driver || "default",
|
||||||
|
Config: ipamConfig.length > 0 ? ipamConfig : undefined,
|
||||||
|
},
|
||||||
|
} as Parameters<typeof docker.createNetwork>[0]);
|
||||||
|
} catch (error) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "BAD_REQUEST",
|
||||||
|
message:
|
||||||
|
error instanceof Error
|
||||||
|
? error.message
|
||||||
|
: "Failed to create Docker network",
|
||||||
|
cause: error,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// Re-creates the Docker network from the stored record, for records whose
|
||||||
|
// network was removed from Docker outside of Dokploy
|
||||||
|
export const recreateNetwork = async (networkId: string) => {
|
||||||
|
const row = await findNetworkById(networkId);
|
||||||
|
await createDockerNetworkFromRow(row);
|
||||||
|
return row;
|
||||||
|
};
|
||||||
|
|
||||||
|
export const inspectNetwork = async (networkId: string) => {
|
||||||
|
const row = await findNetworkById(networkId);
|
||||||
|
|
||||||
|
const docker = await getRemoteDocker(row.serverId ?? null);
|
||||||
|
try {
|
||||||
|
return await docker.getNetwork(row.name).inspect();
|
||||||
|
} catch (error) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "BAD_REQUEST",
|
||||||
|
message:
|
||||||
|
error instanceof Error
|
||||||
|
? error.message
|
||||||
|
: "Failed to inspect Docker network",
|
||||||
|
cause: error,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// Docker networks are immutable: there is no update, only create and remove.
|
||||||
|
export const removeNetwork = async (networkId: string) => {
|
||||||
|
const row = await findNetworkById(networkId);
|
||||||
|
|
||||||
|
const docker = await getRemoteDocker(row.serverId ?? null);
|
||||||
|
try {
|
||||||
|
await docker.getNetwork(row.name).remove();
|
||||||
|
} catch (error) {
|
||||||
|
// If the network is already gone from Docker, still clean up the DB row
|
||||||
|
const statusCode = (error as { statusCode?: number })?.statusCode;
|
||||||
|
if (statusCode !== 404) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "BAD_REQUEST",
|
||||||
|
message:
|
||||||
|
error instanceof Error
|
||||||
|
? error.message
|
||||||
|
: "Failed to remove Docker network",
|
||||||
|
cause: error,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const [deleted] = await db
|
||||||
|
.delete(network)
|
||||||
|
.where(eq(network.networkId, networkId))
|
||||||
|
.returning();
|
||||||
|
|
||||||
|
if (!deleted) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: "NOT_FOUND",
|
||||||
|
message: "Network not found",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
return deleted;
|
||||||
|
};
|
||||||
Reference in New Issue
Block a user