summaryrefslogtreecommitdiffstats
path: root/webchat/sockjs_server_connection_transport.js
diff options
context:
space:
mode:
authormakefu <github@syntax-fehler.de>2013-12-30 17:38:02 +0100
committermakefu <github@syntax-fehler.de>2013-12-30 17:38:02 +0100
commitee33c348658a12a4e54281dc34eaca8639e247f8 (patch)
tree142ea8052af9e75886b6c71979eed302885ab22a /webchat/sockjs_server_connection_transport.js
parentefef353ef2bf65ef6123fc699bce6c69fc37cfcc (diff)
parent11de3d6d4c62f7059cdb45992d7d0fec05dde0e4 (diff)
Merge branch 'master' of ssh://github.com/krebscode/painload
Diffstat (limited to 'webchat/sockjs_server_connection_transport.js')
-rw-r--r--webchat/sockjs_server_connection_transport.js26
1 files changed, 26 insertions, 0 deletions
diff --git a/webchat/sockjs_server_connection_transport.js b/webchat/sockjs_server_connection_transport.js
new file mode 100644
index 00000000..6f68b955
--- /dev/null
+++ b/webchat/sockjs_server_connection_transport.js
@@ -0,0 +1,26 @@
+
+module.exports = function make_sockjs_server_connection_transport (connection) {
+ var transport = {}
+
+ connection.on('data', function (data) {
+ try {
+ var message = JSON.parse(data)
+ } catch (error) {
+ return console.log('error', error)
+ }
+ transport.onmessage(message)
+ })
+ connection.on('close', function () {
+ })
+
+ transport.send = function (message) {
+ try {
+ var data = JSON.stringify(message)
+ } catch (error) {
+ return console.log('sockjs transport send error:', error)
+ }
+ connection.write(data)
+ }
+
+ return transport
+}