mirror of
https://github.com/ilyakooo0/urbit.git
synced 2024-09-22 07:59:22 +03:00
use jael for ixor expiry logic
This commit is contained in:
parent
40817e662f
commit
a8016ca4de
@ -144,8 +144,6 @@
|
|||||||
$: ses/hole :: associated session
|
$: ses/hole :: associated session
|
||||||
him/ship :: static identity
|
him/ship :: static identity
|
||||||
pol/(unit duct) :: long-poll
|
pol/(unit duct) :: long-poll
|
||||||
era/@da :: next wake
|
|
||||||
die/@da :: collection date
|
|
||||||
sus/(set {dock $json wire path}) :: subscriptions
|
sus/(set {dock $json wire path}) :: subscriptions
|
||||||
eve/{p/@u q/(map @u even)} :: queued events
|
eve/{p/@u q/(map @u even)} :: queued events
|
||||||
med/(qeu duct) :: waiting /~/to/
|
med/(qeu duct) :: waiting /~/to/
|
||||||
@ -919,13 +917,8 @@
|
|||||||
==
|
==
|
||||||
::
|
::
|
||||||
$wake
|
$wake
|
||||||
?: ?=($je -.tee)
|
?> ?=($je -.tee)
|
||||||
%.(p.tee wake:(je (~(got by secondary.jel) p.p.tee)))
|
%.(p.tee wake:(je (~(got by secondary.jel) p.p.tee)))
|
||||||
?> ?=({?($of $ow) @ $~} tee)
|
|
||||||
?: ?=($ow -.tee)
|
|
||||||
abut:(ire-ix p.tee)
|
|
||||||
=> wake:(ire-ix p.tee)
|
|
||||||
(give-json 200 ~ (joba %beat %b &))
|
|
||||||
::
|
::
|
||||||
$news :: dependency updated
|
$news :: dependency updated
|
||||||
?: ?=({$se *} tee)
|
?: ?=({$se *} tee)
|
||||||
@ -1653,14 +1646,7 @@
|
|||||||
:: ~& > hurl+[&2.b ire a]
|
:: ~& > hurl+[&2.b ire a]
|
||||||
(pass-note:abet [%of ire (gsig a)] b)
|
(pass-note:abet [%of ire (gsig a)] b)
|
||||||
::
|
::
|
||||||
++ init
|
++ init (jael-note:abet of+/[ire] %save-token ses ire)
|
||||||
=. die (add ~d1 now)
|
|
||||||
abet(mow :_(mow [`/ %pass ow+/[ire] [%b %wait die]]))
|
|
||||||
::
|
|
||||||
++ refresh
|
|
||||||
=. mow :_(mow [`/ %pass ow+/[ire] [%b %rest die]])
|
|
||||||
=. die (add ~d1 now)
|
|
||||||
done(mow :_(mow [`/ %pass ow+/[ire] [%b %wait die]]))
|
|
||||||
::
|
::
|
||||||
++ add-even
|
++ add-even
|
||||||
|= a/even ^+ eve
|
|= a/even ^+ eve
|
||||||
@ -1755,11 +1741,6 @@
|
|||||||
$rush ~[from+(subs-to-json p.ven) data+q.ven]
|
$rush ~[from+(subs-to-json p.ven) data+q.ven]
|
||||||
==
|
==
|
||||||
::
|
::
|
||||||
++ pass-wait (pass-note of+/[ire] [%b %wait era])
|
|
||||||
++ pass-rest
|
|
||||||
=. lyv (~(del by lyv) hen)
|
|
||||||
(pass-note of+/[ire] [%b %rest era])
|
|
||||||
::
|
|
||||||
++ pass-took
|
++ pass-took
|
||||||
|= a/{p/dock ?($mess $lens) wire}
|
|= a/{p/dock ?($mess $lens) wire}
|
||||||
%+ pass-note(hen `~)
|
%+ pass-note(hen `~)
|
||||||
@ -1792,9 +1773,20 @@
|
|||||||
appl+[%s q.a]
|
appl+[%s q.a]
|
||||||
path+(jape (spud b))
|
path+(jape (spud b))
|
||||||
==
|
==
|
||||||
++ wake ^+(..ix abet(ude ~)) :: XX other effects?
|
|
||||||
::
|
::
|
||||||
++ get-jael _!!
|
++ get-jael
|
||||||
|
=* jael-gift-token :: XX types
|
||||||
|
=> (mini-jael-gift /token-ack)
|
||||||
|
?>(?=(?($token-ack $token-dead $token-beat) -) _.)
|
||||||
|
|= a/jael-gift-token ^+ ..ix
|
||||||
|
?- -.a
|
||||||
|
$token-ack abet
|
||||||
|
$token-dead abut :: notify?
|
||||||
|
$token-beat
|
||||||
|
?~ pol abet :: recieved other response
|
||||||
|
~? !=(hen u.pol) [%oryx-beat-weird-duct hen]
|
||||||
|
(give-json:abet(pol ~, hen u.pol) 200 ~ (joba %beat %b &))
|
||||||
|
==
|
||||||
--
|
--
|
||||||
++ vi :: auth engine
|
++ vi :: auth engine
|
||||||
~% %eyre-v ..is ~
|
~% %eyre-v ..is ~
|
||||||
|
Loading…
Reference in New Issue
Block a user