ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-15 01:52:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

graph-store: finished first draft of all actions

Browse Source
This commit is contained in:
Logan Allen 2020-06-10 12:08:49 -04:00
parent d44e7eb9ca
commit 3ce10fe01e
1 changed files with 91 additions and 81 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

148
pkg/arvo/app/graph-store.hoon
View File

@ -57,7 +57,7 @@
|= [=resource:store =graph:store] |= [=resource:store =graph:store]
^- (quip card _state) ^- (quip card _state)
?< (~(has by graphs) resource) ?< (~(has by graphs) resource)
:- (give [/all /keys ~] [%add-graph resource graph]) :- (give [/updates /keys ~] [%add-graph resource graph])
%_ state %_ state
graphs (~(put by graphs) resource graph) graphs (~(put by graphs) resource graph)
action-logs (~(put by action-logs) resource (gas:orm-log ~ ~)) action-logs (~(put by action-logs) resource (gas:orm-log ~ ~))
@ -67,7 +67,7 @@
|= =resource:store |= =resource:store
^- (quip card _state) ^- (quip card _state)
?> (~(has by graphs) resource) ?> (~(has by graphs) resource)
:- (give [/all /keys ~] [%remove-graph resource]) :- (give [/updates /keys ~] [%remove-graph resource])
%_ state %_ state
graphs (~(del by graphs) resource) graphs (~(del by graphs) resource)
action-logs (~(del by action-logs) resource) action-logs (~(del by action-logs) resource)
@ -82,7 +82,7 @@
=. action-log =. action-log
(put:orm-log action-log now.bowl [%0 [%add-nodes resource nodes]]) (put:orm-log action-log now.bowl [%0 [%add-nodes resource nodes]])
:: ::
:- (give [/all]~ [%add-nodes resource nodes]) :- (give [/updates]~ [%add-nodes resource nodes])
%_ state %_ state
action-logs (~(put by action-logs) resource action-log) action-logs (~(put by action-logs) resource action-log)
graphs graphs
@ -116,6 +116,9 @@
=* atom i.index =* atom i.index
:: last index in list :: last index in list
:: ::
%^ put:orm
graph
atom
?~ t.index ?~ t.index
:: verify hash if it exists, otherwise calculate :: verify hash if it exists, otherwise calculate
:: ::
@ -127,12 +130,9 @@
:: hash is present, validate it :: hash is present, validate it
~| "hash of post does not match calculated hash" ~| "hash of post does not match calculated hash"
?> =(calculated-hash u.hash.p) ?> =(calculated-hash u.hash.p)
(put:orm graph atom node) node
:: no hash present :: no hash present
:: ::
%^ put:orm
graph
atom
%= node %= node
hash.post `calculated-hash hash.post `calculated-hash
signatures.post signatures.post
@ -145,34 +145,23 @@
== ==
:: multiple indices left in list :: multiple indices left in list
:: ::
=/ parent=(unit node:store) (get:orm graph atom) ~| "index does not exist to add a node to!"
?~ parent =/ parent=node:store (need (get:orm graph atom))
~& "index does not exist to add a node to!" %_ parent
graph
?+ -.children.u.parent
:: replace empty graph with graph containing one child
::
=* p-hash hash.post.u.parent
%^ put:orm
graph
atom
%= u.parent
children children
^- internal-graph:store ^- internal-graph:store
:- %graph :- %graph
$(graph (gas:orm ~ ~), index t.index, parent-hash p-hash) %_ $
== index t.index
:: parent-hash hash.post.parent
%graph graph
?: ?=(%graph -.children.parent)
:: recurse into children :: recurse into children
:: ::
=* p-hash hash.post.u.parent p.children.parent
%^ put:orm :: replace empty graph with graph containing one child
graph ::
atom (gas:orm ~ ~)
%_ u.parent
p.children
$(graph p.children.u.parent, index t.index, parent-hash p-hash)
== ==
== ==
-- --
@ -186,7 +175,7 @@
=. action-log =. action-log
(put:orm-log action-log now.bowl [%0 [%remove-nodes resource indices]]) (put:orm-log action-log now.bowl [%0 [%remove-nodes resource indices]])
:: ::
:- (give [/all]~ [%remove-nodes resource indices]) :- (give [/updates]~ [%remove-nodes resource indices])
%_ state %_ state
action-logs (~(put by action-logs) resource action-log) action-logs (~(put by action-logs) resource action-log)
graphs graphs
@ -215,24 +204,16 @@
+:`[* graph:store]`(del:orm graph atom) +:`[* graph:store]`(del:orm graph atom)
:: multiple indices left in list :: multiple indices left in list
:: ::
=/ parent=(unit node:store) (get:orm graph atom) ~| "parent index does not exist to remove a node from!"
?~ parent =/ =node:store (need (get:orm graph atom))
~& "index does not exist to remove a node from!" ~| "child index does not exist to remove a node from!"
graph ?> ?=(%graph -.children.node)
?+ -.children.u.parent
~& "child index does not exist to remove a node from!"
graph
::
%graph
:: recurse into children :: recurse into children
:: ::
%^ put:orm %^ put:orm
graph graph
atom atom
%_ u.parent node(p.children $(graph p.children.node, index t.index))
p.children $(graph p.children.u.parent, index t.index)
==
==
-- --
:: ::
++ add-signatures ++ add-signatures
@ -245,7 +226,7 @@
=. action-log =. action-log
(put:orm-log action-log now.bowl [%0 [%add-signatures uid signatures]]) (put:orm-log action-log now.bowl [%0 [%add-signatures uid signatures]])
:: ::
:- (give [/all]~ [%add-signatures uid signatures]) :- (give [/updates]~ [%add-signatures uid signatures])
%_ state %_ state
action-logs (~(put by action-logs) resource action-log) action-logs (~(put by action-logs) resource action-log)
graphs graphs
@ -257,47 +238,76 @@
^- graph:store ^- graph:store
?~ index graph ?~ index graph
=* atom i.index =* atom i.index
=/ node=(unit node:store) (get:orm graph atom) ~| "node does not exist to add signatures to!"
?~ node =/ =node:store (need (get:orm graph atom))
~|("node does not exist to add signatures to!" !!)
:: last index in list :: last index in list
:: ::
?~ t.index
:: TODO: finish this
?. (are-signatures-valid:sigs signatures *hash:store now.bowl)
~|("signatures did not match public keys!" !!)
=/ new-signatures (~(uni in signatures) signatures.post.u.node)
%^ put:orm %^ put:orm
graph graph
atom atom
u.node(signatures.post new-signatures) ?~ t.index
~| "cannot add signatures to a node missing a hash"
?> ?=(^ hash.post.node)
~| "signatures did not match public keys!"
?> (are-signatures-valid:sigs signatures u.hash.post.node now.bowl)
node(signatures.post (~(uni in signatures) signatures.post.node))
:: multiple indices left in list :: multiple indices left in list
:: ::
?+ -.children.u.node ~| "child graph does not exist to add signatures to!"
~|("child graph does not exist to add signatures to!" !!) ?> ?=(%graph -.children.node)
::
%graph
:: recurse into children :: recurse into children
:: ::
%^ put:orm node(p.children $(graph p.children.node, index t.index))
graph
atom
%_ u.node
p.children $(graph p.children.u.node, index t.index)
==
==
-- --
:: ::
++ remove-signatures ++ remove-signatures
|= [=uid:store =signatures:store] |= [=uid:store =signatures:store]
^- (quip card _state) ^- (quip card _state)
[~ state] |^
=* resource resource.uid
=/ =graph:store (~(got by graphs) resource)
=/ =action-log:store (~(got by action-logs) resource)
=. action-log
%^ put:orm-log action-log
now.bowl
[%0 [%remove-signatures uid signatures]]
::
:- (give [/updates]~ [%remove-signatures uid signatures])
%_ state
action-logs (~(put by action-logs) resource action-log)
graphs
%+ ~(put by graphs) resource
(remove-at-index graph index.uid signatures)
==
::
++ remove-at-index
|= [=graph:store =index:store =signatures:store]
^- graph:store
?~ index graph
=* atom i.index
~| "node does not exist to add signatures to!"
=/ =node:store (need (get:orm graph atom))
:: last index in list
::
%^ put:orm
graph
atom
?~ t.index
node(signatures.post (~(dif in signatures) signatures.post.node))
:: multiple indices left in list
::
~| "child graph does not exist to add signatures to!"
?> ?=(%graph -.children.node)
:: recurse into children
::
node(p.children $(graph p.children.node, index t.index))
--
:: ::
++ add-tag ++ add-tag
|= [=term =resource:store] |= [=term =resource:store]
^- (quip card _state) ^- (quip card _state)
?> (~(has by graphs) resource) ?> (~(has by graphs) resource)
:- (give [/all]~ [%add-tag term resource]) :- (give [/updates]~ [%add-tag term resource])
%_ state %_ state
tag-queries (~(put ju tag-queries) term resource) tag-queries (~(put ju tag-queries) term resource)
== ==
@ -306,7 +316,7 @@
|= [=term =resource:store] |= [=term =resource:store]
^- (quip card _state) ^- (quip card _state)
?> (~(has by graphs) resource) ?> (~(has by graphs) resource)
:- (give [/all]~ [%remove-tag term resource]) :- (give [/updates]~ [%remove-tag term resource])
%_ state %_ state
tag-queries (~(del ju tag-queries) term resource) tag-queries (~(del ju tag-queries) term resource)
== ==
@ -325,7 +335,7 @@
?> (team:title our.bowl src.bowl) ?> (team:title our.bowl src.bowl)
=/ cards=(list card) =/ cards=(list card)
?+ path (on-watch:def path) ?+ path (on-watch:def path)
[%all ~] (give [%initial graphs tag-queries]) [%updates ~] ~
[%keys ~] (give [%keys ~(key by graphs)]) [%keys ~] (give [%keys ~(key by graphs)])
== ==
[cards this] [cards this]