From f3768e816f60023f01ebff515267ae217e1f5d13 Mon Sep 17 00:00:00 2001 From: Kalissaac Date: Mon, 23 Nov 2020 17:38:43 -0800 Subject: [PATCH] Ignore port when using Atlas --- mongodb/mongodb.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/mongodb/mongodb.go b/mongodb/mongodb.go index 7520eae5..9841c35b 100644 --- a/mongodb/mongodb.go +++ b/mongodb/mongodb.go @@ -48,7 +48,11 @@ func New(config ...Config) *Storage { if cfg.Username != "" || cfg.Password != "" { dsn += "@" } - dsn += fmt.Sprintf("%s:%d", url.QueryEscape(cfg.Host), cfg.Port) + if cfg.Atlas == true { + dsn += url.QueryEscape(cfg.Host) // Cannot specify port when using MongoDB Atlas + } else { + dsn += fmt.Sprintf("%s:%d", url.QueryEscape(cfg.Host), cfg.Port) + } // Set mongo options opt := options.Client()