Rename database table functions to be clearer
This commit is contained in:
parent
4b53d875e4
commit
5a4cfd0a5f
4 changed files with 5 additions and 5 deletions
10
server.js
10
server.js
|
|
@ -1,6 +1,6 @@
|
|||
const fs = require('fs');
|
||||
const createInitialConfig = require("./util/createInitialConfig")
|
||||
const convertJSONToSQL = require('./util/timer/convertJSONToSQL');
|
||||
const convertTimerJSONToSQL = require('./util/timer/convertTimerJSONToSQL.js');
|
||||
if(!fs.existsSync("./data/config.json")) {
|
||||
createInitialConfig();
|
||||
}
|
||||
|
|
@ -8,16 +8,16 @@ async function checkAndConvertJSONToSQL(){
|
|||
process.stdout.write("Checking if timers.json exists... ")
|
||||
if(fs.existsSync("./data/timers.json")){
|
||||
process.stdout.write(true + "\n")
|
||||
await createDatabaseTables();
|
||||
await convertJSONToSQL();
|
||||
await createTimerTables();
|
||||
await convertTimerJSONToSQL();
|
||||
fs.renameSync('data/timers.json', 'data/timers.json.old');
|
||||
console.log("Renamed timers.json to timers.json.old");
|
||||
}else{
|
||||
process.stdout.write(false + "\n")
|
||||
}
|
||||
}
|
||||
const createDatabaseTables = require('./server/createDatabaseTables');
|
||||
const createLastfmTable = require('./server/createLastfmTable');
|
||||
const createTimerTables = require('./server/createDatabaseTables/createTimersTable');
|
||||
const createLastfmTable = require('./server/createDatabaseTables/createLastfmTable');
|
||||
createLastfmTable();
|
||||
checkAndConvertJSONToSQL();
|
||||
const { Collection, Client, GatewayIntentBits, Partials } = require('discord.js');
|
||||
|
|
|
|||
21
server/createDatabaseTables/createLastfmTable.js
Normal file
21
server/createDatabaseTables/createLastfmTable.js
Normal file
|
|
@ -0,0 +1,21 @@
|
|||
const sqlite3 = require('sqlite3').verbose();
|
||||
module.exports = async function () {
|
||||
const db = new sqlite3.Database('data/database.db');
|
||||
return new Promise ((resolve, reject)=>{
|
||||
db.run(
|
||||
`CREATE TABLE IF NOT EXISTS lastfm (
|
||||
userID INTEGER PRIMARY KEY,
|
||||
lastfmUsername TEXT)`,
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.error(`Error while creating table 'lastfm': ${err}`);
|
||||
reject(err);
|
||||
} else {
|
||||
console.log("Table 'lastfm' created successfully.");
|
||||
resolve();
|
||||
}
|
||||
db.close();
|
||||
}
|
||||
);
|
||||
})
|
||||
}
|
||||
26
server/createDatabaseTables/createTimersTable.js
Normal file
26
server/createDatabaseTables/createTimersTable.js
Normal file
|
|
@ -0,0 +1,26 @@
|
|||
const sqlite3 = require('sqlite3').verbose();
|
||||
|
||||
module.exports = async function () {
|
||||
const db = new sqlite3.Database('data/database.db');
|
||||
return new Promise ((resolve, reject)=>{
|
||||
db.run(
|
||||
`CREATE TABLE IF NOT EXISTS timers (
|
||||
ID INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
user TEXT,
|
||||
reminderTime INTEGER,
|
||||
channel TEXT,
|
||||
customMessage TEXT,
|
||||
hasPassed INTEGER)`,
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.error(`Error while creating table 'timers': ${err}`);
|
||||
reject(err);
|
||||
} else {
|
||||
console.log("Table 'timers' created successfully.");
|
||||
resolve();
|
||||
}
|
||||
db.close();
|
||||
}
|
||||
);
|
||||
})
|
||||
}
|
||||
32
util/timer/convertTimerJSONToSQL.js
Normal file
32
util/timer/convertTimerJSONToSQL.js
Normal file
|
|
@ -0,0 +1,32 @@
|
|||
const sqlite3 = require('sqlite3').verbose();
|
||||
module.exports = async function () {
|
||||
const timers = require('../../data/timers.json')
|
||||
const db = new sqlite3.Database('data/database.db');
|
||||
return new Promise((resolve, reject) => {
|
||||
for (let i = 0; i < timers.length; i++) {
|
||||
let user = timers[i].user;
|
||||
let reminderTime = timers[i].reminderDate;
|
||||
let channel = timers[i].channel;
|
||||
let customMessage = timers[i].customMessage;
|
||||
let hasPassed = false;
|
||||
|
||||
db.run(`INSERT INTO timers (
|
||||
user,
|
||||
reminderTime,
|
||||
channel,
|
||||
customMessage,
|
||||
hasPassed
|
||||
) VALUES (?, ?, ?, ?, ?)`, [user, reminderTime, channel, customMessage, hasPassed], function (error) {
|
||||
if (error) {
|
||||
console.error(`Error while converting timers.json to SQL: ${error}`)
|
||||
reject(error);
|
||||
}
|
||||
})
|
||||
|
||||
|
||||
}
|
||||
db.close();
|
||||
console.log("Converted timers.json to SQL successfully.");
|
||||
resolve();
|
||||
})
|
||||
}
|
||||
Loading…
Reference in a new issue