diff --git a/src/main/java/it/tdlight/reactiveapi/Cli.java b/src/main/java/it/tdlight/reactiveapi/Cli.java index 13fd15b..c82e0ee 100644 --- a/src/main/java/it/tdlight/reactiveapi/Cli.java +++ b/src/main/java/it/tdlight/reactiveapi/Cli.java @@ -1,5 +1,6 @@ package it.tdlight.reactiveapi; +import static it.tdlight.reactiveapi.Lanes.MAIN_LANE; import static java.util.Collections.unmodifiableSet; import it.tdlight.reactiveapi.CreateSessionRequest.CreateBotSessionRequest; @@ -114,7 +115,7 @@ public class Cli { if (parts.length == 4) { lane = parts[3]; } else { - lane = ""; + lane = MAIN_LANE; } CreateSessionRequest request = switch (parts[0]) { case "bot" -> new CreateBotSessionRequest(Long.parseLong(parts[1]), parts[2], lane); diff --git a/src/main/java/it/tdlight/reactiveapi/DiskSession.java b/src/main/java/it/tdlight/reactiveapi/DiskSession.java index 36cf567..1b35a71 100644 --- a/src/main/java/it/tdlight/reactiveapi/DiskSession.java +++ b/src/main/java/it/tdlight/reactiveapi/DiskSession.java @@ -1,5 +1,7 @@ package it.tdlight.reactiveapi; +import static it.tdlight.reactiveapi.Lanes.MAIN_LANE; + import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonInclude; import com.fasterxml.jackson.annotation.JsonInclude.Include; @@ -23,7 +25,7 @@ public class DiskSession { @JsonProperty("lane") @Nullable String lane) { this.token = token; this.phoneNumber = phoneNumber; - this.lane = Objects.requireNonNullElse(lane, ""); + this.lane = Objects.requireNonNullElse(lane, MAIN_LANE); this.validate(); } diff --git a/src/main/java/it/tdlight/reactiveapi/KafkaParameters.java b/src/main/java/it/tdlight/reactiveapi/KafkaParameters.java index 8ee515f..0bd5378 100644 --- a/src/main/java/it/tdlight/reactiveapi/KafkaParameters.java +++ b/src/main/java/it/tdlight/reactiveapi/KafkaParameters.java @@ -16,7 +16,7 @@ public record KafkaParameters(String groupId, String clientId, String bootstrapS public Set getAllLanes() { var lanes = new LinkedHashSet(this.lanes.size() + 1); - lanes.add(""); + lanes.add("main"); lanes.addAll(this.lanes); return lanes; } diff --git a/src/main/java/it/tdlight/reactiveapi/Lanes.java b/src/main/java/it/tdlight/reactiveapi/Lanes.java new file mode 100644 index 0000000..f2cac3e --- /dev/null +++ b/src/main/java/it/tdlight/reactiveapi/Lanes.java @@ -0,0 +1,5 @@ +package it.tdlight.reactiveapi; + +public class Lanes { + public static final String MAIN_LANE = "main"; +}