Add new task to update node metadata with verified_links

Author: Vlad0n20

osf/metadata/serializers/datacite/datacite_tree_walker.py

@@ -113,6 +113,7 @@ def walk(self, doi_override=None):
         self._visit_rights(self.root)
         self._visit_descriptions(self.root, self.basket.focus.iri)
         self._visit_funding_references(self.root)
+        self._visit_verified_links(self.root)
         self._visit_related(self.root)
 
     def _visit_identifier(self, parent_el, *, doi_override=None):
@@ -432,3 +433,20 @@ def _get_resource_type_general(self, focus_iri):
             if isinstance(type_term, rdflib.URIRef) and type_term.startswith(DATACITE):
                 return without_namespace(type_term, DATACITE)
         return 'Text'
+
+    def _visit_verified_links(self, parent_el):
+        osf_item = self.basket.focus.dbmodel
+        verified_links = getattr(osf_item, 'verified_links', None)
+        resource_type = getattr(osf_item, 'link_resource_type', 'Text')
+
+        if verified_links and isinstance(verified_links, list):
+            related_identifiers_el = self.visit(parent_el, 'relatedIdentifiers', is_list=True)
+            for link in verified_links:
+                if link and isinstance(link, str) and smells_like_iri(link):
+                    self.visit(related_identifiers_el, 'relatedIdentifier', text=link, attrib={
+                        'relatedIdentifierType': 'URL',
+                        'relationType': 'IsReferencedBy',
+                        'resourceTypeGeneral': resource_type
+                    })
+                else:
+                    logger.warning('skipping non-URL verified link "%s"', link)

website/identifiers/tasks.py

@@ -17,3 +17,32 @@ def task__update_doi_metadata_on_change(self, target_guid):
 @celery_app.task(ignore_results=True)
 def update_doi_metadata_on_change(target_guid):
     task__update_doi_metadata_on_change(target_guid)
+
+@celery_app.task(bind=True, max_retries=5, acks_late=True)
+def task__update_doi_metadata_with_verified_links(self, target_guid, verified_links=None, link_resource_type='Text'):
+    sentry.log_message('Updating DOI with verified links for guid',
+                      extra_data={'guid': target_guid, 'verified_links': verified_links, 'link_resource_type': link_resource_type},
+                      level=logging.INFO)
+
+    Guid = apps.get_model('osf.Guid')
+    target_object = Guid.load(target_guid).referent
+    try:
+        if verified_links is not None:
+            target_object.verified_links = verified_links
+            target_object.link_resource_type = link_resource_type
+
+        target_object.request_identifier_update(category='doi')
+
+        sentry.log_message('DOI metadata with verified links updated for guid',
+                         extra_data={'guid': target_guid},
+                         level=logging.INFO)
+    except Exception as exc:
+        sentry.log_message('Failed to update DOI metadata with verified links',
+                         extra_data={'guid': target_guid, 'error': str(exc)},
+                         level=logging.ERROR)
+        raise self.retry(exc=exc)
+
+@queued_task
+@celery_app.task(ignore_results=True)
+def update_doi_metadata_with_verified_links(target_guid, verified_links=None, resource_type='Text'):
+    task__update_doi_metadata_with_verified_links.apply_async((target_guid, verified_links, resource_type))