mirror of
https://github.com/fosrl/pangolin.git
synced 2026-03-07 03:06:40 +00:00
point the resource to the nextjs server for maintenance screen
This commit is contained in:
committed by
Owen Schwartz
parent
1d862131dd
commit
d82535d3e1
@@ -23,7 +23,6 @@ import { initCleanup } from "#dynamic/cleanup";
|
|||||||
import license from "#dynamic/license/license";
|
import license from "#dynamic/license/license";
|
||||||
import { initLogCleanupInterval } from "@server/lib/cleanupLogs";
|
import { initLogCleanupInterval } from "@server/lib/cleanupLogs";
|
||||||
import { fetchServerIp } from "@server/lib/serverIpService";
|
import { fetchServerIp } from "@server/lib/serverIpService";
|
||||||
import { startMaintenanceServer } from "./maintenance/maintenance-server.js";
|
|
||||||
|
|
||||||
async function startServers() {
|
async function startServers() {
|
||||||
await setHostMeta();
|
await setHostMeta();
|
||||||
@@ -56,8 +55,6 @@ async function startServers() {
|
|||||||
integrationServer = createIntegrationApiServer();
|
integrationServer = createIntegrationApiServer();
|
||||||
}
|
}
|
||||||
|
|
||||||
startMaintenanceServer();
|
|
||||||
|
|
||||||
await initCleanup();
|
await initCleanup();
|
||||||
|
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -218,7 +218,7 @@ export const configSchema = z
|
|||||||
file_mode: z.boolean().optional().default(false),
|
file_mode: z.boolean().optional().default(false),
|
||||||
pp_transport_prefix: z.string().optional().default("pp-transport-v"),
|
pp_transport_prefix: z.string().optional().default("pp-transport-v"),
|
||||||
maintenance_host: z.string().optional(),
|
maintenance_host: z.string().optional(),
|
||||||
maintenance_port: z.number().optional().default(8888)
|
maintenance_port: z.number().optional().default(3002)
|
||||||
})
|
})
|
||||||
.optional()
|
.optional()
|
||||||
.prefault({}),
|
.prefault({}),
|
||||||
|
|||||||
@@ -1,111 +0,0 @@
|
|||||||
import express from 'express';
|
|
||||||
import { db, resources } from '@server/db';
|
|
||||||
import { eq } from 'drizzle-orm';
|
|
||||||
import { generateMaintenanceHTML } from './maintenanceUI';
|
|
||||||
import config from '@server/lib/config';
|
|
||||||
import logger from '@server/logger';
|
|
||||||
import path from 'path';
|
|
||||||
import fs from 'fs';
|
|
||||||
|
|
||||||
const MAINTENANCE_DIR = path.join(process.cwd(), 'maintenance-pages');
|
|
||||||
if (!fs.existsSync(MAINTENANCE_DIR)) {
|
|
||||||
fs.mkdirSync(MAINTENANCE_DIR, { recursive: true });
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function generateMaintenanceFiles() {
|
|
||||||
logger.info('Regenerating maintenance page files');
|
|
||||||
const maintenanceResources = await db
|
|
||||||
.select()
|
|
||||||
.from(resources)
|
|
||||||
.where(eq(resources.maintenanceModeEnabled, true));
|
|
||||||
|
|
||||||
// Clear old files
|
|
||||||
const files = fs.readdirSync(MAINTENANCE_DIR);
|
|
||||||
files.forEach(file => {
|
|
||||||
if (file.startsWith('maintenance-')) {
|
|
||||||
fs.unlinkSync(path.join(MAINTENANCE_DIR, file));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
// Generate new files
|
|
||||||
for (const resource of maintenanceResources) {
|
|
||||||
if (resource.fullDomain && resource.http) {
|
|
||||||
const html = generateMaintenanceHTML(
|
|
||||||
resource.maintenanceTitle,
|
|
||||||
resource.maintenanceMessage,
|
|
||||||
resource.maintenanceEstimatedTime
|
|
||||||
);
|
|
||||||
|
|
||||||
const filename = `maintenance-${resource.fullDomain.replace(/\./g, '_')}.html`;
|
|
||||||
const filepath = path.join(MAINTENANCE_DIR, filename);
|
|
||||||
|
|
||||||
fs.writeFileSync(filepath, html, 'utf-8');
|
|
||||||
logger.info(`Generated maintenance page: ${filename}`);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
export function startMaintenanceServer() {
|
|
||||||
const app = express();
|
|
||||||
|
|
||||||
app.use(express.static(MAINTENANCE_DIR, {
|
|
||||||
setHeaders: (res) => {
|
|
||||||
res.setHeader('Cache-Control', 'no-cache, no-store, must-revalidate');
|
|
||||||
res.setHeader('Pragma', 'no-cache');
|
|
||||||
res.setHeader('Expires', '0');
|
|
||||||
}
|
|
||||||
}));
|
|
||||||
|
|
||||||
|
|
||||||
app.use(async (req, res) => {
|
|
||||||
const host = req.headers.host;
|
|
||||||
|
|
||||||
if (!host) {
|
|
||||||
return res.status(400).send("Missing Host header");
|
|
||||||
}
|
|
||||||
|
|
||||||
const hostname = host.split(':')[0];
|
|
||||||
const maintenanceFile = path.join(MAINTENANCE_DIR, `maintenance-${hostname}.html`);
|
|
||||||
|
|
||||||
if (fs.existsSync(maintenanceFile)) {
|
|
||||||
res.status(503)
|
|
||||||
.header('Content-Type', 'text/html; charset=utf-8')
|
|
||||||
.header('Retry-After', '3600')
|
|
||||||
.sendFile(maintenanceFile);
|
|
||||||
} else {
|
|
||||||
try {
|
|
||||||
const [resource] = await db
|
|
||||||
.select()
|
|
||||||
.from(resources)
|
|
||||||
.where(eq(resources.fullDomain, hostname));
|
|
||||||
|
|
||||||
if (resource?.maintenanceModeEnabled) {
|
|
||||||
const html = generateMaintenanceHTML(
|
|
||||||
resource.maintenanceTitle,
|
|
||||||
resource.maintenanceMessage,
|
|
||||||
resource.maintenanceEstimatedTime
|
|
||||||
);
|
|
||||||
|
|
||||||
return res.status(503)
|
|
||||||
.header('Content-Type', 'text/html; charset=utf-8')
|
|
||||||
.header('Retry-After', '3600')
|
|
||||||
.send(html);
|
|
||||||
}
|
|
||||||
} catch (error) {
|
|
||||||
logger.error(`Error serving maintenance page: ${error}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
res.status(404).send('Not found');
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
const port = config.getRawConfig().traefik?.maintenance_port || 8888;
|
|
||||||
|
|
||||||
app.listen(port, '0.0.0.0', () => {
|
|
||||||
logger.info(`Maintenance server listening on ${port}`);
|
|
||||||
|
|
||||||
generateMaintenanceFiles().catch(err => {
|
|
||||||
logger.error(`Failed to generate initial maintenance files: ${err}`);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
}
|
|
||||||
@@ -1,102 +0,0 @@
|
|||||||
|
|
||||||
function escapeHtml(text: string): string {
|
|
||||||
const map: Record<string, string> = {
|
|
||||||
'&': '&',
|
|
||||||
'<': '<',
|
|
||||||
'>': '>',
|
|
||||||
'"': '"',
|
|
||||||
"'": '''
|
|
||||||
};
|
|
||||||
return text.replace(/[&<>"']/g, (char) => map[char]);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
export function generateMaintenanceHTML(
|
|
||||||
title: string | null,
|
|
||||||
message: string | null,
|
|
||||||
estimatedTime: string | null
|
|
||||||
): string {
|
|
||||||
const safeTitle = escapeHtml(title || 'Service Temporarily Unavailable');
|
|
||||||
const safeMessage = escapeHtml(message || 'We are currently experiencing technical difficulties. Please check back soon.');
|
|
||||||
const safeEstimatedTime = estimatedTime ? escapeHtml(estimatedTime) : null;
|
|
||||||
|
|
||||||
return `<!DOCTYPE html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
|
||||||
<meta name="robots" content="noindex, nofollow">
|
|
||||||
<title>${safeTitle}</title>
|
|
||||||
<style>
|
|
||||||
* { margin: 0; padding: 0; box-sizing: border-box; }
|
|
||||||
body {
|
|
||||||
font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, 'Helvetica Neue', Arial, sans-serif;
|
|
||||||
display: flex;
|
|
||||||
justify-content: center;
|
|
||||||
align-items: center;
|
|
||||||
min-height: 100vh;
|
|
||||||
background: #fff;
|
|
||||||
color: #000;
|
|
||||||
padding: 1rem;
|
|
||||||
line-height: 1.6;
|
|
||||||
}
|
|
||||||
.container {
|
|
||||||
text-align: center;
|
|
||||||
padding: 3rem 2rem;
|
|
||||||
max-width: 600px;
|
|
||||||
background: rgba(255, 255, 255, 0.1);
|
|
||||||
backdrop-filter: blur(10px);
|
|
||||||
border-radius: 20px;
|
|
||||||
box-shadow: 0 8px 32px rgba(0, 0, 0, 0.1);
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.2);
|
|
||||||
}
|
|
||||||
.icon {
|
|
||||||
font-size: 4rem;
|
|
||||||
margin-bottom: 1.5rem;
|
|
||||||
animation: pulse 2s ease-in-out infinite;
|
|
||||||
}
|
|
||||||
@keyframes pulse {
|
|
||||||
0%, 100% { transform: scale(1); }
|
|
||||||
50% { transform: scale(1.1); }
|
|
||||||
}
|
|
||||||
h1 {
|
|
||||||
font-size: 2.5rem;
|
|
||||||
margin-bottom: 1rem;
|
|
||||||
font-weight: 700;
|
|
||||||
line-height: 1.2;
|
|
||||||
}
|
|
||||||
.message {
|
|
||||||
font-size: 1.2rem;
|
|
||||||
margin-bottom: 1rem;
|
|
||||||
opacity: 0.95;
|
|
||||||
}
|
|
||||||
.time {
|
|
||||||
margin-top: 1.5rem;
|
|
||||||
padding: 1rem;
|
|
||||||
background: rgba(255, 255, 255, 0.15);
|
|
||||||
border-radius: 10px;
|
|
||||||
font-size: 1rem;
|
|
||||||
font-weight: 500;
|
|
||||||
}
|
|
||||||
@media (max-width: 640px) {
|
|
||||||
h1 { font-size: 2rem; }
|
|
||||||
.message { font-size: 1rem; }
|
|
||||||
.container { padding: 2rem 1.5rem; }
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<div class="icon">🔧</div>
|
|
||||||
<h1>${safeTitle}</h1>
|
|
||||||
<p class="message">${safeMessage}</p>
|
|
||||||
${safeEstimatedTime ?
|
|
||||||
`<div class="time">
|
|
||||||
<strong>Estimated completion:</strong><br>
|
|
||||||
${safeEstimatedTime}
|
|
||||||
</div>`
|
|
||||||
: ''}
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>`;
|
|
||||||
}
|
|
||||||
@@ -87,6 +87,13 @@ export async function getTraefikConfig(
|
|||||||
headers: resources.headers,
|
headers: resources.headers,
|
||||||
proxyProtocol: resources.proxyProtocol,
|
proxyProtocol: resources.proxyProtocol,
|
||||||
proxyProtocolVersion: resources.proxyProtocolVersion,
|
proxyProtocolVersion: resources.proxyProtocolVersion,
|
||||||
|
|
||||||
|
maintenanceModeEnabled: resources.maintenanceModeEnabled,
|
||||||
|
maintenanceModeType: resources.maintenanceModeType,
|
||||||
|
maintenanceTitle: resources.maintenanceTitle,
|
||||||
|
maintenanceMessage: resources.maintenanceMessage,
|
||||||
|
maintenanceEstimatedTime: resources.maintenanceEstimatedTime,
|
||||||
|
|
||||||
// Target fields
|
// Target fields
|
||||||
targetId: targets.targetId,
|
targetId: targets.targetId,
|
||||||
targetEnabled: targets.enabled,
|
targetEnabled: targets.enabled,
|
||||||
@@ -220,7 +227,13 @@ export async function getTraefikConfig(
|
|||||||
rewritePathType: row.rewritePathType,
|
rewritePathType: row.rewritePathType,
|
||||||
priority: priority, // may be null, we fallback later
|
priority: priority, // may be null, we fallback later
|
||||||
domainCertResolver: row.domainCertResolver,
|
domainCertResolver: row.domainCertResolver,
|
||||||
preferWildcardCert: row.preferWildcardCert
|
preferWildcardCert: row.preferWildcardCert,
|
||||||
|
|
||||||
|
maintenanceModeEnabled: row.maintenanceModeEnabled,
|
||||||
|
maintenanceModeType: row.maintenanceModeType,
|
||||||
|
maintenanceTitle: row.maintenanceTitle,
|
||||||
|
maintenanceMessage: row.maintenanceMessage,
|
||||||
|
maintenanceEstimatedTime: row.maintenanceEstimatedTime,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -348,8 +361,8 @@ export async function getTraefikConfig(
|
|||||||
if (showMaintenancePage) {
|
if (showMaintenancePage) {
|
||||||
const maintenanceServiceName = `${key}-maintenance-service`;
|
const maintenanceServiceName = `${key}-maintenance-service`;
|
||||||
const maintenanceRouterName = `${key}-maintenance-router`;
|
const maintenanceRouterName = `${key}-maintenance-router`;
|
||||||
|
const rewriteMiddlewareName = `${key}-maintenance-rewrite`;
|
||||||
|
|
||||||
const maintenancePort = config.getRawConfig().traefik.maintenance_port || 8888;
|
|
||||||
const entrypointHttp = config.getRawConfig().traefik.http_entrypoint;
|
const entrypointHttp = config.getRawConfig().traefik.http_entrypoint;
|
||||||
const entrypointHttps = config.getRawConfig().traefik.https_entrypoint;
|
const entrypointHttps = config.getRawConfig().traefik.https_entrypoint;
|
||||||
|
|
||||||
@@ -367,7 +380,8 @@ export async function getTraefikConfig(
|
|||||||
: {})
|
: {})
|
||||||
};
|
};
|
||||||
|
|
||||||
const maintenanceHost = config.getRawConfig().traefik?.maintenance_host || 'pangolin';
|
const maintenancePort = config.getRawConfig().traefik?.maintenance_port;
|
||||||
|
const maintenanceHost = config.getRawConfig().traefik?.maintenance_host || 'dev_pangolin';
|
||||||
|
|
||||||
config_output.http.services[maintenanceServiceName] = {
|
config_output.http.services[maintenanceServiceName] = {
|
||||||
loadBalancer: {
|
loadBalancer: {
|
||||||
@@ -376,11 +390,23 @@ export async function getTraefikConfig(
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
// middleware to rewrite path to /maintenance-screen
|
||||||
|
if (!config_output.http.middlewares) {
|
||||||
|
config_output.http.middlewares = {};
|
||||||
|
}
|
||||||
|
|
||||||
|
config_output.http.middlewares[rewriteMiddlewareName] = {
|
||||||
|
replacePath: {
|
||||||
|
path: "/maintenance-screen"
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
const rule = `Host(\`${fullDomain}\`)`;
|
const rule = `Host(\`${fullDomain}\`)`;
|
||||||
|
|
||||||
config_output.http.routers[maintenanceRouterName] = {
|
config_output.http.routers[maintenanceRouterName] = {
|
||||||
entryPoints: [resource.ssl ? entrypointHttps : entrypointHttp],
|
entryPoints: [resource.ssl ? entrypointHttps : entrypointHttp],
|
||||||
service: maintenanceServiceName,
|
service: maintenanceServiceName,
|
||||||
|
middlewares: [rewriteMiddlewareName],
|
||||||
rule,
|
rule,
|
||||||
priority: 2000,
|
priority: 2000,
|
||||||
...(resource.ssl ? { tls } : {})
|
...(resource.ssl ? { tls } : {})
|
||||||
@@ -389,7 +415,7 @@ export async function getTraefikConfig(
|
|||||||
if (resource.ssl) {
|
if (resource.ssl) {
|
||||||
config_output.http.routers[`${maintenanceRouterName}-redirect`] = {
|
config_output.http.routers[`${maintenanceRouterName}-redirect`] = {
|
||||||
entryPoints: [entrypointHttp],
|
entryPoints: [entrypointHttp],
|
||||||
middlewares: [redirectHttpsMiddlewareName],
|
middlewares: [redirectHttpsMiddlewareName, rewriteMiddlewareName],
|
||||||
service: maintenanceServiceName,
|
service: maintenanceServiceName,
|
||||||
rule,
|
rule,
|
||||||
priority: 2000
|
priority: 2000
|
||||||
@@ -398,7 +424,6 @@ export async function getTraefikConfig(
|
|||||||
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
const domainParts = fullDomain.split(".");
|
const domainParts = fullDomain.split(".");
|
||||||
let wildCard;
|
let wildCard;
|
||||||
if (domainParts.length <= 2) {
|
if (domainParts.length <= 2) {
|
||||||
@@ -885,7 +910,7 @@ export async function getTraefikConfig(
|
|||||||
servers: [
|
servers: [
|
||||||
{
|
{
|
||||||
url: `http://${config.getRawConfig().server
|
url: `http://${config.getRawConfig().server
|
||||||
.internal_hostname
|
.internal_hostname
|
||||||
}:${config.getRawConfig().server.next_port}`
|
}:${config.getRawConfig().server.next_port}`
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
|
|||||||
53
src/app/maintenance-screen/page.tsx
Normal file
53
src/app/maintenance-screen/page.tsx
Normal file
@@ -0,0 +1,53 @@
|
|||||||
|
import { headers } from 'next/headers';
|
||||||
|
import { db } from '@server/db';
|
||||||
|
import { resources } from '@server/db';
|
||||||
|
import { eq } from 'drizzle-orm';
|
||||||
|
|
||||||
|
|
||||||
|
export default async function MaintenanceScreen() {
|
||||||
|
const headersList = await headers();
|
||||||
|
const host = headersList.get('host') || '';
|
||||||
|
const hostname = host.split(':')[0];
|
||||||
|
|
||||||
|
const [resource] = await db
|
||||||
|
.select()
|
||||||
|
.from(resources)
|
||||||
|
.where(eq(resources.fullDomain, hostname))
|
||||||
|
.limit(1);
|
||||||
|
|
||||||
|
|
||||||
|
const title = resource?.maintenanceTitle || 'Service Temporarily Unavailable';
|
||||||
|
const message = resource?.maintenanceMessage || 'We are currently experiencing technical difficulties. Please check back soon.';
|
||||||
|
const estimatedTime = resource?.maintenanceEstimatedTime;
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className="min-h-screen flex items-center justify-center bg-gray-100">
|
||||||
|
<div className="max-w-2xl w-full bg-white/10 backdrop-blur-lg rounded-3xl p-8 shadow-2xl border border-white/20">
|
||||||
|
<div className="text-center">
|
||||||
|
<div className="text-6xl mb-6 animate-pulse">
|
||||||
|
🔧
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<h1 className="text-4xl font-bold text-black mb-4">
|
||||||
|
{title}
|
||||||
|
</h1>
|
||||||
|
|
||||||
|
<p className="text-xl text-black/90 mb-6">
|
||||||
|
{message}
|
||||||
|
</p>
|
||||||
|
|
||||||
|
{estimatedTime && (
|
||||||
|
<div className="mt-8 p-4 bg-white/15 rounded-xl">
|
||||||
|
<p className="text-black font-semibold">
|
||||||
|
Estimated completion:
|
||||||
|
</p>
|
||||||
|
<p className="text-black/90 mt-2">
|
||||||
|
{estimatedTime}
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user