helpers.js

import { sparqlEscapeDateTime, sparqlEscapeString, sparqlEscapeUri } from "mu";
import { querySudo as query } from "@lblod/mu-auth-sudo";
import { MASTER_GRAPH, PUBLIC_GRAPH, MIN_NB_OF_AGENDAITEMS } from "./config";

async function fetchMostRecentAgendas() {
  const since = new Date();
  since.setYear(since.getFullYear() - 1); // 1 year ago
  const queryResult = await query(`
    PREFIX besluitvorming: <https://data.vlaanderen.be/ns/besluitvorming#>
    PREFIX dct: <http://purl.org/dc/terms/>
    PREFIX mu: <http://mu.semte.ch/vocabularies/core/>
    SELECT DISTINCT ?agendaId WHERE {
      GRAPH <${MASTER_GRAPH}> {
        ?s a besluitvorming:Agenda ;
           mu:uuid ?agendaId ;
           dct:modified ?modified .
      }
      FILTER (?modified > ${sparqlEscapeDateTime(since)})
    } ORDER BY DESC(?modified)
  `);

  return queryResult.results.bindings.map((b) => b["agendaId"].value);
}

async function fetchLargeAgendas() {
  const queryResult = await query(`
    PREFIX besluitvorming: <https://data.vlaanderen.be/ns/besluitvorming#>
    PREFIX dct: <http://purl.org/dc/terms/>
    PREFIX mu: <http://mu.semte.ch/vocabularies/core/>
    SELECT ?agendaId ?count WHERE
    {
      {
        SELECT DISTINCT ?agendaId (COUNT(?agendaitem) as ?count) {
          GRAPH <${MASTER_GRAPH}> {
            ?agenda a besluitvorming:Agenda ;
              mu:uuid ?agendaId ;
              dct:hasPart ?agendaitem .
          }
        }
        GROUP BY ?agendaId
      }
      FILTER (?count > ${MIN_NB_OF_AGENDAITEMS})
    } ORDER BY DESC(?count)`);
  return queryResult.results.bindings.map((b) => b["agendaId"].value);
}

async function fetchAgendaitemsFromAgenda(agendaId) {
  const queryResult = await query(`
    PREFIX besluitvorming: <https://data.vlaanderen.be/ns/besluitvorming#>
    PREFIX dct: <http://purl.org/dc/terms/>
    PREFIX mu: <http://mu.semte.ch/vocabularies/core/>
    SELECT DISTINCT ?agendaitemId {
      GRAPH <${MASTER_GRAPH}> {
        ?agenda a besluitvorming:Agenda ;
          mu:uuid ${sparqlEscapeString(agendaId)};
          dct:hasPart ?agendaitem .
        ?agendaitem mu:uuid ?agendaitemId .
      }
    }
    `);
  return queryResult.results.bindings.map((binding) => {
    return binding.agendaitemId.value;
  });
}

async function countConceptsForConceptScheme(conceptSchemeUri) {
  const queryResult = await query(`
  PREFIX skos: <http://www.w3.org/2004/02/skos/core#>

  SELECT (COUNT(DISTINCT ?concept) AS ?count)
  WHERE {
    GRAPH <${PUBLIC_GRAPH}> {
      ?concept skos:inScheme ${sparqlEscapeUri(conceptSchemeUri)} .
    }
  }`);
  if (queryResult.results.bindings.length) {
    return queryResult.results.bindings[0].count.value;
  }
}

function chunk(array, size) {
  let chunked = [];
  for (let i = 0; i < array.length; i += size)
    chunked.push(array.slice(i, i + size));
  return chunked;
};

export {
  fetchMostRecentAgendas,
  fetchLargeAgendas,
  fetchAgendaitemsFromAgenda,
  countConceptsForConceptScheme,
  chunk,
};