Convert all remaining tabs by 2spaces
[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 // 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,
15 // initime: array of integers (when clock start running),
16 // score: string (several options; '*' == running),
17 // }
18
19 import { ajax } from "@/utils/ajax";
20
21 function 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
42 let objectStore = db.createObjectStore("games", { keyPath: "id" });
43 objectStore.createIndex("score", "score"); //to search by game result
44 }
45 }
46
47 export const GameStorage =
48 {
49 // Optional callback to get error status
50 // TODO: this func called from Hall seems to not work now...
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 ?
70 // obj: chat, move, fen, clocks, score[Msg], initime, ...
71 update: function(gameId, obj)
72 {
73 if (Number.isInteger(gameId) || !isNaN(parseInt(gameId)))
74 {
75 // corr: only move, fen and score
76 ajax(
77 "/games",
78 "PUT",
79 {
80 gid: gameId,
81 newObj:
82 {
83 chat: obj.chat,
84 move: obj.move, //may be undefined...
85 fen: obj.fen,
86 score: obj.score,
87 scoreMsg: obj.scoreMsg,
88 drawOffer: obj.drawOffer,
89 }
90 }
91 );
92 }
93 else
94 {
95 // live
96 dbOperation((db) => {
97 let objectStore = db.transaction("games", "readwrite").objectStore("games");
98 objectStore.get(gameId).onsuccess = function(event) {
99 const game = event.target.result;
100 Object.keys(obj).forEach(k => {
101 if (k == "move")
102 game.moves.push(obj[k]);
103 else
104 game[k] = obj[k];
105 });
106 objectStore.put(game); //save updated data
107 }
108 });
109 }
110 },
111
112 // Retrieve all local games (running, completed, imported...)
113 getAll: function(callback)
114 {
115 dbOperation((db) => {
116 let objectStore = db.transaction('games').objectStore('games');
117 let games = [];
118 objectStore.openCursor().onsuccess = function(event) {
119 let cursor = event.target.result;
120 // if there is still another cursor to go, keep running this code
121 if (cursor)
122 {
123 games.push(cursor.value);
124 cursor.continue();
125 }
126 else
127 callback(games);
128 }
129 });
130 },
131
132 // Retrieve any game from its identifiers (locally or on server)
133 // NOTE: need callback because result is obtained asynchronously
134 get: function(gameId, callback)
135 {
136 // corr games identifiers are integers
137 if (Number.isInteger(gameId) || !isNaN(parseInt(gameId)))
138 {
139 ajax("/games", "GET", {gid:gameId}, res => {
140 let game = res.game;
141 game.moves.forEach(m => {
142 m.squares = JSON.parse(m.squares);
143 });
144 callback(game);
145 });
146 }
147 else //local game
148 {
149 dbOperation((db) => {
150 let objectStore = db.transaction('games').objectStore('games');
151 objectStore.get(gameId).onsuccess = function(event) {
152 callback(event.target.result);
153 }
154 });
155 }
156 },
157
158 getCurrent: function(callback)
159 {
160 dbOperation((db) => {
161 let objectStore = db.transaction('games').objectStore('games');
162 objectStore.get("*").onsuccess = function(event) {
163 callback(event.target.result);
164 };
165 });
166 },
167
168 // Delete a game in indexedDB
169 remove: function(gameId, callback)
170 {
171 dbOperation((db) => {
172 let transaction = db.transaction(["games"], "readwrite");
173 if (callback)
174 {
175 transaction.oncomplete = function() {
176 callback({}); //everything's fine
177 }
178 transaction.onerror = function() {
179 callback({errmsg: "removeGame failed: " + transaction.error});
180 };
181 }
182 transaction.objectStore("games").delete(gameId);
183 });
184 },
185 };