Fixes based quantum game execution

Author: amidukr

README.md

@@ -130,7 +130,7 @@ const endpoint2 = vnfHub.openEndpoint("endpoint2-name")
 ```js
 // Creating in browser hub of endpoints
 const webSocketFactory = new Vnf.WebSocketFactory("wss://<server-host-name>/webbroker/vnf-ws")
-const vnfHub = new Vnf.MarshallerHub(new Vnf.ReliableRtcHub((webSocketFactory)));
+const vnfHub = new Vnf.MarshallerHub(new Vnf.ReliableRtcHub(new Vnf.WebSocketHub(webSocketFactory)));
 
 // Creating endpoint in hub
 const endpoint1 = vnfHub.openEndpoint("endpoint1-name")
@@ -182,7 +182,9 @@ const registryClient = new Vnf.WebSocketRegistryClient(new Vnf.WebSocketRpc(eva,
 
 ```
 
-### WebSocketRegistry and WebScoketHub
+# VNF Channel and Registry examples
+
+## WebSocketRegistry and WebScoketHub
 ```js
 const webSocketFactory = new Vnf.WebSocketFactory("wss://<server-host-name>/webbroker/vnf-ws")
 const vnfHub = new Vnf.WebSocketHub(webSocketFactory);
@@ -194,4 +196,22 @@ const registryClient = new Vnf.WebSocketRegistryClient(endpoint1.getWebSocketRpc
 // Rest part the same as InBrowserRegistry
 ...
 
+```
+
+### WebSocketRegistry and RtcHub
+```js
+// Creating in browser hub of endpoints
+const webSocketFactory = new Vnf.WebSocketFactory("wss://<server-host-name>/webbroker/vnf-ws")
+const webSocketHub = new Vnf.WebSocketHub(webSocketFactory)
+const vnfHub = new Vnf.MarshallerHub(new Vnf.ReliableRtcHub(webSocketHub));
+
+// Creating endpoint in hub
+const endpoint1 = vnfHub.openEndpoint("endpoint1-name")
+const webSocketRpc = webSocketHub.openEndpoint("endpoint1-name").getWebSocketRpc()
+
+const registryClient = new Vnf.WebSocketRegistryClient(webSocketRpc)
+
+// Rest part the same as InBrowserRegistry
+...
+
 ```

TODO.md

@@ -2,7 +2,8 @@
 
 
 # Todo List
-1. Apply library for quantum game
+1. Fix, library mode shouldn't generate VNF.VNF.InBrowser
+2. Timeouts.iceSendTimeout - doesn't works by default
 
 
 # Future tasks/On-Hold
@@ -45,4 +46,5 @@
         1. rename big message to name according to specification document (Marshaller Hub) (Done)
         1. Rename store to registry
             1. Update specification 
-            1. update code (store persistent thing)
+            1. update code (store persistent thing)
+1. Registry: most of the command can do with retry

dist/amid-ukr-vnf.js

@@ -68,7 +68,7 @@ export function WebSocketRegistryClient(webSocketRpc) {
     this.createOrUpdate = function(key, value) {
         validateKey(key);
 
-        return webSocketRpc.invoke("CREATE-OR-UPDATE-ENTRY", key.collection + "\n" + key.name + "\n" + VnfSerializer.serializeValue(value))
+        return webSocketRpc.invoke("CREATE-OR-UPDATE-ENTRY", key.collection + "\n" + key.name + "\n" + VnfSerializer.serializeValue(value),{retryResend: true})
         .then(function(evt) {
             if(evt.data == Global.OK) {
                 putToCache(key, value);
@@ -81,7 +81,7 @@ export function WebSocketRegistryClient(webSocketRpc) {
     this.getEntry = function(key, value) {
         validateKey(key);
 
-        return webSocketRpc.invoke("GET-ENTRY", key.collection + "\n" + key.name)
+        return webSocketRpc.invoke("GET-ENTRY", key.collection + "\n" + key.name, {retryResend: true})
         .then(function(evt) {
             return VnfSerializer.deserializeValue(evt.data);
         });
@@ -90,7 +90,7 @@ export function WebSocketRegistryClient(webSocketRpc) {
     this.getEntriesWithBody = function(collection) {
         if(collection.indexOf("\n") != -1) throw new Error("EOL character isn't supported in collection name");
 
-        return webSocketRpc.invoke("GET-ENTRIES-WITH-BODY", collection)
+        return webSocketRpc.invoke("GET-ENTRIES-WITH-BODY", collection, {retryResend: true})
         .then(function(evt){
             var result = {};
 
@@ -121,7 +121,7 @@ export function WebSocketRegistryClient(webSocketRpc) {
     this.deleteEntry = function(key) {
         validateKey(key);
 
-        return webSocketRpc.invoke("DELETE-ENTRY", key.collection + "\n" + key.name)
+        return webSocketRpc.invoke("DELETE-ENTRY", key.collection + "\n" + key.name, {retryResend: true})
         .then(function(evt) {
             if(evt.data == Global.OK) {
                 deleteFromCache(key);