feat(mongo): migrate from mongo-driver v1 to v2

CHANGELOG.md

@@ -1,5 +1,15 @@
 # Lib-commons Changelog
 
+## [5.3.0]
+
+- **Changes:**
+  - **mongo**: Migrated from `go.mongodb.org/mongo-driver` v1 to `go.mongodb.org/mongo-driver/v2` (v2.6.0) in-place across `commons/mongo/`, `commons/outbox/mongo/`, `commons/tenant-manager/core/`, and `commons/tenant-manager/mongo/`. Public function signatures are unchanged, but the concrete `*mongo.Database`/`*mongo.Client` types now resolve to v2. Consumers updating to v5.3.0 must adapt their own MongoDB query code for the following v2 API changes:
+    - `options.UpdateOne()`, `options.Find()`, and `options.Index()` now return builder types (`*XxxOptionsBuilder`). Fluent `.SetX()` chains are unchanged.
+    - `primitive.ObjectID` → `bson.ObjectID`, `primitive.DateTime` → `bson.DateTime`, `primitive.NewObjectID()` → `bson.NewObjectID()` (the `primitive` package was merged into `bson` in v2).
+    - `mongo.Connect` no longer accepts a `context.Context` parameter **and no longer pings the server to validate reachability**. If you relied on `Connect` to fail on unreachable deployments, call `client.Ping(ctx, nil)` explicitly after connecting.
+    - `Collection.Distinct` returns `*DistinctResult` instead of `([]any, error)` — use `result.Err()` followed by `result.Decode(&values)`.
+    - `WithTransaction` callbacks receive `context.Context` instead of `mongo.SessionContext`. Use `mongo.SessionFromContext(ctx)` if you need the session.
+
 ## [5.2.0](https://github.com/LerianStudio/lib-commons/releases/tag/v5.2.0)
 
 - **Features:**

commons/mongo/mongo.go

@@ -22,9 +22,9 @@ import (
 	"github.com/LerianStudio/lib-observability/log"
 	"github.com/LerianStudio/lib-observability/metrics"
 	libOpentelemetry "github.com/LerianStudio/lib-observability/tracing"
-	"go.mongodb.org/mongo-driver/bson"
-	"go.mongodb.org/mongo-driver/mongo"
-	"go.mongodb.org/mongo-driver/mongo/options"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	"go.mongodb.org/mongo-driver/v2/mongo"
+	"go.mongodb.org/mongo-driver/v2/mongo/options"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
 )
