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

Move Codec and Broker into src/.

This commit is contained in:
Tony Garnock-Jones 2016-05-10 00:57:05 -04:00
parent 8546e93e5d
commit 8f1d27c584
5 changed files with 39 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
js/examples/chat/index.html
View File

@ -5,12 +5,9 @@
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<link href="style.css" rel="stylesheet">
<script src="https://cdnjs.cloudflare.com/ajax/libs/immutable/3.8.1/immutable.min.js"></script> <!-- TODO: ??? -->
<script src="../../third-party/jquery-2.2.0.min.js"></script>
<script src="../../dist/syndicatecompiler.js"></script>
<script src="../../dist/syndicate.js"></script>
<script src="codec.js"></script>
<script src="broker-client.js"></script>
<script type="text/syndicate-js" src="index.js"></script>
</head>
<body>

8
js/examples/chat/index.js
View File

@ -4,6 +4,12 @@ assertion type says(who, message);
var DOM = Syndicate.DOM.DOM;
var jQueryEvent = Syndicate.JQuery.jQueryEvent;
var brokerConnected = Syndicate.Broker.brokerConnected;
var brokerConnection = Syndicate.Broker.brokerConnection;
var toBroker = Syndicate.Broker.toBroker;
var fromBroker = Syndicate.Broker.fromBroker;
var forceBrokerDisconnect = Syndicate.Broker.forceBrokerDisconnect;
///////////////////////////////////////////////////////////////////////////
// Application
@ -105,7 +111,7 @@ $(document).ready(function () {
Syndicate.JQuery.spawnJQueryDriver();
Syndicate.DOM.spawnDOMDriver();
Syndicate.WakeDetector.spawnWakeDetector();
spawnBrokerClientDriver();
Syndicate.Broker.spawnBrokerClientDriver();
spawnInputChangeMonitor();
spawnChatApp();
}

29
js/examples/chat/broker-client.js → js/src/broker.js
View File

@ -1,13 +1,17 @@
"use strict";
// WebSocket-based Syndicate broker client
var Trie = Syndicate.Trie;
var Patch = Syndicate.Patch;
var Dataspace = Syndicate.Dataspace;
var Struct = Syndicate.Struct;
var DemandMatcher = Syndicate.DemandMatcher;
var __ = Syndicate.__;
var _$ = Syndicate._$;
var Immutable = require('immutable');
var Trie = require('./trie.js');
var Patch = require('./patch.js');
var Struct = require('./struct.js');
var DemandMatcher = require('./demand-matcher.js').DemandMatcher;
var Codec = require('./codec');
var Dataspace_ = require("./dataspace.js");
var Dataspace = Dataspace_.Dataspace;
var __ = Dataspace_.__;
var _$ = Dataspace_._$;
var DEFAULT_RECONNECT_DELAY = 100; // ms
var MAX_RECONNECT_DELAY = 30000; // ms
@ -235,3 +239,14 @@ BrokerClientConnection.prototype.onclose = function (e) {
? MAX_RECONNECT_DELAY + (Math.random() * 1000)
: this.reconnectDelay;
};
///////////////////////////////////////////////////////////////////////////
module.exports.toBroker = toBroker;
module.exports.fromBroker = fromBroker;
module.exports.brokerConnection = brokerConnection;
module.exports.brokerConnected = brokerConnected;
module.exports.forceBrokerDisconnect = forceBrokerDisconnect;
module.exports.spawnBrokerClientDriver = spawnBrokerClientDriver;
module.exports.BrokerClientConnection = BrokerClientConnection;

20
js/examples/chat/codec.js → js/src/codec.js
View File

@ -1,8 +1,9 @@
"use strict";
// Wire protocol representation of events and actions
var Trie = Syndicate.Trie;
var Struct = Syndicate.Struct;
var Trie = require('./trie.js');
var Patch = require('./patch.js');
var Struct = require('./struct.js');
function _encode(e) {
switch (e.type) {
@ -28,14 +29,7 @@ function _decode(what) {
///////////////////////////////////////////////////////////////////////////
// module.exports.encodeEvent = _encode;
// module.exports.decodeEvent = _decode("event");
// module.exports.encodeAction = _encode;
// module.exports.decodeAction = _decode("action");
var Codec = {
encodeEvent: _encode,
decodeEvent: _decode("event"),
encodeAction: _encode,
decodeAction: _decode("action")
};
module.exports.encodeEvent = _encode;
module.exports.decodeEvent = _decode("event");
module.exports.encodeAction = _encode;
module.exports.decodeAction = _decode("action");

4
js/src/main.js
View File

@ -29,8 +29,10 @@ module.exports.Ack = require('./ack.js').Ack;
module.exports.RandomID = require('./randomid.js');
module.exports.DOM = require("./dom-driver.js");
module.exports.JQuery = require("./jquery-driver.js");
module.exports.WakeDetector = require("./wake-detector-driver.js");
module.exports.Reflect = require("./reflect.js");
module.exports.WakeDetector = require("./wake-detector-driver.js");
module.exports.Codec = require("./codec.js");
module.exports.Broker = require("./broker.js");
module.exports.Patch = require("./patch.js");
copyKeys(['emptyPatch',