urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-04 14:58:10 +03:00
Code Issues Packages Projects Releases Wiki Activity

Clean up requests from dead connections.

Browse Source
This commit is contained in:
C. Guy Yarvin 2014-04-14 11:01:18 -07:00
parent 3cd048c463
commit 20c6d005b3
5 changed files with 98 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

103
arvo/eyre.hoon
View File

@ -15,6 +15,7 @@
fon=(map ship rote) :: foreign servers
ask=[p=@ud q=(map ,@ud ,[p=duct q=hiss])] :: outgoing by number
kes=(map duct ,@ud) :: outgoing by duct
lor=(map duct dual) :: incoming by duct
== ::
++ cyst :: client session
$: ced=cred :: credential
@ -22,6 +23,7 @@
lax=@da :: last used
rey=[p=@ud q=(map ,@ud pimp)] :: live requests
== ::
++ dual ,[p=@ud q=(each ,[p=ship q=hole] ship)] :: request handle
++ dude ,[p=@tas q=@] :: client identity
++ loco ,[p=? q=(unit ,@tas) r=path] :: logical construct
++ pest :: request in progress
@ -200,6 +202,17 @@
[[sec (rash i.u.hot thor:epur)] p.ryp q.ryp]
==
(hell pul +.fav [p.heq mah s.heq])
::
%thud :: cancel request
=+ dul=(~(get by lor) hen)
?~ dul +.$
~& [%thud-dual dul]
=. lor (~(del by lor) hen)
?- -.q.u.dul
& =+ boy=(myth p.p.q.u.dul q.p.q.u.dul)
?~(boy +.$ abet:(idle:u.boy p.u.dul))
| (hops p.q.u.dul p.u.dul)
==
::
%thou :: remote return
?> ?=([@ *] tea)
@ -258,9 +271,11 @@
++ gout
|= [our=ship ses=hole num=@ud rot=riot]
^+ +>
=+ sef=`serf`(need (~(get by own) our))
=+ cyz=`cyst`(need (~(get by wup.sef) ses))
abet:work:(~(iota ya [our ses] sef cyz) num rot)
=+ suf=(~(get by own) our)
?~ suf +>.$
=+ cuz=(~(get by wup.u.suf) ses)
?~ cuz +>.$
abet:work:(~(iota ya [our ses] u.suf u.cuz) num rot)
::
++ hajj :: send %pr response
|= [him=ship tus=path har=httr]
@ -270,8 +285,12 @@
++ hare :: receive request
|= [tus=path him=ship hor=*]
^+ +>
=+ hyx=((hard httx) hor)
+>.$(mow :_(mow [wru [/e [%e (scot %p him) tus] hen] [%this hyx]]))
=+ hux=((hard (unit httx)) hor)
%_ +>.$
mow
:_ mow
[wru [/e [%e (scot %p him) tus] hen] ?~(hux [%thud ~] [%this u.hux])]
==
::
++ hell :: request, no ship
|= [pul=purl hyx=httx moh=moth]
@ -306,6 +325,19 @@
[%warp our rif]
==
::
++ hops :: cancel remote
|= [him=ship num=@]
^+ +>
=+ mun=(scot %ud num)
=+ rot=(need (~(get by fon) him))
%_ +>.$
mow
:_ mow
:+ [~ %gold sor.rot]
[/a [%e %hork mun ~] hen]
[%want him [%q %pr %e %hork mun ~] ~]
==
::
++ hork :: remote request
|= [him=ship hyx=httx]
^+ +>
@ -321,11 +353,12 @@
=+ num=p.rem.rot
=+ mun=(scot %ud num)
%_ +>.$
lor (~(put by lor) hen num [%| him])
mow
:_ mow
:+ [~ %gold sor.rot]
[/a [%e %hork mun ~] hen]
[%want him [%q %pr %e %hork mun ~] hyx]
[%want him [%q %pr %e %hork mun ~] [~ hyx]]
::
fon
%+ ~(put by fon) him
@ -455,7 +488,7 @@
%^ cat 3
(cat 3 (cat 3 pef.sef '=') ses)
:: (cat 3 '; HttpOnly' ?.(sec '' '; Secure'))
'; HttpOnly'
'; Path=/; HttpOnly'
::
now
[1 ~]
@ -466,6 +499,14 @@
|= fav=card
+>(mow :_(mow [wru hen fav]))
::
++ myth :: load session
|= [our=ship ses=hole]
=+ suf=(~(get by own) our)
?~ suf ~
=+ cuz=(~(get by wup.u.suf) ses)
?~ cuz ~
[~ u=~(. ya [our ses] u.suf u.cuz)]
::
++ ya :: session engine
=| [[our=ship ses=hole] serf cyst]
=* sef ->-
@ -546,16 +587,17 @@
=- =+ pey=(cat 3 (end 3 2 nep) %v)
=+ ven=+((,@ (need (sky %cw p.toe q.toe r.toe ~))))
=+ ^= cal :/
"call('".
"path='".
"/{(trip (rsh 3 1 p.toe))}".
"/{(trip pey)}".
"/{(scow %ud ven)}".
"/{(trip q.toe)}');"
[-.sac (weld `marl`+.sac `marl`[cal ~])]
"/{(trip q.toe)}';"
[-.sac [cal +.sac]]
^= sac
;script
;
; tries = 0;
; call = function(path) {
; call = function() {
; xhr = new XMLHttpRequest();
; xhr.open('GET', path, true);
; xhr.addEventListener('load', function() {
@ -572,6 +614,7 @@
; setTimeout(call,1000*tries);
; tries++;
; }
; call();
==
::
++ holy :: structured request
@ -615,11 +658,21 @@
?(%p %c %l) !!
==
::
++ into
++ idle :: cancel request
|= num=@ud
^+ +>
=+ pup=(~(get by q.rey) num)
?~ pup +>.$
=. q.rey (~(del by q.rey) num)
?. ?=(%way pez.u.pup) +>.$
+>.$(..ya (hoot our num ses `riff`[p.som.u.pup ~]))
::
++ into :: introduce
|= [pul=purl moh=moth]
^+ +>
=+ num=p.rey
%= +>.$
lor (~(put by lor) hen num [%& our ses])
p.rey +(num)
q.rey
%+ ~(put by q.rey) num
@ -634,9 +687,12 @@
++ iota :: change response
|= [num=@ud rot=riot]
^+ +>
=+ pip=`pimp`(need (~(get by q.rey) num))
?> ?=(%way pez.pip)
+>.$(q.rey (~(put by q.rey) num pip(pez [%haz rot])))
=+ pup=(~(get by q.rey) num)
?~ pup
~& [%iota-lost ses num rot]
+>.$
?> ?=(%way pez.u.pup)
+>.$(q.rey (~(put by q.rey) num u.pup(pez [%haz rot])))
::
++ lace :: load and execute
|= [pax=path sam=vase]
@ -981,22 +1037,6 @@
=+ sez=step
?: =(rey.sez rey) sez
$(+ sez)
::
++ into
|= [pul=purl moh=moth]
^+ +>
=+ num=p.rey
%= +>.$
p.rey +(num)
q.rey
%+ ~(put by q.rey) num
^- pimp
:* !?=(%head p.moh)
hen
*seam
`pest`[%raw pul moh]
==
==
--
--
--
@ -1009,6 +1049,7 @@
++ beat :: process move
|= [wru=(unit writ) tea=wire hen=duct fav=curd]
=> .(fav ((hard card) fav))
=. ney (shax :(mix (shax now) +(eny) ney)) :: XX!! shd not need
?: ?=(%crud -.fav)
[[[wru [/d hen] %flog fav] ~] ..^$]
^- [p=(list move) q=vane]

28
arvo/hoon.hoon
View File

@ -126,7 +126,6 @@
$= q ::
[p=?(~ axis) q=(list ,[p=type q=foot])] ::
== ::
++ reef ,[p=[p=? q=@ud] q=@ud] :: XX not used
++ rege $| ?(%dote %ende %sart %empt %boun %bout) :: parsed regex
$% [%lite p=char] :: literal
[%pair p=rege q=rege] :: ordering
@ -190,13 +189,13 @@
++ twig $& [p=twig q=twig] ::
$% ::
[%$ p=axis] :: blip, empty name
:: :::::: tile reductions
:: ::
[%bccb p=tile] :: bunt a tile
[%bccm p=tile] :: clam a tile
[%bcpt p=wing q=tile] :: whip p into q
[%bctr p=tile] :: static bunt w/ ^~
[%bczp p=base] :: bunt an axil
:: :::::: cores
:: ::
[%brcb p=tile q=(map term foot)] :: %gold tray, sample p
[%brcn p=(map term foot)] :: %gold core, natural
[%brdt p=twig] :: dry %gold trap
@ -208,7 +207,7 @@
[%brtr p=tile q=twig] :: vulcan. wet gate
[%brts p=tile q=twig] :: dry %gold gate
[%brwt p=twig] :: dry %lead trap
:: :::::: tuples
:: ::
[%clcb p=twig q=twig] :: [q p]
[%clcn p=tusk] :: [[p ~] ~]
[%clfs p=twig] :: [%$ [%$ p ~] ~]
@ -218,7 +217,7 @@
[%clsg p=tusk] :: [p ~]
[%cltr p=tusk] :: p as a tuple
[%clzz p=tusk] :: macro
:: :::::: invocations
:: ::
[%cncb p=wing q=tram] :: %=, then cast to p
[%cncl p=twig q=twig] :: pull $.p w/ sample q
[%cndt p=twig q=twig] :: %-(q p)
@ -230,8 +229,6 @@
[%cnts p=wing q=tram] :: eval. p w/ q changes
[%cnzy p=term] :: pulls limb p
[%cnzz p=wing] :: pulls p
:: ::
:: :: nock
:: ::
[%dtkt p=twig] :: Nock 11 data skyhook
[%dtls p=twig] :: Nock 4 increment
@ -7207,12 +7204,16 @@
%+ cook |=(a=(list tuna) a)
%+ ifix [gap ;~(plug gap duz)]
%+ most gap
;~ pfix
;~(plug sem ace)
%+ cook
|= a=tape
[%a %smdq (weld a `tape`[`@`10 ~])]
(star (shim 32 255))
;~ pfix sem
;~ pose
;~ pfix ace
%+ cook
|= a=tape
[%a %smdq (weld a `tape`[`@`10 ~])]
(star (shim 32 255))
==
(easy [%a %smdq `@`10 ~])
==
==
::
++ nol :: tall tail
@ -8348,6 +8349,7 @@
::
++ poke :: external apply
|= [now=@da ovo=ovum]
=. eny (mix eny (shax now))
^- [(list ovum) _+>]
=^ zef fan
(~(hurl (is eny vil bud fan) now) ovo)

1
arvo/zuse.hoon
View File

@ -2074,6 +2074,7 @@
[%they p=@ud q=httr] :: response to %them
[%this p=? q=clip r=httq] :: secure/src/req
[%thou p=httr] :: raw http response
[%thud ~] :: cancel http request
[%thug p=@p q=@p] :: sign in client
[%thus p=@ud q=(unit hiss)] :: http request/cancel
[%tory p=(list ,@t)] :: history dump

4
try/syn/web/template/htmn.hoon
View File

@ -11,9 +11,9 @@
=+ foo=`manx`i/;"foobarz"
=+ lam=`(list manx)`[lim lum lom ~]
;=
;title: Hi again!
;title: Hi foo!
;
;p: Hello, world. Goodbye! Hello! Typing...
;p: Hello, world. Goodbye! Hello! Typing... more typing...
;p:"Hello: pos is {<pos>}"
;- "Goodbye"
;+ ;p:"Hello again"

9
try/web/test.md
View File

@ -1 +1,8 @@
This is a trivial **markdown file**. When I type stuff, it appears!
#This is a header
This is a simple **markdown file**. When I type stuff, it appears!
I can get it to reload and everything...
But if there are multiple lines...
I really do expect a paragraph break, here, though. I don't