DispatchServer.java 22 KB
Newer Older
Melledy's avatar
Melledy committed
1
2
3
4
5
6
package emu.grasscutter.server.dispatch;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.protobuf.ByteString;
import com.sun.net.httpserver.HttpExchange;
Jaida Wu's avatar
Jaida Wu committed
7
import com.sun.net.httpserver.HttpServer;
Melledy's avatar
Melledy committed
8
9
10
import com.sun.net.httpserver.HttpsConfigurator;
import com.sun.net.httpserver.HttpsServer;

11
import emu.grasscutter.Config;
Melledy's avatar
Melledy committed
12
13
14
15
16
17
18
import emu.grasscutter.Grasscutter;
import emu.grasscutter.database.DatabaseHelper;
import emu.grasscutter.game.Account;
import emu.grasscutter.net.proto.QueryCurrRegionHttpRspOuterClass.QueryCurrRegionHttpRsp;
import emu.grasscutter.net.proto.QueryRegionListHttpRspOuterClass.QueryRegionListHttpRsp;
import emu.grasscutter.net.proto.RegionInfoOuterClass.RegionInfo;
import emu.grasscutter.net.proto.RegionSimpleInfoOuterClass.RegionSimpleInfo;
Jaida Wu's avatar
Jaida Wu committed
19
import emu.grasscutter.server.dispatch.json.*;
Melledy's avatar
Melledy committed
20
21
22
23
import emu.grasscutter.server.dispatch.json.ComboTokenReqJson.LoginTokenData;
import emu.grasscutter.utils.FileUtils;
import emu.grasscutter.utils.Utils;

Jaida Wu's avatar
Jaida Wu committed
24
25
26
import javax.net.ssl.KeyManagerFactory;
import javax.net.ssl.SSLContext;
import java.io.*;
27
import java.net.BindException;
Jaida Wu's avatar
Jaida Wu committed
28
29
30
31
import java.net.InetSocketAddress;
import java.net.URI;
import java.net.URLDecoder;
import java.security.KeyStore;
32
import java.util.*;
Melledy's avatar
Melledy committed
33

KingRainbow44's avatar
KingRainbow44 committed
34
public final class DispatchServer {
Jaida Wu's avatar
Jaida Wu committed
35
36
	public static String query_region_list = "";
	public static String query_cur_region = "";
37

Melledy's avatar
Melledy committed
38
39
	private final InetSocketAddress address;
	private final Gson gson;
40
	private final String defaultServerName = "os_usa";
Melledy's avatar
Melledy committed
41
42
	
	public String regionListBase64;
43
44
	public HashMap<String, RegionData> regions;

Melledy's avatar
Melledy committed
45
	public DispatchServer() {
46
		this.regions = new HashMap<String, RegionData>();
47
		this.address = new InetSocketAddress(Grasscutter.getConfig().getDispatchOptions().Ip, Grasscutter.getConfig().getDispatchOptions().Port);
Melledy's avatar
Melledy committed
48
49
50
51
52
53
54
55
56
57
58
59
60
61
		this.gson = new GsonBuilder().create();
		
		this.loadQueries();
		this.initRegion();
	}
	
	public InetSocketAddress getAddress() {
		return address;
	}
	
	public Gson getGsonFactory() {
		return gson;
	}

62
63
64
65
	public QueryCurrRegionHttpRsp getCurrRegion() {
		// Needs to be fixed by having the game servers connect to the dispatch server.
		if(Grasscutter.getConfig().RunMode.equalsIgnoreCase("HYBRID")) {
			return regions.get(defaultServerName).parsedRegionQuery;
66
67
		}

68
		Grasscutter.getLogger().warn("[Dispatch] Unsupported run mode for getCurrRegion()");
69
		return null;
Melledy's avatar
Melledy committed
70
71
72
73
74
75
76
77
78
	}
	
