RocketChat/Rocket.Chat

import { MongoInternals } from 'meteor/mongo';

import { isWatcherRunning } from '../../../../server/modules/watchers/watchers.module';

function getOplogInfo(): { oplogEnabled: boolean; mongo: MongoConnection } {
    const { mongo } = MongoInternals.defaultRemoteCollectionDriver();

    const oplogEnabled = isWatcherRunning();

    return { oplogEnabled, mongo };
}

async function fallbackMongoInfo(): Promise<{
    oplogEnabled: boolean;
    mongoVersion: string;
    mongoStorageEngine?: string;
    mongo: MongoConnection;
}> {
    let mongoVersion;
    let mongoStorageEngine;

    const { oplogEnabled, mongo } = getOplogInfo();

    try {
        const { version } = await mongo.db.command({ buildinfo: 1 });
        mongoVersion = version;
        mongoStorageEngine = 'unknown';
    } catch (e) {
        console.error('=== Error getting MongoDB info ===');
        console.error(e?.toString());
        console.error('----------------------------------');
        console.error("Without mongodb version we can't ensure you are running a compatible version.");
        console.error('If you are running your mongodb with auth enabled and an user different from admin');
        console.error('you may need to grant permissions for this user to check cluster data.');
        console.error('You can do it via mongo shell running the following command replacing');
        console.error("the string YOUR_USER by the correct user's name:");
        console.error('');
        console.error('   db.runCommand({ grantRolesToUser: "YOUR_USER" , roles: [{role: "clusterMonitor", db: "admin"}]})');
        console.error('');
        console.error('==================================');
    }

    return { oplogEnabled, mongoVersion, mongoStorageEngine, mongo };
}

export async function getMongoInfo(): Promise<{
    oplogEnabled: boolean;
    mongoVersion: string;
    mongoStorageEngine?: string;
    mongo: MongoConnection;
}> {
    let mongoVersion;
    let mongoStorageEngine;

    const { oplogEnabled, mongo } = getOplogInfo();

    try {
        const { version, storageEngine } = await mongo.db.command({ serverStatus: 1 });

        mongoVersion = version;
        mongoStorageEngine = storageEngine.name;
    } catch (e) {
        return fallbackMongoInfo();
    }

    return { oplogEnabled, mongoVersion, mongoStorageEngine, mongo };
}