feat: mongodb url customisations

Closes #6
ECFMP · Oct 17, 2023 · 356c4fe · 356c4fe
1 parent c5e1dab
commit 356c4fe
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 15 deletions.
diff --git a/docker-compose-ci.yml b/docker-compose-ci.yml
@@ -20,8 +20,7 @@ services:
       MONGO_USERNAME: root
       MONGO_PASSWORD: example_password
       MONGO_DB: ecfmp_test
-      MONGO_HOST: mongodb
-      MONGO_PORT: 27017
+      MONGO_HOST: mongodb://mongodb:27017
       AUTH_JWT_PUBLIC_KEY_FILE: './docker/dev_public_key.pub'
       AUTH_JWT_PRIVATE_KEY_FILE: './docker/dev_private_key.pem'
       AUTH_JWT_AUDIENCE: 'ecfmp-discord-dev'
@@ -44,8 +43,7 @@ services:
       MONGO_USERNAME: root
       MONGO_PASSWORD: example_password
       MONGO_DB: ecfmp_test
-      MONGO_HOST: mongodb
-      MONGO_PORT: 27017
+      MONGO_HOST: mongodb://mongodb:27017
       AUTH_JWT_PUBLIC_KEY_FILE: './app/docker/dev_public_key.pub'
       AUTH_JWT_PRIVATE_KEY_FILE: './app/docker/dev_private_key.pem'
       AUTH_JWT_AUDIENCE: 'ecfmp-discord-dev'

diff --git a/docker-compose.yml b/docker-compose.yml
@@ -13,8 +13,7 @@ services:
       MONGO_USERNAME: root
       MONGO_PASSWORD: example_password
       MONGO_DB: ecfmp
-      MONGO_HOST: mongodb
-      MONGO_PORT: 27017
+      MONGO_HOST: mongodb://mongodb:27017
       AUTH_JWT_PUBLIC_KEY_FILE: "./docker/dev_public_key.pub"
       AUTH_JWT_AUDIENCE: "ecfmp-discord-dev"
       LOG_LEVEL: "TRACE"
@@ -47,6 +46,7 @@ services:
 volumes:
   mongodb_data:
 
+
 networks:
   default:
     name: ecfmp
diff --git a/internal/db/mongo.go b/internal/db/mongo.go
@@ -23,17 +23,14 @@ type Mongo struct {
  * Create a new mongo connection
  */
 func NewMongo() (*Mongo, error) {
-	mongoUri := fmt.Sprintf(
-		"mongodb://%s:%s@%s:%s",
-		os.Getenv("MONGO_USERNAME"),
-		os.Getenv("MONGO_PASSWORD"),
-		os.Getenv("MONGO_HOST"),
-		os.Getenv("MONGO_PORT"),
-	)
-
 	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
 	defer cancel()
-	client, err := mongo.Connect(ctx, options.Client().ApplyURI(mongoUri), options.Client().SetMaxPoolSize(10), options.Client().SetMaxConnIdleTime(5*time.Second))
+
+	auth := options.Credential{
+		Username: os.Getenv("MONGO_USERNAME"),
+		Password: os.Getenv("MONGO_PASSWORD"),
+	}
+	client, err := mongo.Connect(ctx, options.Client().ApplyURI(os.Getenv("MONGO_HOST")).SetAuth(auth).SetMaxPoolSize(10).SetMaxConnIdleTime(5*time.Second))
 	if err != nil {
 		log.Errorf("Failed to connect to mongo: %v", err)
 		return nil, err