Changeset e9f11ac for pages/api

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

Location:

pages/api

Files:

• poker/index.js (modified) (1 diff)
• postgre/index.js (modified) (2 diffs)
• roulette/index.js (modified) (3 diffs)

pages/api/poker/index.js

@@ -274 +274 @@
                         table.lastActivity = Date.now();
                         setNextPlayerIdx(table.id);
+                        
+                        update_tables_to_database();
                     }
                 }

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();

pages/api/roulette/index.js

@@ -1 +1 @@
 import axios from 'axios';
+
+import { game, update_game_to_database } from '../postgre/index'
 
 require('dotenv').config();
@@ -141 +143 @@
 })();
 
-let game = {
-    status: '_1_ongoing_timer',     // statuses: _1_ongoing_timer, _2_spinning,
-    timeToStart: 30,                // in seconds
-    COUNTDOWN_FROM: 30,
-    WAIT_BEFORE: 20,
-    magicNumber: -1,
-    winningBets: [],
-    players: [],
+if (game.status === undefined) {
+    game.status = '_1_ongoing_timer';     // statuses: _1_ongoing_timer, _2_spinning
+    game.timeToStart = 30;                // in seconds
+    game.COUNTDOWN_FROM = 30;
+    game.WAIT_BEFORE = 20;
+    game.magicNumber = -1;
+    game.winningBets = [];
+    game.players = [];
 }
 
@@ -262 +264 @@
             }
 
+            if (game.loaded !== undefined && game.loaded) {
+                update_game_to_database();
+            }
+
             res.json({
                 success: true,