update tests

Author: qingyang-hu

internal/integration/client_side_encryption_prose_test.go

@@ -368,9 +368,9 @@ func TestClientSideEncryptionProse(t *testing.T) {
 					assert.NotNil(mt, insertErr, "expected InsertOne auth error, got nil")
 					assert.NotNil(mt, encErr, "expected Encrypt auth error, got nil")
 					assert.True(mt, strings.Contains(insertErr.Error(), "auth error"),
-						"expected InsertOne auth error, got %T: %v", errors.Unwrap(errors.Unwrap(insertErr)), insertErr)
+						"expected InsertOne auth error, got %T: %v", errors.Unwrap(insertErr), insertErr)
 					assert.True(mt, strings.Contains(encErr.Error(), "auth error"),
-						"expected Encrypt auth error, got %T: %v", errors.Unwrap(errors.Unwrap(insertErr)), insertErr)
+						"expected Encrypt auth error, got %T: %v", errors.Unwrap(encErr), encErr)
 					return
 				}
 				assert.Nil(mt, insertErr, "InsertOne error: %v", insertErr)

mongo/errors.go

@@ -12,6 +12,7 @@ import (
 	"errors"
 	"fmt"
 	"net"
+	"reflect"
 	"strings"
 
 	"go.mongodb.org/mongo-driver/v2/bson"
@@ -52,19 +53,21 @@ func replaceErrors(err error) error {
 		return nil
 	}
 
+	fmt.Println("replaceErrors", reflect.TypeOf(err))
+
 	// Do not propagate the acknowledgement sentinel error. For DDL commands,
 	// (creating indexes, dropping collections, etc) acknowledgement should be
 	// ignored. For non-DDL write commands (insert, update, etc), acknowledgement
 	// should be be propagated at the result-level: e.g.,
 	// SingleResult.Acknowledged.
-	if errors.Is(err, driver.ErrUnacknowledgedWrite) {
+	if err == driver.ErrUnacknowledgedWrite {
 		return nil
 	}
 
 	if errors.Is(err, topology.ErrTopologyClosed) {
 		return ErrClientDisconnected
 	}
-	if de := new(driver.Error); errors.As(err, de) {
+	if de, ok := err.(driver.Error); ok {
 		return CommandError{
 			Code:    de.Code,
 			Message: de.Message,
@@ -74,7 +77,7 @@ func replaceErrors(err error) error {
 			Raw:     bson.Raw(de.Raw),
 		}
 	}
-	if qe := new(driver.QueryFailureError); errors.As(err, qe) {
+	if qe, ok := err.(driver.QueryFailureError); ok {
 		// qe.Message is "command failure"
 		ce := CommandError{
 			Name:    qe.Message,
@@ -93,15 +96,15 @@ func replaceErrors(err error) error {
 
 		return ce
 	}
-	if me := new(mongocrypt.Error); errors.As(err, me) {
+	if me, ok := err.(mongocrypt.Error); ok {
 		return MongocryptError{Code: me.Code, Message: me.Message}
 	}
 
 	if errors.Is(err, codecutil.ErrNilValue) {
 		return ErrNilValue
 	}
 
-	if marshalErr := new(codecutil.MarshalError); errors.As(err, marshalErr) {
+	if marshalErr, ok := err.(codecutil.MarshalError); ok {
 		return MarshalError{
 			Value: marshalErr.Value,
 			Err:   marshalErr.Err,