test/integration/services/namespace/service.js

var test = require('prova');
var _ = require('lodash');
var proxyquire = require('proxyquireify')(require);
var mockLRUCache = require('./mocks/lru-cache');

// 8885 is the expected wspr port to be running for the tests
// @noCallThru ensures this completely overrdies the original config
// instead of inheriting the properties that are not defined here from
// the original dependency
var veyronConfigForTest = {
  'authenticate': false,
  'wspr': 'http://localhost:8885',
  '@noCallThru': true
};

// Require namespaceService but using test specific mocks and configs
var namespaceService =
  proxyquire('../../../../src/services/namespace/service.js', {
    '../../veyron-config': veyronConfigForTest,
    'lru-cache': function() {
      return mockLRUCache;
    }
  });

test('getChildren of default namespace root', function(t) {
  t.plan(9+9);

  namespaceService.getChildren().
  then(function assertResult(result) {
    // Wait until we receive the 4 top level items,
    // cottage, house
    var numReturnedChildren;
    result(function(children) {
      numReturnedChildren = children.length;
      if (numReturnedChildren === 2) {
        children = _.sortBy(children, 'mountedName');
        assertCottage(children[0]);
        assertHouse(children[1]);
      }
    });
  }).catch();

  // 9 assertions
  function assertCottage(item) {
    t.equal(item.mountedName, 'cottage');
    t.equal(item.objectName, 'cottage');
    t.equal(item.isServer, true);
    t.equal(item.isGlobbable, true);

    t.ok(item.serverInfo.signature);

    assertMounttableServiceTypeInfo(t, item.serverInfo.typeInfo);
  }

  // 9 assertions
  function assertHouse(item) {
    t.equal(item.mountedName, 'house');
    t.equal(item.objectName, 'house');
    t.equal(item.isServer, true);
    t.equal(item.isGlobbable, true);

    t.ok(item.serverInfo.signature);

    assertMounttableServiceTypeInfo(t, item.serverInfo.typeInfo);
  }
});

test('getChildren of cottage/lawn', function(t) {
  t.plan(9+5);

  namespaceService.getChildren('cottage/lawn').
  then(function assertResult(result) {
    // Wait until we receive the 3 items,
    // back, front and master-sprinkler come back
    var numReturnedChildren;
    result(function(children) {
      numReturnedChildren = children.length;
      if (numReturnedChildren === 3) {
        children = _.sortBy(children, 'mountedName');
        assertBack(children[0]);
        assertSprinkler(children[2]);
      }
    });
  }).catch(t.end);

  // 9 assertions
  function assertSprinkler(item) {
    t.equal(item.mountedName, 'master-sprinkler');
    t.equal(item.objectName, 'cottage/lawn/master-sprinkler');
    t.equal(item.isServer, true);
    t.equal(item.isGlobbable, false);

    assertUnknownServiceTypeInfo(t, item.serverInfo.typeInfo);

    t.ok(item.serverInfo.signature);
  }

  // 5 assertions
  function assertBack(item) {
    t.equal(item.mountedName, 'back');
    t.equal(item.objectName, 'cottage/lawn/back');
    t.equal(item.isServer, false);
    t.equal(item.isGlobbable, true);
    t.equal(item.serverInfo, null);
  }
});

test('getChildren of rooted /localhost:8881/house/kitchen', function(t) {
  t.plan(9+9);

  // 8881 is the expected root mounttable port to be running for the tests
  namespaceService.getChildren('/localhost:8881/house/kitchen').
  then(function assertResult(result) {
  // Wait until we receive the 2 items, lights and smoke-detector
    var numReturnedChildren;
    result(function(children) {
      numReturnedChildren = children.length;
    if (numReturnedChildren === 2) {
      children = _.sortBy(children, 'mountedName');
      assertLightSwitch(children[0]);
      assertSmokeDetector(children[1]);
        t.end();
      }
    });
  }).catch(t.end);

  // 9 assertions
  function assertLightSwitch(item) {
    t.equal(item.mountedName, 'lights');
    t.equal(item.objectName, '/localhost:8881/house/kitchen/lights');
    t.equal(item.isServer, true);
    t.equal(item.isGlobbable, false);

    assertUnknownServiceTypeInfo(t, item.serverInfo.typeInfo);

    t.ok(item.serverInfo.signature);
  }

  // 9 assertions
  function assertSmokeDetector(item) {
    t.equal(item.mountedName, 'smoke-detector');
    t.equal(item.objectName, '/localhost:8881/house/kitchen/smoke-detector');
    t.equal(item.isServer, true);
    t.equal(item.isGlobbable, false);

    assertUnknownServiceTypeInfo(t, item.serverInfo.typeInfo);

    t.ok(item.serverInfo.signature);
  }
});

test('getChildren of non-existing mounttable', function(t) {
  t.plan(1);

  // Should get an error
  namespaceService.getChildren('/DoesNotExist:666/What/Ever').
  then(function shouldNotGetResult(result){
    t.fail('Should have returned an error instead of result');
  }).
  catch(function assertThereIsError(err) {
    t.ok(err);
  });
});

test('glob uses caching', function(t) {
  t.plan(3);

  mockLRUCache.reset();

  namespaceService.glob('house', '*').
  then(function assertNoCacheHit() {
    // First time, no cache hit so a get call followed by a set call
    t.notOk(mockLRUCache.lastCallWasCacheHit);

    // Call second time, there should have been a cache hit
    return namespaceService.glob('house', '*');
  }).then( function assertCacheHit() {
    t.ok(mockLRUCache.lastCallWasCacheHit);

    // call glob with same name, different query, there should be no cache hit
    return namespaceService.glob('house', 'foo*');
  }).then(function assertNoCacheHit() {
    t.notOk(mockLRUCache.lastCallWasCacheHit);
  }).catch(t.end);
});

test('getSignature uses caching', function(t) {
  t.plan(3);

  mockLRUCache.reset();

  namespaceService.getSignature('house/alarm').then(function() {
    // First time, no cache hit
    t.notOk(mockLRUCache.lastCallWasCacheHit);
    // Call a second time
    return namespaceService.getSignature('house/alarm');
  }).then(function() {
    // Second time, must be a cache hit
    t.ok(mockLRUCache.lastCallWasCacheHit);
    // Call a different name
    return namespaceService.getSignature('house/kitchen/smoke-detector');
  }).then(function() {
    // Different name, no cache hit
    t.notOk(mockLRUCache.lastCallWasCacheHit);
  });
});

//TODO(aghassemi)
//Tests for:
// Recursive glob
// Glob with some keyword
// Ensuring array is updated when nodes get mounted and unmounted (when we use
// watchGlob)
// makeRPC TODO(alexfandrianto)

/*
 * Test helpers
 */

/*
 * Asserts that a ServiceTypeInfo is of predefined type of Unknown Service.
 * 4 assertions
 */
function assertUnknownServiceTypeInfo(t, typeInfo) {
  t.equal(typeInfo.key, 'veyron-unknown');
  t.equal(typeInfo.typeName, 'Service');
  t.equal(typeInfo.description, null);
  t.ok(typeInfo.icon);
}

/*
 * Asserts that a ServiceTypeInfo is of predefined type of mounttable.
 * 4 assertions
 */
function assertMounttableServiceTypeInfo(t, typeInfo) {
  t.equal(typeInfo.key, 'veyron-mounttable');
  t.equal(typeInfo.typeName, 'Mount Table');
  t.ok(typeInfo.description);
  t.ok(typeInfo.icon);
}