	public void loadQueries() {
		File file;
		
		file = new File(Grasscutter.getConfig().DATA_FOLDER + "query_region_list.txt");
		if (file.exists()) {
			query_region_list = new String(FileUtils.read(file));
		} else {
Jaida Wu's avatar
Jaida Wu committed
79
			Grasscutter.getLogger().warn("[Dispatch] query_region_list not found! Using default region list.");
Melledy's avatar
Melledy committed
80
81
82
83
84
85
		}
	
		file = new File(Grasscutter.getConfig().DATA_FOLDER + "query_cur_region.txt");
		if (file.exists()) {
			query_cur_region = new String(FileUtils.read(file));
		} else {
Jaida Wu's avatar
Jaida Wu committed
86
			Grasscutter.getLogger().warn("[Dispatch] query_cur_region not found! Using default current region.");
Melledy's avatar
Melledy committed
87
88
89
90
91
92
93
94
95
96
		}
	}

	private void initRegion() {
		try {
			byte[] decoded = Base64.getDecoder().decode(query_region_list);
			QueryRegionListHttpRsp rl = QueryRegionListHttpRsp.parseFrom(decoded);
			
			byte[] decoded2 = Base64.getDecoder().decode(query_cur_region);
			QueryCurrRegionHttpRsp regionQuery = QueryCurrRegionHttpRsp.parseFrom(decoded2);
97

98
99
100
101
102
103
104
			List<RegionSimpleInfo> servers = new ArrayList<RegionSimpleInfo>();
			List<String> usedNames = new ArrayList<String>(); // List to check for potential naming conflicts
			if(Grasscutter.getConfig().RunMode.equalsIgnoreCase("HYBRID")) { // Automatically add the game server if in hybrid mode
				RegionSimpleInfo server = RegionSimpleInfo.newBuilder()
						.setName("os_usa")
						.setTitle(Grasscutter.getConfig().getGameServerOptions().Name)
						.setType("DEV_PUBLIC")
105
						.setDispatchUrl("http" + (Grasscutter.getConfig().getDispatchOptions().FrontHTTPS ? "s" : "") + "://" + (Grasscutter.getConfig().getDispatchOptions().PublicIp.isEmpty() ? Grasscutter.getConfig().getDispatchOptions().Ip : Grasscutter.getConfig().getDispatchOptions().PublicIp) + ":" + (Grasscutter.getConfig().getDispatchOptions().PublicPort != 0 ? Grasscutter.getConfig().getDispatchOptions().PublicPort : Grasscutter.getConfig().getDispatchOptions().Port) + "/query_cur_region_" + defaultServerName)
106
107
108
109
110
111
						.build();
				usedNames.add(defaultServerName);
				servers.add(server);

				RegionInfo serverRegion = regionQuery.getRegionInfo().toBuilder()
						.setIp((Grasscutter.getConfig().getGameServerOptions().PublicIp.isEmpty() ? Grasscutter.getConfig().getGameServerOptions().Ip : Grasscutter.getConfig().getGameServerOptions().PublicIp))
xtaodada's avatar
xtaodada committed
112
						.setPort(Grasscutter.getConfig().getGameServerOptions().PublicPort != 0 ? Grasscutter.getConfig().getGameServerOptions().PublicPort : Grasscutter.getConfig().getGameServerOptions().Port)
113
114
115
116
117
118
119
120
						.setSecretKey(ByteString.copyFrom(FileUtils.read(Grasscutter.getConfig().KEY_FOLDER + "dispatchSeed.bin")))
						.build();

				QueryCurrRegionHttpRsp parsedRegionQuery = regionQuery.toBuilder().setRegionInfo(serverRegion).build();
				regions.put(defaultServerName, new RegionData(parsedRegionQuery, Base64.getEncoder().encodeToString(parsedRegionQuery.toByteString().toByteArray())));

			} else {
				if(Grasscutter.getConfig().getDispatchOptions().getGameServers().length == 0) {
121
					Grasscutter.getLogger().error("[Dispatch] There are no game servers available. Exiting due to unplayable state.");
122
123
124
125
126
127
128
129
130
131
132
133
134
					System.exit(1);
				}
			}

			for (Config.DispatchServerOptions.RegionInfo regionInfo : Grasscutter.getConfig().getDispatchOptions().getGameServers()) {
				if(usedNames.contains(regionInfo.Name)) {
					Grasscutter.getLogger().error("Region name already in use.");
					continue;
				}
				RegionSimpleInfo server = RegionSimpleInfo.newBuilder()
						.setName(regionInfo.Name)
						.setTitle(regionInfo.Title)
						.setType("DEV_PUBLIC")
135
						.setDispatchUrl("http" + (Grasscutter.getConfig().getDispatchOptions().FrontHTTPS ? "s" : "") + "://" + (Grasscutter.getConfig().getDispatchOptions().PublicIp.isEmpty() ? Grasscutter.getConfig().getDispatchOptions().Ip : Grasscutter.getConfig().getDispatchOptions().PublicIp) + ":" + getAddress().getPort() + "/query_cur_region_" + regionInfo.Name)
136
137
138
139
140
141
142
143
144
145
146
147
148
149
						.build();
				usedNames.add(regionInfo.Name);
				servers.add(server);

				RegionInfo serverRegion = regionQuery.getRegionInfo().toBuilder()
						.setIp(regionInfo.Ip)
						.setPort(regionInfo.Port)
						.setSecretKey(ByteString.copyFrom(FileUtils.read(Grasscutter.getConfig().KEY_FOLDER + "dispatchSeed.bin")))
						.build();

				QueryCurrRegionHttpRsp parsedRegionQuery = regionQuery.toBuilder().setRegionInfo(serverRegion).build();
				regions.put(regionInfo.Name, new RegionData(parsedRegionQuery, Base64.getEncoder().encodeToString(parsedRegionQuery.toByteString().toByteArray())));
			}

Melledy's avatar
Melledy committed
150
			QueryRegionListHttpRsp regionList = QueryRegionListHttpRsp.newBuilder()
151
				.addAllServers(servers)
Melledy's avatar
Melledy committed
152
153
154
155
156
157
158
				.setClientSecretKey(rl.getClientSecretKey())
			    .setClientCustomConfigEncrypted(rl.getClientCustomConfigEncrypted())
			    .setEnableLoginPc(true)
				.build();

			this.regionListBase64 = Base64.getEncoder().encodeToString(regionList.toByteString().toByteArray());
		} catch (Exception e) {
159
			Grasscutter.getLogger().error("[Dispatch] Error while initializing region info!", e);
Melledy's avatar
Melledy committed
160
161
		}
	}
162
163
164
165
166
167
168
169
170
171
	
