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

let -> field, for debuggability

This commit is contained in:
Tony Garnock-Jones 2019-06-18 16:45:10 +01:00
parent e806f4b042
commit 76e180b047
1 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
packages/server/src/client.js
View File

@ -57,23 +57,25 @@ export function _genericClientSessionFacet(addr, scope, w0, debug) {
const outboundTurn = recorder(this, 'commitNeeded', (items) => w(Turn(items))); const outboundTurn = recorder(this, 'commitNeeded', (items) => w(Turn(items)));
let pubs = Map(); field this.pubs = Map();
let subs = Map(); field this.subs = Map();
let matches = Map(); field this.matches = Map();
on start w(Connect(scope)); on start w(Connect(scope));
on stop matches.forEach((m) => m.captures.forEach((a) => currentFacet().actor.adhocRetract(a))); on stop this.matches.forEach((m) => {
m.captures.forEach((a) => currentFacet().actor.adhocRetract(a));
});
on asserted ToServer(addr, $a) { on asserted ToServer(addr, $a) {
const ep = genUuid('pub'); const ep = genUuid('pub');
outboundTurn.extend(Assert(ep, a)); outboundTurn.extend(Assert(ep, a));
pubs = pubs.set(a, ep); this.pubs = this.pubs.set(a, ep);
} }
on retracted ToServer(addr, $a) { on retracted ToServer(addr, $a) {
const ep = pubs.get(a); const ep = this.pubs.get(a);
outboundTurn.extend(Clear(ep)); outboundTurn.extend(Clear(ep));
pubs = pubs.remove(a); this.pubs = this.pubs.remove(a);
} }
on message ToServer(addr, $a) { on message ToServer(addr, $a) {
@ -85,19 +87,19 @@ export function _genericClientSessionFacet(addr, scope, w0, debug) {
on asserted Observe(FromServer(addr, $spec)) { on asserted Observe(FromServer(addr, $spec)) {
const ep = genUuid('sub'); const ep = genUuid('sub');
outboundTurn.extend(Assert(ep, Observe(spec))); outboundTurn.extend(Assert(ep, Observe(spec)));
subs = subs.set(spec, ep); this.subs = this.subs.set(spec, ep);
matches = matches.set(ep, { spec, captures: Map() }); this.matches = this.matches.set(ep, { spec, captures: Map() });
} }
on retracted Observe(FromServer(addr, $spec)) { on retracted Observe(FromServer(addr, $spec)) {
outboundTurn.extend(Clear(subs.get(spec))); outboundTurn.extend(Clear(this.subs.get(spec)));
subs = subs.remove(spec); this.subs = this.subs.remove(spec);
} }
const _instantiate = (m, vs) => Skeleton.instantiateAssertion(FromServer(addr, m.spec), vs); const _instantiate = (m, vs) => Skeleton.instantiateAssertion(FromServer(addr, m.spec), vs);
const _lookup = (CTOR, item) => { const _lookup = (CTOR, item) => {
const m = matches.get(CTOR._endpointName(item)); const m = this.matches.get(CTOR._endpointName(item));
const vs = CTOR._captures(item); const vs = CTOR._captures(item);
return { m, vs }; return { m, vs };
} }
@ -118,10 +120,10 @@ export function _genericClientSessionFacet(addr, scope, w0, debug) {
send _instantiate(m, vs); send _instantiate(m, vs);
} else if (End.isClassOf(item)) { } else if (End.isClassOf(item)) {
const ep = End._endpointName(item); const ep = End._endpointName(item);
const m = matches.get(ep); const m = this.matches.get(ep);
if (m) { if (m) {
m.captures.forEach((a) => currentFacet().actor.adhocRetract(a)); m.captures.forEach((a) => currentFacet().actor.adhocRetract(a));
matches = matches.remove(ep); this.matches = this.matches.remove(ep);
} }
} else if (Err.isClassOf(item)) { } else if (Err.isClassOf(item)) {
throw new Error(item.toString()); throw new Error(item.toString());