promesas - ¿Cómo optimizar este código de Node.js+q para evitar el infierno de devolución de llamada?

q defer() node js

Question

Estoy usando Q para prevenir el infierno de devolución de llamada, pero he llegado a una parte de mi código que no sé cómo organizar:

Estoy buscando mensajes programados para ser entregados. Para cada uno de ellos, trato de enviarlos uno por uno y si se pueden enviar, los quita de la base de datos. La parte fea es tener un then () dentro de un ciclo for . ¡De esta forma termino anidando promesas en lugar de callbacks anidados! Sugerencias?

appLog.debug("Looking for scheduled messages");
var messages = messageService.findScheduled()
.then(function(messages){
    appLog.debug("found [%d] stored messages",messages.length);
    for(var i = 0; i<messages.length; i++){
        messageService.send(msg.namespace, msg.message, msg.data)
        .then(function(result) {
            if (result == constants.EVENT_EMIT_SENT) {
                appLog.debug("Message [%s] sent!!!", msg._id);
                messageService.remove(msg._id)
                    .then(function(result) {
                         appLog.debug("Message deleted: [%s]", msg._id);
                    })
                    .fail(function(err) {
                        appLog.error("The message couldn''t be deleted: [%s]", msg._id);
                    });

            }else if (result == constants.EVENT_EMIT_NOT_SENT_AND_NOT_STORED) {
                appLog.debug("Message [%s] not sent", msg._id);
            }

        });
    }
});

Answer 1

Sí, una forma de limpiarlo sería definir una función con nombre:

function SuccessfulSend(result) {
        if (result == constants.EVENT_EMIT_SENT) {
            appLog.debug("Message [%s] sent!!!", msg._id);
            messageService.remove(msg._id)
                .then(function(result) {
                     appLog.debug("Message deleted: [%s]", msg._id);
                })
                .fail(function(err) {
                    appLog.error("The message couldn''t be deleted: [%s]", msg._id);
                });

        }else if (result == constants.EVENT_EMIT_NOT_SENT_AND_NOT_STORED) {
            appLog.debug("Message [%s] not sent", msg._id);
        }

    }

y entonces:

.then(SuccessfulSend);

Answer 2

Simplemente refactorizar sus funciones en funciones nombradas y tratar de hacer un mejor uso del encadenamiento prometedor sería una gran mejora.

var messageService, appLog, constants;

appLog.debug("Looking for scheduled messages");

messageService.findScheduled()
  .then(function(messages){
    appLog.debug("found [%d] stored messages", messages.length);
    messages.map(processMessage);
  });

function processMessage(msg) {

  msg.data.dontStore = true;
  messageService

    .send(msg.namespace, msg.message, msg.data)

    .then(function(result) {

      if (result !== constants.EVENT_EMIT_SENT) {
        throw new Error(constants.EVENT_EMIT_SENT);
      }

      appLog.debug("Message [%s] sent!!!", msg._id);
      return removeMessage(msg);

    })

    .fail(function(err) {
      appLog.debug("Message [%s] not sent", msg._id);
      throw err;
    });

}

function removeMessage(msg) {
  return messageService.remove(msg._id)
    .then(function() {
      appLog.message("Message deleted: [%s]", msg._id);
    })
    .fail(function(err) {
      appLog.message("The message couldn''t be deleted: [%s]", msg._id);
      throw err;
    });
}

Answer 3

La parte fea es tener un then () dentro de un bucle for

No, eso puede suceder. Aunque el estilo de programación funcional de las promesas generalmente lleva a utilizar .map() con una devolución de llamada de todos modos :-) La bucle es una estructura de control y requiere anidamiento (excepto que se usan excepciones para el flujo de control , es decir, bifurcación). Sin embargo, lo que no tienes que hacer es anidar promesas en callbacks de promesas.

Simplificaría tu cuerpo de bucle para

function sendAndDelete(msg) {
    return messageService.send(msg.namespace, msg.message, msg.data)
    .then(function(result) {
        if (result == constants.EVENT_EMIT_SENT) {
            appLog.debug("Message [%s] sent!!!", msg._id);
            return msg._id;
        } else if (result == constants.EVENT_EMIT_NOT_SENT_AND_NOT_STORED) {
            appLog.debug("Message [%s] not sent", msg._id);
            throw new Error("Message not sent");
        }
    })
    .then(messageService.remove)
    .then(function(result) {
         appLog.debug("Message deleted: [%s]", msg._id);
    }, function(err) {
         appLog.error("The message has not been deleted: [%s]", msg._id);
    });
}

Ahora puedes hacer algo como

messageService.findScheduled()
.then(function(messages){
    appLog.debug("found [%d] stored messages",messages.length);
    return Q.all(messages.map(sendAndDelete));
})
.then(function() {
    appLog.debug("all messages done");
});