From 07133d57a9381b77ea06b5e253bfc5b0b43cdab1 Mon Sep 17 00:00:00 2001
From: alex <alex@roese.dev>
Date: Sun, 10 Apr 2022 19:48:49 +0200
Subject: [PATCH] added database and players collection

---
 .../java/earth/krakatoa/core/mongo/MongoManager.java  | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/src/main/java/earth/krakatoa/core/mongo/MongoManager.java b/src/main/java/earth/krakatoa/core/mongo/MongoManager.java
index 30c99bb..4606697 100755
--- a/src/main/java/earth/krakatoa/core/mongo/MongoManager.java
+++ b/src/main/java/earth/krakatoa/core/mongo/MongoManager.java
@@ -4,8 +4,11 @@ import com.mongodb.ConnectionString;
 import com.mongodb.MongoClientSettings;
 import com.mongodb.reactivestreams.client.MongoClient;
 import com.mongodb.reactivestreams.client.MongoClients;
+import com.mongodb.reactivestreams.client.MongoCollection;
+import com.mongodb.reactivestreams.client.MongoDatabase;
 import earth.krakatoa.core.config.MongoConfig;
 import lombok.Data;
+import org.bson.Document;
 
 @Data
 public class MongoManager {
@@ -17,6 +20,10 @@ public class MongoManager {
 
   private MongoConfig mongoConfig;
 
+  private MongoDatabase krakatoaDatabase;
+
+  private MongoCollection<Document> playersCollection;
+
   public MongoManager(MongoConfig mongoConfig) {
     this.mongoConfig = mongoConfig;
   }
@@ -32,6 +39,10 @@ public class MongoManager {
         .applyConnectionString(this.connectionString).build();
 
     this.mongoClient = MongoClients.create(this.mongoClientSettings);
+
+    this.krakatoaDatabase = this.mongoClient.getDatabase("krakatoa");
+
+    this.playersCollection = this.krakatoaDatabase.getCollection("players");
   }
 
   public void shutdown() {