server initial commit

server/models/db.js

@@ -0,0 +1,31 @@
+import dotenv from 'dotenv';
+import {Pool} from 'pg';
+dotenv.config();
+
+const pool = new Pool(process.env.DATABASE_URL ? {connectionString: process.env.DATABASE_URL} : {
+    user: process.env.DB_USER,
+    host: process.env.DB_HOST,
+    database: process.env.DB_NAME,
+    password: process.env.DB_PASSWORD,
+    port: parseInt(process.env.DB_PORT || '5432', 10),
+});
+
+
+/**
+ * Generic query function for PostgreSQL database.
+ * @param {string} text
+ * @param {any[]} [params]
+ * @return {Promise<any[]>}
+ */
+async function query(text, params= []) {
+    const start = Date.now();
+    const res = await pool.query(text, params).then(qr => qr);
+    const duration = Date.now() - start;
+    if (params) for (let i = 0; i < params.length; i++) text = text.replace("$".concat(String(i + 1)), params[i]);
+    console.log('executed query', {text, duration, rows: res.rowCount});
+    return res.rows;
+}
+export default {
+    pool,
+    query
+};

server/models/users.js

@@ -0,0 +1,23 @@
+import db from "./db.js";
+/** @typedef User
+ * @property {number} id - The unique identifier for the user.
+ * @property {string} username - The username of the user.
+ * @property {string} password - The hashed password of the user.
+ */
+
+/**
+ * Fetches all users from the database.
+ * @return {Promise<User[]>}
+ */
+const getAllUsers = async () => {
+    try {
+        return await db.query('SELECT * FROM users').then((users) => users);
+    } catch (error) {
+        console.error('Error fetching users:', error);
+        throw error;
+    }
+}
+
+export default {
+    getAllUsers
+}