Add retry in templates to wait realtime notifications

src/sdk-reference/cpp/1/realtime/subscribe/snippets/document-notifications-leave-scope.cpp

@@ -27,8 +27,6 @@ try {
     "yellow-taxi",
     "nina-vkote",
     "{ \"age\": 42 }");
-
-  sleep(1);
 } catch (kuzzleio::KuzzleException &e) {
   std::cerr << e.getMessage() << std::endl;
-}
+}

src/sdk-reference/cpp/1/realtime/subscribe/snippets/document-notifications-leave-scope.test.yml

@@ -3,5 +3,5 @@ description: Subscribe to documents leaving the scope
 hooks:
   before: curl -X POST kuzzle:7512/nyc-open-data/_create ; curl -X PUT kuzzle:7512/nyc-open-data/yellow-taxi/; curl -X DELETE kuzzle:7512/nyc-open-data/yellow-taxi/nina-vkote
   after:
-template: default
+template: realtime
 expected: Document moved out from the scope

src/sdk-reference/cpp/1/realtime/subscribe/snippets/document-notifications.cpp

@@ -18,4 +18,4 @@ try {
   kuzzle->document->create("nyc-open-data", "yellow-taxi", "nina-vkote", document);
 } catch (kuzzleio::KuzzleException &e) {
   std::cerr << e.getMessage() << std::endl;
-}
+}

src/sdk-reference/cpp/1/realtime/subscribe/snippets/document-notifications.test.yml

@@ -3,5 +3,5 @@ description: Simple subscribe to document notifications
 hooks:
   before: curl -X POST kuzzle:7512/nyc-open-data/_create ; curl -X PUT kuzzle:7512/nyc-open-data/yellow-taxi/ ; curl -X DELETE kuzzle:7512/nyc-open-data/yellow-taxi/nina-vkote
   after:
-template: default
+template: realtime
 expected: Document nina-vkote enter the scope

src/sdk-reference/cpp/1/realtime/subscribe/snippets/message-notifications.cpp

@@ -9,8 +9,6 @@ try {
 
   std::string message = "{ \"metAt\": \"Insane\", \"hello\": \"world\" }";
   kuzzle->realtime->publish("i-dont-exist", "in-database", message);
-
-  sleep(1);
 } catch (kuzzleio::KuzzleException &e) {
   std::cerr << e.getMessage() << std::endl;
-}
+}

src/sdk-reference/cpp/1/realtime/subscribe/snippets/message-notifications.test.yml

@@ -3,5 +3,5 @@ description: Subscribe to message notifications
 hooks:
   before:
   after:
-template: default
+template: realtime
 expected: Message notification received

src/sdk-reference/cpp/1/realtime/subscribe/snippets/user-notifications.cpp

@@ -31,4 +31,4 @@ try {
   fuzzle->realtime->subscribe("nyc-open-data", "yellow-taxi", filters, &listener);
 } catch (kuzzleio::KuzzleException &e) {
   std::cerr << e.getMessage() << std::endl;
-}
+}

src/sdk-reference/cpp/1/realtime/subscribe/snippets/user-notifications.test.yml

@@ -3,5 +3,5 @@ description: Subscribe to users joining or leaving the room
 hooks:
   before: curl -X POST kuzzle:7512/nyc-open-data/_create ; curl -X PUT kuzzle:7512/nyc-open-data/yellow-taxi/
   after:
-template: default
+template: realtime
 expected: Currently 2 users in the room

src/sdk-reference/go/1/realtime/subscribe/snippets/document-notifications-leave-scope.go

@@ -1,6 +1,3 @@
-// Avoid program exit before receiving notification
-exitPrgm := make(chan bool)
-
 // Subscribe to notifications for documents containing a 'name' property
 filters := json.RawMessage(`{ "range": { "age": { "lte": 20 } } }`)
 
@@ -10,8 +7,6 @@ go func() {
   notification := <-listener
 
   fmt.Printf("Document moved %s from the scope\n", notification.Scope)
-
-  exitPrgm <- true
 }()
 
 options := types.NewRoomOptions()
@@ -45,5 +40,3 @@ kuzzle.Document.Update(
 	"nina-vkote",
 	json.RawMessage(`{ "age": 42 }`),
 	nil)
-
-<-exitPrgm

src/sdk-reference/go/1/realtime/subscribe/snippets/document-notifications.go

@@ -1,6 +1,3 @@
-// Avoid program exit before receiving notification
-exitPrgm := make(chan bool)
-
 // Subscribe to notifications for documents containing a 'name' property
 filters := json.RawMessage(`{ "exists": "name" }`)
 
@@ -14,8 +11,6 @@ go func() {
   } else {
     fmt.Printf("Document %s leave the scope\n", notification.Result.Id)
   }
-
-  exitPrgm <- true
 }()
 
 _, err := kuzzle.Realtime.Subscribe(
@@ -36,5 +31,3 @@ kuzzle.Document.Create(
 	"nina-vkote",
 	document,
 	nil)
-
-<-exitPrgm

src/sdk-reference/go/1/realtime/subscribe/snippets/message-notifications.go

@@ -1,14 +1,9 @@
-// Avoid program exit before receiving notification
-exitPrgm := make(chan bool)
-
 // Start an async listener
 listener := make(chan types.KuzzleNotification)
 go func() {
   <-listener
 
   fmt.Printf("Message notification received")
-
-  exitPrgm <- true
 }()
 
 // Subscribe to a room
@@ -26,5 +21,3 @@ if err != nil {
 message := json.RawMessage(`{ "metAt": "Insane", "hello": "world" }`)
 // Publish a message to this room
 kuzzle.Realtime.Publish("i-dont-exist", "i-database", message, nil)
-
-<-exitPrgm

src/sdk-reference/go/1/realtime/subscribe/snippets/user-notifications.go

@@ -1,6 +1,3 @@
-// Avoid program exit before receiving notification
-exitPrgm := make(chan bool)
-
 // Subscribe to notifications for documents containing a 'name' property
 filters := json.RawMessage(`{ "exists": "name" }`)
 
@@ -14,8 +11,6 @@ go func() {
     // Volatile data: {"sdkVersion":"1.0.0","username":"nina vkote"}
     fmt.Printf("Currently %d users in the room\n", notification.Result.Count)
   }
-
-  exitPrgm <- true
 }()
 
 options := types.NewRoomOptions()
@@ -53,5 +48,3 @@ fuzzle.Realtime.Subscribe(
 	filters,
 	make(chan types.KuzzleNotification),
 	nil)
-
-<-exitPrgm

src/sdk-reference/java/1/realtime/subscribe/snippets/document-notifications-leave-scope.java

@@ -11,34 +11,30 @@ public void onMessage(NotificationResult notification) {
 
     // Subscribe to notifications when document leaves the scope
     kuzzle.getRealtime().subscribe(
-      "nyc-open-data", 
-      "yellow-taxi", 
-      filters, 
-      listener, 
+      "nyc-open-data",
+      "yellow-taxi",
+      filters,
+      listener,
       options
     );
 
     String document = "{ \"name\": \"nina vkote\", \"age\": 19 }";
 
     // The document is in the scope
     kuzzle.getDocument().create(
-      "nyc-open-data", 
-      "yellow-taxi", 
-      "nina-vkote", 
+      "nyc-open-data",
+      "yellow-taxi",
+      "nina-vkote",
       document
     );
 
     // The document isn't in the scope anymore
     kuzzle.getDocument().update(
-      "nyc-open-data", 
-      "yellow-taxi", 
-      "nina-vkote", 
+      "nyc-open-data",
+      "yellow-taxi",
+      "nina-vkote",
       "{ \"age\": 42 }"
     );
-
-    Thread.sleep(1000);
 } catch (KuzzleException e) {
     System.err.println(e.getMessage());
-} catch (InterruptedException e) {
-    System.err.println(e.getMessage());
 }

src/sdk-reference/java/1/realtime/subscribe/snippets/document-notifications-leave-scope.test.yml

@@ -3,5 +3,5 @@ description: Subscribe to documents leaving the scope
 hooks:
   before: curl -X POST kuzzle:7512/nyc-open-data/_create ; curl -X PUT kuzzle:7512/nyc-open-data/yellow-taxi/; curl -X DELETE kuzzle:7512/nyc-open-data/yellow-taxi/nina-vkote
   after:
-template: default
+template: realtime
 expected: Document moved out from the scope

src/sdk-reference/java/1/realtime/subscribe/snippets/document-notifications.java

@@ -28,10 +28,6 @@ public void onMessage(NotificationResult notification) {
       "nina-vkote",
       document
     );
-
-    Thread.sleep(1000);
-  } catch (KuzzleException e) {
-    System.err.println(e.getMessage());
-  } catch (InterruptedException e) {
+} catch (KuzzleException e) {
     System.err.println(e.getMessage());
 }

src/sdk-reference/java/1/realtime/subscribe/snippets/document-notifications.test.yml

@@ -3,5 +3,5 @@ description: Simple subscribe to document notifications
 hooks:
   before: curl -X POST kuzzle:7512/nyc-open-data/_create ; curl -X PUT kuzzle:7512/nyc-open-data/yellow-taxi/; curl -X DELETE kuzzle:7512/nyc-open-data/yellow-taxi/nina-vkote
   after:
-template: default
+template: realtime
 expected: Document nina-vkote enter the scope

src/sdk-reference/java/1/realtime/subscribe/snippets/message-notifications.java

