added new tests

tests/icinga.test.ts

@@ -391,4 +391,51 @@ describe('icinga', () => {
  expect(calls[0][0]).toBe('bar');
  });
  });
+
+
+ describe('delete services by filter', () => {
+ it('delete service filtered', async () => {
+ icinga.deleteService = jest.fn();
+ IcingaApi.getServiceFiltered = jest.fn()
+ .mockImplementation((host, cb) => cb(null, [
+ {attrs: {name: "foo", host_name: "foo"}},
+ {attrs: {name: "bar", host_name: "bar"}},
+ ]));
+
+ await expect(icinga.deleteServicesByFilter('vars.bar==true')).resolves.toEqual(true); 
+ expect(icinga.deleteService.mock.calls.length).toBe(2);
+ });
+
+ it('get services filtered failed', async () => {
+ IcingaApi.deleteService = jest.fn();
+ IcingaApi.getServiceFiltered = jest.fn()
+ .mockImplementation((host, cb) => cb({Statuscode: 500}, null));
+
+ await expect(icinga.deleteServicesByFilter('vars.bar==true')).rejects.toEqual({Statuscode: 500}); 
+ expect(IcingaApi.deleteService.mock.calls.length).toBe(0);
+ });
+ });
+
+ describe('delete hosts by filter', () => {
+ it('delete host filtered', async () => {
+ icinga.deleteHost = jest.fn();
+ IcingaApi.getHostFiltered = jest.fn()
+ .mockImplementation((host, cb) => cb(null, [
+ {attrs: {name: "foo"}},
+ {attrs: {name: "bar"}},
+ ]));
+
+ await expect(icinga.deleteHostsByFilter('vars.bar==true')).resolves.toEqual(true); 
+ expect(icinga.deleteHost.mock.calls.length).toBe(2);
+ });
+
+ it('get hosts filtered failed', async () => {
+ IcingaApi.deleteHost = jest.fn();
+ IcingaApi.getHostFiltered = jest.fn()
+ .mockImplementation((host, cb) => cb({Statuscode: 500}, null));
+
+ await expect(icinga.deleteHostsByFilter('vars.bar==true')).rejects.toEqual({Statuscode: 500}); 
+ expect(IcingaApi.deleteHost.mock.calls.length).toBe(0);
+ });
+ });
 });

tests/kube/ingress.test.ts

@@ -114,6 +114,41 @@ describe('kubernetes ingresses', () => {
  await bindings.data(resource);
  expect(Icinga.applyHost.mock.calls.length).toBe(1); 
  });
