adapter code

This commit is contained in:
Philip C Monk 2014-12-18 17:59:41 -05:00
parent 8bce45ea6b
commit 649f5a804d
5 changed files with 1009 additions and 165 deletions

View File

@ -57,7 +57,7 @@
== == == ::
++ riff ,[p=desk q=(unit rave)] :: see %clay
++ sign :: in result $<-
$?
$? ::
$: %c ::
$% [%writ p=riot] ::
== == ::
@ -66,12 +66,14 @@
[%mean p=ares] ::
[%nice ~] ::
$: %rush :: XX
$% [%term-line q=term-line] ::
$% [%term-line q=old-term-line] ::
[%term-line-2 q=term-line] ::
[%hymn q=manx] ::
[%json q=json] ::
== == ::
$: %rust ::
$% [%term-line q=term-line] ::
$% [%term-line q=old-term-line] ::
[%term-line-2 q=term-line] ::
[%hymn q=manx] ::
[%json q=json] ::
== == ::
@ -98,6 +100,8 @@
== == ::
++ term-line ,[p=[p=cord q=prom r=cord] q=(list cord) r=(list tark)]
++ tark ?(tank [%stem p=@da q=tank r=tank]) ::
++ old-term-line ,[p=[p=cord q=prom r=cord] q=(list cord) r=(list old-tark)]
++ old-tark ?(tank [%stem p=tank q=tank]) ::
:::::::: :: dill tiles
++ bein :: terminal control
$: $: bul=@ud :: buffer length
@ -322,42 +326,81 @@
%nice +>.$
%note ?.(p.yar +>.$ (fume p.+.sih q.+.sih)) :: debug message
?(%rush %rust) :: XX reset prompt
?> ?=(%term-line +>-.sih)
=. +>.$
=+ lis=?-(-.+.sih %rust (scag 1.000 r.q.sih), %rush r.q.sih)
=- (furl (zing (turn (flop lis) -)))
|= a=tark
^- wall
?+ -.a (~(win re a) 0 p.q.yar)
%stem
?: =(q.s.yar p.a) ~
~[(welp ~(ram re q.a) ~(ram re r.a))]
?+ +>-.sih !!
%term-line-2
=. +>.$
=+ lis=?-(-.+.sih %rust (scag 1.000 r.q.sih), %rush r.q.sih)
=- (furl (zing (turn (flop lis) -)))
|= a=tark
^- wall
?+ -.a (~(win re a) 0 p.q.yar)
%stem
?: =(q.s.yar p.a) ~
~[(welp ~(ram re q.a) ~(ram re r.a))]
==
%- edit
=| bed=bein
=+ ^= hyt ^- hist
=+ hyt=(~(get by r.yar) /)
?~(hyt *hist u.hyt)
?: &(?=(^ q.q.yar) =(/ hux.u.q.q.yar))
%= u.q.q.yar
bul ?~ r.p.q.sih bul.u.q.q.yar (met 3 r.p.q.sih)
bus ?~ r.p.q.sih bus.u.q.q.yar (met 3 r.p.q.sih)
but ?~ r.p.q.sih but.u.q.q.yar (rip 3 r.p.q.sih)
hyt [+(p.hyt) [%$ q.hyt]]
pot (trip p.p.q.sih)
pol (met 3 p.p.q.sih)
buy q.p.q.sih
==
%_ bed
bul (met 3 r.p.q.sih)
bus (met 3 r.p.q.sih)
but (rip 3 r.p.q.sih)
buy q.p.q.sih
hux /
hiz 0
hyt [+(p.hyt) [%$ q.hyt]]
pot (trip p.p.q.sih)
pol (met 3 p.p.q.sih)
==
%- edit
=| bed=bein
=+ ^= hyt ^- hist
=+ hyt=(~(get by r.yar) /)
?~(hyt *hist u.hyt)
?: &(?=(^ q.q.yar) =(/ hux.u.q.q.yar))
%= u.q.q.yar
bul ?~ r.p.q.sih bul.u.q.q.yar (met 3 r.p.q.sih)
bus ?~ r.p.q.sih bus.u.q.q.yar (met 3 r.p.q.sih)
but ?~ r.p.q.sih but.u.q.q.yar (rip 3 r.p.q.sih)
hyt [+(p.hyt) [%$ q.hyt]]
pot (trip p.p.q.sih)
pol (met 3 p.p.q.sih)
buy q.p.q.sih
::
%term-line
=. +>.$
=+ lis=?-(-.+.sih %rust (scag 1.000 r.q.sih), %rush r.q.sih)
=- (furl (zing (turn (flop lis) -)))
|= a=old-tark
^- wall
?+ -.a (~(win re a) 0 p.q.yar)
%stem
~[(welp ~(ram re p.a) ~(ram re q.a))]
==
%- edit
=| bed=bein
=+ ^= hyt ^- hist
=+ hyt=(~(get by r.yar) /)
?~(hyt *hist u.hyt)
?: &(?=(^ q.q.yar) =(/ hux.u.q.q.yar))
%= u.q.q.yar
bul ?~ r.p.q.sih bul.u.q.q.yar (met 3 r.p.q.sih)
bus ?~ r.p.q.sih bus.u.q.q.yar (met 3 r.p.q.sih)
but ?~ r.p.q.sih but.u.q.q.yar (rip 3 r.p.q.sih)
hyt [+(p.hyt) [%$ q.hyt]]
pot (trip p.p.q.sih)
pol (met 3 p.p.q.sih)
buy q.p.q.sih
==
%_ bed
bul (met 3 r.p.q.sih)
bus (met 3 r.p.q.sih)
but (rip 3 r.p.q.sih)
buy q.p.q.sih
hux /
hiz 0
hyt [+(p.hyt) [%$ q.hyt]]
pot (trip p.p.q.sih)
pol (met 3 p.p.q.sih)
==
%_ bed
bul (met 3 r.p.q.sih)
bus (met 3 r.p.q.sih)
but (rip 3 r.p.q.sih)
buy q.p.q.sih
hux /
hiz 0
hyt [+(p.hyt) [%$ q.hyt]]
pot (trip p.p.q.sih)
pol (met 3 p.p.q.sih)
==
::
%sage :: write a jamfile
@ -370,7 +413,7 @@
%_ +>.$
mos
:_ mos
[hen %pass /term-show %g %show [our /terminal] our /lines]
[hen %pass /term-show %g %show [our /terminal] our /lines-2]
==
::
%wake
@ -512,7 +555,7 @@
mos
:_ :_ mos
[hen %pass /term-show %g %nuke [our /terminal] our]
[hen %pass /term-show %g %show [our /terminal] our /lines]
[hen %pass /term-show %g %show [our /terminal] our /lines-2]
==
%p $(kyz [%belt %aro %u])
%u ?: =(0 bus.u.q.q.yar)

