summaryrefslogtreecommitdiff
path: root/src/web/app/common/scripts/stream.ls
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2017-02-18 13:18:59 +0900
committersyuilo <syuilotan@yahoo.co.jp>2017-02-18 13:18:59 +0900
commit4770e1fab89b35671f9fd1eb3080efca717e27ac (patch)
tree1fa19779dadb27bf1804d4338409146adf62af74 /src/web/app/common/scripts/stream.ls
parent:v: (diff)
downloadsharkey-4770e1fab89b35671f9fd1eb3080efca717e27ac.tar.gz
sharkey-4770e1fab89b35671f9fd1eb3080efca717e27ac.tar.bz2
sharkey-4770e1fab89b35671f9fd1eb3080efca717e27ac.zip
:v:
Diffstat (limited to 'src/web/app/common/scripts/stream.ls')
-rw-r--r--src/web/app/common/scripts/stream.ls39
1 files changed, 0 insertions, 39 deletions
diff --git a/src/web/app/common/scripts/stream.ls b/src/web/app/common/scripts/stream.ls
deleted file mode 100644
index c2c061603e..0000000000
--- a/src/web/app/common/scripts/stream.ls
+++ /dev/null
@@ -1,39 +0,0 @@
-# Stream
-#================================
-
-ReconnectingWebSocket = require \reconnecting-websocket
-riot = require \riot
-
-module.exports = (me) ~>
- state = \initializing
- state-ev = riot.observable!
- event = riot.observable!
-
- host = CONFIG.api.url.replace \http \ws
- socket = new ReconnectingWebSocket "#{host}?i=#{me.token}"
-
- socket.onopen = ~>
- state := \connected
- state-ev.trigger \connected
-
- 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 me.update
-
- {
- state-ev
- get-state
- event
- }