domain range pass

Author: marqh

lib/bald/__init__.py

@@ -12,28 +12,19 @@ def __init__(self):
         self.cache = {}
 
     def __getitem__(self, item):
-        uri = item
+
+        if not item.startswith('http://') or item.startswith('https://'):
+            raise ValueError('{} is not a HTTP URI.'.format(item))
         if item not in self.cache:
-            if not uri.startswith('http://') or uri.startswith('https://'):
-                raise ValueError('{} is not a HTTP URI.'.format(item))
-        if item in self.cache:
-            result = self.cache[item]
-        else:
-            r = requests.get(uri)
-            if r.status_code == 200:
-                headers={'Accept':'text/turtle'}
-                rraw = requests.get(uri, headers=headers)
-                self.cache[item] = rraw.status_code
-            else:
-                self.cache[item] = r.status_code
-
-            result = self.cache[item]
-        return result
+            headers={'Accept':'text/turtle'}
+            self.cache[item] = requests.get(item, headers=headers)
+
+        return self.cache[item]
 
 
     def check_uri(self, uri):
         result = False
-        if self[uri] == 200:
+        if self[uri].status_code == 200:
             result = True
         return result
 
@@ -95,7 +86,7 @@ def validate_hdf5(afilepath):
         valid = True
         cache = {}
         root_container = Subject(fhandle.attrs)
-        root_val = ContainerValidation(subject=root_container)
+        root_val = ContainerValidation(subject=root_container, fhandle=fhandle)
         if not root_val.is_valid():
             valid = False
         # iterate through the datasets
@@ -105,7 +96,7 @@ def validate_hdf5(afilepath):
             sattrs = dict(fhandle.attrs).copy()
             sattrs.update(dataset.attrs)
             dset = Subject(sattrs)
-            dset_val = DatasetValidation(name, dataset, fhandle, subject=dset)
+            dset_val = DatasetValidation(name, dataset, fhandle=fhandle, subject=dset)
             if not dset_val.is_valid():
                 valid = False
 

lib/bald/validation.py

@@ -1,5 +1,6 @@
 
 import numpy as np
+import rdflib
 
 import bald
 
@@ -40,8 +41,9 @@ def exceptions(self):
 
 class SubjectValidation(Validation):
 
-    def __init__(self, subject, httpcache=None): 
+    def __init__(self, subject, fhandle, httpcache=None): 
         self.subject = subject
+        self.fhandle = fhandle
         if isinstance(httpcache, bald.HttpStatusCache):
             self.cache = httpcache
         else:
@@ -55,6 +57,10 @@ def exceptions(self):
         exceptions = []
         exceptions = self.check_attr_uris(exceptions)
         exceptions = self.check_attr_domain_range(exceptions)
+        exceptions = self._extra_exceptions(exceptions)
+        return exceptions
+
+    def _extra_exceptions(self, exceptions):
         return exceptions
 
     def check_attr_uris(self, exceptions):
@@ -77,6 +83,39 @@ def _check_uri(uri, exceptions):
         return exceptions
 
     def check_attr_domain_range(self, exceptions):
+        for attr, value in self.subject.attrs.iteritems():
+            uri = self.subject.unpack_uri(attr)
+            if self.cache.check_uri(uri):
+                #thus we have a payload
+                # go rdf
+                g = rdflib.Graph()
+                g.parse(data=self.cache[uri].text, format="n3")
+                query = ('SELECT ?s \n'
+                         '(GROUP_CONCAT(?domain; SEPARATOR=" | ") AS ?domains) \n'
+                         '(GROUP_CONCAT(?type; SEPARATOR=" | ") AS ?types) \n'
+                         'WHERE {{ \n'
+                         '?s a ?type . \n'
+                         'OPTIONAL{{ ?s rdfs:domain ?domain . }} \n'
+                         'FILTER(?s = <{uria}> || ?s = <{urib}>) \n'
+                         '}} \n'
+                         'GROUP BY ?s \n'.format(uria=uri, urib= uri.rstrip('/')))
+                qres = list(g.query(query))
+                if len(qres) != 1:
+                    raise ValueError('{} does not define one and only one \n'
+                                     'rdfs:domain'.format(uri))
+                qres, = qres
+                # implement recursive inheritance check
+                # we need to check if the value that the attr points to
+                # has an rdf:type which is the same as the one required by
+                # the object property constraint
+                # The value may be a URI or it may be a reference to another
+                # subject within the file.
+                # therefore subjects in the file have to be typed?!?
+
+                # import pdb; pdb.set_trace()
+                # if qres.domains != rdflib.term.URIRef(value):
+                #     msg = ('The attribute {} references ')
+                #     exceptions.appen(ValueError(msg))
         return exceptions
 
 
@@ -85,24 +124,19 @@ class ContainerValidation(SubjectValidation):
     def __init__(self, **kwargs):
         super(ContainerValidation, self).__init__(**kwargs)
 
-    def exceptions(self):
-        exceptions = []
-        exceptions = self.check_attr_uris(exceptions)
-        return exceptions
+
+        
 
 class DatasetValidation(SubjectValidation):
 
 
-    def __init__(self, name, dataset, fhandle, **kwargs):
+    def __init__(self, name, dataset, **kwargs):
 
         self.dataset = dataset
         self.name = name
-        self.fhandle = fhandle
         super(DatasetValidation, self).__init__(**kwargs)
 
-    def exceptions(self):
-        exceptions = []
-        exceptions = self.check_attr_uris(exceptions)
+    def _extra_exceptions(self, exceptions):
         exceptions = self.check_array_references(exceptions)
         return exceptions