# -*- coding: utf-8 -*-
#
# This file is part of INSPIRE.
# Copyright (C) 2014-2018 CERN.
#
# INSPIRE is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# INSPIRE is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with INSPIRE. If not, see <http://www.gnu.org/licenses/>.
#
# In applying this license, CERN does not waive the privileges and immunities
# granted to it by virtue of its status as an Intergovernmental Organization
# or submit itself to any jurisdiction.
from __future__ import absolute_import, division, print_function
from marshmallow import Schema, fields, pre_dump, missing, post_load
from inspire_schemas.builders.authors import AuthorBuilder
from inspire_utils.record import get_value, get_values_for_schema
[docs]class Author(Schema):
display_name = fields.Raw()
family_name = fields.Raw()
given_name = fields.Raw()
native_name = fields.Raw()
public_emails = fields.Raw()
orcid = fields.Raw()
status = fields.Raw()
arxiv_categories = fields.Raw()
websites = fields.Raw()
twitter = fields.Raw()
blog = fields.Raw()
linkedin = fields.Raw()
positions = fields.Raw()
project_membership = fields.Raw()
advisors = fields.Raw()
comments = fields.Raw()
acquisition_source = fields.Raw()
@pre_dump
[docs] def before_dump(self, data):
family_name, given_name = self.get_name_splitted(data)
return {
'advisors': get_value(data, 'advisors', default=missing),
'acquisition_source': get_value(
data, 'acquisition_source', default=missing),
'arxiv_categories': get_value(
data, 'arxiv_categories', default=missing),
'blog': self.get_first_or_missing(
self.get_value_by_description_key(data.get('urls', []), 'blog')),
'display_name': get_value(
data, 'name.preferred_name', default=missing),
'family_name': self.get_value_or_missing(family_name),
'given_name': self.get_value_or_missing(given_name),
'linkedin': self.get_first_or_missing(
get_values_for_schema(data.get('ids', []), 'LINKEDIN')),
'native_name': get_value(
data, 'name.native_names[0]', default=missing),
'orcid': self.get_first_or_missing(
get_values_for_schema(data.get('ids', []), 'ORCID')),
'positions': get_value(data, 'positions', default=missing),
'project_membership': get_value(
data, 'project_membership', default=missing),
'public_emails': get_value(
data, 'email_addresses.value', default=missing),
'status': get_value(data, 'status', default=missing),
'twitter': self.get_first_or_missing(
get_values_for_schema(data.get('ids', []), 'TWITTER')),
'websites': get_value(data, 'urls.value', default=missing),
}
[docs] def get_name_splitted(self, data):
name = get_value(data, 'name.value')
if not name:
return missing, missing
name = name.split(',')
if len(name) > 1:
return name[0].strip(), name[1].strip()
return missing, name[0].strip()
[docs] def get_value_or_missing(self, value):
if value:
return value
return missing
[docs] def get_first_or_missing(self, value):
if value:
return value.pop()
return missing
[docs] def get_full_name(self, family_name, given_name):
if given_name and family_name:
return u'{}, {}'.format(family_name, given_name)
return given_name or family_name
[docs] def get_value_by_description_key(self, data, value):
return [item.get('value') for item in data if item.get('description') == value]
@post_load
[docs] def build_author(self, data):
author = AuthorBuilder()
for advisor in data.get('advisors', []):
author.add_advisor(**advisor)
for arxiv_category in data.get('arxiv_categories', []):
author.add_arxiv_category(arxiv_category)
blog = data.get('blog')
author.add_blog(blog)
comments = data.get('comments')
author.add_private_note(comments)
display_name = data.get('display_name')
author.set_display_name(display_name)
given_name = data.get('given_name')
family_name = data.get('family_name')
full_name = self.get_full_name(family_name, given_name)
author.set_name(full_name)
linkedin = data.get('linkedin')
author.add_linkedin(linkedin)
orcid = data.get('orcid')
author.add_orcid(orcid)
native_name = data.get('native_name')
author.add_native_name(native_name)
for position in data.get('positions', []):
institution = position.get('institution')
start_date = position.get('start_date')
end_date = position.get('end_date')
rank = position.get('rank')
record = position.get('record')
curated_relation = position.get('curated_relation', False)
current = position.get('current', False)
author.add_institution(
institution,
start_date=start_date,
end_date=end_date,
rank=rank,
record=record,
curated=curated_relation,
current=current
)
for project in data.get('project_membership', []):
name = project.get('name')
record = project.get('record')
start_date = project.get('start_date')
end_date = project.get('end_date')
curated_relation = project.get('curated_relation', False)
current = project.get('current', False)
author.add_project(
name,
record=record,
start_date=start_date,
end_date=end_date,
curated=curated_relation,
current=current
)
for email in data.get('public_emails', []):
author.add_email_address(email)
status = data.get('status')
author.set_status(status)
twitter = data.get('twitter')
author.add_twitter(twitter)
for website in data.get('websites', []):
author.add_url(website)
acquisition_source = data.get('acquisition_source')
if acquisition_source:
method = acquisition_source.get('method')
submission_number = acquisition_source.get('submission_number')
internal_uid = acquisition_source.get('internal_uid')
email = acquisition_source.get('email')
orcid = acquisition_source.get('orcid')
source = acquisition_source.get('source')
datetime = acquisition_source.get('datetime')
author.add_acquisition_source(
method,
submission_number=submission_number,
internal_uid=internal_uid,
email=email,
orcid=orcid,
source=source,
datetime=datetime,
)
return author.obj
