Compare commits
33 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
a796c83826 | ||
|
7b37d91012 | ||
|
|
ba39434853 | ||
|
|
0e52e2bcf6 | ||
|
a61d6bed35 | ||
|
|
50a3ff2929 | ||
|
|
b5fbf09c08 | ||
|
|
826aa6d379 | ||
|
|
087f3d2d86 | ||
|
|
74a9ac2eb1 | ||
|
|
28d63c10ba | ||
|
|
bb377639f4 | ||
|
|
4179194e6f | ||
|
|
f5e24f3bc3 | ||
|
|
5bdf87632a | ||
|
|
cbe53c5b6b | ||
|
|
0f7313b944 | ||
|
411d16e33d | ||
|
|
6d1b58ecf0 | ||
|
1767eff19b | ||
|
|
e30e93e00e | ||
|
|
2958262abf | ||
|
|
3b3a7b548c | ||
|
|
bdf7802a31 | ||
|
7b8890b1ff | ||
|
|
bb74c52267 | ||
|
|
3d749242aa | ||
|
|
d52f121a0b | ||
|
|
384a237bc4 | ||
|
|
eb78e3a6aa | ||
|
|
b3621bc103 | ||
|
|
03e5c42dcc | ||
|
|
c5e1436ea8 |
@@ -18,6 +18,7 @@ defmodule Acl.UserGroups.Config do
|
||||
"https://data.vlaanderen.be/ns/besluitvorming#Beslissingsactiviteit",
|
||||
"http://data.vlaanderen.be/ns/besluit#Bestuurseenheid",
|
||||
"http://data.lblod.info/vocabularies/erediensten/BestuurVanDeEredienst",
|
||||
"http://data.lblod.info/vocabularies/erediensten/EredienstBestuurseenheid",
|
||||
"http://data.vlaanderen.be/ns/besluit#Bestuursorgaan",
|
||||
"http://data.lblod.info/vocabularies/erediensten/RolBedienaar",
|
||||
"http://data.lblod.info/vocabularies/erediensten/VoorwaardenBedienaar",
|
||||
|
||||
@@ -12,6 +12,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel",
|
||||
"http://www.w3.org/2004/02/skos/core#altLabel",
|
||||
"http://www.w3.org/ns/adms#identifier",
|
||||
@@ -24,8 +25,6 @@
|
||||
"http://www.w3.org/ns/org#linkedTo",
|
||||
"http://www.w3.org/ns/org#hasSubOrganization",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"http://data.lblod.info/vocabularies/erediensten/betrokkenBestuur",
|
||||
"http://mu.semte.ch/vocabularies/ext/werkingsgebiedNiveau",
|
||||
"http://data.lblod.info/vocabularies/erediensten/denominatie",
|
||||
"http://data.lblod.info/vocabularies/erediensten/grensoverschrijdend",
|
||||
"http://data.lblod.info/vocabularies/erediensten/wordtBediendDoor",
|
||||
@@ -43,6 +42,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel",
|
||||
"http://www.w3.org/2004/02/skos/core#altLabel",
|
||||
"http://www.w3.org/ns/adms#identifier",
|
||||
@@ -55,11 +55,79 @@
|
||||
"http://www.w3.org/ns/org#linkedTo",
|
||||
"http://www.w3.org/ns/org#hasSubOrganization",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"http://data.lblod.info/vocabularies/erediensten/betrokkenBestuur",
|
||||
"http://mu.semte.ch/vocabularies/ext/werkingsgebiedNiveau",
|
||||
"http://data.lblod.info/vocabularies/erediensten/typeEredienst"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://data.vlaanderen.be/ns/besluit#Bestuurseenheid",
|
||||
"strictTypeExport": "true",
|
||||
"graphsFilter": [
|
||||
"http://mu.semte.ch/graphs/organisatieportaal"
|
||||
],
|
||||
"pathToConceptScheme": [
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://data.lblod.info/vocabularies/erediensten/betrokkenBestuur",
|
||||
"http://data.lblod.info/vocabularies/erediensten/denominatie",
|
||||
"http://data.lblod.info/vocabularies/erediensten/grensoverschrijdend",
|
||||
"http://data.lblod.info/vocabularies/erediensten/typeEredienst",
|
||||
"http://data.lblod.info/vocabularies/erediensten/wordtBediendDoor",
|
||||
"http://data.vlaanderen.be/ns/besluit#werkingsgebied",
|
||||
"http://www.opengis.net/ont/geosparql#sfWithin",
|
||||
"http://www.w3.org/2002/07/owl#sameAs",
|
||||
"http://www.w3.org/2004/02/skos/core#altLabel",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel",
|
||||
"http://www.w3.org/ns/adms#identifier",
|
||||
"http://www.w3.org/ns/org#changedBy",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"http://www.w3.org/ns/org#hasPost",
|
||||
"http://www.w3.org/ns/org#hasPrimarySite",
|
||||
"http://www.w3.org/ns/org#hasSite",
|
||||
"http://www.w3.org/ns/org#hasSubOrganization",
|
||||
"http://www.w3.org/ns/org#linkedTo",
|
||||
"http://www.w3.org/ns/org#resultedFrom",
|
||||
"http://www.w3.org/ns/regorg#orgStatus"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://data.lblod.info/vocabularies/erediensten/RepresentatiefOrgaan",
|
||||
"graphsFilter": [
|
||||
"http://mu.semte.ch/graphs/organisatieportaal"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel",
|
||||
"http://www.w3.org/ns/org#linkedTo",
|
||||
"http://data.lblod.info/vocabularies/erediensten/typeEredienst",
|
||||
"http://www.w3.org/ns/adms#identifier"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://data.lblod.info/vocabularies/erediensten/BetrokkenLokaleBesturen",
|
||||
"graphsFilter": [
|
||||
"http://mu.semte.ch/graphs/organisatieportaal"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://data.lblod.info/vocabularies/erediensten/typebetrokkenheid",
|
||||
"http://www.w3.org/ns/org#organization",
|
||||
"http://data.lblod.info/vocabularies/erediensten/financieringspercentage"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://data.lblod.info/vocabularies/erediensten/PositieBedienaar",
|
||||
"graphsFilter": [
|
||||
"http://mu.semte.ch/graphs/organisatieportaal"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/ns/org#role",
|
||||
"http://data.lblod.info/vocabularies/erediensten/functie"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://www.w3.org/ns/org#Site",
|
||||
"graphsFilter": [
|
||||
@@ -72,6 +140,7 @@
|
||||
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/ns/org#siteAddress",
|
||||
"https://data.vlaanderen.be/ns/organisatie#bestaatUit",
|
||||
"http://data.lblod.info/vocabularies/erediensten/vestigingstype"
|
||||
@@ -90,6 +159,7 @@
|
||||
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"https://data.vlaanderen.be/ns/adres#Adresvoorstelling.huisnummer",
|
||||
"https://data.vlaanderen.be/ns/adres#Adresvoorstelling.busnummer",
|
||||
"http://www.w3.org/ns/locn#thoroughfare",
|
||||
@@ -136,6 +206,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#notation",
|
||||
"https://data.vlaanderen.be/ns/generiek#gestructureerdeIdentificator"
|
||||
]
|
||||
@@ -152,6 +223,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"https://data.vlaanderen.be/ns/generiek#lokaleIdentificator"
|
||||
]
|
||||
},
|
||||
@@ -164,6 +236,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel"
|
||||
]
|
||||
},
|
||||
@@ -178,11 +251,34 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://data.vlaanderen.be/ns/mandaat#bindingEinde",
|
||||
"http://data.vlaanderen.be/ns/mandaat#bindingStart",
|
||||
"http://data.vlaanderen.be/ns/besluit#bestuurt",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"https://data.vlaanderen.be/ns/generiek#isTijdspecialisatieVan"
|
||||
"https://data.vlaanderen.be/ns/generiek#isTijdspecialisatieVan",
|
||||
"http://www.w3.org/ns/org#hasPost"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://data.vlaanderen.be/ns/besluit#Bestuursorgaan",
|
||||
"strictTypeExport": "true",
|
||||
"graphsFilter": [
|
||||
"http://mu.semte.ch/graphs/organisatieportaal"
|
||||
],
|
||||
"pathToConceptScheme": [
|
||||
"https://data.vlaanderen.be/ns/generiek#isTijdspecialisatieVan",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://data.vlaanderen.be/ns/mandaat#bindingEinde",
|
||||
"http://data.vlaanderen.be/ns/mandaat#bindingStart",
|
||||
"http://data.vlaanderen.be/ns/besluit#bestuurt",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"https://data.vlaanderen.be/ns/generiek#isTijdspecialisatieVan",
|
||||
"http://www.w3.org/ns/org#hasPost"
|
||||
]
|
||||
},
|
||||
{
|
||||
@@ -194,6 +290,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel"
|
||||
]
|
||||
},
|
||||
@@ -206,6 +303,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel"
|
||||
]
|
||||
},
|
||||
@@ -219,6 +317,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://purl.org/dc/terms/date",
|
||||
"http://purl.org/dc/terms/description",
|
||||
"http://data.lblod.info/vocabularies/contacthub/typeWijziging",
|
||||
@@ -239,6 +338,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel"
|
||||
]
|
||||
},
|
||||
@@ -251,6 +351,7 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel"
|
||||
]
|
||||
},
|
||||
@@ -263,6 +364,40 @@
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://data.vlaanderen.be/ns/mandaat#Mandaat",
|
||||
"graphsFilter": [
|
||||
"http://mu.semte.ch/graphs/organisatieportaal"
|
||||
],
|
||||
"pathToConceptScheme": [
|
||||
"^http://www.w3.org/ns/org#hasPost",
|
||||
"https://data.vlaanderen.be/ns/generiek#isTijdspecialisatieVan",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/ns/org#role"
|
||||
]
|
||||
},
|
||||
{
|
||||
"type": "http://data.lblod.info/vocabularies/leidinggevenden/Bestuursfunctie",
|
||||
"graphsFilter": [
|
||||
"http://mu.semte.ch/graphs/organisatieportaal"
|
||||
],
|
||||
"pathToConceptScheme": [
|
||||
"^http://data.lblod.info/vocabularies/leidinggevenden/heeftBestuursfunctie",
|
||||
"https://data.vlaanderen.be/ns/generiek#isTijdspecialisatieVan",
|
||||
"http://www.w3.org/ns/org#classification",
|
||||
"http://www.w3.org/2004/02/skos/core#inScheme"
|
||||
],
|
||||
"properties": [
|
||||
"http://mu.semte.ch/vocabularies/core/uuid",
|
||||
"http://www.w3.org/ns/org#role",
|
||||
"http://www.w3.org/2004/02/skos/core#prefLabel"
|
||||
]
|
||||
}
|
||||
|
||||
@@ -97,7 +97,7 @@ defmodule Dispatcher do
|
||||
end
|
||||
|
||||
match "/central-worship-services/*path", %{ accept: [:json], layer: :api} do
|
||||
Proxy.forward conn, path, "http://cache/central-worship-services/"
|
||||
Proxy.forward conn, path, "http://resource/central-worship-services/"
|
||||
end
|
||||
|
||||
match "/representative-bodies/*path", %{ accept: [:json], layer: :api} do
|
||||
@@ -113,7 +113,7 @@ defmodule Dispatcher do
|
||||
end
|
||||
|
||||
match "/local-involvements/*path", %{ accept: [:json], layer: :api} do
|
||||
Proxy.forward conn, path, "http://cache/local-involvements/"
|
||||
Proxy.forward conn, path, "http://resource/local-involvements/"
|
||||
end
|
||||
|
||||
match "/identifiers/*path", %{ accept: [:json], layer: :api} do
|
||||
@@ -335,6 +335,14 @@ defmodule Dispatcher do
|
||||
Proxy.forward conn, path, "http://delta-producer-json-diff-file-publisher-organizations/files/"
|
||||
end
|
||||
|
||||
#################################################################
|
||||
# DELTA: public
|
||||
#################################################################
|
||||
|
||||
get "/sync/public/files/*path" do
|
||||
Proxy.forward conn, path, "http://delta-producer-json-diff-publisher-public/files/"
|
||||
end
|
||||
|
||||
#################################################################
|
||||
# DELTA: posts
|
||||
#################################################################
|
||||
|
||||
@@ -0,0 +1,33 @@
|
||||
PREFIX org: <http://www.w3.org/ns/org#>
|
||||
PREFIX locn: <http://www.w3.org/ns/locn#>
|
||||
PREFIX schema: <http://schema.org/>
|
||||
|
||||
DELETE {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
|
||||
?mandatarissen ?pMandatarissen ?oMandatarissen .
|
||||
?contactPoint ?pContactPoint ?oContactPoint .
|
||||
?address ?pAddress ?oAddress .
|
||||
|
||||
}
|
||||
}
|
||||
WHERE {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
|
||||
VALUES ?mandatarissen {
|
||||
<http://data.lblod.info/id/mandatarissen/62629ED7FEE49A5CF118F11D>
|
||||
<http://data.lblod.info/id/mandatarissen/63D24E975410CAD909EF6CD0>
|
||||
}
|
||||
|
||||
?mandatarissen ?pMandatarissen ?oMandatarissen .
|
||||
|
||||
OPTIONAL {
|
||||
?mandatarissen schema:contactPoint ?contactPoint .
|
||||
?contactPoint ?pContactPoint ?oContactPoint.
|
||||
OPTIONAL {
|
||||
?contactPoint locn:address ?address .
|
||||
?address ?pAddress ?oAddress .
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
PREFIX org: <http://www.w3.org/ns/org#>
|
||||
PREFIX adms: <http://www.w3.org/ns/adms#>
|
||||
PREFIX generiek: <https://data.vlaanderen.be/ns/generiek#>
|
||||
PREFIX organisatie: <https://data.vlaanderen.be/ns/organisatie#>
|
||||
|
||||
DELETE {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
?bestuur ?pbestuur ?obestuur .
|
||||
?primarySite ?pprimarySite ?oprimarySite .
|
||||
?address ?paddress ?oaddress .
|
||||
?contactPoint ?pcontactPoint ?ocontactPoint .
|
||||
?identifier ?pidentifier ?oidentifier .
|
||||
?structuredIdentifier ?pstructuredIdentifier ?ostructuredIdentifier .
|
||||
}
|
||||
} WHERE {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
BIND(<http://data.lblod.info/id/besturenVanDeEredienst/578bf96f86056e2260dc21cee91aa519> as ?bestuur)
|
||||
|
||||
?bestuur ?pbestuur ?obestuur .
|
||||
|
||||
OPTIONAL {
|
||||
|
||||
?bestuur org:hasPrimarySite ?primarySite .
|
||||
|
||||
OPTIONAL {
|
||||
?primarySite organisatie:bestaatUit ?address .
|
||||
?address ?paddress ?oaddress .
|
||||
}
|
||||
OPTIONAL {
|
||||
?primarySite org:siteAddress ?contactPoint .
|
||||
?contactPoint ?pcontactPoint ?ocontactPoint .
|
||||
}
|
||||
|
||||
?primarySite ?pprimarySite ?oprimarySite .
|
||||
|
||||
}
|
||||
OPTIONAL {
|
||||
|
||||
?bestuur adms:identifier ?identifier .
|
||||
|
||||
OPTIONAL {
|
||||
?identifier generiek:gestructureerdeIdentificator ?structuredIdentifier .
|
||||
?structuredIdentifier ?pstructuredIdentifier ?ostructuredIdentifier .
|
||||
}
|
||||
|
||||
?identifier ?pidentifier ?oidentifier .
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
# We already had betrokken lokale besturen entered for some CB.
|
||||
# Too keep data aligned with the other applications (Loket, CVP etc), we first flush them
|
||||
# before re-adding only the necessary ones
|
||||
|
||||
DELETE {
|
||||
GRAPH ?g {
|
||||
?localInvolvement ?plocalInvolvement ?olocalInvolvement .
|
||||
?bestuur <http://data.lblod.info/vocabularies/erediensten/betrokkenBestuur> ?localInvolvement .
|
||||
}
|
||||
} WHERE {
|
||||
GRAPH ?g {
|
||||
?centraalBestuur a <http://data.lblod.info/vocabularies/erediensten/CentraalBestuurVanDeEredienst> .
|
||||
|
||||
?localInvolvement <http://www.w3.org/ns/org#organization> ?centraalBestuur ;
|
||||
?plocalInvolvement ?olocalInvolvement .
|
||||
|
||||
?bestuur <http://data.lblod.info/vocabularies/erediensten/betrokkenBestuur> ?localInvolvement .
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1 @@
|
||||
http://mu.semte.ch/graphs/organisatieportaal
|
||||
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,26 @@
|
||||
PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>
|
||||
PREFIX org: <http://www.w3.org/ns/org#>
|
||||
PREFIX mu: <http://mu.semte.ch/vocabularies/core/>
|
||||
PREFIX ext: <http://mu.semte.ch/vocabularies/ext/>
|
||||
PREFIX ch: <http://data.lblod.info/vocabularies/contacthub/>
|
||||
PREFIX code: <http://lblod.data.gift/vocabularies/organisatie/>
|
||||
|
||||
INSERT DATA {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
|
||||
<http://lblod.data.info/id/veranderingsgebeurtenis-resultaten/0b2f1b62-a15d-11ed-a8fc-0242ac120002>
|
||||
rdf:type code:VeranderingsgebeurtenisResultaat;
|
||||
mu:uuid "0b2f1b62-a15d-11ed-a8fc-0242ac120002" ;
|
||||
code:resulterendeStatus <http://lblod.data.gift/concepts/d02c4e12bf88d2fdf5123b07f29c9311> ;
|
||||
ext:resultingOrganization <http://data.lblod.info/id/bestuurseenheden/25b05f670144f166a485a1d0ac37faca672b36642cf1647d846010d6fe9cabb5> .
|
||||
|
||||
<http://data.lblod.info/id/veranderingsgebeurtenissen/63D7E7E07A8167ED439EC88E>
|
||||
rdf:type org:ChangeEvent ;
|
||||
mu:uuid "63D7E7E07A8167ED439EC88E" ;
|
||||
ch:typeWijziging <http://lblod.data.gift/concepts/e4c3d1ef-a34d-43b0-a18c-f4e60e2c8af3> ;
|
||||
org:resultingOrganization <http://data.lblod.info/id/bestuurseenheden/25b05f670144f166a485a1d0ac37faca672b36642cf1647d846010d6fe9cabb5> ;
|
||||
org:originalOrganization <http://data.lblod.info/id/bestuurseenheden/25b05f670144f166a485a1d0ac37faca672b36642cf1647d846010d6fe9cabb5> ;
|
||||
code:veranderingsgebeurtenisResultaat <http://lblod.data.info/id/veranderingsgebeurtenis-resultaten/0b2f1b62-a15d-11ed-a8fc-0242ac120002> .
|
||||
|
||||
}
|
||||
}
|
||||
25
config/migrations/2023/20230131172200-delete-region.sparql
Normal file
25
config/migrations/2023/20230131172200-delete-region.sparql
Normal file
@@ -0,0 +1,25 @@
|
||||
PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>
|
||||
PREFIX besluit: <http://data.vlaanderen.be/ns/besluit#>
|
||||
PREFIX geo: <http://www.opengis.net/ont/geosparql#>
|
||||
|
||||
DELETE {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
|
||||
?werkingsgebied geo:sfWithin ?locatie .
|
||||
|
||||
}
|
||||
} WHERE {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
|
||||
VALUES ?bestuurseenheid {
|
||||
<http://data.lblod.info/id/bestuurseenheden/9b93ff5308590c7d03c97c3b892910f912e695ad45c82465934996fb04dac859> # OP-2033
|
||||
<http://data.lblod.info/id/bestuurseenheden/25b05f670144f166a485a1d0ac37faca672b36642cf1647d846010d6fe9cabb5> # OP-1994
|
||||
}
|
||||
|
||||
?bestuurseenheid rdf:type besluit:Bestuurseenheid ;
|
||||
besluit:werkingsgebied ?werkingsgebied .
|
||||
|
||||
?werkingsgebied geo:sfWithin ?locatie .
|
||||
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,18 @@
|
||||
PREFIX generiek: <https://data.vlaanderen.be/ns/generiek#>
|
||||
|
||||
DELETE {
|
||||
GRAPH ?g {
|
||||
<http://data.lblod.info/id/gestructureerdeIdentificatoren/b4af7f119ea6a0b012e01ef8494c5f72>
|
||||
generiek:lokaleIdentificator ?kbo .
|
||||
}
|
||||
} INSERT {
|
||||
GRAPH ?g {
|
||||
<http://data.lblod.info/id/gestructureerdeIdentificatoren/b4af7f119ea6a0b012e01ef8494c5f72>
|
||||
generiek:lokaleIdentificator "0655698422" .
|
||||
}
|
||||
} WHERE {
|
||||
GRAPH ?g {
|
||||
<http://data.lblod.info/id/gestructureerdeIdentificatoren/b4af7f119ea6a0b012e01ef8494c5f72>
|
||||
generiek:lokaleIdentificator ?kbo .
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
INSERT DATA {
|
||||
GRAPH <http://mu.semte.ch/graphs/organisatieportaal> {
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/f9cac08a-13c1-49da-9bcb-f650b0604054> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Centraal bestuur van de eredienst"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/5ab0e9b8a3b2ca7c5e000001> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Gemeente"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/5ab0e9b8a3b2ca7c5e000000> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Provincie"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/66ec74fd-8cfc-4e16-99c6-350b35012e86> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Bestuur van de eredienst"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/36a82ba0-7ff1-4697-a9dd-2e94df73b721> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Autonoom gemeentebedrijf"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/cc4e2d67-603b-4784-9b61-e50bac1ec089> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #OCMW vereniging"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/ea446861-2c51-45fa-afd3-4e4a37b71562> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Hulpverleningszone"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/a3922c6d-425b-474f-9a02-ffb71a436bfc> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Politiezone"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/b156b67f-c5f4-4584-9b30-4c090be02fdc> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Projectvereniging"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/cd93f147-3ece-4308-acab-5c5ada3ec63d> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Opdrachthoudende vereniging"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/d01bb1f6-2439-4e33-9c25-1fc295de2e71> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Dienstverlenende vereniging"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/5ab0e9b8a3b2ca7c5e000003> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #District"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/5ab0e9b8a3b2ca7c5e000002> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #OCMW"
|
||||
<http://data.vlaanderen.be/id/concept/BestuurseenheidClassificatieCode/80310756-ce0a-4a1b-9b8e-7c01b6cc7a2d> <http://www.w3.org/2004/02/skos/core#inScheme> <http://lblod.data.gift/concept-schemes/10caf4a4-1ff5-4c05-917e-56489910d68b>. #Autonoom provinciebedrijf"
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -23,7 +23,7 @@
|
||||
"skos": "http://www.w3.org/2004/02/skos/core#",
|
||||
"euvoc": "http://publications.europa.eu/ontology/euvoc#",
|
||||
"ere": "http://data.lblod.info/vocabularies/erediensten/",
|
||||
"ch": "http://data.lblod.info/vocabularies/contacthub/",
|
||||
"ch": "http://data.lblod.info/vocabularies/contacthub/",
|
||||
"code": "http://lblod.data.gift/vocabularies/organisatie/",
|
||||
"ext": "http://mu.semte.ch/vocabularies/ext/",
|
||||
"geo": "http://www.opengis.net/ont/geosparql#"
|
||||
@@ -63,7 +63,7 @@
|
||||
"target": "agents",
|
||||
"cardinality": "many",
|
||||
"inverse": true
|
||||
},
|
||||
}
|
||||
},
|
||||
"new-resource-base": "http://data.lblod.info/id/personen/"
|
||||
},
|
||||
@@ -108,7 +108,7 @@
|
||||
},
|
||||
"organization": {
|
||||
"predicate": "org:postIn",
|
||||
"target": "organization",
|
||||
"target": "organizations",
|
||||
"cardinality": "one"
|
||||
},
|
||||
"agents-in-position": {
|
||||
@@ -223,7 +223,7 @@
|
||||
"type": "string",
|
||||
"predicate": "schema:contactType"
|
||||
}
|
||||
},
|
||||
},
|
||||
"relationships": {
|
||||
"contact-address": {
|
||||
"predicate": "locn:address",
|
||||
@@ -269,7 +269,7 @@
|
||||
"type": "datetime",
|
||||
"predicate": "mandaat:einde"
|
||||
}
|
||||
},
|
||||
},
|
||||
"relationships": {
|
||||
"board-position": {
|
||||
"predicate": "org:holds",
|
||||
@@ -358,7 +358,7 @@
|
||||
"predicate": "skos:prefLabel"
|
||||
},
|
||||
"alternative-name": {
|
||||
"type": "string",
|
||||
"type": "string",
|
||||
"predicate": "skos:altLabel"
|
||||
}
|
||||
},
|
||||
@@ -492,10 +492,15 @@
|
||||
"predicate": "ere:wordtBediendDoor",
|
||||
"target": "minister-positions",
|
||||
"cardinality": "many"
|
||||
},
|
||||
"involvements": {
|
||||
"predicate": "org:organization",
|
||||
"target": "local-involvements",
|
||||
"cardinality": "many",
|
||||
"inverse": true
|
||||
}
|
||||
},
|
||||
"new-resource-base": "http://data.lblod.info/id/eredienstBestuurseenheden/"
|
||||
|
||||
},
|
||||
"worship-services": {
|
||||
"class": "ere:BestuurVanDeEredienst",
|
||||
@@ -510,14 +515,6 @@
|
||||
"predicate": "ere:grensoverschrijdend"
|
||||
}
|
||||
},
|
||||
"relationships": {
|
||||
"involvements": {
|
||||
"predicate": "org:organization",
|
||||
"target": "local-involvements",
|
||||
"cardinality": "many",
|
||||
"inverse": true
|
||||
}
|
||||
},
|
||||
"new-resource-base": "http://data.lblod.info/id/besturenVanDeEredienst/"
|
||||
},
|
||||
"recognized-worship-types": {
|
||||
@@ -631,9 +628,9 @@
|
||||
"target": "involvement-types",
|
||||
"cardinality": "one"
|
||||
},
|
||||
"worship-service": {
|
||||
"worship-administrative-unit": {
|
||||
"predicate": "org:organization",
|
||||
"target": "worship-services",
|
||||
"target": "worship-administrative-units",
|
||||
"cardinality": "one"
|
||||
},
|
||||
"administrative-unit": {
|
||||
@@ -711,7 +708,6 @@
|
||||
"type": "url",
|
||||
"predicate": "adres:verwijstNaar"
|
||||
}
|
||||
|
||||
},
|
||||
"relationships": {
|
||||
"source": {
|
||||
@@ -838,9 +834,9 @@
|
||||
"predicate": "ere:voldoetAan",
|
||||
"target": "minister-conditions",
|
||||
"cardinality": "many"
|
||||
}
|
||||
}
|
||||
},
|
||||
"new-resource-base": "http://data.lblod.info/id/rollenBedienaar/"
|
||||
"new-resource-base": "http://data.lblod.info/id/rollenBedienaar/"
|
||||
},
|
||||
"minister-conditions": {
|
||||
"class": "ere:VoorwaardenBedienaar",
|
||||
@@ -968,4 +964,4 @@
|
||||
"new-resource-base": "http://lblod.data.gift/concepts/"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
1
config/search-migrations/.gitignore
vendored
Normal file
1
config/search-migrations/.gitignore
vendored
Normal file
@@ -0,0 +1 @@
|
||||
.migration_history
|
||||
0
config/search-migrations/.gitkeep
Normal file
0
config/search-migrations/.gitkeep
Normal file
@@ -17,6 +17,8 @@ services:
|
||||
volumes:
|
||||
- ./config/dev-migrations:/data/migrations/dev/
|
||||
restart: "no"
|
||||
migrations-triggering-indexing:
|
||||
restart: "no"
|
||||
resource:
|
||||
restart: "no"
|
||||
cache:
|
||||
|
||||
@@ -59,6 +59,16 @@ services:
|
||||
- "logging=true"
|
||||
restart: always
|
||||
logging: *default-logging
|
||||
migrations-triggering-indexing:
|
||||
image: semtech/mu-migrations-service:0.8.0
|
||||
links:
|
||||
- db:database
|
||||
volumes:
|
||||
- ./config/migrations-triggering-indexing:/data/migrations
|
||||
labels:
|
||||
- "logging=true"
|
||||
restart: always
|
||||
logging: *default-logging
|
||||
resource:
|
||||
image: semtech/mu-cl-resources:1.21.1
|
||||
environment:
|
||||
@@ -157,7 +167,7 @@ services:
|
||||
restart: always
|
||||
logging: *default-logging
|
||||
frontend:
|
||||
image: lblod/frontend-organization-portal:1.14.0
|
||||
image: lblod/frontend-organization-portal:1.15.0
|
||||
volumes:
|
||||
- ./config/frontend/add-x-frame-options-header.conf:/config/add-x-frame-options.conf
|
||||
environment:
|
||||
@@ -566,3 +576,13 @@ services:
|
||||
image: lblod/error-report-service:0.1.0
|
||||
links:
|
||||
- db:database
|
||||
|
||||
|
||||
###################################################################################
|
||||
# MU SCRIPTS
|
||||
# #################################################################################
|
||||
project-scripts:
|
||||
image: semtech/mu-scripts:1.0.0
|
||||
volumes:
|
||||
- ./scripts/project:/app/scripts/
|
||||
restart: "no"
|
||||
|
||||
21
scripts/project/config.json
Normal file
21
scripts/project/config.json
Normal file
@@ -0,0 +1,21 @@
|
||||
{
|
||||
"version": "0.1",
|
||||
"scripts": [
|
||||
{
|
||||
"documentation": {
|
||||
"command": "mu-search-delta",
|
||||
"description": "produce delta for mu-search",
|
||||
"arguments": []
|
||||
},
|
||||
"environment": {
|
||||
"image": "node:16",
|
||||
"interactive": true,
|
||||
"script": "mu-search-delta/build.sh",
|
||||
"join_networks": true
|
||||
},
|
||||
"mounts": {
|
||||
"app": "/data/app/"
|
||||
}
|
||||
}
|
||||
]
|
||||
}
|
||||
1
scripts/project/mu-search-delta/.gitignore
vendored
Normal file
1
scripts/project/mu-search-delta/.gitignore
vendored
Normal file
@@ -0,0 +1 @@
|
||||
node_modules
|
||||
43
scripts/project/mu-search-delta/README.md
Normal file
43
scripts/project/mu-search-delta/README.md
Normal file
@@ -0,0 +1,43 @@
|
||||
#### Scripts mu-search-delta
|
||||
* make the script executable: `chmod a+x scripts/project/mu-search-delta/build.sh`
|
||||
* add your delta messages in json format in `config/search-migrations`, e.g:
|
||||
```js
|
||||
// config/search-migrations/2023/001-delete-bedinaeren.json
|
||||
[
|
||||
{
|
||||
"deletes": [
|
||||
{
|
||||
"subject": {
|
||||
"type": "uri",
|
||||
"value": "http://data.lblod.info/id/mandatarissen/807a3e07c95fe40962d64695069af946"
|
||||
},
|
||||
"predicate": {
|
||||
"type": "uri",
|
||||
"value": "http://data.vlaanderen.be/ns/mandaat#isBestuurlijkeAliasVan"
|
||||
},
|
||||
"object": {
|
||||
"type": "uri",
|
||||
"value": "http://data.lblod.info/id/personen/620523C451BFC225E4ECFA97"
|
||||
}
|
||||
},
|
||||
{
|
||||
"subject": {
|
||||
"type": "uri",
|
||||
"value": "http://data.lblod.info/id/mandatarissen/40ed3cb19f9fa33e47b39016780dce1d"
|
||||
},
|
||||
"predicate": {
|
||||
"type": "uri",
|
||||
"value": "http://data.vlaanderen.be/ns/mandaat#isBestuurlijkeAliasVan"
|
||||
},
|
||||
"object": {
|
||||
"type": "uri",
|
||||
"value": "http://data.lblod.info/id/personen/620523C451BFC225E4ECFA97"
|
||||
}
|
||||
}
|
||||
],
|
||||
"inserts": []
|
||||
}
|
||||
]
|
||||
```
|
||||
* make sure virtuoso, mu-auth, elasticsearch & mu search are running
|
||||
* run `mu script project-scripts mu-search-delta`
|
||||
4
scripts/project/mu-search-delta/build.sh
Executable file
4
scripts/project/mu-search-delta/build.sh
Executable file
@@ -0,0 +1,4 @@
|
||||
#!/bin/bash
|
||||
mkdir -p /data/app/config/search-migrations
|
||||
npm i
|
||||
node script.mjs
|
||||
144
scripts/project/mu-search-delta/package-lock.json
generated
Normal file
144
scripts/project/mu-search-delta/package-lock.json
generated
Normal file
@@ -0,0 +1,144 @@
|
||||
{
|
||||
"name": "mu-search-delta",
|
||||
"version": "1.0.0",
|
||||
"lockfileVersion": 2,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
"": {
|
||||
"name": "mu-search-delta",
|
||||
"version": "1.0.0",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"node-fetch": "^3.3.0"
|
||||
}
|
||||
},
|
||||
"node_modules/data-uri-to-buffer": {
|
||||
"version": "4.0.1",
|
||||
"resolved": "https://registry.npmjs.org/data-uri-to-buffer/-/data-uri-to-buffer-4.0.1.tgz",
|
||||
"integrity": "sha512-0R9ikRb668HB7QDxT1vkpuUBtqc53YyAwMwGeUFKRojY/NWKvdZ+9UYtRfGmhqNbRkTSVpMbmyhXipFFv2cb/A==",
|
||||
"engines": {
|
||||
"node": ">= 12"
|
||||
}
|
||||
},
|
||||
"node_modules/fetch-blob": {
|
||||
"version": "3.2.0",
|
||||
"resolved": "https://registry.npmjs.org/fetch-blob/-/fetch-blob-3.2.0.tgz",
|
||||
"integrity": "sha512-7yAQpD2UMJzLi1Dqv7qFYnPbaPx7ZfFK6PiIxQ4PfkGPyNyl2Ugx+a/umUonmKqjhM4DnfbMvdX6otXq83soQQ==",
|
||||
"funding": [
|
||||
{
|
||||
"type": "github",
|
||||
"url": "https://github.com/sponsors/jimmywarting"
|
||||
},
|
||||
{
|
||||
"type": "paypal",
|
||||
"url": "https://paypal.me/jimmywarting"
|
||||
}
|
||||
],
|
||||
"dependencies": {
|
||||
"node-domexception": "^1.0.0",
|
||||
"web-streams-polyfill": "^3.0.3"
|
||||
},
|
||||
"engines": {
|
||||
"node": "^12.20 || >= 14.13"
|
||||
}
|
||||
},
|
||||
"node_modules/formdata-polyfill": {
|
||||
"version": "4.0.10",
|
||||
"resolved": "https://registry.npmjs.org/formdata-polyfill/-/formdata-polyfill-4.0.10.tgz",
|
||||
"integrity": "sha512-buewHzMvYL29jdeQTVILecSaZKnt/RJWjoZCF5OW60Z67/GmSLBkOFM7qh1PI3zFNtJbaZL5eQu1vLfazOwj4g==",
|
||||
"dependencies": {
|
||||
"fetch-blob": "^3.1.2"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=12.20.0"
|
||||
}
|
||||
},
|
||||
"node_modules/node-domexception": {
|
||||
"version": "1.0.0",
|
||||
"resolved": "https://registry.npmjs.org/node-domexception/-/node-domexception-1.0.0.tgz",
|
||||
"integrity": "sha512-/jKZoMpw0F8GRwl4/eLROPA3cfcXtLApP0QzLmUT/HuPCZWyB7IY9ZrMeKw2O/nFIqPQB3PVM9aYm0F312AXDQ==",
|
||||
"funding": [
|
||||
{
|
||||
"type": "github",
|
||||
"url": "https://github.com/sponsors/jimmywarting"
|
||||
},
|
||||
{
|
||||
"type": "github",
|
||||
"url": "https://paypal.me/jimmywarting"
|
||||
}
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=10.5.0"
|
||||
}
|
||||
},
|
||||
"node_modules/node-fetch": {
|
||||
"version": "3.3.0",
|
||||
"resolved": "https://registry.npmjs.org/node-fetch/-/node-fetch-3.3.0.tgz",
|
||||
"integrity": "sha512-BKwRP/O0UvoMKp7GNdwPlObhYGB5DQqwhEDQlNKuoqwVYSxkSZCSbHjnFFmUEtwSKRPU4kNK8PbDYYitwaE3QA==",
|
||||
"dependencies": {
|
||||
"data-uri-to-buffer": "^4.0.0",
|
||||
"fetch-blob": "^3.1.4",
|
||||
"formdata-polyfill": "^4.0.10"
|
||||
},
|
||||
"engines": {
|
||||
"node": "^12.20.0 || ^14.13.1 || >=16.0.0"
|
||||
},
|
||||
"funding": {
|
||||
"type": "opencollective",
|
||||
"url": "https://opencollective.com/node-fetch"
|
||||
}
|
||||
},
|
||||
"node_modules/web-streams-polyfill": {
|
||||
"version": "3.2.1",
|
||||
"resolved": "https://registry.npmjs.org/web-streams-polyfill/-/web-streams-polyfill-3.2.1.tgz",
|
||||
"integrity": "sha512-e0MO3wdXWKrLbL0DgGnUV7WHVuw9OUvL4hjgnPkIeEvESk74gAITi5G606JtZPp39cd8HA9VQzCIvA49LpPN5Q==",
|
||||
"engines": {
|
||||
"node": ">= 8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"dependencies": {
|
||||
"data-uri-to-buffer": {
|
||||
"version": "4.0.1",
|
||||
"resolved": "https://registry.npmjs.org/data-uri-to-buffer/-/data-uri-to-buffer-4.0.1.tgz",
|
||||
"integrity": "sha512-0R9ikRb668HB7QDxT1vkpuUBtqc53YyAwMwGeUFKRojY/NWKvdZ+9UYtRfGmhqNbRkTSVpMbmyhXipFFv2cb/A=="
|
||||
},
|
||||
"fetch-blob": {
|
||||
"version": "3.2.0",
|
||||
"resolved": "https://registry.npmjs.org/fetch-blob/-/fetch-blob-3.2.0.tgz",
|
||||
"integrity": "sha512-7yAQpD2UMJzLi1Dqv7qFYnPbaPx7ZfFK6PiIxQ4PfkGPyNyl2Ugx+a/umUonmKqjhM4DnfbMvdX6otXq83soQQ==",
|
||||
"requires": {
|
||||
"node-domexception": "^1.0.0",
|
||||
"web-streams-polyfill": "^3.0.3"
|
||||
}
|
||||
},
|
||||
"formdata-polyfill": {
|
||||
"version": "4.0.10",
|
||||
"resolved": "https://registry.npmjs.org/formdata-polyfill/-/formdata-polyfill-4.0.10.tgz",
|
||||
"integrity": "sha512-buewHzMvYL29jdeQTVILecSaZKnt/RJWjoZCF5OW60Z67/GmSLBkOFM7qh1PI3zFNtJbaZL5eQu1vLfazOwj4g==",
|
||||
"requires": {
|
||||
"fetch-blob": "^3.1.2"
|
||||
}
|
||||
},
|
||||
"node-domexception": {
|
||||
"version": "1.0.0",
|
||||
"resolved": "https://registry.npmjs.org/node-domexception/-/node-domexception-1.0.0.tgz",
|
||||
"integrity": "sha512-/jKZoMpw0F8GRwl4/eLROPA3cfcXtLApP0QzLmUT/HuPCZWyB7IY9ZrMeKw2O/nFIqPQB3PVM9aYm0F312AXDQ=="
|
||||
},
|
||||
"node-fetch": {
|
||||
"version": "3.3.0",
|
||||
"resolved": "https://registry.npmjs.org/node-fetch/-/node-fetch-3.3.0.tgz",
|
||||
"integrity": "sha512-BKwRP/O0UvoMKp7GNdwPlObhYGB5DQqwhEDQlNKuoqwVYSxkSZCSbHjnFFmUEtwSKRPU4kNK8PbDYYitwaE3QA==",
|
||||
"requires": {
|
||||
"data-uri-to-buffer": "^4.0.0",
|
||||
"fetch-blob": "^3.1.4",
|
||||
"formdata-polyfill": "^4.0.10"
|
||||
}
|
||||
},
|
||||
"web-streams-polyfill": {
|
||||
"version": "3.2.1",
|
||||
"resolved": "https://registry.npmjs.org/web-streams-polyfill/-/web-streams-polyfill-3.2.1.tgz",
|
||||
"integrity": "sha512-e0MO3wdXWKrLbL0DgGnUV7WHVuw9OUvL4hjgnPkIeEvESk74gAITi5G606JtZPp39cd8HA9VQzCIvA49LpPN5Q=="
|
||||
}
|
||||
}
|
||||
}
|
||||
14
scripts/project/mu-search-delta/package.json
Normal file
14
scripts/project/mu-search-delta/package.json
Normal file
@@ -0,0 +1,14 @@
|
||||
{
|
||||
"name": "mu-search-delta",
|
||||
"version": "1.0.0",
|
||||
"description": "",
|
||||
"main": "script.mjs",
|
||||
"scripts": {
|
||||
"test": "echo \"Error: no test specified\" && exit 1"
|
||||
},
|
||||
"author": "Nordine Bittich",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"node-fetch": "^3.3.0"
|
||||
}
|
||||
}
|
||||
82
scripts/project/mu-search-delta/script.mjs
Normal file
82
scripts/project/mu-search-delta/script.mjs
Normal file
@@ -0,0 +1,82 @@
|
||||
import fs from 'fs';
|
||||
import fetch from 'node-fetch';
|
||||
import path from 'path';
|
||||
|
||||
const CONFIG_PATH = process.env.SEARCH_CONFIG_PATH || '/data/app/config/search-migrations';
|
||||
const HISTORY_PATH = process.env.HISTORY_PATH || CONFIG_PATH + '/.migration_history';
|
||||
const MU_SEARCH_DELTA_URL = process.env.MU_SEARCH_DELTA_URL || 'http://search/update';
|
||||
const SEARCH_MIGRATIONS_DIR = process.env.SEARCH_MIGRATIONS_DIR || CONFIG_PATH;
|
||||
const CONTENT_TYPE_JSON_API = { 'Content-Type': 'application/vnd.api+json' };
|
||||
|
||||
function read(fd, len) {
|
||||
const buff = Buffer.alloc(len),
|
||||
pos = 0, offset = 0;
|
||||
fs.readSync(fd, buff, offset, len, pos);
|
||||
return buff.toString();
|
||||
}
|
||||
|
||||
function readDirRecursive(dir, filterHistory = [], filterExtensions = ["json"]) {
|
||||
const files = fs.readdirSync(dir);
|
||||
|
||||
const resultFiles = [];
|
||||
|
||||
for (const file of files) {
|
||||
const filePath = path.join(dir, file);
|
||||
const stat = fs.statSync(filePath);
|
||||
if (stat.isDirectory()) {
|
||||
resultFiles.push(...(readDirRecursive(`${dir}/${file}`, filterHistory)));
|
||||
} else if (filterExtensions.some((ext) => filePath.endsWith(ext)) && !filterHistory.includes(filePath)) {
|
||||
resultFiles.push({
|
||||
time: stat.atimeMs,
|
||||
file: filePath,
|
||||
});
|
||||
} else {
|
||||
console.log(`filter file ${filePath}`);
|
||||
}
|
||||
}
|
||||
|
||||
return resultFiles.sort((a, b) => a.time - b.time);
|
||||
}
|
||||
|
||||
// main
|
||||
|
||||
async function main() {
|
||||
const historyFileDescriptor = fs.openSync(HISTORY_PATH, 'a+');
|
||||
const historyFileLen = fs.statSync(HISTORY_PATH).size;
|
||||
|
||||
const history = read(historyFileDescriptor, historyFileLen)
|
||||
.split(/\r?\n/)
|
||||
.map((f) => f.trim())
|
||||
.filter((f) => f?.length);
|
||||
|
||||
const fileNames = readDirRecursive(SEARCH_MIGRATIONS_DIR, history);
|
||||
console.log(`processing ${fileNames.length} migration(s)`);
|
||||
for (const { file } of fileNames) {
|
||||
console.log(`Current file: ${file}`);
|
||||
const payload = fs.readFileSync(file);
|
||||
|
||||
try {
|
||||
JSON.parse(payload);
|
||||
} catch (e) {
|
||||
console.error("Verify your migration. Exit...");
|
||||
process.exit(1);
|
||||
}
|
||||
|
||||
const r = await fetch(MU_SEARCH_DELTA_URL, {
|
||||
method: "post",
|
||||
body: payload,
|
||||
headers: CONTENT_TYPE_JSON_API,
|
||||
});
|
||||
console.log(`"[Delta]=> Status: ${r.status} `);
|
||||
if (r.status == 200) {
|
||||
const responseBody = await r.json();
|
||||
console.log(`response ${JSON.stringify(responseBody)}`);
|
||||
fs.appendFileSync(HISTORY_PATH, file + '\n');
|
||||
} else {
|
||||
console.error("an error occurred. check your migration, make sure mu search is running.");
|
||||
process.exit(1);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
main().then(() => console.log("Done."));
|
||||
Reference in New Issue
Block a user