const express = require("express");
const cors = require("cors");
const { Pool } = require("pg");

const app = express();
app.use(cors());
app.use(express.json());

const pool = new Pool({
  host: "db",
  user: "user",
  password: "password",
  database: "mydb",
  port: 5432,
});

pool.query("CREATE TABLE IF NOT EXISTS names (id SERIAL PRIMARY KEY, name TEXT);");

app.post("/add", async (req, res) => {
  const { name } = req.body;
  await pool.query("INSERT INTO names(name) VALUES($1)", [name]);
  res.send("Added");
});

app.get("/names", async (req, res) => {
  const result = await pool.query("SELECT * FROM names");
  res.json(result.rows);
});

app.listen(3000, () => console.log("Server running"));
app.get("/", (req, res) => {
  res.send("Backend is running 🚀");
});