shrub/pkg/landscape/app/metadata-pull-hook.hoon

341 lines
8.4 KiB
Plaintext
Raw Normal View History

2021-01-13 07:50:37 +03:00
:: metadata-pull-hook [landscape]:
::
:: allow syncing group data from foreign paths to local paths
::
/- *group, invite-store, metadata=metadata-store, contact=contact-store
2021-01-13 07:50:37 +03:00
/+ default-agent, verb, dbug, store=group-store, grpl=group, pull-hook
/+ resource, mdl=metadata, agn=agentio
2021-01-13 07:50:37 +03:00
~% %group-hook-top ..part ~
|%
+$ card card:agent:gall
::
2021-03-25 03:52:40 +03:00
+$ group-preview-0
$: group=resource
channels=associations-0
members=@ud
channel-count=@ud
metadatum=metadatum-0
==
::
+$ associations-0
(map md-resource:metadata [group=resource metadatum=metadatum-0])
::
+$ metadatum-0
$: title=cord
description=cord
=color:metadata
date-created=time
creator=ship
module=term
picture=url:metadata
preview=?
vip=vip-metadata:metadata
==
::
2021-01-13 07:50:37 +03:00
++ config
^- config:pull-hook
:* %metadata-store
2021-01-28 09:13:57 +03:00
update:metadata
2021-01-13 07:50:37 +03:00
%metadata-update
%metadata-push-hook
2021-07-09 05:54:55 +03:00
2 2
%.n
2021-01-13 07:50:37 +03:00
==
2021-01-21 08:18:13 +03:00
+$ state-zero
2021-03-25 03:52:40 +03:00
[%0 previews=(map resource group-preview-0)]
2021-01-13 07:50:37 +03:00
::
+$ state-one
$: %1
2021-03-25 03:52:40 +03:00
pending=(set resource)
previews=(map resource group-preview-0)
==
::
+$ state-two
$: %2
pending=(set resource)
previews=(map resource group-preview:metadata)
==
::
+$ versioned-state
$% state-zero
state-one
2021-03-25 03:52:40 +03:00
state-two
==
2021-01-13 07:50:37 +03:00
--
::
%- agent:dbug
%+ verb |
^- agent:gall
%- (agent:pull-hook config)
^- (pull-hook:pull-hook config)
2021-03-25 03:52:40 +03:00
=| state-two
2021-01-21 08:18:13 +03:00
=* state -
=> |_ =bowl:gall
++ def ~(. (default-agent state %|) bowl)
++ met ~(. mdl bowl)
++ io ~(. agn bowl)
++ get-preview
|= rid=resource
=/ =path
preview+(en-path:resource rid)
=/ =dock
[entity.rid %metadata-push-hook]
%+ ~(poke pass:io path) dock
metadata-hook-update+!>([%req-preview rid])
::
++ watch-invites
(~(watch-our pass:io /invites) %invite-store /updates)
::
++ take-invites
|= =sign:agent:gall
^- (quip card _state)
?+ -.sign (on-agent:def /invites sign)
%fact
?> ?=(%invite-update p.cage.sign)
=+ !<(=update:invite-store q.cage.sign)
?. ?=(%invite -.update) `state
?: (~(has in pending) resource.invite.update) `state
:_ state(pending (~(put in pending) resource.invite.update))
(get-preview resource.invite.update)^~
::
%kick [watch-invites^~ state]
==
::
++ watch-contacts
(~(watch-our pass:io /contacts) %contact-store /all)
::
++ take-contacts
|= =sign:agent:gall
^- (quip card _state)
?+ -.sign (on-agent:def /contacts sign)
%kick [~[watch-contacts] state]
::
%fact
2021-03-11 07:10:32 +03:00
?> ?=(%contact-update-0 p.cage.sign)
=+ !<(=update:contact q.cage.sign)
?+ -.update `state
%add
=/ missing=(set resource)
(check-contact contact.update)
=. pending
(~(uni in pending) missing)
:_ state
(get-many-previews missing)
::
%edit
?. ?=(%add-group -.edit-field.update) `state
=/ missing=(set resource)
%- add-missing-previews
(~(gas in *(set resource)) resource.edit-field.update ~)
=. pending
(~(uni in pending) missing)
:_ state
(get-many-previews missing)
::
::
%initial
=/ missing=(set resource)
%- add-missing-previews
%+ roll ~(tap by rolodex.update)
|= [[ship =contact:contact] out=(set resource)]
(~(uni in out) (check-contact contact))
=. pending
(~(uni in pending) missing)
:_ state
(get-many-previews missing)
==
==
::
++ get-many-previews
|= rids=(set resource)
(turn ~(tap by rids) get-preview)
::
++ check-contact
|= =contact:contact
^- (set resource)
(add-missing-previews groups.contact)
::
++ add-missing-previews
|= groups=(set resource)
^- (set resource)
=/ have=(set resource)
(~(uni in ~(key by previews)) pending)
=/ missing=(set resource)
(~(dif in groups) have)
%- ~(gas by *(set resource))
%+ murn ~(tap by missing)
|= group=resource
^- (unit resource)
?^ (peek-metadatum:met %groups group) ~
`group
::
++ watch-store
(~(watch-our pass:io /store) %metadata-store /all)
::
++ take-store
|= =sign:agent:gall
^- (quip card _state)
?+ -.sign (on-agent:def /store sign)
%kick [watch-store^~ state]
::
%fact
2021-07-09 05:54:55 +03:00
?> ?=(%metadata-update-2 p.cage.sign)
=+ !<(=update:metadata q.cage.sign)
?. ?=(%initial-group -.update) `state
`state(previews (~(del by previews) group.update))
==
--
2021-01-13 07:50:37 +03:00
|_ =bowl:gall
+* this .
def ~(. (default-agent this %|) bowl)
dep ~(. (default:pull-hook this config) bowl)
met ~(. mdl bowl)
hc ~(. +> bowl)
2021-01-13 07:50:37 +03:00
::
++ on-init
:_ this
:~ watch-invites:hc
watch-contacts:hc
watch-store:hc
==
::
2021-01-21 08:18:13 +03:00
++ on-save !>(state)
++ on-load
|= =vase
=+ !<(old=versioned-state vase)
2021-03-25 03:52:40 +03:00
|^
?- -.old
2021-03-25 03:52:40 +03:00
%2 `this(state old)
::
%1
%_ $
old
%* . *state-two
previews (~(run by previews.old) preview-to-1)
==
==
::
%0
%_ $
old
%* . *state-one
previews previews.old
==
==
==
2021-03-25 03:52:40 +03:00
::
++ metadatum-to-1
|= m=metadatum-0
%* . *metadatum:metadata
title title.m
description description.m
color color.m
date-created date-created.m
creator creator.m
preview preview.m
hidden %|
::
config
?: =(module.m %$)
[%group ~]
[%graph module.m]
==
::
++ preview-to-1
|= preview=group-preview-0
^- group-preview:metadata
%= preview
metadatum (metadatum-to-1 metadatum.preview)
channels (associations-to-1 channels.preview)
==
::
++ associations-to-1
|= a=associations-0
^- associations:metadata
%- ~(run by a)
|= [g=resource m=metadatum-0]
[g (metadatum-to-1 m)]
--
2021-01-21 08:18:13 +03:00
::
++ on-poke
|= [=mark =vase]
?. ?=(%metadata-hook-update mark)
(on-poke:def mark vase)
2021-01-28 09:13:57 +03:00
=+ !<(=hook-update:metadata vase)
?. ?=(%preview -.hook-update)
(on-poke:def mark vase)
2021-02-12 07:59:16 +03:00
=: pending (~(del in pending) group.hook-update)
previews
(~(put by previews) group.hook-update +.hook-update)
==
:_ this
=/ =path
preview+(en-path:resource group.hook-update)
(fact-kick:io path mark^vase)
::
++ on-agent
|= [=wire =sign:agent:gall]
=^ cards state
?+ wire (on-agent:def:hc wire sign)
[%invites ~] (take-invites:hc sign)
[%contacts ~] (take-contacts:hc sign)
[%store ~] (take-store:hc sign)
::
[%preview @ @ @ ~]
?. ?=(%poke-ack -.sign)
(on-agent:def:hc wire sign)
?~ p.sign `state
=/ rid
(de-path:resource t.wire)
:_ state(pending (~(del in pending) rid))
(fact-kick:io wire tang+!>(u.p.sign))
==
[cards this]
::
++ on-watch
|= =path
?> (team:title [our src]:bowl)
?+ path (on-watch:def path)
[%nack ~] `this
::
[%preview @ @ @ ~]
=/ rid=resource
(de-path:resource t.path)
=/ prev=(unit group-preview:metadata)
?^ (peek-metadatum:met %groups rid)
(some (get-preview:met rid))
(~(get by previews) rid)
?~ prev
:_ this(pending (~(put in pending) rid))
(get-preview rid)^~
:_ this
(fact-init:io metadata-hook-update+!>([%preview u.prev]))^~
==
::
2021-01-13 07:50:37 +03:00
++ on-leave on-leave:def
++ on-peek on-peek:def
2021-01-21 08:18:13 +03:00
++ on-arvo on-arvo:def
::
2021-01-13 07:50:37 +03:00
++ on-fail on-fail:def
++ resource-for-update resource-for-update:met
2021-01-13 07:50:37 +03:00
++ on-pull-nack
|= [=resource =tang]
2021-01-13 07:50:37 +03:00
^- (quip card _this)
2021-01-28 09:13:57 +03:00
=/ =associations:metadata
(metadata-for-group:met resource)
:_ this
:- `card`[%give %fact ~[/nack] resource+!>(resource)]
%+ turn ~(tap by associations)
2021-01-28 09:13:57 +03:00
|= [=md-resource:metadata =association:metadata]
%+ poke-our:pass:io %metadata-store
2021-07-09 05:54:55 +03:00
:- %metadata-update-2
2021-01-28 09:13:57 +03:00
!> ^- update:metadata
[%remove resource md-resource]
2021-01-13 07:50:37 +03:00
::
++ on-pull-kick
|= =resource
2021-01-13 07:50:37 +03:00
^- (unit path)
`/
--