From b3f42e62af698a67c2250533c437569559f1fdf9 Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Thu, 29 Dec 2016 07:49:51 +0900
Subject: Initial commit :four_leaf_clover:

---
 src/web/app/common/scripts/stream.ls | 42 ++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 src/web/app/common/scripts/stream.ls

(limited to 'src/web/app/common/scripts/stream.ls')

diff --git a/src/web/app/common/scripts/stream.ls b/src/web/app/common/scripts/stream.ls
new file mode 100644
index 0000000000..534048248f
--- /dev/null
+++ b/src/web/app/common/scripts/stream.ls
@@ -0,0 +1,42 @@
+# Stream
+#================================
+
+ReconnectingWebSocket = require \reconnecting-websocket
+riot = require \riot
+
+module.exports = (me) ~>
+	state = \initializing
+	state-ev = riot.observable!
+	event = riot.observable!
+
+	socket = new ReconnectingWebSocket CONFIG.api.url.replace \http \ws
+
+	socket.onopen = ~>
+		state := \connected
+		state-ev.trigger \connected
+		socket.send JSON.stringify do
+			i: me.token
+
+	socket.onclose = ~>
+		state := \reconnecting
+		state-ev.trigger \closed
+
+	socket.onmessage = (message) ~>
+		try
+			message = JSON.parse message.data
+			if message.type?
+				event.trigger message.type, message.body
+		catch
+			# ignore
+
+	get-state = ~> state
+
+	event.on \i_updated (data) ~>
+		Object.assign me, data
+		me.trigger \updated
+
+	{
+		state-ev
+		get-state
+		event
+	}
-- 
cgit v1.2.3-freya