@@ -8,9 +8,9 @@ public void onMessage(NotificationResult notification) {
 
 try {
     kuzzle.getRealtime().subscribe(
-      "i-dont-exist", 
-      "in-database", 
-      "{}", 
+      "i-dont-exist",
+      "in-database",
+      "{}",
       listener
     );
 

src/sdk-reference/java/1/realtime/subscribe/snippets/message-notifications.test.yml

@@ -3,5 +3,5 @@ description: Subscribe to message notifications
 hooks:
   before:
   after:
-template: default
+template: realtime
 expected: Message notification received

src/sdk-reference/java/1/realtime/subscribe/snippets/user-notifications.java

@@ -12,10 +12,10 @@ public void onMessage(NotificationResult notification) {
 
 try {
     kuzzle.getRealtime().subscribe(
-      "nyc-open-data", 
-      "yellow-taxi", 
-      filters, 
-      listener, 
+      "nyc-open-data",
+      "yellow-taxi",
+      filters,
+      listener,
       options
     );
 
@@ -29,11 +29,11 @@ public void onMessage(NotificationResult notification) {
 
     // Subscribe to the same room with the second client
     fuzzle.getRealtime().subscribe(
-      "nyc-open-data", 
-      "yellow-taxi", 
-      filters, 
+      "nyc-open-data",
+      "yellow-taxi",
+      filters,
       listener
     );
-} catch (KuzzleException e) {
+  } catch (KuzzleException e) {
     System.err.println(e.getMessage());
 }

src/sdk-reference/java/1/realtime/subscribe/snippets/user-notifications.test.yml

@@ -3,5 +3,5 @@ description: Subscribe to users joining or leaving the room
 hooks:
   before: curl -X POST kuzzle:7512/nyc-open-data/_create ; curl -X PUT kuzzle:7512/nyc-open-data/yellow-taxi/
   after:
-template: default
+template: realtime
 expected: Currently 2 users in the room

src/sdk-reference/js/6/realtime/subscribe/snippets/document-notifications-leave-scope.js

@@ -46,4 +46,4 @@ try {
   await kuzzle.document.update('nyc-open-data', 'yellow-taxi', _id, { age: 42 });
 } catch (error) {
   console.log(error.message);
-}
+}

src/sdk-reference/js/6/realtime/subscribe/snippets/document-notifications.test.yml

@@ -3,5 +3,5 @@ description: Simple subscribe to document notifications
 hooks:
   before: curl -X POST kuzzle:7512/nyc-open-data/_create ; curl -X PUT kuzzle:7512/nyc-open-data/yellow-taxi/
   after:
-template: default
+template: realtime
 expected: Document nina vkote enter the scope

test/templates/catch.tpl.js

@@ -9,7 +9,7 @@ const kuzzle = new Kuzzle('websocket', {
 
 // add a listener to detect any connection problems
 kuzzle.on('networkError', error => {
-  console.error(`Network Error: ${error}`);
+  console.error(`Network Error: ${error.message}`);
 });
 
 (async () => {

test/templates/default.tpl.js

@@ -9,7 +9,7 @@ const kuzzle = new Kuzzle('websocket', {
 
 // add a listener to detect any connection problems
 kuzzle.on('networkError', error => {
-  console.error(`Network Error: ${error}`);
+  console.error(`Network Error: ${error.message}`);
 });
 
 (async () => {

test/templates/realtime.tpl.cpp

@@ -0,0 +1,54 @@
+#include <unistd.h>
+
+#include <sstream>
+#include <iostream>
+#include <string>
+#include <ctime>
+#include <vector>
+
+#include "auth.hpp"
+#include "collection.hpp"
+#include "document.hpp"
+#include "server.hpp"
+#include "index.hpp"
+#include "realtime.hpp"
+#include "kuzzle.hpp"
+
+bool is_empty(std::ostringstream *stream) {
+  bool empty;
+  std::streampos position = stream->tellp();
+
+  stream->seekp(0, std::ios_base::end);
+  empty = stream->tellp() == 0;
+  stream->seekp(position);
+
+  return empty;
+}
+
+int main() {
+  std::string hostname = "kuzzle";
+
+  kuzzleio::Kuzzle* kuzzle = new kuzzleio::Kuzzle(hostname);
+
+  char* error = kuzzle->connect();
+  if (error != nullptr) {
+    std::cerr << "Unable to connect to " << hostname << ":7512\n" << error << std::endl;
+    return 1;
+  }
+
+  std::streambuf *cout_original = std::cout.rdbuf();
+  std::ostringstream cout_copy;
+
+  std::cout.rdbuf(cout_copy.rdbuf());
+
+  [snippet-code]
+
+  for (size_t i = 20; i > 0 && is_empty(&cout_copy); --i) {
+    usleep(200);
+  }
+
+  std::cout.rdbuf(cout_original);
+  std::cout << cout_copy.str();
+
+  return 0;
+}

test/templates/realtime.tpl.go

@@ -22,11 +22,20 @@ func main() {
 		os.Exit(1)
 	}
 
+	rescueStdout := os.Stdout
+	r, w, _ := os.Pipe()
+	os.Stdout = w
+
+	[snippet-code]
+
 	go func() {
-		time.Sleep(1 * time.Second)
-		fmt.Println("Timeout exceeded")
-		os.Exit(2)
+		time.Sleep(4 * time.Second)
+		os.Exit(1)
 	}()
 
-	[snippet-code]
+	b := make([]byte, 4096)
+	n, _ := r.Read(b)
+
+	os.Stdout = rescueStdout
+	fmt.Print(string(b[:n]))
 }