janishutz/libreevent
1
0
Fork 0
mirror of https://github.com/janishutz/libreevent.git synced 2025-11-25 13:24:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

json db has major bug -> fix under way

Browse Source
This commit is contained in:
Janis Hutz
2023-08-25 20:09:55 +02:00
parent 9952566b6b
commit 97183cb304
3 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/server/backend/db/data/db.json
View File

@@ -1 +1 @@
{"libreevent_temp":{},"libreevent_admin":{},"libreevent_orders":{},"libreevent_users":{"1":{"email":"info@janishutz.com","first_name":"t","name":"t","two_fa":"","user_data":"{\"country\":\"t\"}","marketing":null,"mail_confirmed":"true"}}} {}

1
src/server/backend/db/db.js
View File

@@ -47,6 +47,7 @@ module.exports.getData = ( db ) => {
}; };
module.exports.writeDataSimple = ( db, column, searchQuery, data ) => { module.exports.writeDataSimple = ( db, column, searchQuery, data ) => {
console.log( 'writingData' );
return new Promise( ( resolve, reject ) => { return new Promise( ( resolve, reject ) => {
dbh.query( { 'command': 'checkDataAvailability', 'property': column, 'searchQuery': searchQuery }, dbRef[ db ] ).then( res => { dbh.query( { 'command': 'checkDataAvailability', 'property': column, 'searchQuery': searchQuery }, dbRef[ db ] ).then( res => {
if ( res.length > 0 ) { if ( res.length > 0 ) {

15
src/server/backend/db/jsondb.js
View File

@@ -24,6 +24,7 @@ class JSONDB {
this.dbIndex = data[ 'index' ] ?? { 'libreevent_temp': 0, 'libreevent_admin': 0, 'libreevent_orders': 0, 'libreevent_users': 0 }; this.dbIndex = data[ 'index' ] ?? { 'libreevent_temp': 0, 'libreevent_admin': 0, 'libreevent_orders': 0, 'libreevent_users': 0 };
this.db[ 'libreevent_temp' ] = {}; this.db[ 'libreevent_temp' ] = {};
this.saveToDisk(); this.saveToDisk();
console.log( this.db );
console.log( '[ JSON-DB ] Database initialized successfully' ); console.log( '[ JSON-DB ] Database initialized successfully' );
return 'connection'; return 'connection';
} }
@@ -38,9 +39,11 @@ class JSONDB {
} }
save () { save () {
fs.writeFile( path.join( __dirname + '/data/db.json' ), JSON.stringify( this.db ), ( err ) => { fs.writeFile( path.join( __dirname + '/data/db.json' ), JSON.stringify( { 'db': this.db, 'index': this.dbIndex } ), ( err ) => {
if ( err ) console.error( '[ JSON-DB ] An error occurred during saving: ' + err ); if ( err ) console.error( '[ JSON-DB ] An error occurred during saving: ' + err );
this.isSaving = false; this.isSaving = false;
console.log( 'afterSaving' );
console.log( this.db );
if ( this.awaitingSaving ) { if ( this.awaitingSaving ) {
this.saveToDisk(); this.saveToDisk();
} }
@@ -48,13 +51,15 @@ class JSONDB {
} }
async resetDB () { async resetDB () {
this.db = {}; this.db = { 'libreevent_temp': {}, 'libreevent_admin': {}, 'libreevent_orders': {}, 'libreevent_users': {} };
fs.writeFile( path.join( __dirname + '/data/db.json' ), JSON.stringify( this.db ) ); this.dbIndex = { 'libreevent_temp': 0, 'libreevent_admin': 0, 'libreevent_orders': 0, 'libreevent_users': 0 };
fs.writeFile( path.join( __dirname + '/data/db.json' ), JSON.stringify( { 'db': this.db, 'index': this.dbIndex } ) );
} }
async setupDB () { async setupDB () {
this.db = { 'libreevent_temp': {}, 'libreevent_admin': {}, 'libreevent_orders': {}, 'libreevent_users': {} }; this.db = { 'libreevent_temp': {}, 'libreevent_admin': {}, 'libreevent_orders': {}, 'libreevent_users': {} };
fs.writeFile( path.join( __dirname + '/data/db.json' ), JSON.stringify( this.db ) ); this.dbIndex = { 'libreevent_temp': 0, 'libreevent_admin': 0, 'libreevent_orders': 0, 'libreevent_users': 0 };
fs.writeFile( path.join( __dirname + '/data/db.json' ), JSON.stringify( { 'db': this.db, 'index': this.dbIndex } ) );
} }
query ( operation, table ) { query ( operation, table ) {
@@ -124,9 +129,11 @@ class JSONDB {
} else if ( operation.command === 'updateData' ) { } else if ( operation.command === 'updateData' ) {
if ( !operation.property || !operation.searchQuery ) reject( 'Refusing to run destructive command: Missing Constraints' ); if ( !operation.property || !operation.searchQuery ) reject( 'Refusing to run destructive command: Missing Constraints' );
else { else {
console.log( operation );
for ( let entry in this.db[ table ] ) { for ( let entry in this.db[ table ] ) {
if ( this.db[ table ][ entry ][ operation.property ] == operation.searchQuery ) { if ( this.db[ table ][ entry ][ operation.property ] == operation.searchQuery ) {
for ( let changed in operation.newValues ) { for ( let changed in operation.newValues ) {
console.log( this.db[ table ][ entry ] );
this.db[ table ][ entry ][ changed ] = operation.newValues[ changed ]; this.db[ table ][ entry ][ changed ] = operation.newValues[ changed ];
} }
} }