diff --git a/index.js b/index.js index e9c9fe1..e0d3d61 100644 --- a/index.js +++ b/index.js @@ -1,5 +1,6 @@ require("dotenv").config(); +const fs = require('fs'); const mariadb = require("mariadb"); const pool = mariadb.createPool({ host: process.env.DB_HOST, @@ -104,22 +105,25 @@ client.on('interactionCreate', async interaction => { } }); -// DEBUG: Insert 200 extensions into discord_users table -// (async () => { -// try { -// const conn = await pool.getConnection(); -// for (let i = 1; i <= 200; i++) { -// const ext = await fpbx.getNextAvailableExtension(); -// await fpbx.addExtension(ext, `Test User ${i}`) -// await conn.query("INSERT INTO discord_users (extension, discordId) VALUES (?, ?)", [ext, '289884287765839882']); -// log.debug(`Inserted extension ${ext} into discord_users table.`); -// } -// log.success("Inserted 200 extensions into discord_users table."); -// conn.release(); -// } catch (err) { -// log.error(`Failed to insert extensions: ${err}`); -// } -// })(); +if (fs.existsSync("./import.json")) { + const importData = JSON.parse(fs.readFileSync("./import.json", "utf8")); + + const insertData = async () => { + try { + const conn = await pool.getConnection(); + for (const ext in importData) { + const discordId = importData[ext]; + await conn.query("INSERT INTO discord_users (extension, discordId) VALUES (?, ?)", [ext, discordId]); + } + conn.release(); + log.success("Data imported successfully."); + } catch (error) { + log.error(`Failed to import data: ${error}`); + } + }; + + insertData(); +} // Startup require("./migrations")(pool).then(() => {