// @ts-check //////////////////////////////////////// //////////////////////////////////////// //////////////////////////////////////// require("dotenv").config({ path: "./../.env" }); const generator = require("generate-password"); const noDatabaseDbHandler = require("./utils/noDatabaseDbHandler"); const dbHandler = require("./utils/dbHandler"); const encrypt = require("../package-shared/functions/backend/encrypt"); /** ****************************************************************************** */ /** ****************************************************************************** */ /** ****************************************************************************** */ /** ****************************************************************************** */ /** ****************************************************************************** */ /** ****************************************************************************** */ /** * Create database from Schema Function * ============================================================================== * @param {object} params - Single object params * @param {number|string|null} params.userId - User ID or null */ async function setSQLCredentials() { /** * @description Users * @type {*[] | null} */ // @ts-ignore const users = await dbHandler({ query: `SELECT * FROM users`, }); if (!users) { process.exit(); } for (let i = 0; i < users.length; i++) { const user = users[i]; if (!user) continue; if (user.mariadb_user && user.mariadb_pass) { continue; } try { const username = `dsql_user_${user.id}`; const password = generator.generate({ length: 16, numbers: true, symbols: true, uppercase: true, exclude: "*#.'`\"", }); const encryptedPassword = encrypt(password); await noDatabaseDbHandler( `CREATE USER IF NOT EXISTS '${username}'@'127.0.0.1' IDENTIFIED BY '${password}' REQUIRE SSL` ); await noDatabaseDbHandler( `GRANT ALL PRIVILEGES ON \`datasquirel\\_user\\_${user.id}\\_%\`.* TO '${username}'@'127.0.0.1'` ); await noDatabaseDbHandler(`FLUSH PRIVILEGES`); const updateUser = await dbHandler({ query: `UPDATE users SET mariadb_user = ?, mariadb_host = '127.0.0.1' mariadb_pass = ? WHERE id = ?`, values: [username, encryptedPassword, user.id], }); console.log( `User ${user.id}: ${user.first_name} ${user.last_name} SQL credentials successfully added.` ); } catch (/** @type {any} */ error) { console.log(`Error in adding SQL user =>`, error.message); } } process.exit(); //////////////////////////////////////// //////////////////////////////////////// //////////////////////////////////////// } /** ****************************************************************************** */ /** ****************************************************************************** */ /** ****************************************************************************** */ /** ****************************************************************************** */ /** ****************************************************************************** */ setSQLCredentials();