Function executeIntrospect

apps/sim/app/api/tools/mongodb/utils.ts:146–197

(
  client: MongoClient,
  database?: string
)

 * Introspect MongoDB to get databases, collections, and indexes
 */
export async function executeIntrospect(
  client: MongoClient,
  database?: string
): Promise<{
  message: string
  databases: string[]
  collections: MongoDBCollectionInfo[]
}> {
  const databases: string[] = []
  const collections: MongoDBCollectionInfo[] = []

  if (database) {
    databases.push(database)
    const db = client.db(database)
    const collectionList = await db.listCollections().toArray()

    for (const collInfo of collectionList) {
      const coll = db.collection(collInfo.name)
      const indexes = await coll.indexes()
      const documentCount = await coll.estimatedDocumentCount()

      collections.push({
        name: collInfo.name,
        type: collInfo.type || 'collection',
        documentCount,
        indexes: indexes.map((idx) => ({
          name: idx.name || '',
          key: idx.key as Record<string, number>,
          unique: idx.unique || false,
          sparse: idx.sparse,
        })),
      })
    }
  } else {
    const admin = client.db().admin()
    const dbList = await admin.listDatabases()

    for (const dbInfo of dbList.databases) {
      databases.push(dbInfo.name)
    }
  }

  const message = database
    ? `Found ${collections.length} collections in database '${database}'`
    : `Found ${databases.length} databases`

  return {
    message,
    databases,
    collections,
  }
}