Merge pull request #199 from konecty/fix/prevent-watch-when-mongo-rs

Fix: prevent watch when mongo rs

src/imports/meta/loadMetaObjects.ts

@@ -8,6 +8,7 @@ import unset from 'lodash/unset';
 import { Document } from '@imports/model/Document';
 import { MetaObject } from '@imports/model/MetaObject';
 import { MetaObjectType } from '@imports/types/metadata';
+import { isReplicaSet } from '@imports/utils/mongo';
 import { Promise as BluebirdPromise } from 'bluebird';
 import path from 'path';
 import { checkInitialData } from '../data/initialData';
@@ -299,5 +300,8 @@ export async function loadMetaObjects() {
 	logger.info('Loading MetaObject.Meta from database');
 	await dbLoad();
 
-	dbWatch();
+	if (await isReplicaSet()) {
+		logger.info('[kondata] Starting watch for changes in the database');
+		dbWatch();
+	}
 }

src/imports/utils/mongo.ts

@@ -0,0 +1,46 @@
+import { db } from '@imports/database';
+import isArray from 'lodash/isArray';
+import isObject from 'lodash/isObject';
+import { MongoServerError, ObjectId } from 'mongodb';
+import { logger } from './logger';
+
+export function convertObjectIds<T>(
+	records: T,
+): T extends ObjectId
+	? string
+	: T extends (infer U)[]
+		? U[]
+		: T extends object
+			? { [K in keyof T]: T[K] extends ObjectId ? string : T[K] extends object | object[] ? ReturnType<typeof convertObjectIds<T[K]>> : T[K] }
+			: T {
+	if (isArray(records)) {
+		return records.map(item => convertObjectIds(item)) as any;
+	}
+
+	if (isObject(records)) {
+		if (records instanceof ObjectId) {
+			return records.toString() as any;
+		}
+
+		return Object.keys(records).reduce((result, key) => {
+			const k = key as keyof T;
+			result[k] = convertObjectIds(records[k]);
+			return result;
+		}, {} as any);
+	}
+
+	return records as any;
+}
+
+export async function isReplicaSet() {
+	try {
+		const status = await db.admin().replSetGetStatus();
+		return status != null;
+	} catch (error) {
+		if ((error as MongoServerError).codeName === 'NoReplicationEnabled') {
+			return false;
+		}
+		logger.error('Erro ao verificar status do replica set:', error);
+		return false;
+	}
+}