ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-24 07:26:51 +03:00
Code Issues Packages Projects Releases Wiki Activity

ames: fix cached state in larval upgrade

Browse Source
This commit is contained in:
yosoyubik 2022-03-11 09:40:14 +01:00
parent ab116653e8
commit 5ecf87cf52
3 changed files with 189 additions and 128 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/arvo/app/azimuth.hoon
View File

@ -342,8 +342,8 @@
=/ =pass =/ =pass
(pass-from-eth:azimuth [32^crypt 32^auth suite]:keys.net) (pass-from-eth:azimuth [32^crypt 32^auth suite]:keys.net)
^- (list [@p udiff:point]) ^- (list [@p udiff:point])
:* [ship id %rift rift.net %.y] :* [ship id %keys [life.keys.net suite.keys.net pass] %.y]
[ship id %keys [life.keys.net suite.keys.net pass] %.y] [ship id %rift rift.net %.y]
[ship id %spon ?:(has.sponsor.net `who.sponsor.net ~)] [ship id %spon ?:(has.sponsor.net `who.sponsor.net ~)]
udiffs udiffs
== ==

207
pkg/arvo/sys/vane/ames.hoon
View File

@ -114,9 +114,9 @@
^+ same ^+ same
?. verb ?. verb
same same
:: ?. => [ship=ship ships=ships in=in] ?. => [ship=ship ships=ships in=in]
:: ~+ |(=(~ ships) (~(has in ships) ship)) ~+ |(=(~ ships) (~(has in ships) ship))
:: same same
(slog leaf/"ames: {(scow %p ship)}: {(print)}" ~) (slog leaf/"ames: {(scow %p ship)}: {(print)}" ~)
:: +qos-update-text: notice text for if connection state changes :: +qos-update-text: notice text for if connection state changes
:: ::
@ -208,19 +208,20 @@
++ parse-bone-wire ++ parse-bone-wire
|= =wire |= =wire
^- %- unit ^- %- unit
$% [%new her=ship =rift =bone] $% [%old her=ship =bone]
[%old her=ship =bone] [%new her=ship =rift =bone]
== ==
?. ?| ?=([%bone @ @ @ ~] wire) ?. ?| ?=([%bone @ @ @ ~] wire)
?=([%bone @ @ ~] wire) ?=([%bone @ @ ~] wire)
== ==
:: ignore malformed wires? :: ignore malformed wires
:: ::
~& >>> malformed-wire+wire
~ ~
?+ wire ~ ?+ wire ~
[%bone @ @ ~] [%bone @ @ ~]
~& >> old-wire+wire :: later on we drop events that come in an old wire but
:: tracking it here let us print a notification to the user
::
`[%old `@p`(slav %p i.t.wire) `@ud`(slav %ud i.t.t.wire)] `[%old `@p`(slav %p i.t.wire) `@ud`(slav %ud i.t.t.wire)]
:: ::
[%bone @ @ @ ~] [%bone @ @ @ ~]
@ -588,6 +589,36 @@
:: ::
+$ naxplanation [=message-num =error] +$ naxplanation [=message-num =error]
:: ::
+$ ames-state-4 ames-state-5
+$ ames-state-5
$: peers=(map ship ship-state-5)
=unix=duct
=life
crypto-core=acru:ames
=bug
==
::
+$ ship-state-4 ship-state-5
+$ ship-state-5
$% [%alien alien-agenda]
[%known peer-state-5]
==
::
+$ peer-state-5
$: $: =symmetric-key
=life
=public-key
sponsor=ship
==
route=(unit [direct=? =lane])
=qos
=ossuary
snd=(map bone message-pump-state)
rcv=(map bone message-sink-state)
nax=(set [=bone =message-num])
heeds=(set duct)
==
::
+| %statics +| %statics
:: ::
:: $ames-state: state for entire vane :: $ames-state: state for entire vane
@ -751,8 +782,7 @@
:: ::
=< =* adult-gate . =< =* adult-gate .
=| queued-events=(qeu queued-event) =| queued-events=(qeu queued-event)
=| larval-bit=_| =| cached-state=[?(%5 %~) ames-state-5]
=| cached-state=*
:: ::
|= [now=@da eny=@ rof=roof] |= [now=@da eny=@ rof=roof]
=* larval-gate . =* larval-gate .
@ -761,35 +791,22 @@
:: +call: handle request $task :: +call: handle request $task
:: ::
++ call ++ call
=> |%
+$ old-state ames-state-4-5:load:adult-core
--
|= [=duct dud=(unit goof) wrapped-task=(hobo task)] |= [=duct dud=(unit goof) wrapped-task=(hobo task)]
~& call-larva+duct
:: ::
=/ =task ((harden task) wrapped-task) =/ =task ((harden task) wrapped-task)
~& task+task
::
:: reject larval error notifications :: reject larval error notifications
:: ::
?^ dud ?^ dud
~|(%ames-larval-call-dud (mean tang.u.dud)) ~|(%ames-larval-call-dud (mean tang.u.dud))
:: ::
~& cach+?=([%5 *] cached-state) =/ update-ready=?
~& queu+?=(~ queued-events)
=/ from-adult=?
?& ?=([%5 *] cached-state) ?& ?=([%5 *] cached-state)
?=(~ queued-events) ?=(~ queued-events)
:: ?=(^ unix-duct:;;(old-state +.cached-state))
== ==
=? ames-state.adult-gate from-adult ?: update-ready
~& "state update to 6" =. ames-state.adult-gate
(state-5-to-6:load:adult-core ;;(old-state +.cached-state)) (state-5-to-6:load:adult-core +.cached-state)
::=? larval-bit from-adult %.y =. -.cached-state %~
::
::?: &(larval-bit ?=(~ queued-events))
?: from-adult
=. cached-state ~
~> %slog.1^leaf/"ames: metamorphosis reload" ~> %slog.1^leaf/"ames: metamorphosis reload"
[~ adult-gate] [~ adult-gate]
:: %born: set .unix-duct and start draining .queued-events :: %born: set .unix-duct and start draining .queued-events
@ -864,6 +881,16 @@
%call (call:adult-core [duct ~ wrapped-task]:+.first-event) %call (call:adult-core [duct ~ wrapped-task]:+.first-event)
%take (take:adult-core [wire duct ~ sign]:+.first-event) %take (take:adult-core [wire duct ~ sign]:+.first-event)
== ==
=/ update-ready=?
?& ?=([%5 *] cached-state)
?=(~ queued-events)
==
?: update-ready
=. ames-state.adult-gate
(state-5-to-6:load:adult-core +.cached-state)
=. -.cached-state %~
~> %slog.1^leaf/"ames: metamorphosis reload"
[moves adult-gate]
:: .queued-events has been cleared; metamorphose :: .queued-events has been cleared; metamorphose
:: ::
?~ queued-events ?~ queued-events
@ -878,23 +905,20 @@
++ scry scry:adult-core ++ scry scry:adult-core
++ stay [%6 %larva queued-events ames-state.adult-gate] ++ stay [%6 %larva queued-events ames-state.adult-gate]
++ load ++ load
=> |%
+$ old-state ames-state-4-5:load:adult-core
--
|= $= old |= $= old
$% $: %4 $% $: %4
$% $: %larva $% $: %larva
events=(qeu queued-event) events=(qeu queued-event)
state=old-state state=ames-state-4
== ==
[%adult state=old-state] [%adult state=ames-state-4]
== == == ==
$: %5 $: %5
$% $: %larva $% $: %larva
events=(qeu queued-event) events=(qeu queued-event)
state=old-state state=ames-state-5
== ==
[%adult state=old-state] [%adult state=ames-state-5]
== == == ==
$: %6 $: %6
$% $: %larva $% $: %larva
@ -903,7 +927,6 @@
== ==
[%adult state=_ames-state.adult-gate] [%adult state=_ames-state.adult-gate]
== == == == == ==
~& %larval-state-loaded
?- old ?- old
[%4 %adult *] (load:adult-core %4 state.old) [%4 %adult *] (load:adult-core %4 state.old)
:: ::
@ -914,21 +937,18 @@
larval-gate larval-gate
:: ::
[%5 %adult *] [%5 %adult *]
~& [%5 %adult unix-duct.state.old]
=. cached-state [%5 state.old] =. cached-state [%5 state.old]
~> %slog.1^leaf/"ames: larva: reload" ~> %slog.1^leaf/"ames: larva reload"
larval-gate larval-gate
:: ::
[%5 %larva *] [%5 %larva *]
~> %slog.1^leaf/"ames: larva: load" ~> %slog.1^leaf/"ames: larva: load"
=. queued-events events.old =. queued-events events.old
=. adult-gate (load:adult-core %5 state.old)
larval-gate larval-gate
:: ::
[%6 %adult *] (load:adult-core %6 state.old) [%6 %adult *] (load:adult-core %6 state.old)
:: ::
[%6 %larva *] [%6 %larva *]
~& larva+-.old
~> %slog.1^leaf/"ames: larva: load" ~> %slog.1^leaf/"ames: larva: load"
=. queued-events events.old =. queued-events events.old
=. adult-gate (load:adult-core %6 state.old) =. adult-gate (load:adult-core %6 state.old)
@ -1009,52 +1029,24 @@
:: ::
++ load ++ load
=< |= $= old-state =< |= $= old-state
$% [%4 ames-state-4-5] $% [%4 ames-state-4]
[%5 ames-state-4-5] [%5 ames-state-5]
[%6 ^ames-state] [%6 ^ames-state]
== ==
^+ ames-gate ^+ ames-gate
~& %load-adult
=? old-state ?=(%4 -.old-state) %5^(state-4-to-5 +.old-state) =? old-state ?=(%4 -.old-state) %5^(state-4-to-5 +.old-state)
:: =? old-state ?=(%5 -.old-state) %6^(state-5-to-6 +.old-state) :: XX this would crash with ames-state-5 but load is never
:: called with it -- the upgrade is handled by the larval load
:: ::
?> ?=(%6 -.old-state) ?> ?=(%6 -.old-state)
ames-gate(ames-state +.old-state) ames-gate(ames-state +.old-state)
|% |%
+$ ames-state-4-5
$: peers=(map ship ship-state-4-5)
=unix=duct
=life
crypto-core=acru:ames
=bug
==
::
+$ ship-state-4-5
$% [%alien alien-agenda]
[%known peer-state-4-5]
==
::
+$ peer-state-4-5
$: $: =symmetric-key
=life
=public-key
sponsor=ship
==
route=(unit [direct=? =lane])
=qos
=ossuary
snd=(map bone message-pump-state)
rcv=(map bone message-sink-state)
nax=(set [=bone =message-num])
heeds=(set duct)
==
::
++ state-4-to-5 ++ state-4-to-5
|= ames-state=ames-state-4-5 |= ames-state=ames-state-4
^- ames-state-4-5 ^- ames-state-4
=. peers.ames-state =. peers.ames-state
%- ~(run by peers.ames-state) %- ~(run by peers.ames-state)
|= ship-state=ship-state-4-5 |= ship-state=ship-state-4
?. ?=(%known -.ship-state) ?. ?=(%known -.ship-state)
ship-state ship-state
=. snd.ship-state =. snd.ship-state
@ -1067,21 +1059,20 @@
ames-state ames-state
:: ::
++ state-5-to-6 ++ state-5-to-6
|= ames-state=ames-state-4-5 |= ames-state=ames-state-5
^- ^^ames-state ^- ^^ames-state
:_ +.ames-state :_ +.ames-state
%- ~(rut by peers.ames-state) %- ~(rut by peers.ames-state)
|= [=ship ship-state=ship-state-4-5] |= [=ship ship-state=ship-state-5]
^- ^ship-state ^- ^ship-state
?. ?=(%known -.ship-state) ?. ?=(%known -.ship-state)
ship-state ship-state
=/ peer-state=peer-state-4-5 +.ship-state =/ peer-state=peer-state-5 +.ship-state
=| =rift =| =rift
=/ scry=(unit (unit cage)) =/ scry=(unit (unit cage))
(rof ~ %j `beam`[[our %rift %da now] /(scot %p ship)]) (rof ~ %j `beam`[[our %rift %da now] /(scot %p ship)])
=? rift ?=([~ ~ ^] scry) =? rift ?=([~ ~ ^] scry)
;;(@ud q.q:u.u.scry) ;;(@ud q.q:u.u.scry)
~& ship^rift
=/ =^peer-state =/ =^peer-state
:_ +.peer-state :_ +.peer-state
=, -.peer-state =, -.peer-state
@ -1231,30 +1222,28 @@
?~ parsed=(parse-bone-wire wire) ?~ parsed=(parse-bone-wire wire)
:: no-op? :: no-op?
:: ::
~& >>> "error parsing wire" =/ =tape "; ames dropping malformed wire"
event-core (emit duct %pass /parse-wire %d %flog %text tape)
?> ?=([@ her=ship *] u.parsed) ?> ?=([@ her=ship *] u.parsed)
=* her her.u.parsed =* her her.u.parsed
=/ =peer-state (got-peer-state her) =/ =peer-state (got-peer-state her)
=/ =channel =/ =channel [[our her] now channel-state -.peer-state]
:^ [our her] now channel-state
=, -.peer-state
[symmetric-key life rift public-key sponsor]
=/ peer-core (make-peer-core peer-state channel) =/ peer-core (make-peer-core peer-state channel)
|^ |^
?- u.parsed ?- u.parsed
[%old *] [%old *]
:: XX ignore events from old wire instead of sending nack? :: ignore events from old wire
:: ::
:: event-core =/ =tape "; ames dropping old wire format"
(send-nack bone.u.parsed [%old-wire ~[(spat wire)]]) (emit duct %pass /parse-wire %d %flog %text tape)
:: ::
[%new *] [%new *]
?: (lth rift.u.parsed rift.peer-state) ?: (lth rift.u.parsed rift.peer-state)
:: XX ignore events from an old rift instead of sending nack? :: ignore events from an old rift
:: ::
:: event-core =/ =tape "; ames dropping wire with old rift ({<rift.u.parsed>})"
(send-nack bone.u.parsed [%old-rift ~]) (emit duct %pass /parse-wire %d %flog %text tape)
?~ error ?~ error
(send-ack bone.u.parsed) (send-ack bone.u.parsed)
(send-nack bone.u.parsed u.error) (send-nack bone.u.parsed u.error)
@ -1264,20 +1253,15 @@
++ send-ack ++ send-ack
|= =bone |= =bone
^+ event-core ^+ event-core
~& send-ack+wire
abet:(run-message-sink:peer-core bone %done ok=%.y) abet:(run-message-sink:peer-core bone %done ok=%.y)
:: failed; send message nack packet :: failed; send message nack packet
:: ::
++ send-nack ++ send-nack
|= [=bone =^error] |= [=bone =^error]
^+ event-core ^+ event-core
~& send-nack+[wire error]
=. event-core abet:(run-message-sink:peer-core bone %done ok=%.n) =. event-core abet:(run-message-sink:peer-core bone %done ok=%.n)
=/ =^peer-state (got-peer-state her) =/ =^peer-state (got-peer-state her)
=/ =^channel =/ =^channel [[our her] now channel-state -.peer-state]
:^ [our her] now channel-state
=, -.peer-state
[symmetric-key life rift public-key sponsor]
:: construct nack-trace message, referencing .failed $message-num :: construct nack-trace message, referencing .failed $message-num
:: ::
=/ failed=message-num last-acked:(~(got by rcv.peer-state) bone) =/ failed=message-num last-acked:(~(got by rcv.peer-state) bone)
@ -1542,30 +1526,27 @@
++ on-take-boon ++ on-take-boon
|= [=wire payload=*] |= [=wire payload=*]
^+ event-core ^+ event-core
~& on-take-boon+wire
:: ::
?~ parsed=(parse-bone-wire wire) ?~ parsed=(parse-bone-wire wire)
:: no-op? =/ =tape "; ames dropping malformed wire"
:: (emit duct %pass /parse-wire %d %flog %text tape)
event-core
:: ::
?> ?=([@ her=ship *] u.parsed) ?> ?=([@ her=ship *] u.parsed)
=/ =peer-state (got-peer-state her.u.parsed) =/ =peer-state (got-peer-state her.u.parsed)
=/ =channel =/ =channel [[our her.u.parsed] now channel-state -.peer-state]
:^ [our her.u.parsed] now channel-state
=, -.peer-state
[symmetric-key life rift public-key sponsor]
:: ::
?- u.parsed ?- u.parsed
[%old *] [%old *]
event-core =/ =tape "; ames dropping old wire"
(emit duct %pass /parse-wire %d %flog %text tape)
:: ::
[%new *] [%new *]
=, u.parsed =, u.parsed
?: (lth rift rift.peer-state) ?: (lth rift rift.peer-state)
:: ignore events from an old rift ? :: ignore events from an old rift
:: ::
event-core =/ =tape "; ames dropping wire with old rift ({<rift>})"
(emit duct %pass /parse-wire %d %flog %text tape)
abet:(on-memo:(make-peer-core peer-state channel) bone payload %boon) abet:(on-memo:(make-peer-core peer-state channel) bone payload %boon)
== ==
:: +on-plea: handle request to send message :: +on-plea: handle request to send message
@ -1586,7 +1567,7 @@
=/ =channel [[our ship] now channel-state -.peer-state] =/ =channel [[our ship] now channel-state -.peer-state]
:: ::
=^ =bone ossuary.peer-state (bind-duct ossuary.peer-state duct) =^ =bone ossuary.peer-state (bind-duct ossuary.peer-state duct)
%- %^ trace & ship %- %^ trace msg.veb ship
|. ^- tape |. ^- tape
=/ sndr [our our-life.channel] =/ sndr [our our-life.channel]
=/ rcvr [ship her-life.channel] =/ rcvr [ship her-life.channel]
@ -1651,7 +1632,6 @@
:: ::
++ on-publ ++ on-publ
|= [=wire =public-keys-result] |= [=wire =public-keys-result]
~& [wire public-keys-result]
^+ event-core ^+ event-core
:: ::
|^ ^+ event-core |^ ^+ event-core
@ -1844,13 +1824,12 @@
?~ ship-state=(~(get by peers.ames-state) ship) ?~ ship-state=(~(get by peers.ames-state) ship)
:: print error here? %rift was probably called before %keys :: print error here? %rift was probably called before %keys
:: ::
~& >> on-publ-rift+[ship %missing-state] ~> %slog.1^leaf/"ames: missing peer-state on-publ-rift"
event-core event-core
?: ?=([%alien *] u.ship-state) ?: ?=([%alien *] u.ship-state)
:: ignore aliens :: ignore aliens
:: ::
event-core event-core
~& ship^rift
=/ =peer-state +.u.ship-state =/ =peer-state +.u.ship-state
=. rift.peer-state rift =. rift.peer-state rift
=. peers.ames-state (~(put by peers.ames-state) ship %known peer-state) =. peers.ames-state (~(put by peers.ames-state) ship %known peer-state)
@ -2150,7 +2129,6 @@
:: ::
=+ ?~ dud ~ =+ ?~ dud ~
%. ~ %. ~
~& >>> bone+bone
%+ slog leaf+"ames: {<her.channel>} ack crashed {<mote.u.dud>}" %+ slog leaf+"ames: {<her.channel>} ack crashed {<mote.u.dud>}"
?. msg.veb ~ ?. msg.veb ~
:- >[bone=bone message-num=message-num meat=meat]:shut-packet< :- >[bone=bone message-num=message-num meat=meat]:shut-packet<
@ -2207,7 +2185,6 @@
++ on-wake ++ on-wake
|= [=bone error=(unit tang)] |= [=bone error=(unit tang)]
^+ peer-core ^+ peer-core
~& wake-bone+bone
:: if we previously errored out, print and reset timer for later :: if we previously errored out, print and reset timer for later
:: ::
:: This really shouldn't happen, but if it does, make sure we :: This really shouldn't happen, but if it does, make sure we
@ -2649,11 +2626,9 @@
$(current.state +(current.state)) $(current.state +(current.state))
:: ::
%nack %nack
~& >>> %nack
message-pump message-pump
:: ::
%naxplanation %naxplanation
~& >>> %naxplanation
=. message-pump (give %done current.state `error.u.cur) =. message-pump (give %done current.state `error.u.cur)
$(current.state +(current.state)) $(current.state +(current.state))
== ==

