09 12 25
Исправил что бы во входящих запросах тоже был payload
This commit is contained in:
AidarKC
parent
199769cac0
commit
2b5fa16824
@ -17,12 +17,13 @@ import java.util.Map;
|
||||
|
||||
/**
|
||||
* JsonInboundProcessor — обработка JSON-сообщений.
|
||||
*.
|
||||
* 1) Парсит общий пакет (op, requestId,...).
|
||||
*
|
||||
* 1) Парсит общий пакет (op, requestId, payload).
|
||||
* 2) По op выбирает класс запроса и хэндлер.
|
||||
* 3) Маппит JSON → NetRequest через ObjectMapper.
|
||||
* 4) Вызывает хэндлер, получает NetResponse.
|
||||
* 5) Собирает JSON-ответ:
|
||||
* 3) Собирает "плоский" объект: op + requestId + поля из payload.
|
||||
* 4) Маппит его в NetRequest через ObjectMapper.
|
||||
* 5) Вызывает хэндлер, получает NetResponse.
|
||||
* 6) Собирает JSON-ответ:
|
||||
* {
|
||||
* "op": ...,
|
||||
* "requestId": ...,
|
||||
@ -42,7 +43,9 @@ public final class JsonInboundProcessor {
|
||||
private static final Map<String, Class<? extends NetRequest>> JSON_REQUEST_TYPES =
|
||||
JsonHandlerRegistry.getRequestTypes();
|
||||
|
||||
private JsonInboundProcessor() {}
|
||||
private JsonInboundProcessor() {
|
||||
// utility
|
||||
}
|
||||
|
||||
public static String processJson(String json, ConnectionContext ctx) {
|
||||
String op = null;
|
||||
@ -63,7 +66,7 @@ public final class JsonInboundProcessor {
|
||||
// 1. Парсим общий пакет
|
||||
JsonNode root = JSON_MAPPER.readTree(json);
|
||||
|
||||
// 2. op и requestId
|
||||
// 2. op и requestId из корня
|
||||
op = getTextOrNull(root, "op");
|
||||
requestId = getTextOrNull(root, "requestId");
|
||||
|
||||
@ -92,12 +95,50 @@ public final class JsonInboundProcessor {
|
||||
return writeResponse(err);
|
||||
}
|
||||
|
||||
// 3. Маппим JSON → нужный NetRequest
|
||||
NetRequest request = JSON_MAPPER.treeToValue(root, reqClass);
|
||||
// 3. Берём payload
|
||||
JsonNode payloadNode = root.get("payload");
|
||||
if (payloadNode == null || payloadNode.isNull()) {
|
||||
NetExceptionResponse err = NetExceptionResponseFactory.error(
|
||||
op,
|
||||
requestId,
|
||||
WireCodes.Status.BAD_REQUEST,
|
||||
"NO_PAYLOAD",
|
||||
"Поле 'payload' отсутствует"
|
||||
);
|
||||
return writeResponse(err);
|
||||
}
|
||||
if (!payloadNode.isObject()) {
|
||||
NetExceptionResponse err = NetExceptionResponseFactory.error(
|
||||
op,
|
||||
requestId,
|
||||
WireCodes.Status.BAD_REQUEST,
|
||||
"BAD_PAYLOAD",
|
||||
"Поле 'payload' должно быть объектом"
|
||||
);
|
||||
return writeResponse(err);
|
||||
}
|
||||
|
||||
// 3.1 Собираем "плоский" объект для маппинга в NetRequest:
|
||||
// op + requestId + поля из payload
|
||||
ObjectNode merged = JSON_MAPPER.createObjectNode();
|
||||
|
||||
// Добавляем op и requestId, чтобы они попали в NetRequest
|
||||
if (op != null) {
|
||||
merged.put("op", op);
|
||||
}
|
||||
if (requestId != null) {
|
||||
merged.put("requestId", requestId);
|
||||
}
|
||||
|
||||
// Добавляем все поля из payload внутрь
|
||||
merged.setAll((ObjectNode) payloadNode);
|
||||
|
||||
// 4. Маппим в конкретный класс NetRequest
|
||||
NetRequest request = JSON_MAPPER.treeToValue(merged, reqClass);
|
||||
|
||||
NetResponse response;
|
||||
|
||||
// 4. Трай-кэтч вокруг хэндлера
|
||||
// 5. Вызываем хэндлер
|
||||
try {
|
||||
response = handler.handle(request, ctx);
|
||||
} catch (Exception handlerError) {
|
||||
@ -116,7 +157,7 @@ public final class JsonInboundProcessor {
|
||||
if (response.getOp() == null) response.setOp(op);
|
||||
if (response.getRequestId() == null) response.setRequestId(requestId);
|
||||
|
||||
// 5. Универсальная сборка ответа
|
||||
// 6. Универсальная сборка ответа
|
||||
return writeResponse(response);
|
||||
|
||||
} catch (Exception e) {
|
||||
|
||||
@ -166,6 +166,7 @@ public class NetAuthSessionNewStep2Handler implements JsonMessageHandler {
|
||||
ctx.setSessionId(sessionId);
|
||||
ctx.setAuthenticationStatus(ConnectionContext.AUTH_STATUS_USER);
|
||||
|
||||
ActiveConnectionsRegistry.getInstance().removeBySessionId(sessionId); // га всякий случай предварительно удаляем что бы точно небыло дублирования активной сессии
|
||||
// Регистрируем это подключение в глобальном реестре активных соединений
|
||||
ActiveConnectionsRegistry.getInstance().register(ctx);
|
||||
|
||||
|
||||
@ -110,6 +110,7 @@ public class NetSessionRefreshHandler implements JsonMessageHandler {
|
||||
ctx.setSessionPwd(sessionPwd);
|
||||
ctx.setAuthenticationStatus(ConnectionContext.AUTH_STATUS_USER);
|
||||
|
||||
ActiveConnectionsRegistry.getInstance().removeBySessionId(sessionId); // на всякий случай удаляем что бы точно небыло повторов
|
||||
// Регистрируем это подключение в глобальном реестре активных соединений
|
||||
ActiveConnectionsRegistry.getInstance().register(ctx);
|
||||
}
|
||||
|
||||
1
src/TODO.txt
Normal file
1
src/TODO.txt
Normal file
@ -0,0 +1 @@
|
||||
Сделать потом что бы на каждую сессию стояло время последнего подключения и откуда оно было - но видимо это уже в свойства запихивать надо.
|
||||
@ -16,15 +16,18 @@ public class TestJsonWsClient2 {
|
||||
{
|
||||
"op": "SessionRefresh",
|
||||
"requestId": "test-1",
|
||||
"payload": {
|
||||
"sessionId": 123,
|
||||
"sessionPwd": "test-password"
|
||||
}
|
||||
}
|
||||
""";
|
||||
|
||||
String jsonRequestAddUser = """
|
||||
{
|
||||
"op": "AddUser",
|
||||
"requestId": "test-add-1",
|
||||
"payload": {
|
||||
"login": "anya1111",
|
||||
"loginId": 100211,
|
||||
"bchId": 4222,
|
||||
@ -32,14 +35,17 @@ public class TestJsonWsClient2 {
|
||||
"pubkey1": "PUB1",
|
||||
"bchLimit": 1000000
|
||||
}
|
||||
}
|
||||
""";
|
||||
|
||||
String jsonRequestAuthSessionNewStep1 = """
|
||||
{
|
||||
"op": "AuthSessionNewStep1",
|
||||
"requestId": "test-auth-1",
|
||||
"payload": {
|
||||
"login": "anya1111"
|
||||
}
|
||||
}
|
||||
""";
|
||||
|
||||
// Что тестируем сейчас:
|
||||
|
||||
@ -64,6 +64,7 @@ public class Test_AddUser_FirstAuth {
|
||||
{
|
||||
"op": "AddUser",
|
||||
"requestId": "test-add-1",
|
||||
"payload": {
|
||||
"login": "%s",
|
||||
"loginId": %d,
|
||||
"bchId": %d,
|
||||
@ -71,6 +72,7 @@ public class Test_AddUser_FirstAuth {
|
||||
"pubkey1": "%s",
|
||||
"bchLimit": %d
|
||||
}
|
||||
}
|
||||
""".formatted(
|
||||
TEST_LOGIN,
|
||||
TEST_LOGIN_ID,
|
||||
@ -87,8 +89,10 @@ public class Test_AddUser_FirstAuth {
|
||||
{
|
||||
"op": "AuthSessionNewStep1",
|
||||
"requestId": "test-auth-1",
|
||||
"payload": {
|
||||
"login": "%s"
|
||||
}
|
||||
}
|
||||
""".formatted(TEST_LOGIN);
|
||||
}
|
||||
|
||||
@ -112,11 +116,13 @@ public class Test_AddUser_FirstAuth {
|
||||
{
|
||||
"op": "AuthSessionNewStep2",
|
||||
"requestId": "test-auth-2",
|
||||
"payload": {
|
||||
"loginId": %d,
|
||||
"sigNum": 0,
|
||||
"timeMs": %d,
|
||||
"signatureB64": "%s"
|
||||
}
|
||||
}
|
||||
""".formatted(
|
||||
TEST_LOGIN_ID,
|
||||
timeMs,
|
||||
|
||||
@ -40,16 +40,17 @@ public class Test_SessionRefreshClient {
|
||||
{
|
||||
"op": "SessionRefresh",
|
||||
"requestId": "test-session-refresh-1",
|
||||
"payload": {
|
||||
"sessionId": %d,
|
||||
"sessionPwd": "%s"
|
||||
}
|
||||
}
|
||||
""".formatted(SESSION_ID, SESSION_PWD);
|
||||
}
|
||||
|
||||
private static class ClientListener implements Listener {
|
||||
|
||||
private final CountDownLatch latch;
|
||||
private boolean sent = false;
|
||||
|
||||
ClientListener(CountDownLatch latch) {
|
||||
this.latch = latch;
|
||||
@ -67,7 +68,6 @@ public class Test_SessionRefreshClient {
|
||||
System.out.println("📤 Отправляем SessionRefresh:");
|
||||
System.out.println(json);
|
||||
webSocket.sendText(json, true);
|
||||
sent = true;
|
||||
|
||||
Listener.super.onOpen(webSocket);
|
||||
}
|
||||
|
||||
@ -21,10 +21,14 @@ public final class WsServer {
|
||||
AppConfig config = AppConfig.getInstance();
|
||||
int port = 7070;
|
||||
try {
|
||||
port = Integer.parseInt(config.getParam("server.port"),7070);
|
||||
} catch (Exception e) {
|
||||
log.info("Установите параметр server.port в файле настроек");
|
||||
String portStr = config.getParam("server.port");
|
||||
if (portStr != null && !portStr.isBlank()) {
|
||||
port = Integer.parseInt(portStr.trim());
|
||||
}
|
||||
} catch (Exception e) {
|
||||
log.info("Не удалось прочитать параметр server.port, используем порт по умолчанию {}", port);
|
||||
}
|
||||
|
||||
|
||||
Server server = new Server(port);
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user