diff --git a/internal/tools/mongodb/mongodbupdatemany/mongodbupdatemany.go b/internal/tools/mongodb/mongodbupdatemany/mongodbupdatemany.go index 6ada0cde19a..5a349b33763 100644 --- a/internal/tools/mongodb/mongodbupdatemany/mongodbupdatemany.go +++ b/internal/tools/mongodb/mongodbupdatemany/mongodbupdatemany.go @@ -80,7 +80,7 @@ func (cfg Config) Initialize(srcs map[string]sources.Source) (tools.Tool, error) } // Create a slice for all parameters - allParameters := slices.Concat(cfg.FilterParams, cfg.FilterParams, cfg.UpdateParams) + allParameters := slices.Concat(cfg.FilterParams, cfg.UpdateParams) // Verify no duplicate parameter names err := tools.CheckDuplicateParameters(allParameters) diff --git a/internal/tools/mongodb/mongodbupdateone/mongodbupdateone.go b/internal/tools/mongodb/mongodbupdateone/mongodbupdateone.go index 9b92c2ada8f..0709c4baa3a 100644 --- a/internal/tools/mongodb/mongodbupdateone/mongodbupdateone.go +++ b/internal/tools/mongodb/mongodbupdateone/mongodbupdateone.go @@ -81,7 +81,7 @@ func (cfg Config) Initialize(srcs map[string]sources.Source) (tools.Tool, error) } // Create a slice for all parameters - allParameters := slices.Concat(cfg.FilterParams, cfg.FilterParams, cfg.UpdateParams) + allParameters := slices.Concat(cfg.FilterParams, cfg.UpdateParams) // Verify no duplicate parameter names err := tools.CheckDuplicateParameters(allParameters) diff --git a/tests/mongodb/mongodb_integration_test.go b/tests/mongodb/mongodb_integration_test.go index 16b13c14bf6..22824651958 100644 --- a/tests/mongodb/mongodb_integration_test.go +++ b/tests/mongodb/mongodb_integration_test.go @@ -666,8 +666,14 @@ func getMongoDBToolsConfig(sourceConfig map[string]any, toolKind string) map[str "authRequired": []string{}, "collection": "test_collection", "canonical": true, - "filterPayload": `{ "id" : 300 }`, - "filterParams": []any{}, + "filterPayload": `{ "id" : {{ .id }} }`, + "filterParams": []map[string]any{ + { + "name": "id", + "type": "integer", + "description": "id", + }, + }, "updatePayload": `{ "$set" : { "name": {{json .name}} } }`, "updateParams": []map[string]any{ {