remove unused; verbiage

Author: FGasper

internal/verifier/change_stream.go

@@ -193,7 +193,7 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
 		case finalTs := <-verifier.changeStreamFinalTsChan:
 			verifier.logger.Debug().
 				Interface("finalTimestamp", finalTs).
-				Msg("Change stream thread received final timestamp.")
+				Msg("Change stream thread received final timestamp. Finalizing change stream.")
 
 			changeStreamEnded = true
 

mbson/bson_raw.go

@@ -1,18 +1,11 @@
 package mbson
 
 import (
-	"fmt"
-
 	"github.com/pkg/errors"
-	"github.com/samber/lo"
 	"go.mongodb.org/mongo-driver/bson"
-	"go.mongodb.org/mongo-driver/bson/bsontype"
 	"go.mongodb.org/mongo-driver/x/bsonx/bsoncore"
 )
 
-// DefaultShortLogLength is a useful default value to pass to ShortenForLogging.
-const DefaultShortLogLength = 256
-
 // RawLookup combines bson.Raw’s LookupErr method with an additional
 // unmarshal step. The result is a convenient way to extract values from
 // bson.Raw. The returned boolean indicates whether the value was found.
@@ -34,45 +27,3 @@ func RawContains(doc bson.Raw, keys ...string) (bool, error) {
 	val := any(nil)
 	return RawLookup(doc, &val, keys...)
 }
-
-// GetTypes returns the types of bson.RawValues.
-func GetTypes(vals []bson.RawValue) []bsontype.Type {
-	return lo.Map(
-		vals,
-		func(v bson.RawValue, _ int) bsontype.Type {
-			return v.Type
-		},
-	)
-}
-
-// ShortenForLogging is meant for use where we need to log the raw BSON
-// bytes for debugging, but don't want to spew enormous amounts of binary data
-// to logs. It returns a byte slice of at most maxLength bytes. Note that this might
-// not return valid BSON!
-func ShortenForLogging(raw bson.Raw, maxLength int) []byte {
-	toLog := make([]byte, maxLength)
-	n := copy(toLog, raw)
-	return toLog[0:n]
-}
-
-// ConvertToRawValue converts the specified argument to a bson.RawValue. It panics if it can't be marshaled.
-func ConvertToRawValue(thing any) bson.RawValue {
-	t, val, err := bson.MarshalValue(thing)
-	if err != nil {
-		panic(err)
-	}
-	return bson.RawValue{
-		Type:  t,
-		Value: val,
-	}
-}
-
-// MustMarshal marshals the given value to BSON.
-// It panics if the marshaling fails.
-func MustMarshal(val any) bson.Raw {
-	raw, err := bson.Marshal(val)
-	if err != nil {
-		panic(fmt.Sprintf("failed to marshal %T (%v) to BSON: %v", val, val, err))
-	}
-	return raw
-}