diff --git a/.env b/.env index 2e417c9..5a95060 100644 --- a/.env +++ b/.env @@ -1 +1,12 @@ +# General application settings APP_NAME=codeword +HTTP_HOST=localhost +HTTP_PORT=8000 + +# MongoDB settings +MONGO_HOST=mongo_host +MONGO_PORT=27017 +MONGO_USER=admin +MONGO_PASSWORD=admin +MONGO_DB=codeword_db +MONGO_AUTH=admin \ No newline at end of file diff --git a/deployment/local/docker-compose.yaml b/deployment/local/docker-compose.yaml index e69de29..fa1faa4 100644 --- a/deployment/local/docker-compose.yaml +++ b/deployment/local/docker-compose.yaml @@ -0,0 +1,15 @@ +version: '3.8' + +services: + mongo: + image: mongo + ports: + - "${MONGO_PORT}:27017" + environment: + - MONGO_INITDB_ROOT_USERNAME=${MONGO_USER} + - MONGO_INITDB_ROOT_PASSWORD=${MONGO_PASSWORD} + volumes: + - mongo_data:/data/db + +volumes: + mongo_data: \ No newline at end of file diff --git a/go.mod b/go.mod index 71dd7ac..85b4922 100644 --- a/go.mod +++ b/go.mod @@ -6,16 +6,26 @@ require ( github.com/andybalholm/brotli v1.0.5 // indirect github.com/caarlos0/env/v8 v8.0.0 // indirect github.com/gofiber/fiber/v2 v2.51.0 // indirect + github.com/golang/snappy v0.0.1 // indirect github.com/google/uuid v1.4.0 // indirect github.com/klauspost/compress v1.16.7 // indirect github.com/mattn/go-colorable v0.1.13 // indirect github.com/mattn/go-isatty v0.0.20 // indirect github.com/mattn/go-runewidth v0.0.15 // indirect + github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe // indirect github.com/rivo/uniseg v0.2.0 // indirect github.com/valyala/bytebufferpool v1.0.0 // indirect github.com/valyala/fasthttp v1.50.0 // indirect github.com/valyala/tcplisten v1.0.0 // indirect + github.com/xdg-go/pbkdf2 v1.0.0 // indirect + github.com/xdg-go/scram v1.1.2 // indirect + github.com/xdg-go/stringprep v1.0.4 // indirect + github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect + go.mongodb.org/mongo-driver v1.13.1 // indirect go.uber.org/multierr v1.10.0 // indirect go.uber.org/zap v1.26.0 // indirect + golang.org/x/crypto v0.7.0 // indirect + golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4 // indirect golang.org/x/sys v0.14.0 // indirect + golang.org/x/text v0.8.0 // indirect ) diff --git a/go.sum b/go.sum index 98f976a..3981795 100644 --- a/go.sum +++ b/go.sum @@ -2,10 +2,15 @@ github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/ github.com/andybalholm/brotli v1.0.5/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig= github.com/caarlos0/env/v8 v8.0.0 h1:POhxHhSpuxrLMIdvTGARuZqR4Jjm8AYmoi/JKlcScs0= github.com/caarlos0/env/v8 v8.0.0/go.mod h1:7K4wMY9bH0esiXSSHlfHLX5xKGQMnkH5Fk4TDSSSzfo= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/gofiber/fiber/v2 v2.51.0 h1:JNACcZy5e2tGApWB2QrRpenTWn0fq0hkFm6k0C86gKQ= github.com/gofiber/fiber/v2 v2.51.0/go.mod h1:xaQRZQJGqnKOQnbQw+ltvku3/h8QxvNi8o6JiJ7Ll0U= +github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4= +github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= +github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/uuid v1.4.0 h1:MtMxsa51/r9yyhkyLsVeVt0B+BGQZzpQiTQ4eHZ8bc4= github.com/google/uuid v1.4.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk= github.com/klauspost/compress v1.16.7 h1:2mk3MPGNzKyxErAw8YaohYh69+pa4sIQSC0fPGCFR9I= github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE= github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= @@ -15,6 +20,8 @@ github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWE github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= github.com/mattn/go-runewidth v0.0.15 h1:UNAjwbU9l54TA3KzvqLGxwWjHmMgBUVhBiTjelZgg3U= github.com/mattn/go-runewidth v0.0.15/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w= +github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe h1:iruDEfMl2E6fbMZ9s0scYfZQ84/6SPL6zC8ACM2oIL0= +github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe/go.mod h1:wL8QJuTMNUDYhXwkmfOly8iTdp5TEcJFWZD2D7SIkUc= github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY= github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc= github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw= @@ -23,11 +30,56 @@ github.com/valyala/fasthttp v1.50.0 h1:H7fweIlBm0rXLs2q0XbalvJ6r0CUPFWK3/bB4N13e github.com/valyala/fasthttp v1.50.0/go.mod h1:k2zXd82h/7UZc3VOdJ2WaUqt1uZ/XpXAfE9i+HBC3lA= github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8= github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc= +github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c= +github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI= +github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY= +github.com/xdg-go/scram v1.1.2/go.mod h1:RT/sEzTbU5y00aCK8UOx6R7YryM0iF1N2MOmC3kKLN4= +github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8= +github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM= +github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d h1:splanxYIlg+5LfHAM6xpdFEAYOk8iySO56hMFq6uLyA= +github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA= +github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= +go.mongodb.org/mongo-driver v1.13.1 h1:YIc7HTYsKndGK4RFzJ3covLz1byri52x0IoMB0Pt/vk= +go.mongodb.org/mongo-driver v1.13.1/go.mod h1:wcDf1JBCXy2mOW0bWHwO/IOYqdca1MPCwDtFu/Z9+eo= go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ= go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= go.uber.org/zap v1.26.0 h1:sI7k6L95XOKS281NhVKOFCUNIvv9e0w4BF8N3u+tCRo= go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so= +golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= +golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= +golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4= +golang.org/x/crypto v0.7.0 h1:AvwMYaRytfdeVt3u6mLaxYtErKYjxA2OXjJ1HHq6t3A= +golang.org/x/crypto v0.7.0/go.mod h1:pYwdfH91IfpZVANVyUOhSIPZaFoJGxTFbZhFTx+dXZU= +golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= +golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= +golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= +golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= +golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= +golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4 h1:uVc8UZUe6tr40fFVnUP5Oj+veunVezqYl9z7DYw9xzw= +golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.14.0 h1:Vz7Qs629MkJkGyHxUlRHizWJRG2j8fbQKjELVSNhy7Q= golang.org/x/sys v0.14.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= +golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= +golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= +golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ= +golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= +golang.org/x/text v0.8.0 h1:57P1ETyNKtuIjB4SRd15iJxuhj8Gc416Y78H3qgMh68= +golang.org/x/text v0.8.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8= +golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= +golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= +golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= +golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= diff --git a/internal/app/app.go b/internal/app/app.go index ea53893..c0e0a18 100644 --- a/internal/app/app.go +++ b/internal/app/app.go @@ -15,10 +15,17 @@ import ( func Run(ctx context.Context, cfg initialize.Config, logger *zap.Logger) error { logger.Info("Запуск приложения", zap.String("AppName", cfg.AppName)) - userRepo := repository.NewUserRepository() + mdb, err := initialize.InitializeMongoDB(ctx, cfg) + if err != nil { + logger.Error("Failed to initialize MongoDB", zap.Error(err)) + return err + } + + userRepo := repository.NewUserRepository(mdb) recoveryEmailSender := &client.RecoveryEmailSender{} recoveryService := services.NewRecoveryService(logger, userRepo, recoveryEmailSender) recoveryController := controller.NewRecoveryController(logger, recoveryService) + server := httpserver.NewServer(httpserver.ServerConfig{ Logger: logger, Repo: userRepo, @@ -26,7 +33,7 @@ func Run(ctx context.Context, cfg initialize.Config, logger *zap.Logger) error { }) go func() { - if err := server.Start(":3000"); err != nil { + if err := server.Start(cfg.HTTPHost + ":" + cfg.HTTPPort); err != nil { logger.Error("Ошибка запуска сервера", zap.Error(err)) } }() diff --git a/internal/initialize/config.go b/internal/initialize/config.go new file mode 100644 index 0000000..dec81f5 --- /dev/null +++ b/internal/initialize/config.go @@ -0,0 +1,25 @@ +package initialize + +import ( + "github.com/caarlos0/env/v8" +) + +type Config struct { + AppName string `env:"APP_NAME" envDefault:"codeword"` + HTTPHost string `env:"HTTP_HOST" envDefault:"localhost"` + HTTPPort string `env:"HTTP_PORT" envDefault:"3000"` + MongoHost string `env:"MONGO_HOST" envDefault:"localhost"` + MongoPort string `env:"MONGO_PORT" envDefault:"27017"` + MongoUser string `env:"MONGO_USER" envDefault:"admin"` + MongoPassword string `env:"MONGO_PASSWORD" envDefault:"admin"` + MongoDatabase string `env:"MONGO_DB" envDefault:"codeword_db"` + MongoAuth string `env:"MONGO_AUTH" envDefault:"admin"` +} + +func LoadConfig() (*Config, error) { + var config Config + if err := env.Parse(&config); err != nil { + return nil, err + } + return &config, nil +} diff --git a/internal/initialize/initialize.go b/internal/initialize/initialize.go deleted file mode 100644 index 0809dc1..0000000 --- a/internal/initialize/initialize.go +++ /dev/null @@ -1,17 +0,0 @@ -package initialize - -import ( - "github.com/caarlos0/env/v8" -) - -type Config struct { - AppName string `env:"APP_NAME" envDefault:"codeword"` -} - -func LoadConfig() (*Config, error) { - var config Config - if err := env.Parse(&config); err != nil { - return nil, err - } - return &config, nil -} diff --git a/internal/initialize/mongo.go b/internal/initialize/mongo.go new file mode 100644 index 0000000..df49819 --- /dev/null +++ b/internal/initialize/mongo.go @@ -0,0 +1,36 @@ +package initialize + +import ( + mdb "codeword/pkg/mongo" + "context" + "go.mongodb.org/mongo-driver/mongo" + "time" +) + +func InitializeMongoDB(ctx context.Context, cfg Config) (*mongo.Database, error) { + dbConfig := &mdb.Configuration{ + MongoHost: cfg.MongoHost, + MongoPort: cfg.MongoPort, + MongoUser: cfg.MongoUser, + MongoPassword: cfg.MongoPassword, + MongoDatabase: cfg.MongoDatabase, + MongoAuth: cfg.MongoAuth, + } + + mongoDeps := &mdb.ConnectDeps{ + Configuration: dbConfig, + Timeout: 10 * time.Second, + } + + db, err := mdb.Connect(ctx, mongoDeps) + if err != nil { + return nil, err + } + + err = db.Client().Ping(ctx, nil) + if err != nil { + return nil, err + } + + return db, nil +} diff --git a/internal/repository/user_repository.go b/internal/repository/user_repository.go index c45fd92..66240fd 100644 --- a/internal/repository/user_repository.go +++ b/internal/repository/user_repository.go @@ -2,16 +2,19 @@ package repository import ( "codeword/internal/models" + "context" + "fmt" + "go.mongodb.org/mongo-driver/mongo" + "go.mongodb.org/mongo-driver/mongo/readpref" "time" ) type UserRepository struct { - //todo + db *mongo.Database } -func NewUserRepository() *UserRepository { - //todo - return &UserRepository{} +func NewUserRepository(db *mongo.Database) *UserRepository { + return &UserRepository{db} } func (r *UserRepository) FindByEmail(email string) (*models.User, error) { @@ -31,6 +34,7 @@ func (r *UserRepository) GetRecoveryRecord(signature string) (*models.RestoreReq return &models.RestoreRequest{UserID: "123", Sign: signature, CreatedAt: time.Now()}, nil } -func (r *UserRepository) Ping() error { - return nil +func (r *UserRepository) Ping(ctx context.Context) error { + fmt.Println("Ping") + return r.db.Client().Ping(ctx, readpref.Primary()) } diff --git a/internal/server/http/http_server.go b/internal/server/http/http_server.go index 3efb2a8..6de8e7f 100644 --- a/internal/server/http/http_server.go +++ b/internal/server/http/http_server.go @@ -50,11 +50,11 @@ func (s *Server) handleLiveness(c *fiber.Ctx) error { } func (s *Server) handleReadiness(c *fiber.Ctx) error { - if err := s.Repo.Ping(); err != nil { + if err := s.Repo.Ping(c.Context()); err != nil { s.Logger.Error("Failed to ping the database", zap.Error(err)) return c.Status(fiber.StatusServiceUnavailable).SendString("DB ping failed") } - return c.Status(fiber.StatusOK).SendString("42") + return c.Status(fiber.StatusOK).SendString("OK") } func (s *Server) Start(addr string) error { diff --git a/pkg/mongo/config.go b/pkg/mongo/config.go new file mode 100644 index 0000000..34d845e --- /dev/null +++ b/pkg/mongo/config.go @@ -0,0 +1,22 @@ +package mongo + +import ( + "go.mongodb.org/mongo-driver/bson/primitive" + "go.mongodb.org/mongo-driver/mongo" + "go.mongodb.org/mongo-driver/mongo/options" +) + +type Configuration struct { + MongoHost string `env:"MONGO_HOST" envDefault:"localhost"` + MongoPort string `env:"MONGO_PORT" envDefault:"27017"` + MongoUser string `env:"MONGO_USER" envDefault:"admin"` + MongoPassword string `env:"MONGO_PASSWORD" envDefault:"admin"` + MongoDatabase string `env:"MONGO_DB" envDefault:"codeword_db"` + MongoAuth string `env:"MONGO_AUTH" envDefault:"admin"` +} + +type RequestSettings struct { + Driver *mongo.Collection + Options *options.FindOptions + Filter primitive.M +} diff --git a/pkg/mongo/connection.go b/pkg/mongo/connection.go new file mode 100644 index 0000000..80c22b1 --- /dev/null +++ b/pkg/mongo/connection.go @@ -0,0 +1,59 @@ +package mongo + +import ( + "context" + "fmt" + "log" + "net" + "net/url" + "time" + + "go.mongodb.org/mongo-driver/mongo" + "go.mongodb.org/mongo-driver/mongo/options" +) + +type ConnectDeps struct { + Configuration *Configuration + Timeout time.Duration +} + +func Connect(ctx context.Context, deps *ConnectDeps) (*mongo.Database, error) { + if deps == nil { + return nil, ErrEmptyArgs + } + + mongoURI := &url.URL{ + Scheme: "mongodb", + Host: net.JoinHostPort(deps.Configuration.MongoHost, deps.Configuration.MongoPort), + } + + connectionOptions := options.Client(). + ApplyURI(mongoURI.String()). + SetAuth(options.Credential{ + AuthMechanism: "SCRAM-SHA-1", + AuthSource: deps.Configuration.MongoAuth, + Username: deps.Configuration.MongoUser, + Password: deps.Configuration.MongoPassword, + }) + + ticker := time.NewTicker(1 * time.Second) + timeoutExceeded := time.After(deps.Timeout) + + defer ticker.Stop() + + for { + select { + case <-ticker.C: + connection, err := mongo.Connect(ctx, connectionOptions) + if err == nil { + return connection.Database(deps.Configuration.MongoDatabase), nil + } + + log.Printf("failed to connect to db <%s>: %s", mongoURI.String(), err.Error()) + case <-timeoutExceeded: + return nil, fmt.Errorf("db connection <%s> failed after %d timeout", mongoURI.String(), deps.Timeout) + default: + time.Sleep(1 * time.Second) + } + } +} diff --git a/pkg/mongo/errors.go b/pkg/mongo/errors.go new file mode 100644 index 0000000..2e592f2 --- /dev/null +++ b/pkg/mongo/errors.go @@ -0,0 +1,7 @@ +package mongo + +import "errors" + +var ( + ErrEmptyArgs = errors.New("arguments are empty") +)