Changes to orchestration data is reflected in response

src/EngineDiscovery.js

@@ -31,6 +31,11 @@ async function discover() {
         const engineEntry = new EngineEntry(item, this.updateInterval);
         logger.info(`Engine discovered at address: ${item.statusIp}:${engineEntry.properties.engine.port} with key: ${item.key}`);
         this.engineMap.add(item.key, engineEntry);
+      } else {
+        const engineEntry = this.engineMap.get(item.key);
+        if (engineEntry) {
+          engineEntry.updateOrchestrationProperties(item);
+        }
       }
     });
 

src/EngineEntry.js

@@ -85,6 +85,16 @@ class EngineEntry {
     }
   }
 
+  updateOrchestrationProperties(properties) {
+    const keys = Object.keys(properties);
+    for (let i = 0; i < keys.length; i += 1) {
+      const key = keys[i];
+      if (key !== 'key' && key !== 'engine' && key !== 'statusIp') {
+        this.properties[key] = properties[key];
+      }
+    }
+  }
+
   /**
    * Starts periodical status checking.
    */

src/EngineMap.js

@@ -76,6 +76,15 @@ class EngineMap {
   has(key) {
     return Object.prototype.hasOwnProperty.call(this.entries, key);
   }
+
+  /**
+   * Returns the engine with the supplied key
+   * @param {string} key - the unique engine identifier.
+   * @returns the engine entry or undefined if missing
+   */
+  get(key) {
+    return this.entries[key];
+  }
 }
 
 module.exports = EngineMap;

test/unit/EngineEntry.spec.js

@@ -155,6 +155,25 @@ describe('EngineEntry', () => {
     });
   });
 
+  describe('#updateOrchestrationProperties()', () => {
+    beforeEach(() => {
+      healthFetcher = new EngineStatusFetcher({ get: () => { } });
+      fetchStub = sinon.stub(healthFetcher, 'fetch');
+      fetchStub.withArgs('10.10.10.10', 9098, '/healthcheck').returns(Promise.resolve(healthOk));
+      fetchStub.withArgs('10.10.10.10', 9999, '/metrics').returns(Promise.resolve(metrics));
+    });
+
+    it('should properties to be updated', () => {
+      entry = new EngineEntry({ engine: { labels: { 'qix-engine-api-port': '9998', 'qix-engine-metrics-port': '9999' } }, statusIp: '10.10.10.10' }, 10, healthFetcher);
+      expect(entry.properties).to.deep.equal({ engine: { port: 9998, metricsPort: 9999, labels: { 'qix-engine-api-port': '9998', 'qix-engine-metrics-port': '9999' } }, statusIp: '10.10.10.10' });
+
+      const newProps = { kubernetes: { newInfo: 'yes' } };
+      entry.updateOrchestrationProperties(newProps);
+      expect(entry.properties).to.deep.equal({ engine: { port: 9998, metricsPort: 9999, labels: { 'qix-engine-api-port': '9998', 'qix-engine-metrics-port': '9999' } }, statusIp: '10.10.10.10', kubernetes: { newInfo: 'yes' } });
+    });
+  });
+
+
   afterEach(() => {
     fetchStub.reset();
   });

test/unit/EngineMap.spec.js

@@ -62,6 +62,13 @@ describe('EngineMap', () => {
     expect(engineMap.has('dummy')).to.equal(false);
   });
 
+  it('should return', () => {
+    const entry = getEntry();
+    engineMap.add('foo', entry);
+    expect(engineMap.get('foo')).to.equal(entry);
+    expect(engineMap.get('dummy')).to.equal(undefined);
+  });
+
   it('should return all entries', () => {
     const entry1 = getEntry();
     const entry2 = getEntry();