urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2025-01-07 13:37:36 +03:00
Code Issues Packages Projects Releases Wiki Activity

multi-dependency support

Browse Source
This commit is contained in:
Anton Dyudin 2015-05-01 14:43:41 -07:00
parent 4c2e39b74b
commit d22f243dfe
1 changed files with 32 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
base/arvo/eyre.hoon
View File

@ -148,7 +148,7 @@
[%beam p=beam] [%beam p=beam]
[%deps p=?(%put %delt) q=@uvH] [%deps p=?(%put %delt) q=@uvH]
[%mess p=hasp q=mark r=wire s=json] [%mess p=hasp q=mark r=wire s=json]
[%poll p=@uvH] [%poll p=[i=@uvH t=(list ,@uvH)]]
[%spur p=spur] [%spur p=spur]
[%subs p=?(%put %delt) q=[hasp %json wire path]] [%subs p=?(%put %delt) q=[hasp %json wire path]]
[%view p=ixor q=[~ u=@ud]] [%view p=ixor q=[~ u=@ud]]
@ -264,25 +264,33 @@
''' '''
urb.tries = 0 urb.tries = 0
urb.call = function() { urb.call = function() {
xhr = new XMLHttpRequest() urb.wreq = new XMLHttpRequest()
xhr.open('GET', urb.poll, true) urb.wreq.open('GET', urb.poll, true)
xhr.addEventListener('load', function() { urb.wreq.addEventListener('load', function() {
// if(~~(this.status / 100) == 4) // if(~~(this.status / 100) == 4)
// return document.write(xhr.responseText) // return document.write(this.responseText)
if(this.status !== 205) { if(this.status !== 205) {
return urb.keep() return urb.keep()
} }
document.location.reload() document.location.reload()
}) })
xhr.addEventListener('error', urb.keep) urb.wreq.addEventListener('error', urb.keep)
xhr.addEventListener('abort', urb.keep) urb.wreq.addEventListener('abort', urb.keep)
xhr.send() urb.wreq.send()
} }
urb.keep = function() { urb.keep = function() {
setTimeout(urb.call,1000*urb.tries) setTimeout(urb.call,1000*urb.tries)
urb.tries++ urb.tries++
} }
urb.call() urb.call()
urb.wasp = function(deh){
var old = /[^/]*$/.exec(urb.poll)[0]
var deps = old.replace(/^on.json\?|.json$/,'').split('&')
if (deps.indexOf(deh) !== -1) return;
deps.push(deh)
urb.poll = "/~/on.json?"+deps.join('&')
urb.wreq.abort() // trigger keep
}
''' '''
:: ::
++ auth-redir ++ auth-redir
@ -564,7 +572,8 @@
== ==
~| q.q.cay ~| q.q.cay
=+ ((hard ,[mit=mite rez=octs]) q.q.cay) =+ ((hard ,[mit=mite rez=octs]) q.q.cay)
(give-thou 200 [content-type/(moon mit)]~ ~ rez) =+ dep=(crip (pojo %s (scot %uv p.sih)))
(give-thou 200 ~[etag/dep content-type/(moon mit)] ~ rez)
== ==
== ==
:: ::
@ -803,7 +812,13 @@
%own our %own our
== ==
:: ::
%on [%poll (raid but %uv ~)] %on
:- %poll
?^ but [(raid but %uv ~)]~
=+ dep=((hard (list ,[@ ~])) quy)
=< ?~(. !! .)
(turn dep |=([a=@tas ~] (slav %uv a)))
::
%of %of
:+ %view ?>(?=([@ ~] but) i.but) :+ %view ?>(?=([@ ~] but) i.but)
?> ?=([[%poll @] ~] quy) :: XX eventsource ?> ?=([[%poll @] ~] quy) :: XX eventsource
@ -901,10 +916,13 @@
(ford-req root-beak [%cast q.hem %done ~ cay]) (ford-req root-beak [%cast q.hem %done ~ cay])
:: ::
%poll %poll
?. ?=([~ %js] p.pok) :: XX treat non-json cases? ?: ?=([~ %js] p.pok) :: XX treat non-json cases?
[%| (new-dependency p.hem %& hen)] =+ polling-url=['/' (apex:earn %| pok(u.p %json) quy)]
=+ polling-url=['/' (apex:earn %| pok(u.p %json) quy)] [%& %js (add-json (joba %poll (jape polling-url)) poll:js)]
[%& %js (add-json (joba %poll (jape polling-url)) poll:js)] |-
=. done (new-dependency i.p.hem %& hen)
?~ t.p.hem [%| done]
$(p.hem t.p.hem)
:: ::
%subs %subs
?- p.hem ?- p.hem