Обещание путаницы с использованием узла (ES6) и Bluebird

У меня была проблема с присвоением значений до завершения асинхронного вызова, поэтому я решил использовать Promises (в данном случае: Bluebird). Я думал, что это решит проблему, но, поскольку я совсем не знаком с промисами/или узлом в этом отношении, он все еще делает то же самое.

Как мне изменить мой код ниже, чтобы правильно использовать промисы? И поддерживать поток, чтобы я мог проверить modules на основе предыдущего row ?

var Promise         = require('bluebird');
var db              = require('../shared/db');
var queryHelper     = require('../shared/queryHelper');
var schemas         = require('../schemas/schemas');
var _               = require('lodash');
var serverSettings  = require('../shared/coreServerSettings');

// Create new instance of mysql module
var connection      = new db();
var queryhelper     = new queryHelper();

// Promised methods
var queryAndWait = Promise.promisify(connection.query);

..отрезать..

queryAndWait(query + '; ' + queryFoundRows, params).then(function (result) {
  var payload = [];
  var site_access = [];
  var module_access = [];

  _.each(result[0], function (row) {
    var sites = row.site_access.split(',');
    _.each(sites, function (site_id) {
      site_access.push(site_id);
    });

    row.site_access = site_access;
    site_access = [];

    queryAndWait(queryModules, [row.priv_id]).then(function (result) {
      _.each(result, function (module) {
        var modulePriv = {
          priv_name: module.priv_name,
          priv_num: module.priv_num,
          enabled: module.enabled
        };

        module_access.push(modulePriv);
      });

      //console.log("am assigning " + JSON.stringify(module_access));
      row.module_access = module_access;
      module_access = []
    });

    payload.push(row);
  });
});

Чтобы уточнить:

Извините, модули — это группы продуктов, к которым имеют доступ пользователи (строка), которые рассчитываются «на лету» (побитово — следовательно, соединение недоступно и отдельный запрос), запрос модуля возвращает что-то вроде следующего, которое я затем перебираю и прикрепите к строке перед возвратом полезной нагрузки:

[{"priv_name":"INTERACT","priv_num":1,"enabled":1},{"priv_name":"STAFF_ADMIN","priv_num":32,"enabled":1},{"priv_name":"INT_EDIT","priv_num":64,"enabled":0},{"priv_name":"FAILED_LOGIN","priv_num":128,"enabled":0},{"priv_name":"INT_TAGS","priv_num":256,"enabled":0},{"priv_name":"NC","priv_num":512,"enabled":0},{"priv_name":"CC_TIMETABLE_MGR","priv_num":1024,"enabled":0}]

node.js javascript promise bluebird
person fantasitcalbeastly    schedule 23.09.2015    source источник
comment
Что такое modules и каков ожидаемый результат?   -  person thefourtheye    schedule 23.09.2015
comment
Обновлено, чтобы уточнить   -  person fantasitcalbeastly    schedule 23.09.2015
comment
Просто примечание: все функции lodash, которые вы здесь используете, изначально реализованы в JavaScript, и нет необходимости в библиотеке.   -  person baao    schedule 23.09.2015

Ответы (2)


arrow_upward
1
arrow_downward

да, внутренний queryAndWait будет работать независимо для каждой строки, так как вы не связываете обещания.

Поскольку вы используете bluebird, вам понадобится что-то подобное для поддержания потока

queryAndWait(query + '; ' + queryFoundRows, params).then(function (result) {
    return Promise.map(result[0], function (row) {
        var site_access = [];
        var module_access = [];

        var sites = row.site_access.split(',');
        _.each(sites, function (site_id) {
            site_access.push(site_id);
        });

        row.site_access = site_access;

        return queryAndWait(queryModules, [row.priv_id]).then(function (result) {
            _.each(result, function (module) {
                var modulePriv = {
                    priv_name: module.priv_name,
                    priv_num: module.priv_num,
                    enabled: module.enabled
                };

                module_access.push(modulePriv);
            });
            row.module_access = module_access;
            return row;
        });
    });
}).then(function(payload) {
    console.log(payload);
}).catch(function(error) {
    console.log(error);
});
person code-jaff    schedule 23.09.2015
comment
row.site_access = row.site_access.split(',');. Чтение в другой массив не требуется. - person Roamer-1888; 23.09.2015

arrow_upward
1
arrow_downward

Обещание поможет вам контролировать поток приложения простым способом. Я рекомендую вам ознакомиться с основными принципами обещаний, по крайней мере, со спецификацией Promise A+.

Ваш код может быть написан по-разному, я рекомендую именно этот способ, потому что он модульный:

var Promise         = require('bluebird');
var queryAndWait = Promise.promisify(connection.query);

function getRows(params) {
  return queryAndWait(query + '; ' + queryFoundRows, params)
          .then(function (result) {
            var site_access = [];
            _.each(result[0], function (row) {
              var sites = row.site_access.split(',');
              _.each(sites, function (site_id) {
                site_access.push(site_id);
              });
              row.site_access = site_access;
              site_access = [];
              return row;
            });
          });
}


function getModules(row) {
 return queryAndWait(queryModules, [row.priv_id])
         .then(function (result) {
          var payload = [];
          var module_access = [];
          _.each(result, function (module) {
            var modulePriv = {
              priv_name: module.priv_name,
              priv_num: module.priv_num,
              enabled: module.enabled
            };

            module_access.push(modulePriv);
          });              
          row.module_access = module_access;

          payload.push(row);
          return payload;
        });
}

getRows(params)
  .then(getModules)
  .then(function(payload) {
    // Do something with your payload
  })

Я сделал следующее:

  1. Разделяйте каждую логику в своей функции (почему?, потому что вы можете повторно использовать логику в другом промисе, экспортировать методы в другие библиотеки и т. д.)
  2. Я возвращаю обещание в каждой функции. Обещание может быть вложенным и выполняться по порядку.
  3. Каждое внутреннее обещание разрешает значение. getRows -> разрешать строки, getModules -> разрешать полезную нагрузку

Вы также можете управлять ошибками, используя метод catch промисов, например:

getRows(params)
  .catch(function(err) {
    // Something went wrong with getRows
    // If i can't recovery must return a reject.
  })
  .then(getModules)
  .catch(function(err) {
    //Something went wrong with getModules
    // If i can't recovery must return a reject.
  })
  .then(function(payload) {
    // Do something with your payload
  })
person Jesús Quintana    schedule 23.09.2015