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

Support nested observation across broker protocol

This commit is contained in:
Tony Garnock-Jones 2016-05-15 06:10:51 -04:00
parent ee120022a4
commit e7b0e15786
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
racket/syndicate/broker/server.rkt
View File

@ -75,19 +75,29 @@
value)
(define (unwrap-patch scope p)
(patch-step* p (list broker-data-parenthesis
broker-scope-parenthesis
(broker-scope-host scope)
(broker-scope-path scope))))
(match-define (patch added removed) p)
(patch (unwrap-trie scope added) (unwrap-trie scope removed)))
(define (unwrap-trie scope t)
(if (trie-empty? t)
t
(let ((observations (trie-step t observe-parenthesis)))
(trie-union (trie-prepend observe-parenthesis (unwrap-trie scope observations))
(trie-step* t (list broker-data-parenthesis
broker-scope-parenthesis
(broker-scope-host scope)
(broker-scope-path scope)))))))
(define (wrap-patch scope p)
(match-define (patch added removed) p)
(patch (wrap-trie scope added) (wrap-trie scope removed)))
(define (wrap-trie scope t)
(define observations (trie-step t observe-parenthesis))
(trie-union (trie-prepend observe-parenthesis (wrap-trie* scope observations))
(wrap-trie* scope t)))
(if (trie-empty? t)
t
(let ((observations (trie-step t observe-parenthesis)))
(trie-union (trie-prepend observe-parenthesis (wrap-trie scope observations))
(wrap-trie* scope t)))))
(define (wrap-trie* scope t)
(pattern->trie #t (broker-data scope (embedded-trie t))))