From feb7f5104ddbcb9fd42b93d78f385804793ebb6c Mon Sep 17 00:00:00 2001
From: Rutger van Beusekom <rutger.van.beusekom@verum.com>
Date: Thu, 19 Nov 2020 11:34:37 +0100
Subject: [PATCH] websocket: Test failure interleaved frames from 2 separate
 messages.

---
 demos/websocket/8s-server.scm  |  8 ++++++--
 demos/websocket/ws-client.html | 16 ++++++++--------
 2 files changed, 14 insertions(+), 10 deletions(-)

diff --git a/demos/websocket/8s-server.scm b/demos/websocket/8s-server.scm
index c4b638f..5ea8834 100755
--- a/demos/websocket/8s-server.scm
+++ b/demos/websocket/8s-server.scm
@@ -42,7 +42,7 @@
 
 (define (main . args)
   (let* ((hive (make-hive))
-         (sleeper (bootstrap-actor hive <sleeper>))
+         ;; (sleeper (bootstrap-actor hive <sleeper>))
          (server (bootstrap-actor
                   hive <websocket-server>
                   #:port %server-port
@@ -55,7 +55,11 @@
                   #:on-ws-message (lambda (ws msg)
                                     (format (current-error-port) "on-message: ~s: ~s\n" ws msg))
                   #:on-ws-open (lambda (ws)
-                                 (format (current-error-port) "on-open: ~s\n" ws)))))
+                                 (format (current-error-port) "on-open: ~s\n" ws)
+                                 (format (current-error-port) "sending: AAA...\n")
+				 (<- (actor-id ws) 'send (make-string (* 1024 1024) #\A))
+                                 (format (current-error-port) "sending: BBB...\n")
+				 (<- (actor-id ws) 'send (make-string (* 1024 1024) #\B))))))
     (format (current-error-port) "listening: ~s\n" %server-port)
     (run-hive hive '())))
 
diff --git a/demos/websocket/ws-client.html b/demos/websocket/ws-client.html
index 5e9c811..7dc87b6 100644
--- a/demos/websocket/ws-client.html
+++ b/demos/websocket/ws-client.html
@@ -26,18 +26,18 @@
     <p id="log"></p>
     <script>
       var server = "ws://localhost:1236";
-      var log = document.getElementById ("log");
-      console.log ('log=%j', log);
-      console.log ('document=%j', document);
-      console.log ('body=%j', document.body);
+      //var log = document.getElementById ("log");
+      //console.log ('log=%j', log);
+      //console.log ('document=%j', document);
+      //console.log ('body=%j', document.body);
       var ws = new WebSocket (server);
       ws.onopen = function () {
-        console.log ('open!'); log.innerHTML += 'open!<br>';
+        console.log ('open!'); //log.innerHTML += 'open!<br>';
         ws.send ('Hello, Web Socket!');
-        ws.send ('Say: ' + 'A'.repeat (Math.pow (2, 16)) + '\n');
+        //ws.send ('Say: ' + 'A'.repeat (Math.pow (2, 16)) + '\n');
       };
-      ws.close = function () { console.log ('close!'); log.innerHTML += 'close!<br>'; };
-      ws.onmessage = function () { console.log ('message'); log.innerHTML += 'message!<br>'; };
+      ws.close = function () { console.log ('close!'); }//log.innerHTML += 'close!<br>'; };
+      ws.onmessage = function (event) { console.log ('message:%s', event.data); }//log.innerHTML += 'message!<br>'; };
     </script>
   </body>
 </html>
-- 
2.31.1