diff --git a/config/ldes-delta-pusher/dispatch.ts b/config/ldes-delta-pusher/dispatch.ts index 9ff7ab3..a3c9c89 100644 --- a/config/ldes-delta-pusher/dispatch.ts +++ b/config/ldes-delta-pusher/dispatch.ts @@ -11,12 +11,16 @@ export default async function dispatch(changesets: Changeset[]) { PREFIX code: PREFIX org: PREFIX adms: + PREFIX generiek: CONSTRUCT { ?organization a org:Organization; skos:prefLabel ?prefLabel; adms:identifier ?identifier; org:hasPrimarySite ?site. + ?identifier skos:notation ?identifierLabel; + generiek:gestructureerdeIdentificator ?gestructureerdeIdentificator. + ?gestructureerdeIdentificator generiek:lokaleIdentificator ?lokaleIdentificator. ?site org:siteAddress ?siteAddress. ?siteAddress ?p ?o. } WHERE { @@ -26,6 +30,9 @@ export default async function dispatch(changesets: Changeset[]) { skos:prefLabel ?prefLabel; adms:identifier ?identifier; org:hasPrimarySite ?site. + ?identifier skos:notation ?identifierLabel; + generiek:gestructureerdeIdentificator ?gestructureerdeIdentificator. + ?gestructureerdeIdentificator generiek:lokaleIdentificator ?lokaleIdentificator. ?site org:siteAddress ?siteAddress. ?siteAddress ?p ?o. } UNION { @@ -34,6 +41,9 @@ export default async function dispatch(changesets: Changeset[]) { skos:prefLabel ?prefLabel; adms:identifier ?identifier; org:hasPrimarySite ?site. + ?identifier skos:notation ?identifierLabel; + generiek:gestructureerdeIdentificator ?gestructureerdeIdentificator. + ?gestructureerdeIdentificator generiek:lokaleIdentificator ?lokaleIdentificator. ?site org:siteAddress ?siteAddress. ?siteAddress ?p ?o. } UNION { @@ -42,12 +52,16 @@ export default async function dispatch(changesets: Changeset[]) { skos:prefLabel ?prefLabel; adms:identifier ?identifier; org:hasPrimarySite ?site. + ?identifier skos:notation ?identifierLabel; + generiek:gestructureerdeIdentificator ?gestructureerdeIdentificator. + ?gestructureerdeIdentificator generiek:lokaleIdentificator ?lokaleIdentificator. ?site org:siteAddress ?siteAddress. ?siteAddress ?p ?o. } } `); if(bindings.length){ + console.log('SUCCESS') await moveTriples([ { inserts: bindings.map(({ s, p, o}) => { return { subject: s, predicate: p, object: o} }),