198 lines
7.3 KiB
JavaScript
198 lines
7.3 KiB
JavaScript
const http = require("http");
|
|
const { URL } = require("url");
|
|
const { Pool } = require("pg");
|
|
|
|
function buildPgConfig() {
|
|
if (process.env.DATABASE_URL) {
|
|
return {
|
|
connectionString: process.env.DATABASE_URL,
|
|
ssl: process.env.PGSSLMODE === "require" ? { rejectUnauthorized: false } : undefined,
|
|
};
|
|
}
|
|
|
|
return {
|
|
host: process.env.PGHOST,
|
|
port: Number(process.env.PGPORT || "5432"),
|
|
user: process.env.PGUSER,
|
|
password: process.env.PGPASSWORD,
|
|
database: process.env.PGDATABASE || "postgres",
|
|
ssl: process.env.PGSSLMODE === "require" ? { rejectUnauthorized: false } : undefined,
|
|
};
|
|
}
|
|
|
|
const pool = new Pool(buildPgConfig());
|
|
|
|
async function ensureTable() {
|
|
await pool.query(
|
|
"CREATE TABLE IF NOT EXISTS nubes_test_table (id SERIAL PRIMARY KEY, test_data TEXT, created_at TIMESTAMP DEFAULT NOW())"
|
|
);
|
|
}
|
|
|
|
function parseForm(body) {
|
|
return body
|
|
.split("&")
|
|
.map((pair) => pair.split("="))
|
|
.reduce((acc, [key, value]) => {
|
|
acc[decodeURIComponent(key)] = decodeURIComponent((value || "").replace(/\+/g, " "));
|
|
return acc;
|
|
}, {});
|
|
}
|
|
|
|
function renderPage(rows, error) {
|
|
const errorHtml = error ? `<p style="color:red">${error}</p>` : "";
|
|
const rowsHtml = rows
|
|
.map(
|
|
(row) => `
|
|
<tr>
|
|
<td>${row.id}</td>
|
|
<td>
|
|
<form method="POST" action="/update">
|
|
<input type="hidden" name="id" value="${row.id}">
|
|
<input type="text" name="txt_content" value="${row.test_data}">
|
|
<button type="submit">save</button>
|
|
</form>
|
|
</td>
|
|
<td>
|
|
<form method="POST" action="/delete" onsubmit="return confirm('Delete?')">
|
|
<input type="hidden" name="id" value="${row.id}">
|
|
<button type="submit">delete</button>
|
|
</form>
|
|
</td>
|
|
</tr>`
|
|
)
|
|
.join("");
|
|
|
|
return `<!doctype html>
|
|
<html lang="en">
|
|
<head>
|
|
<meta charset="utf-8">
|
|
<title>NodeJS + Postgres Demo</title>
|
|
<link rel="icon" href="https://nubes.ru/themes/custom/nubes/images/nubes-ico.svg" type="image/svg+xml">
|
|
<style>
|
|
:root { --nubes-blue: #005BFF; --nubes-dark: #1A1A1A; --nubes-grey: #F8F9FA; --nubes-border: #E5E7EB; }
|
|
body { font-family: 'Segoe UI', Tahoma, sans-serif; margin: 0; padding: 0; background: var(--nubes-grey); color: var(--nubes-dark); }
|
|
.header-bg { position: sticky; top: 0; z-index: 1000; background: #fff; border-bottom: 1px solid var(--nubes-border); padding: 15px 0; box-shadow: 0 2px 10px rgba(0,0,0,0.05); }
|
|
.container { max-width: 1000px; margin: auto; padding: 0 20px; }
|
|
.header-content { display: flex; align-items: center; justify-content: space-between; }
|
|
.logo { height: 40px; }
|
|
.main-content { padding: 40px 0; }
|
|
.card { background: #fff; padding: 32px; border-radius: 16px; box-shadow: 0 4px 20px rgba(0,0,0,0.04); }
|
|
.btn { display: inline-flex; align-items: center; justify-content: center; cursor: pointer; padding: 12px 24px; border: none; border-radius: 8px; font-weight: 600; font-size: 14px; }
|
|
.btn-primary { background: var(--nubes-blue); color: #fff; }
|
|
.btn-action { padding: 12px; background: #fff; border: 1px solid var(--nubes-border); border-radius: 8px; font-size: 18px; line-height: 1; cursor: pointer; min-width: 44px; }
|
|
.btn-action:hover { background: var(--nubes-grey); border-color: var(--nubes-blue); }
|
|
.input-group { display: flex; gap: 12px; margin-bottom: 32px; }
|
|
input[type="text"] { flex-grow: 1; width: 100%; padding: 12px 16px; border: 1px solid var(--nubes-border); border-radius: 8px; font-size: 14px; }
|
|
table { width: 100%; border-collapse: collapse; }
|
|
th { text-align: left; padding: 16px; font-size: 12px; text-transform: uppercase; color: #6B7280; border-bottom: 1px solid var(--nubes-border); }
|
|
td { padding: 16px; border-bottom: 1px solid var(--nubes-border); }
|
|
tbody tr:nth-child(even) { background-color: #FAFBFC; }
|
|
tbody tr:hover { background-color: #F3F4F6; }
|
|
.id-cell { font-family: monospace; color: #9CA3AF; width: 60px; }
|
|
.actions-cell { display: flex; gap: 12px; width: 130px; }
|
|
</style>
|
|
</head>
|
|
<body>
|
|
<div class="header-bg">
|
|
<div class="container header-content">
|
|
<img src="https://nubes.ru/themes/custom/nubes_2025/logo.svg" alt="Nubes" class="logo">
|
|
<div style="font-size: 14px; color: var(--nubes-blue); font-weight: 600;">NodeJS + Postgres Demo</div>
|
|
</div>
|
|
</div>
|
|
<div class="container main-content">
|
|
<div class="card">
|
|
${errorHtml}
|
|
<form method="POST" action="/add" class="input-group" onsubmit="const btn=this.querySelector('button'); if(btn){btn.disabled=true; btn.textContent='Adding...';}">
|
|
<input type="text" name="txt_content" placeholder="New message" required>
|
|
<button type="submit" class="btn btn-primary">Add</button>
|
|
</form>
|
|
<table>
|
|
<thead><tr><th>ID</th><th>Content</th><th>Actions</th></tr></thead>
|
|
<tbody>
|
|
${rowsHtml}
|
|
</tbody>
|
|
</table>
|
|
</div>
|
|
</div>
|
|
</body>
|
|
</html>`;
|
|
}
|
|
|
|
async function handleRequest(req, res) {
|
|
const url = new URL(req.url, `http://${req.headers.host}`);
|
|
|
|
if (req.method === "GET" && url.pathname === "/healthz") {
|
|
res.writeHead(200, { "Content-Type": "text/plain" });
|
|
res.end("ok");
|
|
return;
|
|
}
|
|
|
|
if (req.method === "GET" && url.pathname === "/") {
|
|
try {
|
|
await ensureTable();
|
|
const { rows } = await pool.query(
|
|
"SELECT id, test_data FROM nubes_test_table ORDER BY id DESC LIMIT 20"
|
|
);
|
|
res.writeHead(200, { "Content-Type": "text/html; charset=utf-8" });
|
|
res.end(renderPage(rows));
|
|
} catch (err) {
|
|
res.writeHead(500, { "Content-Type": "text/html; charset=utf-8" });
|
|
res.end(renderPage([], err.message));
|
|
}
|
|
return;
|
|
}
|
|
|
|
if (req.method === "POST" && ["/add", "/update", "/delete"].includes(url.pathname)) {
|
|
let body = "";
|
|
req.on("data", (chunk) => {
|
|
body += chunk;
|
|
});
|
|
req.on("end", async () => {
|
|
const form = parseForm(body);
|
|
try {
|
|
await ensureTable();
|
|
if (url.pathname === "/add") {
|
|
const content = form.txt_content || "Node did it";
|
|
const { rows: lastRows } = await pool.query(
|
|
"SELECT test_data, created_at FROM nubes_test_table ORDER BY id DESC LIMIT 1"
|
|
);
|
|
const last = lastRows[0];
|
|
const isDuplicate =
|
|
last &&
|
|
last.test_data === content &&
|
|
Date.now() - new Date(last.created_at).getTime() < 3000;
|
|
|
|
if (!isDuplicate) {
|
|
await pool.query("INSERT INTO nubes_test_table (test_data) VALUES ($1)", [content]);
|
|
}
|
|
}
|
|
if (url.pathname === "/update") {
|
|
await pool.query("UPDATE nubes_test_table SET test_data=$1 WHERE id=$2", [
|
|
form.txt_content || "",
|
|
form.id,
|
|
]);
|
|
}
|
|
if (url.pathname === "/delete") {
|
|
await pool.query("DELETE FROM nubes_test_table WHERE id=$1", [form.id]);
|
|
}
|
|
res.writeHead(303, { Location: "/" });
|
|
res.end();
|
|
} catch (err) {
|
|
res.writeHead(500, { "Content-Type": "text/html; charset=utf-8" });
|
|
res.end(renderPage([], err.message));
|
|
}
|
|
});
|
|
return;
|
|
}
|
|
|
|
res.writeHead(404, { "Content-Type": "text/plain" });
|
|
res.end("Not found");
|
|
}
|
|
|
|
const port = process.env.PORT || 3000;
|
|
const server = http.createServer(handleRequest);
|
|
|
|
server.listen(port, () => {
|
|
console.log(`Server running on port ${port}`);
|
|
});
|