Update from main repo

.gitignore

@@ -1,5 +1,6 @@
 # intellij, pycharm, webstorm...
 /.idea/*
-
+.vscode
 node_modules
 .*.swp
+coverage

EmberClient/EmberClient.js

@@ -73,7 +73,7 @@ class EmberClient extends EventEmitter {
                 }
             }
             catch(e) {
-                winston.debug(e, root);
+                winston.error(e, root);
                 if (this._callback) {
                     this._callback(e);
                 }
@@ -88,7 +88,7 @@ class EmberClient extends EventEmitter {
         try {
             this._makeRequest();
         } catch(e) {
-            winston.debug(e);
+            winston.error(e);
             if (this._callback != null) {
                 this._callback(e);
             }
@@ -140,8 +140,8 @@ class EmberClient extends EventEmitter {
         if (n == null) {
             parent.addChild(node);
             n = node;
-        } else {
-            n.update(node);
+        } else if (n.update(node)) {
+            n.updateSubscribers();
         }
 
         const children = node.getChildren();
@@ -165,7 +165,9 @@ class EmberClient extends EventEmitter {
         let element = parent.getElementByPath(node.path);
         if (element !== null) {
             this.emit("value-change", node);
-            element.update(node);
+            if (element.update(node)) {
+                element.updateSubscribers();
+            }
         }
         else {
             const path = node.path.split(".");
@@ -344,17 +346,16 @@ class EmberClient extends EventEmitter {
                         if (nodeElements != null &&
                             ((qnode.isMatrix() && nodeElements.length === 1 && nodeElements[0].getPath() === requestedPath) ||
                              (!qnode.isMatrix() && nodeElements.every(el => isDirectSubPathOf(el.getPath(), requestedPath))))) {
-                            winston.debug("Received getDirectory response", node);
+                                winston.debug("Received getDirectory response", node);
                             this._finishRequest();
                             return resolve(node); // make sure the info is treated before going to next request.
                         }
                         else {
                             winston.debug(node);
-                            winston.debug(new Error(requestedPath));
+                            winston.error(new Error(requestedPath));
                         }
                     }
                 };
-                winston.debug("Sending getDirectory", qnode);
                 try {
                     this._client.sendBERNode(qnode.getDirectory(callback));
                 }
@@ -420,6 +421,9 @@ class EmberClient extends EventEmitter {
                     // We have this part already.
                     pos++;
                     if (pos >= pathArray.length) {
+                        if (callback) {
+                            node.getDirectory(callback);
+                        }
                         return node;
                     }
                     currentNode = node;                   
@@ -514,7 +518,7 @@ class EmberClient extends EventEmitter {
                         return; 
                     }
                     if (error) {
-                        winston.debug("Received getDirectory error", error);
+                        winston.error("Received getDirectory error", error);
                         this._clearTimeout(); // clear the timeout now. The resolve below may take a while.
                         this._finishRequest();
                         reject(error);
@@ -612,7 +616,7 @@ class EmberClient extends EventEmitter {
                             resolve(node);
                         }
                     };
-                        winston.debug('setValue sending ...', node.getPath(), value);
+                    winston.debug('setValue sending ...', node.getPath(), value);
                     this._client.sendBERNode(node.setValue(value));
                 }});
             }

EmberLib/QualifiedParameter.js

@@ -36,28 +36,6 @@ class QualifiedParameter extends QualifiedElement {
         return r;
     }
 
-    /**
-     * 
-     * @param {QualifiedParameter} other 
-     */
-    update(other) {
-        if ((other != null) && (other.contents != null)) {
-            if (this.contents == null) {
-                this.contents = other.contents;
-            }
-            else {
-                for (var key in other.contents) {
-                    if (key[0] === "_") {
-                        continue;
-                    }
-                    if (other.contents.hasOwnProperty(key)) {
-                        this.contents[key] = other.contents[key];
-                    }
-                }
-            }
-        }
-        return;
-    }
 
     /**
      * 

EmberLib/StreamCollection.js

@@ -0,0 +1,102 @@
+const BER = require("../ber");
+const StreamEntry = require("./StreamEntry");
+
+class StreamCollection {
+    /**
+     * 
+     */ 
+    constructor() {
+        /** @type {Map<number,StreamEntry>} */
+        this.elements = new Map();
+    }
+    /**
+     * 
+     * @param {StreamEntry} entry 
+     */
+    addEntry(entry) {
+        this.elements.set(entry.identifier, entry);
+    }
+     /**
+     * 
+     * @param {StreamEntry} entry 
+     */
+    removeEntry(entry) {
+        this.elements.delete(entry.identifier);
+    }
+    /**
+     * 
+     * @param {number} identifier
+     * @returns {StreamEntry}
+     */
+    getEntry(identifier) {
+        return this.elements.get(identifier);
+    }
+
+    /**
+     * @returns {StreamEntry}
+     */
+    [Symbol.iterator]() {
+        return this.elements.values();
+    }
+
+    /**
+     * @retuns {number}
+     */
+    size() {
+        return this.elements.size;
+    }
+
+    /**
+     * 
+     * @param {BER.Writer} ber 
+     */
+    encode(ber) {
+        ber.startSequence(StreamCollection.BERID);
+        for(let [, entry] of this.elements) {
+            ber.startSequence(BER.CONTEXT(0));
+            entry.encode(ber);
+            ber.endSequence();
+        }
+        ber.endSequence();
+    }
+
+    /**
+     * @returns {
+     * {identifier: number, value: string|number|boolean|Buffer}[]
+     * }
+     */
+    toJSON() {
+        const js = [];
+        for(let [, entry] of this.elements) {
+            js.push(entry.toJSON());
+        }
+        return js;
+    }
+
+    /**
+     * @returns {number}
+     */
+    static get BERID() {
+        return BER.APPLICATION(5);
+    }
+
+    /**
+     * 
+     * @param {BER.ExtendedReader} ber 
+     * @returns {StreamCollection}
+     */
+    static decode(ber) {
+        const streamCollection = new StreamCollection();
+        const seq = ber.getSequence(this.BERID);                
+        while (seq.remain > 0) {
+            const rootReader = seq.getSequence(BER.CONTEXT(0));
+            while (rootReader.remain > 0) {
+                const entry = StreamEntry.decode(rootReader);
+                streamCollection.addEntry(entry);
+            }
+        }
+        return streamCollection;
+    }
+}
+
+module.exports = StreamCollection;

