Merge branch 'release/9.0.0'

Author: furey

README.md

@@ -70,7 +70,6 @@
 - [`list-collections`](https://github.com/search?type=code&q=repo%3Afurey%2Fmongodb-lens+%2Fserver%5C.tool%5C%28%5Cs*%27list-collections%27%2C%2F): Explore collections in the current database
 - [`list-connections`](https://github.com/search?type=code&q=repo%3Afurey%2Fmongodb-lens+%2Fserver%5C.tool%5C%28%5Cs*%27list-connections%27%2C%2F): View all available MongoDB connection aliases
 - [`list-databases`](https://github.com/search?type=code&q=repo%3Afurey%2Fmongodb-lens+%2Fserver%5C.tool%5C%28%5Cs*%27list-databases%27%2C%2F): View all accessible databases
-- [`map-reduce`](https://github.com/search?type=code&q=repo%3Afurey%2Fmongodb-lens+%2Fserver%5C.tool%5C%28%5Cs*%27map-reduce%27%2C%2F): Run MapReduce operations for complex data processing
 - [`rename-collection`](https://github.com/search?type=code&q=repo%3Afurey%2Fmongodb-lens+%2Fserver%5C.tool%5C%28%5Cs*%27rename-collection%27%2C%2F): Rename existing collections ([requires confirmation](#data-protection-confirmation-for-destructive-operations) when dropping targets)
 - [`shard-status`](https://github.com/search?type=code&q=repo%3Afurey%2Fmongodb-lens+%2Fserver%5C.tool%5C%28%5Cs*%27shard-status%27%2C%2F): View sharding configuration for databases and collections
 - [`text-search`](https://github.com/search?type=code&q=repo%3Afurey%2Fmongodb-lens+%2Fserver%5C.tool%5C%28%5Cs*%27text-search%27%2C%2F): Perform full-text search across text-indexed fields
@@ -1127,8 +1126,6 @@ With your MCP Client running and connected to MongoDB Lens, try the following ex
 
 - _"Switch to sample_geospatial db, then find all shipwrecks within 10km of coordinates [-80.12, 26.46]"_<br>
   <sup>➥ Uses `geo-query` tool</sup>
-- _"Switch to sample_mflix db, then run this map reduce to calculate movie counts by year: map=`'function () { emit(this.year, 1) }'` reduce=`'function (key, values) { return Array.sum(values) }'`"_<br>
-  <sup>➥ Uses `map-reduce` tool</sup>
 - _"Switch to sample_analytics db, then execute a transaction to move funds between accounts: \<account ids\>"_<br>
   <sup>➥ Uses `transaction` tool</sup>
 - _"Create a time series collection for sensor readings"_<br>

mongodb-lens.js

@@ -7,6 +7,7 @@ import { readFileSync, existsSync } from 'fs'
 import { dirname, join } from 'path'
 import { fileURLToPath } from 'url'
 import mongodb from 'mongodb'
+import { EJSON } from 'bson'
 import { z } from 'zod'
 import _ from 'lodash'
 
@@ -2819,35 +2820,6 @@ const registerTools = (server) => {
     )
   }
 
-  if (!isDisabled('tools', 'map-reduce')) {
-    server.tool(
-      'map-reduce',
-      'Run Map-Reduce operations (note: Map-Reduce deprecated as of MongoDB 5.0)',
-      {
-        collection: z.string().min(1).describe('Collection name'),
-        map: z.string().describe('Map function as string e.g. "function() { emit(this.field, 1); }"'),
-        reduce: z.string().describe('Reduce function as string e.g. "function(key, values) { return Array.sum(values); }"'),
-        options: z.string().optional().describe('Options as JSON string (query, limit, etc.)')
-      },
-      async ({ collection, map, reduce, options }) => {
-        return withErrorHandling(async () => {
-          log(`Tool: Running Map-Reduce on collection '${collection}'…`)
-          const mapFunction = eval(`(${map})`)
-          const reduceFunction = eval(`(${reduce})`)
-          const parsedOptions = options ? JSON.parse(options) : {}
-          const results = await runMapReduce(collection, mapFunction, reduceFunction, parsedOptions)
-          log(`Tool: Map-Reduce operation complete.`)
-          return {
-            content: [{
-              type: 'text',
-              text: formatMapReduceResults(results)
-            }]
-          }
-        }, `Error running Map-Reduce on collection '${collection}'`)
-      }
-    )
-  }
-
   if (!isDisabled('tools', 'watch-changes')) {
     server.tool(
       'watch-changes',
@@ -4177,39 +4149,6 @@ const getDistinctValues = async (collectionName, field, filter = {}) => {
 const isValidFieldName = (field) =>
   typeof field === 'string' && field.length > 0 && !field.startsWith('$')
 
-const runMapReduce = async (collectionName, map, reduce, options = {}) => {
-  log(`DB Operation: Running Map-Reduce on collection '${collectionName}'…`)
-  try {
-    await throwIfCollectionNotExists(collectionName)
-    const collection = currentDb.collection(collectionName)
-
-    if (!options.out) options.out = { inline: 1 }
-
-    const results = await collection.mapReduce(map, reduce, options)
-
-    if (results && typeof results.toArray === 'function') {
-      log(`DB Operation: Map-Reduce operation complete (legacy mode).`)
-      return results.toArray()
-    } else if (results && Array.isArray(results)) {
-      log(`DB Operation: Map-Reduce operation complete (array results).`)
-      return results
-    } else if (results && options.out && options.out.inline !== 1) {
-      log(`DB Operation: Map-Reduce output to collection '${typeof options.out === 'string' ? options.out : JSON.stringify(options.out)}'.`)
-      const outCollection = currentDb.collection(
-        typeof options.out === 'string' ? options.out : options.out.replace
-      )
-      memoryCache.collections.delete(currentDbName)
-      return outCollection.find().toArray()
-    } else {
-      log(`DB Operation: Map-Reduce operation complete (unknown format).`)
-      return Array.isArray(results) ? results : (results.result || results)
-    }
-  } catch (error) {
-    log(`DB Operation: Map-Reduce operation failed: ${error.message}`)
-    throw error
-  }
-}
-
 const bulkOperations = async (collectionName, operations, ordered = config.tools.bulkOperations.ordered) => {
   log(`DB Operation: Performing bulk operations on collection '${collectionName}'…`)
   try {
@@ -4650,16 +4589,6 @@ const formatUpdateResult = (result) => {
   return output
 }
 
-const formatMapReduceResults = (results) => {
-  if (!results || !Array.isArray(results)) return 'Map-Reduce results not available'
-  let output = `Map-Reduce Results (${results.length} entries):\n`
-  for (const result of results) {
-    output += `- Key: ${formatValue(result._id)}\n`
-    output += `  Value: ${formatValue(result.value)}\n`
-  }
-  return output
-}
-
 const formatBulkResult = (result) => {
   if (!result) return 'Bulk operation results not available'
 
@@ -5789,7 +5718,7 @@ const parseEnvValue = (value, defaultValue, path) => {
 const parseJsonString = (jsonString) => {
   if (!jsonString || typeof jsonString !== 'string') return jsonString
   try {
-    return JSON.parse(jsonString)
+    return EJSON.parse(jsonString, { relaxed: false })
   } catch (error) {
     throw new Error(`Invalid JSON: ${error.message}`)
   }
@@ -5954,7 +5883,7 @@ CAPS:
 - DOC: find/count/insert-doc/update-doc/delete
 - SCH: infer/validate/compare/analyze
 - IDX: create/analyze/optimize
-- AGG: pipeline/mapreduce/distinct
+- AGG: pipeline/distinct
 - PERF: explain/analyze/monitor
 - UTIL: clear-cache/export/validate
 - ADV: text/geo/timeseries/bulk/txn/gridfs/sharding/export
@@ -5966,7 +5895,7 @@ PTRNS:
 - MOD: insert-doc/update-doc/delete-doc/bulk-ops
 - SCH: collection-schema/analyze-schema/compare-schemas
 - OPT: explain-query/analyze-patterns/create-index
-- AGG: aggregate-data/map-reduce
+- AGG: aggregate-data
 - MON: server-status/performance-metrics/watch-changes
 - CACHE: clear-cache{all|specific}
 - CONN: add-alias→connect-mongodb→db-ops→connect-original

mongodb-lens.test.js

@@ -1161,31 +1161,6 @@ const testAggregateDataTool = async () => {
   assert(content.includes('"count":'), 'Count not found')
 }
 
-const testMapReduceTool = async () => {
-  await useTestDatabase()
-
-  const mapFunction = 'function() { emit(this.isActive, 1); }'
-  const reduceFunction = 'function(key, values) { return Array.sum(values); }'
-
-  const response = await runLensCommand({
-    command: 'mcp.tool.invoke',
-    params: {
-      name: 'map-reduce',
-      args: {
-        collection: TEST_COLLECTION_NAME,
-        map: mapFunction,
-        reduce: reduceFunction,
-        options: JSON.stringify({ out: { inline: 1 } })
-      }
-    }
-  })
-
-  assertToolSuccess(response, 'Map-Reduce Results')
-
-  const content = response.result.content[0].text
-  assert(content.includes('Key:') && content.includes('Value:'), 'Map-reduce key-value pairs not found')
-}
-
 const testCreateIndexTool = async () => {
   await useTestDatabase()
 
@@ -2412,7 +2387,6 @@ const TEST_GROUPS = [
     name: 'Advanced Tools',
     tests: [
       { name: 'aggregate-data Tool', fn: testAggregateDataTool },
-      { name: 'map-reduce Tool', fn: testMapReduceTool },
       { name: 'create-index Tool', fn: testCreateIndexTool },
       { name: 'drop-index Tool', fn: testDropIndexTool },
       { name: 'analyze-schema Tool', fn: testAnalyzeSchemaTool },