	private HttpServer safelyCreateServer(InetSocketAddress address) {
		try {
			return HttpServer.create(address, 0);
		} catch (BindException ignored) {
			Grasscutter.getLogger().error("Unable to bind to port: " + getAddress().getPort() + " (HTTP)");
		} catch (Exception exception) {
			Grasscutter.getLogger().error("Unable to start HTTP server.", exception);
		} return null;
	}
Melledy's avatar
Melledy committed
172
173

	public void start() throws Exception {
174
		HttpServer server;
175
		if (Grasscutter.getConfig().getDispatchOptions().UseSSL) {
176
			HttpsServer httpsServer = HttpsServer.create(getAddress(), 0);
177
			SSLContext sslContext = SSLContext.getInstance("TLS");
178
179
			try (FileInputStream fis = new FileInputStream(Grasscutter.getConfig().getDispatchOptions().KeystorePath)) {
				char[] keystorePassword = Grasscutter.getConfig().getDispatchOptions().KeystorePassword.toCharArray();
180
181
182
183
184
185
186
187
188
				KeyStore ks = KeyStore.getInstance("PKCS12");
				ks.load(fis, keystorePassword);
				KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");
				kmf.init(ks, keystorePassword);
				
				sslContext.init(kmf.getKeyManagers(), null, null);
				
				httpsServer.setHttpsConfigurator(new HttpsConfigurator(sslContext));
				server = httpsServer;
189
190
191
			} catch (BindException ignored) {
				Grasscutter.getLogger().error("Unable to bind to port: " + getAddress().getPort() + " (HTTPS)");
				server = this.safelyCreateServer(this.getAddress());
192
			} catch (Exception e) {
Jaida Wu's avatar
Jaida Wu committed
193
				Grasscutter.getLogger().warn("[Dispatch] No SSL cert found! Falling back to HTTP server.");
194
				Grasscutter.getConfig().getDispatchOptions().UseSSL = false;
195
				server = this.safelyCreateServer(this.getAddress());
196
197
			}
		} else {
198
			server = this.safelyCreateServer(this.getAddress());
Melledy's avatar
Melledy committed
199
		}
200
201
202
		
		if(server == null)
			throw new NullPointerException("An HTTP server was not created.");
Jaida Wu's avatar
Jaida Wu committed
203

Jaida Wu's avatar
Jaida Wu committed
204
		server.createContext("/", t -> responseHTML(t, "Hello"));
Melledy's avatar
Melledy committed
205
206
		
		// Dispatch
KingRainbow44's avatar
KingRainbow44 committed
207
208
		server.createContext("/query_region_list", t -> {
			// Log
Jaida Wu's avatar
Jaida Wu committed
209
			Grasscutter.getLogger().info(String.format("[Dispatch] Client %s request: query_region_list", t.getRemoteAddress()));
Jaida Wu's avatar
Jaida Wu committed
210
211

			responseHTML(t, regionListBase64);
Melledy's avatar
Melledy committed
212
		});
213
214
215
216
217

		for (String regionName : regions.keySet()) {
			server.createContext("/query_cur_region_" + regionName, t -> {
				String regionCurrentBase64 = regions.get(regionName).Base64;
				// Log
218
				Grasscutter.getLogger().info(String.format("Client %s request: query_cur_region_%s", t.getRemoteAddress(), regionName));
219
220
221
222
223
224
				// Create a response form the request query parameters
				URI uri = t.getRequestURI();
				String response = "CAESGE5vdCBGb3VuZCB2ZXJzaW9uIGNvbmZpZw==";
				if (uri.getQuery() != null && uri.getQuery().length() > 0) {
					response = regionCurrentBase64;
				}
225
				responseHTML(t, response);
226
227
228
			});
		}

Melledy's avatar
Melledy committed
229
		// Login via account
KingRainbow44's avatar
KingRainbow44 committed
230
231
232
233
234
235
		server.createContext("/hk4e_global/mdk/shield/api/login", t -> {
			// Get post data
			LoginAccountRequestJson requestData = null;
			try {
				String body = Utils.toString(t.getRequestBody());
				requestData = getGsonFactory().fromJson(body, LoginAccountRequestJson.class);
236
237
			} catch (Exception ignored) { }

KingRainbow44's avatar
KingRainbow44 committed
238
239
240
241
242
			// Create response json
			if (requestData == null) {
				return;
			}
			LoginResultJson responseData = new LoginResultJson();
Jaida Wu's avatar
Jaida Wu committed
243

Jaida Wu's avatar
Jaida Wu committed
244
			Grasscutter.getLogger().info(String.format("[Dispatch] Client %s is trying to log in", t.getRemoteAddress()));
KingRainbow44's avatar
KingRainbow44 committed
245
246
247
248
			
			// Login
			Account account = DatabaseHelper.getAccountByName(requestData.account);
			
249
			// Check if account exists, else create a new one.
250
251
			if (account == null) {
				// Account doesnt exist, so we can either auto create it if the config value is set
252
				if (Grasscutter.getConfig().getDispatchOptions().AutomaticallyCreateAccounts) {
253
254
					// This account has been created AUTOMATICALLY. There will be no permissions added.
					account = DatabaseHelper.createAccountWithId(requestData.account, 0);
Jaida Wu's avatar
Jaida Wu committed
255
256
257
258
259
260

					if (account != null) {
						responseData.message = "OK";
						responseData.data.account.uid = account.getId();
						responseData.data.account.token = account.generateSessionKey();
						responseData.data.account.email = account.getEmail();
Jaida Wu's avatar
Jaida Wu committed
261

Jaida Wu's avatar
Jaida Wu committed
262
						Grasscutter.getLogger().info(String.format("[Dispatch] Client %s failed to log in: Account %s created", t.getRemoteAddress(), responseData.data.account.uid));
Jaida Wu's avatar
Jaida Wu committed
263
264
265
					} else {
						responseData.retcode = -201;
						responseData.message = "Username not found, create failed.";
Jaida Wu's avatar
Jaida Wu committed
266

Jaida Wu's avatar
Jaida Wu committed
267
						Grasscutter.getLogger().info(String.format("[Dispatch] Client %s failed to log in: Account create failed", t.getRemoteAddress()));
Jaida Wu's avatar
Jaida Wu committed
268
					}
269
270
271
				} else {
					responseData.retcode = -201;
					responseData.message = "Username not found.";
Jaida Wu's avatar
Jaida Wu committed
272

Jaida Wu's avatar
Jaida Wu committed
273
					Grasscutter.getLogger().info(String.format("[Dispatch] Client %s failed to log in: Account no found", t.getRemoteAddress()));
274
				} 
KingRainbow44's avatar
KingRainbow44 committed
275
			} else {
276
				// Account was found, log the player in
KingRainbow44's avatar
KingRainbow44 committed
277
278
279
280
				responseData.message = "OK";
				responseData.data.account.uid = account.getId();
				responseData.data.account.token = account.generateSessionKey();
				responseData.data.account.email = account.getEmail();
Jaida Wu's avatar
Jaida Wu committed
281

Jaida Wu's avatar
Jaida Wu committed
282
				Grasscutter.getLogger().info(String.format("[Dispatch] Client %s logged in as %s", t.getRemoteAddress(), responseData.data.account.uid));
KingRainbow44's avatar
KingRainbow44 committed
283
			}
Jaida Wu's avatar
Jaida Wu committed
284

Jaida Wu's avatar
Jaida Wu committed
285
			responseJSON(t, responseData);
Melledy's avatar
Melledy committed
286
287
		});
		// Login via token
KingRainbow44's avatar
KingRainbow44 committed
288
289
290
291
292
293
		server.createContext("/hk4e_global/mdk/shield/api/verify", t -> {
			// Get post data
			LoginTokenRequestJson requestData = null;
			try {
				String body = Utils.toString(t.getRequestBody());
				requestData = getGsonFactory().fromJson(body, LoginTokenRequestJson.class);
294
295
			} catch (Exception ignored) { }

KingRainbow44's avatar
KingRainbow44 committed
296
297
298
299
300
			// Create response json
			if (requestData == null) {
				return;
			}
			LoginResultJson responseData = new LoginResultJson();
Jaida Wu's avatar
Jaida Wu committed
301
			Grasscutter.getLogger().info(String.format("[Dispatch] Client %s is trying to log in via token", t.getRemoteAddress()));
KingRainbow44's avatar
KingRainbow44 committed
302
303
304
305
306
307
308
309

			// Login
			Account account = DatabaseHelper.getAccountById(requestData.uid);
			
			// Test
			if (account == null || !account.getSessionKey().equals(requestData.token)) {
				responseData.retcode = -111;
				responseData.message = "Game account cache information error";
Jaida Wu's avatar
Jaida Wu committed
310

Jaida Wu's avatar
Jaida Wu committed
311
				Grasscutter.getLogger().info(String.format("[Dispatch] Client %s failed to log in via token", t.getRemoteAddress()));
KingRainbow44's avatar
KingRainbow44 committed
312
313
314
315
316
			} else {
				responseData.message = "OK";
				responseData.data.account.uid = requestData.uid;
				responseData.data.account.token = requestData.token;
				responseData.data.account.email = account.getEmail();
Jaida Wu's avatar
Jaida Wu committed
317

Jaida Wu's avatar
Jaida Wu committed
318
				Grasscutter.getLogger().info(String.format("[Dispatch] Client %s logged in via token as %s", t.getRemoteAddress(), responseData.data.account.uid));
KingRainbow44's avatar
KingRainbow44 committed
319
			}
Jaida Wu's avatar
Jaida Wu committed
320

Jaida Wu's avatar
Jaida Wu committed
321
			responseJSON(t, responseData);
Melledy's avatar
Melledy committed
322
323
		});
		// Exchange for combo token
KingRainbow44's avatar
KingRainbow44 committed
324
325
326
327
328
329
		server.createContext("/hk4e_global/combo/granter/login/v2/login", t -> {
			// Get post data
			ComboTokenReqJson requestData = null;
			try {
				String body = Utils.toString(t.getRequestBody());
				requestData = getGsonFactory().fromJson(body, ComboTokenReqJson.class);
330
331
			} catch (Exception ignored) { }

KingRainbow44's avatar
KingRainbow44 committed
332
333
334
335
336
337
338
339
340
341
342
343
344
345
			// Create response json
			if (requestData == null || requestData.data == null) {
				return;
			}
			LoginTokenData loginData = getGsonFactory().fromJson(requestData.data, LoginTokenData.class); // Get login data
			ComboTokenResJson responseData = new ComboTokenResJson();

			// Login
			Account account = DatabaseHelper.getAccountById(loginData.uid);
			
			// Test
			if (account == null || !account.getSessionKey().equals(loginData.token)) {
				responseData.retcode = -201;
				responseData.message = "Wrong session key.";
Jaida Wu's avatar
Jaida Wu committed
346

Jaida Wu's avatar
Jaida Wu committed
347
				Grasscutter.getLogger().info(String.format("[Dispatch] Client %s failed to exchange combo token", t.getRemoteAddress()));
KingRainbow44's avatar
KingRainbow44 committed
348
349
350
351
352
			} else {
				responseData.message = "OK";
				responseData.data.open_id = loginData.uid;
				responseData.data.combo_id = "157795300";
				responseData.data.combo_token = account.generateLoginToken();
Jaida Wu's avatar
Jaida Wu committed
353

Jaida Wu's avatar
Jaida Wu committed
354
				Grasscutter.getLogger().info(String.format("[Dispatch] Client %s succeed to exchange combo token", t.getRemoteAddress()));
KingRainbow44's avatar
KingRainbow44 committed
355
			}
Jaida Wu's avatar
Jaida Wu committed
356

Jaida Wu's avatar
Jaida Wu committed
357
			responseJSON(t, responseData);
Melledy's avatar
Melledy committed
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
		});
		// Agreement and Protocol
		server.createContext( // hk4e-sdk-os.hoyoverse.com
				"/hk4e_global/mdk/agreement/api/getAgreementInfos", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"marketing_agreements\":[]}}")
		);
		server.createContext( // hk4e-sdk-os.hoyoverse.com
				"/hk4e_global/combo/granter/api/compareProtocolVersion", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"modified\":true,\"protocol\":{\"id\":0,\"app_id\":4,\"language\":\"en\",\"user_proto\":\"\",\"priv_proto\":\"\",\"major\":7,\"minimum\":0,\"create_time\":\"0\",\"teenager_proto\":\"\",\"third_proto\":\"\"}}}")
		);
		// Game data
		server.createContext( // hk4e-api-os.hoyoverse.com
				"/common/hk4e_global/announcement/api/getAlertPic", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"total\":0,\"list\":[]}}")
		);
		server.createContext( // hk4e-api-os.hoyoverse.com
				"/common/hk4e_global/announcement/api/getAlertAnn",
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"alert\":false,\"alert_id\":0,\"remind\":true}}")
		);
		server.createContext( // hk4e-api-os.hoyoverse.com
				"/common/hk4e_global/announcement/api/getAnnList", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"list\":[],\"total\":0,\"type_list\":[],\"alert\":false,\"alert_id\":0,\"timezone\":0,\"t\":\"" + System.currentTimeMillis() + "\"}}")
		);
		server.createContext( // hk4e-api-os-static.hoyoverse.com
				"/common/hk4e_global/announcement/api/getAnnContent", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"list\":[],\"total\":0}}")
		);
		server.createContext( // hk4e-sdk-os.hoyoverse.com
				"/hk4e_global/mdk/shopwindow/shopwindow/listPriceTier", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"suggest_currency\":\"USD\",\"tiers\":[]}}")
		);
		// Captcha
		server.createContext( // api-account-os.hoyoverse.com
				"/account/risky/api/check", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"id\":\"c8820f246a5241ab9973f71df3ddd791\",\"action\":\"\",\"geetest\":{\"challenge\":\"\",\"gt\":\"\",\"new_captcha\":0,\"success\":1}}}")
		);
		// Config	
		server.createContext( // sdk-os-static.hoyoverse.com
				"/combo/box/api/config/sdk/combo", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"vals\":{\"disable_email_bind_skip\":\"false\",\"email_bind_remind_interval\":\"7\",\"email_bind_remind\":\"true\"}}}")
		);
		server.createContext( // hk4e-sdk-os-static.hoyoverse.com
				"/hk4e_global/combo/granter/api/getConfig", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"protocol\":true,\"qr_enabled\":false,\"log_level\":\"INFO\",\"announce_url\":\"https://webstatic-sea.hoyoverse.com/hk4e/announcement/index.html?sdk_presentation_style=fullscreen\\u0026sdk_screen_transparent=true\\u0026game_biz=hk4e_global\\u0026auth_appid=announcement\\u0026game=hk4e#/\",\"push_alias_type\":2,\"disable_ysdk_guard\":false,\"enable_announce_pic_popup\":true}}")
		);
		server.createContext( // hk4e-sdk-os-static.hoyoverse.com
				"/hk4e_global/mdk/shield/api/loadConfig", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"message\":\"OK\",\"data\":{\"id\":6,\"game_key\":\"hk4e_global\",\"client\":\"PC\",\"identity\":\"I_IDENTITY\",\"guest\":false,\"ignore_versions\":\"\",\"scene\":\"S_NORMAL\",\"name\":\"原神海外\",\"disable_regist\":false,\"enable_email_captcha\":false,\"thirdparty\":[\"fb\",\"tw\"],\"disable_mmt\":false,\"server_guest\":false,\"thirdparty_ignore\":{\"tw\":\"\",\"fb\":\"\"},\"enable_ps_bind_account\":false,\"thirdparty_login_configs\":{\"tw\":{\"token_type\":\"TK_GAME_TOKEN\",\"game_token_expires_in\":604800},\"fb\":{\"token_type\":\"TK_GAME_TOKEN\",\"game_token_expires_in\":604800}}}}")
		);
		// Test api?
		server.createContext( // abtest-api-data-sg.hoyoverse.com
				"/data_abtest_api/config/experiment/list", 
				new DispatchHttpJsonHandler("{\"retcode\":0,\"success\":true,\"message\":\"\",\"data\":[{\"code\":1000,\"type\":2,\"config_id\":\"14\",\"period_id\":\"6036_99\",\"version\":\"1\",\"configs\":{\"cardType\":\"old\"}}]}")
		);
		// Log Server 
		server.createContext( // log-upload-os.mihoyo.com
				"/log/sdk/upload", 
				new DispatchHttpJsonHandler("{\"code\":0}")
		);
		server.createContext( // log-upload-os.mihoyo.com
				"/sdk/upload", 
				new DispatchHttpJsonHandler("{\"code\":0}")
		);
