Commit | Line | Data |
---|---|---|
967a2686 BA |
1 | // Game object: { |
2 | // // Static informations: | |
11667c79 | 3 | // id: string |
967a2686 BA |
4 | // vname: string, |
5 | // fenStart: string, | |
6 | // players: array of sid+id+name, | |
71468011 | 7 | // cadence: string, |
967a2686 | 8 | // increment: integer (seconds), |
910d631b | 9 | // type: string ("live" or "corr") |
967a2686 BA |
10 | // // Game (dynamic) state: |
11 | // fen: string, | |
12 | // moves: array of Move objects, | |
13 | // clocks: array of integers, | |
809ba2aa | 14 | // initime: array of integers (when clock start running), |
967a2686 BA |
15 | // score: string (several options; '*' == running), |
16 | // } | |
17 | ||
602d6bef | 18 | import { store } from "@/store"; |
fd7aea36 | 19 | |
6808d7a1 | 20 | function dbOperation(callback) { |
967a2686 BA |
21 | let db = null; |
22 | let DBOpenRequest = window.indexedDB.open("vchess", 4); | |
23 | ||
24 | DBOpenRequest.onerror = function(event) { | |
8477e53d | 25 | alert(store.state.tr["Database error: stop private browsing, or update your browser"]); |
934f7f70 | 26 | callback("error", null); |
967a2686 BA |
27 | }; |
28 | ||
6808d7a1 | 29 | DBOpenRequest.onsuccess = function() { |
967a2686 | 30 | db = DBOpenRequest.result; |
934f7f70 | 31 | callback(null, db); |
967a2686 BA |
32 | db.close(); |
33 | }; | |
34 | ||
35 | DBOpenRequest.onupgradeneeded = function(event) { | |
36 | let db = event.target.result; | |
bee36510 BA |
37 | let upgradeTransaction = event.target.transaction; |
38 | let objectStore = undefined; | |
39 | if (!db.objectStoreNames.contains("games")) | |
40 | objectStore = db.createObjectStore("games", { keyPath: "id" }); | |
41 | else | |
42 | objectStore = upgradeTransaction.objectStore("games"); | |
43 | if (!objectStore.indexNames.contains("score")) | |
44 | // To sarch games by score (useful for running games) | |
45 | objectStore.createIndex("score", "score", { unique: false }); | |
46 | if (!objectStore.indexNames.contains("created")) | |
47 | // To search by date intervals. Two games cannot start at the same time | |
48 | objectStore.createIndex("created", "created", { unique: true }); | |
6808d7a1 | 49 | }; |
967a2686 BA |
50 | } |
51 | ||
6808d7a1 | 52 | export const GameStorage = { |
967a2686 | 53 | // Optional callback to get error status |
6808d7a1 | 54 | add: function(game, callback) { |
8477e53d | 55 | dbOperation((err,db) => { |
c292ebb2 | 56 | if (!!err) { |
8477e53d BA |
57 | callback("error"); |
58 | return; | |
967a2686 | 59 | } |
8477e53d BA |
60 | let transaction = db.transaction("games", "readwrite"); |
61 | transaction.oncomplete = function() { | |
934f7f70 BA |
62 | // Everything's fine |
63 | callback(); | |
8477e53d | 64 | }; |
c292ebb2 | 65 | transaction.onerror = function(err) { |
934f7f70 BA |
66 | // Duplicate key error (most likely) |
67 | callback(err); | |
c292ebb2 | 68 | }; |
934f7f70 | 69 | transaction.objectStore("games").add(game); |
967a2686 BA |
70 | }); |
71 | }, | |
72 | ||
dcd68c41 | 73 | // obj: chat, move, fen, clocks, score[Msg], initime, ... |
6808d7a1 | 74 | update: function(gameId, obj) { |
aae89b49 BA |
75 | // live |
76 | dbOperation((err,db) => { | |
77 | let objectStore = db | |
78 | .transaction("games", "readwrite") | |
79 | .objectStore("games"); | |
80 | objectStore.get(gameId).onsuccess = function(event) { | |
81 | // Ignoring error silently: shouldn't happen now. TODO? | |
82 | if (event.target.result) { | |
83 | let game = event.target.result; | |
84 | // Hidden tabs are delayed, to prevent multi-updates: | |
85 | if (obj.moveIdx < game.moves.length) return; | |
86 | Object.keys(obj).forEach(k => { | |
87 | if (k == "move") game.moves.push(obj[k]); | |
88 | else game[k] = obj[k]; | |
89 | }); | |
90 | objectStore.put(game); //save updated data | |
3d55deea | 91 | } |
aae89b49 BA |
92 | }; |
93 | }); | |
967a2686 BA |
94 | }, |
95 | ||
934f7f70 BA |
96 | // Retrieve (all) running local games |
97 | getRunning: function(callback) { | |
8477e53d | 98 | dbOperation((err,db) => { |
934f7f70 BA |
99 | let objectStore = db |
100 | .transaction("games", "readonly") | |
101 | .objectStore("games"); | |
102 | let index = objectStore.index("score"); | |
103 | const range = IDBKeyRange.only("*"); | |
fd7aea36 | 104 | let games = []; |
934f7f70 | 105 | index.openCursor(range).onsuccess = function(event) { |
fd7aea36 | 106 | let cursor = event.target.result; |
934f7f70 BA |
107 | if (!cursor) callback(games); |
108 | else { | |
109 | // If there is still another cursor to go, keep running this code | |
db1f1f9a | 110 | let g = cursor.value; |
6b7b2cf7 BA |
111 | // Do not retrieve moves or clocks (unused in list mode) |
112 | g.movesCount = g.moves.length; | |
113 | delete g.moves; | |
114 | delete g.clocks; | |
115 | delete g.initime; | |
db1f1f9a | 116 | games.push(g); |
fd7aea36 | 117 | cursor.continue(); |
934f7f70 BA |
118 | } |
119 | }; | |
120 | }); | |
121 | }, | |
122 | ||
123 | // Retrieve completed local games | |
124 | getNext: function(upperDt, callback) { | |
125 | dbOperation((err,db) => { | |
126 | let objectStore = db | |
127 | .transaction("games", "readonly") | |
128 | .objectStore("games"); | |
129 | let index = objectStore.index("created"); | |
130 | const range = IDBKeyRange.upperBound(upperDt); | |
131 | let games = []; | |
132 | index.openCursor(range).onsuccess = function(event) { | |
133 | let cursor = event.target.result; | |
134 | if (!cursor) { | |
135 | // Most recent games first: | |
136 | games = games.sort((g1, g2) => g2.created - g1.created); | |
137 | // TODO: 20 games showed per request is arbitrary | |
138 | callback(games.slice(0, 20)); | |
139 | } | |
140 | else { | |
141 | // If there is still another cursor to go, keep running this code | |
142 | let g = cursor.value; | |
143 | if (g.score != "*") { | |
144 | // Do not retrieve moves or clocks (unused in list mode) | |
145 | g.movesCount = g.moves.length; | |
146 | delete g.moves; | |
147 | delete g.clocks; | |
148 | delete g.initime; | |
149 | games.push(g); | |
150 | } | |
151 | cursor.continue(); | |
152 | } | |
6808d7a1 | 153 | }; |
fd7aea36 BA |
154 | }); |
155 | }, | |
156 | ||
157 | // Retrieve any game from its identifiers (locally or on server) | |
158 | // NOTE: need callback because result is obtained asynchronously | |
6808d7a1 | 159 | get: function(gameId, callback) { |
aae89b49 BA |
160 | // Local game |
161 | dbOperation((err,db) => { | |
162 | let objectStore = db.transaction("games").objectStore("games"); | |
163 | objectStore.get(gameId).onsuccess = function(event) { | |
f54f4c26 BA |
164 | // event.target.result is null if game not found |
165 | callback(event.target.result); | |
aae89b49 BA |
166 | }; |
167 | }); | |
967a2686 BA |
168 | }, |
169 | ||
170 | // Delete a game in indexedDB | |
6808d7a1 | 171 | remove: function(gameId, callback) { |
8477e53d BA |
172 | dbOperation((err,db) => { |
173 | if (!err) { | |
934f7f70 | 174 | let transaction = db.transaction("games", "readwrite"); |
967a2686 | 175 | transaction.oncomplete = function() { |
3b0f26c1 | 176 | callback(); //everything's fine |
6808d7a1 | 177 | }; |
8477e53d | 178 | transaction.objectStore("games").delete(gameId); |
967a2686 | 179 | } |
967a2686 | 180 | }); |
6808d7a1 | 181 | } |
967a2686 | 182 | }; |