zetta/test/test_metadata_api.js

var assert = require('assert');
var request = require('supertest');
var zetta = require('../');
var rels = require('zetta-rels');
var Scout = require('./fixture/example_scout');
var Driver = require('./fixture/example_driver');
var Registry = require('./fixture/mem_registry');
var PeerRegistry = require('./fixture/mem_peer_registry');

function getHttpServer(app) {
  return app.httpServer.server;
}

function getBody(fn) {
  return function(res) {
    try {
      if(res.text) {
        var body = JSON.parse(res.text);
      } else {
        var body = '';
      }
    } catch(err) {
      throw new Error('Failed to parse json body');
    }

    fn(res, body);
  }
}

describe('Metadata API', function() {
  var reg = null;
  var peerRegistry = null;
  var app = null;
  var url = null;
  var device = null;

  beforeEach(function(done) {
    reg = new Registry();
    peerRegistry = new PeerRegistry();

    app = zetta({ registry: reg, peerRegistry: peerRegistry })
      .silent()
      .use(Driver)
      .name('local')
      ._run(function() {
        device = app.runtime._jsDevices[Object.keys(app.runtime._jsDevices)[0]];
        url = '/servers/' + app._name + '/devices/' + device.id;
        done();
      });
  });

  it('should contain a metadata class', function(done) {
      request(getHttpServer(app))
        .get('/servers/local/meta')
        .expect(getBody(function(res, body){
          assert.deepEqual(body.class, ['metadata']);
        }))
        .end(done);
  });

  it('should contain a self link', function(done) {
      request(getHttpServer(app))
        .get('/servers/local/meta')
        .expect(getBody(function(res, body){
          assert.equal(body.links[0].rel[0], 'self');
        }))
        .end(done);
  });

  it('should contain a server link', function(done) {
      request(getHttpServer(app))
        .get('/servers/local/meta')
        .expect(getBody(function(res, body){
          assert.equal(body.links[1].rel[0], rels.server);
        }))
        .end(done);
  });

  it('should contain a monitor link', function(done) {
      request(getHttpServer(app))
        .get('/servers/local/meta')
        .expect(getBody(function(res, body){
          assert.equal(body.links[2].rel[0], 'monitor');
          assert.notEqual(body.links[2].href.indexOf('topic=meta'), -1);
        }))
        .end(done);
  });

  describe('Type Sub-entity', function() {
    it('should contain a type class', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta')
          .expect(getBody(function(res, body){
            assert.deepEqual(body.entities[0].class, ['type']);
          }))
          .end(done);
    });

    it('should contain properties', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta')
          .expect(getBody(function(res, body){
            assert(Object.keys(body.entities[0].properties.properties).length > 0);
          }))
          .end(done);
    });

    it('should contain streams', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta')
          .expect(getBody(function(res, body){
            assert(body.entities[0].properties.streams.length > 0);
          }))
          .end(done);
    });

    it('should contain transitions', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta')
          .expect(getBody(function(res, body){
            assert(body.entities[0].properties.transitions.length > 0);
          }))
          .end(done);
    });

    it('should contain a self link', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta')
          .expect(getBody(function(res, body){
            assert.equal(body.entities[0].links[0].rel[0], 'self');
          }))
          .end(done);
    });
  });

  describe('Type Sub-resource', function() {
    it('should contain a type class', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta/testdriver')
          .expect(getBody(function(res, body){
            assert.deepEqual(body.class, ['type']);
          }))
          .end(done);
    });

    it('should contain properties', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta/testdriver')
          .expect(getBody(function(res, body){
            assert(Object.keys(body.properties.properties).length > 0);
          }))
          .end(done);
    });

    it('should contain streams', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta/testdriver')
          .expect(getBody(function(res, body){
            assert(body.properties.streams.length > 0);
          }))
          .end(done);
    });

    it('should contain transitions', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta/testdriver')
          .expect(getBody(function(res, body){
            assert(body.properties.transitions.length > 0);
          }))
          .end(done);
    });

    it('should contain a self link', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta/testdriver')
          .expect(getBody(function(res, body){
            assert.equal(body.links[0].rel[0], 'self');
          }))
          .end(done);
    });

    it('should contain a collection link', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta/testdriver')
          .expect(getBody(function(res, body){
            assert.equal(body.links[1].rel[0], 'collection');
            assert.equal(body.links[1].rel[1], rels.metadata);
          }))
          .end(done);
    });

    it('should contain an instances link', function(done) {
        request(getHttpServer(app))
          .get('/servers/local/meta/testdriver')
          .expect(getBody(function(res, body){
            assert.equal(body.links[2].rel[0], rels.instances);
            assert.equal(body.links[2].rel[1], 'describes');
          }))
          .end(done);
    });
  });
});