File size: 3,148 Bytes
e758fa7 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 |
module.exports = function ({ models, Users }) {
const { readFileSync, writeFileSync } = require("fs-extra");
var path = __dirname + "/data/usersData.json";
try {
var Currencies = require(path)
} catch {
writeFileSync(path, "{}", { flag: 'a+' });
}
async function saveData(data) {
try {
if (!data) throw new Error('Data cannot be left blank');
writeFileSync(path, JSON.stringify(data, null, 4))
return true
} catch (error) {
return false
}
}
async function getData(userID) {
try {
if (!userID) throw new Error("User ID cannot be blank");
if (isNaN(userID)) throw new Error("Invalid user ID");
if (!userID) throw new Error("userID cannot be empty");
if (!Currencies.hasOwnProperty(userID)) console.log(`User ID: ${userID} does not exist in Database`);
const data = await Users.getData(userID);
return data
}
catch (error) {
console.log(error)
return false
};
}
async function setData(userID, options = {}) {
try {
if (!userID) throw new Error("User ID cannot be blank");
if (isNaN(userID)) throw new Error("Invalid user ID");
if (!userID) throw new Error("userID cannot be empty");
if (!Currencies.hasOwnProperty(userID)) throw new Error(`User ID: ${userID} does not exist in Database`);
if (typeof options != 'object') throw new Error("The options parameter passed must be an object");
Currencies[userID] = {...Currencies[userID], ...options};
await saveData(Currencies);
return Currencies[userID];
} catch (error) {
return false
}
}
async function delData(userID, callback) {
try {
if (!userID) throw new Error("User ID cannot be blank");
if (isNaN(userID)) throw new Error("Invalid user ID");
if (!usersData.hasOwnProperty(userID)) throw new Error(`User ID: ${userID} does not exist in Database`);
usersData[userID].money = 0;
await saveData(usersData);
if (callback && typeof callback == "function") callback(null, usersData);
return usersData;
} catch (error) {
if (callback && typeof callback == "function") callback(error, null);
return false
}
}
async function increaseMoney(userID, money) {
if (typeof money != 'number') throw global.getText("currencies", "needNumber");
try {
let balance = (await getData(userID)).money;
await setData(userID, { money: balance + money });
return true;
}
catch (error) {
console.error(error);
throw new Error(error);
}
}
async function decreaseMoney(userID, money) {
if (typeof money != 'number') throw global.getText("currencies", "needNumber");
try {
let balance = (await getData(userID)).money;
if (balance < money) return false;
await setData(userID, { money: balance - money });
return true;
} catch (error) {
throw new Error(error);
}
}
return {
getData,
setData,
delData,
increaseMoney,
decreaseMoney
};
}; |