EmberLib/StreamDescription.js

@@ -1,15 +1,17 @@
 "use strict";
-const Element = require("./Element");
 const BER = require('../ber.js');
 const StreamFormat = require("./StreamFormat");
 const Errors = require("../Errors");
 
-class StreamDescription extends Element{
+class StreamDescription {
     /**
      * 
+     * @param {number} offset 
+     * @param {StreamFormat} format 
      */
-    constructor() {
-        super();
+    constructor(offset, format) {
+        this.offset = offset;
+        this.format = format;
     }
 
     /**

EmberLib/StreamEntry.js

@@ -0,0 +1,70 @@
+const BER = require("../ber");
+const Errors = require("../Errors");
+
+class StreamEntry {
+    /**
+     * 
+     * @param {number} identifier 
+     * @param {string|number|boolean|Buffer} value 
+     */
+    constructor(identifier, value ) {
+        this.identifier = identifier;
+        this.value = value;
+    }
+
+    /**
+     * 
+     * @param {BER} ber 
+     */
+    encode(ber) {
+        ber.startSequence(StreamEntry.BERID);
+        if (this.identifier != null) {
+            ber.startSequence(BER.CONTEXT(0));
+            ber.writeInt(this.identifier);
+            ber.endSequence();
+        }
+        if (this.value != null) {
+            ber.startSequence(BER.CONTEXT(1));
+            ber.writeValue(this.value);
+            ber.endSequence();
+        }
+        ber.endSequence();
+    }
+
+    /**
+     * @returns {{
+     * identifier: number,
+     * value: string|number
+     * }}
+     */
+    toJSON()  {
+        return {
+            identifier: this.identifier,
+            value: this.value
+        }
+    }
+
+    static get BERID() {
+        return BER.APPLICATION(5);
+    }
+
+    static decode(ber) {
+        const entry = new StreamEntry();
+        const seq = ber.getSequence(this.BERID);
+        while(seq.remain > 0) {
+            const tag = seq.peek();
+            const data = seq.getSequence(tag);
+            if(tag == BER.CONTEXT(0)) {
+                entry.identifier = data.readInt();
+            } else if(tag == BER.CONTEXT(1)) {
+                entry.value = data.readValue();
+            }
+            else {
+                throw new Errors.UnimplementedEmberTypeError(tag);
+            }
+        }
+        return entry;
+    }
+}
+
+module.exports = StreamEntry;

EmberLib/TreeNode.js

@@ -16,8 +16,7 @@ class TreeNode extends ElementInterface {
 
     _isSubscribable(callback) {
         return (callback != null && 
-            ((this.isParameter() && this.isStream()) ||
-            this.isMatrix()));
+            (this.isParameter() || this.isMatrix()));
     }
 
     _subscribe(callback) {
@@ -236,7 +235,7 @@ class TreeNode extends ElementInterface {
      * @param {function} callback 
      */
     getDirectory(callback) {
-        if (this._isSubscribable(callback)) {
+        if (this._isSubscribable(callback) && !this.isStream()) {
             this._subscribe(callback);
         }
         return this.getCommand(new Command(COMMAND_GETDIRECTORY));
@@ -471,7 +470,7 @@ class TreeNode extends ElementInterface {
      * @param {function} callback 
      */
     subscribe(callback) {
-        if (this._isSubscribable(callback)) {
+        if (this._isSubscribable(callback) && this.isStream()) {
             this._subscribe(callback);
         }
         return this.getCommand(new Command(COMMAND_SUBSCRIBE));

EmberLib/index.js

@@ -32,6 +32,7 @@ const StringIntegerPair = require("./StringIntegerPair");
 const StringIntegerCollection = require("./StringIntegerCollection");
 const StreamFormat = require("./StreamFormat");
 const StreamDescription = require("./StreamDescription");
+const StreamCollection = require("./StreamCollection");
 const Template = require("./Template");
 const TemplateElement = require("./TemplateElement");
 const QualifiedTemplate = require("./QualifiedTemplate");
@@ -151,6 +152,7 @@ module.exports = {
     QualifiedTemplate,
     StreamFormat,
     StreamDescription,
+    StreamCollection,
     StringIntegerPair,
     StringIntegerCollection,
     Template,