1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
|
package ch.asynk.rustanddust;
import java.security.MessageDigest;
import java.math.BigInteger;
import com.badlogic.gdx.sql.Database;
import com.badlogic.gdx.sql.DatabaseCursor;
import com.badlogic.gdx.sql.DatabaseFactory;
import com.badlogic.gdx.sql.SQLiteGdxException;
import ch.asynk.rustanddust.RustAndDust;
public class DB
{
private static final int DB_SCHEMA_VERSION = 1;
public static final int NO_RECORDS = -1;
private static final String DIGEST = "SHA-256";
private Database db;
private MessageDigest md;
private static final String TBL_CFG_CRT = "create table if not exists"
+ " config ( key text primary key, value text not null);"
+ " insert or ignore into config values(\"version\", " + DB_SCHEMA_VERSION + ");";
private static final String TBL_PLAYERS_CRT = "create table if not exists"
+ " players ( _id integer primary key autoincrement,"
+ " hash text unique not null, gmail text unique not null, firstname text, lastname text"
+ ");";
private static final String TBL_BATTLES_CRT = "create table if not exists"
+ " battles ( _id integer primary key, name text"
+ ");";
private static final String TBL_GAMES_CRT = "create table if not exists"
+ " games ( _id integer primary key autoincrement,"
+ " _p1 integer not null, _p2 integer not null, _b integer not null,"
+ " int mode not null, ts datetime default current_timestamp,"
+ " foreign key (_p1) references players(_id),"
+ " foreign key (_p2) references players(_id),"
+ " foreign key (_b) references battles(_id),"
+ " unique (_p1, _p2, _b)"
+ ");";
private static final String TBL_TURNS_CRT = "create table if not exists"
+ " turns ( _id integer primary key autoincrement, _g integer not null,"
+ " _p integer not null, hash text not null, payload text not null,"
+ " foreign key (_g) references games(_id),"
+ " foreign key (_p) references players(_id)"
+ ");";
private static final String TBL_STATES_CRT = "create table if not exists"
+ " states ( _g integer unique not null,"
+ " hash text not null, payload text not null,"
+ " foreign key (_g) references games(_id)"
+ ");";
private static final String INSERT_PLAYER = "insert into players(hash,gmail,firstname,lastname) values ('%s','%s','%s','%s');";
private static final String GET_PLAYER_ID = "select _id from players where hash='%s';";
private static final String UPDATE_BATTLE = "insert or replace into battles values (%d,'%s');";
private static final String INSERT_GAME = "insert into games(_p1,_p2,_b,m) values (%d,%d,%d,%d);";
private static final String GET_GAME_ID = "select _id from games where _p1=%d and _p2=%d and _b=%d;";
private static final String INSERT_TURN = "insert into turns(_g,_p,hash,payload) values (%d,%d,'%s','%s'); update games set ts=current_timestamp where _id=%d;";
private static final String INSERT_STATE = "insert or replace into states(_g,hash,payload) values (%d,'%s','%s'); update games set ts=current_timestamp where _id=%d;";
private static final String DB_CRT = TBL_CFG_CRT + TBL_PLAYERS_CRT + TBL_BATTLES_CRT + TBL_GAMES_CRT + TBL_TURNS_CRT + TBL_STATES_CRT;
public DB(String dbPath)
{
db = DatabaseFactory.getNewDatabase(dbPath, DB_SCHEMA_VERSION, DB_CRT, null);
db.setupDatabase();
}
public void setup()
{
try {
md = MessageDigest.getInstance(DIGEST);
} catch (java.security.NoSuchAlgorithmException e) { RustAndDust.error("NoSuchAlgorithm"); }
try {
db.openOrCreateDatabase();
} catch (SQLiteGdxException e) { RustAndDust.error("openOrCreateDatabase"); }
}
private String getDigest(String str)
{
String hash = null;
try {
hash = new BigInteger(1, md.digest(str.getBytes("UTF-8"))).toString(16);
} catch (java.io.UnsupportedEncodingException e) { RustAndDast.error("getDigest"); }
return hash;
}
public String storePlayer(String gmail, String firstname, String lastname)
{
String hash = getDigest(gmail + firstname + lastname);
if (hash == null) return null;
try {
if (getPlayerId(hash) == NO_RECORDS) {
db.execSQL(String.format(INSERT_PLAYER, hash, gmail, firstname, lastname));
}
} catch (SQLiteGdxException e) {
RustAndDust.error("storePlayer");
return null;
}
return hash;
}
public int getPlayerId(String hash)
{
int ret = NO_RECORDS;
try {
DatabaseCursor cursor = db.rawQuery(String.format(GET_PLAYER_ID, hash));
if (cursor.getCount() > 0) {
cursor.next();
ret = cursor.getInt(0);
}
} catch (SQLiteGdxException e) { RustAndDust.error("getPlayerId"); }
return ret;
}
public int storePlayerGetId(String gmail, String firstname, String lastname)
{
String hash = storePlayer(gmail, firstname, lastname);
if (hash == null) return NO_RECORDS;
return getPlayerId(hash);
}
public void storeBattle(int id, String name)
{
try {
db.execSQL(String.format(UPDATE_BATTLE, id, name));
} catch (SQLiteGdxException e) { RustAndDust.error("storeBattle"); }
}
public void storeGame(int you, int opponent, int battle, int mode)
{
try {
if (getGameId(you, opponent, battle, mode) == NO_RECORDS)
db.execSQL(String.format(INSERT_GAME, you, opponent, battle, mode));
} catch (SQLiteGdxException e) { RustAndDust.error("storeGame"); }
}
public int getGameId(int you, int opponent, int battle, int mode)
{
int ret = NO_RECORDS;
try {
DatabaseCursor cursor = db.rawQuery(String.format(GET_GAME_ID, you, opponent, battle, mode));
if (cursor.getCount() > 0) {
cursor.next();
ret = cursor.getInt(0);
}
} catch (SQLiteGdxException e) { RustAndDust.error("getGameId"); }
return ret;
}
public int storeGameGetId(int you, int opponent, int battle, int mode)
{
storeGame(you, opponent, battle, mode);
return getGameId(you, opponent, battle, mode);
}
public boolean storeTurn(int game, int player, String payload)
{
try {
String hash = getDigest(payload);
if (hash == null) return false;
db.execSQL(String.format(INSERT_TURN, game, player, hash, payload, game));
} catch (SQLiteGdxException e) {
RustAndDust.error("storeTurn");
return false;
}
return true;
}
public boolean storeState(int game, String payload)
{
try {
String hash = getDigest(payload);
if (hash == null) return false;
db.execSQL(String.format(INSERT_STATE, game, hash, payload, game));
} catch (SQLiteGdxException e) {
RustAndDust.error("storeState");
return false;
}
return true;
}
}
|
