img:first-child]:pt-0 data-[size=sm]:[--card-spacing:--spacing(4)] dark:ring-foreground/10 *:[img:first-child]:rounded-t-[min(var(--radius-4xl),24px)] *:[img:last-child]:rounded-b-[min(var(--radius-4xl),24px)]",
+ className
+ )}
+ {...props}
+ />
+ )
+}
+
+function CardHeader({ className, ...props }: React.ComponentProps<"div">) {
+ return (
+
+ )
+}
+
+function CardTitle({ className, ...props }: React.ComponentProps<"div">) {
+ return (
+
+ )
+}
+
+function CardDescription({ className, ...props }: React.ComponentProps<"div">) {
+ return (
+
+ )
+}
+
+function CardAction({ className, ...props }: React.ComponentProps<"div">) {
+ return (
+
+ )
+}
+
+function CardContent({ className, ...props }: React.ComponentProps<"div">) {
+ return (
+
+ )
+}
+
+function CardFooter({ className, ...props }: React.ComponentProps<"div">) {
+ return (
+
+ )
+}
+
+export {
+ Card,
+ CardHeader,
+ CardFooter,
+ CardTitle,
+ CardAction,
+ CardDescription,
+ CardContent,
+}
diff --git a/src/frontend/src/lib/shadcn/components/ui/input.tsx b/src/frontend/src/lib/shadcn/components/ui/input.tsx
new file mode 100644
index 0000000..3d4f4f0
--- /dev/null
+++ b/src/frontend/src/lib/shadcn/components/ui/input.tsx
@@ -0,0 +1,29 @@
+import * as React from "react"
+import {
+ composeRenderProps,
+ Input as InputPrimitive,
+} from "react-aria-components"
+
+import { cn } from "@shadcn/lib/utils"
+
+function Input({
+ className,
+ type,
+ ...props
+}: React.ComponentProps
) {
+ return (
+
+ cn(
+ "h-8 w-full min-w-0 rounded-2xl border border-transparent bg-input/50 px-2.5 py-1 text-base transition-[color,box-shadow] duration-200 outline-none file:inline-flex file:h-6 file:border-0 file:bg-transparent file:text-sm file:font-medium file:text-foreground placeholder:text-muted-foreground focus-visible:border-ring focus-visible:ring-3 focus-visible:ring-ring/30 disabled:pointer-events-none disabled:cursor-not-allowed disabled:opacity-50 aria-invalid:border-destructive aria-invalid:ring-3 aria-invalid:ring-destructive/20 md:text-sm dark:aria-invalid:border-destructive/50 dark:aria-invalid:ring-destructive/40",
+ className
+ )
+ )}
+ {...props}
+ />
+ )
+}
+
+export { Input }
diff --git a/src/frontend/src/lib/shadcn/components/ui/tabs.tsx b/src/frontend/src/lib/shadcn/components/ui/tabs.tsx
new file mode 100644
index 0000000..b689597
--- /dev/null
+++ b/src/frontend/src/lib/shadcn/components/ui/tabs.tsx
@@ -0,0 +1,91 @@
+import * as React from "react"
+import { cva, type VariantProps } from "class-variance-authority"
+import {
+ TabList as TabListPrimitive,
+ TabPanel as TabPanelPrimitive,
+ Tab as TabPrimitive,
+ Tabs as TabsPrimitive,
+} from "react-aria-components"
+
+import { cn } from "@shadcn/lib/utils"
+
+function Tabs({
+ className,
+ ...props
+}: React.ComponentProps) {
+ return (
+
+ )
+}
+
+const tabsListVariants = cva(
+ "group/tabs-list inline-flex w-fit items-center justify-center rounded-2xl p-[3px] text-muted-foreground group-data-horizontal/tabs:h-8 group-data-vertical/tabs:h-fit group-data-vertical/tabs:flex-col group-data-vertical/tabs:p-1 data-[variant=line]:rounded-none",
+ {
+ variants: {
+ variant: {
+ default: "bg-muted",
+ line: "gap-1 bg-transparent",
+ },
+ },
+ defaultVariants: {
+ variant: "default",
+ },
+ }
+)
+
+function TabsList({
+ className,
+ variant = "default",
+ ...props
+}: React.ComponentProps &
+ VariantProps) {
+ return (
+
+ )
+}
+
+function TabsTrigger({
+ className,
+ ...props
+}: React.ComponentProps) {
+ return (
+
+ )
+}
+
+function TabsContent({
+ className,
+ ...props
+}: React.ComponentProps) {
+ return (
+
+ )
+}
+
+export { Tabs, TabsList, TabsTrigger, TabsContent, tabsListVariants }
diff --git a/src/frontend/src/lib/shadcn/lib/utils.ts b/src/frontend/src/lib/shadcn/lib/utils.ts
new file mode 100644
index 0000000..bd0c391
--- /dev/null
+++ b/src/frontend/src/lib/shadcn/lib/utils.ts
@@ -0,0 +1,6 @@
+import { clsx, type ClassValue } from "clsx"
+import { twMerge } from "tailwind-merge"
+
+export function cn(...inputs: ClassValue[]) {
+ return twMerge(clsx(inputs))
+}
diff --git a/src/frontend/src/lib/types.ts b/src/frontend/src/lib/types.ts
new file mode 100644
index 0000000..571147a
--- /dev/null
+++ b/src/frontend/src/lib/types.ts
@@ -0,0 +1,70 @@
+export interface PortMapping {
+ host: number;
+ guest: number;
+}
+
+export interface NetworkConfig {
+ name: string;
+ mode: "bridge" | "host" | "none" | "overlay" | "ipvlan" | "macvlan" | string;
+ ports: PortMapping[];
+}
+
+export interface RegistryItem {
+ name: string
+ version: string
+ image?: string
+ source?: string
+ title?: string
+ vendor?: string
+ author?: string
+ description?: string
+ created_at?: string
+
+ // Runtime properties
+ id?: string;
+ status?: string;
+ origin?: ContainerOrigin;
+ remoteSource?: string;
+ latestVersion?: string;
+ hasUpdate?: boolean;
+}
+
+export const STATUS_PRIORITY: Record = {
+ running: 3,
+ restarting: 2,
+ starting: 2,
+ stopped: 1,
+ exited: 1,
+}
+
+// --- SINGLE UNIFIED CONTAINER TYPE ---
+
+export type ContainerOrigin = 'local' | 'remote' | 'both';
+
+export interface Container {
+ id: string;
+ name: string;
+ // Status can be from Docker ("running", "stopped") or our UI ("uninstalled")
+ status: string;
+
+ // Origin tracking (populated by our App logic during merge)
+ origin?: ContainerOrigin;
+
+ // Fields populated by local Docker Daemon
+ docker_name?: string;
+ image?: string;
+ network?: {
+ name: string;
+ mode: "bridge" | "host" | "none" | "overlay" | "ipvlan" | "macvlan" | string;
+ ports: Array<{ host: number, guest: number }>;
+ };
+
+ // Fields populated by remote Git Registry
+ source?: string;
+ version?: string;
+
+ // Optional properties for update state
+ remoteSource?: string;
+ latestVersion?: string;
+ hasUpdate?: boolean;
+}
\ No newline at end of file
diff --git a/src/frontend/src/lib/ws/client.ts b/src/frontend/src/lib/ws/client.ts
new file mode 100644
index 0000000..356b079
--- /dev/null
+++ b/src/frontend/src/lib/ws/client.ts
@@ -0,0 +1,48 @@
+import { registry } from "./registry";
+import { type Container } from "../types";
+
+const HOST = "127.0.0.1";
+const PORT = "8080";
+const PATH = "api/ws";
+const URL = `ws://${HOST}:${PORT}/${PATH}`;
+
+let socket: WebSocket | null = null;
+
+export function connectWebSocket(): void {
+ if (socket && (socket.readyState === WebSocket.OPEN || socket.readyState === WebSocket.CONNECTING)) {
+ return;
+ }
+
+ socket = new WebSocket(URL);
+ registry.setStatus("connecting");
+
+ socket.onopen = () => {
+ console.log("[WS] Connected");
+ registry.setStatus("open");
+ };
+
+ socket.onmessage = (event: MessageEvent) => {
+ try {
+ // Parses into the unified type (missing fields will safely be undefined)
+ const containers: Array = JSON.parse(event.data)
+ registry.setContainers(containers);
+ } catch (err) {
+ console.error("[WS] Failed to parse message payload:", err);
+ }
+ };
+
+ socket.onclose = () => {
+ console.warn("[WS] Closed");
+ registry.setStatus("closed");
+ setTimeout(connectWebSocket, 3000);
+ };
+
+ socket.onerror = (err) => {
+ console.error("[WS] Error", err);
+ socket?.close();
+ };
+}
+
+export function isConnected(): boolean {
+ return socket !== null && socket.readyState === WebSocket.OPEN;
+}
\ No newline at end of file
diff --git a/src/frontend/src/lib/ws/registry.ts b/src/frontend/src/lib/ws/registry.ts
new file mode 100644
index 0000000..4da74a2
--- /dev/null
+++ b/src/frontend/src/lib/ws/registry.ts
@@ -0,0 +1,51 @@
+import { type Container } from "../types";
+
+export type ConnectionStatus = "connecting" | "open" | "closing" | "closed";
+
+type Listener = () => void;
+
+class ContainerRegistry {
+ private containers: Container[] = [];
+ private status: ConnectionStatus = "closed";
+ private listeners: Set = new Set();
+
+ private state = {
+ containers: this.containers,
+ status: this.status,
+ };
+
+ public getState = () => {
+ return this.state;
+ };
+
+ public setContainers(nextContainers: Container[]) {
+ this.containers = nextContainers;
+ this.updateSnapshot();
+ }
+
+ public setStatus(nextStatus: ConnectionStatus) {
+ this.status = nextStatus;
+ this.updateSnapshot();
+ }
+
+ private updateSnapshot() {
+ this.state = {
+ containers: this.containers,
+ status: this.status,
+ };
+ this.notify();
+ }
+
+ public subscribe = (listener: Listener): () => void => {
+ this.listeners.add(listener);
+ return () => this.listeners.delete(listener);
+ };
+
+ private notify() {
+ for (const listener of this.listeners) {
+ listener();
+ }
+ }
+}
+
+export const registry = new ContainerRegistry();
\ No newline at end of file
diff --git a/src/frontend/src/main.tsx b/src/frontend/src/main.tsx
new file mode 100644
index 0000000..100a9c0
--- /dev/null
+++ b/src/frontend/src/main.tsx
@@ -0,0 +1,5 @@
+import { render } from 'preact'
+import './index.css'
+import { App } from './app.tsx'
+
+render(, document.querySelector("body")!)
diff --git a/src/frontend/tsconfig.app.json b/src/frontend/tsconfig.app.json
new file mode 100644
index 0000000..98dfe85
--- /dev/null
+++ b/src/frontend/tsconfig.app.json
@@ -0,0 +1,35 @@
+{
+ "compilerOptions": {
+ "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.app.tsbuildinfo",
+ "target": "es2023",
+ "module": "esnext",
+ "lib": ["ES2023", "DOM"],
+ "types": ["vite/client"],
+ "allowArbitraryExtensions": true,
+ "skipLibCheck": true,
+ "paths": {
+ "react": ["./node_modules/preact/compat/"],
+ "react-dom": ["./node_modules/preact/compat/"],
+ "react/jsx-runtime": ["./node_modules/preact/jsx-runtime"],
+ "react/jsx-dev-runtime": ["./node_modules/preact/jsx-dev-runtime"],
+ "@lib/*": ["./src/lib/*"],
+ "@shadcn/*": ["./src/lib/shadcn/*"]
+ },
+
+ /* Bundler mode */
+ "moduleResolution": "bundler",
+ "allowImportingTsExtensions": true,
+ "verbatimModuleSyntax": true,
+ "moduleDetection": "force",
+ "noEmit": true,
+ "jsx": "react-jsx",
+ "jsxImportSource": "preact",
+
+ /* Linting */
+ "noUnusedLocals": true,
+ "noUnusedParameters": true,
+ "erasableSyntaxOnly": true,
+ "noFallthroughCasesInSwitch": true
+ },
+ "include": ["src"]
+}
diff --git a/src/frontend/tsconfig.json b/src/frontend/tsconfig.json
new file mode 100644
index 0000000..fcf5db7
--- /dev/null
+++ b/src/frontend/tsconfig.json
@@ -0,0 +1,11 @@
+{
+ "files": [],
+ "references": [
+ {
+ "path": "./tsconfig.app.json"
+ },
+ {
+ "path": "./tsconfig.node.json"
+ }
+ ],
+}
\ No newline at end of file
diff --git a/src/frontend/tsconfig.node.json b/src/frontend/tsconfig.node.json
new file mode 100644
index 0000000..8455dcb
--- /dev/null
+++ b/src/frontend/tsconfig.node.json
@@ -0,0 +1,23 @@
+{
+ "compilerOptions": {
+ "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.node.tsbuildinfo",
+ "target": "es2023",
+ "lib": ["ES2023"],
+ "types": ["node"],
+ "skipLibCheck": true,
+
+ /* Bundler mode */
+ "module": "nodenext",
+ "allowImportingTsExtensions": true,
+ "verbatimModuleSyntax": true,
+ "moduleDetection": "force",
+ "noEmit": true,
+
+ /* Linting */
+ "noUnusedLocals": true,
+ "noUnusedParameters": true,
+ "erasableSyntaxOnly": true,
+ "noFallthroughCasesInSwitch": true
+ },
+ "include": ["vite.config.ts"]
+}
diff --git a/src/frontend/vite.config.ts b/src/frontend/vite.config.ts
new file mode 100644
index 0000000..b617d3b
--- /dev/null
+++ b/src/frontend/vite.config.ts
@@ -0,0 +1,33 @@
+import { defineConfig, type UserConfig } from 'vite'
+import preact from '@preact/preset-vite'
+import tailwindcss from '@tailwindcss/vite'
+import path from 'path'
+
+// https://vite.dev/config/
+export default defineConfig(({ command }): UserConfig => {
+ const isDev = command === 'serve'
+
+ return {
+ resolve: {
+ alias: {
+ "@lib": path.resolve(__dirname, "./src/lib"),
+ "@shadcn": path.resolve(__dirname, "./src/lib/shadcn"),
+ "react": path.resolve(__dirname, "./node_modules/preact/compat"),
+ },
+ },
+ plugins: [preact(), tailwindcss()],
+ server: {
+ proxy: isDev
+ ? {
+ '/api': 'http://127.0.0.1:8080',
+ '/gitea-api': {
+ target: 'https://git.dcntrlized.org', // Your Gitea base URL
+ changeOrigin: true,
+ rewrite: (path) => path.replace(/^\/gitea-api/, ''),
+ },
+
+ }
+ : undefined, // Using undefined instead of an empty object satisfies the index signature type
+ },
+ }
+})
\ No newline at end of file
diff --git a/src/go.mod b/src/go.mod
new file mode 100644
index 0000000..d58f9da
--- /dev/null
+++ b/src/go.mod
@@ -0,0 +1,50 @@
+module git.dcntrlized.org/Dcntrlized/Maestro
+
+go 1.26.4
+
+require (
+ github.com/docker/docker v28.5.2+incompatible
+ github.com/gorilla/websocket v1.5.3
+)
+
+require (
+ github.com/docker/cli v29.5.3+incompatible // indirect
+ github.com/docker/docker-credential-helpers v0.9.3 // indirect
+ github.com/klauspost/compress v1.18.6 // indirect
+ golang.org/x/sync v0.21.0 // indirect
+)
+
+require (
+ github.com/Microsoft/go-winio v0.6.2 // indirect
+ github.com/cespare/xxhash/v2 v2.3.0 // indirect
+ github.com/containerd/errdefs v1.0.0 // indirect
+ github.com/containerd/errdefs/pkg v0.3.0 // indirect
+ github.com/containerd/log v0.1.0 // indirect
+ github.com/distribution/reference v0.6.0 // indirect
+ github.com/docker/go-connections v0.7.0 // indirect
+ github.com/docker/go-units v0.5.0 // indirect
+ github.com/felixge/httpsnoop v1.0.4 // indirect
+ github.com/go-logr/logr v1.4.3 // indirect
+ github.com/go-logr/stdr v1.2.2 // indirect
+ github.com/google/go-containerregistry v0.21.7
+ github.com/moby/docker-image-spec v1.3.1 // indirect
+ github.com/moby/sys/atomicwriter v0.1.0 // indirect
+ github.com/moby/term v0.5.2 // indirect
+ github.com/morikuni/aec v1.1.0 // indirect
+ github.com/opencontainers/go-digest v1.0.0 // indirect
+ github.com/opencontainers/image-spec v1.1.1 // indirect
+ github.com/pkg/errors v0.9.1 // indirect
+ github.com/sirupsen/logrus v1.9.4 // indirect
+ go.opentelemetry.io/auto/sdk v1.2.1 // indirect
+ go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.61.0 // indirect
+ go.opentelemetry.io/otel v1.44.0 // indirect
+ go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.44.0 // indirect
+ go.opentelemetry.io/otel/metric v1.44.0 // indirect
+ go.opentelemetry.io/otel/sdk v1.44.0 // indirect
+ go.opentelemetry.io/otel/sdk/metric v1.44.0 // indirect
+ go.opentelemetry.io/otel/trace v1.44.0 // indirect
+ golang.org/x/mod v0.38.0
+ golang.org/x/sys v0.46.0 // indirect
+ golang.org/x/time v0.11.0 // indirect
+ gotest.tools/v3 v3.5.2 // indirect
+)
diff --git a/src/go.sum b/src/go.sum
new file mode 100644
index 0000000..7f7792f
--- /dev/null
+++ b/src/go.sum
@@ -0,0 +1,113 @@
+github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c h1:udKWzYgxTojEKWjV8V+WSxDXJ4NFATAsZjh8iIbsQIg=
+github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c/go.mod h1:xomTg63KZ2rFqZQzSB4Vz2SUXa1BpHTVz9L5PTmPC4E=
+github.com/Microsoft/go-winio v0.6.2 h1:F2VQgta7ecxGYO8k3ZZz3RS8fVIXVxONVUPlNERoyfY=
+github.com/Microsoft/go-winio v0.6.2/go.mod h1:yd8OoFMLzJbo9gZq8j5qaps8bJ9aShtEA8Ipt1oGCvU=
+github.com/cenkalti/backoff/v5 v5.0.3 h1:ZN+IMa753KfX5hd8vVaMixjnqRZ3y8CuJKRKj1xcsSM=
+github.com/cenkalti/backoff/v5 v5.0.3/go.mod h1:rkhZdG3JZukswDf7f0cwqPNk4K0sa+F97BxZthm/crw=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/containerd/errdefs v1.0.0 h1:tg5yIfIlQIrxYtu9ajqY42W3lpS19XqdxRQeEwYG8PI=
+github.com/containerd/errdefs v1.0.0/go.mod h1:+YBYIdtsnF4Iw6nWZhJcqGSg/dwvV7tyJ/kCkyJ2k+M=
+github.com/containerd/errdefs/pkg v0.3.0 h1:9IKJ06FvyNlexW690DXuQNx2KA2cUJXx151Xdx3ZPPE=
+github.com/containerd/errdefs/pkg v0.3.0/go.mod h1:NJw6s9HwNuRhnjJhM7pylWwMyAkmCQvQ4GpJHEqRLVk=
+github.com/containerd/log v0.1.0 h1:TCJt7ioM2cr/tfR8GPbGf9/VRAX8D2B4PjzCpfX540I=
+github.com/containerd/log v0.1.0/go.mod h1:VRRf09a7mHDIRezVKTRCrOq78v577GXq3bSa3EhrzVo=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/distribution/reference v0.6.0 h1:0IXCQ5g4/QMHHkarYzh5l+u8T3t73zM5QvfrDyIgxBk=
+github.com/distribution/reference v0.6.0/go.mod h1:BbU0aIcezP1/5jX/8MP0YiH4SdvB5Y4f/wlDRiLyi3E=
+github.com/docker/cli v29.5.3+incompatible h1:nbEFfz774vBwQ5KRYv7c/AghjReqnGISvrRhzjV0evs=
+github.com/docker/cli v29.5.3+incompatible/go.mod h1:JLrzqnKDaYBop7H2jaqPtU4hHvMKP+vjCwu2uszcLI8=
+github.com/docker/docker v28.5.2+incompatible h1:DBX0Y0zAjZbSrm1uzOkdr1onVghKaftjlSWt4AFexzM=
+github.com/docker/docker v28.5.2+incompatible/go.mod h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk=
+github.com/docker/docker-credential-helpers v0.9.3 h1:gAm/VtF9wgqJMoxzT3Gj5p4AqIjCBS4wrsOh9yRqcz8=
+github.com/docker/docker-credential-helpers v0.9.3/go.mod h1:x+4Gbw9aGmChi3qTLZj8Dfn0TD20M/fuWy0E5+WDeCo=
+github.com/docker/go-connections v0.7.0 h1:6SsRfJddP22WMrCkj19x9WKjEDTB+ahsdiGYf0mN39c=
+github.com/docker/go-connections v0.7.0/go.mod h1:no1qkHdjq7kLMGUXYAduOhYPSJxxvgWBh7ogVvptn3Q=
+github.com/docker/go-units v0.5.0 h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4=
+github.com/docker/go-units v0.5.0/go.mod h1:fgPhTUdO+D/Jk86RDLlptpiXQzgHJF7gydDDbaIK4Dk=
+github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
+github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
+github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
+github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=
+github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
+github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
+github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
+github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
+github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
+github.com/google/go-containerregistry v0.21.7 h1:/vPFuVXDjtFREsVArW+0h1CIl5urnOhzei4X2DMW9IU=
+github.com/google/go-containerregistry v0.21.7/go.mod h1:kjSbt7/zMsKLWfnHrIvKvhXHUw91jbe9DNjPPJ32gXE=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
+github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.29.0 h1:5VipnvEpbqr2gA2VbM+nYVbkIF28c5ZQfqCBQ5g2xfk=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.29.0/go.mod h1:Hyl3n6Twe1hvtd9XUXDec4pTvgMSEixRuQKPTMH2bNs=
+github.com/klauspost/compress v1.18.6 h1:2jupLlAwFm95+YDR+NwD2MEfFO9d4z4Prjl1XXDjuao=
+github.com/klauspost/compress v1.18.6/go.mod h1:cwPg85FWrGar70rWktvGQj8/hthj3wpl0PGDogxkrSQ=
+github.com/moby/docker-image-spec v1.3.1 h1:jMKff3w6PgbfSa69GfNg+zN/XLhfXJGnEx3Nl2EsFP0=
+github.com/moby/docker-image-spec v1.3.1/go.mod h1:eKmb5VW8vQEh/BAr2yvVNvuiJuY6UIocYsFu/DxxRpo=
+github.com/moby/sys/atomicwriter v0.1.0 h1:kw5D/EqkBwsBFi0ss9v1VG3wIkVhzGvLklJ+w3A14Sw=
+github.com/moby/sys/atomicwriter v0.1.0/go.mod h1:Ul8oqv2ZMNHOceF643P6FKPXeCmYtlQMvpizfsSoaWs=
+github.com/moby/sys/sequential v0.6.0 h1:qrx7XFUd/5DxtqcoH1h438hF5TmOvzC/lspjy7zgvCU=
+github.com/moby/sys/sequential v0.6.0/go.mod h1:uyv8EUTrca5PnDsdMGXhZe6CCe8U/UiTWd+lL+7b/Ko=
+github.com/moby/term v0.5.2 h1:6qk3FJAFDs6i/q3W/pQ97SX192qKfZgGjCQqfCJkgzQ=
+github.com/moby/term v0.5.2/go.mod h1:d3djjFCrjnB+fl8NJux+EJzu0msscUP+f8it8hPkFLc=
+github.com/morikuni/aec v1.1.0 h1:vBBl0pUnvi/Je71dsRrhMBtreIqNMYErSAbEeb8jrXQ=
+github.com/morikuni/aec v1.1.0/go.mod h1:xDRgiq/iw5l+zkao76YTKzKttOp2cwPEne25HDkJnBw=
+github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U=
+github.com/opencontainers/go-digest v1.0.0/go.mod h1:0JzlMkj0TRzQZfJkVvzbP0HBR3IKzErnv2BNG4W4MAM=
+github.com/opencontainers/image-spec v1.1.1 h1:y0fUlFfIZhPF1W537XOLg0/fcx6zcHCJwooC2xJA040=
+github.com/opencontainers/image-spec v1.1.1/go.mod h1:qpqAh3Dmcf36wStyyWU+kCeDgrGnAve2nCC8+7h8Q0M=
+github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
+github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/sirupsen/logrus v1.9.4 h1:TsZE7l11zFCLZnZ+teH4Umoq5BhEIfIzfRDZ1Uzql2w=
+github.com/sirupsen/logrus v1.9.4/go.mod h1:ftWc9WdOfJ0a92nsE2jF5u5ZwH8Bv2zdeOC42RjbV2g=
+github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
+github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
+go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ64=
+go.opentelemetry.io/auto/sdk v1.2.1/go.mod h1:KRTj+aOaElaLi+wW1kO/DZRXwkF4C5xPbEe3ZiIhN7Y=
+go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.61.0 h1:F7Jx+6hwnZ41NSFTO5q4LYDtJRXBf2PD0rNBkeB/lus=
+go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.61.0/go.mod h1:UHB22Z8QsdRDrnAtX4PntOl36ajSxcdUMt1sF7Y6E7Q=
+go.opentelemetry.io/otel v1.44.0 h1:JjwHmHpA4iZ3wBxluu2fbbE7j4kqlE8jXyAyPXH7HqU=
+go.opentelemetry.io/otel v1.44.0/go.mod h1:BMgjTHL9WPRlRjL2oZCBTL4whCGtXch2H4BhOPIAyYc=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.44.0 h1:4YsVu3B8+3qtWYYrsUYgn0OG78pN0rnNPRGX4SbokQI=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.44.0/go.mod h1:+wnlSn0mD1ADVMe3v9Z/WIaiz6q6gL2J/ejaAmdmv80=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.44.0 h1:lgh3PiVrRUWMLOVSkQicxzZll5NjF1r+AtsX1XRIHw0=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.44.0/go.mod h1:5Cnhth3m/AgOeTgE3ex12pPmiu/gGtZit03kSzx9X7s=
+go.opentelemetry.io/otel/metric v1.44.0 h1:1w0gILTcHdr3YI+ixLyjemwrVnsMURbTZFrSYCdDdmc=
+go.opentelemetry.io/otel/metric v1.44.0/go.mod h1:8O7hanEPBNgEMmybD3s2VBKcgWOCsA6tzHBPODAiquo=
+go.opentelemetry.io/otel/sdk v1.44.0 h1:nHYwb9lK+fJPU/dnT6s7W7Z8itMWyqrnVfbheVYrZ58=
+go.opentelemetry.io/otel/sdk v1.44.0/go.mod h1:Osuydd3Se74nqjAKxid74N5eC+jfEqfTegHRnq58oK0=
+go.opentelemetry.io/otel/sdk/metric v1.44.0 h1:3LlKgI+VjbVsjNRFZJZAJ30WjXC5VkNRks6si09iEfI=
+go.opentelemetry.io/otel/sdk/metric v1.44.0/go.mod h1:5B5pMARnXxKhltooO4xUuCBorl65a4EpnTalObqOigA=
+go.opentelemetry.io/otel/trace v1.44.0 h1:jxF5CsGYCe74MCRx2X4g7WsY/VBKRqqpNvXlX/6gtIk=
+go.opentelemetry.io/otel/trace v1.44.0/go.mod h1:oLl1jrMQAVo6v3GAggN+1VH9VIz9iUSvW53sW1Q8PIE=
+go.opentelemetry.io/proto/otlp v1.10.0 h1:IQRWgT5srOCYfiWnpqUYz9CVmbO8bFmKcwYxpuCSL2g=
+go.opentelemetry.io/proto/otlp v1.10.0/go.mod h1:/CV4QoCR/S9yaPj8utp3lvQPoqMtxXdzn7ozvvozVqk=
+golang.org/x/mod v0.38.0 h1:MECBjubtXD7yj4HrhIUcywNaGeNVUdfVnxmPajOk4yk=
+golang.org/x/mod v0.38.0/go.mod h1:V6Xz0pq8TQ3dGqVQ1FVHuelZpAL0uNhSkk9ogYP3c40=
+golang.org/x/net v0.55.0 h1:bcvxaJn3e1U6InsFWt1JUq1aSjnRxLzT2rtD2KfkDF8=
+golang.org/x/net v0.55.0/go.mod h1:L5U2KuzuOe1lY7Z+aWVIKK6qEeJXnXV9yzGA+WCHJww=
+golang.org/x/sync v0.21.0 h1:HLII4xRRTtCRkxYp4HNFF0Js/Og6q2i++KXbg0gHCwM=
+golang.org/x/sync v0.21.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
+golang.org/x/sys v0.46.0 h1:noSf2Fq6F8DBgS+LysIkx7rIExoNHJsxOAtPp4rthXw=
+golang.org/x/sys v0.46.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
+golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
+golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
+golang.org/x/time v0.11.0 h1:/bpjEDfN9tkoN/ryeYHnv5hcMlc8ncjMcM4XBk5NWV0=
+golang.org/x/time v0.11.0/go.mod h1:CDIdPxbZBQxdj6cxyCIdrNogrJKMJ7pr37NYpMcMDSg=
+google.golang.org/genproto/googleapis/api v0.0.0-20260526163538-3dc84a4a5aaa h1:Kjn0N0tCrDgiAFW+lGO4JZ3ck44CehvJQMAwj9QF0G8=
+google.golang.org/genproto/googleapis/api v0.0.0-20260526163538-3dc84a4a5aaa/go.mod h1:q4lMZS6kskjT5HvCPrnnypcDPVJqT/f4nfxmkE7gryY=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa h1:mZHHdPZl0dbGHCflZgAq/Q468DWVFcU2whhB2KAo8fk=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
+google.golang.org/grpc v1.81.1 h1:VnnIIZ88UzOOKLukQi+ImGz8O1Wdp8nAGGnvOfEIWQQ=
+google.golang.org/grpc v1.81.1/go.mod h1:xGH9GfzOyMTGIOXBJmXt+BX/V0kcdQbdcuwQ/zNw42I=
+google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
+google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gotest.tools/v3 v3.5.2 h1:7koQfIKdy+I8UTetycgUqXWSDwpgv193Ka+qRsmBY8Q=
+gotest.tools/v3 v3.5.2/go.mod h1:LtdLGcnqToBH83WByAAi/wiwSFCArdFIUV/xxN4pcjA=
diff --git a/src/handlers/actions/actions.go b/src/handlers/actions/actions.go
new file mode 100644
index 0000000..150483c
--- /dev/null
+++ b/src/handlers/actions/actions.go
@@ -0,0 +1,10 @@
+package actions
+
+import "net/http"
+
+func RunAction(w http.ResponseWriter, r *http.Request) {
+ // Stub, to implement, receives an action via frontend code and redirects it to the correct container, which will execute it and return the result to the frontend
+ // Request comes in format {"container_id": string, "action": { "method": "GET" | "POST" | "PUT" | "DELETE", "action_name": string }, "payload": object}
+
+ http.Error(w, "Action not implemented", http.StatusNotImplemented)
+}
diff --git a/src/handlers/containers/install.go b/src/handlers/containers/install.go
new file mode 100644
index 0000000..c2a3a8a
--- /dev/null
+++ b/src/handlers/containers/install.go
@@ -0,0 +1,10 @@
+package containers
+
+import (
+ "net/http"
+)
+
+func InstallContainer(w http.ResponseWriter, r *http.Request) {
+ // Stub, to implement, receives a container via frontend code, triggers it's install automagically and registers it in a local database
+ http.Error(w, "Action not implemented", http.StatusNotImplemented)
+}
diff --git a/src/handlers/containers/list.go b/src/handlers/containers/list.go
new file mode 100644
index 0000000..ed5c4b3
--- /dev/null
+++ b/src/handlers/containers/list.go
@@ -0,0 +1,31 @@
+package containers
+
+import (
+ "encoding/json"
+ "log"
+ "net/http"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/containers"
+)
+
+// NewListContainersHandler takes the cache instance from main and wraps it in a handler function
+func NewListContainersHandler(cache *containers.ContainerCache) http.HandlerFunc {
+ return func(w http.ResponseWriter, r *http.Request) {
+ cache.RLock()
+ defer cache.RUnlock()
+
+ w.Header().Set("Content-Type", "application/json")
+
+ if cache.GetServices() == nil {
+ w.WriteHeader(http.StatusInternalServerError)
+ w.Write([]byte("No services available\n"))
+ }
+
+ services := cache.GetServices()
+ if err := json.NewEncoder(w).Encode(services); err != nil {
+ log.Printf("Error encoding services: %v", err)
+ http.Error(w, "Error marshaling service data", http.StatusInternalServerError)
+ return
+ }
+ }
+}
diff --git a/src/handlers/containers/ws.go b/src/handlers/containers/ws.go
new file mode 100644
index 0000000..dd6f989
--- /dev/null
+++ b/src/handlers/containers/ws.go
@@ -0,0 +1,85 @@
+package containers
+
+import (
+ "encoding/json"
+ "log"
+ "net/http"
+ "sync"
+
+ libcontainers "git.dcntrlized.org/Dcntrlized/Maestro/lib/containers"
+ "github.com/gorilla/websocket"
+)
+
+type WebSocketHub struct {
+ cache *libcontainers.ContainerCache
+ clients map[*websocket.Conn]bool
+ mu sync.Mutex
+ upgrader websocket.Upgrader
+}
+
+func NewWebSocketHub(cache *libcontainers.ContainerCache) *WebSocketHub {
+ hub := &WebSocketHub{
+ cache: cache,
+ clients: make(map[*websocket.Conn]bool),
+ upgrader: websocket.Upgrader{
+ // Allow connections from your local frontend during dev
+ CheckOrigin: func(r *http.Request) bool { return true },
+ },
+ }
+
+ // Start a background worker to listen for cache changes
+ go hub.listenForUpdates()
+ return hub
+}
+
+// Broadcasts the new state to all connected clients
+func (h *WebSocketHub) listenForUpdates() {
+ for range h.cache.UpdateCh {
+ services := h.cache.GetServices()
+ msg, _ := json.Marshal(services)
+
+ h.mu.Lock()
+ for client := range h.clients {
+ err := client.WriteMessage(websocket.TextMessage, msg)
+ if err != nil {
+ client.Close()
+ delete(h.clients, client) // Clean up dead connections
+ }
+ }
+ h.mu.Unlock()
+ }
+}
+
+func (h *WebSocketHub) HandleWS(w http.ResponseWriter, r *http.Request) {
+ conn, err := h.upgrader.Upgrade(w, r, nil)
+ if err != nil {
+ log.Println("WebSocket upgrade failed:", err)
+ return
+ }
+
+ // Register new client
+ h.mu.Lock()
+ h.clients[conn] = true
+ h.mu.Unlock()
+
+ // Push state to client
+ services := h.cache.GetServices()
+ msg, _ := json.Marshal(services)
+ conn.WriteMessage(websocket.TextMessage, msg)
+
+ // Keep connection alive and clean up on disconnect
+ go func() {
+ defer func() {
+ h.mu.Lock()
+ delete(h.clients, conn)
+ h.mu.Unlock()
+ conn.Close()
+ }()
+ for {
+ // If ReadMessage fails, the frontend closed the tab or lost connection
+ if _, _, err := conn.ReadMessage(); err != nil {
+ break
+ }
+ }
+ }()
+}
diff --git a/src/handlers/registry/registry.go b/src/handlers/registry/registry.go
new file mode 100644
index 0000000..02c7f6d
--- /dev/null
+++ b/src/handlers/registry/registry.go
@@ -0,0 +1,198 @@
+package handlers
+
+import (
+ "encoding/json"
+ "fmt"
+ "net/http"
+ "sort"
+ "strings"
+ "time"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/consts"
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/logger"
+
+ "github.com/google/go-containerregistry/pkg/authn"
+ "github.com/google/go-containerregistry/pkg/name"
+ "github.com/google/go-containerregistry/pkg/v1/remote"
+ "golang.org/x/mod/semver"
+)
+
+// RegistryContainer represents a clean API payload specifically for container registry items.
+type RegistryContainer struct {
+ Name string `json:"name"`
+ Version string `json:"version"`
+ Image string `json:"image"`
+ Title string `json:"title,omitempty"`
+ Vendor string `json:"vendor,omitempty"`
+ Author string `json:"author,omitempty"`
+ Description string `json:"description,omitempty"`
+ Source string `json:"source,omitempty"`
+ CreatedAt string `json:"created_at,omitempty"`
+}
+
+type RawPackage struct {
+ Name string `json:"name"`
+ Version string `json:"version"`
+ CreatedAt string `json:"created_at"`
+ HTMLURL string `json:"html_url"`
+ Repository *struct {
+ HTMLURL string `json:"html_url"`
+ } `json:"repository"`
+}
+
+func GetRegistry(w http.ResponseWriter, r *http.Request) {
+ // 1. Query Gitea REST API using the exact Org name
+ apiURL := fmt.Sprintf("https://git.dcntrlized.org/api/v1/packages/%s?type=container", consts.GITEA_ORG)
+
+ req, err := http.NewRequestWithContext(r.Context(), http.MethodGet, apiURL, nil)
+ if err != nil {
+ logger.Error("Failed to create request: %v", err)
+ http.Error(w, "Internal server error", http.StatusInternalServerError)
+ return
+ }
+
+ req.Header.Set("Authorization", "token "+consts.GITEA_RW_PACKAGE_TOKEN)
+
+ client := &http.Client{Timeout: 10 * time.Second}
+ resp, err := client.Do(req)
+ if err != nil {
+ logger.Error("Failed to reach Gitea package API: %v", err)
+ http.Error(w, "Failed to connect to upstream registry", http.StatusBadGateway)
+ return
+ }
+ defer resp.Body.Close()
+
+ if resp.StatusCode < 200 || resp.StatusCode >= 300 {
+ logger.Error("Registry API returned non-200 status code: %d", resp.StatusCode)
+ http.Error(w, fmt.Sprintf("Registry API error: %s", resp.Status), resp.StatusCode)
+ return
+ }
+
+ var rawPackages []RawPackage
+ if err := json.NewDecoder(resp.Body).Decode(&rawPackages); err != nil {
+ logger.Error("Failed to decode registry response: %v", err)
+ http.Error(w, "Failed to decode registry response", http.StatusInternalServerError)
+ return
+ }
+
+ // 2. Group by Name and filter out "latest" & "sha256:"
+ groupedPackages := make(map[string][]RawPackage)
+ for _, pkg := range rawPackages {
+ if pkg.Version == "latest" || strings.HasPrefix(pkg.Version, "sha256:") {
+ continue
+ }
+ groupedPackages[pkg.Name] = append(groupedPackages[pkg.Name], pkg)
+ }
+
+ // Helper function to normalize version strings for semver package (requires 'v' prefix)
+ formatSemver := func(v string) string {
+ if !strings.HasPrefix(v, "v") {
+ return "v" + v
+ }
+ return v
+ }
+
+ // 3. For each container name, find the package entry with the highest semver
+ var latestPackages []RawPackage
+ for _, pkgs := range groupedPackages {
+ if len(pkgs) == 0 {
+ continue
+ }
+
+ sort.Slice(pkgs, func(i, j int) bool {
+ vI := formatSemver(pkgs[i].Version)
+ vJ := formatSemver(pkgs[j].Version)
+
+ // Compare using semver package
+ if semver.IsValid(vI) && semver.IsValid(vJ) {
+ return semver.Compare(vI, vJ) > 0
+ }
+ // Fall back to string comparison if not valid semver
+ return pkgs[i].Version > pkgs[j].Version
+ })
+
+ // First item after descending sort is the highest version
+ latestPackages = append(latestPackages, pkgs[0])
+ }
+
+ ociAuth := remote.WithAuth(&authn.Basic{
+ Username: consts.GITEA_USER,
+ Password: consts.GITEA_RW_PACKAGE_TOKEN,
+ })
+
+ ociOrg := strings.ToLower(consts.GITEA_ORG)
+ var registryItems []RegistryContainer
+
+ // 4. Fetch OCI metadata only for the highest version of each package
+ for _, pkg := range latestPackages {
+ pkgNameLower := strings.ToLower(pkg.Name)
+ imageRef := fmt.Sprintf("git.dcntrlized.org/%s/%s:%s", ociOrg, pkgNameLower, pkg.Version)
+
+ source := pkg.HTMLURL
+ if pkg.Repository != nil && pkg.Repository.HTMLURL != "" {
+ source = pkg.Repository.HTMLURL
+ }
+
+ item := RegistryContainer{
+ Name: pkg.Name,
+ Version: pkg.Version,
+ Image: imageRef,
+ Source: source,
+ CreatedAt: pkg.CreatedAt,
+ }
+
+ ref, err := name.ParseReference(imageRef)
+ if err != nil {
+ logger.Error("Failed to parse image reference %s: %v", imageRef, err)
+ registryItems = append(registryItems, item)
+ continue
+ }
+
+ img, err := remote.Image(ref, ociAuth, remote.WithContext(r.Context()))
+ if err != nil {
+ logger.Error("Failed to fetch OCI metadata for %s: %v", imageRef, err)
+ registryItems = append(registryItems, item)
+ continue
+ }
+
+ // Extract annotations from OCI manifest
+ if manifest, err := img.Manifest(); err == nil && manifest != nil {
+ if title, ok := manifest.Annotations["org.opencontainers.image.title"]; ok {
+ item.Title = title
+ }
+ if vendor, ok := manifest.Annotations["org.opencontainers.image.vendor"]; ok {
+ item.Vendor = vendor
+ }
+ if author, ok := manifest.Annotations["org.opencontainers.image.authors"]; ok {
+ item.Author = author
+ }
+ if desc, ok := manifest.Annotations["org.opencontainers.image.description"]; ok {
+ item.Description = desc
+ }
+ }
+
+ // Fallback to Image Config labels
+ if configFile, err := img.ConfigFile(); err == nil && configFile != nil {
+ labels := configFile.Config.Labels
+ if item.Title == "" {
+ item.Title = labels["org.opencontainers.image.title"]
+ }
+ if item.Vendor == "" {
+ item.Vendor = labels["org.opencontainers.image.vendor"]
+ }
+ if item.Author == "" {
+ item.Author = labels["org.opencontainers.image.authors"]
+ }
+ if item.Description == "" {
+ item.Description = labels["org.opencontainers.image.description"]
+ }
+ }
+
+ registryItems = append(registryItems, item)
+ }
+
+ w.Header().Set("Content-Type", "application/json")
+ if err := json.NewEncoder(w).Encode(registryItems); err != nil {
+ logger.Error("Failed to write response: %v", err)
+ }
+}
diff --git a/src/lib/actions/actions.go b/src/lib/actions/actions.go
new file mode 100644
index 0000000..cc1ca08
--- /dev/null
+++ b/src/lib/actions/actions.go
@@ -0,0 +1,54 @@
+package actions
+
+import (
+ "bytes"
+ "fmt"
+ "net/http"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/containers"
+)
+
+type ActionProxyPayload struct {
+ Method string
+ Action string
+ Data string `json:"data"`
+}
+
+type ActionProxyResponse struct {
+ StatusCode int
+ Body string
+}
+
+func ActionProxy(container_id, action string, payload ActionProxyPayload) (ActionProxyResponse, error) {
+ // Forward the action to the container with the given ID, and return the result to the frontend
+
+ containers := containers.NewContainerCache().GetServices()
+ for _, container := range containers {
+ if container.ID == container_id {
+ // Forward the action to this container
+
+ body := bytes.NewBuffer([]byte(payload.Data))
+
+ req, err := http.NewRequest(payload.Method, fmt.Sprintf("http://%s:%s/action/%s", container.ID[:12], container.Network.Ports[0].Host, payload.Action), body)
+ if err != nil {
+ return ActionProxyResponse{}, err
+ }
+
+ client := &http.Client{}
+ resp, err := client.Do(req)
+ if err != nil {
+ return ActionProxyResponse{}, err
+ }
+ defer resp.Body.Close()
+
+ buf := new(bytes.Buffer)
+ buf.ReadFrom(resp.Body)
+
+ return ActionProxyResponse{
+ StatusCode: resp.StatusCode,
+ Body: buf.String(),
+ }, nil
+ }
+ }
+ return ActionProxyResponse{}, fmt.Errorf("container with ID %s not found", container_id)
+}
diff --git a/src/lib/consts/admin.go b/src/lib/consts/admin.go
new file mode 100644
index 0000000..dc8a49e
--- /dev/null
+++ b/src/lib/consts/admin.go
@@ -0,0 +1,6 @@
+package consts
+
+const GITEA_RO_TOKEN = ""
+const GITEA_RW_PACKAGE_TOKEN = ""
+const GITEA_ORG = ""
+const GITEA_USER = ""
diff --git a/src/lib/containers/cache.go b/src/lib/containers/cache.go
new file mode 100644
index 0000000..2a97567
--- /dev/null
+++ b/src/lib/containers/cache.go
@@ -0,0 +1,66 @@
+package containers
+
+import (
+ "sync"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/types"
+)
+
+type ContainerCache struct {
+ sync.RWMutex
+ // Maps Container ID -> Container
+ services map[string]types.Container
+ UpdateCh chan struct{}
+}
+
+func NewContainerCache() *ContainerCache {
+ return &ContainerCache{
+ services: make(map[string]types.Container),
+ UpdateCh: make(chan struct{}, 10),
+ }
+}
+
+func (cache *ContainerCache) AddService(c types.Container) {
+ cache.Lock()
+ if cache.services == nil {
+ cache.services = make(map[string]types.Container)
+ }
+ cache.services[c.ID] = c
+ cache.Unlock()
+
+ // Trigger update AFTER unlocking to prevent holding locks during channel sends
+ cache.TriggerUpdate()
+}
+
+func (cache *ContainerCache) RemoveService(c types.Container) {
+ cache.Lock()
+ _, exists := cache.services[c.ID]
+ if exists {
+ delete(cache.services, c.ID)
+ }
+ cache.Unlock()
+
+ // Only trigger an update if an item was actually removed
+ if exists {
+ cache.TriggerUpdate()
+ }
+}
+
+func (cache *ContainerCache) TriggerUpdate() {
+ select {
+ case cache.UpdateCh <- struct{}{}:
+ default:
+ // Channel buffer is full; subscriber already knows an update is pending
+ }
+}
+
+func (cache *ContainerCache) GetServices() []types.Container {
+ cache.RLock()
+ defer cache.RUnlock()
+
+ services := make([]types.Container, 0, len(cache.services))
+ for _, service := range cache.services {
+ services = append(services, service)
+ }
+ return services
+}
diff --git a/src/lib/containers/install.go b/src/lib/containers/install.go
new file mode 100644
index 0000000..0c09d3e
--- /dev/null
+++ b/src/lib/containers/install.go
@@ -0,0 +1 @@
+package containers
diff --git a/src/lib/containers/watcher.go b/src/lib/containers/watcher.go
new file mode 100644
index 0000000..4af6b09
--- /dev/null
+++ b/src/lib/containers/watcher.go
@@ -0,0 +1,117 @@
+package containers
+
+import (
+ "context"
+ "fmt"
+ "log"
+ "os"
+ "time"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/docker"
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/types"
+ "github.com/docker/docker/api/types/events"
+ "github.com/docker/docker/api/types/filters"
+)
+
+func (cache *ContainerCache) WatchContainers(ctx context.Context, dc *docker.DockerClient) {
+ filter := filters.NewArgs()
+ filter.Add("type", "container")
+ filter.Add("event", "start")
+ filter.Add("event", "die")
+ filter.Add("event", "destroy")
+
+ messages, errs := dc.Client.Events(ctx, events.ListOptions{Filters: filter})
+
+ log.Println("Subscribed to Docker container events...")
+
+ for {
+ select {
+ case <-ctx.Done():
+ return
+ case err := <-errs:
+ log.Printf("Docker event stream error: %v", err)
+ os.Exit(1)
+ return
+ case event := <-messages:
+ serviceLabel, ok := event.Actor.Attributes["org.dcntrlized.service"]
+ if !ok {
+ log.Default().Printf("Found unrelated service %s\n", serviceLabel)
+ for attribute := range event.Actor.Attributes {
+ log.Default().Printf("\tKey: %s\tValue: %s\n", attribute, event.Actor.Attributes[attribute])
+ }
+ continue
+ }
+ _ = serviceLabel
+ containerID := event.Actor.ID
+ containerName := event.Actor.Attributes["name"]
+
+ cache.Lock()
+
+ switch event.Action {
+ case "start":
+ // Inspect Container
+ inspectData, inspectErr := dc.Client.ContainerInspect(ctx, containerID)
+
+ // Get Network information
+ var containerNetwork types.Network
+
+ if inspectErr != nil {
+ log.Printf("Failed to inspect container %s: %v", containerID, inspectErr)
+ } else {
+ netInfo, shouldCache, err := docker.ExtractNetworkInfo(ctx, dc, inspectData)
+ if err != nil {
+ log.Printf("Error extracting network details: %v", err)
+ }
+ if !shouldCache {
+ fmt.Printf("Bypassing special network mode: %s\n", inspectData.HostConfig.NetworkMode)
+ cache.Unlock()
+ return
+ }
+ containerNetwork = netInfo
+ }
+
+ // Get Versions
+ ver, err := docker.GetContainerVersion(ctx, dc, containerID)
+
+ // Fetch Manifest
+ host := containerID[:12]
+ port := event.Actor.Attributes["org.dcntrlized.port"]
+ manifest, err := docker.FetchManifestWithRetry(ctx, host, port, 20, 50*time.Millisecond)
+ if err != nil {
+ log.Printf("Error fetching manifest for container %s: %v", containerID, err)
+ cache.Unlock()
+ continue
+ }
+
+ // Save to Cache
+ log.Printf("Service started. Adding container %s - %s to cache", host, containerName)
+ cache.services[containerID] = types.Container{
+ ID: containerID,
+ Name: manifest.Name,
+ DockerName: containerName,
+ Image: event.Actor.Attributes["image"],
+ CreatedAt: fmt.Sprint(event.TimeNano),
+ Network: containerNetwork,
+ Status: "running",
+ Version: ver,
+ }
+
+ case "die":
+ if container, exists := cache.services[containerID]; exists {
+ log.Printf("Service stopping: %s", containerName)
+ container.Status = "stopping"
+ cache.services[containerID] = container
+ }
+
+ case "destroy":
+ if container, exists := cache.services[containerID]; exists {
+ log.Printf("Service destroyed: %s", containerName)
+ cache.RemoveService(container)
+ }
+ }
+
+ cache.Unlock()
+ cache.TriggerUpdate()
+ }
+ }
+}
diff --git a/src/lib/containers/watcher_dev.go b/src/lib/containers/watcher_dev.go
new file mode 100644
index 0000000..c46ba91
--- /dev/null
+++ b/src/lib/containers/watcher_dev.go
@@ -0,0 +1,37 @@
+package containers
+
+import (
+ "encoding/json"
+ "log"
+ "os"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/types"
+)
+
+type DevService struct {
+ ID string `json:"id"` // Use "localhost" or IP
+ Port string `json:"port"`
+ Name string `json:"name"`
+}
+
+func (cache *ContainerCache) LoadDevServices(filePath string) {
+ log.Printf("Dev Mode: Loading services from %s", filePath)
+
+ data, err := os.ReadFile(filePath)
+ if err != nil {
+ log.Fatalf("Failed to read dev services file: %v", err)
+ }
+
+ var devServices []DevService
+ if err := json.Unmarshal(data, &devServices); err != nil {
+ log.Fatalf("Failed to parse dev services: %v", err)
+ }
+
+ for _, ds := range devServices {
+ cache.AddService(types.Container{
+ ID: ds.ID,
+ Name: ds.Name,
+ Status: "unknown",
+ })
+ }
+}
diff --git a/src/lib/docker/client.go b/src/lib/docker/client.go
new file mode 100644
index 0000000..15ce9aa
--- /dev/null
+++ b/src/lib/docker/client.go
@@ -0,0 +1,308 @@
+package docker
+
+import (
+ "bytes"
+ "context"
+ "encoding/json"
+ "fmt"
+ "log"
+ "net/http"
+ "strings"
+ "time"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/logger"
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/types"
+
+ "github.com/docker/docker/api/types/container"
+ "github.com/docker/docker/api/types/filters"
+ "github.com/docker/docker/api/types/network"
+ "github.com/docker/docker/client"
+)
+
+// DockerClient is a wrapper around the Docker client that provides additional functionality.
+type DockerClient struct {
+ *client.Client
+}
+
+// ContainerMetadata holds essential high-level metadata extracted from an inspection.
+type ContainerMetadata struct {
+ ID string
+ Name string
+ Image string
+ Version string
+ IPAddress string
+ Status string
+ Created string
+ Labels map[string]string
+ Env map[string]string
+}
+
+// NewDockerClient creates a new instance of DockerClient.
+func NewDockerClient() (*DockerClient, error) {
+ cli, err := client.NewClientWithOpts(client.FromEnv)
+ if err != nil {
+ return nil, err
+ }
+ return &DockerClient{cli}, nil
+}
+
+func (dc *DockerClient) Close() error {
+ return dc.Client.Close()
+}
+
+func ListContainers(dc *DockerClient) ([]string, error) {
+ // Lists containers with org.dcntrlized.service label
+
+ filter := filters.NewArgs()
+ filter.Add("label", "org.dcntrlized.service")
+ options := container.ListOptions{
+ All: true,
+ Filters: filter,
+ }
+
+ containers, err := dc.Client.ContainerList(context.Background(), options)
+ if err != nil {
+ return nil, err
+ }
+
+ var containerNames []string
+ for _, container := range containers {
+ if _, ok := container.Labels["org.dcntrlized.service"]; ok {
+ containerNames = append(containerNames, container.Names[0])
+ }
+ }
+ return containerNames, nil
+}
+
+// fetchManifestWithRetry polls the container's manifest endpoint until it succeeds or max retries are reached.
+// Could probably be simplified to (ctx, container) with maxRetries and retryDelay hardcoded, low priority TODO
+func FetchManifestWithRetry(ctx context.Context, host, port string, maxRetries int, retryDelay time.Duration) (*types.Manifest, error) {
+ url := fmt.Sprintf("http://%s:%s/_manifest", host, port)
+ var resp *http.Response
+ var err error
+
+ // Create a client that respects context deadlines/cancellation
+ client := &http.Client{Timeout: 2 * time.Second}
+
+ for range maxRetries {
+ req, reqErr := http.NewRequestWithContext(ctx, http.MethodGet, url, nil)
+ if reqErr == nil {
+ resp, err = client.Do(req)
+ if err == nil {
+ break
+ }
+ }
+
+ select {
+ case <-ctx.Done():
+ return nil, ctx.Err()
+ case <-time.After(retryDelay):
+ }
+ }
+
+ if err != nil {
+ return nil, fmt.Errorf("failed after %d retries: %w", maxRetries, err)
+ }
+ defer resp.Body.Close()
+
+ if resp.StatusCode != http.StatusOK {
+ return nil, fmt.Errorf("unexpected status code: %d", resp.StatusCode)
+ }
+
+ var manifest types.Manifest
+ if err := json.NewDecoder(resp.Body).Decode(&manifest); err != nil {
+ return nil, fmt.Errorf("failed to decode manifest: %w", err)
+ }
+
+ return &manifest, nil
+}
+
+// GetContainerVersion retrieves the container or image version from inspection data.
+func GetContainerVersion(ctx context.Context, dc *DockerClient, containerID string) (string, error) {
+ inspectData, err := dc.Client.ContainerInspect(ctx, containerID)
+ if err != nil {
+ logger.Error("Failed to inspect container: %v", err)
+ return "", fmt.Errorf("failed to inspect container: %w", err)
+ }
+
+ // 1. Check for standard image/version labels
+ labels := inspectData.Config.Labels
+ if version, ok := labels["org.opencontainers.image.version"]; ok && version != "" {
+ logger.Debug("Found version from org.opencontainers.image.version label: %s", version)
+ return version, nil
+ }
+ if version, ok := labels["version"]; ok && version != "" {
+ logger.Debug("Found version from version label: %s", version)
+ return version, nil
+ }
+
+ logger.Debug("No version label found, falling back to image tag parsing for container %s", containerID)
+ // 2. Fall back to parsing the image tag (e.g., "redis:7.0" -> "7.0")
+ imageParts := strings.Split(inspectData.Config.Image, ":")
+ if len(imageParts) > 1 {
+ logger.Debug("Extracted version from image tag: %s", imageParts[len(imageParts)-1])
+ return imageParts[len(imageParts)-1], nil
+ }
+
+ logger.Debug("No version found in image tag, defaulting to 'latest' for container %s", containerID)
+ // 3. If no version is found, default to "latest"
+ return "latest", nil
+}
+
+// ExtractNetworkInfo parses the network mode, active network name, and port mappings.
+func ExtractNetworkInfo(ctx context.Context, dc *DockerClient, inspectData container.InspectResponse) (types.Network, bool, error) {
+ var netInfo types.Network
+
+ hostConfig := inspectData.HostConfig
+ networkMode := string(hostConfig.NetworkMode)
+
+ // Host, none, and container-sharing modes bypass traditional network inspection
+ if networkMode == "host" || networkMode == "none" || strings.HasPrefix(networkMode, "container:") {
+ return netInfo, false, nil // Return false indicating non-standard/ignored network mode
+ }
+
+ networkName := ""
+ for nwName := range inspectData.NetworkSettings.Networks {
+ if nwName == "dcntrlized_net" {
+ netInfo.IPAddress.Address = inspectData.NetworkSettings.Networks[nwName].IPAddress
+ netInfo.IPAddress.Version = types.IPv4 // Currently hardcoded (I'm assuming ^^ will always be an IPv4 IP but if not we should gather version correctly low priority TODO)
+ }
+ networkName = nwName
+ break // First active network
+ }
+ if networkName == "" {
+ networkName = "bridge"
+ }
+
+ networkResource, err := dc.Client.NetworkInspect(ctx, networkName, network.InspectOptions{})
+ if err != nil {
+ netInfo.Mode = "bridge" // Fallback
+ } else {
+ netInfo.Mode = networkResource.Driver // e.g., "bridge", "overlay"
+ }
+
+ for p := range hostConfig.PortBindings {
+ hostPort, guestPort, err := p.Range()
+ if err != nil {
+ log.Printf("Error parsing port range for container: %v", err)
+ continue
+ }
+ netInfo.Ports = append(netInfo.Ports, types.PortMapping{Host: hostPort, Guest: guestPort})
+ }
+
+ netInfo.Name = networkName
+ return netInfo, true, nil
+}
+
+// GetContainerMetadata collects the primary useful metadata for a given container.
+func GetContainerMetadata(ctx context.Context, dc *DockerClient, containerID string) (*ContainerMetadata, error) {
+ inspectData, err := dc.Client.ContainerInspect(ctx, containerID)
+ if err != nil {
+ return nil, fmt.Errorf("failed to inspect container %s: %w", containerID, err)
+ }
+
+ // Parse environment variables into a key-value map
+ envMap := make(map[string]string)
+ for _, env := range inspectData.Config.Env {
+ parts := strings.SplitN(env, "=", 2)
+ if len(parts) == 2 {
+ envMap[parts[0]] = parts[1]
+ }
+ }
+
+ // Extract primary IP address from the active network settings
+ ipAddress := ""
+ for _, netSetting := range inspectData.NetworkSettings.Networks {
+ if netSetting.IPAddress != "" {
+ ipAddress = netSetting.IPAddress
+ break
+ }
+ }
+
+ version, _ := GetContainerVersion(ctx, dc, containerID)
+
+ return &ContainerMetadata{
+ ID: inspectData.ID,
+ Name: strings.TrimPrefix(inspectData.Name, "/"), // Clean leading slash
+ Image: inspectData.Config.Image,
+ Version: version,
+ IPAddress: ipAddress,
+ Status: inspectData.State.Status,
+ Created: inspectData.Created,
+ Labels: inspectData.Config.Labels,
+ Env: envMap,
+ }, nil
+}
+
+func GetImageTagFromContainer(ctx context.Context, cli *client.Client, containerID string) (string, error) {
+ // Step 1: Inspect the container
+ containerJSON, err := cli.ContainerInspect(ctx, containerID)
+ if err != nil {
+ return "", fmt.Errorf("failed to inspect container: %w", err)
+ }
+
+ // containerJSON.Config.Image holds the image name or digest used to run it
+ imageRef := containerJSON.Config.Image
+
+ // Step 2: Inspect the image to get its official RepoTags array
+ var rawBody bytes.Buffer
+ inspectResult, err := cli.ImageInspect(ctx, imageRef, client.ImageInspectWithRawResponse(&rawBody))
+ if err != nil {
+
+ return "", fmt.Errorf("failed to inspect image %s: %w", imageRef, err)
+ }
+
+ // If the image has repo tags, return the first match
+ if len(inspectResult.RepoTags) > 0 {
+ return inspectResult.RepoTags[0], nil
+ }
+
+ return imageRef, nil // Fallback to raw reference if untagged
+}
+
+/* func HasUpdateAvailable(ctx context.Context, cli *client.Client, containerID string) (bool, error) {
+ dc, _ := NewDockerClient()
+ ver, _ := GetContainerVersion(ctx, dc, containerID)
+
+ remote, _ := GetLatestRemoteVersion()
+} */
+
+/* func GetLatestRemoteVersion(registryRepo string) (string, error) {
+ // 1. Parse the repository reference (e.g., "git.local/dcntrlized/sampleservicedeploytest/sampleservicedeploytest")
+ repo, err := name.NewRepository(registryRepo)
+ if err != nil {
+ return "", fmt.Errorf("failed to parse repository: %w", err)
+ }
+
+ // 2. Fetch all tags from the remote registry (uses default keychain credentials like docker login)
+ tags, err := remote.List(repo, remote.WithAuthFromKeychain(remote.DefaultKeychain))
+ if err != nil {
+ return "", fmt.Errorf("failed to list remote tags: %w", err)
+ }
+
+ var latestVersion string
+
+ // 3. Filter and find the highest semantic version
+ for _, tag := range tags {
+ // Ensure it follows semantic versioning format (e.g., v1.2.3)
+ formattedTag := tag
+ if !semver.IsValid(formattedTag) {
+ // If it doesn't have a 'v' prefix, try prepending it to check if it's a valid semver core
+ if semver.IsValid("v" + tag) {
+ formattedTag = "v" + tag
+ } else {
+ continue // Skip non-semver tags like "latest"
+ }
+ }
+
+ if latestVersion == "" || semver.Compare(formattedTag, latestVersion) > 0 {
+ latestVersion = formattedTag
+ }
+ }
+
+ if latestVersion == "" {
+ return "", fmt.Errorf("no valid semantic version tags found in registry")
+ }
+
+ return latestVersion, nil
+} */
diff --git a/src/lib/logger/logger.go b/src/lib/logger/logger.go
new file mode 100644
index 0000000..327fd47
--- /dev/null
+++ b/src/lib/logger/logger.go
@@ -0,0 +1,88 @@
+package logger
+
+import (
+ "io"
+ "log"
+ "os"
+ "sync"
+ "time"
+)
+
+var (
+ infoLogger *log.Logger
+ warnLogger *log.Logger
+ errorLogger *log.Logger
+ debugLogger *log.Logger
+
+ once sync.Once
+)
+
+func initLogger() {
+ if err := os.MkdirAll("logs", 0755); err != nil {
+ log.Printf("Failed to create logs directory: %v. Falling back to standard output.", err)
+ }
+
+ // 1. Setup Info Logger
+ var infoOutput io.Writer = os.Stdout
+ if infoFile, err := os.OpenFile("logs/info.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666); err == nil {
+ infoOutput = io.MultiWriter(os.Stdout, infoFile)
+ writeHeader(infoFile)
+ }
+ infoLogger = log.New(infoOutput, "INFO: ", log.Ldate|log.Ltime|log.LUTC)
+
+ // 2. Setup Warn Logger
+ var warnOutput io.Writer = os.Stdout
+ if warnFile, err := os.OpenFile("logs/warn.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666); err == nil {
+ warnOutput = io.MultiWriter(os.Stdout, warnFile)
+ writeHeader(warnFile)
+ }
+ warnLogger = log.New(warnOutput, "WARN: ", log.Ldate|log.Ltime|log.LUTC)
+
+ // 3. Setup Error Logger
+ var errorOutput io.Writer = os.Stderr
+ if errorFile, err := os.OpenFile("logs/error.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666); err == nil {
+ errorOutput = io.MultiWriter(os.Stderr, errorFile)
+ writeHeader(errorFile)
+ }
+ // Note: increased call depth isn't an issue for Lshortfile here because
+ // log.Logger.Printf correctly tracks the caller frame right above it.
+ errorLogger = log.New(errorOutput, "ERROR: ", log.Ldate|log.Ltime|log.LUTC|log.Lshortfile)
+
+ // 4. Setup Debug Logger
+ var debugOutput io.Writer = os.Stdout
+ if debugFile, err := os.OpenFile("logs/debug.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666); err == nil {
+ debugOutput = io.MultiWriter(os.Stdout, debugFile)
+ writeHeader(debugFile)
+ }
+ debugLogger = log.New(debugOutput, "DEBUG: ", log.Ldate|log.Ltime|log.LUTC)
+}
+
+func writeHeader(file *os.File) {
+ file.WriteString("========== Start Log ==========\n")
+ file.WriteString("[INFO] Logger initialized\n")
+ file.WriteString("[" + time.Now().Format(time.RFC3339) + "]\n")
+}
+
+// Info accepts a format string and an optional, arbitrary number of arguments.
+func Info(format string, v ...any) {
+ once.Do(initLogger)
+ infoLogger.Printf(format, v...)
+}
+
+// Warn accepts a format string and an optional, arbitrary number of arguments.
+func Warn(format string, v ...any) {
+ once.Do(initLogger)
+ warnLogger.Printf(format, v...)
+}
+
+// Error accepts a format string and an optional, arbitrary number of arguments.
+func Error(format string, v ...any) {
+ once.Do(initLogger)
+ errorLogger.Printf(format, v...)
+}
+
+// Debug accepts a format string and an optional, arbitrary number of arguments.
+func Debug(format string, v ...any) {
+ once.Do(initLogger)
+ debugLogger.Printf(format, v...)
+}
diff --git a/src/lib/types/docker.go b/src/lib/types/docker.go
new file mode 100644
index 0000000..9c9d90e
--- /dev/null
+++ b/src/lib/types/docker.go
@@ -0,0 +1,42 @@
+package types
+
+type PortMapping struct {
+ Host int `json:"host"`
+ Guest int `json:"guest"`
+}
+
+type IPVersion string
+
+const (
+ IPv4 IPVersion = "v4"
+ IPv6 IPVersion = "v6"
+)
+
+type IPAddress struct {
+ Version IPVersion `json:"version"`
+ Address string `json:"address"`
+}
+
+type Network struct {
+ Name string `json:"name"`
+ IPAddress IPAddress `json:"ipAddress"`
+ Mode string `json:"mode"` // e.g., "bridge", "host", "none", "overlay", "ipvlan", "macvlan"
+ Ports []PortMapping `json:"ports"`
+}
+
+type Container struct {
+ ID string `json:"id"`
+ Name string `json:"name"`
+ DockerName string `json:"docker_name"`
+ Image string `json:"image"`
+ Version string `json:"version"`
+ Status string `json:"status"`
+ CreatedAt string `json:"created_at"`
+ Network Network `json:"network"`
+
+ Title string `json:"title,omitempty"`
+ Vendor string `json:"vendor,omitempty"`
+ Author string `json:"author,omitempty"`
+ Description string `json:"description,omitempty"`
+ Source string `json:"source,omitempty"`
+}
diff --git a/src/lib/types/service.go b/src/lib/types/service.go
new file mode 100644
index 0000000..4ad7b56
--- /dev/null
+++ b/src/lib/types/service.go
@@ -0,0 +1,11 @@
+package types
+
+type Manifest struct {
+ Name string `json:"name"`
+ Version string `json:"version"`
+ Author string `json:"author"`
+ Capabilities []string `json:"capabilities"`
+ HasAuth bool `json:"has_auth"`
+ PublicKey string `json:"public_key"`
+ Icon string `json:"icon"`
+}
diff --git a/src/main.go b/src/main.go
new file mode 100644
index 0000000..4992565
--- /dev/null
+++ b/src/main.go
@@ -0,0 +1,71 @@
+package main
+
+import (
+ "context"
+ "embed"
+ "io/fs"
+ "log"
+ "net/http"
+ "os"
+
+ "git.dcntrlized.org/Dcntrlized/Maestro/handlers/actions"
+ "git.dcntrlized.org/Dcntrlized/Maestro/handlers/containers"
+ handlers "git.dcntrlized.org/Dcntrlized/Maestro/handlers/registry"
+ libcontainers "git.dcntrlized.org/Dcntrlized/Maestro/lib/containers"
+ "git.dcntrlized.org/Dcntrlized/Maestro/lib/docker"
+)
+
+//go:embed all:frontend/dist
+var embeddedFrontend embed.FS
+
+func main() {
+ ctx, cancel := context.WithCancel(context.Background())
+ defer cancel()
+
+ cache := libcontainers.NewContainerCache()
+
+ if os.Getenv("DEV_MODE_STATIC_SERVICES") == "true" {
+ // DEV MODE: Load from file, skip Docker client
+ cache.LoadDevServices("services.json")
+ } else {
+ // PROD MODE: Use Docker
+ dc, err := docker.NewDockerClient()
+ if err != nil {
+ log.Fatalf("Failed to init docker client: %v", err)
+ }
+ defer dc.Close()
+ go cache.WatchContainers(ctx, dc)
+ }
+
+ wsHub := containers.NewWebSocketHub(cache)
+
+ mux := http.NewServeMux()
+ mux.HandleFunc("/api/containers", containers.NewListContainersHandler(cache))
+ mux.HandleFunc("/api/ws", wsHub.HandleWS)
+ mux.HandleFunc("/api/containers/install", containers.InstallContainer)
+ mux.HandleFunc("/api/actions", actions.RunAction)
+ mux.HandleFunc("/api/registry", handlers.GetRegistry)
+
+ if os.Getenv("DEV_MODE") != "true" {
+ frontendDir, err := fs.Sub(embeddedFrontend, "frontend/dist")
+ if err != nil {
+ log.Fatalf("Failed to parse embedded frontend subtree: %v", err)
+ }
+ mux.Handle("/", http.FileServer(http.FS(frontendDir)))
+ }
+
+ port := os.Getenv("PORT")
+ if port == "" {
+ port = "8080"
+ }
+
+ server := &http.Server{
+ Addr: ":" + port, // Use the variable here
+ Handler: mux,
+ }
+
+ log.Printf("Server starting on port %s...", port)
+ if err := server.ListenAndServe(); err != nil {
+ log.Fatal(err)
+ }
+}