ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-16 19:22:22 +03:00
Code Issues Packages Projects Releases Wiki Activity
90c70cc916
urbit/app/talk-guardian.hoon

2066 lines
62 KiB
Plaintext
Raw Blame History

:: :: ::
:::: /hoon/talk/app :: ::
:: :: ::
::
::TODO rename to hall
::TODO master changes
::TODO char57 comments as line comments when regarding code.
::TODO avoid lark where possible
::TODO document what user-facing messages actually mean!
::TODO maybe have brokers accept reactions as well, redirect them to readers.
:: that way we can have foreign brokers react to our requests!
::TODO document gate samples fully.
::TODO ::> to :> etc.
::
::TODO we can't do away with the default mailbox because we need it for things
:: like invite notifications etc. can we do better than request that apps
:: don't use it frivolously?
::
::TODO crash on pokes/peers we do not expect
::
::TODO federation should not be present at all in delta-application cores. the
:: way changes are to be applied should be figured out by the delta-
:: geenration cores entirely.
::
::TODO for using moons as tmp identities for friends: stories may want to keep
:: lists of moons (or just ships in general?) that we define as "standalone"
:: so that the "convert to true identity" doesn't happen for them.
::
::TODO we need to have something for upward changes on burdens as well. we
:: could use entirely new query for this. to do so, we'd need to add
:: a new code path in front of changes that checks if it's not a config
:: change, and then redirects it to existing arms.
::
/? 151 ::< hoon version
/- talk ::< structures
/+ talk, time-to-id ::< libraries
/= seed /~ !>(.)
!:
::::
::
[. talk] ::TODO =,
=> ::> ||
::> || %arch
::> ||
::> data structures
::
|%
++ state ::> broker state
$: stories/(map knot story) ::< conversations
log/(map knot @ud) ::< logged to clay
nicks/(map ship knot) ::< nicknames
nak/(jug char (set partner)) ::< circle glyph lookup
== ::
++ story ::> wire content
$: count/@ud ::< (lent grams)
grams/(list telegram) ::< all messages
locals/group ::< local presence
remotes/(map partner group) ::< remote presence
shape/config ::< configuration
mirrors/(map circle config) ::< remote config
::TODO? never gets updated. still needed? ::
sequence/(map partner @ud) ::< partners heard
known/(map serial @ud) ::< messages heard
burden/? ::< from parent?
== ::
++ move (pair bone card) ::< all actions
++ lime ::> diff fruit
$% {$talk-prize prize} ::
{$talk-rumor rumor} ::
== ::
++ pear ::> poke fruit
$% {$talk-command command} ::
{$write-comment spur ship cord} ::
{$write-fora-post spur ship cord cord} ::
== ::
++ card ::> general card
$% {$diff lime} ::
{$info wire ship term nori} ::
{$peer wire dock path} ::
{$poke wire dock pear} ::
{$pull wire dock $~} ::
{$quit $~} ::
== ::
++ weir ::> parsed wire
$% {$repeat cir/circle} ::< messaging wire
{$circle nom/knot cir/circle} ::< subscription wire
== ::
--
::
::> ||
::> || %work
::> ||
::> functional cores and arms.
::
|_ {bol/bowl state}
::
++ prep ::< prepare state
::> adapts state.
::
|= old/(unit state)
^- (quip move ..prep)
?~ old
%- pre-bake
ta-done:ta-init:ta
[~ ..prep(+<+ u.old)]
::
::> ||
::> || %engines
::> ||
::> main cores.
::+|
::
++ ta ::< per transaction
::> thinker core, used for processing pokes into
::> deltas.
::
::TODO maybe rewrite all arms to produce (list delta)
:: instead of state? or nah?
|_ ::> deltas: deltas created by core operations.
::
deltas/(list delta)
::
++ ta-done ::< resolve core
::> produces the moves stored in ++ta's moves.
::> they are produced in reverse order because
::> ++ta-emil and ++ta-emit add them to the head of
::> the {moves}.
::> we don't produce any new state, because ++ta
::> doesn't make any changes to it itself.
::
^- (list delta)
(flop deltas)
::
::> ||
::> || %emitters
::> ||
::> arms that create outward changes.
::+|
::
++ ta-delta ::< emit a delta
::> adds a delta to the head of {deltas}.
::
|= dif/delta
%_(+> deltas [dif deltas])
::
++ ta-deltas ::< emit delta list
::> adds multiple deltas to the head of {deltas}.
::> flops to stay consistent with ++ta-delta.
::
|= dis/(list delta)
%_(+> deltas (welp (flop dis) deltas))
::
++ ta-note ::< tell user
::> sends {msg} as an %app message to the user's
::> inbox.
::
|= msg/cord
%^ ta-action 0 %phrase
:- [[%& our.bol (main our.bol)] ~ ~]
[%app %talk-guardian msg]~
::
++ ta-evil ::< emit error
::> tracing printf and crash.
::
|= msg/cord
~| [%talk-ta-evil msg]
!!
::
::> ||
::> || %data
::> ||
::> utility functions for data retrieval.
::+|
::
++ ta-know ::< story monad
::> produces a gill that takes a gate.
::> if the story {nom} exists, calls the gate with
::> a story core. if it doesn't, does nothing.
::
|= nom/knot
|= fun/$-(_so _ta)
^+ +>+>
=+ pur=(~(get by stories) nom)
?~ pur
%- ta-evil
(crip "no story '{(trip nom)}'")
(fun ~(. so nom ~ u.pur))
::
::> ||
::> || %interaction-events
::> ||
::> arms that apply events we received.
::+|
::
++ ta-init ::< initialize app
::> populate state on first boot.
::> creates our default mailbox and journal.
::
:: create default circles.
=> %+ roll
^- (list {security knot cord})
:~ [%brown (main our.bol) 'default home']
[%green ~.public 'visible activity']
==
|= {{typ/security nom/knot des/cord} _ta}
%+ ta-action ost.bol
[%create nom des typ]
%- ta-deltas
:: change inbox filter to allow everything.
:- :+ %story (main our.bol)
:+ %config [our.bol (main our.bol)]
[%filter [& &]]
:: if needed, subscribe to our parent's /burden.
=+ sen=(above our.bol)
?: ?| !=(%czar (clan sen))
=(sen our.bol)
=(%pawn (clan our.bol))
==
~
[%init ~]~
::
++ ta-apply ::< apply command
::> applies the command sent by {src}.
::
|= {src/ship cod/command}
^+ +>
?- -.cod
::> %publish commands prompt us (as a circle host)
::> to verify and distribute messages.
$publish (ta-think | src +.cod)
::> %present commands are used to ask us to set
::> someone's status in the indicated stories.
$present (ta-present src +.cod)
::> %bearing commands are used by our children to
::> let us know they're bearing our /burden. we
::> need to watch them to allow changes to go up.
$bearing (ta-observe src)
==
::
++ ta-present ::< update a status
::>
::
|= {who/ship nos/(set knot) dif/diff-status}
^+ +>
%- ta-deltas
%- ~(rep in nos)
|= {n/knot l/(list delta)}
:_ l
[%story n %status [%& our.bol n] who dif]
::
++ ta-action ::< apply reader action
::> performs action sent by a reader.
::
|= {red/bone act/action}
^+ +>
=< work
::> ||
::> || %actions
::> ||
::> action processing core
::>
::> ++work calls the appropriate action processing
::> arm. most use ++affect to retrieve the affected
::> story, crashing if it doesn't exist.
|%
:: || %utility
::+|
++ work ::< perform action
^+ ..ta-action
::TODO require deltas as product!
?- -.act
:: circle configuration
$create (action-create +.act)
$source (action-source +.act)
$depict (action-depict +.act)
$filter (action-filter +.act)
$permit (action-permit +.act)
$delete (action-delete +.act)
:: messaging
$convey (action-convey +.act)
$phrase (action-phrase +.act)
:: personal metadata
$notify (action-notify +.act)
$naming (action-naming +.act)
:: changing shared ui
$glyph (action-glyph +.act)
$nick (action-nick +.act)
==
::
++ affect ::< delta to story
::> store a delta about a story. if the story
::> does not exist, crash.
::
|= {nom/knot dif/diff-story}
?: (~(has by stories) nom)
(impact nom dif)
(ta-evil (crip "no story {(trip nom)}"))
::
++ impact ::< delta for story
::> Store a delta about a story.
::
|= {nom/knot dif/diff-story}
(ta-delta %story nom dif)
::
++ present ::< send status update
::>
::
|= {cis/(set circle) dif/diff-status}
^+ ..ta-action
=/ cic
^- (jug ship knot)
%- ~(rep in cis)
|= {c/circle m/(jug ship knot)}
(~(put ju m) hos.c nom.c)
=. ..ta-action ::TODO =?
?. (~(has by cic) our.bol) ..ta-action
%- ~(rep in (~(get ju cic) our.bol))
|= {n/knot _ta}
(affect n %status [%& our.bol n] our.bol dif)
=. cic (~(del by cic) our.bol)
%- ta-deltas
%- ~(rep by cic)
|= {{h/ship s/(set knot)} l/(list delta)}
:_ l
[%present h s dif]
::
::> || %circle-configuration
::+|
++ action-create ::< create story
::> creates a story with the specified parameters.
::
|= {nom/knot des/cord typ/security}
^+ ..ta-action
?. (~(has in stories) nom)
%^ impact nom %new
:* [[%& our.bol nom] ~ ~]
des
[| |]
:- typ
?. ?=(?($white $green) typ) ~
[our.bol ~ ~]
==
(ta-evil (crip "{(trip nom)}: already exists"))
::
++ action-delete ::< delete + announce
::> delete story {nom}, optionally announcing the
::> event with message {mes}.
::
|= {nom/knot mes/(unit cord)}
^+ ..ta-action
=. ..ta-action ::TODO =?
?~ mes ..ta-action
%+ action-phrase
[[%& our.bol nom] ~ ~]
[%lin | u.mes]~
(affect nom %remove ~)
::
++ action-depict ::< change description
::> change description of story {nom} to {des}.
::
|= {nom/knot cap/cord}
(affect nom %config [our.bol nom] %caption cap)
::
++ action-filter ::< change message rules
::> replaces the story's current filter with the
::> specified one.
::
|= {nom/knot fit/filter}
(affect nom %config [our.bol nom] %filter fit)
::
++ action-permit ::< invite/banish
::> invite to/banish from story {nom} all {sis}.
::
|= {nom/knot inv/? sis/(set ship)}
=+ soy=(~(get by stories) nom)
?~ soy
(ta-evil (crip "no story {(trip nom)}"))
so-done:(~(so-permit so nom ~ u.soy) inv sis)
::
++ action-source ::< un/sub p to/from r
::> add/remove {pas} as sources for story {nom}.
::
|= {nom/knot sub/? pos/(map partner range)}
=+ soy=(~(get by stories) nom)
?~ soy
(ta-evil (crip "no story {(trip nom)}"))
so-done:(~(so-sources so nom ~ u.soy) sub pos)
::
::> || %messaging
::+|
++ action-convey ::< post exact
::> sends the messages provided in the action.
::
|= tos/(list thought)
(ta-think & our.bol tos)
::
++ action-phrase ::< post easy
::> sends the message contents provided in the
::> action generating a serial and setting a
::> timestamp.
::
|= {pas/(set partner) ses/(list speech)}
^+ ..ta-action
=- (ta-think & our.bol tos)
|- ^- tos/(list thought)
?~ ses ~
=^ sir eny.bol (uniq eny.bol)
:_ $(ses t.ses)
[sir pas [now.bol i.ses]]
::
::> || %personal-metadata
::+|
::
++ action-notify ::< our presence update
::>
::
|= {cis/(set circle) pes/presence}
^+ ..ta-action
(present cis %presence pes)
::
++ action-naming ::< our name update
::>
::
|= {cis/(set circle) man/human}
^+ ..ta-action
(present cis %human %full man)
::
::> || %changing-shared-ui
::+|
++ action-nick ::< new identity
::> assigns a new local identity ("nickname") to the
::> target ship.
::
|= {who/ship nic/cord}
^+ ..ta-action
?. =((~(get by nicks) who) `nic) ..ta-action ::< no change
(ta-delta %nick who nic)
::
++ action-glyph ::< bind a glyph
::> un/bind glyph {lif} to partners {pas}.
::
|= {lif/char pas/(set partner) bin/?}
(ta-delta %glyph bin lif pas)
--
::
::> ||
::> || %subscription-events
::> ||
::> arms that react to subscription events.
::+|
::
++ ta-observe ::< watch burden bearer
::> subscribe to a child who is bearing our burden.
::
|= who/ship
^+ +>
?. =(our.bol (above who))
~&([%not-our-bearer who] +>)
(ta-delta %observe who)
::
++ ta-subscribe ::< listen to
::> add her to a presence list if applicable.
::
|= {her/ship qer/query}
^+ +>
?+ -.qer
+>
::
$burden
(ta-observe her)
::
$circle
%- (ta-know nom.qer) |= sor/_so =< so-done
(so-attend:sor her %hear [~ ~])
==
::
++ ta-cancel ::< forget
::> drops {src}'s subscription. deduce the right way
::> to do this from the subscription path {pax}.
::
|= {src/ship nom/knot}
^+ +>
:: set ship status to %gone.
%- (ta-know nom) |= sor/_so =< so-done
(so-absent:sor src)
::
++ ta-greet ::< subscription success
::> store a started subscription as source.
::
|= {nom/knot cir/circle}
%- (ta-know nom) |= sor/_so =< so-done
(so-greet:sor %& cir)
::
++ ta-leave ::< subscription failed
::> removes {cir} from story {nom}'s followers.
::
|= {nom/knot cir/circle}
%- (ta-know nom) |= sor/_so =< so-done
(so-leave:sor %& cir)
::
++ ta-take ::< apply prize
::> for a %burden prize, bear the burden in a new
::> or existing story.
::> for a %circle prize, use ++so to accept it.
::
|= {wir/wire piz/prize}
^+ +>
?+ -.piz
~&([%ignoring-prize -.piz] +>)
::
$burden
%+ roll (~(tap by sos.piz))
|= {{n/knot b/burden} _..ta-take}
=< so-done
(~(so-bear so n ~ (fall (~(get by stories) n) *story)) b)
::
$circle
=+ wer=(etch wir)
?> ?=($circle -.wer)
%- (ta-know nom.wer) |= sor/_so =< so-done
(so-take:sor cir.wer +.piz)
==
::
++ ta-hear ::< apply rumor
::> apply changes from a rumor to our state.
::> for %burden, authoratively apply the story
::> diff. if it's a new one, bear it.
::> for %circle, apply the story diff normally.
::
|= {wir/wire dif/rumor}
^+ +>
?+ -.dif
~&([%ignoring-rumor -.dif] +>)
::
$burden
?+ -.dif.dif
%- (ta-know nom.dif) |= sor/_so =< so-done
(so-hear:sor & [our.bol nom.dif] dif.dif)
::
$new
=< so-done
%- ~(so-bear so nom.dif ~ (fall (~(get by stories) nom.dif) *story))
[~ [cof.dif.dif ~] [~ ~]]
==
::
$circle
=+ wer=(etch wir)
?> ?=($circle -.wer)
%- (ta-know nom.wer) |= sor/_so =< so-done
(so-hear:sor | cir.wer dif.dif)
==
::
++ ta-repeat ::< message delivered
::> message got delivered. if an error was returned
::> mark the message as rejected. if not, received.
::
|= {who/partner fal/(unit tang)}
^+ +>
~? ?=(^ fal) u.fal
::TODO store delivery state locally
::?~(fal %received ~>(%slog.[0 u.fal] %rejected))
+>
::
::> ||
::> || %messaging
::> ||
::> arms for sending and processing messages.
::+|
::
++ ta-think ::< publish or review
::> consumes each thought.
::
|= {pub/? aut/ship tos/(list thought)}
^+ +>
?~ tos +>
$(tos t.tos, +> (ta-consume pub aut i.tos))
::
++ ta-consume ::< to each audience
::> conducts thought {tot} to each partner in its audience.
::
|= {pub/? aut/ship tot/thought}
=+ aud=(~(tap in aud.tot))
|- ^+ +>.^$
?~ aud +>.^$
$(aud t.aud, +>.^$ (ta-conduct pub aut i.aud tot))
::
++ ta-conduct ::< thought to partner
::> either publishes or records a thought.
::
|= {pub/? aut/ship pan/partner tot/thought}
^+ +>
?- -.pan
$& ::< circle partner
?: pub
?. (team our.bol aut)
%- ta-note
(crip "strange author {(scow %p aut)}")
=. aut our.bol
?: =(aut hos.p.pan)
(ta-record nom.p.pan hos.p.pan tot)
(ta-transmit p.pan tot)
?. =(our.bol hos.p.pan) +>
(ta-record nom.p.pan aut tot)
::
$| !! ::< passport partner
==
::
++ ta-record ::< add to story
::> add or update telegram {gam} in story {nom}.
::
|= {nom/knot gam/telegram}
%- (ta-know nom) |= sor/_so =< so-done
(so-learn:sor gam)
::
++ ta-transmit ::< send message
::> sends thought {tot} to {cir}.
::
|= {cir/circle tot/thought}
^+ +>
(ta-delta %out cir tot ~)
::
::> ||
::> || %stories
::> ||
::> arms for modifying stories.
::+|
::
++ so ::< story core
::> story core, used for doing work on a story.
::
|_ ::> nom: story name in {stories}.
::> acs: talk actions issued due to changes.
::> story is faceless to ease data access.
::
$: nom/knot
acs/(list action)
story
==
::
++ so-done ::< apply changes
::> put changed story back into the map and apply
::> actions.
::TODO update inline docs
::TODO maybe produce list of actions, apply in ++ta
::
^+ +>
=. acs (flop acs)
|- ^+ +>+
?~ acs +>+
=. +>+ (ta-action ost.bol i.acs)
$(acs t.acs)
::
::> ||
::> || %emitters
::> ||
::> arms that create outward changes.
::+|
::
++ so-act ::< send action
::> stores a talk action.
::
|= act/action
^+ +>
+>(acs [act acs])
::
++ so-note ::< tell user
::> sends {msg} as an %app message to the user's
::> inbox.
::
|= msg/cord
^+ +>
%+ so-act %phrase
:- [[%& our.bol (main our.bol)] ~ ~]
[%app %talk-guardian msg]~
::
++ so-delta ::< send delta
::> store delta in ++ta core.
::
::TODO maybe keep our own list of deltas, produce in done
|= dif/delta
^+ +>
+>(deltas [dif deltas])
::
++ so-deltas ::< send delta list
::> store multiple deltas in ++ta core.
::
|= dis/(list delta)
%_(+> deltas (welp (flop dis) deltas))
::
++ so-delta-our ::< send delta of us
::> adds a delta about this story.
::
|= dif/diff-story
^+ +>
(so-delta %story nom dif)
::
::> ||
::> || %data
::> ||
::> utility functions for data retrieval.
::+|
::
++ so-pan [%& our.bol nom] ::< us as partner
++ so-cir [our.bol nom] ::< us as circle
::
::> ||
::> || %interaction-events
::> ||
::> arms that apply events we received.
::+|
::
++ so-take ::< accept circle prize
::> apply the prize as if it were rumors.
::
|= {src/circle gaz/(list telegram) cos/lobby pes/crowd}
^+ +>
=. +>.$
(so-hear | src %config src %full loc.cos)
=. +>.$
%- ~(rep in loc.pes)
|= {{w/ship s/status} _+>.$}
(so-hear | src %status [%& src] w %full s)
(so-lesson gaz)
::
++ so-hear ::< accept circle rumor
::> apply changes from a rumor to this story.
::
|= {bur/? src/circle dif/diff-story}
^+ +>
:: check that we're still subscribed to this story
:: this is a small %gall bug, we shouldn't get these
::
~? ?! ?| (~(has in src.shape) [%& src])
=(src so-cir)
==
[%unexpected-rumor-source nom -.dif src]
?- -.dif
$new ?: =(src so-cir)
(so-config-full ~ cof.dif)
$(dif [%config src %full cof.dif])
$bear ~&(%so-bear (so-bear bur.dif))
$burden ~&(%burden-not-rumor +>)
$grams (so-lesson gaz.dif)
$config :: full changes to us need to get split up.
?: &(=(cir.dif so-cir) ?=($full -.dif.dif))
(so-config-full `shape cof.dif.dif)
:: remotes are fine.
?: =(src cir.dif)
(so-delta-our dif)
:: remotes of remotes are not.
~& %ignoring-remote-config
~? =(src so-cir) %but-src-is-us
+>
$status :: ignore foreign remotes.
?. |(=([%& src] pan.dif) =(src so-cir))
~& %ignoring-remote-status
+>
(so-delta-our dif)
$follow ~&(%follow-not-rumor +>) ::REVIEW
$remove (so-delta-our %config src %remove ~)
==
::
++ so-bear ::< accept burden
::> add what was pushed down from above to our
::> state. in case of conflict, existing data is
::> overwritten.
::
|= {gaz/(list telegram) cos/lobby pes/crowd}
^+ +>
=* self +>
:: local config
=. self
(so-config-full `shape loc.cos)
:: remote config
=. self
%+ roll (~(tap by rem.cos))
|= {{r/circle c/config} _self}
(so-delta-our %config r %full c)
:: local presence
=. self
%+ roll (~(tap by loc.pes))
|= {{w/ship s/status} _self}
(so-delta-our %status so-pan w %full s)
:: remote presence
=. self
%+ roll (~(tap by rem.pes))
|= {{p/partner g/group} _self}
%+ roll (~(tap by g))
|= {{w/ship s/status} _self}
(so-delta-our %status p w %full s)
:: telegrams
=. self
%+ so-delta-our %grams
%+ turn gaz
|= t/telegram
:: in audience, replace above with us.
=- t(aud.tot -)
=+ (~(del in aud.tot.t) [%& (above our.bol) nom])
(~(put in -) so-pan)
:: burden flag
(so-delta-our %burden &)
::
::> ||
::> || %changes
::> ||
::> arms that make miscellaneous changes to this story.
::+|
::
++ so-config-full ::< split full config
::> split a %full config delta up into multiple
::> smaller ones, for easier application.
::TODO mention side-effects
::
|= {old/(unit config) cof/config}
^+ +>
%- so-deltas
%+ turn
%+ weld
^- (list diff-story)
?~ old ~
::TODO? what to do about src?
:~ ::[%follow | src.u.old]
[%config so-cir %permit | ses.con.u.old]
==
^- (list diff-story)
:~ ::[%follow & src.cof]
[%config so-cir %caption cap.cof]
[%config so-cir %filter fit.cof]
[%config so-cir %secure sec.con.cof]
[%config so-cir %permit & ses.con.cof]
==
|= d/diff-story
[%story nom d]
::
++ so-sources ::< change source
::> adds or removes {pas} from our sources.
::
::TODO should ++action-source make use of this,
:: because of the {sus} logic?
|= {add/? pos/(map partner range)}
^+ +>
::TODO for new sources, follow.
:: for existing sources, unfollow and refollow
:: with new range?
::=/ sus/(set partner)
:: %. src.shape
:: ?:(add ~(dif in pas) ~(int in pas))
::?~ sus +>.$
(so-delta-our %follow & pos)
::
++ so-depict ::< change description
::> modifies our caption.
::
|= cap/cord
^+ +>
?: =(cap cap.shape) +>
(so-delta-our %config so-cir %caption cap)
::
++ so-filter ::< change message rules
::> modifies our filter.
::
|= fit/filter
^+ +>
?: =(fit fit.shape) +>
(so-delta-our %config so-cir %filter fit)
::
++ so-delete ::< delete story
::> deletes this story. removes it from {stories}
::> and unsubscribes from all src.
::
(so-delta-our %remove ~)
::
++ so-attend ::< add local presence
::> add {her} status to this story's presence map.
::
|= {her/ship sat/status}
^+ +>
?: =(`sat (~(get by locals) her)) +>.$
(so-delta-our %status so-pan her %full sat)
::
++ so-absent ::< del local presence
::> remove {her} from our presence map.
::
|= her/ship
^+ +>
?. (~(has by locals) her) +>
(so-delta-our %status so-pan her %remove ~)
::
::> ||
::> || %subscriptions
::> ||
::> arms for starting and ending subscriptions
::+|
::
++ so-greet ::< subscription started
::> store a started subscription as source.
::
|= pan/partner
^+ +>
?: (~(has in src.shape) pan) +>
(so-delta-our %config so-cir %source & pan)
::
++ so-leave ::< subscription ended
::> delete {pan} from our sources.
::
|= pan/partner
^+ +>
?. (~(has in src.shape) pan) +>
(so-delta-our %config so-cir %source | pan)
::
++ so-first-grams ::< beginning of stream
::> find all grams that fall within the range.
::
::TODO strip unused vars.
|= ran/range
^- (list telegram)
=+ [num=0 gaz=grams zeg=*(list telegram)]
:: fill in empty ranges to select all grams.
=. ran
?~ ran `[[%ud 0] `[%ud count]]
?~ tal.u.ran `[hed.u.ran `[%ud count]]
ran
:: never fails, but compiler needs it.
?> &(?=(^ ran) ?=(^ tal.u.ran))
%- flop
|- ^- (list telegram)
?~ gaz zeg
?: ?- -.u.tal.u.ran :: after the end
$ud (lth +.u.tal.u.ran num)
$da (lth +.u.tal.u.ran wen.sam.tot.i.gaz)
==
:: if past the river, we're done searching.
zeg
?: ?- -.hed.u.ran :: before the start
$ud (lth num +.hed.u.ran)
$da (lth wen.sam.tot.i.gaz +.hed.u.ran)
==
:: if before the river, continue onward.
$(num +(num), gaz t.gaz)
:: if in the river, add this gram and continue.
$(num +(num), gaz t.gaz, zeg [i.gaz zeg])
::
++ so-in-range ::< place in range?
::> produces two booleans: whether we're
::> currently in the range, and whether the range
::> has passed.
::
|= ran/range
^- {in/? done/?}
?~ ran [& |]
=/ min
?- -.hed.u.ran
$ud (gth count +.hed.u.ran)
$da (gth now.bol +.hed.u.ran)
==
?~ tal.u.ran
[min |]
=- [&(min -) !-]
?- -.u.tal.u.ran
$ud (gte +(+.u.tal.u.ran) count)
$da (gte +.u.tal.u.ran now.bol)
==
::
::> ||
::> || %messaging
::> ||
::> arms for adding to this story's messages.
::+|
::
++ so-sane ::< sanitize
::> sanitize %lin speech according to our settings.
::
|= tot/thought
^- thought
?. ?=({$lin *} sep.sam.tot) tot
%_ tot
msg.sep.sam
%- crip
%- tufa
%+ turn (tuba (trip msg.sep.sam.tot))
|= a/@c
:: always replace control characters.
?: |((lth a 32) =(a `@c`127))
`@`'?'
:: if desired, remove uppercasing.
?: ?& !cas.fit.shape
(gte a 'A')
(lte a 'Z')
==
(add a 32)
:: if desired, replace non-ascii characters.
?: ?& !utf.fit.shape
(gth a 127)
==
`@`'?'
a
==
::
++ so-lesson ::< learn messages
::> learn all telegrams in a list.
::
|= gaz/(list telegram)
^+ +>
?~ gaz +>
$(gaz t.gaz, +> (so-learn i.gaz))
::
++ so-learn ::< save/update message
::> store an incoming telegram, updating if it
::> already exists.
::
|= gam/telegram
^+ +>
:: check for write permissions.
?. (so-admire aut.gam) +>
:: clean up the message to conform to our rules.
=. tot.gam (so-sane tot.gam)
(so-delta-our %grams [gam ~])
::
::> ||
::> || %permissions
::> ||
::> arms relating to story permissions.
::+|
::
++ so-permit ::< invite/banish
::> update config to dis/allow ships permission.
::
|= {inv/? sis/(set ship)}
^+ +>
::> wyt: whitelist?
::> add: add to list?
=/ wyt/? ?=(?($white $green) sec.con.shape)
=/ add/? =(inv wyt)
=/ sus/(set ship)
%. ses.con.shape
?:(add ~(dif in sis) ~(int in sis))
=. +>.$
%- so-act
:- %phrase
%- ~(rep in sus)
|= {s/ship a/(set partner) t/(list speech)}
:- (~(put in a) [%& s (main s)])
[[%inv inv so-cir] t]
(so-delta-our %config so-cir %permit [add sus])
::
++ so-admire ::< accept from
::> checks {her} write permissions.
::
|= her/ship
^- ?
?- sec.con.shape
$black !(~(has in ses.con.shape) her) ::< channel, blacklist
$white (~(has in ses.con.shape) her) ::< village, whitelist
$green (~(has in ses.con.shape) her) ::< journal, whitelist
$brown !(~(has in ses.con.shape) her) ::< mailbox, blacklist
==
::
++ so-visible ::< display to
::> checks {her} read permissions.
::
|= her/ship
^- ?
?- sec.con.shape
$black !(~(has in ses.con.shape) her) ::< channel, blacklist
$white (~(has in ses.con.shape) her) ::< village, whitelist
$green & ::< journal, all
$brown (team our.bol her) ::< mailbox, our team
==
--
--
::
++ da ::< delta application
::> core for doing things, mostly applying deltas to
::> application state, but also dealing with events
::> that aren't pokes.
::> where appropriate, creates moves. those get
::> produced when finalizing with ++da-done.
::
|_ ::> moves: moves created by core operations.
::
moves/(list move)
::
++ da-done ::< resolve core
::> produces the moves stored in ++da's moves.
::> they are produced in reverse order because
::> ++da-emil and ++da-emit add them to the head of
::> the {moves}.
::
^- (quip move +>)
[(flop moves) +>]
::
::> ||
::> || %emitters
::> ||
::> arms that create outward changes.
::+|
::
++ da-emil ::< emit move list
::> adds multiple moves to the head of {moves}.
::> flops to stay consistent with ++ta-emit.
::
|= mol/(list move)
%_(+> moves (welp (flop mol) moves))
::
++ da-emit ::< emit a move
::> adds a move to the head of {moves}.
::
|= mov/move
%_(+> moves [mov moves])
::
++ da-present ::< send %present cmd
::>
::
|= {hos/ship nos/(set knot) dif/diff-status}
^+ +>
%- da-emit
:* ost.bol
%poke
/present
[hos %talk-guardian]
[%talk-command %present nos dif]
==
::
::> ||
::> || %change-application
::> ||
::> arms that change the application state.
::+|
::
++ da-change ::< apply delta
::> modifies application state according to the
::> change specified in {dif}.
::
|= dif/delta
^+ +>
?- -.dif
$out (da-change-out +.dif)
$glyph (da-change-glyph +.dif)
$nick (da-change-nick +.dif)
$story (da-change-story +.dif)
$init da-init
$observe (da-observe +.dif)
$present (da-present +.dif)
$quit (da-emit [ost.dif %quit ~])
==
::
++ da-init ::< startup side-effects
::> apply %init delta, querying the /burden of the
::> ship above us.
::
%- da-emit
:* 0
%peer
/burden
[(above our.bol) %talk-guardian]
/burden/(scot %p our.bol)
==
::
++ da-observe ::< watch burden bearer
::> apply %observe delta, querying the /report of
::> {who} below us.
::
|= who/ship
~& [%peering-report who]
%- da-emit
:* 0
%peer
/report/(scot %p who)
[who %talk-guardian]
/report
==
::
++ da-change-out ::< outgoing messages
::> apply an %out delta, sending a message.
::
|= {cir/circle out/(list thought)}
^+ +>
~& [%da-change-out hos.cir]
%+ da-emit ost.bol
:* %poke
/repeat/(scot %p hos.cir)/[nom.cir]
[hos.cir %talk-guardian]
[%talk-command %publish out]
==
::
++ da-change-glyph ::< un/bound glyph
::> apply a %glyph delta, un/binding a glyph to/from
::> a set of partners.
::
|= {bin/? gyf/char pas/(set partner)}
^+ +>
?: bin
%_ +>
nak (~(put ju nak) gyf pas)
==
=/ ole/(list (set partner))
?. =(pas ~) [pas ~]
(~(tap in (~(get ju nak) gyf)))
|- ^+ +>.^$
?~ ole +>.^$
%_ $
nak (~(del ju nak) gyf i.ole)
ole t.ole
==
::
++ da-change-nick ::< changed nickname
::> apply a %nick delta, setting a nickname for a
::> ship.
::
|= {who/ship nic/cord}
^+ +>
+>(nicks (change-nicks nicks who nic))
::
::> ||
::> || %stories
::> ||
::> arms for modifying stories.
::+|
::
++ da-change-story ::< apply circle delta
::> apply a %story delta, redirecting the delta
::> itself to ++sa-change.
::> in case of a new or deleted story, specialized
::> arms are called.
::
|= {nom/knot dif/diff-story}
^+ +>
?+ -.dif
=< sa-done
%. dif
%~ sa-change sa nom
%+ fall
(~(get by stories) nom)
%*(. *story burden |)
==
::
$new (da-create nom +.dif)
$bear ~&(%unexpected-unsplit-bear +>)
$remove (da-delete nom)
==
::
++ da-create ::< configure story
::> creates story {nom} with config {con}.
::
|= {nom/knot cof/config}
^+ +>
=< sa-done
:: default for ? is &, so we manually set to | now.
%- ~(sa-change sa nom %*(. *story burden |))
[%config [our.bol nom] %full cof]
::
++ da-delete ::< delete story
::> calls the story core to delete story {nom}.
::
|= nom/knot
^+ +>
=. +>
%- da-emil
~(sa-delete sa nom (~(got by stories) nom))
+>(stories (~(del by stories) nom))
::
++ sa ::< story delta core
::> story core, used for doing work on a story.
::
|_ ::> nom: story name in {stories}.
::> story is faceless to ease data access.
::
$: nom/knot
story
==
::
++ sa-done ::< apply changes
::> put changed story back into the map.
::
+>(stories (~(put by stories) nom +<+))
::
::> ||
::> || %emitters
::> ||
::> arms that create outward changes.
::+|
::
++ sa-emil ::< emit move list
::> adds multiple moves to the head of {moves}.
::> flops to stay consistent with ++ta-emit.
::
|= mol/(list move)
%_(+> moves (welp (flop mol) moves))
::
++ sa-emit ::< emit a move
::> adds a move to the head of {moves}.
::
|= mov/move
%_(+> moves [mov moves])
::
++ sa-sauce ::< play cards
::> cards to moves.
::
|= {ost/bone cub/(list card)}
^- (list move)
(flop (turn cub |=(a/card [ost a])))
::
::> ||
::> || %data
::> ||
::> utility functions for data retrieval.
::+|
::
++ sa-cir [our.bol nom]
++ sa-pan [%& our.bol nom]
::
::> ||
::> || %delta-application
::> ||
::> arms for applying deltas.
::+|
::
++ sa-delete ::< deletion of story
::> apply a %remove story delta, unsubscribing
::> this story from all its active sources.
::
(sa-abjure (~(tap in src.shape)))
::
++ sa-change ::< apply circle delta
::> figure out whether to apply a %story delta to
::> local or remote data.
::
|= dif/diff-story
^+ +>
%. dif
?+ -.dif
sa-change-local
::
$config
?: =(cir.dif sa-cir)
sa-change-local
sa-change-remote
::
$status
?: =(pan.dif sa-pan)
sa-change-local
sa-change-remote
==
::
++ sa-change-local ::< apply our delta
::> apply a %story delta to local data.
::
|= dif/diff-story
^+ +>
?+ -.dif
~&([%unexpected-delta-local -.dif] !!)
::
$burden
+>(burden bur.dif)
::
$grams
|- ^+ +>.^$
?~ gaz.dif +>.^$
=. +>.^$ (sa-change-gram i.gaz.dif)
$(gaz.dif t.gaz.dif)
::
$config
=. +>
%- sa-emil
(sa-config-effects shape dif.dif)
+>(shape (change-config shape dif.dif))
::
$status
%_ +>
locals
%+ ~(put by locals) who.dif
%+ change-status
(fall (~(get by locals) who.dif) *status)
dif.dif
==
::
$follow
(sa-emil (sa-follow-effects sub.dif pas.dif))
==
::
++ sa-change-gram ::< save/update message
::> apply a %grams delta, either appending or
::> updating a message.
::
|= gam/telegram
^+ +>
=+ old=(~(get by known) uid.tot.gam)
?~ old
:: new message
%_ +>.$
grams (welp grams [gam ~])
count +(count)
known (~(put by known) uid.tot.gam count)
==
:: changed message
=+ dex=(sub count u.old)
%_ +>.$
grams %+ welp
(scag (dec dex) grams)
[gam (slag dex grams)]
==
::
++ sa-change-remote ::< apply remote's delta
::> apply a story diff to remote data.
::
::TODO split?
|= dif/diff-story
^+ +>
?+ -.dif
~&([%unexpected-delta-remote -.dif] !!)
::
$config
?: ?=($remove -.dif.dif)
+>(mirrors (~(del by mirrors) cir.dif))
=/ new/config
%+ change-config
(fall (~(get by mirrors) cir.dif) *config)
dif.dif
+>.$(mirrors (~(put by mirrors) cir.dif new))
::
$status
%_ +>.$
remotes
%+ ~(put by remotes) pan.dif
=+ ole=(fall (~(get by remotes) pan.dif) *group)
?: ?=($remove -.dif.dif) (~(del by ole) who.dif)
=+ old=(fall (~(get by ole) who.dif) *status)
(~(put by ole) who.dif (change-status old dif.dif))
==
==
::
++ sa-config-effects ::< config side-effects
::> apply side-effects for a %config delta.
::
|= {old/config dif/diff-config}
^- (list move)
?+ -.dif ~
$permit (sa-permit-effects sec.con.old ses.con.old +.dif)
::NOTE when doing a lone %secure, calculate the
:: necessary %permit deltas alongside it.
==
::
++ sa-follow-effects ::< un/subscribe
::> apply side-effects for a %follow delta,
::> un/subscribing this story to/from {pas}.
::
|= {sub/? pos/(map partner range)}
^- (list move)
?: sub
(sa-acquire (~(tap by pos)))
(sa-abjure (~(tap in (key-by pos))))
::
++ sa-permit-effects ::< notify permitted
::> apply side-effects for a %permit delta,
::> kicking the subscriptions of {sis} if they
::> are being banished.
::
|= {sec/security old/(set ship) add/? sis/(set ship)}
^- (list move)
=/ wyt ?=(?($white $green) sec)
=/ inv =(wyt add)
?: inv ~
=/ sus/(set ship)
%. ses.con.shape
?:(add ~(dif in sis) ~(int in sis))
(sa-eject sus)
::
::> ||
::> || %subscriptions
::> ||
::> arms for starting and ending subscriptions
::+|
::
++ sa-acquire ::< subscribe us
::> subscribes this story to each partner.
::
|= pas/(list (pair partner range))
%+ sa-sauce 0 :: subscription is caused by this app
%- zing
%+ turn pas
|= {pan/partner ran/range}
^- (list card)
?: =(pan sa-pan) ~ :: ignore self-subs
:: unless otherwise specified, subscribe starting
:: at the last message we heard.
=. ran ::TODO =?
?^ ran ran
=+ num=(~(get by sequence) pan)
?~ num `[[%ud 0] ~]
`[[%ud u.num] ~]
?- -.pan
$| !! ::< passport partner
::
$& ::< circle partner
:_ ~
(circle-peer nom p.pan ran)
==
::
++ sa-abjure ::< unsubscribe us
::> unsubscribes this story from each partner.
::
|= pas/(list partner)
%+ sa-sauce 0 :: subscription is caused by this app
%- zing
%+ turn pas
|= pan/partner
^- (list card)
?- -.pan
$| !! ::< passport partner
::
$& ::< circle partner
:_ ~
:* %pull
/circle/[nom]/(scot %p hos.p.pan)/[nom.p.pan]
[hos.p.pan %talk-guardian]
~
==
==
::
++ sa-eject ::< unsubscribe ships
::> removes ships {sis} from {followers}.
::
|= sis/(set ship)
^- (list move)
%+ turn (~(tap in (sa-unearth sis)))
|= {b/bone}
[b %quit ~]
::
++ sa-unearth ::< ships' bones
::> find the bones in {sup.bol} that belong to
::> a ship in {sis}.
::
|= sis/(set ship)
^- (set bone)
%- ~(rep in sup.bol)
|= {{b/bone s/ship p/path} c/(set bone)}
?. ?& (~(has in sis) s)
?=({@tas *} p)
=(i.p nom)
==
c
(~(put in c) b)
--
--
::
::
::> ||
::> || %wire-parsing
::> ||
::+|
::
++ etch ::< parse wire
::> parses {wir} to obtain either %circle with story
::> and circle or %repeat with message number, source
::> ship and story.
::
|= wir/wire
^- weir
?+ -.wir !!
$circle
?> ?=({@ @ @ *} t.wir)
:^ %circle
i.t.wir
(slav %p i.t.t.wir)
i.t.t.t.wir
::
$repeat
?> ?=({@ @ $~} t.wir)
:+ %repeat
(slav %p i.t.wir)
i.t.t.wir
==
::
++ etch-circle ::< parse /circle wire
::> parses a /circle wire, call a gate with the
::> result.
::
|= $: wir/wire
$= fun
$- {nom/knot cir/circle}
{(list move) _.}
==
=+ wer=(etch wir)
?>(?=($circle -.wer) (fun nom.wer cir.wer))
::
++ etch-repeat ::< parse /repeat wire
::> parses a /repeat wire, call gate with the result.
::
|= $: wir/wire
$= fun
$- cir/circle
{(list move) _.}
==
=+ wer=(etch wir)
?>(?=($repeat -.wer) (fun cir.wer))
::
++ circle-peer ::< /circle peer card
::> constructs a %peer move to subscribe {nom} to
::> {cir}.
::
|= {nom/cord cir/circle wen/range}
^- card
=/ ran
?~ wen ~
%+ welp
/(scot -.hed.u.wen +.hed.u.wen)
?~ tal.u.wen ~
/(scot -.u.tal.u.wen +.u.tal.u.wen)
:* %peer
(welp /circle/[nom]/(scot %p hos.cir)/[nom.cir] ran)
[hos.cir %talk-guardian]
(welp /circle/[nom.cir] ran)
==
::
::> ||
::> || %new-events
::> ||
::+|
++ bake ::< apply state delta
::> applies a change to the application state,
::> producing side-effects.
::
|= dif/delta
^- (quip move +>)
=^ mos +>.$
da-done:(da-change:da dif)
:_ +>.$
::TODO move affection to pre-bake, but then station creation doesn't happen?
(welp mos (affection dif))
::
++ pre-bake ::< apply more deltas
::> bake a list of deltas.
::
|= dis/(list delta)
^- (quip move +>)
%+ roll dis
|= {d/delta m/(list move) _+>.$} ::REVIEW ^$ find-fails, how is this correct?
=^ mos +>.^$ (bake d)
[(welp m mos) +>.^$]
::
++ peek ::< query on state
::> find the result (if any) for a given query.
::
|= qer/query
^- (unit (unit prize))
?- -.qer
$reader
``[%reader nak nicks]
::
$burden
:+ ~ ~
:- %burden
%- ~(gas in *(map knot burden))
%+ murn (~(tap by stories))
|= {n/knot s/story}
^- (unit (pair knot burden))
:: only auto-federate channels for now. ::REVIEW
?. ?=($black sec.con.shape.s) ~
:+ ~ n
:+ grams.s
[shape.s mirrors.s]
[locals.s remotes.s]
::
$report
::REVIEW we just don't have a prize... but do have rumors.
:: or do we need [%report ~] ?
::TODO gall note: need to be able to subscirbe to just changes... or just
:: data etc.
~
::
$circle ::REVIEW should we send precs & config to out of range subs?
=+ soy=(~(get by stories) nom.qer)
?~ soy ~
:+ ~ ~
:- %circle
:+ (~(so-first-grams so:ta nom.qer ~ u.soy) ran.qer)
[shape.u.soy mirrors.u.soy]
[locals.u.soy remotes.u.soy]
==
::
++ dedicate ::< diff-story to theirs
::> modify a %story delta to make it about their ship
::> instead of ours.
::
|= {who/ship dif/diff-story}
^- diff-story
?+ -.dif
dif
::
$grams
%= dif
gaz
%+ turn gaz.dif
|= gam/telegram
=. aud.tot.gam
%- ~(run in aud.tot.gam)
|= p/partner
::TODO it probably isn't safe to do this for
:: all audience members hosted by us, even
:: if this is only called for burdens.
?. &(?=($& -.p) =(hos.p.p our.bol)) p
[%& who nom.p.p]
gam
==
::
$config
?. =(hos.cir.dif our.bol) dif
dif(cir [who nom.cir.dif])
::
$status
?. &(?=($& -.pan.dif) =(hos.p.pan.dif our.bol)) dif
dif(pan [%& who nom.p.pan.dif])
==
::
++ feel ::< delta to rumor
::> if the given delta changes the result of the given
::> query, produce the relevant rumor.
::
|= {qer/query dif/delta}
^- (unit rumor)
?- -.qer
$reader
:: changes to shared ui state apply.
?+ -.dif ~
$glyph `[%reader dif]
$nick `[%reader dif]
==
::
$burden
::?: &(=(who.qer src.bol) did-they-send-a-burden) ~
?. ?=($story -.dif) ~
?: ?=(?($follow $burden) -.dif.dif) ~
:: only burden channels for now.
?. =(%black sec.con.shape:(~(got by stories) nom.dif)) ~
`[%burden nom.dif (dedicate who.qer dif.dif)]
::
$report
:: only send changes we didn't get from above.
?: =(src.bol (above our.bol)) ~
:: only send story reports about grams and status.
?. ?=($story -.dif) ~
?. ?=(?($grams $status) -.dif.dif) ~
=+ soy=(~(got by stories) nom.dif)
:: and only if the story is inherited.
?. burden.soy ~
:: only burden channels for now.
?. =(%black sec.con.shape.soy) ~
`[%burden nom.dif (dedicate (above our.bol) dif.dif)]
::
$circle
?. ?=($story -.dif) ~
?. =(nom.qer nom.dif) ~
?: ?=(?($follow $burden) -.dif.dif) ~ :: internal-only delta
=+ ren=(~(so-in-range so:ta nom.qer ~ (~(got by stories) nom.qer)) ran.qer)
::TODO if done.ren, %quit bone
?. in.ren ~
`[%circle dif.dif]
==
::
++ affection ::< rumors to interested
::> for a given delta, send rumors to all queries it
::> affects.
::
::TODO? %quit bones that are done with their subscription.
:: ...but that would also require a ta-cancel call to remove
:: them from the presence list! how do?
:: should there be an ++away arm for gall to call?
|= dif/delta
^- (list move)
:: cache results for paths.
=| res/(map path (unit rumor))
%+ murn (~(tap by sup.bol))
|= {b/bone s/ship p/path}
^- (unit move)
=+ mur=(~(get by res) p)
?^ mur
?~ u.mur ~
`[b %diff %talk-rumor u.u.mur]
=+ rum=(feel (path-to-query p) dif)
=. res (~(put by res) p rum)
?~ rum ~
`[b %diff %talk-rumor u.rum]
::
++ path-to-query ::< path, coins, query
::> parse a path into a (list coin), then parse that
::> into a query structure.
::
|= pax/path
(coins-to-query (path-to-coins pax))
::
++ path-to-coins ::< path to coin list
::> parse a path into a list of coins.
::
|= pax/path
^- (list coin)
%+ turn `path`pax
|= a/@ta
(need (slay a))
::
++ coins-to-query ::< coin list to query
::> parse a list of coins into a query structure.
::
^- $-((list coin) query)
=> depa
|^ %- af :~
[%reader ul]
[%burden (at /[%p])]
[%report ul]
[%circle (al knot rang)]
==
++ knot (do %tas)
++ rang (mu (al plac (mu (un plac))))
++ plac (or %da %ud)
--
::
++ leak ::< visible to
::> determine if the given query is visible to the
::> ship.
::
|= {who/ship qer/query}
^- ?
?- -.qer
$reader (team our.bol who)
$burden ?& =(who who.qer)
=(our.bol (above who))
==
$report =(who (above our.bol))
::
$circle
?. (~(has by stories) nom.qer) |
%. who
~(so-visible so:ta nom.qer ~ (~(got by stories) nom.qer))
==
::
::> ||
::> || %poke-events
::> ||
::+|
::
++ poke-talk-command ::< accept command
::> incoming talk command. process it and update logs.
::
|= cod/command
^- (quip move +>)
=^ mos +>.$
%- pre-bake
ta-done:(ta-apply:ta src.bol cod)
=^ mow +>.$
log-all-to-file
[(welp mos mow) +>.$]
::
++ poke-talk-action ::< accept action
::> incoming talk action. process it.
::
|= act/action
^- (quip move +>)
?. (team src.bol our.bol)
%- pre-bake
=< ta-done
%- ta-note:ta %- crip
"talk-action stranger {(scow %p src.bol)}"
%- pre-bake
ta-done:(ta-action:ta ost.bol act)
::
::> ||
::> || %subscription-events
::> ||
::+|
::
++ diff-talk-prize ::< accept prize
::> accept a query result.
::
|= {wir/wire piz/prize}
^- (quip move +>)
=^ mos +>.$
%- pre-bake
ta-done:(ta-take:ta wir piz)
=^ mow +>.$
log-all-to-file
[(welp mos mow) +>.$]
::
++ diff-talk-rumor ::< accept rumor
::> accept a query result change.
::
|= {wir/wire dif/rumor}
^- (quip move +>)
=^ mos +>.$
%- pre-bake
ta-done:(ta-hear:ta wir dif)
=^ mow +>.$
log-all-to-file
[(welp mos mow) +>.$]
::
++ peer ::< accept subscription
::> incoming subscription on {pax}.
::
|= pax/path
^- (quip move +>)
?: ?=({$sole *} pax) ~&(%talk-broker-no-sole !!)
=+ qer=(path-to-query pax)
?. (leak src.bol qer) ~&(%peer-invisible !!)
=^ mos +>.$
%- pre-bake
ta-done:(ta-subscribe:ta src.bol qer)
:_ +>.$
=+ piz=(peek qer)
?~ piz ~&([%query-unavailable pax] mos)
?~ u.piz ~&([%query-invalid pax] mos)
:_ mos
[ost.bol %diff %talk-prize u.u.piz]
::
++ pull ::< unsubscribe
::> unsubscribes.
::
|= pax/path
^- (quip move +>)
=+ qer=(path-to-query pax)
?. ?=($circle -.qer) [~ +>.$]
%- pre-bake
ta-done:(ta-cancel:ta src.bol nom.qer)
::
++ reap ::< catch-all reap
::> handle all remote errors.
::
|= {wir/wire fal/(unit tang)}
^- (quip move +>)
?~ fal [~ +>]
~| reap-fail+wir
(mean u.fal)
::
++ reap-circle ::< subscription n/ack
::> if subscribing failed, update state to reflect
::> that.
::
::TODO update to handle all subscription kinds.
|= {wir/wire fal/(unit tang)}
^- (quip move +>)
%+ etch-circle [%circle wir]
|= {nom/knot cir/circle}
?~ fal
%- pre-bake
ta-done:(ta-greet:ta nom cir)
=. u.fal [>%reap-circle-fail nom cir< u.fal]
%- (slog (flop u.fal))
%- pre-bake
ta-done:(ta-leave:ta nom cir)
::
++ quit-circle ::< dropped subscription
::> gall dropped our subscription. resubscribe.
::
::TODO update for all subscription kinds.
::TODO? does new gall still drop subscriptions?
|= wir/wire
^- (quip move +>)
%+ etch-circle [%circle wir]
|= {nom/knot cir/circle}
:_ +>.^$ :_ ~
[0 (circle-peer nom cir `[[%da (sub now.bol ~m5)] ~])]
::
++ coup-repeat ::< message n/ack
::> ack from ++ta-transmit. mark the message as
::> received or rejected.
::
|= {wir/wire fal/(unit tang)}
^- (quip move +>)
%+ etch-repeat [%repeat wir]
|= cir/circle
%- pre-bake
ta-done:(ta-repeat:ta [%& cir] fal)
::
::> ||
::> || %logging
::> ||
::+|
::
++ poke-talk-save ::< save as log
::> stores the telegrams of story {nom} in a log file,
::> to be re-loaded by ++poke-talk-load.
::
|= nom/knot
^- (quip move +>)
=/ paf/path
/(scot %p our.bol)/home/(scot %da now.bol)/talk/[nom]/talk-telegrams
=+ grams:(~(got by stories) nom)
:_ +>.$
:_ ~
:* ost.bol
%info
/jamfile
our.bol
(foal paf [%talk-telegrams !>(-)])
==
::
++ poke-talk-load ::< load from log
::> loads the telegrams of story {nom} into our state,
::> as saved in ++poke-talk-save.
::
|= nom/knot
^- (quip move +>)
=/ grams
.^ (list telegram)
%cx
/(scot %p our.bol)/home/(scot %da now.bol)/talk/[nom]/talk-telegrams
==
=+ soy=(~(got by stories) nom)
:- ~
%= +>.$
stories
%+ ~(put by stories) nom
soy(grams grams, count (lent grams))
==
::
++ poke-talk-log ::< start logging
::> starts logging story {nom}'s messages.
::
|= nom/knot
~& %talk-poke-log
^- (quip move +>)
:- [(log-to-file nom) ~]
%= +>.$
log
%+ ~(put by log) nom
count:(~(got by stories) nom)
==
::
++ poke-talk-unlog ::< stop logging
::> stops logging story {nom}'s messages.
::
|= nom/knot
^- (quip move +>)
:- ~
+>.$(log (~(del by log) nom))
::
++ log-all-to-file ::< update stories logs
::> for every story we're logging, (over)writes all
::> their grams to log files if new ones have arrived.
::
::TODO re-enable and test.
^- (quip move .)
?: & [~ .] :: XXX!!!!
:_ %_ .
log
%- ~(urn by log)
|= {nom/knot len/@ud}
count:(~(got by stories) nom)
==
%+ murn (~(tap by log))
|= {nom/knot len/@ud}
^- (unit move)
?: (gte len count:(~(got by stories) nom))
~
`(log-to-file nom)
::
++ log-to-file ::< update story log
::> logs all grams of story {nom} to a file.
::
|= nom/knot
^- move
=+ ^- paf/path
=+ day=(year %*(. (yore now.bol) +.t +:*tarp))
%+ tope [our.bol %home da+now.bol]
/talk-telegrams/(scot %da day)/[nom]/talk
=+ grams:(~(got by stories) nom)
[ost.bol %info /jamfile our.bol (foal paf [%talk-telegrams !>(-)])]
--
Reference in New Issue View Git Blame Copy Permalink