executeDbCommand method
Implementation
Future<Map<String, dynamic>> executeDbCommand(MongoMessage message,
{Connection? connection}) async {
connection ??= _masterConnectionVerified;
//var result = Completer<Map<String, dynamic>>();
var replyMessage = await connection.query(message);
if (replyMessage.documents == null || replyMessage.documents!.isEmpty) {
throw {
keyOk: 0.0,
keyErrmsg:
'Error executing Db command, documents are empty $replyMessage'
};
}
var firstRepliedDocument = replyMessage.documents!.first;
/*var errorMessage = '';
if (replyMessage.documents.isEmpty) {
errorMessage =
'Error executing Db command, documents are empty $replyMessage';
print('Error: $errorMessage');
var m = <String, dynamic>{};
m['errmsg'] = errorMessage;
result.completeError(m);
} else */
if (documentIsNotAnError(firstRepliedDocument)) {
//result.complete(firstRepliedDocument);
return firstRepliedDocument;
} //else {
//result.completeError(firstRepliedDocument);
throw firstRepliedDocument;
//}
//return result.future;
}