executeDbCommand method

Future<Map<String, dynamic>> executeDbCommand(MongoMessage message, { Connection? connection, })

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;
}