From e70e0016b9278617ee85a79ada6a688d64625697 Mon Sep 17 00:00:00 2001
From: Sarah Hilse <sarah.hilse@liip.ch>
Date: Thu, 21 Sep 2023 15:13:47 +0200
Subject: [PATCH] chore: add vocabulary check uri by name

---
 ckanext/dcatapchharvest/profiles.py | 34 +++++++++++++++++++++++------
 1 file changed, 27 insertions(+), 7 deletions(-)

diff --git a/ckanext/dcatapchharvest/profiles.py b/ckanext/dcatapchharvest/profiles.py
index 0fb68d4..43321f7 100644
--- a/ckanext/dcatapchharvest/profiles.py
+++ b/ckanext/dcatapchharvest/profiles.py
@@ -804,9 +804,19 @@ def graph_from_dataset(self, dataset_dict, dataset_ref):  # noqa
                     g.add((rights_ref, RDF.type, DCT.RightsStatement))
                     g.add((distribution, DCT.rights, rights_ref))
                 if rights_uri is None:
-                    resource_rights_ref = URIRef(resource_dict.get('rights'))
-                    g.add((resource_rights_ref, RDF.type, DCT.RightsStatement))
-                    g.add((distribution, DCT.rights, resource_rights_ref))
+                    rights_name = dh.get_license_name_by_uri(
+                        resource_dict.get('rights')
+                        )
+                    if rights_name is not None:
+                        resource_rights_ref = URIRef(
+                            resource_dict.get('rights')
+                            )
+                        g.add((
+                            resource_rights_ref,
+                            RDF.type,
+                            DCT.RightsStatement)
+                            )
+                        g.add((distribution, DCT.rights, resource_rights_ref))
 
             if resource_dict.get('license'):
                 license_uri = dh.get_license_uri_by_name(
@@ -817,11 +827,21 @@ def graph_from_dataset(self, dataset_dict, dataset_ref):  # noqa
                     g.add((license_ref, RDF.type, DCT.LicenseDocument))
                     g.add((distribution, DCT.license, license_ref))
                 if license_uri is None:
-                    resource_license_ref = URIRef(resource_dict.get('license'))
-                    g.add(
-                        (resource_license_ref, RDF.type, DCT.LicenseDocument)
+                    license_name = dh.get_license_name_by_uri(
+                        resource_dict.get('license')
                         )
-                    g.add((distribution, DCT.license, resource_license_ref))
+                    if license_name is not None:
+                        resource_license_ref = URIRef(
+                            resource_dict.get('license')
+                            )
+                        g.add((
+                            resource_license_ref,
+                            RDF.type,
+                            DCT.LicenseDocument)
+                            )
+                        g.add(
+                            (distribution, DCT.license, resource_license_ref)
+                            )
 
             self._add_triples_from_dict(resource_dict, distribution, items)
             self._add_multilang_value(distribution, DCT.title, 'display_name', resource_dict)  # noqa