urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-09-11 12:25:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

Add WIP mast and eyre channel neo additions

Browse Source
This commit is contained in:
Robin Guerrier 2024-07-23 05:44:13 -04:00
parent b98a5ca7c7
commit 5f036e3802
9 changed files with 951 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
pkg/arvo/app/neo.hoon
View File

@ -257,6 +257,7 @@
%noun (on-noun q.vase)
%neo-raw-poke (on-move (poke:harden !<(raw-poke:neo vase)))
%handle-http-request (handle-http-request:sttp !<([@ta inbound-request:eyre] vase))
%json (handle-eyre-chan-request:sttp !<(json vase))
==
++ on-noun
|= non=*
@ -322,6 +323,7 @@
[%sync rest=*] (on-peer-sync (pave:neo rest.pole) stop)
[%fetch rest=*] ?:(stop run (on-peer-fetch (pave:neo rest.pole)))
[%http-response *] run
[%eyre-chan *] run
==
::
++ on-peer-fetch
@ -2312,10 +2314,11 @@
++ call
|= [src=pith:neo dst=pith:neo =note:neo]
?> ?=(%poke -.note) :: XX: all shanes should be virtualised and hand deliver acks
?+ p.pail.note ~|(bad-eyre-call/p.pail.note !!)
%ack run
%eyre-req (on-eyre-req !<(req:eyre:neo q.pail.note))
%eyre-sign (on-eyre-sign src !<(sign:eyre:neo q.pail.note))
?+ p.pail.note ~|(bad-eyre-call/p.pail.note !!)
%ack run
%eyre-req (on-eyre-req !<(req:eyre:neo q.pail.note))
%eyre-sign (on-eyre-sign src !<(sign:eyre:neo q.pail.note))
%eyre-chan-gift (on-eyre-chan-gift !<(chan-gift:eyre:neo q.pail.note))
==
+$ request-line
$: [ext=(unit @ta) site=(list @t)]
@ -2348,6 +2351,13 @@
%data `http-response-data/!>(dat.gift)
%done ~
==
::
++ on-eyre-chan-gift
|= [sub=path dat=json]
^+ run
=/ cag=cage [%json !>(dat)]
(give %fact ~[sub] cag)
::
++ match-binding
=| test=(list @t)
|= site=(list @t)
@ -2370,6 +2380,28 @@
=/ =card:neo [u.bin %poke eyre-task/!>(`task:eyre:neo`[eyre-id req])]
=/ =move:neo [#/[p/our.bowl]/$/eyre card]
(emit (do-move move))
::
++ handle-eyre-chan-request
|= jon=json
^+ run
=/ dst=(unit pith:neo)
?. &(?=(^ jon) ?=(%o -.jon))
~
=/ str=(unit json) (~(get by p.jon) 'path')
?. &(?=(^ str) ?=(^ u.str) ?=(%s -.u.str))
~
(rush p.u.str stap)
?~ dst ~|(eyre-channel-req-missing-pith/jon !!)
=. u.dst [p/our.bowl u.dst]
=. jon
?. &(?=(^ jon) ?=(%o -.jon))
~
=/ dat=(unit json) (~(get by p.jon) 'data')
?~ dat ~
u.dat
=/ =card:neo [u.dst %poke eyre-chan-task/!>(`chan-task:eyre:neo`jon)]
=/ =move:neo [#/[p/our.bowl]/$/eyre card]
(emit (do-move move))
--
++ cttp

1
pkg/arvo/neo/cod/std/src/imp/manx.hoon Normal file
View File

@ -0,0 +1 @@
~

147
pkg/arvo/neo/cod/std/src/imp/mast-diary-ui.hoon Normal file
View File

@ -0,0 +1,147 @@
/@ ui-event
/@ txt
/@ diary-diff
^- kook:neo
=<
|%
++ state pro/%manx
++ poke (sy %ui-event %rely %gift ~)
++ kids
*kids:neo
:: ^- kids:neo
:: :+ ~ %y
:: %- my
:: :~ [[&/%selection |] pro/%sig ~]
:: ==
++ deps
^- deps:neo
%- my
:~ :^ %diary & [pro/%diary (sy %diary-diff ~)]
:+ ~ %y
%- my
:~ [[|/%da |] only/%txt ~]
==
==
++ form
^- form:neo
|_ [=bowl:neo =aeon:neo =pail:neo]
::
++ init
|= pal=(unit pail:neo)
^- (quip card:neo pail:neo)
=/ diary-entries
(get-diary-entries deps.bowl)
:- ~
manx/!>((render [diary-entries ~]))
::
++ poke
|= [sud=stud:neo vaz=vase]
^- (quip card:neo pail:neo)
?+ sud ~|(bad-stud/sud !!)
::
%ui-event
=/ eve !<(ui-event vaz)
?+ path.eve ~|(missing-event-handler-for/path.eve !!)
::
[%click %submit ~]
=/ dat=(unit @t)
(~(get by data.eve) '/diary-input/value')
?~ dat
~|(%diary-input-fail !!)
=/ dif=diary-diff
[%put-entry now.bowl u.dat]
:_ pail
:~ [#/[p/our.bowl]/mast-diary-demo %poke diary-diff/!>(dif)]
==
::
==
::
%rely
=/ diary-entries
(get-diary-entries deps.bowl)
`manx/!>((render [diary-entries ~]))
::
==
::
--
--
::
|%
::
++ render
|_ $: diary-entries=(list [date=@da =txt])
selection=(unit @da)
==
++ $
^- manx
;html
;head
;meta(charset "utf-8");
==
;body
=style "margin: 0; width: 100%; display: grid; place-items: center;"
;main
;h1: Diary
;+ diary-form
;+ diary-items
==
==
==
::
++ diary-form
^- manx
;div
;textarea(id "diary-input", style "height: 10rem; width: 25rem; margin-block: 1rem;");
;button
=event "/click/submit"
=return "/diary-input/value"
;+ ;/ "Enter"
==
==
::
++ diary-items
^- manx
;div
;* %+ turn diary-entries
|= [date=@da =txt]
;div
;p: {(pretty-date date)}
;p: {(trip txt)}
==
==
::
--
:: :: :: :: :: :: :: :: :: ::
++ get-diary-entries
|= sam=(map term (pair pith:neo lore:neo))
^- (list [date=@da =txt])
=/ dat=(unit (pair pith:neo lore:neo))
(~(get by sam) %diary)
?~ dat
~|(%no-diary !!)
=/ pod=(list [date=@da =txt])
%+ turn ~(tap by kid.q.u.dat)
|= (pair iota:neo (axal:neo idea:neo))
?> &(?=(^ p) ?=(%da -.p))
?> ?=(^ fil.q)
[+.p !<(txt q.pail.u.fil.q)]
%+ sort pod
|= (pair [date=@da =txt] [date=@da =txt])
(gth date.p date.q)
::
++ get-selection
|= sam=(axal:neo idea:neo)
^- (unit @da)
=/ dat=(unit (axal:neo idea:neo))
(~(get by kid.sam) %selection)
?~ dat ~
?~ fil.u.dat ~
[~ !<(@da q.pail.u.fil.u.dat)]
::
++ pretty-date :: from diary-htmx
|= date=@da
^- tape
=/ d (yore date)
"{(y-co:co y:d)}-{(y-co:co m:d)}-{(y-co:co d:t:d)}"
::
--

739
pkg/arvo/neo/cod/std/src/imp/mast.hoon Normal file
View File

@ -0,0 +1,739 @@
/- mast
=<
^- kook:neo
|%
++ state [%pro %sig]
++ poke (sy %eyre-task %eyre-chan-task %gift ~)
++ kids
:+ ~ %y
%- my
:~ [[|/%p &] [%pro %manx] (sy %sig ~)] :: fix
[[&/%aft |/%p |] [%pro %manx] ~]
==
++ deps *deps:neo
++ form
^- form:neo
|_ [=bowl:neo =aeon:neo =pail:neo]
::
++ init
|= pal=(unit pail:neo)
^- (quip card:neo pail:neo)
?> ?=(^ pal)
=+ !<(prow:mast q.u.pal)
=/ =pith:neo #/[p/our.bowl]/$/eyre
=/ =binding:eyre [~ url]
=/ =req:eyre:neo [%connect binding here.bowl]
=/ =rig:mast
:* urth
made
/eyre-chan/mast/(scot %ud ^-(@ud (mug here.bowl)))
~
==
:_ sig/!>(rig)
:~ [pith %poke eyre-req/!>(req)]
[(snoc here.bowl p/ship.src.bowl) %make made.rig] :: temporary
==
::
++ poke
|= [sud=stud:neo vaz=vase]
^- (quip card:neo pail:neo)
~& mast-poke/sud
=+ !<(=rig:mast q.pail)
?+ sud ~|(bad-stud/sud !!)
::
%eyre-task
=+ !<([rid=@ta req=inbound-request:eyre] vaz)
?. authenticated.req
:_ pail
(~(make-auth-redirect res bowl) rid)
?+ method.request.req
[(~(make-400 res bowl) rid) pail]
::
%'GET'
?. |(urth:rig =(our.bowl ship.src.bowl))
:_ pail
(~(make-403 res bowl) rid)
=/ jig=(unit idea:neo)
=/ g (~(get by kid.kids.bowl) p/ship.src.bowl)
?~ g ~
fil.u.g
?~ jig
=. open-http.rig
(~(put by open-http.rig) ship.src.bowl rid)
~& open-http/rid
:_ sig/!>(rig)
:~ [(snoc here.bowl p/ship.src.bowl) %make made.rig]
==
=/ sail=manx
(hoist !<(manx q.pail.u.jig))
:_ pail
(~(gale res bowl) rid sail rig)
::
==
::
%gift
=/ rum=(list [=pith:neo =loot:neo])
~(tap of:neo !<(gift:neo vaz))
=^ cards rig
=| cards=(list card:neo)
|- ^- (quip card:neo rig:mast)
?~ rum
[cards rig]
?: ?=([%aft *] pith.i.rum)
$(rum t.rum)
=/ jig=(unit idea:neo)
(~(get of:neo kids.bowl) pith.i.rum)
?~ jig
$(rum t.rum)
=/ sail=manx
(hoist !<(manx q.pail.u.jig))
=/ boat=@p
=/ p (rear pith.i.rum)
?> &(?=(^ p) ?=(%p -.p))
+.p
=/ rid=(unit @ta)
(~(get by open-http.rig) boat)
?^ rid
~& close-http/u.rid
%= $
open-http.rig (~(del by open-http.rig) boat)
rum t.rum
cards
%+ weld
cards
%+ snoc
(~(gale res bowl) u.rid sail rig)
[(welp here.bowl #/aft/[p/boat]) %make [%manx [~ manx/!>(sail)] ~]]
==
?+ mode.loot.i.rum
$(rum t.rum)
::
%add
~& >>> missing-eyre-id/pith.i.rum
$(rum t.rum)
::
%dif
=/ aft=manx
=/ ide=(unit idea:neo)
(~(get of:neo kids.bowl) #/aft/[p/boat])
?~ ide
~& >>> missing-aft-sail/[here.bowl aft/boat]
(hoist [[%html ~] [[%head ~] ~] [[%body ~] ~] ~])
!<(manx q.pail.u.ide)
%= $
rum t.rum
cards
%+ weld
cards
%+ snoc
(~(gust res bowl) rig aft sail)
[(welp here.bowl #/aft/[p/boat]) %make [%manx [~ manx/!>(sail)] ~]]
==
::
==
[cards sig/!>(rig)]
::
%eyre-chan-task
=+ !<(jon=json vaz)
=/ dat
(parse-channel-data jon)
:_ pail
:~ [(snoc here.bowl p/ship.src.bowl) %poke ui-event/!>(dat)]
==
::
==
::
--
--
::
|%
::
++ res
|_ =bowl:neo
::
++ gale
|= [rid=@ta sail=manx =rig:mast]
^- (list card:neo)
?> ?=(^ c.sail)
%^ make-direct-http-cards
rid
[200 ['Content-Type' 'text/html'] ~]
:- ~
^- octs
%- as-octt:mimes:html
%- en-xml:html
%_ sail
a.g
^- mart
:* [%pith <^-(path ?>(?=(^ here.bowl) (pout:neo t.here.bowl)))>] :: destination path to shrub from neo
[%app "neo"]
[%path <^-(path (snoc base-sub.rig (scot %p ship.src.bowl)))>] :: sub path, shrub to eyre
[%ship +:(scow %p our.bowl)]
a.g.sail
==
c.i.c
(marl [script-node c.i.c.sail])
==
::
++ gust
|= [=rig:mast old=manx new=manx]
^- (list card:neo)
?~ c.old !!
?~ c.new !!
?~ t.c.old !! :: fix
?~ t.c.new !!
?~ a.g.new !!
:_ ~
:- #/[p/our.bowl]/$/eyre
:- %poke
:- %eyre-chan-gift
!>
^- chan-gift:eyre:neo
:- (snoc base-sub.rig (scot %p ship.src.bowl))
%- tape:enjs:format
%- en-xml:html
:: ~& >> gust/(algo c.i.t.c.old c.i.t.c.new)
^- manx
;g
=url v.i.a.g.new
;* %+ algo
c.i.t.c.old
c.i.t.c.new
==
::
++ make-400
|= rid=@ta
^- (list card:neo)
%^ make-direct-http-cards
rid
[400 ~]
~
::
++ make-403
|= rid=@ta
^- (list card:neo)
%^ make-direct-http-cards
rid
[403 ~]
~
::
++ make-auth-redirect
|= rid=@ta
^- (list card:neo)
%^ make-direct-http-cards
rid
[307 ['Location' '/~/login?redirect='] ~]
~
::
++ make-direct-http-cards
|= [rid=@ta hed=response-header:http dat=(unit octs)]
^- (list card:neo)
=/ eyre=pith:neo #/[p/our.bowl]/$/eyre
=/ head=sign:eyre:neo [rid %head hed]
=/ data=sign:eyre:neo [rid %data dat]
=/ done=sign:eyre:neo [rid %done ~]
:~ [eyre %poke eyre-sign/!>(head)]
[eyre %poke eyre-sign/!>(data)]
[eyre %poke eyre-sign/!>(done)]
==
::
--
::
++ parse-channel-data
|= jon=json
^- crow:mast
((ot ~[path+pa data+(om so)]):dejs:format jon)
::
++ algo
|= [old=marl new=marl]
^- marl
=/ i=@ud 0
=/ acc=marl ~
|-
?~ new
?. =(~ old)
?: =(%skip -.-.-.old)
$(old +.old)
:_ acc
:_ ~
:- %d
=/ c=@ud 0
|- ^- mart
?~ old
~
:- :- (crip (weld "d" <c>))
(getv a.g.i.old %key)
$(old t.old, c +(c))
acc
?: &(?=(^ old) =(%skip -.-.-.old))
$(old t.old)
?: =(%m n.g.i.new)
$(new t.new, i +(i), acc (snoc acc i.new))
=/ j=@ud 0
=/ jold=marl old
=/ nkey=[n=mane k=tape] [n.g.i.new (getv a.g.i.new %key)]
|-
?~ new
!!
?~ jold
%= ^$
new t.new
i +(i)
acc %+ snoc acc
;n(id <i>)
;+ i.new
==
==
?~ old
!!
?: =(%skip n.g.i.jold)
$(jold t.jold, j +(j))
?: .=(nkey [n.g.i.jold (getv a.g.i.jold %key)])
?. =(0 j)
=/ n=@ud 0
=/ nnew=marl new
=/ okey=[n=mane k=tape] [n.g.i.old (getv a.g.i.old %key)]
|-
?~ nnew
^^$(old (snoc t.old i.old))
?: =(%m n.g.i.nnew)
$(nnew t.nnew, n +(n))
=/ nnky=[n=mane k=tape] [n.g.i.nnew (getv a.g.i.nnew %key)]
?. .=(okey nnky)
$(nnew t.nnew, n +(n))
?: (gte n j)
=/ aupd=mart (upda a.g.i.old a.g.i.nnew)
?~ aupd
%= ^^$
old c.i.old
new c.i.nnew
i 0
acc
%= ^^$
old t.old
new %^ newm new n
;m(id <(add n i)>, key k.nnky);
==
==
%= ^^$
old c.i.old
new c.i.nnew
i 0
acc
%= ^^$
old t.old
new %^ newm new n
;m(id <(add n i)>, key k.nnky);
acc :_ acc
[[%c [[%key k.nnky] aupd]] ~]
==
==
=/ aupd=mart (upda a.g.i.jold a.g.i.new)
?~ aupd
%= ^^$
old c.i.jold
new c.i.new
i 0
acc
%= ^^$
old (newm old j ;skip;)
new t.new
i +(i)
acc %+ snoc acc
;m(id <i>, key k.nkey);
==
==
%= ^^$
old c.i.jold
new c.i.new
i 0
acc
%= ^^$
old (newm old j ;skip;)
new t.new
i +(i)
acc :- [[%c [[%key k.nkey] aupd]] ~]
%+ snoc
acc
;m(id <i>, key k.nkey);
==
==
?: =("text" (getv a.g.i.new %mast))
?: =(+.-.+.-.-.+.-.old +.-.+.-.-.+.-.new)
^$(old t.old, new t.new, i +(i))
%= ^$
old t.old
new t.new
i +(i)
acc [i.new acc]
==
=/ aupd=mart (upda a.g.i.old a.g.i.new)
?~ aupd
%= ^$
old c.i.old
new c.i.new
i 0
acc ^$(old t.old, new t.new, i +(i))
==
%= ^$
old c.i.old
new c.i.new
i 0
acc
%= ^$
old t.old
new t.new
i +(i)
acc :_ acc
[[%c [[%key k.nkey] aupd]] ~]
==
==
$(jold t.jold, j +(j))
::
++ hoist
|= root=manx
|^ ^- manx
(tanx root "0" "~")
++ tanx
|= [m=manx key=tape pkey=tape]
=/ fkey=tape (getv a.g.m %key)
=/ nkey=tape ?~(fkey key fkey)
?: =(%$ n.g.m)
;span
=mast "text"
=key nkey
=pkey pkey
;+ m
==
=: a.g.m %- mart
?~ fkey
[[%key nkey] [[%pkey pkey] a.g.m]]
[[%pkey pkey] a.g.m]
c.m (tarl c.m nkey)
==
m
++ tarl
|= [m=marl key=tape]
=/ i=@ud 0
|- ^- marl
?~ m
~
:- %^ tanx
(manx i.m)
(weld (scow %ud i) (weld "-" key))
key
$(m t.m, i +(i))
--
::
++ getv
|= [m=mart tag=@tas]
^- tape
?~ m
~
?: =(n.i.m tag)
v.i.m
$(m t.m)
::
++ upda
|= [om=mart nm=mart]
=/ acc=mart ~
|- ^- mart
?~ nm
?~ om
acc
:_ acc
:- %rem
=/ omom=mart om
|-
?~ omom
~
=/ nom=tape +:<n.i.omom>
|-
?~ nom
[' ' ^$(omom t.omom)]
[i.nom $(nom t.nom)]
=/ i=@ud 0
=/ com=mart om
|-
?~ nm
!!
?~ com
^$(nm t.nm, acc [i.nm acc])
?~ om
!!
?: =(n.i.com n.i.nm)
?: =(v.i.com v.i.nm)
^$(om (oust [i 1] (mart om)), nm t.nm)
%= ^$
om (oust [i 1] (mart om))
nm t.nm
acc [i.nm acc]
==
$(com t.com, i +(i))
::
++ newm
|= [ml=marl i=@ud mx=manx]
=/ j=@ud 0
|- ^- marl
?~ ml
~
:- ?: =(i j)
mx
i.ml
$(ml t.ml, j +(j))
::
++ paru
|= turl=tape
^- path
=/ tacc=tape ~
=/ pacc=path ~
|-
?~ turl
?~ tacc
pacc
(snoc pacc (crip tacc))
?: =('/' i.turl)
?~ tacc
$(turl t.turl)
%= $
turl t.turl
tacc ~
pacc (snoc pacc (crip tacc))
==
$(turl t.turl, tacc (snoc tacc i.turl))
::
++ script-node
^- manx
;script
;+ ;/ script
==
::
++ script
^~
%- trip
'''
let pith;
let ship;
let app;
let displayUpdatePath;
let channelMessageId = 0;
let eventSource;
const channelId = `${Date.now()}${Math.floor(Math.random() * 100)}`;
const channelPath = `${window.location.origin}/~/channel/${channelId}`;
addEventListener('DOMContentLoaded', async () => {
pith = document.documentElement.getAttribute('pith');
ship = document.documentElement.getAttribute('ship');
app = document.documentElement.getAttribute('app');
displayUpdatePath = document.documentElement.getAttribute('path');
await connectToShip();
let eventElements = document.querySelectorAll('[event]');
eventElements.forEach(el => setEventListeners(el));
});
function setEventListeners(el) {
const eventTags = el.getAttribute('event');
const returnTags = el.getAttribute('return');
eventTags.split(/\s+/).forEach(eventStr => {
const eventType = eventStr.split('/', 2)[1];
el[`on${eventType}`] = (e) => pokeShip(e, eventStr, returnTags);
});
};
async function connectToShip() {
try {
const storageKey = `${ship}${app}${displayUpdatePath}`;
let storedId = localStorage.getItem(storageKey);
localStorage.setItem(storageKey, channelId);
if (storedId) {
const delPath = `${window.location.origin}/~/channel/${storedId}`;
await fetch(delPath, {
method: 'PUT',
body: JSON.stringify([{
id: channelMessageId,
action: 'delete'
}])
});
};
const body = JSON.stringify(makeSubscribeBody());
await fetch(channelPath, {
method: 'PUT',
body
});
eventSource = new EventSource(channelPath);
eventSource.addEventListener('message', handleChannelStream);
} catch (error) {
console.error(error);
};
};
function pokeShip(event, tagString, dataString) {
try {
let data = {};
if (dataString) {
const dataToReturn = dataString.split(/\s+/);
dataToReturn.forEach(dataTag => {
let splitDataTag = dataTag.split('/');
if (splitDataTag[0] === '') splitDataTag.shift();
const kind = splitDataTag[0];
const key = splitDataTag.pop();
if (kind === 'event') {
if (!(key in event)) {
console.error(`Property: ${key} does not exist on the event object`);
return;
};
data[dataTag] = String(event[key]);
} else if (kind === 'target') {
if (!(key in event.currentTarget)) {
console.error(`Property: ${key} does not exist on the target object`);
return;
};
data[dataTag] = String(event.currentTarget[key]);
} else {
const elementId = splitDataTag.join('/');
const linkedEl = document.getElementById(elementId);
if (!linkedEl) {
console.error(`No element found for id: ${kind}`);
return;
};
if (!(key in linkedEl)) {
console.error(`Property: ${key} does not exist on the object with id: ${elementId}`);
return;
};
data[dataTag] = String(linkedEl[key]);
};
});
};
fetch(channelPath, {
method: 'PUT',
body: JSON.stringify(makePokeBody({
path: tagString,
data
}))
});
} catch (error) {
console.error(error);
};
};
function handleChannelStream(event) {
try {
const streamResponse = JSON.parse(event.data);
if (streamResponse.response !== 'diff') return;
fetch(channelPath, {
method: 'PUT',
body: JSON.stringify(makeAck(streamResponse.id))
});
const htmlData = streamResponse.json;
if (!htmlData) return;
let container = document.createElement('template');
container.innerHTML = htmlData;
if (container.content.firstElementChild.childNodes.length === 0) return;
// const navUrl = container.content.firstElementChild.getAttribute('url');
// if (navUrl && (navUrl !== window.location.pathname)) {
// history.pushState({}, '', navUrl);
// };
while (container.content.firstElementChild.children.length > 0) {
let gustChild = container.content.firstElementChild.firstElementChild;
if (gustChild.tagName === 'D') {
for (const att of gustChild.attributes) {
const dkey = att.value;
document.querySelector(`[key="${dkey}"]`).remove();
};
gustChild.remove();
} else if (gustChild.tagName === 'N') {
const nodeKey = gustChild.firstElementChild.getAttribute('key');
const parentKey = gustChild.firstElementChild.getAttribute('pkey');
const appendIndex = gustChild.id;
let domParent = document.querySelector(`[key="${parentKey}"]`);
domParent.insertBefore(gustChild.firstElementChild, domParent.children[appendIndex]);
let appendedChild = domParent.querySelector(`[key="${nodeKey}"]`);
if (appendedChild.getAttribute('event')) {
setEventListeners(appendedChild);
};
if (appendedChild.childElementCount > 0) {
let needingListeners = appendedChild.querySelectorAll('[event]');
needingListeners.forEach(child => setEventListeners(child));
};
appendedChild = appendedChild.nextElementSibling;
gustChild.remove();
} else if (gustChild.tagName === 'M') {
const nodeKey = gustChild.getAttribute('key');
const nodeIndex = gustChild.id;
let existentNode = document.querySelector(`[key="${nodeKey}"]`);
let childAtIndex = existentNode.parentElement.children[nodeIndex];
if (existentNode.nextElementSibling
&& (existentNode.nextElementSibling.getAttribute('key')
=== childAtIndex.getAttribute('key'))) {
existentNode.parentElement.insertBefore(existentNode, childAtIndex.nextElementSibling);
} else {
existentNode.parentElement.insertBefore(existentNode, childAtIndex);
};
gustChild.remove();
} else if (gustChild.tagName === 'C') {
const nodeKey = gustChild.getAttribute('key');
const attToRem = gustChild.getAttribute('rem')?.slice(0, -1).split(' ') ?? [];
let existentNode = document.querySelector(`[key="${nodeKey}"]`);
attToRem.forEach(att => {
if (att === 'event') {
const eventType = existentNode.getAttribute('event').split('/', 2)[1];
existentNode[`on${eventType}`] = null;
};
existentNode.removeAttribute(att);
});
gustChild.removeAttribute('key');
gustChild.removeAttribute('rem');
for (const att of gustChild.attributes) {
existentNode.setAttribute(att.name, att.value);
if (att.name === 'event') {
const eventType = existentNode.getAttribute('event').split('/', 2)[1];
existentNode[`on${eventType}`] = null;
setEventListeners(existentNode);
};
};
gustChild.remove();
} else {
const nodeKey = gustChild.getAttribute('key');
let existentNode = document.querySelector(`[key="${nodeKey}"]`);
existentNode.replaceWith(gustChild);
let replacedNode = document.querySelector(`[key="${nodeKey}"]`);
if (replacedNode.getAttribute('event')) {
setEventListeners(replacedNode);
};
if (replacedNode.childElementCount > 0) {
let needingListeners = replacedNode.querySelectorAll('[event]');
needingListeners.forEach(child => setEventListeners(child));
};
};
};
} catch (error) {
console.error(error);
};
};
function makeSubscribeBody() {
channelMessageId++;
return [{
id: channelMessageId,
action: 'subscribe',
ship: ship,
app: app,
path: displayUpdatePath
}];
};
function makePokeBody(jsonData) {
channelMessageId++;
return [{
id: channelMessageId,
action: 'poke',
ship: ship,
app: app,
mark: 'json',
json: { path: pith, data: jsonData }
}];
};
function makeAck(eventId) {
channelMessageId++;
return [{
id: channelMessageId,
action: 'ack',
"event-id": eventId
}];
};
'''
::
--

19
pkg/arvo/neo/cod/std/src/lib/mast.hoon Normal file
View File

@ -0,0 +1,19 @@
|%
::
+$ crow :: :: :: mast event poke data
[=path data=(map @t @t)]
::
+$ prow :: :: :: mast init data
$: urth=? :: > are you serving to earth?
url=path :: > the base url that mast will bind with eyre
=made:neo :: > the +$made mast uses to spawn your ui shrubs
==
::
+$ rig :: :: :: mast state
$: urth=?
=made:neo
base-sub=path
open-http=(map @p @ta) :: eyre ids of http requests pending session creation
==
::
--

1
pkg/arvo/neo/cod/std/src/pro/json.hoon Normal file
View File

@ -0,0 +1 @@
json

1
pkg/arvo/neo/cod/std/src/pro/manx.hoon Normal file
View File

@ -0,0 +1 @@
manx

3
pkg/arvo/neo/cod/std/src/pro/ui-event.hoon Normal file
View File

@ -0,0 +1,3 @@
$: =path
data=(map @t @t)
==

4
pkg/arvo/sur/neo.hoon
View File

@ -1287,6 +1287,10 @@
==
+$ task
(pair @ta inbound-request:^eyre)
+$ chan-task
json
+$ chan-gift
[sub=path dat=json]
--
:: +clay: Filesystem overlay
::