mongodb_client.go

// Connect returns a successfully connected mongo client
func Connect(ctx context.Context) (*mongo.Client, error) {
	url := "mongodb://admin:admin@localhost:27017"

	log.Printf("connect to mongodb at: %v", url)

	opts := options.Client()

	opts.ApplyURI(url)

	client, err := mongo.Connect(ctx, opts)
	if err != nil {
		msg := fmt.Sprintf("invalid mongodb connection: %v", err)
		log.Println(msg)
		return nil, fmt.Errorf(msg)
	}

	// test connection
	err = client.Ping(ctx, readpref.Primary())

	if err != nil {
		log.Printf("connection test to mongodb client failed: %v", err)
		return nil, fmt.Errorf(fmt.Sprintf("connection test to mongodb client failed: %v", err))
	}

	log.Println("connected successfully to mongodb")

	return client, nil
}