urbit/app/ph.hoon

373 lines
8.4 KiB
Plaintext
Raw Normal View History

2019-02-12 02:25:25 +03:00
:: Test the pH of your aquarium. See if it's safe to put in real fish.
2019-02-06 05:21:41 +03:00
::
:: usage:
:: :aqua [%run-test %test-add]
::
:: TODO:
:: - Restore a fleet
:: - Compose tests
::
/- aquarium
/+ ph
=, aquarium
=, ph
=> $~ |%
2019-03-06 23:22:37 +03:00
+$ move (pair bone card)
+$ card
2019-03-08 08:15:42 +03:00
$% [%poke wire dock poke-type]
2019-02-09 00:34:24 +03:00
[%peer wire dock path]
[%pull wire dock ~]
2019-03-08 08:15:42 +03:00
[%diff diff-type]
2019-02-06 05:21:41 +03:00
==
::
2019-03-08 08:15:42 +03:00
+$ poke-type
2019-03-07 10:31:14 +03:00
$% [%aqua-events (list aqua-event)]
[%drum-start term term]
2019-03-08 08:15:42 +03:00
[%aqua-vane-control ?(%subscribe %unsubscribe)]
==
::
+$ diff-type
$% [%aqua-effects aqua-effects]
2019-03-07 10:31:14 +03:00
==
::
2019-03-06 23:22:37 +03:00
+$ state
2019-02-06 05:21:41 +03:00
$: %0
2019-03-07 10:31:14 +03:00
raw-test-cores=(map term raw-test-core)
2019-03-06 23:22:37 +03:00
test-cores=(map term test-core-state)
2019-02-06 05:21:41 +03:00
other-state
==
2019-03-06 23:22:37 +03:00
::
+$ test-core-state
$: hers=(list ship)
2019-03-07 10:31:14 +03:00
cor=raw-test-core
effect-log=(list [who=ship uf=unix-effect])
2019-03-06 23:22:37 +03:00
==
::
+$ other-state
2019-02-06 05:21:41 +03:00
$~
--
=, gall
2019-03-09 00:48:09 +03:00
=/ vane-apps=(list term)
~[%aqua %aqua-ames %aqua-behn %aqua-dill %aqua-eyre]
2019-02-06 05:21:41 +03:00
|_ $: hid=bowl
state
==
++ this .
2019-02-12 05:46:36 +03:00
++ test-lib ~(. ^test-lib our.hid)
2019-03-20 23:57:24 +03:00
::
:: Tests that will be run automatically with :ph %run-all-tests
::
++ auto-tests
=, test-lib
%- malt
^- (list (pair term raw-test-core))
:~
:- %boot-bud
(galaxy ~bud)
::
:- %add
^- raw-test-core
%+ compose-tests (galaxy ~bud)
%+ stateless-test
%add
|%
++ start
|= now=@da
(dojo ~bud "[%test-result (add 2 3)]")
2019-02-12 05:46:36 +03:00
::
2019-03-20 23:57:24 +03:00
++ route
|= [now=@da who=ship uf=unix-effect]
(expect-dojo-output ~bud who uf "[%test-result 5]")
--
::
:- %hi
%+ compose-tests
2019-02-12 22:26:48 +03:00
%+ compose-tests
2019-03-20 23:57:24 +03:00
(galaxy ~bud)
(galaxy ~dev)
%+ stateless-test
%hi
|%
++ start
|= now=@da
(dojo ~bud "|hi ~dev")
2019-02-09 02:21:40 +03:00
::
2019-03-20 23:57:24 +03:00
++ route
|= [now=@da who=ship uf=unix-effect]
(expect-dojo-output ~bud who uf "hi ~dev successful")
--
::
:- %boot-planet
(planet ~linnup-torsyx)
::
:- %hi-grandparent
%+ compose-tests (planet ~linnup-torsyx)
%+ stateless-test
%hi-grandparent
|%
++ start
|= now=@da
(dojo ~linnup-torsyx "|hi ~bud")
::
2019-03-20 23:57:24 +03:00
++ route
|= [now=@da who=ship uf=unix-effect]
(expect-dojo-output ~linnup-torsyx who uf "hi ~bud successful")
--
::
:- %second-cousin-hi
%+ compose-tests
%+ compose-tests (planet ~mitnep-todsut)
(planet ~haplun-todtus)
%+ stateless-test
%second-cousin-hi
|%
++ start
|= now=@da
(dojo ~haplun-todtus "|hi ~bud")
2019-03-06 23:22:37 +03:00
::
2019-03-20 23:57:24 +03:00
++ route
|= [now=@da who=ship uf=unix-effect]
(expect-dojo-output ~haplun-todtus who uf "hi ~bud successful")
--
::
:- %change-file
%+ compose-tests (galaxy ~bud)
(touch-file ~bud %home)
::
:- %child-sync
%+ compose-tests
%+ compose-tests
(star ~marbud)
(touch-file ~bud %base)
(check-file-touched ~marbud %home)
==
::
:: Tests that will not be run automatically.
::
:: Some valid reasons for not running a test automatically:
:: - Nondeterministic
:: - Depends on external services
:: - Is very slow
::
++ manual-tests
=, test-lib
%- malt
^- (list (pair term raw-test-core))
:~ :- %boot-from-azimuth
2019-03-06 23:22:37 +03:00
%+ compose-tests
%+ compose-tests
(raw-ship ~bud `(dawn:azimuth ~bud))
(touch-file ~bud %home)
:: %- assert-happens
:: :~
:: ==
2019-03-07 10:31:14 +03:00
*raw-test-core
2019-03-20 23:57:24 +03:00
==
::
++ install-tests
^+ this
=. raw-test-cores
(~(uni by auto-tests) manual-tests)
2019-02-06 05:21:41 +03:00
this
::
++ prep
|= old=(unit [@ tests=* rest=*])
2019-02-09 00:34:24 +03:00
^- (quip move _this)
2019-03-20 23:57:24 +03:00
~& jael=.^(noun %j /(scot %p our.hid)/code/(scot %da now.hid)/(scot %p our.hid))
2019-02-06 05:21:41 +03:00
=. this install-tests
?~ old
`this
=/ new ((soft other-state) rest.u.old)
?~ new
`this
2019-02-09 00:34:24 +03:00
`this(+<+>+> u.new)
2019-02-06 05:21:41 +03:00
::
2019-03-07 10:31:14 +03:00
++ publish-aqua-effects
|= afs=aqua-effects
^- (list move)
%+ murn ~(tap by sup.hid)
|= [b=bone her=ship pax=path]
^- (unit move)
?. ?=([%effects ~] pax)
~
2019-03-08 09:28:10 +03:00
`[b %diff %aqua-effects afs]
2019-03-07 10:31:14 +03:00
::
2019-02-06 05:21:41 +03:00
++ run-events
2019-02-09 00:34:24 +03:00
|= [lab=term what=(list ph-event)]
^- (quip move _this)
2019-02-06 05:21:41 +03:00
?: =(~ what)
`this
=/ res
|- ^- (each (list aqua-event) $~)
?~ what
[%& ~]
?: ?=(%test-done -.i.what)
2019-03-08 09:28:10 +03:00
~& ?~(p.i.what "TEST SUCCESSFUL" "TEST FAILED")
2019-02-06 05:21:41 +03:00
[%| ~]
=/ nex $(what t.what)
?: ?=(%| -.nex)
nex
[%& `aqua-event`i.what p.nex]
?: ?=(%| -.res)
2019-02-09 00:34:24 +03:00
(cancel-test lab)
2019-02-06 05:21:41 +03:00
[[ost.hid %poke /running [our.hid %aqua] %aqua-events p.res]~ this]
::
2019-02-09 00:34:24 +03:00
:: Cancel subscriptions to ships
::
++ cancel-test
|= lab=term
^- (quip move _this)
=/ test (~(get by test-cores) lab)
?~ test
`this
=. test-cores (~(del by test-cores) lab)
:_ this
%- zing
%+ turn hers.u.test
|= her=ship
^- (list move)
:~ [ost.hid %pull /[lab]/(scot %p her) [our.hid %aqua] ~]
:* ost.hid
%poke
/cancelling
[our.hid %aqua]
%aqua-events
[%pause-events her]~
==
==
::
2019-02-06 05:21:41 +03:00
:: Should check whether we're already subscribed
::
++ subscribe-to-effects
|= [lab=@tas hers=(list ship)]
:_ this
%+ turn hers
|= her=ship
^- move
:* ost.hid
%peer
/[lab]/(scot %p her)
[our.hid %aqua]
/effects/(scot %p her)
==
::
2019-03-09 00:48:09 +03:00
:: Start the vane drivers
::
++ init-vanes
^- (list move)
%+ murn
`(list term)`[%aqua vane-apps]
|= vane-app=term
^- (unit move)
=/ app-started
.^(? %gu /(scot %p our.hid)/[vane-app]/(scot %da now.hid))
?: app-started
~
`[ost.hid %poke /start [our.hid %hood] %drum-start %home vane-app]
::
:: Restart the vane drivers' subscriptions
::
++ subscribe-vanes
^- (list move)
%+ turn
vane-apps
|= vane-app=term
[ost.hid %poke /init [our.hid vane-app] %aqua-vane-control %subscribe]
::
2019-03-13 14:50:56 +03:00
:: Pause all existing ships
::
++ pause-fleet
^- (list move)
:_ ~
:* ost.hid %poke /pause-fleet [our.hid %aqua] %aqua-events
%+ turn
.^((list ship) %gx /(scot %p our.hid)/aqua/(scot %da now.hid)/ships/noun)
|= who=ship
[%pause-events who]
==
::
2019-03-09 00:48:09 +03:00
:: User interface
::
2019-02-06 05:21:41 +03:00
++ poke-noun
|= arg=*
^- (quip move _this)
?+ arg ~|(%bad-noun-arg !!)
2019-03-07 10:31:14 +03:00
%init
2019-03-09 00:48:09 +03:00
[init-vanes this]
2019-03-07 10:31:14 +03:00
::
2019-02-06 05:21:41 +03:00
[%run-test lab=@tas]
2019-03-07 10:31:14 +03:00
=/ res=[events=(list ph-event) new-state=raw-test-core]
2019-02-12 05:46:36 +03:00
(start:(~(got by raw-test-cores) lab.arg) now.hid)
2019-03-06 23:22:37 +03:00
=. test-cores (~(put by test-cores) lab.arg [ships . ~]:new-state.res)
2019-02-12 02:25:25 +03:00
=^ moves-1 this (subscribe-to-effects lab.arg ships.new-state.res)
2019-02-09 00:34:24 +03:00
=^ moves-2 this (run-events lab.arg events.res)
2019-03-13 14:50:56 +03:00
[:(weld init-vanes pause-fleet subscribe-vanes moves-1 moves-2) this]
2019-03-06 23:22:37 +03:00
::
[%print lab=@tas]
=/ log effect-log:(~(got by test-cores) lab.arg)
~& lent=(lent log)
~& %+ roll log
2019-03-07 10:31:14 +03:00
|= [[who=ship uf=unix-effect] ~]
?: ?=(?(%blit %doze) -.q.uf)
2019-03-06 23:22:37 +03:00
~
2019-03-07 10:31:14 +03:00
?: ?=(%ergo -.q.uf)
~& [who [- +<]:uf %omitted-by-ph]
2019-03-06 23:22:37 +03:00
~
2019-03-07 10:31:14 +03:00
~& [who uf]
2019-03-06 23:22:37 +03:00
~
`this
2019-02-06 05:21:41 +03:00
==
::
2019-03-09 00:48:09 +03:00
:: Receive effects back from aqua
::
2019-02-08 05:03:46 +03:00
++ diff-aqua-effects
2019-03-07 10:31:14 +03:00
|= [way=wire afs=aqua-effects]
2019-02-06 05:21:41 +03:00
^- (quip move _this)
2019-03-08 08:15:42 +03:00
:: ~& [%diff-aqua-effect way who.afs]
2019-02-09 00:34:24 +03:00
?> ?=([@tas @ ~] way)
2019-02-06 05:21:41 +03:00
=/ lab i.way
2019-02-12 00:42:54 +03:00
=/ test-cor (~(get by test-cores) lab)
?~ test-cor
~& [%ph-dropping lab]
`this
2019-03-08 08:15:42 +03:00
=+ |- ^- $: thru-effects=(list unix-effect)
events=(list ph-event)
2019-03-07 10:31:14 +03:00
cor=_u.test-cor
==
2019-03-08 08:15:42 +03:00
?~ ufs.afs
2019-03-07 10:31:14 +03:00
[~ ~ u.test-cor]
=. effect-log.u.test-cor
2019-03-08 08:15:42 +03:00
[[who i.ufs]:afs effect-log.u.test-cor]
=+ ^- [thru=? events-1=(list ph-event) cor=_cor.u.test-cor]
(route:cor.u.test-cor now.hid who.afs i.ufs.afs)
2019-03-07 10:31:14 +03:00
=. cor.u.test-cor cor
2019-03-08 08:15:42 +03:00
=+ $(ufs.afs t.ufs.afs)
2019-03-07 10:31:14 +03:00
:+ ?: thru
2019-03-08 08:15:42 +03:00
[i.ufs.afs thru-effects]
thru-effects
2019-03-07 10:31:14 +03:00
(weld events-1 events)
cor
2019-03-08 08:15:42 +03:00
=. u.test-cor cor
2019-02-12 02:25:25 +03:00
=. test-cores (~(put by test-cores) lab u.test-cor)
2019-03-08 08:15:42 +03:00
=/ moves-1 (publish-aqua-effects who.afs thru-effects)
=^ moves-2 this (run-events lab events)
[(weld moves-1 moves-2) this]
2019-03-07 10:31:14 +03:00
::
:: Subscribe to effects
::
++ peer-effects
|= pax=path
^- (quip move _this)
?. ?=(~ pax)
~& [%ph-bad-peer-effects pax]
`this
`this
2019-03-13 14:50:56 +03:00
::
:: Subscription cancelled
::
++ pull
|= pax=path
~& [%ph-unsubscribed pax ost.hid]
`+>.$
2019-02-06 05:21:41 +03:00
--