Initial work on websocket sagas

3 files changed, 64 insertions, 3 deletions

diff --git a/src/main/js/package.json b/src/main/js/package.json
index 30ecc9e2..eff6dc38 100644
--- a/src/main/js/package.json
+++ b/src/main/js/package.json
@@ -12,7 +12,9 @@
     "react-redux": "^5.0.1",
     "react-router": "4.0.0-alpha.6",
     "redux": "^3.6.0",
-    "redux-saga": "^0.13.0"
+    "redux-saga": "^0.13.0",
+    "sockjs-client": "latest",
+    "webstomp-client": "^1.0.3"
   },
   "scripts": {
     "start": "react-scripts start",
diff --git a/src/main/js/src/wsSagas.js b/src/main/js/src/wsSagas.js
new file mode 100644
index 00000000..b6dcce95
--- /dev/null
+++ b/src/main/js/src/wsSagas.js
@@ -0,0 +1,42 @@
+import { call, put, take } from 'redux-saga/effects'
+import SockJS from 'sockjs-client'
+import Stomp from 'webstomp-client'
+const wsURL = '/seven-wonders-websocket'
+let socket = null;
+
+const openSocket = () => {
+    socket = Stomp.over(new SockJS(wsURL))
+    socket.connect({}, (frame) => {
+        console.log('Connected')
+
+        socket.subscribe('/user/queue/errors', (msg) =>
+            console.error('/user/queue/errors', msg)
+        )
+
+        socket.subscribe('/topic/games', (msg) => {
+            const game = JSON.parse(msg)
+            console.error('/topic/games', game)
+        })
+
+        socket.subscribe('/user/queue/join-game', (msg) => {
+            const game = JSON.parse(msg)
+            console.error('/user/queue/join-game', game)
+        })
+    })
+}
+
+const disconnect = () => {
+    if (!socket) {
+        socket.disconnect()
+        console.log('Disconnected')
+    }
+}
+
+export default function* wsSagas() {
+    const channel = yield call(openSocket)
+
+    while (true) {
+        const action = yield take(channel)
+        yield put(action)
+    }
+}
diff --git a/src/main/js/yarn.lock b/src/main/js/yarn.lock
index 983f930a..bd375f1c 100644
--- a/src/main/js/yarn.lock
+++ b/src/main/js/yarn.lock
@@ -1940,7 +1940,7 @@ events@^1.0.0:
   version "1.1.1"
   resolved "https://registry.yarnpkg.com/events/-/events-1.1.1.tgz#9ebdb7635ad099c70dcc4c2a1f5004288e8bd924"
 
-eventsource@^0.1.3:
+eventsource@^0.1.3, eventsource@~0.1.6:
   version "0.1.6"
   resolved "https://registry.yarnpkg.com/eventsource/-/eventsource-0.1.6.tgz#0acede849ed7dd1ccc32c811bb11b944d4f29232"
   dependencies:
@@ -2035,6 +2035,12 @@ faye-websocket@^0.10.0:
   dependencies:
     websocket-driver ">=0.5.1"
 
+faye-websocket@~0.11.0:
+  version "0.11.0"
+  resolved "https://registry.yarnpkg.com/faye-websocket/-/faye-websocket-0.11.0.tgz#d9ccf0e789e7db725d74bc4877d23aa42972ac50"
+  dependencies:
+    websocket-driver ">=0.5.1"
+
 faye-websocket@~0.7.3:
   version "0.7.3"
   resolved "https://registry.yarnpkg.com/faye-websocket/-/faye-websocket-0.7.3.tgz#cc4074c7f4a4dfd03af54dd65c354b135132ce11"
@@ -4678,6 +4684,17 @@ sockjs-client@^1.0.3, sockjs-client@1.0.3:
     json3 "^3.3.2"
     url-parse "^1.0.1"
 
+sockjs-client@latest:
+  version "1.1.1"
+  resolved "https://registry.yarnpkg.com/sockjs-client/-/sockjs-client-1.1.1.tgz#284843e9a9784d7c474b1571b3240fca9dda4bb0"
+  dependencies:
+    debug "^2.2.0"
+    eventsource "~0.1.6"
+    faye-websocket "~0.11.0"
+    inherits "^2.0.1"
+    json3 "^3.3.2"
+    url-parse "^1.1.1"
+
 sockjs@^0.3.15:
   version "0.3.18"
   resolved "https://registry.yarnpkg.com/sockjs/-/sockjs-0.3.18.tgz#d9b289316ca7df77595ef299e075f0f937eb4207"
@@ -5039,7 +5056,7 @@ url-loader@0.5.7:
     loader-utils "0.2.x"
     mime "1.2.x"
 
-url-parse@^1.0.1:
+url-parse@^1.0.1, url-parse@^1.1.1:
   version "1.1.7"
   resolved "https://registry.yarnpkg.com/url-parse/-/url-parse-1.1.7.tgz#025cff999653a459ab34232147d89514cc87d74a"
   dependencies: