mapping-webapi.rml.ttl

# 
# RML mapping rules for https://datapiloten.be/bluebike/availabilities.geojson
# (c) Dylan Van Assche (2021)
# IDLab - Ghent University - imec
#
@prefix rml: <http://semweb.mmlab.be/ns/rml#> .
@prefix rr: <http://www.w3.org/ns/r2rml#> .
@prefix rmlt: <http://semweb.mmlab.be/ns/rml-target#> .
@prefix rdfs: <https://www.w3.org/2000/01/rdf-schema#> .
@prefix comp: <http://semweb.mmlab.be/ns/rml-compression#> .
@prefix formats: <http://www.w3.org/ns/formats/> .
@prefix ex: <http://example.com/> .
@prefix ql: <http://semweb.mmlab.be/ns/ql#> .
@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> .
@prefix td: <https://www.w3.org/2019/wot/td#> .
@prefix htv: <http://www.w3.org/2011/http#> .
@prefix hctl: <https://www.w3.org/2019/wot/hypermedia#> .
@prefix schema: <http://schema.org/> .
@prefix gtfs: <http://vocab.gtfs.org/terms#> .
@prefix geo: <http://www.w3.org/2003/01/geo/wgs84_pos#> .
@prefix xsd: <http://www.w3.org/2001/XMLSchema#> .
@prefix fnml: <http://semweb.mmlab.be/ns/fnml#> .
@prefix fno: <https://w3id.org/function/ontology#> .
@prefix grel: <http://users.ugent.be/~bjdmeest/function/grel.ttl#> .
@prefix dcterms: <http://purl.org/dc/terms/> .
@prefix tree: <https://w3id.org/tree#> .
@prefix ldes: <https://w3id.org/ldes#> .
@base <http://example.org/rules/> .

# Github will serve GZip compressed files if available.
# However, you have to provide the regular file as well.
<#TargetDump> a rmlt:LogicalTarget;
  rmlt:target [ a void:Dataset;
    void:dataDump <file://./history/bluebike-webapi.ttl>;
  ];
  rmlt:serialization formats:Turtle;
.

<#TargetDumpGzip> a rmlt:LogicalTarget;
  rmlt:target [ a void:Dataset;
    void:dataDump <file://./history/bluebike-webapi.ttl.gz>;
  ];
  rmlt:serialization formats:Turtle;
  rmlt:compression comp:gzip;
.

<#WoTWebAPISource> a td:PropertyAffordance;
  td:hasForm [
    # URL and content type
    hctl:hasTarget "https://datapiloten.be/bluebike/availabilities.geojson";
    hctl:forContentType "application/json";
    # Read only
    hctl:hasOperationType td:readproperty;
    # Set HTTP method and headers
    htv:methodName "GET";
    htv:headers ([
      htv:fieldName "User-Agent";
      htv:fieldValue "IDLab - Ghent University - imec (RMLMapper)";
    ]);
  ];
.

<#WoTWebAPI> a td:Thing;
  td:hasPropertyAffordance <#WoTWebResource>;
.

# TREE view
<#ViewTriplesMap> a rr:TriplesMap;
  rml:logicalSource [
    rml:source "ldes.json";
    rml:referenceFormulation ql:JSONPath;
    rml:iterator "$";
  ];

  rr:subjectMap[
    rml:reference "ldes.iri";
    rr:termType rr:IRI;
    rml:logicalTarget <#TargetDump>;
    rml:logicalTarget <#TargetDumpGzip>;
  ];

  # LDES retention policy
  rr:predicateObjectMap [
    rr:predicate ldes:retentionPolicy;
    rr:objectMap [
       fnml:functionValue [
           rr:predicateObjectMap [
               rr:predicate fno:executes ;
               rr:objectMap [ rr:constant grel:array_join ]
           ];
           rr:predicateObjectMap [
               rr:predicate grel:p_array_a ;
               rr:objectMap [ rml:reference "ldes.iri" ]
           ];
           rr:predicateObjectMap [
               rr:predicate grel:p_array_a ;
               rr:objectMap [ rr:constant "#retention"; ]
           ];
       ];
       rr:termType rr:IRI;
    ];
  ];
.

# LDES RetentionPolicy
<#RetentionPolicyTriplesMap> a rr:TriplesMap;
  rml:logicalSource [
    rml:source "ldes.json";
    rml:referenceFormulation ql:JSONPath;
    rml:iterator "$";
  ];

  rr:subjectMap[
    fnml:functionValue [
       rr:predicateObjectMap [
           rr:predicate fno:executes ;
           rr:objectMap [ rr:constant grel:array_join ]
       ];
       rr:predicateObjectMap [
           rr:predicate grel:p_array_a ;
           rr:objectMap [ rml:reference "ldes.iri" ]
       ];
       rr:predicateObjectMap [
           rr:predicate grel:p_array_a ;
           rr:objectMap [ rr:constant "#retention"; ]
       ];
    ];
    rr:termType rr:IRI;
    rml:logicalTarget <#TargetDump>;
  ];

  # rdf:type
  rr:predicateObjectMap [
    rr:predicate rdf:type;
    rr:objectMap [ rml:reference "ldes.retentionPolicy.type"; rr:termType rr:IRI; ];
  ];

  rr:predicateObjectMap [
    rr:predicate ldes:amount;
    rr:objectMap [ rml:reference "ldes.retentionPolicy.amount"; rr:datatype xsd:integer; ];
  ];

  rr:predicateObjectMap [
    rr:predicate ldes:timestampPath;
    rr:object dcterms:created;
  ];

  rr:predicateObjectMap [
    rr:predicate ldes:versionOfPath;
    rr:object dcterms:isVersionOf;
  ];
