Spaces:
Runtime error
Runtime error
| ; | |
| var __importDefault = (this && this.__importDefault) || function (mod) { | |
| return (mod && mod.__esModule) ? mod : { "default": mod }; | |
| }; | |
| Object.defineProperty(exports, "__esModule", { value: true }); | |
| const express_1 = __importDefault(require("express")); | |
| const pg_1 = require("pg"); | |
| const fs_1 = __importDefault(require("fs")); | |
| const path_1 = __importDefault(require("path")); | |
| const app = (0, express_1.default)(); | |
| const port = 3000; | |
| app.use(express_1.default.json()); | |
| app.use(express_1.default.static("public")); | |
| let caCert; | |
| try { | |
| caCert = fs_1.default.readFileSync(path_1.default.join(__dirname, "ca.pem"), "utf8"); | |
| console.log("CA certificate loaded successfully."); | |
| } | |
| catch (error) { | |
| console.error("Failed to load CA certificate:", error.message); | |
| process.exit(1); | |
| } | |
| const pool = new pg_1.Pool({ | |
| connectionString: "postgres://avnadmin:AVNS_BsUJEz_hcswptIqk5yR@postgres-bs-bebb.l.aivencloud.com:21759/defaultdb", | |
| ssl: { | |
| ca: caCert, | |
| rejectUnauthorized: true, | |
| checkServerIdentity: () => undefined, | |
| }, | |
| }); | |
| pool.connect((err, client, release) => { | |
| if (err) { | |
| console.error("Database connection error:", err.message); | |
| process.exit(1); | |
| } | |
| console.log("Successfully connected to PostgreSQL database."); | |
| release(); | |
| }); | |
| app.post("/save", async (req, res) => { | |
| const { date, technology, entries } = req.body; | |
| const client = await pool.connect(); | |
| try { | |
| await client.query("BEGIN"); | |
| for (const entry of entries) { | |
| await client.query("INSERT INTO daily_reports (report_date, technology, sl_no, work_completed, from_time, to_time) VALUES ($1, $2, $3, $4, $5, $6)", [ | |
| date, | |
| technology, | |
| entry.sl_no, | |
| entry.work_completed, | |
| entry.from_time, | |
| entry.to_time, | |
| ]); | |
| } | |
| await client.query("COMMIT"); | |
| res.json({ success: true }); | |
| } | |
| catch (error) { | |
| await client.query("ROLLBACK"); | |
| res.status(500).json({ error: error.message }); | |
| } | |
| finally { | |
| client.release(); | |
| } | |
| }); | |
| app.get("/fetch", async (req, res) => { | |
| const { date } = req.query; | |
| try { | |
| const result = await pool.query("SELECT * FROM daily_reports WHERE report_date = $1 ORDER BY sl_no ASC", [date]); | |
| res.json(result.rows); | |
| } | |
| catch (error) { | |
| res.status(500).json({ error: error.message }); | |
| } | |
| }); | |
| app.listen(port, () => { | |
| console.log(`Server running on http://localhost:${port}`); | |
| }); | |