@@ -143,8 +143,8 @@ type clientDeps struct {
 
 func defaultDeps() clientDeps {
 	return clientDeps{
-		connect: func(ctx context.Context, clientOptions *options.ClientOptions) (*mongo.Client, error) {
-			return mongo.Connect(ctx, clientOptions)
+		connect: func(_ context.Context, clientOptions *options.ClientOptions) (*mongo.Client, error) {
+			return mongo.Connect(clientOptions)
 		},
 		ping: func(ctx context.Context, client *mongo.Client) error {
 			return client.Ping(ctx, nil)

commons/mongo/mongo_integration_test.go

@@ -14,8 +14,8 @@ import (
 	"github.com/testcontainers/testcontainers-go"
 	tcmongo "github.com/testcontainers/testcontainers-go/modules/mongodb"
 	"github.com/testcontainers/testcontainers-go/wait"
-	"go.mongodb.org/mongo-driver/bson"
-	mongodriver "go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	mongodriver "go.mongodb.org/mongo-driver/v2/mongo"
 )
 
 const (

commons/mongo/mongo_test.go

@@ -23,9 +23,9 @@ import (
 	"github.com/LerianStudio/lib-observability/log"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
-	"go.mongodb.org/mongo-driver/bson"
-	"go.mongodb.org/mongo-driver/mongo"
-	"go.mongodb.org/mongo-driver/mongo/options"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	"go.mongodb.org/mongo-driver/v2/mongo"
+	"go.mongodb.org/mongo-driver/v2/mongo/options"
 )
 
 // ---------------------------------------------------------------------------

commons/outbox/mongo/claim.go

@@ -8,9 +8,9 @@ import (
 	"github.com/LerianStudio/lib-commons/v5/commons/outbox"
 	libOpentelemetry "github.com/LerianStudio/lib-observability/tracing"
 	"github.com/google/uuid"
-	"go.mongodb.org/mongo-driver/bson"
-	mongodriver "go.mongodb.org/mongo-driver/mongo"
-	mongooptions "go.mongodb.org/mongo-driver/mongo/options"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	mongodriver "go.mongodb.org/mongo-driver/v2/mongo"
+	mongooptions "go.mongodb.org/mongo-driver/v2/mongo/options"
 )
 
 func (repo *Repository) claimPending(ctx context.Context, limit int, eventType string, spanName string) ([]*outbox.OutboxEvent, error) {

commons/outbox/mongo/coverage_boost_test.go

@@ -9,8 +9,7 @@ import (
 	"github.com/google/uuid"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
-	"go.mongodb.org/mongo-driver/bson"
-	"go.mongodb.org/mongo-driver/bson/primitive"
+	"go.mongodb.org/mongo-driver/v2/bson"
 )
 
 // -------------------------------------------------------------------
@@ -131,7 +130,7 @@ func TestTimeField_PrimitiveDateTime(t *testing.T) {
 	t.Parallel()
 
 	now := time.Now().UTC().Truncate(time.Millisecond)
-	raw := bson.M{"ts": primitive.NewDateTimeFromTime(now)}
+	raw := bson.M{"ts": bson.NewDateTimeFromTime(now)}
 	val, err := timeField(raw, "ts")
 	require.NoError(t, err)
 	assert.WithinDuration(t, now, val, time.Millisecond)
@@ -183,7 +182,7 @@ func TestOptionalTimeField_PrimitiveDateTime(t *testing.T) {
 	t.Parallel()
 
 	now := time.Now().UTC().Truncate(time.Millisecond)
-	raw := bson.M{"ts": primitive.NewDateTimeFromTime(now)}
+	raw := bson.M{"ts": bson.NewDateTimeFromTime(now)}
 	val, err := optionalTimeField(raw, "ts")
 	require.NoError(t, err)
 	require.NotNil(t, val)

commons/outbox/mongo/document.go

@@ -9,9 +9,8 @@ import (
 
 	"github.com/LerianStudio/lib-commons/v5/commons/outbox"
 	"github.com/google/uuid"
-	"go.mongodb.org/mongo-driver/bson"
-	"go.mongodb.org/mongo-driver/bson/primitive"
-	mongodriver "go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	mongodriver "go.mongodb.org/mongo-driver/v2/mongo"
 )
 
 func (doc document) toBSON(tenantField string) bson.M {
@@ -418,7 +417,7 @@ func timeField(raw bson.M, key string) (time.Time, error) {
 	switch typed := value.(type) {
 	case time.Time:
 		return typed, nil
-	case primitive.DateTime:
+	case bson.DateTime:
 		return typed.Time(), nil
 	default:
 		return time.Time{}, fmt.Errorf("field %q must be time", key)
@@ -434,7 +433,7 @@ func optionalTimeField(raw bson.M, key string) (*time.Time, error) {
 	switch typed := value.(type) {
 	case time.Time:
 		return &typed, nil
-	case primitive.DateTime:
+	case bson.DateTime:
 		timeValue := typed.Time()
 		return &timeValue, nil
 	default:

commons/outbox/mongo/extra_test.go

@@ -8,7 +8,7 @@ import (
 	libMongo "github.com/LerianStudio/lib-commons/v5/commons/mongo"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
-	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/v2/bson"
 )
 
 // TestWithLogger covers the WithLogger option.

commons/outbox/mongo/helpers.go

@@ -4,7 +4,7 @@ import (
 	"maps"
 	"regexp"
 
-	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/v2/bson"
 )
 
 var mongoIdentifierPattern = regexp.MustCompile(`^[a-zA-Z_][a-zA-Z0-9_]*$`)

commons/outbox/mongo/indexes.go

@@ -1,9 +1,9 @@
 package mongo
 
 import (
-	"go.mongodb.org/mongo-driver/bson"
-	mongodriver "go.mongodb.org/mongo-driver/mongo"
-	mongooptions "go.mongodb.org/mongo-driver/mongo/options"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	mongodriver "go.mongodb.org/mongo-driver/v2/mongo"
+	mongooptions "go.mongodb.org/mongo-driver/v2/mongo/options"
 )
 
 func buildIndexes(tenantField string) []mongodriver.IndexModel {

commons/outbox/mongo/pure_functions_test.go

@@ -10,7 +10,7 @@ import (
 	"github.com/google/uuid"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
-	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/v2/bson"
 )
 
 // ---------------------------------------------------------------------------

commons/outbox/mongo/repository.go

@@ -18,8 +18,8 @@ import (
 	libLog "github.com/LerianStudio/lib-observability/log"
 	libOpentelemetry "github.com/LerianStudio/lib-observability/tracing"
 	"github.com/google/uuid"
-	"go.mongodb.org/mongo-driver/bson"
-	mongodriver "go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	mongodriver "go.mongodb.org/mongo-driver/v2/mongo"
 	"go.opentelemetry.io/otel/trace"
 	"go.opentelemetry.io/otel/trace/noop"
 )
@@ -345,16 +345,23 @@ func (repo *Repository) ListTenants(ctx context.Context) ([]string, error) {
 		return nil, err
 	}
 
-	values, err := collection.Distinct(ctx, repo.tenantField, bson.M{
+	distinctResult := collection.Distinct(ctx, repo.tenantField, bson.M{
 		mongoFieldStatus: bson.M{"$in": bson.A{outbox.OutboxStatusPending, outbox.OutboxStatusFailed, outbox.OutboxStatusProcessing}},
 		repo.tenantField: bson.M{"$ne": defaultScopeTenantID},
 	})
-	if err != nil {
+	if err := distinctResult.Err(); err != nil {
 		libOpentelemetry.HandleSpanError(span, "failed to list tenants", err)
 
 		return nil, fmt.Errorf("listing tenants: %w", err)
 	}
 
+	var values []any
+	if err := distinctResult.Decode(&values); err != nil {
+		libOpentelemetry.HandleSpanError(span, "failed to decode tenants", err)
+
+		return nil, fmt.Errorf("listing tenants: %w", err)
+	}
+
 	tenants := make([]string, 0, len(values))
 	for _, value := range values {
 		tenantID, ok := value.(string)

commons/outbox/mongo/repository_integration_test.go

@@ -20,9 +20,9 @@ import (
 	"github.com/testcontainers/testcontainers-go"
 	tcmongo "github.com/testcontainers/testcontainers-go/modules/mongodb"
 	"github.com/testcontainers/testcontainers-go/wait"
-	"go.mongodb.org/mongo-driver/bson"
-	mongodriver "go.mongodb.org/mongo-driver/mongo"
-	mongooptions "go.mongodb.org/mongo-driver/mongo/options"
+	"go.mongodb.org/mongo-driver/v2/bson"
+	mongodriver "go.mongodb.org/mongo-driver/v2/mongo"
+	mongooptions "go.mongodb.org/mongo-driver/v2/mongo/options"
 	"go.opentelemetry.io/otel/trace/noop"
 )
 
@@ -115,7 +115,7 @@ func waitForMongoPrimary(t *testing.T, uri string) {
 
 	for time.Now().Before(deadline) {
 		ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
-		client, err := mongodriver.Connect(ctx, mongooptions.Client().ApplyURI(uri))
+		client, err := mongodriver.Connect(mongooptions.Client().ApplyURI(uri))
 		if err == nil {
 			err = client.Ping(ctx, nil)
 		}
@@ -294,7 +294,7 @@ func TestIntegration_Repository_CreateJoinsMongoTransactionContext(t *testing.T)
 
 	tenantCtx := outbox.ContextWithTenantID(suite.ctx, "tenant-a")
 	var committedID uuid.UUID
-	_, err = commitSession.WithTransaction(tenantCtx, func(sessionCtx mongodriver.SessionContext) (any, error) {
+	_, err = commitSession.WithTransaction(tenantCtx, func(sessionCtx context.Context) (any, error) {
 		event, eventErr := outbox.NewOutboxEvent(sessionCtx, "payment.tx.commit", uuid.New(), []byte(`{"ok":true}`))
 		if eventErr != nil {
 			return nil, eventErr
@@ -322,7 +322,7 @@ func TestIntegration_Repository_CreateJoinsMongoTransactionContext(t *testing.T)
 
 	var rolledBackID uuid.UUID
 	rollbackErr := errors.New("rollback sentinel")
-	_, err = rollbackSession.WithTransaction(tenantCtx, func(sessionCtx mongodriver.SessionContext) (any, error) {
+	_, err = rollbackSession.WithTransaction(tenantCtx, func(sessionCtx context.Context) (any, error) {
 		event, eventErr := outbox.NewOutboxEvent(sessionCtx, "payment.tx.rollback", uuid.New(), []byte(`{"ok":true}`))
 		if eventErr != nil {
 			return nil, eventErr

commons/outbox/mongo/repository_test.go

@@ -14,7 +14,7 @@ import (
 	tmcore "github.com/LerianStudio/lib-commons/v5/commons/tenant-manager/core"
 	"github.com/google/uuid"
 	"github.com/stretchr/testify/require"
-	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/v2/bson"
 )
 
 func TestNewRepository_Validation(t *testing.T) {

commons/tenant-manager/core/context.go

@@ -4,7 +4,7 @@ import (
 	"context"
 
 	"github.com/bxcodec/dbresolver/v2"
-	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/v2/mongo"
 )
 
 // nonNilContext returns ctx if non-nil, otherwise context.Background().

commons/tenant-manager/core/context_test.go

@@ -11,7 +11,7 @@ import (
 
 	"github.com/bxcodec/dbresolver/v2"
 	"github.com/stretchr/testify/assert"
-	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/v2/mongo"
 )
 
 func TestContextWithTenantID(t *testing.T) {

commons/tenant-manager/mongo/coverage_boost_test.go

@@ -78,7 +78,7 @@ func TestSwapMongoConnection_UpdatesEntry(t *testing.T) {
 	m.databaseNames["tenant-swap"] = "olddb"
 
 	newConn := &MongoConnection{DB: nil}
-	m.swapMongoConnection(context.Background(), "tenant-swap", newConn, "newdb")
+	m.swapMongoConnection("tenant-swap", newConn, "newdb")
 
 	m.mu.RLock()
 	stored := m.connections["tenant-swap"]