Improve Configuration.java, store config has hashmap in memory not as json

This commit is contained in:
Bixilon 2020-12-05 16:09:21 +01:00
parent cf02469411
commit f359eb2d49
No known key found for this signature in database
GPG Key ID: 5CAD791931B09AC4
9 changed files with 132 additions and 95 deletions

View File

@ -1,8 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<module type="JAVA_MODULE" version="4">
<component name="FacetManager">
<facet type="Python" name="Python">
<configuration sdkName="" />
</facet>
</component>
</module>

View File

@ -50,9 +50,7 @@ import java.util.UUID;
public final class Minosoft { public final class Minosoft {
public static final HashSet<EventManager> eventManagers = new HashSet<>(); public static final HashSet<EventManager> eventManagers = new HashSet<>();
private static final CountUpAndDownLatch startStatusLatch = new CountUpAndDownLatch(1); private static final CountUpAndDownLatch startStatusLatch = new CountUpAndDownLatch(1);
public static HashBiMap<String, MojangAccount> accountList;
public static MojangAccount selectedAccount; public static MojangAccount selectedAccount;
public static ArrayList<Server> serverList;
public static Configuration config; public static Configuration config;
public static void main(String[] args) { public static void main(String[] args) {
@ -112,8 +110,6 @@ public final class Minosoft {
// set log level from config // set log level from config
Log.setLevel(LogLevels.valueOf(config.getString(ConfigurationPaths.StringPaths.GENERAL_LOG_LEVEL))); Log.setLevel(LogLevels.valueOf(config.getString(ConfigurationPaths.StringPaths.GENERAL_LOG_LEVEL)));
Log.info(String.format("Logging info with level: %s", Log.getLevel())); Log.info(String.format("Logging info with level: %s", Log.getLevel()));
serverList = config.getServers();
progress.countDown(); progress.countDown();
}, "Configuration", String.format("Load config file (%s)", StaticConfiguration.CONFIG_FILENAME), Priorities.HIGHEST, TaskImportance.REQUIRED)); }, "Configuration", String.format("Load config file (%s)", StaticConfiguration.CONFIG_FILENAME), Priorities.HIGHEST, TaskImportance.REQUIRED));
@ -139,8 +135,7 @@ public final class Minosoft {
taskWorker.addTask(new Task(progress -> { taskWorker.addTask(new Task(progress -> {
Log.debug("Refreshing account token..."); Log.debug("Refreshing account token...");
checkClientToken(); checkClientToken();
accountList = config.getMojangAccounts(); selectAccount(config.getAccountList().get(config.getString(ConfigurationPaths.StringPaths.ACCOUNT_SELECTED)));
selectAccount(accountList.get(config.getString(ConfigurationPaths.StringPaths.ACCOUNT_SELECTED)));
}, "Token refresh", "Refresh selected account token", Priorities.LOW, TaskImportance.OPTIONAL, "Configuration")); }, "Token refresh", "Refresh selected account token", Priorities.LOW, TaskImportance.OPTIONAL, "Configuration"));
taskWorker.addTask(new Task(progress -> { taskWorker.addTask(new Task(progress -> {
@ -195,7 +190,6 @@ public final class Minosoft {
} }
MojangAccount.RefreshStates refreshState = account.refreshToken(); MojangAccount.RefreshStates refreshState = account.refreshToken();
if (refreshState == MojangAccount.RefreshStates.ERROR) { if (refreshState == MojangAccount.RefreshStates.ERROR) {
accountList.remove(account.getUserId());
account.delete(); account.delete();
AccountListCell.listView.getItems().remove(account); AccountListCell.listView.getItems().remove(account);
selectedAccount = null; selectedAccount = null;
@ -211,14 +205,6 @@ public final class Minosoft {
return config; return config;
} }
public static ArrayList<Server> getServerList() {
return serverList;
}
public static HashBiMap<String, MojangAccount> getAccountList() {
return accountList;
}
public static MojangAccount getSelectedAccount() { public static MojangAccount getSelectedAccount() {
return selectedAccount; return selectedAccount;
} }

View File

@ -14,9 +14,7 @@
package de.bixilon.minosoft.config; package de.bixilon.minosoft.config;
import com.google.common.collect.HashBiMap; import com.google.common.collect.HashBiMap;
import com.google.gson.Gson; import com.google.gson.*;
import com.google.gson.GsonBuilder;
import com.google.gson.JsonObject;
import de.bixilon.minosoft.gui.main.Server; import de.bixilon.minosoft.gui.main.Server;
import de.bixilon.minosoft.logging.Log; import de.bixilon.minosoft.logging.Log;
import de.bixilon.minosoft.util.Util; import de.bixilon.minosoft.util.Util;
@ -25,11 +23,15 @@ import de.bixilon.minosoft.util.mojang.api.MojangAccount;
import java.io.*; import java.io.*;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.Paths; import java.nio.file.Paths;
import java.util.ArrayList; import java.util.HashMap;
import java.util.Map;
public class Configuration { public class Configuration {
public static final int LATEST_CONFIG_VERSION = 1; public static final int LATEST_CONFIG_VERSION = 1;
final JsonObject config; private final static JsonObject DEFAULT_CONFIGURATION = JsonParser.parseReader(new InputStreamReader(Configuration.class.getResourceAsStream("/config/" + StaticConfiguration.CONFIG_FILENAME))).getAsJsonObject();
private final HashMap<ConfigurationPaths.ConfigurationPath, Object> config = new HashMap<>();
private final HashBiMap<String, MojangAccount> accountList = HashBiMap.create();
private final HashBiMap<Integer, Server> serverList = HashBiMap.create();
private final Object lock = new Object(); private final Object lock = new Object();
public Configuration() throws IOException, ConfigMigrationException { public Configuration() throws IOException, ConfigMigrationException {
@ -47,7 +49,23 @@ public class Configuration {
Files.copy(input, Paths.get(file.getAbsolutePath())); Files.copy(input, Paths.get(file.getAbsolutePath()));
file = new File(StaticConfiguration.HOME_DIRECTORY + "config/" + StaticConfiguration.CONFIG_FILENAME); file = new File(StaticConfiguration.HOME_DIRECTORY + "config/" + StaticConfiguration.CONFIG_FILENAME);
} }
config = Util.readJsonFromFile(file.getAbsolutePath());
JsonObject json = Util.readJsonFromFile(file.getAbsolutePath());
for (ConfigurationPaths.ConfigurationPath path : ConfigurationPaths.ALL_PATHS) {
config.put(path, getData(json, path));
}
// servers
for (Map.Entry<String, JsonElement> entry : json.getAsJsonObject("servers").getAsJsonObject("entries").entrySet()) {
serverList.put(Integer.parseInt(entry.getKey()), Server.deserialize(entry.getValue().getAsJsonObject()));
}
// accounts
for (Map.Entry<String, JsonElement> entry : json.getAsJsonObject("accounts").getAsJsonObject("entries").entrySet()) {
MojangAccount account = MojangAccount.deserialize(entry.getValue().getAsJsonObject());
accountList.put(account.getUserId(), account);
}
int configVersion = getInt(ConfigurationPaths.IntegerPaths.GENERAL_CONFIG_VERSION); int configVersion = getInt(ConfigurationPaths.IntegerPaths.GENERAL_CONFIG_VERSION);
if (configVersion > LATEST_CONFIG_VERSION) { if (configVersion > LATEST_CONFIG_VERSION) {
throw new ConfigMigrationException(String.format("Configuration was migrated to newer config format (version=%d, expected=%d). Downgrading the config file is unsupported!", configVersion, LATEST_CONFIG_VERSION)); throw new ConfigMigrationException(String.format("Configuration was migrated to newer config format (version=%d, expected=%d). Downgrading the config file is unsupported!", configVersion, LATEST_CONFIG_VERSION));
@ -76,9 +94,27 @@ public class Configuration {
e.printStackTrace(); e.printStackTrace();
return; return;
} }
JsonObject jsonObject = DEFAULT_CONFIGURATION.deepCopy();
synchronized (config) { synchronized (config) {
gson.toJson(config, writer);
// accounts
JsonObject accountsEntriesJson = jsonObject.getAsJsonObject("servers").getAsJsonObject("entries");
for (Map.Entry<Integer, Server> entry : serverList.entrySet()) {
accountsEntriesJson.add(String.valueOf(entry.getKey()), entry.getValue().serialize());
}
// servers
JsonObject serversEntriesJson = jsonObject.getAsJsonObject("accounts").getAsJsonObject("entries");
for (Map.Entry<String, MojangAccount> entry : accountList.entrySet()) {
serversEntriesJson.add(entry.getKey(), entry.getValue().serialize());
}
// rest of data
for (ConfigurationPaths.ConfigurationPath path : ConfigurationPaths.ALL_PATHS) {
saveData(jsonObject, path, config.get(path));
}
} }
gson.toJson(jsonObject, writer);
try { try {
writer.close(); writer.close();
} catch (IOException e) { } catch (IOException e) {
@ -99,65 +135,39 @@ public class Configuration {
} }
public boolean getBoolean(ConfigurationPaths.BooleanPaths path) { public boolean getBoolean(ConfigurationPaths.BooleanPaths path) {
return switch (path) { return (boolean) config.get(path);
case NETWORK_FAKE_CLIENT_BRAND -> config.getAsJsonObject("network").get("fake-network-brand").getAsBoolean();
case NETWORK_SHOW_LAN_SERVERS -> config.getAsJsonObject("network").get("show-lan-servers").getAsBoolean();
case DEBUG_VERIFY_ASSETS -> config.getAsJsonObject("debug").get("verify-assets").getAsBoolean();
};
} }
public void putBoolean(ConfigurationPaths.BooleanPaths path, boolean value) { public void putBoolean(ConfigurationPaths.BooleanPaths path, boolean value) {
switch (path) { config.put(path, value);
case NETWORK_FAKE_CLIENT_BRAND -> config.getAsJsonObject("network").addProperty("fake-network-brand", value);
case NETWORK_SHOW_LAN_SERVERS -> config.getAsJsonObject("network").addProperty("show-lan-servers", value);
case DEBUG_VERIFY_ASSETS -> config.getAsJsonObject("debug").addProperty("verify-assets", value);
}
} }
public int getInt(ConfigurationPaths.IntegerPaths path) { public int getInt(ConfigurationPaths.IntegerPaths path) {
return switch (path) { return (int) config.get(path);
case GENERAL_CONFIG_VERSION -> config.getAsJsonObject("general").get("version").getAsInt();
case GAME_RENDER_DISTANCE -> config.getAsJsonObject("game").get("render-distance").getAsInt();
};
} }
public void putInt(ConfigurationPaths.IntegerPaths path, int value) { public void putInt(ConfigurationPaths.IntegerPaths path, int value) {
switch (path) { config.put(path, value);
case GENERAL_CONFIG_VERSION -> config.getAsJsonObject("general").addProperty("version", value);
case GAME_RENDER_DISTANCE -> config.getAsJsonObject("game").addProperty("render-distance", value);
}
} }
public String getString(ConfigurationPaths.StringPaths path) { public String getString(ConfigurationPaths.StringPaths path) {
return switch (path) { return (String) config.get(path);
case ACCOUNT_SELECTED -> config.getAsJsonObject("accounts").get("selected").getAsString();
case GENERAL_LOG_LEVEL -> config.getAsJsonObject("general").get("log-level").getAsString();
case GENERAL_LANGUAGE -> config.getAsJsonObject("general").get("language").getAsString();
case RESOURCES_URL -> config.getAsJsonObject("download").getAsJsonObject("urls").get("resources").getAsString();
case CLIENT_TOKEN -> config.getAsJsonObject("accounts").get("client-token").getAsString();
};
} }
public void putString(ConfigurationPaths.StringPaths path, String value) { public void putString(ConfigurationPaths.StringPaths path, String value) {
switch (path) { config.put(path, value);
case ACCOUNT_SELECTED -> config.getAsJsonObject("accounts").addProperty("selected", value);
case GENERAL_LOG_LEVEL -> config.getAsJsonObject("general").addProperty("log-level", value);
case GENERAL_LANGUAGE -> config.getAsJsonObject("general").addProperty("language", value);
case RESOURCES_URL -> config.getAsJsonObject("download").getAsJsonObject("urls").addProperty("resources", value);
case CLIENT_TOKEN -> config.getAsJsonObject("accounts").addProperty("client-token", value);
}
} }
public void putMojangAccount(MojangAccount account) { public void putMojangAccount(MojangAccount account) {
config.getAsJsonObject("accounts").getAsJsonObject("entries").add(account.getUserId(), account.serialize()); accountList.put(account.getUserId(), account);
} }
public void putServer(Server server) { public void putServer(Server server) {
config.getAsJsonObject("servers").getAsJsonObject("entries").add(String.valueOf(server.getId()), server.serialize()); serverList.put(server.getId(), server);
} }
public void removeServer(Server server) { public void removeServer(Server server) {
config.getAsJsonObject("servers").getAsJsonObject("entries").remove(String.valueOf(server.getId())); serverList.remove(server.getId());
} }
public void saveToFile() { public void saveToFile() {
@ -166,29 +176,16 @@ public class Configuration {
} }
} }
public HashBiMap<String, MojangAccount> getMojangAccounts() {
HashBiMap<String, MojangAccount> accounts = HashBiMap.create();
JsonObject entries = config.getAsJsonObject("accounts").getAsJsonObject("entries");
entries.keySet().forEach((entry) -> {
MojangAccount account = MojangAccount.deserialize(entries.get(entry).getAsJsonObject());
accounts.put(account.getUserId(), account);
});
return accounts;
}
public ArrayList<Server> getServers() {
ArrayList<Server> servers = new ArrayList<>();
JsonObject entries = config.getAsJsonObject("servers").getAsJsonObject("entries");
entries.keySet().forEach((entry) -> servers.add(Server.deserialize(entries.get(entry).getAsJsonObject())));
return servers;
}
public void removeAccount(MojangAccount account) { public void removeAccount(MojangAccount account) {
config.getAsJsonObject("accounts").getAsJsonObject("entries").remove(account.getUserId()); accountList.remove(account.getUserId());
} }
public JsonObject getConfig() { public HashBiMap<Integer, Server> getServerList() {
return config; return serverList;
}
public HashBiMap<String, MojangAccount> getAccountList() {
return accountList;
} }
private void migrateConfiguration() throws ConfigMigrationException { private void migrateConfiguration() throws ConfigMigrationException {
@ -209,4 +206,53 @@ public class Configuration {
default -> throw new ConfigMigrationException("Can not migrate config: Unknown config version " + nextVersion); default -> throw new ConfigMigrationException("Can not migrate config: Unknown config version " + nextVersion);
} }
} }
private Object getData(JsonObject json, ConfigurationPaths.ConfigurationPath path) {
if (path instanceof ConfigurationPaths.BooleanPaths booleanPath) {
return switch (booleanPath) {
case NETWORK_FAKE_CLIENT_BRAND -> json.getAsJsonObject("network").get("fake-network-brand").getAsBoolean();
case NETWORK_SHOW_LAN_SERVERS -> json.getAsJsonObject("network").get("show-lan-servers").getAsBoolean();
case DEBUG_VERIFY_ASSETS -> json.getAsJsonObject("debug").get("verify-assets").getAsBoolean();
};
}
if (path instanceof ConfigurationPaths.IntegerPaths integerPath) {
return switch (integerPath) {
case GENERAL_CONFIG_VERSION -> json.getAsJsonObject("general").get("version").getAsInt();
case GAME_RENDER_DISTANCE -> json.getAsJsonObject("game").get("render-distance").getAsInt();
};
}
if (path instanceof ConfigurationPaths.StringPaths stringPath) {
return switch (stringPath) {
case ACCOUNT_SELECTED -> json.getAsJsonObject("accounts").get("selected").getAsString();
case GENERAL_LOG_LEVEL -> json.getAsJsonObject("general").get("log-level").getAsString();
case GENERAL_LANGUAGE -> json.getAsJsonObject("general").get("language").getAsString();
case RESOURCES_URL -> json.getAsJsonObject("download").getAsJsonObject("urls").get("resources").getAsString();
case CLIENT_TOKEN -> json.getAsJsonObject("accounts").get("client-token").getAsString();
};
}
throw new RuntimeException();
}
private void saveData(JsonObject input, ConfigurationPaths.ConfigurationPath path, Object data) {
if (data instanceof Boolean bool) {
switch ((ConfigurationPaths.BooleanPaths) path) {
case NETWORK_FAKE_CLIENT_BRAND -> input.getAsJsonObject("network").addProperty("fake-network-brand", bool);
case NETWORK_SHOW_LAN_SERVERS -> input.getAsJsonObject("network").addProperty("show-lan-servers", bool);
case DEBUG_VERIFY_ASSETS -> input.getAsJsonObject("debug").addProperty("verify-assets", bool);
}
} else if (data instanceof Integer integer) {
switch ((ConfigurationPaths.IntegerPaths) path) {
case GENERAL_CONFIG_VERSION -> input.getAsJsonObject("general").addProperty("version", integer);
case GAME_RENDER_DISTANCE -> input.getAsJsonObject("game").addProperty("render-distance", integer);
}
} else if (data instanceof String string) {
switch ((ConfigurationPaths.StringPaths) path) {
case ACCOUNT_SELECTED -> input.getAsJsonObject("accounts").addProperty("selected", string);
case GENERAL_LOG_LEVEL -> input.getAsJsonObject("general").addProperty("log-level", string);
case GENERAL_LANGUAGE -> input.getAsJsonObject("general").addProperty("language", string);
case RESOURCES_URL -> input.getAsJsonObject("download").getAsJsonObject("urls").addProperty("resources", string);
case CLIENT_TOKEN -> input.getAsJsonObject("accounts").addProperty("client-token", string);
}
}
}
} }

View File

@ -13,8 +13,19 @@
package de.bixilon.minosoft.config; package de.bixilon.minosoft.config;
import java.util.Arrays;
import java.util.HashSet;
public abstract class ConfigurationPaths { public abstract class ConfigurationPaths {
public enum StringPaths { static HashSet<ConfigurationPath> ALL_PATHS = new HashSet<>();
static {
ALL_PATHS.addAll(Arrays.asList(StringPaths.values()));
ALL_PATHS.addAll(Arrays.asList(BooleanPaths.values()));
ALL_PATHS.addAll(Arrays.asList(IntegerPaths.values()));
}
public enum StringPaths implements ConfigurationPath {
GENERAL_LOG_LEVEL, GENERAL_LOG_LEVEL,
CLIENT_TOKEN, CLIENT_TOKEN,
RESOURCES_URL, RESOURCES_URL,
@ -22,14 +33,17 @@ public abstract class ConfigurationPaths {
GENERAL_LANGUAGE, GENERAL_LANGUAGE,
} }
public enum BooleanPaths { public enum BooleanPaths implements ConfigurationPath {
NETWORK_FAKE_CLIENT_BRAND, NETWORK_FAKE_CLIENT_BRAND,
NETWORK_SHOW_LAN_SERVERS, NETWORK_SHOW_LAN_SERVERS,
DEBUG_VERIFY_ASSETS DEBUG_VERIFY_ASSETS
} }
public enum IntegerPaths { public enum IntegerPaths implements ConfigurationPath {
GENERAL_CONFIG_VERSION, GENERAL_CONFIG_VERSION,
GAME_RENDER_DISTANCE GAME_RENDER_DISTANCE
} }
public interface ConfigurationPath {
}
} }

View File

@ -102,10 +102,10 @@ public class AccountListCell extends ListCell<MojangAccount> implements Initiali
public void delete() { public void delete() {
account.delete(); account.delete();
if (Minosoft.getSelectedAccount() == account) { if (Minosoft.getSelectedAccount() == account) {
if (Minosoft.getAccountList().isEmpty()) { if (Minosoft.getConfig().getAccountList().isEmpty()) {
Minosoft.selectAccount(null); Minosoft.selectAccount(null);
} else { } else {
Minosoft.selectAccount(Minosoft.getAccountList().values().iterator().next()); Minosoft.selectAccount(Minosoft.getConfig().getAccountList().values().iterator().next());
} }
listView.refresh(); listView.refresh();
} }

View File

@ -46,7 +46,7 @@ public class AccountWindow implements Initializable {
public void initialize(URL url, ResourceBundle resourceBundle) { public void initialize(URL url, ResourceBundle resourceBundle) {
AccountListCell.listView.setCellFactory((lv) -> AccountListCell.newInstance()); AccountListCell.listView.setCellFactory((lv) -> AccountListCell.newInstance());
ObservableList<MojangAccount> accounts = FXCollections.observableArrayList(Minosoft.getAccountList().values()); ObservableList<MojangAccount> accounts = FXCollections.observableArrayList(Minosoft.getConfig().getAccountList().values());
AccountListCell.listView.setItems(accounts); AccountListCell.listView.setItems(accounts);
accountPane.setCenter(AccountListCell.listView); accountPane.setCenter(AccountListCell.listView);
@ -91,7 +91,7 @@ public class AccountWindow implements Initializable {
if (attempt.succeeded()) { if (attempt.succeeded()) {
// login okay // login okay
MojangAccount account = attempt.getAccount(); MojangAccount account = attempt.getAccount();
Minosoft.accountList.put(account.getUserId(), account); Minosoft.getConfig().putMojangAccount(account);
account.saveToConfig(); account.saveToConfig();
AccountListCell.listView.getItems().add(account); AccountListCell.listView.getItems().add(account);
Log.info(String.format("Added and saved account (playerName=%s, email=%s, uuid=%s)", account.getPlayerName(), account.getMojangUserName(), account.getUUID())); Log.info(String.format("Added and saved account (playerName=%s, email=%s, uuid=%s)", account.getPlayerName(), account.getMojangUserName(), account.getUUID()));

View File

@ -62,7 +62,7 @@ public class Launcher {
ServerListCell.listView.setCellFactory((lv) -> ServerListCell.newInstance()); ServerListCell.listView.setCellFactory((lv) -> ServerListCell.newInstance());
ObservableList<Server> servers = FXCollections.observableArrayList(); ObservableList<Server> servers = FXCollections.observableArrayList();
servers.addAll(Minosoft.serverList); servers.addAll(Minosoft.getConfig().getServerList().values());
ServerListCell.listView.setItems(servers); ServerListCell.listView.setItems(servers);
LANServerListener.removeAll(); // remove all LAN Servers LANServerListener.removeAll(); // remove all LAN Servers

View File

@ -203,7 +203,7 @@ public class MainWindow implements Initializable {
if (server1 == null) { if (server1 == null) {
server1 = new Server(Server.getNextServerId(), serverName, serverAddress, desiredVersionId); server1 = new Server(Server.getNextServerId(), serverName, serverAddress, desiredVersionId);
Minosoft.serverList.add(server1); Minosoft.getConfig().putServer(server1);
ServerListCell.listView.getItems().add(server1); ServerListCell.listView.getItems().add(server1);
} else { } else {
server1.setName(serverName); server1.setName(serverName);

View File

@ -105,7 +105,6 @@ public class MojangAccount {
} }
public void delete() { public void delete() {
Minosoft.getAccountList().remove(this.getUserId());
Minosoft.getConfig().removeAccount(this); Minosoft.getConfig().removeAccount(this);
Minosoft.getConfig().saveToFile(); Minosoft.getConfig().saveToFile();
} }