+
+ it('modify ingress object delete and create host', async () => {
+ let instance = new Ingress(Logger, Node, Icinga, {
+ hostName: null
+ });
+
+ var resource = { 
+ type: 'MODIFIED', 
+ object: fixture
+ };
+
+ Icinga.applyHost = jest.fn();
+ Icinga.deleteServicesByFilter = jest.fn();
+ Icinga.deleteHost = function(name) {
+ expect(name).toEqual('ingress-foobar-foo');
+ return new Promise((resolve,reject) => {
+ resolve(true);
+ });
+ };
+
+ var bindings = {};
+ var json = {
+ on: async function(name, callback) {
+ bindings[name] = callback;
+ }
+ };
+
+ await instance.kubeListener(() => {
+ return json;
+ });
+
+ await bindings.data(resource);
+ expect(Icinga.applyHost.mock.calls.length).toBe(1); 
+ expect(Icinga.deleteServicesByFilter.mock.calls.length).toBe(0); 
+ });
 
  it('delete ingress object delete', async () => {
  let instance = new Ingress(Logger, Node, Icinga);
@@ -321,6 +356,33 @@ describe('kubernetes ingresses', () => {
  expect(calls[1][2]['vars.http_ssl']).toBe(true);
  });
 
+ it('attach services to kube workers if attachToNodes is enabled', async () => {
+ let instance = new Ingress(Logger, Node, Icinga, {
+ attachToNodes: true
+ });
+
+ Node.getWorkerNodes = function() {
+ return ['foo', 'bar'];
+ };
+
+ Icinga.applyService = jest.fn();
+ Icinga.applyServiceGroup = jest.fn();
+ Icinga.applyHost = jest.fn();
+
+ await instance.prepareObject(fixture); 
+ const calls = Icinga.applyService.mock.calls;
+ expect(Icinga.applyHost.mock.instances.length).toBe(0);
+ expect(Icinga.applyService.mock.instances.length).toBe(4);
+
+ expect(calls[0][0]).toBe('foo');
+ expect(calls[1][0]).toBe('bar');
+ expect(calls[2][0]).toBe('foo');
+ expect(calls[3][0]).toBe('bar');
+ expect(calls[0][1]).toBe('foobar.example.org-http--');
+ expect(calls[1][1]).toBe('foobar.example.org-http--');
+ expect(calls[2][1]).toBe('barfoo.example.org-http--foo');
+ expect(calls[3][1]).toBe('barfoo.example.org-http--foo');
+ }); 
  });
 
  describe('kubernetes annotations', () => {

tests/kube/volume.test.ts

@@ -109,7 +109,42 @@ describe('kubernetes volumes', () => {
  await bindings.data(resource);
  expect(Icinga.applyHost.mock.calls.length).toBe(1); 
  });
+
+ it('modify ingress object delete and create host', async () => {
+ let instance = new Volume(Logger, Node, Icinga, {
+ hostName: null
+ });
+
+ var resource = { 
+ type: 'MODIFIED', 
+ object: fixture
+ };
+
+ Icinga.applyHost = jest.fn();
+ Icinga.deleteServicesByFilter = jest.fn();
+ Icinga.deleteHost = function(name) {
+ expect(name).toEqual('volume-generic-nimble-fad5684e-22fb-11e9-94e3-0050568fe3c2');
+ return new Promise((resolve,reject) => {
+ resolve(true);
+ });
+ };
+
+ var bindings = {};
+ var json = {
+ on: async function(name, callback) {
+ bindings[name] = callback;
+ }
+ };
 
+ await instance.kubeListener(() => {
+ return json;
+ });
+
+ await bindings.data(resource);
+ expect(Icinga.applyHost.mock.calls.length).toBe(1); 
+ expect(Icinga.deleteServicesByFilter.mock.calls.length).toBe(0); 
+ });
+
  it('delete volume object delete', async () => {
  let instance = new Volume(Logger, Node, Icinga);
 
@@ -233,7 +268,7 @@ describe('kubernetes volumes', () => {
  });
  });
 
- describe('add all volume object http path rules as service objects', () => {
+ describe('add all volume objects as service objects', () => {
  it('create service object', async () => {
  let instance = new Volume(Logger, Node, Icinga);
 
@@ -288,6 +323,30 @@ describe('kubernetes volumes', () => {
  expect(Icinga.applyService.mock.instances.length).toBe(1);
  expect(calls[0][3]).toEqual(['foo', 'bar']);
  });
+
+ it('attach services to kube workers if attachToNodes is enabled', async () => {
+ let instance = new Volume(Logger, Node, Icinga, {
+ attachToNodes: true
+ });
+
+ Node.getWorkerNodes = function() {
+ return ['foo', 'bar'];
+ };
+
+ Icinga.applyService = jest.fn();
+ Icinga.applyServiceGroup = jest.fn();
+ Icinga.applyHost = jest.fn();
+
+ await instance.prepareObject(fixture); 
+ const calls = Icinga.applyService.mock.calls;
+ expect(Icinga.applyHost.mock.instances.length).toBe(0);
+ expect(Icinga.applyService.mock.instances.length).toBe(2);
+
+ expect(calls[0][0]).toBe('foo');
+ expect(calls[1][0]).toBe('bar');
+ expect(calls[0][1]).toBe('generic-nimble-fad5684e-22fb-11e9-94e3-0050568fe3c2');
+ expect(calls[1][1]).toBe('generic-nimble-fad5684e-22fb-11e9-94e3-0050568fe3c2');
+ }); 
  });
 
  describe('kubernetes annotations', () => {