.

<#TreeTriplesMap> a rr:TriplesMap;
  rml:logicalSource [ 
    rml:source "ldes.json";
    rml:referenceFormulation ql:JSONPath;
    rml:iterator "$"
  ];

  # LDES stream
  rr:subjectMap[
    fnml:functionValue [
       rr:predicateObjectMap [
           rr:predicate fno:executes ;
           rr:objectMap [ rr:constant grel:array_join ]
       ];
       rr:predicateObjectMap [
           rr:predicate grel:p_array_a ;
           rr:objectMap [ rml:reference "ldes.iri" ]
       ];
       rr:predicateObjectMap [
           rr:predicate grel:p_array_a ;
           rr:objectMap [ rr:constant "#eventstream"; ]
       ];
    ];
    rr:termType rr:IRI;
    rr:class ldes:EventStream;
    rml:logicalTarget <#TargetDump>;
  ];

  # TREE member
  rr:predicateObjectMap [
    rr:predicate tree:member;
    rr:objectMap [ a rr:ObjectMap;
      rr:parentTriplesMap <#StationsTriplesMap>;
      rr:termType rr:IRI;
    ];
  ];

  # TREE view
  rr:predicateObjectMap [
    rr:predicate tree:view;
    rr:objectMap [ a rr:ObjectMap;
      rml:reference "ldes.iri";
      rr:termType rr:IRI;
    ];
  ];
.

<#StationsTriplesMap> a rr:TriplesMap;
  rml:logicalSource [ a rml:LogicalSource;
    rml:source <#WoTWebAPISource>;
    rml:referenceFormulation ql:JSONPath;
    rml:iterator "$.features.[*]";
  ];
  # Unique IRI generation: $stationId#$generatedAtTime
  rr:subjectMap [ 
    fnml:functionValue [
        rr:predicateObjectMap [
            rr:predicate fno:executes ;
            rr:objectMap [ rr:constant grel:array_join ]
        ];
        rr:predicateObjectMap [
            rr:predicate grel:p_array_a ;
            rr:objectMap [ rml:reference "properties.@id" ]
        ];
        rr:predicateObjectMap [
            rr:predicate grel:p_array_a ;
            rr:objectMap [ 
                fnml:functionValue [
                    rr:predicateObjectMap [
                        rr:predicate fno:executes ;
                        rr:objectMap [ rr:constant grel:array_join ]
                    ];
            
                    rr:predicateObjectMap [
                        rr:predicate grel:p_array_a ;
                        rr:objectMap [ rr:constant "#" ]
                    ];

                    rr:predicateObjectMap [
                        rr:predicate grel:p_array_a ;
                        rr:objectMap [ rml:reference "generatedAtTime" ]
                    ];
                ];
            ];
        ];
    ];
    rr:termType rr:IRI;
    rml:logicalTarget <#TargetDump>;
  ];

  # rdf:type
  rr:predicateObjectMap [ 
    rr:predicate rdf:type ; 
    rr:objectMap [ rml:reference "properties.@type"; rr:termType rr:IRI; ]
  ];

  # BlueBike station: name
  rr:predicateObjectMap [ 
    rr:predicate rdfs:label ; 
    rr:objectMap [ rml:reference "properties.name"; rr:datatype xsd:string; ]
  ];

  # BlueBike station: available bicycles
  rr:predicateObjectMap [ 
    rr:predicate ex:bikesAvailable ; 
    rr:objectMap [ rml:reference "properties.bikes_available"; rr:datatype xsd:integer; ]
  ];

  # BlueBike station: maximum capacity
  rr:predicateObjectMap [ 
    rr:predicate ex:capacity ; 
    rr:objectMap [ rml:reference "properties.capacity"; rr:datatype xsd:integer; ]
  ];

  # BlueBike station: available docks
  rr:predicateObjectMap [ 
    rr:predicate ex:docksAvailable ; 
    rr:objectMap [ rml:reference "properties.docks_available"; rr:datatype xsd:integer; ]
  ];

  # Nearby NMBS station
  rr:predicateObjectMap [ 
    rr:predicate ex:nearby ; 
    rr:objectMap [ rml:reference "properties.nearby"; rr:termType rr:IRI; ]
  ];

  # Geo location
  rr:predicateObjectMap [ 
    rr:predicate geo:latitude ; 
    rr:objectMap [ rml:reference "properties.latitude"; rr:datatype xsd:float; ]
  ];

  rr:predicateObjectMap [ 
    rr:predicate geo:longitude ; 
    rr:objectMap [ rml:reference "properties.longitude"; rr:datatype xsd:float; ]
  ];

  # Versioning
  rr:predicateObjectMap [
    rr:predicate dcterms:created ;
    rr:objectMap [ rml:reference "generatedAtTime"; rr:dataType xsd:dateTime; ]
  ];

  rr:predicateObjectMap [
    rr:predicate dcterms:isVersionOf ;
    rr:objectMap [ rml:reference "properties.@id"; rr:termType rr:IRI; ]
  ];
.