const mysql = require('mysql2/promise');

const pool = mysql.createPool({
  host:             process.env.DB_HOST || 'localhost',
  port:             parseInt(process.env.DB_PORT) || 3306,
  user:             process.env.DB_USER || 'wifiuser',
  password:         process.env.DB_PASS || 'wifipass',
  database:         process.env.DB_NAME || 'wifiplatform',
  waitForConnections: true,
  connectionLimit:  20,
  charset:          'utf8mb4',
  timezone:         '+00:00',
});

async function query(sql, params = []) {
  const [rows] = await pool.execute(sql, params);
  return rows;
}

async function queryOne(sql, params = []) {
  const rows = await query(sql, params);
  return rows[0] || null;
}

module.exports = { pool, query, queryOne };