Ignore $readPreference field (#3996)

FerretDB · Jan 23, 2024 · 0e2d108 · 0e2d108
1 parent 5201cab
commit 0e2d108
Show file tree

Hide file tree

Showing 6 changed files with 24 additions and 18 deletions.
diff --git a/internal/handler/common/count.go b/internal/handler/common/count.go
@@ -34,11 +34,12 @@ type CountParams struct {
 
 	Fields any `ferretdb:"fields,ignored"` // legacy MongoDB shell adds it, but it is never actually used
 
-	Hint        any             `ferretdb:"hint,ignored"`
-	ReadConcern *types.Document `ferretdb:"readConcern,ignored"`
-	Comment     string          `ferretdb:"comment,ignored"`
-	LSID        any             `ferretdb:"lsid,ignored"`
-	ClusterTime any             `ferretdb:"$clusterTime,ignored"`
+	Hint           any             `ferretdb:"hint,ignored"`
+	ReadConcern    *types.Document `ferretdb:"readConcern,ignored"`
+	Comment        string          `ferretdb:"comment,ignored"`
+	LSID           any             `ferretdb:"lsid,ignored"`
+	ClusterTime    any             `ferretdb:"$clusterTime,ignored"`
+	ReadPreference *types.Document `ferretdb:"$readPreference,ignored"`
 }
 
 // GetCountParams returns the parameters for the count command.

diff --git a/internal/handler/common/delete_params.go b/internal/handler/common/delete_params.go
@@ -34,9 +34,10 @@ type DeleteParams struct {
 
 	Let *types.Document `ferretdb:"let,unimplemented"`
 
-	WriteConcern *types.Document `ferretdb:"writeConcern,ignored"`
-	LSID         any             `ferretdb:"lsid,ignored"`
-	ClusterTime  any             `ferretdb:"$clusterTime,ignored"`
+	WriteConcern   *types.Document `ferretdb:"writeConcern,ignored"`
+	LSID           any             `ferretdb:"lsid,ignored"`
+	ClusterTime    any             `ferretdb:"$clusterTime,ignored"`
+	ReadPreference *types.Document `ferretdb:"$readPreference,ignored"`
 }
 
 // Delete represents single delete operation parameters.

diff --git a/internal/handler/common/distinct.go b/internal/handler/common/distinct.go
@@ -42,9 +42,10 @@ type DistinctParams struct {
 
 	Collation *types.Document `ferretdb:"collation,unimplemented"`
 
-	ReadConcern *types.Document `ferretdb:"readConcern,ignored"`
-	LSID        any             `ferretdb:"lsid,ignored"`
-	ClusterTime any             `ferretdb:"$clusterTime,ignored"`
+	ReadConcern    *types.Document `ferretdb:"readConcern,ignored"`
+	LSID           any             `ferretdb:"lsid,ignored"`
+	ClusterTime    any             `ferretdb:"$clusterTime,ignored"`
+	ReadPreference *types.Document `ferretdb:"$readPreference,ignored"`
 }
 
 // GetDistinctParams returns `distinct` command parameters.

diff --git a/internal/handler/common/find.go b/internal/handler/common/find.go
@@ -46,13 +46,14 @@ type FindParams struct {
 	Collation *types.Document `ferretdb:"collation,unimplemented"`
 	Let       *types.Document `ferretdb:"let,unimplemented"`
 
-	AllowDiskUse bool            `ferretdb:"allowDiskUse,ignored"`
-	ReadConcern  *types.Document `ferretdb:"readConcern,ignored"`
-	Max          *types.Document `ferretdb:"max,ignored"`
-	Min          *types.Document `ferretdb:"min,ignored"`
-	Hint         any             `ferretdb:"hint,ignored"`
-	LSID         any             `ferretdb:"lsid,ignored"`
-	ClusterTime  any             `ferretdb:"$clusterTime,ignored"`
+	AllowDiskUse   bool            `ferretdb:"allowDiskUse,ignored"`
+	ReadConcern    *types.Document `ferretdb:"readConcern,ignored"`
+	Max            *types.Document `ferretdb:"max,ignored"`
+	Min            *types.Document `ferretdb:"min,ignored"`
+	Hint           any             `ferretdb:"hint,ignored"`
+	LSID           any             `ferretdb:"lsid,ignored"`
+	ClusterTime    any             `ferretdb:"$clusterTime,ignored"`
+	ReadPreference *types.Document `ferretdb:"$readPreference,ignored"`
 
 	ReturnKey           bool `ferretdb:"returnKey,unimplemented-non-default"`
 	OplogReplay         bool `ferretdb:"oplogReplay,ignored"`

diff --git a/internal/handler/common/findandmodify.go b/internal/handler/common/findandmodify.go
@@ -52,6 +52,7 @@ type FindAndModifyParams struct {
 	BypassDocumentValidation bool            `ferretdb:"bypassDocumentValidation,ignored"`
 	LSID                     any             `ferretdb:"lsid,ignored"`
 	ClusterTime              any             `ferretdb:"$clusterTime,ignored"`
+	ReadPreference           *types.Document `ferretdb:"$readPreference,ignored"`
 }
 
 // GetFindAndModifyParams returns `findAndModifyParams` command parameters.

diff --git a/internal/handler/common/update_params.go b/internal/handler/common/update_params.go
@@ -39,6 +39,7 @@ type UpdateParams struct {
 	WriteConcern             *types.Document `ferretdb:"writeConcern,ignored"`
 	LSID                     any             `ferretdb:"lsid,ignored"`
 	ClusterTime              any             `ferretdb:"$clusterTime,ignored"`
+	ReadPreference           *types.Document `ferretdb:"$readPreference,ignored"`
 }
 
 // Update represents a single update operation parameters.