=, clay =* dude dude:gall |% +$ pike $: sync=(unit [=ship =desk]) hash=@uv =zest wic=(set weft) == :: +$ pikes (map desk pike) :: :: $rung: reference to upstream commit :: +$ rung [=aeon =weft] :: +$ sync-state [nun=@ta kid=(unit desk) let=@ud] +$ sink (unit [her=@p sud=desk kid=(unit desk) let=@ud]) :: +report-prep: get data required for reports :: ++ report-prep |= [our=@p now=@da] =/ ego (scot %p our) =/ wen (scot %da now) :* .^(rock:tire %cx /(scot %p our)//(scot %da now)/tire) .^(=cone %cx /(scot %p our)//(scot %da now)/domes) .^((map desk [ship desk]) %gx /[ego]/hood/[wen]/kiln/sources/noun) .^ (map [desk ship desk] sync-state) %gx /[ego]/hood/[wen]/kiln/syncs/noun == == :: +report-vats: report on all desk installations :: ++ report-vats |= [our=@p now=@da] ^- tang =/ desks .^((set desk) %cd /(scot %p our)/base/(scot %da now)) =/ prep (report-prep our now) %+ turn ~(tap in desks) |=(syd=desk (report-vat prep our now syd)) :: +report-vat: report on a single desk installation :: ++ report-vat |= $: $: tyr=rock:tire =cone sor=(map desk [ship desk]) zyn=(map [desk ship desk] sync-state) == our=ship now=@da syd=desk == ^- tank =/ ego (scot %p our) =/ wen (scot %da now) =+ .^(=cass %cw /[ego]/[syd]/[wen]) ?: =(ud.cass 0) leaf+"desk does not yet exist: {}" ?: =(%kids syd) =+ .^(hash=@uv %cz /[ego]/[syd]/[wen]) leaf+"%kids %cz hash: {}" =/ kel-path /[ego]/[syd]/[wen]/sys/kelvin ?. .^(? %cu kel-path) leaf+"bad desk: {}" =+ .^(=waft %cx kel-path) :+ %rose ["" "{}" "::"] ^- tang =/ hash .^(@uv %cz /[ego]/[syd]/[wen]) =/ =sink ?~ s=(~(get by sor) syd) ~ ?~ z=(~(get by zyn) syd u.s) ~ `[-.u.s +.u.s +.u.z] =/ meb=(list @uv) ?~ sink [hash]~ (mergebase-hashes our syd now her.u.sink sud.u.sink) =/ dek (~(got by tyr) syd) =/ =dome (~(got by cone) our syd) =/ [on=(list [@tas ?]) of=(list [@tas ?])] (skid ~(tap by ren.dome) |=([* ?] +<+)) =/ sat ?- zest.dek %live "running" %dead "suspended" %held "suspended until next update" == =/ kul=tape %+ roll %+ sort ~(tap in (waft-to-wefts:clay waft)) |= [a=weft b=weft] ?: =(lal.a lal.b) (lte num.a num.b) (lte lal.a lal.b) |= [=weft =tape] (welp " {<[lal num]:weft>}" tape) :~ leaf/"/sys/kelvin: {kul}" leaf/"base hash: {?.(=(1 (lent meb)) <(head meb)>)}" leaf/"%cz hash: {}" :: leaf/"app status: {sat}" leaf/"force on: {?:(=(~ on) "~" )}" leaf/"force off: {?:(=(~ of) "~" )}" :: leaf/"publishing ship: {?~(sink <~> <(get-publisher our syd now)>)}" leaf/"updates: {?~(sink "local" "remote")}" leaf/"source ship: {?~(sink <~> )}" leaf/"source desk: {?~(sink <~> )}" leaf/"source aeon: {?~(sink <~> )}" leaf/"kids desk: {?~(sink <~> ?~(kid.u.sink <~> ))}" leaf/"pending updates: {<`(list [@tas @ud])`~(tap in wic.dek)>}" == :: +report-kids: non-vat cz hash report for kids desk :: ++ report-kids |= [our=ship now=@da] ^- tank =/ syd %kids =/ ego (scot %p our) =/ wen (scot %da now) ?. (~(has in .^((set desk) %cd /[ego]//[wen])) syd) leaf/"no %kids desk" =+ .^(hash=@uv %cz /[ego]/[syd]/[wen]) leaf/"%kids %cz hash: {}" :: +read-bill-foreign: read /desk/bill from a foreign desk :: ++ read-bill-foreign |= [=ship =desk =aeon] ^- (list dude) ~| +< =/ her (scot %p ship) =/ syd (scot %tas desk) =/ yon (scot %ud aeon) :: =/ dom .^(domo cv/~[her syd yon]) =/ tak ~| aeons=~(key by hit.dom) (scot %uv (~(got by hit.dom) aeon)) =/ yak .^(yaki cs/~[her syd yon %yaki tak]) =/ fil (~(get by q.yak) /desk/bill) ?~ fil ~ =/ lob (scot %uv u.fil) =/ peg .^(page cs/~[her syd yon %blob lob]) ;;((list dude) q.peg) :: +read-bill: read contents of /desk/bill manifest :: ++ read-bill |= [our=ship =desk now=@da] =/ pax (en-beam [our desk da+now] /desk/bill) ?. .^(? cu/pax) *(list dude) .^((list dude) cx/pax) :: ++ get-remote-diff |= [our=ship here=desk now=@da her=ship there=desk when=aeon] =+ .^(our-hash=@uv cz/[(scot %p our) here (scot %da now) ~]) =+ .^(her-hash=@uv cz/[(scot %p her) there (scot %ud when) ~]) !=(our-hash her-hash) :: ++ get-publisher |= [our=ship =desk now=@da] ^- (unit ship) =/ pax /(scot %p our)/[desk]/(scot %da now)/desk/ship ?. .^(? %cu pax) ~ `.^(ship %cx pax) :: ++ get-apps-live |= [our=ship =desk now=@da] ^- (list dude) %+ murn (get-apps-have our desk now) |=([=dude live=?] ?.(live ~ `dude)) :: +get-apps-have: find which apps Gall is running on a desk :: ++ get-apps-have |= [our=ship =desk now=@da] ^- (list [=dude live=?]) %~ tap in .^((set [=dude live=?]) ge+/(scot %p our)/[desk]/(scot %da now)) :: ++ mergebase-hashes |= [our=@p syd=desk now=@da her=ship sud=desk] =/ her (scot %p her) =/ ego (scot %p our) =/ wen (scot %da now) %+ turn .^((list tako) %cs ~[ego syd wen %base her sud]) |=(=tako .^(@uv %cs ~[ego syd wen %hash (scot %uv tako)])) :: ++ enjs =, enjs:format |% ++ tim |= t=@ ^- json (numb (fall (mole |.((unm:chrono:userlib t))) 0)) :: ++ cass |= c=^cass %- pairs :~ ud+(numb ud.c) da+(tim da.c) == :: ++ weft |= w=^weft %- pairs :~ name+s+lal.w kelvin+(numb num.w) == :: ++ rung |= r=^rung %- pairs :~ aeon+(numb aeon.r) weft+(weft weft.r) == -- --