From 4581fd0b61cebaa65f449ef302c022e127ae731a Mon Sep 17 00:00:00 2001
From: Elena Poelman <elena.poelman@redpencil.io>
Date: Thu, 13 Jul 2023 09:04:19 +0200
Subject: [PATCH] include local-identifier and label for each identifier of
 organizations sent to ldes feed

---
 config/ldes-delta-pusher/dispatch.ts | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

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: <http://telegraphis.net/ontology/measurement/code#>
         PREFIX org: <http://www.w3.org/ns/org#>
         PREFIX adms: <http://www.w3.org/ns/adms#>
+        PREFIX generiek: <https://data.vlaanderen.be/ns/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} }),