syndicate-lang
/
syndicate-js
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Try out preserves

This commit is contained in:
Tony Garnock-Jones 2018-11-15 11:00:30 +00:00
parent 018a2bd399
commit e65c361c14
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/broker/package.json
View File

@ -15,7 +15,8 @@
"@syndicate-lang/driver-browser-ui": "^0.0.12",
"@syndicate-lang/driver-http-node": "^0.0.11",
"@syndicate-lang/driver-tcp-node": "^0.0.1",
"@syndicate-lang/driver-timer": "^0.0.15"
"@syndicate-lang/driver-timer": "^0.0.15",
"preserves": "^0.0.0"
},
"scripts": {
"prepare": "which redo >/dev/null && redo || ../../do"

5
packages/broker/src/index.js
View File

@ -14,6 +14,9 @@ spawn named 'serverLogger' {
on asserted Http.Request(_, server, $method, $path, $query, $req) {
console.log(method, path.toJS(), query.toJS());
}
on asserted Http.WebSocket(_, server, $path, $query) {
console.log(path.toJS(), query.toJS());
}
}
spawn named 'rootServer' {
@ -31,7 +34,7 @@ spawn named 'rootServer' {
spawn named 'websocketListener' {
during Http.WebSocket($reqId, server, ['broker'], _) spawn named ['wsConnection', reqId] {
on message Http.DataIn(reqId, $message) {
console.log('got', reqId, message);
console.log('got', reqId, new (require('preserves').Decoder)(message).next())
^ Http.DataOut(reqId, message);
}