100
pkg/arvo/tests/sys/vane/ames.hoon
View File

@ -1,5 +1,6 @@
/+ *test /+ *test
/= ames /sys/vane/ames /= ames /sys/vane/ames
/= jael /sys/vane/jael
:: construct some test fixtures :: construct some test fixtures
:: ::
=/ nec (ames ~nec) =/ nec (ames ~nec)
@ -44,6 +45,7 @@
=. -.peer-state =. -.peer-state
:* symmetric-key=bud-sym :* symmetric-key=bud-sym
life=3 life=3
rift=0
public-key=bud-pub public-key=bud-pub
sponsor=~nec sponsor=~nec
== ==
@ -56,6 +58,7 @@
=. -.peer-state =. -.peer-state
:* symmetric-key=nec-sym :* symmetric-key=nec-sym
life=2 life=2
rift=0
public-key=nec-pub public-key=nec-pub
sponsor=~nec sponsor=~nec
== ==
@ -195,7 +198,7 @@
=^ moves1 bud (call bud ~[//unix] %hear lane-foo blob) =^ moves1 bud (call bud ~[//unix] %hear lane-foo blob)
=^ moves2 bud =^ moves2 bud
=/ =point:ames =/ =point:ames
:* rift=1 :* rift=0
life=4 life=4
keys=[[life=4 [crypto-suite=1 `@`nec-pub]] ~ ~] keys=[[life=4 [crypto-suite=1 `@`nec-pub]] ~ ~]
sponsor=`~bus sponsor=`~bus
@ -213,7 +216,7 @@
:: ::
%+ expect-eq %+ expect-eq
!> %- sy !> %- sy
:~ :^ ~[//unix] %pass /bone/~bus/1 :~ :^ ~[//unix] %pass /bone/~bus/0/1
[%g %plea ~bus %g /talk [%first %post]] [%g %plea ~bus %g /talk [%first %post]]
:: ::
:^ ~[//unix] %pass /qos :^ ~[//unix] %pass /qos
@ -267,7 +270,7 @@
!> :~ :* ~[//unix] %pass /qos %d %flog %text !> :~ :* ~[//unix] %pass /qos %d %flog %text
"; {<our.comet>} is your neighbor" "; {<our.comet>} is your neighbor"
== ==
:* ~[//unix] %pass /bone/(scot %p our.comet)/1 :* ~[//unix] %pass /bone/(scot %p our.comet)/0/1
%g %plea our.comet plea %g %plea our.comet plea
== == == ==
!> moves1 !> moves1
@ -280,11 +283,11 @@
=^ moves2 bud (call bud ~[//unix] %hear (snag-packet 0 moves1)) =^ moves2 bud (call bud ~[//unix] %hear (snag-packet 0 moves1))
:: ~bud -> %done -> ~nec :: ~bud -> %done -> ~nec
:: ::
=^ moves3 bud (take bud /bone/~nec/1 ~[//unix] %g %done ~) =^ moves3 bud (take bud /bone/~nec/0/1 ~[//unix] %g %done ~)
=^ moves4 nec (call nec ~[//unix] %hear (snag-packet 0 moves3)) =^ moves4 nec (call nec ~[//unix] %hear (snag-packet 0 moves3))
:: ~bud -> %boon -> ~nec :: ~bud -> %boon -> ~nec
:: ::
=^ moves5 bud (take bud /bone/~nec/1 ~[//unix] %g %boon [%post 'first1!!']) =^ moves5 bud (take bud /bone/~nec/0/1 ~[//unix] %g %boon [%post 'first1!!'])
=^ moves6 nec (call nec ~[//unix] %hear (snag-packet 0 moves5)) =^ moves6 nec (call nec ~[//unix] %hear (snag-packet 0 moves5))
:: ~nec -> %done -> ~bud (just make sure ~bud doesn't crash on ack) :: ~nec -> %done -> ~bud (just make sure ~bud doesn't crash on ack)
:: ::
@ -293,7 +296,7 @@
;: weld ;: weld
%+ expect-eq %+ expect-eq
!> :~ [~[//unix] %pass /qos %d %flog %text "; ~nec is your neighbor"] !> :~ [~[//unix] %pass /qos %d %flog %text "; ~nec is your neighbor"]
[~[//unix] %pass /bone/~nec/1 %g %plea ~nec %g /talk [%get %post]] [~[//unix] %pass /bone/~nec/0/1 %g %plea ~nec %g /talk [%get %post]]
== ==
!> moves2 !> moves2
:: ::
@ -318,7 +321,7 @@
:: ~bud -> nack -> ~nec :: ~bud -> nack -> ~nec
:: ::
=/ =error:ames [%flub [%leaf "sinusoidal repleneration"]~] =/ =error:ames [%flub [%leaf "sinusoidal repleneration"]~]
=^ moves3 bud (take bud /bone/~nec/1 ~[/bud] %g %done `error) =^ moves3 bud (take bud /bone/~nec/0/1 ~[/bud] %g %done `error)
=^ moves4 nec (call nec ~[//unix] %hear (snag-packet 0 moves3)) =^ moves4 nec (call nec ~[//unix] %hear (snag-packet 0 moves3))
:: ~bud -> nack-trace -> ~nec :: ~bud -> nack-trace -> ~nec
:: ::
@ -330,4 +333,87 @@
%+ expect-eq %+ expect-eq
!> [~[/g/talk] %give %done `error] !> [~[/g/talk] %give %done `error]
!> (snag 1 `(list move:ames)`moves5) !> (snag 1 `(list move:ames)`moves5)
::
++ test-old-ames-wire ^- tang
=^ moves1 bud (take bud /bone/~nec/1 ~[//unix] %g %done ~)
%+ expect-eq
!> %- sy
:_ ~
[~[//unix] %pass /parse-wire %d %flog %text "; ames dropping old wire format"]
!> (sy ,.moves1)
:: ::
++ test-dangling-bone ^- tang
:: ~nec -> %plea -> ~bud
::
=^ moves1 nec (call nec ~[/g/talk] %plea ~bud %g /talk [%get %post])
=^ moves2 bud (call bud ~[//unix] %hear (snag-packet 0 moves1))
:: ~bud receives a gift from %jael with ~nec's new rift
::
=^ moves3 bud
%- take
:^ bud /public-keys ~[//unix]
^- sign:ames
[%jael %public-keys %diff who=~nec %rift from=0 to=1]
:: %gall has a pending wire with the old rift, so sending a gift to
:: %ames on it will drop that request, and print a message to the user
::
=^ moves3 bud (take bud /bone/~nec/0/1 ~[//unix] %g %done ~)
::
%+ expect-eq
!> %- sy
:_ ~
:* ~[//unix]
%pass
/parse-wire
%d
%flog
%text
"; ames dropping wire with old rift (0)"
==
!> (sy ,.moves3)
::
++ test-ames-flow-with-new-rift ^- tang
:: ~bunecd receives a gift from %jael with ~bud's new rift
::
=^ moves1 nec
%- take
:^ nec /public-keys ~[//unix]
^- sign:ames
[%jael %public-keys %diff who=~bud %rift from=0 to=1]
:: now we try a normal message flow using the new rift in the wire
:: ~nec -> %plea -> ~bud
::
=^ moves2 nec (call nec ~[/g/talk] %plea ~bud %g /talk [%get %post])
=^ moves3 bud (call bud ~[//unix] %hear (snag-packet 0 moves2))
:: ~bud -> %done -> ~nec
::
=^ moves4 bud (take bud /bone/~nec/1/1 ~[//unix] %g %done ~)
=^ moves5 nec (call nec ~[//unix] %hear (snag-packet 0 moves4))
:: ~bud -> %boon -> ~nec
::
=^ moves6 bud (take bud /bone/~nec/1/1 ~[//unix] %g %boon [%post '¡hola!'])
=^ moves7 nec (call nec ~[//unix] %hear (snag-packet 0 moves6))
:: ~nec -> %done -> ~bud (just make sure ~bud doesn't crash on ack)
::
=^ moves8 bud (call bud ~[//unix] %hear (snag-packet 0 moves7))
::
;: weld
%+ expect-eq
!> :~ [~[//unix] %pass /qos %d %flog %text "; ~nec is your neighbor"]
[~[//unix] %pass /bone/~nec/0/1 %g %plea ~nec %g /talk [%get %post]]
==
!> moves3
::
%+ expect-eq
!> %- sy
:~ [~[/ames] %pass /pump/~bud/0 %b %rest ~1111.1.1..00.00.03]
[~[//unix] %pass /qos %d %flog %text "; ~bud is your neighbor"]
[~[/g/talk] %give %done error=~]
==
!> (sy ,.moves5)
::
%+ expect-eq
!> [~[/g/talk] %give %boon [%post '¡hola!']]
!> (snag 0 `(list move:ames)`moves7)
==
-- --