Mirror/LunarCore
1
0
Fork 0
mirror of https://github.com/Melledy/LunarCore.git synced 2026-02-04 06:55:05 +01:00
Code Issues Packages Projects Releases Wiki Activity

Warn server owner if a local mongodb server cant be created

Browse Source
This commit is contained in:
Melledy
2024-07-31 19:09:42 -07:00
parent a1be806ea1
commit b388a62db6
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/emu/lunarcore/database/DatabaseManager.java
View File

@@ -36,7 +36,8 @@ import lombok.Getter;
@Getter @Getter
public final class DatabaseManager { public final class DatabaseManager {
@Getter private static MongoServer server; @Getter
private static MongoServer server;
private Datastore datastore; private Datastore datastore;
private static final InsertOneOptions INSERT_OPTIONS = new InsertOneOptions(); private static final InsertOneOptions INSERT_OPTIONS = new InsertOneOptions();
@@ -48,10 +49,14 @@ public final class DatabaseManager {
var internalConfig = LunarCore.getConfig().getInternalMongoServer(); var internalConfig = LunarCore.getConfig().getInternalMongoServer();
String connectionString = info.getUri(); String connectionString = info.getUri();
// Local mongo server // Start local mongo server
if (info.isUseInternal() && Utils.isPortOpen(internalConfig.getAddress(), internalConfig.getPort())) { if (info.isUseInternal()) {
connectionString = startInternalMongoServer(internalConfig); if (Utils.isPortOpen(internalConfig.getAddress(), internalConfig.getPort())) {
LunarCore.getLogger().info("Started local MongoDB server at " + server.getConnectionString()); connectionString = startInternalMongoServer(internalConfig);
LunarCore.getLogger().info("Started local MongoDB server at " + server.getConnectionString());
} else {
LunarCore.getLogger().warn("Local MongoDB server could not be created because the port is in use.");
}
} }
// Initialize // Initialize
@@ -101,6 +106,9 @@ public final class DatabaseManager {
// Ensure indexes // Ensure indexes
ensureIndexes(); ensureIndexes();
// Done
LunarCore.getLogger().info("Connected to the MongoDB database at " + connectionString);
} }
public MongoDatabase getDatabase() { public MongoDatabase getDatabase() {