Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
JavaScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475#!/usr/bin/env node
import { MongoClient } from 'mongodb';
const MONGODB_CONNECTION_STRING = process.env.MONGODB_CONNECTION_STRING;const MONGODB_NAME = process.env.MONGODB_NAME || 'aesthetic';
if (!MONGODB_CONNECTION_STRING) { console.error('Error: MONGODB_CONNECTION_STRING environment variable is required'); console.error('Usage: MONGODB_CONNECTION_STRING=your_uri node inspect-mongodb.mjs'); process.exit(1);}
async function main() { const client = new MongoClient(MONGODB_CONNECTION_STRING); try { await client.connect(); console.log('Connected to MongoDB\n'); const db = client.db(MONGODB_NAME); // List all collections console.log('Collections in database:'); const collections = await db.listCollections().toArray(); for (const coll of collections) { console.log(` - ${coll.name}`); } // Check for chat-related collections console.log('\n='.repeat(80)); const chatCollections = collections.filter(c => c.name.toLowerCase().includes('chat') || c.name.toLowerCase().includes('message') ); if (chatCollections.length > 0) { console.log('\nChat-related collections found:'); for (const coll of chatCollections) { console.log(`\n${coll.name}:`); const collection = db.collection(coll.name); const count = await collection.countDocuments(); console.log(` Total documents: ${count}`); if (count > 0) { const sample = await collection.findOne(); console.log(` Sample document:`); console.log(JSON.stringify(sample, null, 2)); } } } else { console.log('\nNo chat-related collections found. Checking all collections for messages...\n'); for (const coll of collections) { const collection = db.collection(coll.name); const count = await collection.countDocuments(); if (count > 0) { const sample = await collection.findOne(); console.log(`\n${coll.name} (${count} documents):`); console.log(JSON.stringify(sample, null, 2).substring(0, 500) + '...'); } } } } catch (error) { console.error('Error:', error.message); process.exit(1); } finally { await client.close(); }}
main();