OtakuNekoP's avatar
OtakuNekoP committed
421
422
423
424
		server.createContext( // /perf/config/verify?device_id=xxx&platform=x&name=xxx
				"/perf/config/verify", 
				new DispatchHttpJsonHandler("{\"code\":0}")
		);
Melledy's avatar
Melledy committed
425
426
		
		// Logging servers
Jaida Wu's avatar
Jaida Wu committed
427
		server.createContext( // overseauspider.yuanshen.com
Jaida Wu's avatar
Jaida Wu committed
428
				"/log",
Melledy's avatar
Melledy committed
429
430
				new DispatchHttpJsonHandler("{\"code\":0}")
		);
Jaida Wu's avatar
Jaida Wu committed
431

Jaida Wu's avatar
Jaida Wu committed
432
		server.createContext( // log-upload-os.mihoyo.com
Jaida Wu's avatar
Jaida Wu committed
433
				"/crash/dataUpload",
Melledy's avatar
Melledy committed
434
435
				new DispatchHttpJsonHandler("{\"code\":0}")
		);
Jaida Wu's avatar
Jaida Wu committed
436
		server.createContext("/gacha", t -> responseHTML(t, "<!doctype html><html lang=\"en\"><head><title>Gacha</title></head><body></body></html>"));
437

Jaida Wu's avatar
Jaida Wu committed
438
439
		// Start server
		server.start();
