Changeset 95ce58b for pages/api/postgre

Timestamp:

07/08/22 13:51:13 (2 years ago)

Author:

anastasovv <simon@…>

Branches:

main

Children:

d0ef259

Parents:

aac3b2b

Message:

Saving sessions data and poker data to database

File:

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

pages/api/postgre/index.js

@@ -6 +6 @@
 
 const crypto = require('crypto');
+
+import { progressRoundTillTheEnd } from '../poker/tableSpecific';
 
 const Pool = require('pg').Pool
@@ -11 +13 @@
   connectionString: `postgres://${process.env.POSTGRES_USER}:${process.env.POSTGRES_PASSWORD}@${process.env.POSTGRES_HOST}/${process.env.POSTGRES_DB}`
 });
-
-const sessions = []
-// example session = { id, displayName, username, credits, lastActivity }
 
 export default function handler(req, res) {
@@ -97 +96 @@
           });
         }
+
+        update_sessions_to_database();
           
         res.json({
@@ -159 +160 @@
           }
         });
+
+        update_sessions_to_database();
 
         res.json({
@@ -253 +256 @@
 
         axios.get(`${process.env.HOME_URL}/api/blackjack/?action=remove_room&session_id=${session_id}`);
+
+        update_sessions_to_database();
       }
 
@@ -427 +432 @@
                       lastActivity: Date.now(),
                     }
-                    
+
                     sessions.push(session);
+
+                    update_sessions_to_database();
     
                     res.json({
@@ -453 +460 @@
   }
 }
+
+
+/**
+ * User session data
+ */
+export var sessions = []
+
+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;
+   });
+}
+   
+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 || []);
+   });
+}
+load_sessions_from_database();
+ 
+ /**
+  * Poker game data
+  */
+export var tables = []
+ 
+export function cleanTables() {
+   tables = [];
+}
+ 
+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;
+   });
+}
+   
+export async function load_tables_from_database() {
+   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();