add listCollections

Author: qingyang-hu

internal/integration/unified/crud_helpers.go

@@ -173,6 +173,8 @@ func createListCollectionsArguments(args bson.Raw) (*listCollectionsArguments, e
 			lca.filter = val.Document()
 		case "nameOnly":
 			lca.opts.SetNameOnly(val.Boolean())
+		case "rawData":
+			lca.opts.SetRawData(val.Boolean())
 		default:
 			return nil, fmt.Errorf("unrecognized listCollections option %q", key)
 		}

mongo/database.go

@@ -487,6 +487,9 @@ func (db *Database) ListCollections(
 	if args.AuthorizedCollections != nil {
 		op = op.AuthorizedCollections(*args.AuthorizedCollections)
 	}
+	if args.RawData != nil {
+		op = op.RawData(*args.RawData)
+	}
 
 	retry := driver.RetryNone
 	if db.client.retryReads {

mongo/options/listcollectionsoptions.go

@@ -14,6 +14,7 @@ type ListCollectionsOptions struct {
 	NameOnly              *bool
 	BatchSize             *int32
 	AuthorizedCollections *bool
+	RawData               *bool
 }
 
 // ListCollectionsOptionsBuilder contains options to configure list collection
@@ -70,3 +71,15 @@ func (lc *ListCollectionsOptionsBuilder) SetAuthorizedCollections(b bool) *ListC
 
 	return lc
 }
+
+// SetRawData sets the value for the RawData field. If true, it allows the CRUD operations to access timeseries
+// collections on the bucket-level. This option is only valid for MongoDB versions >= 9.0. The default value is false.
+func (lc *ListCollectionsOptionsBuilder) SetRawData(rawData bool) *ListCollectionsOptionsBuilder {
+	lc.Opts = append(lc.Opts, func(opts *ListCollectionsOptions) error {
+		opts.RawData = &rawData
+
+		return nil
+	})
+
+	return lc
+}

x/mongo/driver/operation/list_collections.go

@@ -39,6 +39,7 @@ type ListCollections struct {
 	batchSize             *int32
 	serverAPI             *driver.ServerAPIOptions
 	timeout               *time.Duration
+	rawData               *bool
 }
 
 // NewListCollections constructs and returns a new ListCollections.
@@ -92,7 +93,7 @@ func (lc *ListCollections) Execute(ctx context.Context) error {
 
 }
 
-func (lc *ListCollections) command(dst []byte, _ description.SelectedServer) ([]byte, error) {
+func (lc *ListCollections) command(dst []byte, desc description.SelectedServer) ([]byte, error) {
 	dst = bsoncore.AppendInt32Element(dst, "listCollections", 1)
 	if lc.filter != nil {
 		dst = bsoncore.AppendDocumentElement(dst, "filter", lc.filter)
@@ -110,6 +111,11 @@ func (lc *ListCollections) command(dst []byte, _ description.SelectedServer) ([]
 	}
 	dst = bsoncore.AppendDocumentElement(dst, "cursor", cursorDoc.Build())
 
+	// Set rawData for 8.2+ servers.
+	if lc.rawData != nil && desc.WireVersion != nil && driverutil.VersionRangeIncludes(*desc.WireVersion, 27) {
+		dst = bsoncore.AppendBooleanElement(dst, "rawData", *lc.rawData)
+	}
+
 	return dst, nil
 }
 
@@ -274,3 +280,13 @@ func (lc *ListCollections) Authenticator(authenticator driver.Authenticator) *Li
 	lc.authenticator = authenticator
 	return lc
 }
+
+// RawData sets the rawData to access timeseries data in the compressed format.
+func (lc *ListCollections) RawData(rawData bool) *ListCollections {
+	if lc == nil {
+		lc = new(ListCollections)
+	}
+
+	lc.rawData = &rawData
+	return lc
+}