Some fixes, work on Eightpieces draft, add a few capturing variants
[vchess.git] / client / src / utils / gameStorage.js
1 // Game object: {
2 // // Static informations:
3 // id: string
4 // vname: string,
5 // fenStart: string,
6 // players: array of sid+id+name,
7 // cadence: string,
8 // increment: integer (seconds),
9 // type: string ("live" or "corr")
10 // // Game (dynamic) state:
11 // fen: string,
12 // moves: array of Move objects,
13 // clocks: array of integers,
14 // initime: array of integers (when clock start running),
15 // score: string (several options; '*' == running),
16 // }
17
18 import { store } from "@/store";
19
20 function dbOperation(callback) {
21 let db = null;
22 let DBOpenRequest = window.indexedDB.open("vchess", 4);
23
24 DBOpenRequest.onerror = function(event) {
25 alert(store.state.tr["Database error: stop private browsing, or update your browser"]);
26 callback("error",null);
27 };
28
29 DBOpenRequest.onsuccess = function() {
30 db = DBOpenRequest.result;
31 callback(null,db);
32 db.close();
33 };
34
35 DBOpenRequest.onupgradeneeded = function(event) {
36 let db = event.target.result;
37 let objectStore = db.createObjectStore("games", { keyPath: "id" });
38 objectStore.createIndex("score", "score"); //to search by game result
39 };
40 }
41
42 export const GameStorage = {
43 // Optional callback to get error status
44 add: function(game, callback) {
45 dbOperation((err,db) => {
46 if (!!err) {
47 callback("error");
48 return;
49 }
50 let transaction = db.transaction("games", "readwrite");
51 transaction.oncomplete = function() {
52 callback(); //everything's fine
53 };
54 transaction.onerror = function(err) {
55 callback(err); //duplicate key error (most likely)
56 };
57 let objectStore = transaction.objectStore("games");
58 objectStore.add(game);
59 });
60 },
61
62 // obj: chat, move, fen, clocks, score[Msg], initime, ...
63 update: function(gameId, obj) {
64 // live
65 dbOperation((err,db) => {
66 let objectStore = db
67 .transaction("games", "readwrite")
68 .objectStore("games");
69 objectStore.get(gameId).onsuccess = function(event) {
70 // Ignoring error silently: shouldn't happen now. TODO?
71 if (event.target.result) {
72 let game = event.target.result;
73 // Hidden tabs are delayed, to prevent multi-updates:
74 if (obj.moveIdx < game.moves.length) return;
75 Object.keys(obj).forEach(k => {
76 if (k == "move") game.moves.push(obj[k]);
77 else game[k] = obj[k];
78 });
79 objectStore.put(game); //save updated data
80 }
81 };
82 });
83 },
84
85 // Retrieve all local games (running, completed, imported...)
86 getAll: function(callback) {
87 dbOperation((err,db) => {
88 let objectStore = db.transaction("games").objectStore("games");
89 let games = [];
90 objectStore.openCursor().onsuccess = function(event) {
91 let cursor = event.target.result;
92 // if there is still another cursor to go, keep running this code
93 if (cursor) {
94 let g = cursor.value;
95 // Do not retrieve moves or clocks (unused in list mode)
96 g.movesCount = g.moves.length;
97 delete g.moves;
98 delete g.clocks;
99 delete g.initime;
100 games.push(g);
101 cursor.continue();
102 } else callback(games);
103 };
104 });
105 },
106
107 // Retrieve any game from its identifiers (locally or on server)
108 // NOTE: need callback because result is obtained asynchronously
109 get: function(gameId, callback) {
110 // Local game
111 dbOperation((err,db) => {
112 let objectStore = db.transaction("games").objectStore("games");
113 objectStore.get(gameId).onsuccess = function(event) {
114 if (event.target.result)
115 callback(event.target.result);
116 };
117 });
118 },
119
120 // Delete a game in indexedDB
121 remove: function(gameId, callback) {
122 dbOperation((err,db) => {
123 if (!err) {
124 let transaction = db.transaction(["games"], "readwrite");
125 transaction.oncomplete = function() {
126 callback(); //everything's fine
127 };
128 transaction.objectStore("games").delete(gameId);
129 }
130 });
131 }
132 };