+ Nginx Proxy Manager is offline
+The app shell is installed, but management actions require a connection to the NPM server.
+ +
+ 
-
-
+
+ 
-
- 
+
+ 
-This project comes as a pre-built Docker image that enables you to easily forward to your websites
+This fork is maintained for our own deployment and is published as a pre-built Docker image at
+`registry.nightaye.top/nginx-proxy-manager:latest`. It enables you to easily forward to your websites
running at home or otherwise, including free SSL, without having to know too much about Nginx or Letsencrypt.
- [Quick Setup](#quick-setup)
@@ -61,7 +62,7 @@ I won't go into too much detail here, but here are the basics for someone new to
```yml
services:
app:
- image: 'docker.io/jc21/nginx-proxy-manager:latest'
+ image: 'registry.nightaye.top/nginx-proxy-manager:latest'
restart: unless-stopped
ports:
- '80:80'
@@ -72,7 +73,7 @@ services:
- ./letsencrypt:/etc/letsencrypt
```
-This is the bare minimum configuration required. See the [documentation](https://nginxproxymanager.com/setup/) for more.
+This is the bare minimum configuration required for our self-maintained image. Use a pinned tag such as `registry.nightaye.top/nginx-proxy-manager:2.15.1-nightwatcher.1` if you do not want automatic `latest` updates.
3. Bring up your stack by running
diff --git a/backend/internal/agent-client.js b/backend/internal/agent-client.js
new file mode 100644
index 0000000000..507618da64
--- /dev/null
+++ b/backend/internal/agent-client.js
@@ -0,0 +1,140 @@
+import errs from "../lib/error.js";
+import agentModel from "../models/agent.js";
+
+const tokenCache = new Map();
+
+function publicAgent(agent) {
+ return `${agent.name || agent.id} (${agent.url})`;
+}
+
+function trimBaseUrl(url) {
+ return String(url || "").replace(/\/$/, "");
+}
+
+async function parsePayload(response) {
+ const contentType = response.headers.get("content-type") || "";
+ if (contentType.includes("application/json")) {
+ return await response.json();
+ }
+ return await response.text();
+}
+
+async function request(agent, path, options = {}) {
+ const url = `${trimBaseUrl(agent.url)}${path}`;
+ const response = await fetch(url, options);
+ const payload = await parsePayload(response);
+ if (!response.ok) {
+ const message = payload?.error?.message || payload?.message || payload || `HTTP ${response.status}`;
+ const err = new errs.ValidationError(`Agent ${publicAgent(agent)} request failed: ${message}`);
+ err.status = response.status;
+ throw err;
+ }
+ return { response, payload };
+}
+
+async function getToken(agent, force = false) {
+ const cached = tokenCache.get(agent.id || agent.url);
+ if (!force && cached?.token && new Date(cached.expires).getTime() > Date.now() + 60000) {
+ return cached.token;
+ }
+
+ const { payload } = await request(agent, "/api/tokens", {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({
+ identity: agent.identity,
+ secret: agent.secret,
+ }),
+ });
+
+ if (payload?.requires_2fa) {
+ throw new errs.ValidationError(`Agent ${publicAgent(agent)} requires 2FA; use a non-2FA service account`);
+ }
+ if (!payload?.token) {
+ throw new errs.ValidationError(`Agent ${publicAgent(agent)} did not return a token`);
+ }
+ tokenCache.set(agent.id || agent.url, payload);
+ return payload.token;
+}
+
+function buildForwardPath(req) {
+ const query = new URLSearchParams();
+ for (const [key, value] of Object.entries(req.query || {})) {
+ if (["agent_id", "agent", "node"].includes(key)) {
+ continue;
+ }
+ if (Array.isArray(value)) {
+ value.forEach((item) => {
+ query.append(key, item);
+ });
+ } else if (typeof value !== "undefined" && value !== null) {
+ query.append(key, value);
+ }
+ }
+ const qs = query.toString();
+ return `/api${req.baseUrl}${req.path}${qs ? `?${qs}` : ""}`;
+}
+
+const internalAgentClient = {
+ findRequestedAgentId: (req) => req.query.agent_id || req.query.agent || req.query.node,
+
+ shouldForward: (req) => {
+ const agentId = internalAgentClient.findRequestedAgentId(req);
+ return agentId && agentId !== "local" && agentId !== "0";
+ },
+
+ getAgent: async (id) => {
+ const agent = await agentModel.query().where("id", Number.parseInt(id, 10)).andWhere("is_deleted", 0).first();
+ if (!agent?.id || !agent.enabled) {
+ throw new errs.ItemNotFoundError(`agent ${id}`);
+ }
+ return agent;
+ },
+
+ health: async (agent) => {
+ const { payload } = await request(agent, "/api", { method: "GET" });
+ await getToken(agent, true);
+ return {
+ ok: true,
+ version: payload.version,
+ setup: payload.setup,
+ checked_on: new Date().toISOString(),
+ };
+ },
+
+ forward: async (req, res) => {
+ const agent = await internalAgentClient.getAgent(internalAgentClient.findRequestedAgentId(req));
+ let token = await getToken(agent);
+ const headers = {
+ Authorization: `Bearer ${token}`,
+ };
+ let body;
+ if (!["GET", "HEAD"].includes(req.method)) {
+ headers["Content-Type"] = "application/json";
+ body = JSON.stringify(req.body || {});
+ }
+ const path = buildForwardPath(req);
+ let response = await fetch(`${trimBaseUrl(agent.url)}${path}`, {
+ method: req.method,
+ headers,
+ body,
+ });
+ if (response.status === 401) {
+ token = await getToken(agent, true);
+ response = await fetch(`${trimBaseUrl(agent.url)}${path}`, {
+ method: req.method,
+ headers: { ...headers, Authorization: `Bearer ${token}` },
+ body,
+ });
+ }
+ const payload = await parsePayload(response);
+ res.status(response.status);
+ if (typeof payload === "string") {
+ res.send(payload);
+ } else {
+ res.send(payload);
+ }
+ },
+};
+
+export default internalAgentClient;
diff --git a/backend/internal/agent.js b/backend/internal/agent.js
new file mode 100644
index 0000000000..ee17147698
--- /dev/null
+++ b/backend/internal/agent.js
@@ -0,0 +1,107 @@
+import errs from "../lib/error.js";
+import utils from "../lib/utils.js";
+import agentModel from "../models/agent.js";
+import internalAgentClient from "./agent-client.js";
+
+const omissions = () => ["is_deleted", "secret"];
+
+function normalizeUrl(url) {
+ try {
+ const parsed = new URL(url);
+ parsed.pathname = parsed.pathname.replace(/\/$/, "");
+ parsed.search = "";
+ parsed.hash = "";
+ return parsed.toString().replace(/\/$/, "");
+ } catch {
+ throw new errs.ValidationError("Invalid agent URL");
+ }
+}
+
+const internalAgent = {
+ getAll: async (access) => {
+ await access.can("users:list");
+ return agentModel
+ .query()
+ .where("is_deleted", 0)
+ .orderBy("name", "ASC")
+ .then(utils.omitRows(omissions()));
+ },
+
+ get: async (access, data) => {
+ await access.can("users:list");
+ const row = await agentModel.query().where("id", data.id).andWhere("is_deleted", 0).first();
+ if (!row?.id) {
+ throw new errs.ItemNotFoundError(data.id);
+ }
+ return utils.omitRow(omissions())(row);
+ },
+
+ create: async (access, data) => {
+ await access.can("users:list");
+ const row = await agentModel.query().insertAndFetch({
+ name: data.name,
+ url: normalizeUrl(data.url),
+ identity: data.identity,
+ secret: data.secret,
+ enabled: typeof data.enabled === "undefined" ? true : data.enabled,
+ meta: {},
+ });
+ return utils.omitRow(omissions())(row);
+ },
+
+ update: async (access, data) => {
+ await access.can("users:list");
+ const existing = await agentModel.query().where("id", data.id).andWhere("is_deleted", 0).first();
+ if (!existing?.id) {
+ throw new errs.ItemNotFoundError(data.id);
+ }
+ const patch = {};
+ ["name", "identity", "enabled"].forEach((key) => {
+ if (typeof data[key] !== "undefined") {
+ patch[key] = data[key];
+ }
+ });
+ if (typeof data.url !== "undefined") {
+ patch.url = normalizeUrl(data.url);
+ }
+ if (typeof data.secret === "string" && data.secret.length) {
+ patch.secret = data.secret;
+ }
+ await agentModel.query().where("id", data.id).patch(patch);
+ return internalAgent.get(access, { id: data.id });
+ },
+
+ delete: async (access, data) => {
+ await access.can("users:list");
+ const existing = await agentModel.query().where("id", data.id).andWhere("is_deleted", 0).first();
+ if (!existing?.id) {
+ throw new errs.ItemNotFoundError(data.id);
+ }
+ await agentModel.query().where("id", data.id).patch({ is_deleted: 1 });
+ return true;
+ },
+
+ test: async (access, data) => {
+ await access.can("users:list");
+ let agent;
+ if (data.id) {
+ agent = await agentModel.query().where("id", data.id).andWhere("is_deleted", 0).first();
+ } else {
+ agent = {
+ url: normalizeUrl(data.url),
+ identity: data.identity,
+ secret: data.secret,
+ };
+ }
+ if (!agent) {
+ throw new errs.ItemNotFoundError(data.id);
+ }
+ const result = await internalAgentClient.health(agent);
+ if (data.id) {
+ await agentModel.query().where("id", data.id).patch({ meta: { last_test: result } });
+ }
+ return result;
+ },
+};
+
+export default internalAgent;
diff --git a/backend/lib/express/agent-forward.js b/backend/lib/express/agent-forward.js
new file mode 100644
index 0000000000..85ad4fbbd5
--- /dev/null
+++ b/backend/lib/express/agent-forward.js
@@ -0,0 +1,18 @@
+import internalAgentClient from "../../internal/agent-client.js";
+import { debug, express as logger } from "../../logger.js";
+
+export default function () {
+ return async (req, res, next) => {
+ if (!internalAgentClient.shouldForward(req)) {
+ next();
+ return;
+ }
+ try {
+ await res.locals.access.can("users:list");
+ await internalAgentClient.forward(req, res);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.originalUrl}: ${err}`);
+ next(err);
+ }
+ };
+}
diff --git a/backend/migrations/20260520160000_agent_table.js b/backend/migrations/20260520160000_agent_table.js
new file mode 100644
index 0000000000..7383315478
--- /dev/null
+++ b/backend/migrations/20260520160000_agent_table.js
@@ -0,0 +1,33 @@
+import { migrate as logger } from "../logger.js";
+
+const migrateName = "agent-table";
+
+const up = (knex) => {
+ logger.info(`[${migrateName}] Migrating Up...`);
+ return knex.schema.hasTable("agent").then((exists) => {
+ if (exists) {
+ logger.info(`[${migrateName}] agent Table already exists`);
+ return;
+ }
+ return knex.schema.createTable("agent", (table) => {
+ table.increments().primary();
+ table.dateTime("created_on").notNull();
+ table.dateTime("modified_on").notNull();
+ table.integer("is_deleted").notNull().unsigned().defaultTo(0);
+ table.integer("enabled").notNull().unsigned().defaultTo(1);
+ table.string("name").notNull();
+ table.string("url").notNull();
+ table.string("identity").notNull();
+ table.text("secret").notNull();
+ table.json("meta").notNull();
+ table.unique("url");
+ });
+ });
+};
+
+const down = (knex) => {
+ logger.warn(`[${migrateName}] Migrating Down...`);
+ return knex.schema.dropTableIfExists("agent");
+};
+
+export { up, down };
diff --git a/backend/models/agent.js b/backend/models/agent.js
new file mode 100644
index 0000000000..86eb239ff2
--- /dev/null
+++ b/backend/models/agent.js
@@ -0,0 +1,49 @@
+import { Model } from "objection";
+import db from "../db.js";
+import { convertBoolFieldsToInt, convertIntFieldsToBool } from "../lib/helpers.js";
+import now from "./now_helper.js";
+
+Model.knex(db());
+
+const boolFields = ["is_deleted", "enabled"];
+
+class Agent extends Model {
+ $beforeInsert() {
+ this.created_on = now();
+ this.modified_on = now();
+ if (typeof this.enabled === "undefined") {
+ this.enabled = true;
+ }
+ if (typeof this.meta === "undefined") {
+ this.meta = {};
+ }
+ }
+
+ $beforeUpdate() {
+ this.modified_on = now();
+ }
+
+ $parseDatabaseJson(json) {
+ const thisJson = super.$parseDatabaseJson(json);
+ return convertIntFieldsToBool(thisJson, boolFields);
+ }
+
+ $formatDatabaseJson(json) {
+ const thisJson = convertBoolFieldsToInt(json, boolFields);
+ return super.$formatDatabaseJson(thisJson);
+ }
+
+ static get name() {
+ return "Agent";
+ }
+
+ static get tableName() {
+ return "agent";
+ }
+
+ static get jsonAttributes() {
+ return ["meta"];
+ }
+}
+
+export default Agent;
diff --git a/backend/routes/agents.js b/backend/routes/agents.js
new file mode 100644
index 0000000000..819ebb4888
--- /dev/null
+++ b/backend/routes/agents.js
@@ -0,0 +1,98 @@
+import express from "express";
+import internalAgent from "../internal/agent.js";
+import jwtdecode from "../lib/express/jwt-decode.js";
+import { debug, express as logger } from "../logger.js";
+
+const router = express.Router({
+ caseSensitive: true,
+ strict: true,
+ mergeParams: true,
+});
+
+router
+ .route("/")
+ .options((_, res) => res.sendStatus(204))
+ .all(jwtdecode())
+ .get(async (req, res, next) => {
+ try {
+ const rows = await internalAgent.getAll(res.locals.access);
+ res.status(200).send(rows);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.path}: ${err}`);
+ next(err);
+ }
+ })
+ .post(async (req, res, next) => {
+ try {
+ const result = await internalAgent.create(res.locals.access, req.body || {});
+ res.status(201).send(result);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.path}: ${err}`);
+ next(err);
+ }
+ });
+
+router
+ .route("/test")
+ .options((_, res) => res.sendStatus(204))
+ .all(jwtdecode())
+ .post(async (req, res, next) => {
+ try {
+ const result = await internalAgent.test(res.locals.access, req.body || {});
+ res.status(200).send(result);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.path}: ${err}`);
+ next(err);
+ }
+ });
+
+router
+ .route("/:agent_id")
+ .options((_, res) => res.sendStatus(204))
+ .all(jwtdecode())
+ .get(async (req, res, next) => {
+ try {
+ const row = await internalAgent.get(res.locals.access, { id: Number.parseInt(req.params.agent_id, 10) });
+ res.status(200).send(row);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.path}: ${err}`);
+ next(err);
+ }
+ })
+ .put(async (req, res, next) => {
+ try {
+ const result = await internalAgent.update(res.locals.access, {
+ ...(req.body || {}),
+ id: Number.parseInt(req.params.agent_id, 10),
+ });
+ res.status(200).send(result);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.path}: ${err}`);
+ next(err);
+ }
+ })
+ .delete(async (req, res, next) => {
+ try {
+ const result = await internalAgent.delete(res.locals.access, { id: Number.parseInt(req.params.agent_id, 10) });
+ res.status(200).send(result);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.path}: ${err}`);
+ next(err);
+ }
+ });
+
+router
+ .route("/:agent_id/test")
+ .options((_, res) => res.sendStatus(204))
+ .all(jwtdecode())
+ .post(async (req, res, next) => {
+ try {
+ const result = await internalAgent.test(res.locals.access, { id: Number.parseInt(req.params.agent_id, 10) });
+ res.status(200).send(result);
+ } catch (err) {
+ debug(logger, `${req.method.toUpperCase()} ${req.path}: ${err}`);
+ next(err);
+ }
+ });
+
+export default router;
diff --git a/backend/routes/main.js b/backend/routes/main.js
index a308ea6179..c93d2cbddb 100644
--- a/backend/routes/main.js
+++ b/backend/routes/main.js
@@ -4,6 +4,7 @@ import errs from "../lib/error.js";
import logRequest from "../lib/express/log-request.js";
import pjson from "../package.json" with { type: "json" };
import { isSetup } from "../setup.js";
+import agentsRoutes from "./agents.js";
import auditLogRoutes from "./audit-log.js";
import ciRoutes from "./ci.js";
import accessListsRoutes from "./nginx/access_lists.js";
@@ -49,6 +50,7 @@ router.get("/", async (_, res /*, next*/) => {
router.use("/schema", schemaRoutes);
router.use("/tokens", tokensRoutes);
router.use("/users", usersRoutes);
+router.use("/agents", agentsRoutes);
router.use("/audit-log", auditLogRoutes);
router.use("/reports", reportsRoutes);
router.use("/settings", settingsRoutes);
diff --git a/backend/routes/nginx/access_lists.js b/backend/routes/nginx/access_lists.js
index 9dfcf7ec31..0a2228e1b2 100644
--- a/backend/routes/nginx/access_lists.js
+++ b/backend/routes/nginx/access_lists.js
@@ -1,5 +1,6 @@
import express from "express";
import internalAccessList from "../../internal/access-list.js";
+import agentForward from "../../lib/express/agent-forward.js";
import jwtdecode from "../../lib/express/jwt-decode.js";
import apiValidator from "../../lib/validator/api.js";
import validator from "../../lib/validator/index.js";
@@ -21,6 +22,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/access-lists
@@ -81,6 +83,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/access-lists/123
diff --git a/backend/routes/nginx/certificates.js b/backend/routes/nginx/certificates.js
index 99f429b446..a3e503b1a6 100644
--- a/backend/routes/nginx/certificates.js
+++ b/backend/routes/nginx/certificates.js
@@ -2,6 +2,7 @@ import express from "express";
import dnsPlugins from "../../certbot/dns-plugins.json" with { type: "json" };
import internalCertificate from "../../internal/certificate.js";
import errs from "../../lib/error.js";
+import agentForward from "../../lib/express/agent-forward.js";
import jwtdecode from "../../lib/express/jwt-decode.js";
import apiValidator from "../../lib/validator/api.js";
import validator from "../../lib/validator/index.js";
@@ -23,6 +24,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/certificates
@@ -95,6 +97,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/certificates/dns-providers
@@ -131,6 +134,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/certificates/test-http
@@ -167,6 +171,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/certificates/validate
@@ -201,6 +206,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/certificates/123
@@ -269,6 +275,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/certificates/123/upload
@@ -304,6 +311,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/certificates/123/renew
@@ -334,6 +342,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/certificates/123/download
diff --git a/backend/routes/nginx/dead_hosts.js b/backend/routes/nginx/dead_hosts.js
index 31f7043635..c631996e0c 100644
--- a/backend/routes/nginx/dead_hosts.js
+++ b/backend/routes/nginx/dead_hosts.js
@@ -1,5 +1,6 @@
import express from "express";
import internalDeadHost from "../../internal/dead-host.js";
+import agentForward from "../../lib/express/agent-forward.js";
import jwtdecode from "../../lib/express/jwt-decode.js";
import apiValidator from "../../lib/validator/api.js";
import validator from "../../lib/validator/index.js";
@@ -21,6 +22,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/dead-hosts
@@ -81,6 +83,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/dead-hosts/123
@@ -163,6 +166,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/dead-hosts/123/enable
@@ -190,6 +194,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/dead-hosts/123/disable
diff --git a/backend/routes/nginx/proxy_hosts.js b/backend/routes/nginx/proxy_hosts.js
index 7045a195cc..a173b0dfb3 100644
--- a/backend/routes/nginx/proxy_hosts.js
+++ b/backend/routes/nginx/proxy_hosts.js
@@ -1,5 +1,6 @@
import express from "express";
import internalProxyHost from "../../internal/proxy-host.js";
+import agentForward from "../../lib/express/agent-forward.js";
import jwtdecode from "../../lib/express/jwt-decode.js";
import apiValidator from "../../lib/validator/api.js";
import validator from "../../lib/validator/index.js";
@@ -21,6 +22,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/proxy-hosts
@@ -81,6 +83,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/proxy-hosts/123
@@ -163,6 +166,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/proxy-hosts/123/enable
@@ -190,6 +194,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/proxy-hosts/123/disable
diff --git a/backend/routes/nginx/redirection_hosts.js b/backend/routes/nginx/redirection_hosts.js
index 9b5b5b374d..b06680c356 100644
--- a/backend/routes/nginx/redirection_hosts.js
+++ b/backend/routes/nginx/redirection_hosts.js
@@ -1,5 +1,6 @@
import express from "express";
import internalRedirectionHost from "../../internal/redirection-host.js";
+import agentForward from "../../lib/express/agent-forward.js";
import jwtdecode from "../../lib/express/jwt-decode.js";
import apiValidator from "../../lib/validator/api.js";
import validator from "../../lib/validator/index.js";
@@ -21,6 +22,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/redirection-hosts
@@ -81,6 +83,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* GET /api/nginx/redirection-hosts/123
@@ -166,6 +169,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/redirection-hosts/123/enable
@@ -193,6 +197,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/redirection-hosts/123/disable
diff --git a/backend/routes/nginx/streams.js b/backend/routes/nginx/streams.js
index dec2e1a13f..b1cb660470 100644
--- a/backend/routes/nginx/streams.js
+++ b/backend/routes/nginx/streams.js
@@ -1,5 +1,6 @@
import express from "express";
import internalStream from "../../internal/stream.js";
+import agentForward from "../../lib/express/agent-forward.js";
import jwtdecode from "../../lib/express/jwt-decode.js";
import apiValidator from "../../lib/validator/api.js";
import validator from "../../lib/validator/index.js";
@@ -20,7 +21,8 @@ router
.options((_, res) => {
res.sendStatus(204);
})
- .all(jwtdecode()) // preferred so it doesn't apply to nonexistent routes
+ .all(jwtdecode())
+ .all(agentForward()) // preferred so it doesn't apply to nonexistent routes
/**
* GET /api/nginx/streams
@@ -80,7 +82,8 @@ router
.options((_, res) => {
res.sendStatus(204);
})
- .all(jwtdecode()) // preferred so it doesn't apply to nonexistent routes
+ .all(jwtdecode())
+ .all(agentForward()) // preferred so it doesn't apply to nonexistent routes
/**
* GET /api/nginx/streams/123
@@ -163,6 +166,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/streams/123/enable
@@ -190,6 +194,7 @@ router
res.sendStatus(204);
})
.all(jwtdecode())
+ .all(agentForward())
/**
* POST /api/nginx/streams/123/disable
diff --git a/frontend/index.html b/frontend/index.html
index 08c760964f..f70e667ed0 100644
--- a/frontend/index.html
+++ b/frontend/index.html
@@ -5,6 +5,10 @@
+ The app shell is installed, but management actions require a connection to the NPM server.
+ ++ Add remote Nginx Proxy Manager instances. The proxy host page can then switch nodes and forward + operations to the selected instance. +
+| Name | URL | Login | Status | Actions |
|---|---|---|---|---|
| {agent.name} | +{agent.url} | +{agent.identity} | +{agent.meta?.lastTest?.ok ? "online" : agent.enabled ? "unknown" : "disabled"} | ++ + + | +