Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in / Register
Toggle navigation
Menu
Open sidebar
ziqian zhang
Grasscutter
Commits
d11413c0
Commit
d11413c0
authored
Apr 21, 2022
by
Jaida Wu
Browse files
Add dispatch server log prefix
Signed-off-by:
Jaida Wu
<
mlgmxyysd@meowcat.org
>
parent
1143886b
Changes
1
Hide whitespace changes
Inline
Side-by-side
src/main/java/emu/grasscutter/server/dispatch/DispatchServer.java
View file @
d11413c0
...
@@ -67,14 +67,14 @@ public final class DispatchServer {
...
@@ -67,14 +67,14 @@ public final class DispatchServer {
if
(
file
.
exists
())
{
if
(
file
.
exists
())
{
query_region_list
=
new
String
(
FileUtils
.
read
(
file
));
query_region_list
=
new
String
(
FileUtils
.
read
(
file
));
}
else
{
}
else
{
Grasscutter
.
getLogger
().
warn
(
"query_region_list not found! Using default region list."
);
Grasscutter
.
getLogger
().
warn
(
"
[Dispatch]
query_region_list not found! Using default region list."
);
}
}
file
=
new
File
(
Grasscutter
.
getConfig
().
DATA_FOLDER
+
"query_cur_region.txt"
);
file
=
new
File
(
Grasscutter
.
getConfig
().
DATA_FOLDER
+
"query_cur_region.txt"
);
if
(
file
.
exists
())
{
if
(
file
.
exists
())
{
query_cur_region
=
new
String
(
FileUtils
.
read
(
file
));
query_cur_region
=
new
String
(
FileUtils
.
read
(
file
));
}
else
{
}
else
{
Grasscutter
.
getLogger
().
warn
(
"query_cur_region not found! Using default current region."
);
Grasscutter
.
getLogger
().
warn
(
"
[Dispatch]
query_cur_region not found! Using default current region."
);
}
}
}
}
...
@@ -120,7 +120,7 @@ public final class DispatchServer {
...
@@ -120,7 +120,7 @@ public final class DispatchServer {
this
.
regionCurrentBase64
=
Base64
.
getEncoder
().
encodeToString
(
parsedRegionQuery
.
toByteString
().
toByteArray
());
this
.
regionCurrentBase64
=
Base64
.
getEncoder
().
encodeToString
(
parsedRegionQuery
.
toByteString
().
toByteArray
());
this
.
currRegion
=
parsedRegionQuery
;
this
.
currRegion
=
parsedRegionQuery
;
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
Grasscutter
.
getLogger
().
error
(
"Error while initializing region info!"
,
e
);
Grasscutter
.
getLogger
().
error
(
"
[Dispatch]
Error while initializing region info!"
,
e
);
}
}
}
}
...
@@ -142,7 +142,7 @@ public final class DispatchServer {
...
@@ -142,7 +142,7 @@ public final class DispatchServer {
httpsServer
.
setHttpsConfigurator
(
new
HttpsConfigurator
(
sslContext
));
httpsServer
.
setHttpsConfigurator
(
new
HttpsConfigurator
(
sslContext
));
server
=
httpsServer
;
server
=
httpsServer
;
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
Grasscutter
.
getLogger
().
error
(
"
No SSL cert found! Falling back to HTTP server."
);
Grasscutter
.
getLogger
().
warn
(
"[Dispatch]
No SSL cert found! Falling back to HTTP server."
);
Grasscutter
.
getConfig
().
UseSSL
=
false
;
Grasscutter
.
getConfig
().
UseSSL
=
false
;
server
=
HttpServer
.
create
(
getAddress
(),
0
);
server
=
HttpServer
.
create
(
getAddress
(),
0
);
}
}
...
@@ -155,13 +155,13 @@ public final class DispatchServer {
...
@@ -155,13 +155,13 @@ public final class DispatchServer {
// Dispatch
// Dispatch
server
.
createContext
(
"/query_region_list"
,
t
->
{
server
.
createContext
(
"/query_region_list"
,
t
->
{
// Log
// Log
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s request: query_region_list"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s request: query_region_list"
,
t
.
getRemoteAddress
()));
responseHTML
(
t
,
regionListBase64
);
responseHTML
(
t
,
regionListBase64
);
});
});
server
.
createContext
(
"/query_cur_region"
,
t
->
{
server
.
createContext
(
"/query_cur_region"
,
t
->
{
// Log
// Log
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s request: query_cur_region"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s request: query_cur_region"
,
t
.
getRemoteAddress
()));
// Create a response form the request query parameters
// Create a response form the request query parameters
URI
uri
=
t
.
getRequestURI
();
URI
uri
=
t
.
getRequestURI
();
String
response
=
"CAESGE5vdCBGb3VuZCB2ZXJzaW9uIGNvbmZpZw=="
;
String
response
=
"CAESGE5vdCBGb3VuZCB2ZXJzaW9uIGNvbmZpZw=="
;
...
@@ -186,7 +186,7 @@ public final class DispatchServer {
...
@@ -186,7 +186,7 @@ public final class DispatchServer {
}
}
LoginResultJson
responseData
=
new
LoginResultJson
();
LoginResultJson
responseData
=
new
LoginResultJson
();
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s is trying to log in"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s is trying to log in"
,
t
.
getRemoteAddress
()));
// Login
// Login
Account
account
=
DatabaseHelper
.
getAccountByName
(
requestData
.
account
);
Account
account
=
DatabaseHelper
.
getAccountByName
(
requestData
.
account
);
...
@@ -204,18 +204,18 @@ public final class DispatchServer {
...
@@ -204,18 +204,18 @@ public final class DispatchServer {
responseData
.
data
.
account
.
token
=
account
.
generateSessionKey
();
responseData
.
data
.
account
.
token
=
account
.
generateSessionKey
();
responseData
.
data
.
account
.
email
=
account
.
getEmail
();
responseData
.
data
.
account
.
email
=
account
.
getEmail
();
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s failed to log in: Account %s created"
,
t
.
getRemoteAddress
(),
responseData
.
data
.
account
.
uid
));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s failed to log in: Account %s created"
,
t
.
getRemoteAddress
(),
responseData
.
data
.
account
.
uid
));
}
else
{
}
else
{
responseData
.
retcode
=
-
201
;
responseData
.
retcode
=
-
201
;
responseData
.
message
=
"Username not found, create failed."
;
responseData
.
message
=
"Username not found, create failed."
;
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s failed to log in: Account create failed"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s failed to log in: Account create failed"
,
t
.
getRemoteAddress
()));
}
}
}
else
{
}
else
{
responseData
.
retcode
=
-
201
;
responseData
.
retcode
=
-
201
;
responseData
.
message
=
"Username not found."
;
responseData
.
message
=
"Username not found."
;
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s failed to log in: Account no found"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s failed to log in: Account no found"
,
t
.
getRemoteAddress
()));
}
}
}
else
{
}
else
{
// Account was found, log the player in
// Account was found, log the player in
...
@@ -224,7 +224,7 @@ public final class DispatchServer {
...
@@ -224,7 +224,7 @@ public final class DispatchServer {
responseData
.
data
.
account
.
token
=
account
.
generateSessionKey
();
responseData
.
data
.
account
.
token
=
account
.
generateSessionKey
();
responseData
.
data
.
account
.
email
=
account
.
getEmail
();
responseData
.
data
.
account
.
email
=
account
.
getEmail
();
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s logged in as %s"
,
t
.
getRemoteAddress
(),
responseData
.
data
.
account
.
uid
));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s logged in as %s"
,
t
.
getRemoteAddress
(),
responseData
.
data
.
account
.
uid
));
}
}
responseJSON
(
t
,
responseData
);
responseJSON
(
t
,
responseData
);
...
@@ -244,7 +244,7 @@ public final class DispatchServer {
...
@@ -244,7 +244,7 @@ public final class DispatchServer {
return
;
return
;
}
}
LoginResultJson
responseData
=
new
LoginResultJson
();
LoginResultJson
responseData
=
new
LoginResultJson
();
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s is trying to log in via token"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s is trying to log in via token"
,
t
.
getRemoteAddress
()));
// Login
// Login
Account
account
=
DatabaseHelper
.
getAccountById
(
requestData
.
uid
);
Account
account
=
DatabaseHelper
.
getAccountById
(
requestData
.
uid
);
...
@@ -254,14 +254,14 @@ public final class DispatchServer {
...
@@ -254,14 +254,14 @@ public final class DispatchServer {
responseData
.
retcode
=
-
111
;
responseData
.
retcode
=
-
111
;
responseData
.
message
=
"Game account cache information error"
;
responseData
.
message
=
"Game account cache information error"
;
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s failed to log in via token"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s failed to log in via token"
,
t
.
getRemoteAddress
()));
}
else
{
}
else
{
responseData
.
message
=
"OK"
;
responseData
.
message
=
"OK"
;
responseData
.
data
.
account
.
uid
=
requestData
.
uid
;
responseData
.
data
.
account
.
uid
=
requestData
.
uid
;
responseData
.
data
.
account
.
token
=
requestData
.
token
;
responseData
.
data
.
account
.
token
=
requestData
.
token
;
responseData
.
data
.
account
.
email
=
account
.
getEmail
();
responseData
.
data
.
account
.
email
=
account
.
getEmail
();
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s logged in via token as %s"
,
t
.
getRemoteAddress
(),
responseData
.
data
.
account
.
uid
));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s logged in via token as %s"
,
t
.
getRemoteAddress
(),
responseData
.
data
.
account
.
uid
));
}
}
responseJSON
(
t
,
responseData
);
responseJSON
(
t
,
responseData
);
...
@@ -290,14 +290,14 @@ public final class DispatchServer {
...
@@ -290,14 +290,14 @@ public final class DispatchServer {
responseData
.
retcode
=
-
201
;
responseData
.
retcode
=
-
201
;
responseData
.
message
=
"Wrong session key."
;
responseData
.
message
=
"Wrong session key."
;
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s failed to exchange combo token"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s failed to exchange combo token"
,
t
.
getRemoteAddress
()));
}
else
{
}
else
{
responseData
.
message
=
"OK"
;
responseData
.
message
=
"OK"
;
responseData
.
data
.
open_id
=
loginData
.
uid
;
responseData
.
data
.
open_id
=
loginData
.
uid
;
responseData
.
data
.
combo_id
=
"157795300"
;
responseData
.
data
.
combo_id
=
"157795300"
;
responseData
.
data
.
combo_token
=
account
.
generateLoginToken
();
responseData
.
data
.
combo_token
=
account
.
generateLoginToken
();
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"Client %s succeed to exchange combo token"
,
t
.
getRemoteAddress
()));
Grasscutter
.
getLogger
().
info
(
String
.
format
(
"
[Dispatch]
Client %s succeed to exchange combo token"
,
t
.
getRemoteAddress
()));
}
}
responseJSON
(
t
,
responseData
);
responseJSON
(
t
,
responseData
);
...
@@ -382,7 +382,7 @@ public final class DispatchServer {
...
@@ -382,7 +382,7 @@ public final class DispatchServer {
server
.
createContext
(
"/gacha"
,
t
->
responseHTML
(
t
,
"<!doctype html><html lang=\"en\"><head><title>Gacha</title></head><body></body></html>"
));
server
.
createContext
(
"/gacha"
,
t
->
responseHTML
(
t
,
"<!doctype html><html lang=\"en\"><head><title>Gacha</title></head><body></body></html>"
));
// Start server
// Start server
server
.
start
();
server
.
start
();
Grasscutter
.
getLogger
().
info
(
"Dispatch server started on port "
+
getAddress
().
getPort
());
Grasscutter
.
getLogger
().
info
(
"
[Dispatch]
Dispatch server started on port "
+
getAddress
().
getPort
());
}
}
private
void
responseJSON
(
HttpExchange
t
,
Object
data
)
throws
IOException
{
private
void
responseJSON
(
HttpExchange
t
,
Object
data
)
throws
IOException
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment