diff --git a/mongo/connection.go b/mongo/connection.go index 6f606ad..1bcf40a 100644 --- a/mongo/connection.go +++ b/mongo/connection.go @@ -8,7 +8,6 @@ import ( "net/url" "time" - "go.mongodb.org/mongo-driver/event" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options" ) @@ -28,17 +27,17 @@ func Connect(ctx context.Context, deps *ConnectDeps) (*mongo.Database, error) { Host: net.JoinHostPort(deps.Configuration.Host, deps.Configuration.Port), } - cmdMonitor := &event.CommandMonitor{ - Started: func(_ context.Context, evt *event.CommandStartedEvent) { - log.Println(evt.Command) - }, - Succeeded: func(_ context.Context, evt *event.CommandSucceededEvent) { - log.Println(evt.Reply) - }, - Failed: func(_ context.Context, evt *event.CommandFailedEvent) { - log.Println(evt.Failure) - }, - } + //cmdMonitor := &event.CommandMonitor{ + // Started: func(_ context.Context, evt *event.CommandStartedEvent) { + // log.Println(evt.Command) + // }, + // Succeeded: func(_ context.Context, evt *event.CommandSucceededEvent) { + // log.Println(evt.Reply) + // }, + // Failed: func(_ context.Context, evt *event.CommandFailedEvent) { + // log.Println(evt.Failure) + // }, + //} connectionOptions := options.Client(). ApplyURI(mongoURI.String()). @@ -47,8 +46,7 @@ func Connect(ctx context.Context, deps *ConnectDeps) (*mongo.Database, error) { AuthSource: deps.Configuration.Auth, Username: deps.Configuration.User, Password: deps.Configuration.Password, - }). - SetMonitor(cmdMonitor) + }) ticker := time.NewTicker(1 * time.Second) timeoutExceeded := time.After(deps.Timeout)