:: publish [landscape] :: :: stores notebooks in clay, subscribes and allow subscriptions to notebooks :: /- *publish /- *group /- group-hook /- *permission-hook /- *permission-group-hook /- *permission-store /- *invite-store /- *metadata-store /- *metadata-hook /- contact-view /- pull-hook /- push-hook /+ *server /+ *publish /+ cram /+ default-agent /+ dbug /+ verb /+ grpl=group /+ group-store /+ graph-store /+ resource :: ~% %publish ..is ~ |% +$ card card:agent:gall :: +$ collection-zero [* pos=(map @tas *) *] :: +$ state-zero $: pubs=(map @tas collection-zero) * == :: +$ state-two $: our-paths=(list path) books=(map @tas notebook-2) subs=(map [@p @tas] notebook-2) tile-num=@ud == :: +$ state-three $: our-paths=(list path) books=(map [@p @tas] notebook) tile-num=@ud $= limbo $: notes=(map [@p @tas @tas] note) comments=(map [@p @tas @tas @da] comment) == == :: +$ versioned-state $% [%1 state-two] [%2 state-two] [%3 state-three] [%4 state-three] [%5 state-three] [%6 state-three] [%7 state-three] == :: +$ metadata-delta $% $: %add group-path=path app-path=path title=@t desc=@t author=@p created=@da == [%remove author=@p book=@tas] == -- :: =| [%7 state-three] =* state - %- agent:dbug %+ verb | ^- agent:gall =< |_ bol=bowl:gall +* this . def ~(. (default-agent this %|) bol) main ~(. +> bol) :: ++ on-init ^- (quip card _this) =/ rav [%sing %t [%da now.bol] /app/publish/notebooks] :_ this :~ [%pass /view-bind %arvo %e %connect [~ /'publish-view'] %publish] [%pass /read/paths %arvo %c %warp our.bol q.byk.bol `rav] (invite-poke:main [%create /publish]) :* %pass /invites %agent [our.bol %invite-store] %watch /invitatory/publish == :* %pass / %agent [our.bol %invite-store] %poke %invite-action !>([%create /publish]) == :* %pass /srv %agent [our.bol %file-server] %poke %file-server-action !>([%serve-dir /'~publish' /app/landscape %.n %.y]) == [%pass /groups %agent [our.bol %group-store] %watch /groups] == :: ++ on-save !>(state) :: ++ on-load |= old=vase ^- (quip card _this) =/ old-state=(each versioned-state tang) (mule |.(!<(versioned-state old))) =| cards=(list card) |^ ?: ?=(%| -.old-state) =/ zero !<(state-zero old) =/ rav [%next %t [%da now.bol] /app/publish/notebooks] =/ init-cards=(list card) :~ [%pass /read/paths %arvo %c %warp our.bol q.byk.bol `rav] :* %pass /permissions %agent [our.bol %permission-store] %watch /updates == (invite-poke:main [%create /publish]) :* %pass /invites %agent [our.bol %invite-store] %watch /invitatory/publish == [%pass /bind %arvo %e %disconnect [~ /'~publish']] [%pass /view-bind %arvo %e %connect [~ /'publish-view'] %publish] :* %pass /srv %agent [our.bol %file-server] %poke %file-server-action !>([%serve-dir /'~publish' /app/landscape %.n %.y]) == == =+ ^- [kick-cards=(list card) old-subs=(jug @tas @p)] kick-subs =/ inv-scry-pax /(scot %p our.bol)/invite-store/(scot %da now.bol)/invitatory/publish/noun =/ inv=(unit invitatory) .^((unit invitatory) %gx inv-scry-pax) =| new-state=state-two =? tile-num.new-state ?=(^ inv) ~(wyt by u.inv) %= $ old-state [%& %2 new-state] :: cards ;: weld kick-cards init-cards (move-files old-subs) == == ?- -.p.old-state %1 %= $ -.p.old-state %2 :: cards %- zing %+ turn ~(tap by books.p.old-state) |= [name=@tas book=notebook-2] ^- (list card) =/ group-host=(unit @p) ?> ?=(^ writers.book) (slaw %p i.writers.book) ?~ group-host ~ ?: =(u.group-host our.bol) ~ :~ %- perm-group-hook-poke:main [%associate writers.book [[writers.book %white] ~ ~]] :: (perm-hook-poke:main [%add-owned writers.book writers.book]) == == :: %2 %= $ p.old-state =/ new-books=(map [@p @tas] notebook) %- %~ uni by %- ~(run by subs.p.old-state) |= old-notebook=notebook-2 ^- notebook-3 (convert-notebook-2-3 old-notebook) ^- (map [@p @tas] notebook) %- ~(rep by books.p.old-state) |= [[key=@tas val=notebook-2] out=(map [@p @tas] notebook)] ^- (map [@p @tas] notebook) %+ ~(put by out) [our.bol key] (convert-notebook-2-3 val) [%3 our-paths.p.old-state new-books tile-num.p.old-state [~ ~]] == :: %3 %= $ -.p.old-state %4 :: cards %+ welp cards :~ [%pass /bind %arvo %e %disconnect [~ /'~publish']] [%pass /view-bind %arvo %e %connect [~ /'publish-view'] %publish] :* %pass /srving %agent [our.bol %file-server] %poke %file-server-action !>([%serve-dir /'~publish' /app/landscape %.n %.y]) == == == :: %4 %= $ p.old-state =/ new-books=(map [@p @tas] notebook) %- ~(run by books.p.old-state) |= old-notebook=notebook-3 ^- notebook-3 (convert-notebook-3-4 old-notebook) [%5 our-paths.p.old-state new-books tile-num.p.old-state [~ ~]] :: cards %+ welp cards :~ [%pass /groups %agent [our.bol %group-store] %watch /groups] == == :: %5 %= $ -.p.old-state %6 cards %+ weld cards %+ roll ~(tap by books.p.old-state) |= [[[who=@p book=@tas] nb=notebook] out=(list card)] ^- (list card) ?. =(who our.bol) out =/ rid (de-path:resource writers.nb) =/ grp=(unit group) (scry-group:grup:main rid) ?~ grp out ?: hidden.u.grp out =/ =tag [%publish (cat 3 'writers-' book)] :_ out (group-proxy-poke entity.rid %add-tag rid tag members.u.grp) == :: %6 %_ $ -.p.old-state %7 :: cards %+ weld cards %+ roll ~(tap by books.p.old-state) |= [[[who=@p book=@tas] nb=notebook] out=(list card)] ^- (list card) =/ =resource [who book] ?. =(who our.bol) :_ out (poke-graph-pull %add who resource) =/ =graph:graph-store (notebook-to-graph nb) %+ weld out ^- (list card) :~ %- poke-graph-store :* %0 date-created.nb %add-graph resource graph `%graph-validator-publish == (poke-graph-push %add resource) == == :: %7 [cards this(state p.old-state)] == ++ notebook-to-graph |= =notebook ^- graph:graph-store %+ gas:orm:graph-store *graph:graph-store %+ turn ~(tap by notes.notebook) |= [@ta =note] ^- [atom node:graph-store] :- date-created.note (note-to-node note) :: ++ comments-to-children |= [=index:graph-store =note] ^- internal-graph:graph-store ?: =(~ comments.note) [%empty ~] :- %graph %+ gas:orm:graph-store *graph:graph-store %+ turn ~(tap by comments.note) |= [when=@da =comment] ^- [atom node:graph-store] :- when :_ [%empty ~] ^- post:graph-store :* author.comment (snoc index when) when [%text content.comment]~ ~ ~ == :: ++ note-to-node |= =note ^- node:graph-store =/ =index:graph-store ~[date-created.note] =/ contents=(list content:graph-store) :~ [%text title.note] [%text file.note] == :_ (comments-to-children index note) ^- post:graph-store :* author.note index date-created.note contents ~ ~ == :: ++ poke-our |= [app=term =cage] [%pass / %agent [our.bol app] %poke cage] :: ++ poke-graph-pull |= =action:pull-hook (poke-our %graph-pull-hook pull-hook-action+!>(action)) :: ++ poke-graph-store |= =update:graph-store (poke-our %graph-store graph-update+!>(update)) :: ++ poke-graph-push |= =action:push-hook (poke-our %graph-push-hook push-hook-action+!>(action)) ++ convert-notebook-3-4 |= prev=notebook-3 ^- notebook-3 %= prev writers ?> ?=(^ writers.prev) :- %ship ?: =('~' i.writers.prev) t.writers.prev writers.prev :: subscribers ?> ?=(^ subscribers.prev) :- %ship %+ scag 2 ?: =('~' i.subscribers.prev) t.subscribers.prev subscribers.prev == :: ++ convert-comment-2-3 |= prev=comment-2 ^- comment-3 %= prev content [content.prev %.n] == :: ++ convert-note-2-3 |= prev=note-2 ^- note-3 %= prev comments [(~(run by comments.prev) convert-comment-2-3) %.n] == :: ++ convert-notebook-2-3 |= prev=notebook-2 ^- notebook-3 %= prev notes %- ~(run by notes.prev) |= =note-2 (convert-note-2-3 note-2) == :: ++ kick-subs ^- [(list card) (jug @tas @p)] =+ ^- [paths=(list path) subs=(jug @tas @p)] %+ roll ~(tap by sup.bol) |= [[duct [who=@p pax=path]] paths=(list path) subs=(jug @tas @p)] ^- [(list path) (jug @tas @p)] ?. ?=([%collection @ ~] pax) [paths subs] =/ book-name i.t.pax :- [pax paths] (~(put ju subs) book-name who) ?~ paths [~ subs] [[%give %kick paths ~]~ subs] :: ++ send-invites |= [book=@tas subscribers=(set @p)] ^- (list card) %+ turn ~(tap in subscribers) |= who=@p ^- card =/ uid (sham %publish who book eny.bol) =/ inv=invite :* our.bol %publish /notebook/[book] who (crip "invite for notebook {}/{(trip book)}") == =/ act=invite-action [%invite /publish uid inv] [%pass /invite %agent [who %invite-hook] %poke %invite-action !>(act)] :: ++ move-files |= old-subs=(jug @tas @p) ^- (list card) =+ ^- [cards=(list card) sob=soba:clay] %+ roll .^((list path) %ct (weld our-beak:main /web/publish)) |= [pax=path car=(list card) sob=soba:clay] ^- [(list card) soba:clay] ?+ pax [car sob] :: [%web %publish @ %publish-info ~] =/ book-name i.t.t.pax =/ old=old-info .^(old-info %cx (welp our-beak:main pax)) =/ group-pax /~/(scot %p our.bol)/[book-name] =/ book=notebook-info [title.old '' =(%open comments.old) / /] =+ ^- [grp-car=(list card) write-pax=path read-pax=path] (make-groups:main book-name [group-pax ~ %.n %.n] title.old '') =. writers.book write-pax =. subscribers.book read-pax =/ inv-car (send-invites book-name (~(get ju old-subs) book-name)) :- :(weld car grp-car inv-car) ^- soba:clay :+ [pax %del ~] :- /app/publish/notebooks/[book-name]/publish-info [%ins %publish-info !>(book)] sob :: [%web %publish @ @ %udon ~] =/ book i.t.t.pax =/ note i.t.t.t.pax :- car :+ [pax %del ~] :- /app/publish/notebooks/[book]/[note]/udon [%ins %udon !>(.^(@t %cx (welp our-beak:main pax)))] sob :: [%web %publish @ @ @ %publish-comment ~] =/ book i.t.t.pax =/ note i.t.t.t.pax =/ comm i.t.t.t.t.pax =/ old-com .^(old-comment %cx (welp our-beak:main pax)) =/ new=comment-2 [creator.old-com date-created.old-com content.old-com] :- car :+ [pax %del ~] :- /app/publish/notebooks/[book]/[note]/[comm]/publish-comment [%ins %publish-comment !>(new)] sob == [[%pass /move-files %arvo %c %info q.byk.bol %& sob] cards] -- :: ++ on-poke |= [mar=mark vas=vase] ^- (quip card _this) ?+ mar (on-poke:def mar vas) :: %noun ?+ q.vas [~ this] :: %flush-limbo [~ this(limbo [~ ~])] :: %reset-warp =/ rav [%sing %t [%da now.bol] /app/publish/notebooks] :_ this [%pass /read/paths %arvo %c %warp our.bol q.byk.bol `rav]~ == :: %handle-http-request =+ !<([id=@ta req=inbound-request:eyre] vas) :_ this %+ give-simple-payload:app id %+ require-authorization:app req handle-http-request:main :: %publish-action =^ cards state (poke-publish-action:main !<(action vas)) [cards this] == :: ++ on-watch |= pax=path ^- (quip card _this) ?+ pax (on-watch:def pax) [%http-response *] [~ this] [%primary ~] [~ this] [%notebook @ ~] =^ cards state (watch-notebook:main pax) [cards this] == :: ++ on-leave on-leave:def ++ on-peek |= pax=path ^- (unit (unit cage)) ?+ pax (on-peek:def pax) [%t %limbo ~] :^ ~ ~ %noun !> ^- (list path) %+ weld %+ turn ~(tap by notes.limbo) |= [[who=@p book=@tas note=@tas] *] ^- path /(scot %p who)/[book]/[note] %+ turn ~(tap by comments.limbo) |= [[who=@p book=@tas note=@tas comment=@da] *] ^- path /(scot %p who)/[book]/[note]/(scot %ds comment) :: [%x %limbo @ @ @ ~] =/ host=(unit @p) (slaw %p i.t.t.pax) ?~ host [~ ~] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ note (~(get by notes.limbo) u.host book-name note-name) ?~ note ~ ``noun+!>(u.note) :: [%x %limbo @ @ @ @ ~] =/ host=(unit @p) (slaw %p i.t.t.pax) =/ comment-date=(unit @da) (slaw %da i.t.t.t.t.t.pax) ?~ host [~ ~] ?~ comment-date [~ ~] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ comment (~(get by comments.limbo) u.host book-name note-name u.comment-date) ?~ comment ~ ``noun+!>(u.comment) :: [%x %book @ @ ~] =/ host=(unit @p) (slaw %p i.t.t.pax) =/ book-name i.t.t.t.pax ?~ host [~ ~] =/ book (~(get by books) u.host book-name) ?~ book ~ ``noun+!>(u.book) == :: ++ on-agent |= [wir=wire sin=sign:agent:gall] ^- (quip card _this) ?- -.sin %poke-ack ?: ?=([%join-group @ @ ~] wir) ?^ p.sin (on-agent:def wir sin) =/ =ship (slav %p i.t.wir) =^ cards state (subscribe-notebook ship i.t.t.wir) [cards this] ?~ p.sin [~ this] =^ cards state (handle-poke-fail:main wir) [cards this] :: If our subscribe failed, delete notebook associated with subscription if :: it exists :: %watch-ack ?. ?=([%subscribe @ @ ~] wir) (on-agent:def wir sin) ?~ p.sin [~ this] =/ who=@p (slav %p i.t.wir) =/ book=@tas i.t.t.wir =/ del [%del-book who book] :_ this(books (~(del by books) who book)) [%give %fact [/primary]~ %publish-primary-delta !>(del)]~ :: Resubscribe to any subscription we get kicked from. The case of actually :: getting banned from a notebook is handled by %watch-ack :: %kick ?+ wir [~ this] :: [%subscribe @ @ ~] =/ who=@p (slav %p i.t.wir) =/ book=@tas i.t.t.wir =/ wen=(unit @da) (get-last-update:main who book) =/ pax=path ?~ wen /notebook/[book] /notebook/[book]/(scot %da u.wen) :_ this [%pass wir %agent [who %publish] %watch pax]~ :: [%permissions ~] :_ this [%pass /permissions %agent [our.bol %permission-store] %watch /updates]~ :: [%groups ~] :_ this [%pass /groups %agent [our.bol %group-store] %watch /groups]~ :: [%invites ~] :_ this :_ ~ :* %pass /invites %agent [our.bol %invite-store] %watch /invitatory/publish == == :: %fact ?+ wir (on-agent:def wir sin) [%subscribe @ @ ~] =/ who=@p (slav %p i.t.wir) =/ book-name i.t.t.wir ?> ?=(%publish-notebook-delta p.cage.sin) =^ cards state (handle-notebook-delta:main !<(notebook-delta q.cage.sin) state) [cards this] :: [%groups ~] =^ cards state (handle-group-update:main !<(update:group-store q.cage.sin)) [cards this] :: [%invites ~] =^ cards state (handle-invite-update:main !<(invite-update q.cage.sin)) [cards this] :: [%collection *] [~ this] == == :: ++ on-arvo |= [wir=wire sin=sign-arvo] ^- (quip card _this) ?+ wir (on-arvo:def wir sin) :: [%read %paths ~] ?> ?=([?(%b %c) %writ *] sin) =/ rot=riot:clay +>.sin ?> ?=(^ rot) =^ cards state (read-paths:main u.rot) [cards this] :: [%read %info *] ?> ?=([?(%b %c) %writ *] sin) =/ rot=riot:clay +>.sin =^ cards state (read-info:main t.t.wir rot) [cards this] :: [%read %note *] ?> ?=([?(%b %c) %writ *] sin) =/ rot=riot:clay +>.sin =^ cards state (read-note:main t.t.wir rot) [cards this] :: [%read %comment *] ?> ?=([?(%b %c) %writ *] sin) =/ rot=riot:clay +>.sin =^ cards state (read-comment:main t.t.wir rot) [cards this] :: [%bind ~] [~ this] :: [%view-bind ~] [~ this] == :: ++ on-fail on-fail:def -- :: |_ bol=bowl:gall ++ grup ~(. grpl bol) :: ++ metadata-store-poke |= act=metadata-action ^- card [%pass / %agent [our.bol %metadata-store] %poke %metadata-action !>(act)] :: :: ++ get-last-update |= [host=@p book-name=@tas] ^- (unit @da) =/ book (~(get by books) host book-name) ?~ book ~ =/ wen date-created.u.book %- some %- ~(rep by notes.u.book) |= [[@tas =note] out=_wen] ^- @da %+ max out %+ max last-edit.note %- ~(rep by comments.note) |= [[@da =comment] out=_out] (max date-created.comment out) :: ++ get-notebook-from-date |= [host=@p book-name=@tas wen=@da] ^- notebook =/ book (~(got by books) host book-name) %= book notes %- ~(rep by notes.book) |= [[nom=@tas not=note] out=(map @tas note)] ^- (map @tas note) ?: (gth last-edit.not wen) (~(put by out) nom not) =. comments.not %- ~(rep by comments.not) |= [[nam=@da com=comment] out=(map @da comment)] ?: (gth date-created.com wen) (~(put by out) nam com) out ?~ comments.not out (~(put by out) nom not) == :: ++ merge-notebooks |= [base=notebook diff=notebook] ^- notebook %= diff notes %- ~(rep by notes.diff) |= [[nom=@tas not=note] out=_notes.base] =/ base-note=(unit note) (~(get by out) nom) ?~ base-note (~(put by out) nom not) =. comments.u.base-note (~(uni by comments.u.base-note) comments.not) (~(put by out) nom u.base-note) == :: ++ read-paths |= ran=rant:clay ^- (quip card _state) =/ rav [%next %t [%da now.bol] /app/publish/notebooks] =/ new (filter-and-sort-paths !<((list path) q.r.ran)) =/ dif (diff-paths our-paths new) =^ del-moves state (del-paths del.dif) =^ add-moves state (add-paths add.dif) :: =/ cards=(list card) ;: weld [%pass /read/paths %arvo %c %warp our.bol q.byk.bol `rav]~ del-moves add-moves == [cards state(our-paths new)] :: ++ read-info |= [pax=path rot=riot:clay] ^- (quip card _state) ?> ?=([%app %publish %notebooks @ %publish-info ~] pax) =/ book-name i.t.t.t.pax ?~ rot [~ state] =/ info=notebook-info !<(notebook-info q.r.u.rot) =/ new-book=notebook :* title.info description.info comments.info writers.info subscribers.info now.bol ~ ~ ~ == =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] =/ delta=notebook-delta [%edit-book our.bol book-name new-book] =^ cards state (handle-notebook-delta delta state) :_ state :* [%pass (welp /read/info pax) %arvo %c %warp our.bol rif] cards == :: ++ read-note |= [pax=path rot=riot:clay] ^- (quip card _state) ?> ?=([%app %publish %notebooks @ @ %udon ~] pax) =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ book (~(get by books) our.bol book-name) ?~ book [~ state] =/ old-note (~(get by notes.u.book) note-name) ?~ old-note [~ state] ?~ rot [~ state] =/ udon !<(@t q.r.u.rot) =/ new-note=note (form-note note-name udon) =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] =/ delta=notebook-delta [%edit-note our.bol book-name note-name new-note] =^ cards state (handle-notebook-delta delta state) :_ state :* [%pass (welp /read/note pax) %arvo %c %warp our.bol rif] cards == :: ++ read-comment |= [pax=path rot=riot:clay] ^- (quip card _state) ?> ?=([%app %publish %notebooks @ @ @ %publish-comment ~] pax) ?~ rot [~ state] =/ comment-date (slaw %da i.t.t.t.t.t.pax) ?~ comment-date [~ state] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ com-2-3 !<(?(comment-2 comment-3) q.r.u.rot) =/ new-comment=comment-3 ?: ?=(comment-2 com-2-3) [author.com-2-3 date-created.com-2-3 content.com-2-3 %.n] com-2-3 =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] =/ delta=notebook-delta [%edit-comment our.bol book-name note-name u.comment-date new-comment] =^ cards state (handle-notebook-delta delta state) :_ state :* [%pass (welp /read/comment pax) %arvo %c %warp our.bol rif] cards == :: ++ filter-and-sort-paths |= paths=(list path) ^- (list path) %+ sort %+ skim paths |= pax=path ?| ?=([%app %publish %notebooks @ %publish-info ~] pax) ?=([%app %publish %notebooks @ @ %udon ~] pax) ?=([%app %publish %notebooks @ @ @ %publish-comment ~] pax) == |= [a=path b=path] ^- ? (lte (lent a) (lent b)) :: ++ diff-paths |= [old=(list path) new=(list path)] ^- [del=(list path) add=(list path)] =/ del=(list path) (skim old |=(p=path ?=(~ (find [p]~ new)))) =/ add=(list path) (skim new |=(p=path ?=(~ (find [p]~ old)))) [del add] :: ++ del-paths |= paths=(list path) ^- (quip card _state) %+ roll paths |= [pax=path cad=(list card) sty=_state] ?+ pax !! [%app %publish %notebooks @ %publish-info ~] =/ book-name i.t.t.t.pax =/ delta=notebook-delta [%del-book our.bol book-name] =^ cards sty (handle-notebook-delta delta sty) [(weld cards cad) sty] :: [%app %publish %notebooks @ @ %udon ~] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ book (~(get by books.sty) our.bol book-name) ?~ book [cad sty] =. notes.u.book (~(del by notes.u.book) note-name) =/ delta=notebook-delta [%del-note our.bol book-name note-name] =^ cards sty (handle-notebook-delta delta sty) [(weld cards cad) sty] :: [%app %publish %notebooks @ @ @ %publish-comment ~] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ comment-date (slaw %da i.t.t.t.t.t.pax) ?~ comment-date [cad sty] =/ delta=notebook-delta [%del-comment our.bol book-name note-name u.comment-date] =^ cards sty (handle-notebook-delta delta sty) [(weld cards cad) sty] == :: ++ add-paths |= paths=(list path) ^- (quip card _state) %+ roll paths |= [pax=path cad=(list card) sty=_state] ^- (quip card _state) ?+ pax !! [%app %publish %notebooks @ %publish-info ~] =/ book-name i.t.t.t.pax =/ info=notebook-info .^(notebook-info %cx (welp our-beak pax)) =* title title.info =* description description.info =/ new-book=notebook :* title description comments.info writers.info subscribers.info now.bol ~ ~ ~ == =+ ^- [grp-car=(list card) write-pax=path read-pax=path] ?: =(writers.new-book /) =/ group-path /~/(scot %p our.bol)/[book-name] (make-groups book-name [group-path ~ %.n %.n] title description) [~ writers.info subscribers.info] =. writers.new-book write-pax =. subscribers.new-book read-pax =+ ^- [read-cards=(list card) notes=(map @tas note)] (watch-notes /app/publish/notebooks/[book-name]) =. notes.new-book notes =/ delta=notebook-delta [%add-book our.bol book-name new-book] =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] =^ update-cards sty (handle-notebook-delta delta sty) :_ sty ;: weld grp-car [%pass (welp /read/info pax) %arvo %c %warp our.bol rif]~ read-cards update-cards cad == :: [%app %publish %notebooks @ @ %udon ~] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ new-note=note (scry-note pax) =+ ^- [read-cards=(list card) comments=(map @da comment)] (watch-comments /app/publish/notebooks/[book-name]/[note-name]) =. comments.new-note comments =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] =/ delta=notebook-delta [%add-note our.bol book-name note-name new-note] =^ update-cards sty (handle-notebook-delta delta sty) :_ sty ;: weld [%pass (welp /read/note pax) %arvo %c %warp our.bol rif]~ read-cards update-cards cad == :: [%app %publish %notebooks @ @ @ %publish-comment ~] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ comment-name (slaw %da i.t.t.t.t.t.pax) ?~ comment-name [~ sty] =/ com-2-3 .^(?(comment-2 comment-3) %cx (welp our-beak pax)) =/ new-com=comment-3 ?: ?=(comment-2 com-2-3) [author.com-2-3 date-created.com-2-3 content.com-2-3 %.n] com-2-3 =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] :: =/ delta=notebook-delta [%add-comment our.bol book-name note-name u.comment-name new-com] =^ update-cards sty (handle-notebook-delta delta sty) :_ sty ;: weld [%pass (welp /read/comment pax) %arvo %c %warp our.bol rif]~ update-cards cad == == :: ++ watch-notes |= pax=path ^- [(list card) (map @tas note)] =/ paths .^((list path) %ct (weld our-beak pax)) %+ roll paths |= [pax=path cards=(list card) notes=(map @tas note)] ?. ?=([%app %publish %notebooks @ @ %udon ~] pax) [cards notes] =/ book-name i.t.t.t.pax =/ note-name i.t.t.t.t.pax =/ new-note (scry-note pax) =^ comment-cards comments.new-note (watch-comments /app/publish/notebooks/[book-name]/[note-name]) =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] :_ (~(put by notes) note-name new-note) ;: weld [%pass (welp /read/note pax) %arvo %c %warp our.bol rif]~ comment-cards cards == :: ++ watch-comments |= pax=path ^- [(list card) (map @da comment)] =/ paths .^((list path) %ct (weld our-beak pax)) %+ roll paths |= [pax=path cards=(list card) comments=(map @da comment)] ?. ?=([%app %publish %notebooks @ @ @ %publish-comment ~] pax) [cards comments] =/ comment-name (slaw %da i.t.t.t.t.t.pax) ?~ comment-name [cards comments] =/ new-com .^(comment %cx (welp our-beak pax)) =/ rif=riff:clay [q.byk.bol `[%next %x [%da now.bol] pax]] :_ (~(put by comments) u.comment-name new-com) [[%pass (welp /read/comment pax) %arvo %c %warp our.bol rif] cards] :: ++ scry-note |= pax=path ^- note ?> ?=([%app %publish %notebooks @ @ %udon ~] pax) =/ note-name i.t.t.t.t.pax =/ udon=@t .^(@t %cx (welp our-beak pax)) (form-note note-name udon) :: ++ form-snippet |= file=@t ^- @t =/ front-idx (add 3 (need (find ";>" (trip file)))) =/ front-matter (cat 3 (end 3 front-idx file) 'dummy text\0a') =/ body (cut 3 [front-idx (met 3 file)] file) (of-wain:format (scag 1 (to-wain:format body))) :: ++ form-note |= [note-name=@tas file=@t] ^- note =/ snippet=@t (form-snippet file) =/ front-idx (add 3 (need (find ";>" (trip file)))) =/ front-matter (cat 3 (end 3 front-idx file) 'dummy text\0a') =/ meta=(each (map term knot) tang) %- mule |. %- ~(run by inf:(static:cram (ream front-matter))) |= a=dime ^- cord ?+ (end 3 1 p.a) (scot a) %t q.a == :: =/ author=@p our.bol =? author ?=(%.y -.meta) %+ fall (biff (~(get by p.meta) %author) (slat %p)) our.bol :: =/ title=@t note-name =? title ?=(%.y -.meta) (fall (~(get by p.meta) %title) note-name) :: =/ date-created=@da now.bol =? date-created ?=(%.y -.meta) %+ fall (biff (~(get by p.meta) %date-created) (slat %da)) now.bol :: =/ last-modified=@da now.bol =? last-modified ?=(%.y -.meta) %+ fall (biff (~(get by p.meta) %last-modified) (slat %da)) now.bol :: :* author title note-name date-created last-modified %.y file snippet ~ %.n == :: ++ handle-group-update |= =update:group-store ^- (quip card _state) ?. ?=(?(%remove-members %add-members) -.update) [~ state] =* ships ships.update =/ =path (en-path:resource resource.update) =/ book=(unit @tas) %+ roll ~(tap by books) |= [[[who=@p nom=@tas] book=notebook] out=(unit @tas)] ?. =(who our.bol) out ?. =(path subscribers.book) out `nom ?~ book [~ state] :_ state %- zing :- ^- (list card) %+ roll ~(tap by books) |= [[[who=@p book=@tas] nb=notebook] out=(list card)] ^- (list card) ?. =(who our.bol) out ?. =(writers.nb path) out =/ rid (de-path:resource writers.nb) =/ grp=(unit group) (scry-group:grup rid) ?~ grp out ?: hidden.u.grp out =/ =tag [%publish (cat 3 'writers-' book)] :_ out (group-proxy-poke entity.rid %add-tag rid tag members.u.grp) %+ turn ~(tap in ships) |= who=@p ?. (allowed who %read u.book) [%give %kick [/notebook/[u.book]]~ `who]~ ?: ?|(?=(%remove-members -.update) (is-managed-path:grup path)) ~ =/ uid (sham %publish who u.book eny.bol) =/ inv=invite :* our.bol %publish /notebook/[u.book] who (crip "invite for notebook {}/{(trip u.book)}") == =/ act=invite-action [%invite /publish uid inv] [%pass / %agent [our.bol %invite-hook] %poke %invite-action !>(act)]~ :: ++ handle-invite-update |= upd=invite-update ^- (quip card _state) ?+ -.upd [~ state] :: %delete [~ state] :: %invite [~ state] :: %decline [~ state] :: %accepted ?> ?=([@ @ *] path.invite.upd) =/ book i.t.path.invite.upd =/ group (group-from-book notebook+book^~) ?^ group (subscribe-notebook ship.invite.upd book) =/ rid=resource (de-path:resource ship+path.invite.upd) =/ join-wire=wire /join-group/[(scot %p ship.invite.upd)]/[book] =/ =cage :- %group-update !> ^- action:group-store [%add-members rid (sy our.bol ~)] :_ state [%pass join-wire %agent [entity.rid %group-push-hook] %poke cage]~ == :: ++ subscribe-notebook |= [=ship book=@tas] ^- (quip card _state) =/ pax=path /notebook/[book] =/ wir=wire /subscribe/[(scot %p ship)]/[book] =? tile-num (gth tile-num 0) (dec tile-num) =/ jon=json (frond:enjs:format %notifications (numb:enjs:format tile-num)) :_ state :~ [%pass wir %agent [ship %publish] %watch pax] [%give %fact [/publishtile]~ %json !>(jon)] == :: ++ watch-notebook |= pax=path ?> ?=([%notebook @ *] pax) =/ book-name i.t.pax ?. (allowed src.bol %read book-name) ~|("not permitted" !!) =/ book ?: ?=([%notebook @ @ ~] pax) =/ wen=@da (slav %da i.t.t.pax) (get-notebook-from-date our.bol book-name wen) (~(got by books) our.bol book-name) =/ delta=notebook-delta [%add-book our.bol book-name book] :_ state [%give %fact ~ %publish-notebook-delta !>(delta)]~ :: ++ our-beak /(scot %p our.bol)/[q.byk.bol]/(scot %da now.bol) :: ++ book-writers |= [host=@p book=@tas] ^- (set ship) =/ =notebook (~(got by books) host book) =/ rid=resource (de-path:resource writers.notebook) %- ~(uni in (fall (scry-tag:grup rid %admin) ~)) %+ fall (scry-tag:grup rid `tag`[%publish (cat 3 %writers- book)]) ~ :: ++ allowed |= [who=@p mod=?(%read %write) book=@tas] ^- ? =/ =notebook (~(got by books) our.bol book) =/ rid=resource (de-path:resource writers.notebook) ?: ?=(%read mod) (~(has in (members:grup rid)) who) (~(has in (book-writers our.bol book)) who) :: ++ write-file |= [pax=path cay=cage] ^- card =. pax (weld our-beak pax) [%pass (weld /write pax) %arvo %c %info (foal:space:userlib pax cay)] :: ++ delete-file |= pax=path ^- card =. pax (weld our-beak pax) [%pass (weld /delete pax) %arvo %c %info (fray:space:userlib pax)] :: ++ delete-dir |= pax=path ^- card =/ nor=nori:clay :- %& %+ turn .^((list path) %ct (weld our-beak pax)) |= pax=path ^- [path miso:clay] [pax %del ~] [%pass (weld /delete pax) %arvo %c %info q.byk.bol nor] :: ++ add-front-matter |= [fro=(map knot cord) udon=@t] ^- @t %- of-wain:format =/ tum (trip udon) =/ id (find ";>" tum) ?~ id %+ weld (front-to-wain fro) (to-wain:format (crip :(weld ";>\0a" tum))) %+ weld (front-to-wain fro) (to-wain:format (crip (slag u.id tum))) :: ++ front-to-wain |= a=(map knot cord) ^- wain =/ entries=wain %+ turn ~(tap by a) |= b=[knot cord] =/ c=[term cord] (,[term cord] b) (crip " [{<-.c>} {<+.c>}]") :: ?~ entries ~ ;: weld [':- :~' ~] entries [' ==' ~] == :: ++ give-primary-delta |= del=primary-delta ^- card [%give %fact [/primary]~ %publish-primary-delta !>(del)] :: ++ group-poke |= act=action:group-store ^- card [%pass / %agent [our.bol %group-store] %poke %group-action !>(act)] :: ++ group-proxy-poke |= [who=ship act=action:group-store] ^- card [%pass / %agent [who %group-push-hook] %poke %group-update !>(act)] :: ++ group-pull-hook-poke |= act=action:pull-hook ^- card [%pass / %agent [our.bol %group-pull-hook] %poke %pull-hook-action !>(act)] :: ++ contact-view-poke |= act=contact-view-action:contact-view ^- card [%pass / %agent [our.bol %contact-view] %poke %contact-view-action !>(act)] :: ++ contact-view-create |= [=path ships=(set ship) =policy title=@t description=@t] =/ rid=resource (de-path:resource path) =/ act=contact-view-action:contact-view [%create name.rid policy title description] (contact-view-poke act) :: ++ perm-hook-poke |= act=permission-hook-action ^- card :* %pass / %agent [our.bol %permission-hook] %poke %permission-hook-action !>(act) == :: ++ invite-poke |= act=invite-action ^- card [%pass / %agent [our.bol %invite-store] %poke %invite-action !>(act)] :: ++ perm-group-hook-poke |= act=permission-group-hook-action ^- card :* %pass / %agent [our.bol %permission-group-hook] %poke %permission-group-hook-action !>(act) == :: ++ generate-invites |= [book=@tas invitees=(set ship)] ^- (list card) %+ turn ~(tap in invitees) |= who=ship =/ uid (sham %publish who book eny.bol) =/ inv=invite :* our.bol %publish /(scot %p our.bol)/[book] who (crip "invite for notebook {}/{(trip book)}") == =/ act=invite-action [%invite /publish uid inv] [%pass / %agent [our.bol %invite-hook] %poke %invite-action !>(act)] :: ++ make-groups |= [book=@tas group=group-info title=@t about=@t] ^- [(list card) write=path read=path] ?> ?=(^ group-path.group) =/ scry-path ;: welp /(scot %p our.bol)/group-store/(scot %da now.bol) [%groups group-path.group] /noun == =/ rid=resource (de-path:resource group-path.group) =/ grp=(unit ^group) (scry-group:grup rid) ?: use-preexisting.group ?~ grp !! ?. (is-managed group-path.group) !! =/ =tag [%publish (cat 3 'writers-' book)] :_ [group-path.group group-path.group] [(group-proxy-poke entity.rid %add-tag rid tag members.u.grp)]~ :: =/ =policy *open:policy ?: make-managed.group ?^ grp [~ group-path.group group-path.group] ?. (is-managed group-path.group) !! =/ whole-grp (~(put in invitees.group) our.bol) :_ [group-path.group group-path.group] [(contact-view-create [group-path.group whole-grp policy title about])]~ :: make unmanaged group =* group-path group-path.group :_ [group-path group-path] ?^ grp ~ =/ rid=resource (de-path:resource group-path) :- (group-poke %add-group rid policy %.y) (generate-invites book (~(del in invitees.group) our.bol)) :: ++ handle-poke-fail |= wir=wire ^- (quip card _state) ?+ wir [~ state] :: new note failed, stash it in limbo :: [%forward %new-note @ @ @ ~] =/ host=@p (slav %p i.t.t.wir) =/ book-name i.t.t.t.wir =/ note-name i.t.t.t.t.wir =/ book (~(get by books) [host book-name]) ?~ book [~ state] =/ note (~(get by notes.u.book) note-name) ?~ note [~ state] =. notes.limbo (~(put by notes.limbo) [host book-name note-name] u.note) =. notes.u.book (~(del by notes.u.book) note-name) =/ del [%del-note host book-name note-name] :- [(give-primary-delta del)]~ state(books (~(put by books) [host book-name] u.book)) :: new comment failed, stash it in limbo :: [%forward %new-comment @ @ @ @ ~] =/ host=@p (slav %p i.t.t.wir) =/ book-name i.t.t.t.wir =/ note-name i.t.t.t.t.wir =/ comment-date=@da (slav %da i.t.t.t.t.t.wir) =/ book (~(get by books) [host book-name]) ?~ book [~ state] =/ note (~(get by notes.u.book) note-name) ?~ note [~ state] =/ comment (~(get by comments.u.note) comment-date) ?~ comment [~ state] =. comments.limbo %+ ~(put by comments.limbo) [host book-name note-name comment-date] u.comment =. comments.u.note (~(del by comments.u.note) comment-date) =. notes.u.book (~(put by notes.u.book) note-name u.note) =/ del [%del-comment host book-name note-name comment-date] :- [(give-primary-delta del)]~ state(books (~(put by books) [host book-name] u.book)) :: edit note failed, restore old version :: [%forward %edit-note @ @ @ ~] =/ host=@p (slav %p i.t.t.wir) =/ book-name i.t.t.t.wir =/ note-name i.t.t.t.t.wir =/ book (~(get by books) [host book-name]) ?~ book [~ state] =/ note (~(get by notes.limbo) host book-name note-name) ?~ note [~ state] =. notes.u.book (~(put by notes.u.book) note-name u.note) =/ del [%edit-note host book-name note-name u.note] :- [(give-primary-delta del)]~ %= state books (~(put by books) [host book-name] u.book) notes.limbo (~(del by notes.limbo) host book-name note-name) == :: edit comment failed, restore old version :: [%forward %new-comment @ @ @ @ ~] =/ host=@p (slav %p i.t.t.wir) =/ book-name i.t.t.t.wir =/ note-name i.t.t.t.t.wir =/ comment-date=@da (slav %da i.t.t.t.t.t.wir) =/ book (~(get by books) [host book-name]) ?~ book [~ state] =/ note (~(get by notes.u.book) note-name) ?~ note [~ state] =/ comment (~(get by comments.limbo) host book-name note-name comment-date) ?~ comment [~ state] =. comments.u.note (~(put by comments.u.note) comment-date u.comment) =. notes.u.book (~(put by notes.u.book) note-name u.note) =/ del [%edit-comment host book-name note-name comment-date u.comment] :- [(give-primary-delta del)]~ %= state books (~(put by books) [host book-name] u.book) :: comments.limbo %+ ~(del by comments.limbo) [host book-name note-name comment-date] u.comment == :: delete note failed, restore old version :: [%forward %del-note @ @ @ ~] =/ host=@p (slav %p i.t.t.wir) =/ book-name i.t.t.t.wir =/ note-name i.t.t.t.t.wir =/ book (~(get by books) [host book-name]) ?~ book [~ state] =/ note (~(get by notes.limbo) host book-name note-name) ?~ note [~ state] =. notes.u.book (~(put by notes.u.book) note-name u.note) =/ del [%add-note host book-name note-name u.note] :- [(give-primary-delta del)]~ %= state books (~(put by books) [host book-name] u.book) notes.limbo (~(del by notes.limbo) host book-name note-name) == :: delete comment failed, restore old version :: [%forward %del-comment @ @ @ @ ~] =/ host=@p (slav %p i.t.t.wir) =/ book-name i.t.t.t.wir =/ note-name i.t.t.t.t.wir =/ comment-date=@da (slav %da i.t.t.t.t.t.wir) =/ book (~(get by books) [host book-name]) ?~ book [~ state] =/ note (~(get by notes.u.book) note-name) ?~ note [~ state] =/ comment (~(get by comments.limbo) host book-name note-name comment-date) ?~ comment [~ state] =. comments.u.note (~(put by comments.u.note) comment-date u.comment) =. notes.u.book (~(put by notes.u.book) note-name u.note) =/ del [%add-comment host book-name note-name comment-date u.comment] :- [(give-primary-delta del)]~ %= state books (~(put by books) [host book-name] u.book) :: comments.limbo %+ ~(del by comments.limbo) [host book-name note-name comment-date] u.comment == == :: ++ poke-publish-action |= act=action ^- (quip card _state) ?- -.act :: %new-book: Make groups and save publish info file. :: %new-book ?. (team:title our.bol src.bol) ~|("action not permitted" !!) ?: (~(has by books) our.bol book.act) ~|("notebook already exists: {}" !!) =+ ^- [cards=(list card) write-pax=path read-pax=path] (make-groups book.act group.act title.act about.act) =/ new-book=notebook-info :* title.act about.act coms.act write-pax read-pax == =/ pax=path /app/publish/notebooks/[book.act]/publish-info :_ state [(write-file pax %publish-info !>(new-book)) cards] :: %new-note: :: If poke is from us, eagerly store new note in books. If poke is to us, :: save file, otherwise forward the poke. If forwarded poke fails, note is :: removed from books and stored in limbo. :: %new-note =/ book=(unit notebook) (~(get by books) who.act book.act) ?~ book ~|("nonexistent notebook {}" !!) ?: (~(has by notes.u.book) note.act) ~|("note already exists: {}" !!) =/ front=(map knot cord) %- my :~ title+title.act author+(scot %p src.bol) date-created+(scot %da now.bol) last-modified+(scot %da now.bol) == =/ file=@t (add-front-matter front body.act) :: =^ cards books ?. =(src.bol our.bol) [~ books] =/ new-note=note :* src.bol title.act note.act now.bol now.bol %.y file (form-snippet file) ~ %.y == =/ del=primary-delta [%add-note who.act book.act note.act new-note] :- [(give-primary-delta del)]~ %+ ~(put by books) [who.act book.act] u.book(notes (~(put by notes.u.book) note.act new-note)) :: :_ state ?. =(who.act our.bol) =/ poke-wir=wire /forward/new-note/(scot %p who.act)/[book.act]/[note.act] :_ cards [%pass poke-wir %agent [who.act %publish] %poke %publish-action !>(act)] ?. ?| (team:title our.bol src.bol) (allowed src.bol %write book.act) == ~|("action not permitted" !!) =/ pax=path /app/publish/notebooks/[book.act]/[note.act]/udon :_ cards [(write-file pax %udon !>(file))] :: %new-comment :: If poke is from us, eagerly store new comment in books. If poke is to :: us, save file, otherwise forward the poke. If forwarded poke fails, :: comment is removed from books and stored in limbo. :: %new-comment =/ book=(unit notebook) (~(get by books) who.act book.act) ?~ book ~|("nonexistent notebook {}" !!) =/ note=(unit note) (~(get by notes.u.book) note.act) ?~ note ~|("nonexistent note {}" !!) =/ new-comment=comment :* author=src.bol date-created=now.bol content=body.act %.y == :: =^ cards books ?. =(src.bol our.bol) [~ books] =/ new-note %= u.note comments (~(put by comments.u.note) now.bol new-comment) == =/ del=primary-delta [%add-comment who.act book.act note.act now.bol new-comment] :- [(give-primary-delta del)]~ %+ ~(put by books) [who.act book.act] u.book(notes (~(put by notes.u.book) note.act new-note)) :_ state ?. =(who.act our.bol) =/ poke-wir=wire :~ %forward %new-comment (scot %p who.act) book.act note.act (scot %da now.bol) == :_ cards [%pass poke-wir %agent [who.act %publish] %poke %publish-action !>(act)] ?. ?& ?| (team:title our.bol src.bol) (allowed src.bol %read book.act) == comments.u.book == ~|("action not permitted" !!) =/ pax=path %+ weld /app/publish/notebooks /[book.act]/[note.act]/(scot %da now.bol)/publish-comment [(write-file pax %publish-comment !>(new-comment(pending %.n)))]~ :: %edit-book: Make groups and save publish-info file :: %edit-book ?. (team:title our.bol src.bol) ~|("action not permitted" !!) =/ book (~(get by books) our.bol book.act) ?~ book ~|("nonexistent notebook" !!) =+ ^- [cards=(list card) write-pax=path read-pax=path] ?~ group.act [~ writers.u.book subscribers.u.book] (make-groups book.act u.group.act title.act about.act) =/ new-info=notebook-info :* title.act about.act coms.act write-pax read-pax == =/ pax=path /app/publish/notebooks/[book.act]/publish-info :_ state [(write-file pax %publish-info !>(new-info)) cards] :: %edit-note: :: If poke is from us, eagerly store new note in books, and place the old :: note in limbo. If poke is to us, save file, otherwise forward the poke. :: If forwarded poke fails, old note is restored from limbo. :: %edit-note =/ book=(unit notebook) (~(get by books) who.act book.act) ?~ book ~|("nonexistent notebook {}" !!) =/ note=(unit note) (~(get by notes.u.book) note.act) ?~ note ~|("nonexistent note: {}" !!) =/ front=(map knot cord) %- my :~ title+title.act author+(scot %p src.bol) date-created+(scot %da date-created.u.note) last-modified+(scot %da now.bol) == =/ file=@t (add-front-matter front body.act) :: =^ cards state ?. =(src.bol our.bol) [~ state] =/ new-note %= u.note author src.bol title title.act last-edit now.bol file file snippet (form-snippet file) pending %.y == =/ del=primary-delta [%edit-note who.act book.act note.act new-note] :- [(give-primary-delta del)]~ %= state notes.limbo (~(put by notes.limbo) [who.act book.act note.act] u.note) :: books %+ ~(put by books) [who.act book.act] u.book(notes (~(put by notes.u.book) note.act new-note)) == :: :_ state ?. =(who.act our.bol) =/ poke-wir=wire /forward/edit-note/(scot %p who.act)/[book.act]/[note.act] :_ cards [%pass poke-wir %agent [who.act %publish] %poke %publish-action !>(act)] ?. ?| (team:title our.bol src.bol) ?& =(author.u.note src.bol) (allowed src.bol %write book.act) == == ~|("action not permitted" !!) =/ pax=path /app/publish/notebooks/[book.act]/[note.act]/udon [(write-file pax %udon !>(file))]~ :: %edit-comment: :: If poke is from us, eagerly store new comment in books, and place the :: old note in limbo. If poke is to us, save file, otherwise forward the :: poke. If forwarded poke fails, old comment is restored from limbo. :: %edit-comment =/ book=(unit notebook) (~(get by books) who.act book.act) ?~ book ~|("nonexistent notebook {}" !!) =/ note=(unit note) (~(get by notes.u.book) note.act) ?~ note ~|("nonexistent note {}" !!) =/ comment-date (slav %da comment.act) =/ comment=(unit comment) (~(get by comments.u.note) comment-date) ?~ comment ~|("nonexistent comment {}" !!) =/ new-comment u.comment(content body.act, pending %.y) :: =^ cards state ?. =(src.bol our.bol) [~ state] =/ new-note %= u.note comments (~(put by comments.u.note) comment-date new-comment) == =/ del=primary-delta [%edit-comment who.act book.act note.act comment-date new-comment] :- [(give-primary-delta del)]~ %= state books %+ ~(put by books) [who.act book.act] u.book(notes (~(put by notes.u.book) note.act new-note)) :: comments.limbo %+ ~(put by comments.limbo) [who.act book.act note.act comment-date] u.comment == :: :_ state ?. =(who.act our.bol) =/ poke-wir :~ %forward %edit-comment (scot %p who.act) book.act note.act comment.act == :_ cards [%pass poke-wir %agent [who.act %publish] %poke %publish-action !>(act)] ?. ?| (team:title our.bol src.bol) ?& =(author.u.comment src.bol) (allowed src.bol %read book.act) == == ~|("action not permitted" !!) =/ pax=path %+ weld /app/publish/notebooks /[book.act]/[note.act]/[comment.act]/publish-comment [(write-file pax %publish-comment !>(new-comment(pending %.n)))]~ :: %del-book: Delete whole notebook directory, delete groups and permissions :: %del-book ?. (team:title our.bol src.bol) ~|("action not permitted" !!) =/ book=(unit notebook) (~(get by books) our.bol book.act) ?~ book ~|("nonexistent notebook {}" !!) =/ pax=path /app/publish/notebooks/[book.act] ?> ?=(^ writers.u.book) ?> ?=(^ subscribers.u.book) =/ cards=(list card) ~[(delete-dir pax)] =/ rid=resource (de-path:resource writers.u.book) =? cards !(is-managed:grup rid) [(group-poke %remove-group rid ~) cards] [cards state] :: %del-note: :: If poke is from us, eagerly remove note from books, and place the :: old note in limbo. If poke is to us, save file, otherwise forward the :: poke. If forwarded poke fails, old note is restored from limbo. :: %del-note =/ book=(unit notebook) (~(get by books) who.act book.act) ?~ book ~|("nonexistent notebook {}" !!) =/ note=(unit note) (~(get by notes.u.book) note.act) ?~ note ~|("nonexistent note: {}" !!) :: =^ cards state ?. =(src.bol our.bol) [~ state] =/ del=primary-delta [%del-note who.act book.act note.act] =. notes.u.book (~(del by notes.u.book) note.act) :- [(give-primary-delta del)]~ %= state books (~(put by books) [who.act book.act] u.book) notes.limbo (~(put by notes.limbo) [who.act book.act note.act] u.note) == :: :_ state ?. =(who.act our.bol) =/ poke-wir=wire /forward/del-note/(scot %p who.act)/[book.act]/[note.act] :_ cards [%pass poke-wir %agent [who.act %publish] %poke %publish-action !>(act)] ?. ?| (team:title our.bol src.bol) ?& =(author.u.note src.bol) (allowed src.bol %write book.act) == == ~|("action not permitted" !!) =/ pax=path /app/publish/notebooks/[book.act]/[note.act]/udon [(delete-file pax)]~ :: %del-comment: :: If poke is from us, eagerly remove comment from books, and place the :: old note in limbo. If poke is to us, save file, otherwise forward the :: poke. If forwarded poke fails, old comment is restored from limbo. :: %del-comment =/ book=(unit notebook) (~(get by books) who.act book.act) ?~ book ~|("nonexistent notebook {}" !!) =/ note=(unit note) (~(get by notes.u.book) note.act) ?~ note ~|("nonexistent note {}" !!) =/ comment-date (slav %da comment.act) =/ comment=(unit comment) (~(get by comments.u.note) comment-date) ?~ comment ~|("nonexistent comment {}" !!) :: =^ cards state ?. =(src.bol our.bol) [~ state] =/ del=primary-delta [%del-comment who.act book.act note.act comment-date] =. comments.u.note (~(del by comments.u.note) comment-date) =. notes.u.book (~(put by notes.u.book) note.act u.note) :- [(give-primary-delta del)]~ %= state books (~(put by books) [who.act book.act] u.book) :: comments.limbo %+ ~(put by comments.limbo) [who.act book.act note.act comment-date] u.comment == :: :_ state ?. =(who.act our.bol) =/ poke-wir=wire :~ %forward %del-comment (scot %p who.act) book.act note.act comment.act == :_ cards [%pass poke-wir %agent [who.act %publish] %poke %publish-action !>(act)] ?. ?| (team:title our.bol src.bol) ?& =(author.u.comment src.bol) (allowed src.bol %read book.act) == == ~|("action not permitted" !!) =/ pax=path %+ weld /app/publish/notebooks /[book.act]/[note.act]/[comment.act]/publish-comment [(delete-file pax)]~ :: %subscribe :: %subscribe ?> (team:title our.bol src.bol) ?: =(our.bol who.act) [~ state] =/ join-wire=wire /join-group/[(scot %p who.act)]/[book.act] =/ meta=(unit (set path)) (metadata-resource-scry %publish /(scot %p who.act)/[book.act]) ?^ meta (subscribe-notebook who.act book.act) =/ rid=resource [who.act book.act] =/ =cage :- %group-update !> ^- action:group-store [%add-members rid (sy our.bol ~)] :_ state [%pass join-wire %agent [who.act %group-push-hook] %poke cage]~ :: %unsubscribe :: %unsubscribe ?> (team:title our.bol src.bol) =/ wir=wire /subscribe/(scot %p who.act)/[book.act] =/ del=primary-delta [%del-book who.act book.act] =/ book=notebook (~(got by books) who.act book.act) =/ rid=resource (de-path:resource writers.book) =/ =group (need (scry-group:grup rid)) =/ cards=(list card) :~ [%pass wir %agent [who.act %publish] %leave ~] [%give %fact [/primary]~ %publish-primary-delta !>(del)] == =? cards hidden.group %+ weld cards :~ (group-proxy-poke who.act %remove-members rid (sy our.bol ~)) (group-poke %remove-group rid ~) == [cards state(books (~(del by books) who.act book.act))] :: %read :: %read ?> (team:title our.bol src.bol) =/ book=(unit notebook) (~(get by books) who.act book.act) ?~ book ~|("nonexistent notebook: {}" !!) =/ not=(unit note) (~(get by notes.u.book) note.act) ?~ not ~|("nonexistent note: {}" !!) =? tile-num &(!read.u.not (gth tile-num 0)) (dec tile-num) =. read.u.not %.y =. notes.u.book (~(put by notes.u.book) note.act u.not) =. books (~(put by books) [who.act book.act] u.book) :_ state [%give %fact [/primary]~ %publish-primary-delta !>(act)]~ :: %groupify :: %groupify ?. (team:title our.bol src.bol) ~|("action not permitted" !!) =/ book (~(get by books) our.bol book.act) ?~ book ~|("nonexistent notebook: {}" !!) :: =* old-group-path writers.u.book =/ app-path /[(scot %p our.bol)]/[book.act] =/ =metadata (need (metadata-scry old-group-path app-path)) =/ old-rid=resource (de-path:resource old-group-path) ?< (is-managed:grup old-rid) ?~ target.act :: just create contacts object for group :_ state ~[(contact-view-poke %groupify old-rid title.metadata description.metadata)] :: change associations =* group-path u.target.act =/ rid=resource (de-path:resource group-path) =/ old-group=group (need (scry-group:grup old-rid)) =/ =group (need (scry-group:grup rid)) =/ ships=(set ship) (~(dif in members.old-group) members.group) =. subscribers.u.book group-path =. writers.u.book group-path =. books (~(put by books) [our.bol book.act] u.book) =/ del [%edit-book our.bol book.act u.book] :_ state :* [%give %fact [/primary]~ %publish-primary-delta !>(del)] [%give %fact [/notebook/[book.act]]~ %publish-notebook-delta !>(del)] (metadata-store-poke %remove app-path %publish app-path) (metadata-store-poke %add group-path [%publish app-path] metadata) (group-poke %remove-group old-rid ~) ?. inclusive.act ~ :- (group-poke %add-members rid ships) %+ turn ~(tap in ships) |= =ship =/ =invite :* our.bol %contact-hook group-path ship '' == =/ act=invite-action [%invite /contacts (shaf %msg-uid eny.bol) invite] [%pass / %agent [our.bol %invite-hook] %poke %invite-action !>(act)] == == :: ++ get-subscribers |= book=@tas ^- (set @p) %+ roll ~(val by sup.bol) |= [[who=@p pax=path] out=(set @p)] ^- (set @p) ?. ?=([%notebook @ ~] pax) out ?. =(book i.t.pax) out (~(put in out) who) :: ++ get-notebook |= [host=@p book-name=@tas sty=_state] ^- (unit notebook) (~(get by books.sty) host book-name) :: ++ get-unread |= book=notebook ^- @ud %+ roll ~(tap by notes.book) |= [[nom=@tas not=note] out=@ud] ?: read.not out +(out) :: ++ emit-updates-and-state |= [host=@p book-name=@tas book=notebook del=notebook-delta sty=_state] ^- (quip card _state) :_ sty(books (~(put by books.sty) [host book-name] book)) ?: =(our.bol host) :~ [%give %fact [/notebook/[book-name]]~ %publish-notebook-delta !>(del)] [%give %fact [/primary]~ %publish-primary-delta !>(del)] == [%give %fact [/primary]~ %publish-primary-delta !>(del)]~ :: ++ metadata-poke |= act=metadata-action ^- card [%pass / %agent [our.bol %metadata-hook] %poke %metadata-action !>(act)] :: :: ++ metadata-scry |= [group-path=path app-path=path] ^- (unit metadata) ?. .^(? %gu (scot %p our.bol) %metadata-store (scot %da now.bol) ~) ~ .^ (unit metadata) %gx (scot %p our.bol) %metadata-store (scot %da now.bol) %metadata (scot %t (spat group-path)) %publish (scot %t (spat app-path)) /noun == :: ++ metadata-resource-scry |= [app=@tas app-path=path] ^- (unit (set path)) ?. .^(? %gu (scot %p our.bol) %metadata-store (scot %da now.bol) ~) ~ .^ (unit (set path)) %gx ;: weld /(scot %p our.bol)/metadata-store/(scot %da now.bol)/resource/[app] app-path /noun == == :: ++ emit-metadata |= del=metadata-delta ^- (list card) |^ ?- -.del %add =/ preexisting (metadata-scry group-path.del app-path.del) =/ meta=metadata %* . *metadata title title.del description desc.del date-created created.del creator author.del == ?~ preexisting (add group-path.del app-path.del meta) =. color.meta color.u.preexisting (add group-path.del app-path.del meta) :: %remove =/ app-path [(scot %p author.del) /[book.del]] =/ group-path=(unit path) (group-from-book app-path) ?~ group-path ~ [(metadata-poke [%remove u.group-path [%publish app-path]])]~ == :: ++ add |= [group-path=path app-path=path =metadata] ^- (list card) [(metadata-poke [%add group-path [%publish app-path] metadata])]~ -- :: ++ group-from-book |= app-path=path ^- (unit path) ?. .^(? %gu (scot %p our.bol) %metadata-store (scot %da now.bol) ~) ?: ?=([@ ^] app-path) ~& [%assuming-ported-legacy-publish app-path] `[%'~' app-path] ~&([%weird-publish app-path] ~) =/ resource-indices .^ (jug md-resource group-path) %gy (scot %p our.bol) %metadata-store (scot %da now.bol) /resource-indices == =/ groups=(unit (set path)) (~(get by resource-indices) [%publish app-path]) ?~ groups ~ =/ group-paths ~(tap in u.groups) ?~ group-paths ~ `i.group-paths :: ++ metadata-hook-poke |= act=metadata-hook-action ^- card :* %pass / %agent [our.bol %metadata-hook] %poke %metadata-hook-action !>(act) == :: ++ handle-notebook-delta |= [del=notebook-delta sty=_state] ^- (quip card _state) ?- -.del %add-book ?: =(our.bol host.del) =^ cards state (emit-updates-and-state host.del book.del data.del del sty) :_ state %- zing :~ cards [(metadata-hook-poke [%add-owned writers.data.del])]~ %- emit-metadata :* %add writers.data.del [(scot %p host.del) /[book.del]] title.data.del description.data.del host.del date-created.data.del == == =? data.del (~(has by books) host.del book.del) (merge-notebooks (~(got by books) host.del book.del) data.del) =^ cards state (emit-updates-and-state host.del book.del data.del del sty) =/ rid=resource (de-path:resource writers.data.del) =? cards !=(our.bol entity.rid) :_ cards (group-pull-hook-poke [%add host.del rid]) :_ state :* (metadata-hook-poke [%add-synced host.del writers.data.del]) cards == :: %add-note =/ book=(unit notebook) (get-notebook host.del book.del sty) ?~ book [~ sty] =. read.data.del =(our.bol author.data.del) =. notes.u.book (~(put by notes.u.book) note.del data.del) (emit-updates-and-state host.del book.del u.book del sty) :: %add-comment =/ book=(unit notebook) (get-notebook host.del book.del sty) ?~ book [~ sty] =/ note (~(get by notes.u.book) note.del) ?~ note [~ sty] =/ limbo-comment=(unit @da) %- ~(rep by comments.u.note) |= [[date=@da com=comment] out=(unit @da)] ?: ?& =(author.com author.data.del) =(content.com content.data.del) =(%.y pending.com) == `date out =? comments.u.note ?=(^ limbo-comment) (~(del by comments.u.note) u.limbo-comment) =. comments.u.note (~(put by comments.u.note) comment-date.del data.del) =. notes.u.book (~(put by notes.u.book) note.del u.note) (emit-updates-and-state host.del book.del u.book del sty) :: %edit-book =/ old-book=(unit notebook) (get-notebook host.del book.del sty) ?~ old-book [~ sty] =/ new-book=notebook %= data.del date-created date-created.u.old-book notes notes.u.old-book order order.u.old-book == =^ cards state (emit-updates-and-state host.del book.del new-book del sty) :_ state %+ weld cards %- emit-metadata :* %add writers.new-book [(scot %p host.del) /[book.del]] title.new-book description.new-book host.del date-created.new-book == :: %edit-note =. notes.limbo.sty (~(del by notes.limbo.sty) host.del book.del note.del) =/ book=(unit notebook) (get-notebook host.del book.del sty) ?~ book [~ sty] =/ old-note (~(get by notes.u.book) note.del) ?~ old-note [~ sty] ?: =(our.bol author.u.old-note) [~ sty] =/ new-note=note %= data.del date-created date-created.u.old-note comments comments.u.old-note read read.u.old-note == =. notes.u.book (~(put by notes.u.book) note.del new-note) (emit-updates-and-state host.del book.del u.book del sty) :: %edit-comment =. comments.limbo.sty %- ~(del by comments.limbo.sty) [host.del book.del note.del comment-date.del] =/ book=(unit notebook) (get-notebook host.del book.del sty) ?~ book [~ sty] =/ note (~(get by notes.u.book) note.del) ?~ note [~ sty] =/ old-comment (~(get by comments.u.note) comment-date.del) ?~ old-comment [~ sty] =. comments.u.note (~(put by comments.u.note) comment-date.del data.del) =. notes.u.book (~(put by notes.u.book) note.del u.note) (emit-updates-and-state host.del book.del u.book del sty) :: %del-book =/ book=(unit notebook) (get-notebook host.del book.del sty) ?~ book [~ sty] :_ sty(books (~(del by books.sty) host.del book.del)) ?. =(our.bol host.del) %+ welp [%give %fact [/primary]~ %publish-primary-delta !>(del)]~ ?: (is-managed writers.u.book) ~ [(metadata-hook-poke [%remove writers.u.book])]~ %- zing :~ [%give %fact [/notebook/[book.del]]~ %publish-notebook-delta !>(del)]~ [%give %fact [/primary]~ %publish-primary-delta !>(del)]~ (emit-metadata %remove host.del book.del) :: ?: (is-managed writers.u.book) ~ [(metadata-hook-poke [%remove writers.u.book])]~ == :: %del-note =. notes.limbo.sty (~(del by notes.limbo.sty) host.del book.del note.del) =/ book=(unit notebook) (get-notebook host.del book.del sty) ?~ book [~ sty] =/ not=(unit note) (~(get by notes.u.book) note.del) ?~ not [~ sty] =. notes.u.book (~(del by notes.u.book) note.del) (emit-updates-and-state host.del book.del u.book del sty) :: %del-comment =. comments.limbo.sty %- ~(del by comments.limbo.sty) [host.del book.del note.del comment.del] =/ book=(unit notebook) (get-notebook host.del book.del sty) ?~ book [~ sty] =/ note (~(get by notes.u.book) note.del) ?~ note [~ sty] =. comments.u.note (~(del by comments.u.note) comment.del) =. notes.u.book (~(put by notes.u.book) note.del u.note) (emit-updates-and-state host.del book.del u.book del sty) == :: ++ get-subscribers-json |= book=@tas ^- json :- %a %+ roll ~(val by sup.bol) |= [[who=@p pax=path] out=(list json)] ^- (list json) ?. ?=([%notebook @ ~] pax) out ?. =(book i.t.pax) out [[%s (scot %p who)] out] :: ++ get-writers-json |= [host=@p book=@tas] =/ =tag [%publish (cat 3 %writers- book)] ^- json =/ writers=(list ship) ~(tap in (book-writers host book)) :- %a %+ turn writers |= who=@p ^- json [%s (scot %p who)] :: ++ get-notebook-json |= [host=@p book-name=@tas] ^- (unit json) =, enjs:format =/ book=(unit notebook) (~(get by books) host book-name) ?~ book ~ =/ notebook-json (notebook-full:enjs host book-name u.book) ?> ?=(%o -.notebook-json) =. p.notebook-json (~(uni by p.notebook-json) (notes-page:enjs notes.u.book 0 50)) =. p.notebook-json (~(put by p.notebook-json) %subscribers (get-subscribers-json book-name)) =/ notebooks-json (notebooks-map:enjs our.bol books) =. p.notebook-json (~(put by p.notebook-json) %writers (get-writers-json host book-name)) ?> ?=(%o -.notebooks-json) =/ host-books-json (~(got by p.notebooks-json) (scot %p host)) ?> ?=(%o -.host-books-json) =. p.host-books-json (~(put by p.host-books-json) book-name notebook-json) =. p.notebooks-json (~(put by p.notebooks-json) (scot %p host) host-books-json) `(pairs notebooks+notebooks-json ~) :: ++ get-note-json |= [host=@p book-name=@tas note-name=@tas] ^- (unit json) =, enjs:format =/ book=(unit notebook) (~(get by books) host book-name) ?~ book ~ =/ note=(unit note) (~(get by notes.u.book) note-name) ?~ note ~ =/ notebook-json (notebook-full:enjs host book-name u.book) ?> ?=(%o -.notebook-json) =/ note-json (note-presentation:enjs u.book note-name u.note) =. p.notebook-json (~(uni by p.notebook-json) note-json) =/ notebooks-json (notebooks-map:enjs our.bol books) ?> ?=(%o -.notebooks-json) =/ host-books-json (~(got by p.notebooks-json) (scot %p host)) ?> ?=(%o -.host-books-json) =. p.host-books-json (~(put by p.host-books-json) book-name notebook-json) =. p.notebooks-json (~(put by p.notebooks-json) (scot %p host) host-books-json) `(pairs notebooks+notebooks-json ~) :: ++ is-managed |= =path ^- ? ?> ?=(^ path) !=(i.path '~') :: ++ handle-http-request |= req=inbound-request:eyre ^- simple-payload:http =/ url (parse-request-line url.request.req) ?+ url not-found:gen :: :: pagination endpoints :: :: all notebooks, short form [[[~ %json] [%'publish-view' %notebooks ~]] ~] %- json-response:gen (notebooks-map:enjs our.bol books) :: :: notes pagination [[[~ %json] [%'publish-view' %notes @ @ @ @ ~]] ~] =/ host=(unit @p) (slaw %p i.t.t.site.url) ?~ host not-found:gen =/ book-name i.t.t.t.site.url =/ book=(unit notebook) (~(get by books) u.host book-name) ?~ book not-found:gen =/ start (rush i.t.t.t.t.site.url dem) ?~ start not-found:gen =/ length (rush i.t.t.t.t.t.site.url dem) ?~ length not-found:gen %- json-response:gen :- %o (notes-page:enjs notes.u.book u.start u.length) :: :: comments pagination [[[~ %json] [%'publish-view' %comments @ @ @ @ @ ~]] ~] =/ host=(unit @p) (slaw %p i.t.t.site.url) ?~ host not-found:gen =/ book-name i.t.t.t.site.url =/ book=(unit notebook) (~(get by books) u.host book-name) ?~ book not-found:gen =/ note-name i.t.t.t.t.site.url =/ note=(unit note) (~(get by notes.u.book) note-name) ?~ note not-found:gen =/ start (rush i.t.t.t.t.t.site.url dem) ?~ start not-found:gen =/ length (rush i.t.t.t.t.t.t.site.url dem) ?~ length not-found:gen %- json-response:gen (comments-page:enjs comments.u.note u.start u.length) :: :: single notebook with initial 50 notes in short form, as json [[[~ %json] [%'publish-view' @ @ ~]] ~] =, enjs:format =/ host=(unit @p) (slaw %p i.t.site.url) ?~ host not-found:gen =/ book-name i.t.t.site.url =/ book=(unit notebook) (~(get by books) u.host book-name) ?~ book not-found:gen =/ notebook-json (notebook-full:enjs u.host book-name u.book) ?> ?=(%o -.notebook-json) =. p.notebook-json (~(uni by p.notebook-json) (notes-page:enjs notes.u.book 0 50)) =. p.notebook-json (~(put by p.notebook-json) %subscribers (get-subscribers-json book-name)) =. p.notebook-json (~(put by p.notebook-json) %writers (get-writers-json u.host book-name)) (json-response:gen (pairs notebook+notebook-json ~)) :: :: single note, with initial 50 comments, as json [[[~ %json] [%'publish-view' @ @ @ ~]] ~] =, enjs:format =/ host=(unit @p) (slaw %p i.t.site.url) ?~ host not-found:gen =/ book-name i.t.t.site.url =/ book=(unit notebook) (~(get by books) u.host book-name) ?~ book not-found:gen =/ note-name i.t.t.t.site.url =/ note=(unit note) (~(get by notes.u.book) note-name) ?~ note not-found:gen =/ jon=json o+(note-presentation:enjs u.book note-name u.note) (json-response:gen jon) == :: --