diff --git a/migrate/systemdata/schemas.yml b/migrate/systemdata/schemas.yml index c90e65c..a2b5b14 100644 --- a/migrate/systemdata/schemas.yml +++ b/migrate/systemdata/schemas.yml @@ -14,6 +14,10 @@ SchemaOrg.Dataset: type: metadata uri: https://odp.saeon.ac.za/schema/metadata/schema.org/dataset +RIS.Citation: + type: metadata + uri: https://odp.saeon.ac.za/schema/metadata/ris/citation + Tag.Collection.Infrastructure: type: tag uri: https://odp.saeon.ac.za/schema/tag/collection/infrastructure diff --git a/odp/catalog/saeon.py b/odp/catalog/saeon.py index f49dc0a..80ee2f6 100644 --- a/odp/catalog/saeon.py +++ b/odp/catalog/saeon.py @@ -29,8 +29,7 @@ def create_published_record(self, record_model: RecordModel) -> PublishedRecordM timestamp=record_model.timestamp, ) - @staticmethod - def _create_published_metadata(record_model: RecordModel) -> list[PublishedMetadataModel]: + def _create_published_metadata(self, record_model: RecordModel) -> list[PublishedMetadataModel]: """Create the published metadata outputs for a record.""" published_metadata = [ PublishedMetadataModel( @@ -40,7 +39,10 @@ def _create_published_metadata(record_model: RecordModel) -> list[PublishedMetad ) ] - if record_model.schema_id == ODPMetadataSchema.SAEON_ISO19115: + if record_model.schema_id == ODPMetadataSchema.SAEON_DATACITE4: + datacite_metadata = record_model.metadata + + elif record_model.schema_id == ODPMetadataSchema.SAEON_ISO19115: iso19115_schemaobj = Session.get(Schema, (ODPMetadataSchema.SAEON_ISO19115, SchemaType.metadata)) datacite_schemaobj = Session.get(Schema, (ODPMetadataSchema.SAEON_DATACITE4, SchemaType.metadata)) @@ -61,8 +63,24 @@ def _create_published_metadata(record_model: RecordModel) -> list[PublishedMetad ) ] + # add an RIS citation record + ris_schema = Session.get(Schema, (ODPMetadataSchema.RIS_CITATION, SchemaType.metadata)) + published_metadata += [ + PublishedMetadataModel( + schema_id=ris_schema.id, + schema_uri=ris_schema.uri, + metadata={'ris': self._create_ris_citation(datacite_metadata)} + ) + ] + return published_metadata + @staticmethod + def _create_ris_citation(datacite_metadata: dict) -> str: + """Create an RIS citation from the DataCite metadata for a record.""" + return ''' + ''' + @staticmethod def _create_published_tags(record_model: RecordModel) -> list[PublishedTagInstanceModel]: """Create the published tags for a record."""