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,18 @@ 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):
+        verified_links = getattr(self.basket.focus.osf_item, 'verified_links', None)
+
+        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',
+                    })
+                else:
+                    logger.warning('skipping non-URL verified link "%s"', link)

website/identifiers/tasks.py

@@ -17,3 +17,34 @@ 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):
+    sentry.log_message('Updating DOI with verified links for guid',
+                       extra_data={'guid': target_guid, 'verified_links': verified_links},
+                       level=logging.INFO)
+
+    Guid = apps.get_model('osf.Guid')
+    target_object = Guid.load(target_guid).referent
+
+    if target_object.get_identifier('doi'):
+        if verified_links:
+            target_object.verified_links = verified_links
+
+        target_object.request_identifier_update(category='doi')
+
+        if verified_links and hasattr(target_object, 'verified_links'):
+            delattr(target_object, 'verified_links')
+
+        sentry.log_message('DOI metadata with verified links updated for guid',
+                          extra_data={'guid': target_guid},
+                          level=logging.INFO)
+    else:
+        sentry.log_message('No DOI found for guid, skipping update',
+                          extra_data={'guid': target_guid},
+                          level=logging.INFO)
+
+@queued_task
+@celery_app.task(ignore_results=True)
+def update_doi_metadata_with_verified_links(target_guid, verified_links=None):
+    task__update_doi_metadata_with_verified_links(target_guid, verified_links)