Changeset e9f11ac for pages/api/postgre

Timestamp:

07/12/22 17:03:03 (2 years ago)

Author:

anastasovv <simon@…>

Branches:

main

Children:

1df3fde

Parents:

d0ef259

Message:

Saving roulette data to database

File:

• pages/api/postgre/index.js (modified) (2 diffs)

pages/api/postgre/index.js

@@ -468 +468 @@
 
 export function update_sessions_to_database() {
-   pool.query('UPDATE sessions SET data = $1 WHERE identifier = $2', [JSON.stringify(sessions), 'sessions_data'], (error, results) => {
-     if (error) throw error;
-   });
+  pool.query('UPDATE sessions SET data = $1 WHERE identifier = $2', [JSON.stringify(sessions), 'sessions_data'], (error, results) => {
+    if (error) throw error;
+  });
 }
    
 export function load_sessions_from_database() {
-   pool.query('SELECT data FROM sessions WHERE identifier = $1', ['sessions_data'], (error, results) => {
-     if (error) throw error;
- 
-     sessions = JSON.parse(results?.rows[0]?.data || []);
-   });
+  pool.query('SELECT data FROM sessions WHERE identifier = $1', ['sessions_data'], (error, results) => {
+    if (error) throw error;
+
+    sessions = JSON.parse(results?.rows[0]?.data || []);
+  });
 }
 load_sessions_from_database();
  
- /**
-  * Poker game data
-  */
+/**
+ *  Poker game data
+ */
 export var tables = []
  
@@ -492 +492 @@
  
 export function update_tables_to_database() {
-   tables = tables.map(table => ({...table, turnTimeout: null}));
- 
-   pool.query('UPDATE poker SET data = $1 WHERE identifier = $2', [JSON.stringify(tables), 'poker_data'], (error, results) => {
-     if (error) throw error;
-   });
+  tables = tables.map(table => ({...table, turnTimeout: null}));
+
+  pool.query('UPDATE poker SET data = $1 WHERE identifier = $2', [JSON.stringify(tables), 'poker_data'], (error, results) => {
+    if (error) throw error;
+  });
 }
    
 export async function load_tables_from_database() {
-   pool.query('SELECT data FROM poker WHERE identifier = $1', ['poker_data'], (error, results) => {
-       if (error) throw error;
+  pool.query('SELECT data FROM poker WHERE identifier = $1', ['poker_data'], (error, results) => {
+    if (error) throw error;
+
+    tables = JSON.parse(results?.rows[0]?.data || []);
+
+    tables.forEach(table => {
+      if (table.started) {
+        progressRoundTillTheEnd(table.id);
+      }
+    })
+
+    cleanTables();
+
+    update_tables_to_database();
+  });
+}
+load_tables_from_database();
+
+/**
+ *  Roulette game data
+ */
+export var game = {}
+  
+export function update_game_to_database() {
+  pool.query('UPDATE roulette SET data = $1 WHERE identifier = $2', [JSON.stringify(game), 'roulette_data'], (error, results) => {
+    if (error) throw error;
+  });
+}
+    
+export async function load_game_from_database() {
+  pool.query('SELECT data FROM roulette WHERE identifier = $1', ['roulette_data'], (error, results) => {
+    if (error) throw error;
+
+    game = JSON.parse(results?.rows[0]?.data || []);
+
+    game.loaded = true;
+    console.log(game);
+  });
+}
+load_game_from_database();
  
-       tables = JSON.parse(results?.rows[0]?.data || []);
- 
-       tables.forEach(table => {
-         if (table.started) {
-           progressRoundTillTheEnd(table.id);
-         }
-       })
- 
-       cleanTables();
- 
-       update_tables_to_database();
-   });
-}
-load_tables_from_database();