const mysql = require('mysql'); const config = require('../config'); // Set up database connection const connection = mysql.createConnection({ host: config.mysqlUri, user: process.env.MYSQL_USER, password: process.env.MYSQL_PASSWORD, database: config.mysqlDBName, }); // Connect to database connection.connect((err) => { if (err) { console.error(`Error connecting to database: ${err.stack}`); return; } console.log(`Connected to database as id ${connection.threadId}`); }); module.exports = { async getAllUsers() { return new Promise((resolve, reject) => { connection.query('SELECT * FROM users', (error, results, fields) => { if (error) { console.error(`Error retrieving users: ${error}`); reject(error); } else { resolve(results); } }); }); }, async addUser(user) { return new Promise((resolve, reject) => { connection.query('INSERT INTO users SET ?', user, (error, results, fields) => { if (error) { console.error(`Error adding user: ${error}`); reject(error); } else { resolve(results); } }); }); }, };