View File

@ -1,64 +1,838 @@
/- mess,user,users,zing,zong,*radio
::
:::: /hook/core/radio/app
::
/? 314
/- *radio
::/+ twitter
::
::::
::
!:
=> |%
++ axle
$% [%0 p=(map path ,[p=(list zong) q=(map ship ,?)])]
==
++ blitz
$% [%zong p=zong]
[%user p=user]
==
++ iron
$% [%zongs p=(list zong)]
[%users p=users]
==
++ gift
$% [%rush blitz]
[%rust iron]
[%mean ares]
[%nice ~]
==
++ move ,[p=bone q=(mold note gift)]
++ note ,~
=> |% :: data structures
++ house ,[%1 house-1] :: full state
++ house-any :: app history
$% [%1 house-1] :: 1: rodeo
[%0 house-0] :: 0: initial version
== ::
++ house-1 ::
$: parties=(map span party) :: conversations
general=(set bone) :: meta-subscribe
outbox=(pair ,@ud (map ,@ud thought)) :: urbit outbox
sent=(map ,@u serial) :: own tweets
folks=(map ship human) :: human identities
== ::
++ house-0 :: legacy state
%+ map path ::
,[p=(list zong) q=(map ship ,?)] ::
++ zong :: legacy messages
$% $: %mess p=@da q=ship ::
$= r ::
$% [%do p=@t] ::
[%exp p=@t q=tank] ::
[%say p=@t] ::
== == == ::
++ party :: a conversation
$: count=@ud :: (lent grams)
grams=(list telegram) :: all history
locals=(map ship (pair ,@da status)) :: local presence
remotes=(map station atlas) :: remote presence
sequence=(map station ,@ud) :: stations heard
shape=config :: configuration
known=(map serial ,@ud) :: messages heard
guests=(map bone river) :: message followers
viewers=(set bone) :: presence followers
owners=(set bone) :: config followers
== ::
++ river (pair point point) :: stream definition
++ point :: stream endpoint
$% [%ud p=@ud] :: by number
[%da p=@da] :: by date
== ::
++ gift :: result
$% [%rust %radio-report report] :: refresh
[%mean ares] :: cancel
[%nice ~] :: accept
== ::
++ sign :: response
$% $: %e :: from %eyre
$% [%thou p=httr] :: HTTP response
== == ::
$: %g :: application
$% [%mean p=ares] :: cancel
[%nice ~] :: acknowledge
[%rust %radio-report report] :: refresh
== == ::
$: %t ::
$% [%wake ~] :: timer wakeup
== == == ::
++ move ,[p=bone q=(mold note gift)] :: all actions
++ hapt ,[p=ship q=path] :: app instance
++ note :: requests
$% $: %c ::
$% [%info p=@p q=@tas r=nori] ::
== == ::
$: %e :: through %eyre
$% [%them p=(unit hiss)] :: HTTP request
== == ::
$: %g :: network
$% [%mess p=hapt q=ship r=cage] :: message
[%nuke p=hapt q=ship] :: cancel
[%show p=hapt q=ship r=path] :: subscribe
== == ::
$: %t ::
$% [%wait p=@da] ::
== == == ::
++ twim :: twitter endpoints
$%([%mine p=span] [%stat p=@uv])
--
|_ [hid=hide vat=axle]
++ grab
|= sta=path
(fall (~(get by p.vat) sta) *[p=(list zong) q=(map ship ,?)])
|_ [hid=hide house]
++ ti
=+ ^= key :: XX use %jael
:* :- 'AP3G1t8ki6rPzeeAqdWCTw03F'
'VV784LPwZSaAxtF16RWWTnST4F85BHN8VqQKNyv7MprCkA0xZD'
:- '2821727326-RZGXSeTn7hCFQfJqR0ViivM3YYpu2O1M71gelBl'
'jW9VygFPOTsEK0WmrJDHYSoEnofOPdCE1oQRzueemVTl8'
==
::=> ~(. twit key lat.hid `@`eny.hid)
=+ me=%hoontap :: XX use %khan
|%
++ sta |=(who=span [%| %twitter who])
++ post |=(cord *hiss) :: |=(a=cord `hiss`(stat-upda [%status a]~ ~))
++ mine *hiss :: `hiss`(stat-home)
::
++ line =- (ar:jo a) ::(ar:jo stat:twir) :: reparse timeline
a=*$+(json (unit ,[id=@u who=@ta now=@da txt=@t]))
--
::
++ ident
|= you=ship
%- (hard ,@t)
.^(%a (scot %p our.hid) %name (scot %da lat.hid) (scot %p you) ~)
::
++ peer
|= [ost=bone you=ship pax=path]
^- [(list move) _+>]
?~ pax
[[ost %give %mean ~ %radio-bad-path ~]~ +>.$]
=+ ya=(grab t.pax)
?+ -.pax [~ +>.$]
%mensajes
[[ost %give %rust %zongs p.ya]~ +>.$]
%amigos
=. q.ya (~(put by q.ya) you %.y)
:_ +>.$(p.vat (~(put by p.vat) t.pax ya))
:_ (send pax %give %rush %user %in you (ident you))
:* ost %give %rust %users
%+ murn (~(tap by q.ya))
|= [shi=ship liv=?]
?. liv
~
(some [shi (ident shi)])
++ ra :: transaction core
|_ [ost=bone moves=(list move)]
++ ra-abet :: resolve core
^- [(list move) _+>]
[(flop moves) +>]
::
++ ra-emil :: ra-emit move list
|= mol=(list move)
%_(+> moves (welp (flop mol) moves))
::
++ ra-emit :: emit a move
|= mov=move
%_(+> moves [mov moves])
::
++ ra-ever :: emit success
(ra-emit ost %give %nice ~)
::
++ ra-evil :: emit error
|= msg=cord
~& [%ra-evil msg]
(ra-emit ost %give %mean ~ msg ~)
::
++ ra-hiss :: emit http request
|= [pax=path hiz=hiss]
(ra-emit ost %pass pax %e %them ~ hiz)
::
++ ra-house :: emit stations
|= ost=bone
%+ ra-emit ost
:^ %give %rust %radio-report
:- %house
%- ~(gas in *(set span))
^- (list span)
(turn (~(tap by parties) ~) |=([a=span *] a))
::
++ ra-homes :: update stations
=+ gel=general
|- ^+ +>
?~ gel +>
=. +> $(gel l.gel)
=. +> $(gel r.gel)
(ra-house n.gel)
::
++ ra-apply :: apply command
|= [her=ship cod=command]
^+ +>
~& [%ra-apply cod]
?- -.cod
%design
?. =(her our.hid)
(ra-evil %radio-no-owner)
?~ q.cod
?. (~(has by parties) p.cod)
(ra-evil %radio-no-party)
=. +>.$ (ra-config p.cod *config)
ra-ever(parties (~(del by parties) p.cod))
=. +>.$ (ra-config p.cod u.q.cod)
ra-ever
::
%review ra-ever:(ra-think | her +.cod)
%publish ra-ever:(ra-think & her +.cod)
%ping (ra-notice her +.cod)
==
::
++ ra-config :: configure party
|= [man=span con=config]
^+ +>
=+ :- neu=(~(has by parties) man)
pur=(fall (~(get by parties) man) *party)
=. +>.$ pa-abet:(~(pa-reform pa man pur) con)
?:(neu +>.$ ra-homes)
::
++ ra-friend :: %friend response
|= [man=span sih=sign]
^+ +>
=+ pur=(~(get by parties) man)
?~ pur ~& [%ra-friend-none man] +>.$
pa-abet:(~(pa-friend pa man u.pur) sih)
::
++ ra-stalk :: %stalk response
|= [man=span tay=station sih=sign]
^+ +>
=+ pur=(~(get by parties) man)
?~ pur ~& [%ra-stalk-none man] +>.$
pa-abet:(~(pa-stalk pa man u.pur) tay sih)
::
++ ra-timer :: timeout
^+ .
=+ paz=parties
|- ^+ +>
?~ paz +>.$
=. +>.$ $(paz l.paz)
=. +>.$ $(paz r.paz)
pa-abet:~(pa-timer pa p.n.paz q.n.paz)
::
++ ra-twitter :: %twitter response
|= [met=twim sih=sign]
^+ +>
?> ?=(%thou +<.sih)
?. &(=(2 (div p.p.sih 100)) ?=(^ r.p.sih))
~& [%twit-lost met [p `(unit ,[@ @t])`r]:[p.sih .]]
+>
?- -.met
%stat
=+ =- sta=(need %.(q.u.r.p.sih ;~(biff poja a)))
a=*$+(json (unit ,[id=@u who=@ta now=@da txt=@t]))
~& [%tweet-ack p.met sta]
=. sent (~(put by sent) id:sta p.met)
+>.$
%mine
=+ pur=(~(get by parties) p.met) :: XX all subscribed
?~ pur ~& [%ra-twitter-none p.met] !!
=< pa-abet
%- ~(pa-lesson pa p.met u.pur)
%+ turn (need %.(q.u.r.p.sih ;~(biff poja line:ti)))
|= [id=@u who=@t now=@da txt=@t]
^- telegram
:* our.hid
((bond |.((shaf %twit id))) (~(get by sent) id))
[[(sta me):ti %received] `~]
now
[%say txt]
==
==
::
++ ra-repeat :: %repeat response
|= [num=@ud her=ship man=span sih=sign]
=+ oot=(~(get by q.outbox) num)
?~ oot ~& [%ra-repeat-none num] +>.$
=. q.outbox (~(del by q.outbox) num)
=. q.u.oot
%+ ~(put by q.u.oot)
[%& her man]
?+ sih !!
[%g %mean *] ~&([%radio-repeat-rejected num her man sih] %rejected)
[%g %nice ~] %received
==
(ra-think | her u.oot ~)
::
++ ra-cancel :: drop a bone
%_ .
general (~(del in general) ost)
parties
|- ^- (map span party)
?~ parties ~
:- :- p.n.parties
%= q.n.parties
guests (~(del by guests.q.n.parties) ost)
viewers (~(del in viewers.q.n.parties) ost)
owners (~(del in owners.q.n.parties) ost)
==
[$(parties l.parties) $(parties r.parties)]
==
::
++ ra-subscribe :: listen to
|= [her=ship pax=path]
^+ +>
:: ~& [%ra-subscribe pax]
?: ?=(~ pax)
(ra-house(general (~(put in general) ost)) ost)
?: ?=([%am @ ~] pax)
=+ pur=(~(get by parties) i.t.pax)
?~ pur
~& [%bad-subscribe-party-a i.t.pax parties]
(ra-evil %radio-no-party)
pa-abet:(~(pa-watch pa i.t.pax u.pur) her)
?: ?=([%xm @ ~] pax)
=+ pur=(~(get by parties) i.t.pax)
?~ pur
~& [%bad-subscribe-party-b i.t.pax]
(ra-evil %radio-no-party)
pa-abet:(~(pa-master pa i.t.pax u.pur) her)
?. ?=([%fm *] pax)
~& [%bad-subscribe-a pax]
(ra-evil %radio-bad-path)
?. &(?=([@ *] t.pax) ((sane %tas) i.t.pax))
~& [%bad-subscribe-b pax]
(ra-evil %radio-bad-path)
=+ pur=(~(get by parties) i.t.pax)
?~ pur
~& [%bad-subscribe-party-c i.t.pax]
(ra-evil %radio-no-party)
pa-abet:(~(pa-listen pa i.t.pax u.pur) her t.t.pax)
::
++ ra-think :: publish/review
|= [pub=? her=ship tiz=(list thought)]
^+ +>
?~ tiz +>
$(tiz t.tiz, +> (ra-consume pub her i.tiz))
::
++ ra-consume :: consume thought
|= [pub=? her=ship tip=thought]
=+ aud=`(list (pair station delivery))`(~(tap by q.tip) ~)
|- ^+ +>.^$
?~ aud +>.^$
$(aud t.aud, +>.^$ (ra-conduct pub her p.i.aud tip))
::
++ ra-notice :: declare presence
|= [her=ship vig=(map station presence)]
^+ +>
=+ sul=(~(tap by vig) ~)
|- ^+ +>.^$
?~ sul ra-ever
=. +>.^$ $(sul t.sul)
?- -.p.i.sul
%| +>.^$
%& ?: =(`ship`p.p.p.i.sul our.hid)
(ra-appear her q.p.p.i.sul q.i.sul)
?: =(her our.hid)
(ra-provoke p.p.p.i.sul i.sul)
(ra-evil %radio-unauthorized-presence)
==
::
++ ra-appear :: review presence
|= [her=ship man=span per=presence]
=^ who folks
=+ who=(~(get by folks) her)
?^ who [u.who folks]
=+ who=*human :: XX do right
[who (~(put by folks) her who)]
=+ pur=(~(get by parties) man)
?~ pur
~& [%bad-appear man]
(ra-evil %radio-no-party)
pa-abet:(~(pa-notify pa man u.pur) her per who)
::
++ ra-provoke :: forward presence
|= [him=ship tay=station per=presence]
%+ ra-emit ost
:* %pass
/provoke
%g
%mess
[him /radio]
our.hid
[%radio-command !>(`command`[%ping [[tay per] ~ ~]])]
==
::
++ ra-conduct :: thought to station
|= [pub=? her=ship tay=station tip=thought]
^+ +>
?- -.tay
%& ?: pub
=. her our.hid :: XX security!
?: =(her p.p.tay)
(ra-record q.p.tay p.p.tay tip)
(ra-transmit p.tay tip)
?: =(our.hid q.p.tay)
+>
(ra-record q.p.tay p.p.tay tip)
%| ?. pub +>
?- -.p.tay
%twitter
~& [%conduct-twitters p.p.tay]
?> =(me:ti p.p.tay)
=+ ^= msg
?+ -.q.r.tip !!
%say "{<her>}: {(trip p.q.r.tip)}"
%own "{<her>} {(trip p.q.r.tip)}"
==
?: (gth (lent msg) 140)
(ra-evil %radio-tweet-long)
%+ ra-hiss
/twitter/stat/(scot %uv p.tip)
(post:ti (crip msg))
== ==
::
++ ra-record :: add to party
|= [man=span gam=telegram]
^+ +>
=+ pur=(~(get by parties) man)
?~ pur
~& [%no-party man]
+>.$
pa-abet:(~(pa-learn pa man u.pur) gam)
::
++ ra-transmit :: send to neighbor
|= [cuz=cousin tip=thought]
^+ +>
=. +>
%+ ra-emit ost
:* %pass
/repeat/(scot %ud p.outbox)/(scot %p p.cuz)/[q.cuz]
%g
%mess
[p.cuz /radio]
our.hid
[%radio-command !>(`command`[%review tip ~])]
==
+>(p.outbox +(p.outbox), q.outbox (~(put by q.outbox) p.outbox tip))
::
++ pa :: party core
|_ $: man=span
party
==
++ pa-abet
^+ +>
+>(parties (~(put by parties) man `party`+<+))
::
++ pa-admire :: accept from
|= her=ship
^- ?
::?- -.cordon.shape
:: %& (~(has in p.cordon.shape) her)
:: %| !(~(has in p.cordon.shape) her)
::==
&
::
++ pa-timer :: timer expire
^+ .
=+ cul=(~(tap by locals) ~)
=+ ^= hay
%+ skim cul
|= [a=ship b=@da c=status]
(lte lat.hid (add ~m2 b))
?: =(cul hay) +>
%. viewers
pa-display(locals (~(gas by *(map ship (pair ,@da status))) hay))
::
++ pa-watch :: watch presence
|= her=ship
?. (pa-admire her)
(pa-sauce ost [[%mean ~ %radio-watch-unauthorized ~] ~])
=. viewers (~(put in viewers) ost)
(pa-display ost ~ ~)
::
++ pa-master :: hear config
|= her=ship
?. (pa-admire her)
(pa-sauce ost [[%mean ~ %radio-master-unauthorized ~] ~])
=. owners (~(put in owners) ost)
~& [%pa-master her man shape]
(pa-sauce ost [[%rust %radio-report %config shape] ~])
::
++ pa-display :: update presence
|= vew=(set bone)
=+ ^= reg
:_ remotes
|- ^- atlas
?~ locals ~
[[p.n.locals q.q.n.locals] $(locals l.locals) $(locals r.locals)]
~& [%pa-display man reg]
|- ^+ +>.^$
?~ vew +>.^$
=. +>.^$ $(vew l.vew)
=. +>.^$ $(vew r.vew)
(pa-sauce n.vew [[%rust %radio-report %group reg] ~])
::
++ pa-monitor :: update config
=+ owe=owners
|- ^+ +>
?~ owe +>
=. +> $(owe l.owe)
=. +> $(owe r.owe)
~& [%pa-monitor man shape]
(pa-sauce n.owe [[%rust %radio-report %config shape] ~])
::
++ pa-friend :: subscribed update
|= sih=sign
^+ +>
?+ sih ~&([%radio-bad-friend sih] !!)
[%g %nice ~]
~& %pa-friend-nice
+>.$
::
[%g %rust %radio-report *]
~& [%pa-friend-report +>+.sih]
?+ -.+>+.sih ~&([%radio-odd-friend sih] !!)
%grams
(pa-lesson q.+.+>+.sih)
==
==
::
++ pa-stalk :: subscribed present
|= [tay=station sih=sign]
^+ +>
?+ sih ~&([%radio-bad-friend sih] !!)
[%g %nice ~]
~& %pa-stalk-nice
+>.$
::
[%g %rust %radio-report *]
?+ -.+>+.sih ~&([%radio-odd-friend sih] !!)
%group
(pa-remind tay +.+>+.sih)
==
==
::
++ pa-scrub :: pass forward
|= [ost=bone bub=(list (pair path note))]
%_ +>.$
moves
(welp (flop (turn bub |=(a=(pair path note) [ost %pass a]))) moves)
==
::
++ pa-sauce :: send backward
|= [ost=bone gub=(list gift)]
%_ +>.$
moves
(welp (flop (turn gub |=(a=gift [ost %give a]))) moves)
==
::
++ pa-abjure :: unsubscribe move
|= tal=(list station)
%+ pa-scrub 0
%- zing
%+ turn tal
|= tay=station
?- -.tay
%| ~& tweet-abjure/p.p.tay
:_ ~
:- /twitter/mine/[p.p.tay]/[man]
?> =(me:ti p.p.tay)
[%e %them ~]
::
%& ~& [%pa-abjure [our.hid man] [p.p.tay q.p.tay]]
:~ :- /friend/nuke/[man]
[%g %nuke [p.p.tay /radio] our.hid]
:- /stalk/nuke/[man]
[%g %nuke [p.p.tay /radio] our.hid]
==
==
::
++ pa-acquire :: subscribe to
|= tal=(list station)
%+ pa-scrub 0
%- zing
%+ turn tal
|= tay=station
^- (list (pair path note))
=+ num=(fall (~(get by sequence) tay) 0)
?- -.tay
%| ~& tweet-acquire/p.p.tay
:_ ~
:- /twitter/mine/[p.p.tay]/[man]
?> =(me:ti p.p.tay)
[%e %them ~ mine:ti]
::
%& ~& [%pa-acquire [our.hid man] [p.p.tay q.p.tay]]
:~ :- /friend/show/[man]
[%g %show [p.p.tay /radio] our.hid /fm/[q.p.tay]/(scot %ud num)]
:- /stalk/show/[man]/(scot %p p.p.tay)/[q.p.tay]
[%g %show [p.p.tay /radio] our.hid /am/[q.p.tay]]
==
==
::
++ pa-reform :: reconfigure, ugly
|= cof=config
=+ ^= dif ^- (pair (list station) (list station))
=+ old=`(list station)`(~(tap in sources.shape) ~)
=+ new=`(list station)`(~(tap in sources.cof) ~)
:- (skip new |=(a=station (~(has in sources.shape) a)))
(skip old |=(a=station (~(has in sources.cof) a)))
=. +>.$ (pa-acquire p.dif)
=. +>.$ (pa-abjure q.dif)
=. shape cof
pa-monitor
::
++ pa-cancel :: unsubscribe from
^+ .
~& [%pa-cancel ost]
=. guests (~(del in guests) ost)
(pa-sauce ost [[%mean ~] ~])
::
++ pa-notify :: local presence
|= [her=ship saz=status]
^+ +>
=+ guz=(~(get by locals) her)
=. locals (~(put by locals) her lat.hid saz)
?. |(?=(~ guz) !=(saz q.u.guz))
+>.$
(pa-display viewers)
::
++ pa-remind :: remote presence
|= [tay=station loc=atlas rem=(map station atlas)]
=+ ^= buk
=+ mer=(turn (~(tap by rem) ~) |=([* a=atlas] a))
|- ^- atlas
?~ mer loc
=. loc $(mer t.mer)
=+ dur=`(list (pair ship status))`(~(tap by i.mer) ~)
|- ^- atlas
?~ dur loc
=. loc $(dur t.dur)
=+ fuy=(~(get by loc) p.i.dur)
?~ fuy (~(put by loc) p.i.dur q.i.dur)
?: =(`presence`p.q.i.dur `presence`p.u.fuy)
loc
?- p.u.fuy
%talk loc
%hear (~(put by loc) p.i.dur q.i.dur)
==
=+ gub=(~(get by remotes) tay)
~& [%pa-remind tay gub buk]
?. |(?=(~ gub) !=(buk u.gub))
+>.$
=. remotes (~(put by remotes) tay buk)
(pa-display viewers)
::
++ pa-start :: start stream
|= riv=river
^+ +>
=- =. +>.$ (pa-sauce ost [[%rust %radio-report %grams q.lab r.lab] ~])
?: p.lab
(pa-sauce ost [[%mean ~] ~])
+>.$(guests (~(put by guests) ost riv))
^= lab
=+ [end=count gaz=grams dun=| zeg=*(list telegram)]
~& [%river riv]
|- ^- (trel ,? ,@ud (list telegram))
?~ gaz [dun end (flop zeg)]
?: ?- -.q.riv :: after the end
%ud (lte p.q.riv end)
%da (lte p.q.riv p.r.q.i.gaz)
==
$(end (dec end), gaz t.gaz)
?: ?- -.p.riv :: before the start
%ud (lth end p.p.riv)
%da (lth p.r.q.i.gaz p.p.riv)
==
[dun end (flop zeg)]
$(end (dec end), gaz t.gaz, zeg [i.gaz zeg])
::
++ pa-listen :: subscribe
|= [her=ship pax=path]
^+ +>
?. (pa-admire her)
(pa-sauce ost [[%mean ~ %radio-listen-unauthorized ~] ~])
=+ ^= ruv ^- (unit river)
?: ?=(~ pax)
`[[%ud count] [%da (dec (bex 128))]]
?: ?=([@ ~] pax)
=+ say=(slay i.pax)
?. ?=([~ %$ ?(%ud %da) @] say) ~
`[(point +>.say) [%da (dec (bex 128))]]
?. ?=([@ @ ~] pax) ~
=+ [say=(slay i.pax) den=(slay i.t.pax)]
?. ?=([~ %$ ?(%ud %da) @] say) ~
?. ?=([~ %$ ?(%ud %da) @] den) ~
`[(point +>.say) (point +>.den)]
?~ ruv
(pa-sauce ost [[%mean ~ %radio-malformed ~] ~])
(pa-start u.ruv)
::
++ pa-refresh :: update stream
|= [num=@ud gam=telegram]
~& [%pa-refresh num gam]
=+ ^= moy
|- ^- (pair (list bone) (list move))
?~ guests [~ ~]
=+ lef=$(guests l.guests)
=+ rit=$(guests r.guests)
=+ old=[p=(welp p.lef p.rit) q=(welp q.lef q.rit)]
?: ?- -.q.q.n.guests :: after the end
%ud (lte p.q.q.n.guests num)
%da (lte p.q.q.n.guests p.r.q.gam)
==
[[p.n.guests p.old] [[p.n.guests %give %mean ~] q.old]]
?: ?- -.p.q.n.guests :: before the start
%ud (gth p.p.q.n.guests num)
%da (gth p.p.q.n.guests p.r.q.gam)
==
old
:- p.old
[[p.n.guests %give %rust %radio-report %grams num gam ~] q.old]
=. moves (welp q.moy moves)
|- ^+ +>.^$
?~ p.moy +>.^$
$(p.moy t.p.moy, guests (~(del by guests) i.p.moy))
::
++ pa-lesson :: learn multiple
|= gaz=(list telegram)
^+ +>
?~ gaz +>
$(gaz t.gaz, +> (pa-learn i.gaz))
::
++ pa-learn :: learn message
|= gam=telegram
^+ +>
?. (pa-admire p.gam)
~& %pa-admire-rejected
+>.$
=. q.q.gam (~(put by q.q.gam) [%& our.hid man] %received)
=+ old=(~(get by known) p.q.gam)
?~ old
(pa-append gam)
(pa-revise u.old gam)
::
++ pa-append :: append new
|= gam=telegram
^+ +>
%+ %= pa-refresh
grams [gam grams]
count +(count)
known (~(put by known) p.q.gam count)
==
count
gam
::
++ pa-revise :: revise existing
|= [num=@ud gam=telegram]
=+ way=(sub count num)
=. grams (welp (scag (dec way) grams) [gam (slag way grams)])
(pa-refresh num gam)
--
--
++ peer
|= [ost=bone her=ship pax=path]
^- [(list move) _+>]
:: ~& [%radio-peer ost her pax]
ra-abet:(~(ra-subscribe ra ost ~) her pax)
::
++ poke-radio-command
|= [ost=bone her=ship cod=command]
^- [(list move) _+>]
:: ~& [%radio-poke-command her cod]
ra-abet:(~(ra-apply ra ost ~) her cod)
::
++ pour
|= [ost=bone pax=path sih=*]
^- [(list move) _+>]
~& [%radio-pour ost pax sih]
:: ~& sih=sih
=+ sih=((hard sign) sih)
?+ pax ~& [%radio-strange-path pax] !!
::
[%provoke ~] [~ +>.$]
[%time ~]
?> ?=(0 ost)
=^ moz +>.$ ra-abet:~(ra-timer ra 0 ~)
:_(+>.$ :_(moz [0 %pass /time %t %wait (add ~s10 lat.hid)]))
::
[%twitter *]
=- ra-abet:(~(ra-twitter ra ost ~) met sih)
^= met
?+ t.pax ~& [%radio-twitter-strange-path pax] !!
[%mine @ @ ~]
[i.t.pax i.t.t.t.pax]
[%stat @ ~]
[i.t.pax (slav %uv i.t.t.pax)]
==
::
[%friend *]
?> ?=([@ @ ~] t.pax)
?. =(%show i.t.pax)
~& [%pour-friend-nuke-nuke pax]
[~ +>.$]
ra-abet:(~(ra-friend ra ost ~) i.t.t.pax sih)
::
[%stalk *]
?> ?=([@ @ @ @ ~] t.pax)
?. =(%show i.t.pax)
~& [%pour-friend-nuke-nuke pax]
[~ +>.$]
=+ [man tay]=[i.t.t.pax [%& (slav %p i.t.t.t.pax) i.t.t.t.t.pax]]
ra-abet:(~(ra-stalk ra ost ~) man tay sih)
::
[%repeat *]
?> ?=([@ @ @ ~] t.pax)
=+ [num her man]=[(slav %ud i.t.pax) (slav %p i.t.t.pax) i.t.t.t.pax]
ra-abet:(~(ra-repeat ra ost ~) num her man sih)
==
::
++ mamed
++ pull
|= ost=bone
^- [(list move) _+>]
~& [%radio-pull ost]
ra-abet:~(ra-cancel ra ost ~)
::
++ poke-bit
|= [ost=bone you=ship ~]
^- [(list move) _+>]
:_ +>.$
=+ paf=/(scot %p our.hid)/try/(scot %da lat.hid)/radio/backlog/jam
[ost %pass /jamfile %c %info our.hid (foal paf (jam +<+.+>.$))]~
::
++ prep
|= old=(unit (unit house-any))
^- [(list move) _+>]
=+ paf=/(scot %p our.hid)/try/(scot %da lat.hid)/radio/backlog/jam
:- [0 %pass /time %t %wait (add ~s10 lat.hid)]~
|-
?> ?=(^ old)
?~ u.old
?. ?=([%0 %0 %0] [.^(%cy paf)])
$(u.old (some ((hard house-any) (cue ((hard ,@) .^(%cx paf))))))
~& %radio-prep-new
+:ra-abet:(~(ra-apply ra 0 ~) our.hid %design %main `[~ [%| ~]])
~& %radio-prep-old
=- ~& > [%parties parties] -
|-
?- -.u.u.old
%1 %_(+>.^^$ +<+ u.u.old)
%0 $(u.u.old [%1 (house-0-to-house-1 +.u.u.old)])
==
::
++ house-0-to-house-1
|= vat=house-0
^- house-1
=- :* parties=-
general=~
outbox=[0 ~]
sent=~
folks=~
==
^- (map span party)
=- %- ~(run by -)
|= grams=(list telegram)
^- party
:* count=(lent grams)
grams=grams
locals=~
remotes=~
sequence=~
shape=[.(cordon [%| ~])]:*config
^= known %- mo ^- (list ,[serial @]) =< +
(roll grams |=([telegram a=@ b=(list ,[serial @])] [+(a) [a p.q] b]))
guests=~
viewers=~
owners=~
==
^- (map span (list telegram))
%- mo %+ turn (~(tap by p.vat))
%- mo %+ turn (~(tap by vat))
|= [a=path b=(list zong) c=(map ship ,?)]
=+ =+ (turn a |=(d=span leaf/(trip d)))
par=(crip ~(ram re %rose ["_" ~ ~] -))
=+ ^= par
?: =(/ a) 'hub'
=+ (turn a |=(d=span leaf/(trip d)))
(crip ~(ram re %rose ["_" ~ ~] -))
:- par
=+ aud=`audience`[[[%& our.hid par] %received] `~]
=+ ^= spe
@ -68,48 +842,7 @@
%do [%own p.r]
%exp [%exp p.r [~ q.r]]
==
%+ turn b
%+ turn b
|= d=zong ^- telegram
[q.d (sham eny.hid d) aud p.d (spe r.d)]
::
++ poke-zing
|= [ost=bone you=ship zig=zing]
^- [(list move) _+>]
=+ ya=(grab p.zig)
?. (~(has by q.ya) you)
[[ost %give %mean ~ %no-te-conozco ~]~ +>.$]
=+ zog=`zong`[%mess lat.hid you q.zig]
=. p.vat (~(put by p.vat) p.zig [[zog p.ya] q.ya])
:_ +>.$
:- [ost %give %nice ~]
(send mensajes/p.zig %give %rush %zong zog)
::
++ poke-bit
|= [ost=bone you=ship ~]
^- [(list move) _+>]
:_ +>.$
~& mamed
%+ turn (~(tap by sup.hid))
|= [ost=bone her=ship pax=path]
[ost %give %mean ~ %reload leaf/"please quit chat and re-enter" ~]
::
++ pull
|= ost=bone
^- [(list move) _+>]
=+ ^- (unit ,[his=ship pax=path])
(~(get by sup.hid) ost)
?~ - ~& %strange-pull [~ +>.$]
?. ?=([%mensajes *] pax.u)
[~ +>.$]
=+ sta=(~(got by p.vat) t.pax.u)
=. q.sta %+ ~(put by q.sta) his.u %.n
=. p.vat %+ ~(put by p.vat) t.pax.u sta
[(send amigos/t.pax.u %give %rush %user %out his.u (ident his.u)) +>.$]
::
++ send
|= [pax=path msg=(mold note gift)]
^- (list move)
:: ~& [%radi-sub pus.hid]
%+ turn (~(tap in (~(get ju pus.hid) pax)))
|=(ost=bone [ost msg])
--

View File

@ -9,7 +9,13 @@
:::: structures
::
|% ::
++ axle ::
++ axle ,[%0xdead.bef0 axle-1] :: full state
++ axle-any :: app history
$? [%0xdead.bef0 axle-1] :: 1: typing indicator
[%0xdead.beef axle-0] :: 0: initial version
axle-0 ::
== ::
++ axle-1 ::
$: tiv=? :: typing?
pid=@u :: next process id
pax=_`path`/=try= :: working directory
@ -19,6 +25,15 @@
pot=(map span ,[cord prom cord]) :: prompts
var=(map term vase) :: variables
== ::
++ axle-0 ::
$: pid=@u :: next process id
pax=_`path`/=try= :: working directory
act=(unit span) :: active child
pip=(map span span) :: pipe out->in
pop=(map span span) :: pipe in->out
pot=(map span ,[cord prom cord]) :: prompts
var=(map term vase) :: variables
== ::
++ gift ::
$% [%rush p=gilt] ::
[%init p=@p] ::
@ -517,4 +532,17 @@
?> ?=([%child span ?(%fork %out %main) ~] pax)
=+ abet:(purr:(ve hid ost vat) i.t.pax i.t.t.pax typ sih)
[-< +>.$(vat ->)]
::
++ prep
|= old=(unit (unit axle-any))
^- [(list move) _+>]
:- ~
?> ?=(^ old)
?~ u.old
+>.$
|-
?+ -.u.u.old $(u.u.old [%0xdead.beef u.u.old])
%0xdead.bef0 %_(+>.^$ +<+ ((hard axle) u.u.old))
%0xdead.beef $(u.u.old [%0xdead.bef0 %| ((hard axle-0) +.u.u.old)])
==
--

View File

@ -4,16 +4,27 @@
::
/? 314 :: need urbit 314
/- term-line, term-in, term-ctrl, kyev
/= stat /:/%%/:/hymn/
::/= stat /:/%%/:/hymn/
::
:::: structures
::
!:
|% ::
++ axle $: %1 ::
hiz=(map path term-line) ::
== ::
++ axle ,[%2 axle-2] ::
++ axle-any ::
$% [%1 axle-1] ::
[%2 axle-2] ::
== ::
++ axle-2 $=(hiz (map path term-line)) ::
++ axle-1 (map path old-term-line) ::
++ old-term-line ::
$: p=[p=cord q=prom r=cord] ::
q=(list cord) ::
r=(list ?(tank [%stem p=tank q=tank])) ::
== ::
++ gilt ::
$% [%term-line p=term-line] ::
$% [%term-line p=old-term-line] ::
[%term-line-2 p=term-line] ::
[%hymn p=manx] ::
== ::
++ gift ::
@ -28,7 +39,7 @@
[%veer p=@ta q=path r=@t] ::
[%vega p=path] ::
== ::
++ glas ?(%term %lines) ::
++ glas ?(%term %lines %lines-2) ::
++ hapt ,[p=ship q=path] ::
++ mess ::
$% [%txt p=(hypo cord)] ::
@ -37,7 +48,10 @@
== ::
++ move ,[p=bone q=(mold note gift)] ::
++ note ::
$% $: %g ::
$% $: %c ::
$% [%info p=@p q=@tas r=nori] ::
== == ::
$: %g ::
$% [%cide p=span] ::
[%show p=hapt q=ship r=path] ::
[%sire p=term q=span] ::
@ -103,18 +117,18 @@
[(flop mow) (~(put by hiz) pax tel)]
::
++ page
:: ;html
:: ;head
:: ;title: Not yet
:: ==
:: ;body;
:: ==
%. stat
%+ inject
~[%html %head]
;= ;script: urb.appl = "{(trip app.hid)}"
;script: urb.term = \{pax: "{(spud pax)}"}
;html
;head
;title: Not yet
==
;body;
==
:: %. stat
:: %+ inject
:: ~[%html %head]
:: ;= ;script: urb.appl = "{(trip app.hid)}"
:: ;script: urb.term = \{pax: "{(spud pax)}"}
:: ==
::
++ peer
|= gal=glas
@ -122,8 +136,9 @@
mow
:_ mow
?- gal
%term [ost %give %rust %hymn page] :: hymn front end
%lines [ost %give %rust %term-line tel] :: term-line output
%term [ost %give %rust %hymn page] :: hymn front end
%lines-2 [ost %give %rust %term-line-2 tel] :: term-line output
%lines [ost %give %rust %term-line (term-line-to-old-term-line tel)]
==
==
::
@ -168,7 +183,7 @@
==
::
++ poke-ctrl
.(mow :_(mow [ost %give %rush %term-line [p q ~]:tel]))
.(mow (welp (spam [p q ~]:tel) mow))
::
++ pour
|= [dis=?(%fork %resp %txt %kyev %type) sih=sign]
@ -225,8 +240,17 @@
(~(tap by sup.hid))
|= [ost=bone @ paf=path]
?: =([%lines pax] paf)
(some ost %give %rush %term-line tol)
(some ost %give %rush %term-line (term-line-to-old-term-line tol))
?: =([%lines-2 pax] paf)
(some ost %give %rush %term-line-2 tol)
~
::
++ term-line-to-old-term-line
|= term-line
^- old-term-line
:+ p q
%+ turn r
|=(?(tank [%stem p=@da q=tank r=tank]) ?.(?=(%stem +<-) +< [%stem q r]))
--
--
!:
@ -261,19 +285,34 @@
=+ sih=((hard sign) sih)
?: ?=(?(%sage %init %logo %verb %veer %vega) &2.sih) :: vomit
[[ost %give +.sih]~ +>.$]
?~ pax !!
?~ pax ~& %terminal-bad-path [~ +>.$]
?. ?=(?(%fork %resp %txt %kyev %type) i.pax) !!
=+ abet:(pour:(se hid ost our.hid hiz t.pax) i.pax sih)
[-< +>.$(hiz ->)]
::
++ prep
|= old=(unit (unit axle))
|= old=(unit (unit axle-any))
^- [(list move) _+>]
:- ~
%_ +>.$
hiz
?. ?=([~ ~ *] old) hiz
%- ~(run by hiz.u.u.old)
|=(term-line [p q ~])
=+ pax=|=(@tas [(scot %p our.hid) %arvo (scot %da lat.hid) +< %hoon ~])
:- :~ [0 %give %veer %d (pax %dill) (,@ .^(%cx (pax %dill)))]
==
=< %_(. hiz (~(run by hiz) |=(term-line [p q ~])))
?> ?=(^ old)
?~ u.old
+>.$
|-
?- -.u.u.old
%2 %_(+>.^$ +<+ u.u.old)
%1 $(u.u.old [%2 (axle-1-to-axle-2 +.u.u.old)])
==
::
++ axle-1-to-axle-2
|= vat=axle-1
^- axle-2
%- ~(run by vat)
|= old-term-line
^- term-line
:+ p q
%+ turn r
|=(?(tank [%stem p=tank q=tank]) ?.(?=(%stem +<-) +< [%stem *@da p q]))
--

View File

@ -1,6 +1,7 @@
::
:::: /hook/core/radio/sur
::
!:
|%
++ audience (map station delivery) :: destination/state
++ atlas (map ship status) :: presence map