Corr games: almost there. Then remote games + abort/resign/draw/message
[vchess.git] / client / src / utils / gameStorage.js
CommitLineData
967a2686
BA
1// Game object: {
2// // Static informations:
3// gameId: string
4// vname: string,
5// fenStart: string,
6// players: array of sid+id+name,
7// timeControl: string,
8// increment: integer (seconds),
9// mode: string ("live" or "corr")
10// imported: boolean (optional, default false)
11// // Game (dynamic) state:
12// fen: string,
13// moves: array of Move objects,
14// clocks: array of integers,
809ba2aa 15// initime: array of integers (when clock start running),
967a2686
BA
16// score: string (several options; '*' == running),
17// }
18
fd7aea36
BA
19import { ajax } from "@/utils/ajax";
20
967a2686
BA
21function dbOperation(callback)
22{
23 let db = null;
24 let DBOpenRequest = window.indexedDB.open("vchess", 4);
25
26 DBOpenRequest.onerror = function(event) {
27 alert("Database error: " + event.target.errorCode);
28 };
29
30 DBOpenRequest.onsuccess = function(event) {
31 db = DBOpenRequest.result;
32 callback(db);
33 db.close();
34 };
35
36 DBOpenRequest.onupgradeneeded = function(event) {
37 let db = event.target.result;
38 db.onerror = function(event) {
39 alert("Error while loading database: " + event.target.errorCode);
40 };
41 // Create objectStore for vchess->games
42c15a75
BA
42 let objectStore = db.createObjectStore("games", { keyPath: "gameId" });
43 objectStore.createIndex("score", "score"); //to search by game result
967a2686
BA
44 }
45}
46
47export const GameStorage =
48{
49 // Optional callback to get error status
c0b27606 50 // TODO: this func called from Hall seems to not work now...
967a2686
BA
51 add: function(game, callback)
52 {
53 dbOperation((db) => {
54 let transaction = db.transaction("games", "readwrite");
55 if (callback)
56 {
57 transaction.oncomplete = function() {
58 callback({}); //everything's fine
59 }
60 transaction.onerror = function() {
61 callback({errmsg: "addGame failed: " + transaction.error});
62 };
63 }
64 let objectStore = transaction.objectStore("games");
65 objectStore.add(game);
66 });
67 },
68
69 // TODO: also option to takeback a move ?
22efa391 70 update: function(gameId, obj) //move, fen, clocks, score, initime, ...
967a2686 71 {
3d55deea
BA
72 if (Number.isInteger(gameId) || !isNaN(parseInt(gameId)))
73 {
74 // corr: only move, fen and score
75 ajax(
76 "/games",
77 "PUT",
78 {
79 gid: gameId,
80 newObj:
81 {
f41ce580 82 move: obj.move, //may be undefined...
3d55deea
BA
83 fen: obj.fen,
84 score: obj.score,
85 }
86 }
87 );
88 }
89 else
90 {
91 // live
92 dbOperation((db) => {
93 let objectStore = db.transaction("games", "readwrite").objectStore("games");
94 objectStore.get(gameId).onsuccess = function(event) {
95 const game = event.target.result;
96 Object.keys(obj).forEach(k => {
97 if (k == "move")
98 game.moves.push(obj[k]);
99 else
100 game[k] = obj[k];
101 });
102 objectStore.put(game); //save updated data
103 }
104 });
105 }
967a2686
BA
106 },
107
fd7aea36
BA
108 // Retrieve all local games (running, completed, imported...)
109 getAll: function(callback)
967a2686
BA
110 {
111 dbOperation((db) => {
112 let objectStore = db.transaction('games').objectStore('games');
fd7aea36
BA
113 let games = [];
114 objectStore.openCursor().onsuccess = function(event) {
115 let cursor = event.target.result;
116 // if there is still another cursor to go, keep running this code
117 if (cursor)
118 {
119 games.push(cursor.value);
120 cursor.continue();
967a2686 121 }
fd7aea36
BA
122 else
123 callback(games);
967a2686 124 }
fd7aea36
BA
125 });
126 },
127
128 // Retrieve any game from its identifiers (locally or on server)
129 // NOTE: need callback because result is obtained asynchronously
130 get: function(gameId, callback)
131 {
132 // corr games identifiers are integers
133 if (Number.isInteger(gameId) || !isNaN(parseInt(gameId)))
134 {
135 ajax("/games", "GET", {gid:gameId}, res => {
136 callback(res.game);
137 });
138 }
139 else //local game
140 {
141 dbOperation((db) => {
142 let objectStore = db.transaction('games').objectStore('games');
967a2686
BA
143 objectStore.get(gameId).onsuccess = function(event) {
144 callback(event.target.result);
145 }
fd7aea36
BA
146 });
147 }
967a2686
BA
148 },
149
42c15a75
BA
150 getCurrent: function(callback)
151 {
152 dbOperation((db) => {
153 let objectStore = db.transaction('games').objectStore('games');
154 objectStore.get("*").onsuccess = function(event) {
155 callback(event.target.result);
156 };
157 });
158 },
159
967a2686
BA
160 // Delete a game in indexedDB
161 remove: function(gameId, callback)
162 {
163 dbOperation((db) => {
164 let transaction = db.transaction(["games"], "readwrite");
165 if (callback)
166 {
167 transaction.oncomplete = function() {
168 callback({}); //everything's fine
169 }
170 transaction.onerror = function() {
171 callback({errmsg: "removeGame failed: " + transaction.error});
172 };
173 }
174 transaction.objectStore("games").delete(gameId);
175 });
176 },
177};