Add Plugin Handler and Enhance SQLite Wrapper

apps/docknode/.dockerignore

@@ -0,0 +1,7 @@
+.gitignore
+.dockstacks_instance_uuid.txt
+dockerfile
+.env
+.prod.env
+.dev.envw
+node_modules

apps/docknode/.dockstacks_instance_uuid.txt

@@ -0,0 +1 @@
+34ca4e88-4ffc-40b5-b72e-592854728b5a

apps/docknode/.gitignore

@@ -0,0 +1,42 @@
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+/.pnp
+.pnp.js
+
+# testing
+/coverage
+
+# next.js
+/.next/
+/out/
+
+# production
+/build
+
+# misc
+.DS_Store
+*.pem
+
+# debug
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# local env files
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+# vercel
+.vercel
+
+**/*.trace
+**/*.zip
+**/*.tar.gz
+**/*.tgz
+**/*.log
+package-lock.json
+**/*.bun

apps/docknode/README.md

@@ -0,0 +1,15 @@
+# Elysia with Bun runtime
+
+## Getting Started
+To get started with this template, simply paste this command into your terminal:
+```bash
+bun create elysia ./elysia-example
+```
+
+## Development
+To start the development server run:
+```bash
+bun run dev
+```
+
+Open http://localhost:3000/ with your browser to see the result.

apps/docknode/dockerfile

@@ -0,0 +1,8 @@
+FROM oven/bun:1.3 as BASE
+
+FROM BASE AS BUNINSTALL
+WORKDIR "/tmp/docknode-installer"
+COPY . /tmp 
+
+RUN bun install
+RUN bun run build

apps/docknode/environment.d.ts

@@ -0,0 +1,9 @@
+declare module "bun" {
+  interface Env {
+    DOCKNODE_DOCKSTACK_AUTH_PSK?: string;
+    DOCKNODE_DOCKSTACK_DEV_AUTH?: string;
+    DOCKNODE_DOCKSTACK_AUTH_PRIORITY: string;
+    PORT?: string;
+    NODE_ENV: "development" | "production" | "test";
+  }
+}

apps/docknode/package.json

@@ -0,0 +1,21 @@
+{
+  "name": "docknode",
+  "version": "1.0.50",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1",
+    "install": "bunx turbo install",
+    "dev": "bun run --watch src/index.ts",
+    "build": "bun run src/build.ts"
+  },
+  "dependencies": {
+    "@dockstat/logger": "workspace:*",
+    "@elysiajs/openapi": "^1.4.0",
+    "@tqman/nice-logger": "^1.1.1",
+    "elysia": "1.4.12",
+    "elysia-basic-auth": "^1.0.7"
+  },
+  "devDependencies": {
+    "bun-types": "latest"
+  },
+  "module": "src/index.js"
+}

apps/docknode/src/builder.ts

@@ -0,0 +1,14 @@
+import { build } from "bun";
+
+await build({
+  sourcemap: "linked",
+  compile: false,
+  entrypoints: ["./index.ts"],
+  minify: {
+    identifiers: false,
+    syntax: true,
+    whitespace: true,
+    keepNames: false,
+  },
+  outdir: "./dist",
+});

apps/docknode/src/handlers/auth/auth.model.ts

@@ -0,0 +1,10 @@
+import Elysia, { t } from "elysia";
+
+const AuthObject = t.Object({
+  handler: t.String(),
+  key: t.String(),
+});
+
+export const authModel = new Elysia().model({ auth: AuthObject });
+
+export type AuthObjectType = typeof AuthObject.static;

apps/docknode/src/handlers/dockstack/index.ts