Jaida Wu's avatar
Jaida Wu committed
440
		Grasscutter.getLogger().info("[Dispatch] Dispatch server started on port " + getAddress().getPort());
Melledy's avatar
Melledy committed
441
	}
Jaida Wu's avatar
Jaida Wu committed
442

Jaida Wu's avatar
Jaida Wu committed
443
	private void responseJSON(HttpExchange t, Object data) throws IOException {
Jaida Wu's avatar
Jaida Wu committed
444
445
446
447
448
449
450
451
452
453
454
		// Create a response
		String response = getGsonFactory().toJson(data);
		// Set the response header status and length
		t.getResponseHeaders().put("Content-Type", Collections.singletonList("application/json"));
		t.sendResponseHeaders(200, response.getBytes().length);
		// Write the response string
		OutputStream os = t.getResponseBody();
		os.write(response.getBytes());
		os.close();
	}

Jaida Wu's avatar
Jaida Wu committed
455
456
457
458
459
460
461
462
	private void responseHTML(HttpExchange t, String response) throws IOException {
		// Set the response header status and length
		t.getResponseHeaders().put("Content-Type", Collections.singletonList("text/html; charset=UTF-8"));
		t.sendResponseHeaders(200, response.getBytes().length);
		//Write the response string
		OutputStream os = t.getResponseBody();
		os.write(response.getBytes());
		os.close();
Melledy's avatar
Melledy committed
463
464
465
	}
	
	private Map<String, String> parseQueryString(String qs) {
Jaida Wu's avatar
Jaida Wu committed
466
		Map<String, String> result = new HashMap<>();
Jaida Wu's avatar
Jaida Wu committed
467
		if (qs == null) {
Jaida Wu's avatar
Jaida Wu committed
468
			return result;
Jaida Wu's avatar
Jaida Wu committed
469
		}
Jaida Wu's avatar
Jaida Wu committed
470
471
472
473

		int last = 0, next, l = qs.length();
		while (last < l) {
			next = qs.indexOf('&', last);
Jaida Wu's avatar
Jaida Wu committed
474
			if (next == -1) {
Jaida Wu's avatar
Jaida Wu committed
475
				next = l;
Jaida Wu's avatar
Jaida Wu committed
476
			}
Jaida Wu's avatar
Jaida Wu committed
477
478
479
480

			if (next > last) {
				int eqPos = qs.indexOf('=', last);
				try {
Jaida Wu's avatar
Jaida Wu committed
481
					if (eqPos < 0 || eqPos > next) {
Jaida Wu's avatar
Jaida Wu committed
482
						result.put(URLDecoder.decode(qs.substring(last, next), "utf-8"), "");
Jaida Wu's avatar
Jaida Wu committed
483
					} else {
Jaida Wu's avatar
Jaida Wu committed
484
						result.put(URLDecoder.decode(qs.substring(last, eqPos), "utf-8"), URLDecoder.decode(qs.substring(eqPos + 1, next), "utf-8"));
Jaida Wu's avatar
Jaida Wu committed
485
					}
Jaida Wu's avatar
Jaida Wu committed
486
487
488
489
490
491
492
				} catch (UnsupportedEncodingException e) {
					throw new RuntimeException(e); // will never happen, utf-8 support is mandatory for java
				}
			}
			last = next + 1;
		}
		return result;
Melledy's avatar
Melledy committed
493
	}
494
495
496
497
498
499
500
501
502
503
504

	public static class RegionData {

		QueryCurrRegionHttpRsp parsedRegionQuery;
		String Base64;

		public RegionData(QueryCurrRegionHttpRsp prq, String b64) {
			this.parsedRegionQuery = prq;
			this.Base64 = b64;
		}
	}
Melledy's avatar
Melledy committed
505
}