mirror of
https://github.com/NginxProxyManager/nginx-proxy-manager.git
synced 2026-02-26 20:35:21 +00:00
105 lines
3.0 KiB
JavaScript
Executable File
105 lines
3.0 KiB
JavaScript
Executable File
#!/usr/bin/env node
|
|
|
|
import * as process from "node:process"; // Use the node: protocol for built-ins
|
|
import internalNginx from "../internal/nginx.js";
|
|
import { castJsonIfNeed } from "../lib/helpers.js";
|
|
import { global as logger } from "../logger.js";
|
|
import deadHostModel from "../models/dead_host.js";
|
|
import proxyHostModel from "../models/proxy_host.js";
|
|
import redirectionHostModel from "../models/redirection_host.js";
|
|
import streamModel from "../models/stream.js";
|
|
|
|
const args = process.argv.slice(2);
|
|
const UNATTENDED = args.includes("-y") || args.includes("--yes");
|
|
if (args.includes("--help")) {
|
|
console.log("Usage: ./regenerate-config [--help] [-y|--yes]");
|
|
}
|
|
|
|
// ask for the user to confirm the action if not in unattended mode
|
|
if (!UNATTENDED) {
|
|
const readline = await import("node:readline");
|
|
const rl = readline.createInterface({
|
|
input: process.stdin,
|
|
output: process.stdout,
|
|
});
|
|
|
|
const question = (query) =>
|
|
new Promise((resolve) => rl.question(query, resolve));
|
|
|
|
const answer = await question(
|
|
"This will iterate over all Hosts and regnerate their Nginx configs.\n\nAre you sure you want to proceed? (y/N) ",
|
|
);
|
|
rl.close();
|
|
|
|
if (answer.toLowerCase() !== "y") {
|
|
console.log("Aborting.");
|
|
process.exit(0);
|
|
}
|
|
}
|
|
|
|
// Let's do it.
|
|
|
|
// Proxy hosts
|
|
const proxyRows = await proxyHostModel
|
|
.query()
|
|
.where("is_deleted", 0)
|
|
.andWhere("enabled", 1)
|
|
.groupBy("id")
|
|
.allowGraph("[owner,access_list,certificate]")
|
|
.orderBy(castJsonIfNeed("domain_names"), "ASC");
|
|
|
|
for (const row of proxyRows) {
|
|
logger.info(
|
|
`Regenerating config for Proxy Host #${row.id}: ${row.domain_names.join(", ")}`,
|
|
);
|
|
await internalNginx.configure(proxyHostModel, "proxy_host", row);
|
|
}
|
|
|
|
// Redirection hosts
|
|
const redirectionRows = await redirectionHostModel
|
|
.query()
|
|
.where("is_deleted", 0)
|
|
.andWhere("enabled", 1)
|
|
.groupBy("id")
|
|
.allowGraph("[owner,access_list,certificate]")
|
|
.orderBy(castJsonIfNeed("domain_names"), "ASC");
|
|
|
|
for (const row of redirectionRows) {
|
|
logger.info(
|
|
`Regenerating config for Redirection Host #${row.id}: ${row.domain_names.join(", ")}`,
|
|
);
|
|
await internalNginx.configure(redirectionHostModel, "redirection_host", row);
|
|
}
|
|
|
|
// 404 hosts
|
|
const deadRows = await deadHostModel
|
|
.query()
|
|
.where("is_deleted", 0)
|
|
.andWhere("enabled", 1)
|
|
.groupBy("id")
|
|
.allowGraph("[owner,access_list,certificate]")
|
|
.orderBy(castJsonIfNeed("domain_names"), "ASC");
|
|
|
|
for (const row of deadRows) {
|
|
logger.info(
|
|
`Regenerating config for 404 Host #${row.id}: ${row.domain_names.join(", ")}`,
|
|
);
|
|
await internalNginx.configure(deadHostModel, "dead_host", row);
|
|
}
|
|
|
|
// Streams
|
|
const streamRows = await streamModel
|
|
.query()
|
|
.where("is_deleted", 0)
|
|
.andWhere("enabled", 1)
|
|
.groupBy("id")
|
|
.allowGraph("[owner,access_list,certificate]");
|
|
|
|
for (const row of streamRows) {
|
|
logger.info(`Regenerating config for Stream #${row.id}: ${row.incoming_port} -> ${row.forwarding_host}:${row.forwarding_port}`);
|
|
await internalNginx.configure(deadHostModel, "stream", row);
|
|
}
|
|
|
|
logger.success("Completed");
|
|
process.exit(0);
|