角

Question

我有一个服务，它公开了一个函数，该函数接收一个解析的CSV（使用Papapass），并promise反映解析状态：
如果文件缺少强制字段，promise将被拒绝
否则，它将每行解析为一个项，并自动填充缺少字段（自动填充过程是异步的）。
当所有项都被填充时，函数用项数组解析promise

我要测试的函数是onCsvParse：

angular.module('csvParser', [])
  .factory('csvParser', ['$http',
    function($http) {
      var service = {
        onCsvParse: function(results, creatingBulkItems) {
          var errors = this.getCsvErrors(results);
          if (errors.length > 0) {
            //reject
            creatingBulkItems.reject(errors);
          } else {

            var items = this.parseCsv(results);
            var autoPopulateItems = [],
              populatedItems = [];
            for (var i = 0; i < populatedItems.length; i++) {
              var item = items[i];
              if (item.name === "" /*or some any field is missing */ ) {
                // auto populate item
                autoPopulateItems.push(this.autoPopulateItem(item));
              } else {
                var populatedItem = $q.when(item);
                populatedItems.push(populatedItem);
              }
            }
            populatedItems =autoPopulateItems.concat(populatedItems);
            var populatingAllItems = $q.all(populatedItems);
            populatingAllItems.then(function(items) {
              creatingBulkItems.resolve(items);
            }, function(err) {
              creatingBulkItems.resolve(err);
            });
          }
        },
        autoPopulateItem: function(newItem) {
          var populatingItem = $q.defer();
          var item = angular.copy(newItem);
          $http.post('api/getItemData', { /*.....*/ })
            .success(function(response) {
              //----Populate item fields
              item.name = response.name;
              //....
              //resolve the promise
              populatingItem.resolve(item)

            }).error(err) {
              // resolving on error for $q.all indication
              populatingItem.resolve(item)
            };
          return populatingItem.promise;

        }
      }
      return service;
    }
  ])

我对该方法的测试如下（简化）：

describe('bulk items upload test', function() {
  //upload csv & test scenarios...
  var $rootScope, $q, csvResults = {};
  var $httpBackend, requestHandler;
  beforeEach(module('csvParser'));

  beforeEach(inject(function(_$rootScope_, _$q_) {
    $rootScope = _$rootScope_;
    $q = _$q_;
  }));
  beforeEach(inject(function($injector) {
    // Set up the mock http service responses
    $httpBackend = $injector.get('$httpBackend');
    // backend definition common for all tests
    requestHandler = $httpBackend.when('POST', 'api/getItemData')
      .respond({
        name: "name",
        description: "description",
        imageUrl: "www.google.com"

      });


    //   afterEach(function(){ $rootScope.$apply();});

  }));
  it('Should parse csv string', function(done) {
    var csvString = "Name,Description of the page";//...

    Papa.parse(csvString, {
      complete: function(results) {
        csvResults = results;
        done();
      }
    });

  });
  it('Should fail', function(done) {
    var creatingBulkItems = $q.defer();
    console.log("here..");
    csvParser.onCsvParse(csvResults, creatingBulkItems);
    creatingBulkItems.promise.then(function() {
      console.log("1here..");
      //promise is never resolved
      expect(1).toEqual(1);
      done();
    }, function() {
      //promise is never rejeceted
      console.log("2here..");
      expect(1).toEqual(1);
      done();
    });
    $rootScope.$apply();

  });

});

这样我得到了一个错误：error:Timeout-Async回调没有在jasmine指定的超时内调用。默认超时时间间隔。

虽然我调用了$rootScope，但promise没有得到解决$apply（）并且我也没有调用真正的异步调用（只调用mock，除了$q.all）。我怎样才能让它工作？

Answer 1

读完这篇文章后：https://gist.github.com/domenic/3889970 我发现了我的问题
关键的一点是使用promise扁平化promise链。然后返回值。

这个[promise.then]函数应该返回一个新的promise，当给定的满足处理程序或错误处理程序回调结束时，这个promise就会实现。这允许将promise操作链接在一起。从回调处理程序返回的值是返回的promise的实现值。如果回调抛出一个错误，返回的promise将被移动到失败状态。

不是在内部promise成功/失败回调中解决外部promise，而是在内部promise.then回调中解决外部promise

所以我的解决方案是这样的：

onCsvParse: function(results) {
      var errors = this.getCsvErrors(results);
      if (errors.length > 0) {
         var deferred = $q.defer();
        //reject
        return deferred.reject(errors);
      } else {

        var items = this.parseCsv(results);
        var autoPopulateItems = [],
          populatedItems = [];
        for (var i = 0; i < populatedItems.length; i++) {
          var item = items[i];
          if (item.name === "" /*or some any field is missing */ ) {
            // auto populate item
            autoPopulateItems.push(this.autoPopulateItem(item));
          } else {
            var populatedItem = $q.when(item);
            populatedItems.push(populatedItem);
          }
        }
        populatedItems = autoPopulateItems.concat(populatedItems);
        var populatingAllItems = $q.all(populatedItems);
        return populatingAllItems.then(function(items) {
            return items;
        }, function(err) {
          return err;
        });
      }
    },

测试代码：

it('Should not fail :)', function(done) {
csvParser.onCsvParse(csvResults).then(function(items) {
  //promise is resolved
  expect(items).not.toBeNull();
  done();
}, function() {
  //promise is rejeceted
  //expect(1).toEqual(1);
  done();
});
$rootScope.$apply();});

Answer 2

无效的语法。您需要传递一个函数到错误回调。

        }).error(function(err) {
          // resolving on error for $q.all indication
          populatingItem.resolve(item)
        });
      return populatingItem.promise;

另外你jasime测试需要一些更多的初始化：http://plnkr.co/edit/wjykvpwtRA0kBBh3LcX3?p=preview