@@ -0,0 +1,65 @@
+import { rm } from "node:fs/promises";
+import Logger from "@dockstat/logger";
+import openapi from "@elysiajs/openapi";
+import Elysia, { t } from "elysia";
+import { getStackDir, writeDockerCompose } from "./src/deployStack";
+
+export const dockStackLogger = new Logger("DockStack", ["DockNode"]);
+
+export const DockStackHandler = new Elysia({ prefix: "/dockstack" })
+  .use(
+    openapi({
+      path: "/docs",
+      provider: "scalar",
+    })
+  )
+  .post(
+    "/deploy",
+    async ({ body }) => {
+      try {
+        await writeDockerCompose(body.id, body.name, body.vars, body.data);
+        return new Response(
+          JSON.stringify({
+            status: "200",
+            message: `Succesfully deployed ${body.name}`,
+          })
+        );
+      } catch (error) {
+        return new Response(
+          JSON.stringify({
+            status: "400",
+            message: "An error occured while writing the Docker Compose file!",
+            error: `${error}`,
+          })
+        );
+      }
+    },
+    {
+      body: t.Object({
+        id: t.Number(),
+        name: t.String(),
+        data: t.String(),
+        vars: t.Record(t.String(), t.String()),
+      }),
+    }
+  )
+  .delete(
+    "/delete",
+    async ({ body }) => {
+      try {
+        await rm(getStackDir(body.id, body.name), { recursive: true });
+      } catch (error) {
+        if ((error as { code: string }).code === "ENOENT") {
+          console.log("Directory doesn't exist");
+        } else {
+          throw error;
+        }
+      }
+    },
+    {
+      body: t.Object({
+        id: t.Number(),
+        name: t.String(),
+      }),
+    }
+  );

apps/docknode/src/handlers/dockstack/src/deployStack.ts

@@ -0,0 +1,41 @@
+import { dockStackLogger } from "..";
+
+export const STACK_DIR = "./stacks" as const;
+
+export async function writeDockerCompose(
+  stackId: number,
+  stackName: string,
+  vars: Record<string, string>,
+  compose: string
+) {
+  try {
+    dockStackLogger.info(`Writing Docker Compose of ${stackName}`);
+    const stackDir = getStackDir(stackId, stackName);
+
+    const YamlDump = Bun.YAML.parse(parseVars(vars, compose)) as string;
+
+    return await Bun.write(`${stackDir}/docker-compose.yaml`, YamlDump);
+  } catch (error) {
+    throw new Error(`Could not write Docker Compose file ${error}`);
+  }
+}
+
+function parseVars(deployConfig: Record<string, string>, data: string) {
+  data.replace(/{{(.*?)}}/g, (_, key) => deployConfig[key.trim()] ?? "");
+
+  const matches = data.search(/{{(.*?)}}/g);
+
+  if (matches <= 0) {
+    throw new Error(
+      "Not all variables were provided values in the deploy config"
+    );
+  }
+
+  return data;
+}
+
+export function getStackDir(stackId: number, stackName: string) {
+  const pId = Number(stackId);
+  const pSN = String(stackName).replaceAll("../", "").replaceAll("..\\", "");
+  return `./stacks/stackId${pId}-stackName${pSN}`;
+}

apps/docknode/src/handlers/dockstack/src/types.ts

@@ -0,0 +1,50 @@
+export interface BaseResponse {
+  success: boolean;
+  message: string;
+  timestamp: string;
+}
+
+export interface SuccessResponse<T = undefined> extends BaseResponse {
+  success: true;
+  data?: T;
+}
+
+export interface ErrorResponse extends BaseResponse {
+  success: false;
+  error: {
+    code: string;
+    details?: string;
+  };
+}
+
+export const ErrorCodes = {
+  // Authentication errors
+  UNAUTHORIZED: "UNAUTHORIZED",
+  INVALID_TOKEN: "INVALID_TOKEN",
+  MISSING_CREDENTIALS: "MISSING_CREDENTIALS",
+  INVALID_CREDENTIALS: "INVALID_CREDENTIALS",
+
+  // Validation errors
+  VALIDATION_ERROR: "VALIDATION_ERROR",
+
+  // Server errors
+  INTERNAL_SERVER_ERROR: "INTERNAL_SERVER_ERROR",
+  SERVICE_UNAVAILABLE: "SERVICE_UNAVAILABLE",
+
+  // Client errors
+  BAD_REQUEST: "BAD_REQUEST",
+  NOT_FOUND: "NOT_FOUND",
+  FORBIDDEN: "FORBIDDEN",
+} as const;
+
+// HTTP Status Codes
+export const HttpStatus = {
+  OK: 200,
+  CREATED: 201,
+  BAD_REQUEST: 400,
+  UNAUTHORIZED: 401,
+  FORBIDDEN: 403,
+  NOT_FOUND: 404,
+  INTERNAL_SERVER_ERROR: 500,
+  SERVICE_UNAVAILABLE: 503,
+} as const;

apps/docknode/src/handlers/dockstack/src/utils/constants.ts

@@ -0,0 +1,3 @@
+// src/constants.ts
+export const INSTANCE_UUID_PATH = "./.dockstacks_instance_uuid.txt";
+export const INSTANCE_UUID_BUN_FILE = Bun.file(INSTANCE_UUID_PATH);