# -*- coding: utf-8 -*-
#
# This file is part of INSPIRE.
# Copyright (C) 2014-2017 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.
"""HAL SWORD core."""
from __future__ import absolute_import, division, print_function
from tempfile import TemporaryFile
from zipfile import ZIP_DEFLATED, ZipFile
import httplib2
from flask import current_app
from sword2 import Connection
from sword2.http_layer import HttpLib2Layer
[docs]def create(tei, doc_file=None):
"""Create a record on HAL using the SWORD2 protocol."""
connection = _new_connection()
payload, mimetype, filename = _create_payload(tei, doc_file)
col_iri = current_app.config['HAL_COL_IRI']
return connection.create(
col_iri=col_iri,
payload=payload,
mimetype=mimetype,
filename=filename,
packaging='http://purl.org/net/sword-types/AOfr',
in_progress=False,
)
[docs]def update(tei, hal_id, doc_file=None):
"""Update a record on HAL using the SWORD2 protocol."""
connection = _new_connection()
payload, mimetype, filename = _create_payload(tei, doc_file)
edit_iri = current_app.config['HAL_EDIT_IRI'] + hal_id
edit_media_iri = edit_iri
return connection.update(
edit_iri=edit_iri,
edit_media_iri=edit_media_iri,
payload=payload,
mimetype=mimetype,
filename=filename,
packaging='http://purl.org/net/sword-types/AOfr',
in_progress=False,
)
[docs]class HttpLib2LayerIgnoreCert(HttpLib2Layer):
def __init__(self, cache_dir):
super(HttpLib2LayerIgnoreCert, self).__init__()
self.h = httplib2.Http(
cache_dir, timeout=30.0, ca_certs=None,
disable_ssl_certificate_validation=True)
def _new_connection():
user_name = current_app.config['HAL_USER_NAME']
user_pass = current_app.config['HAL_USER_PASS']
if current_app.config['HAL_IGNORE_CERTIFICATES']:
http_impl = HttpLib2LayerIgnoreCert('.cache')
else:
http_impl = HttpLib2Layer('.cache')
return Connection(
'', user_name=user_name, user_pass=user_pass, http_impl=http_impl)
def _create_payload(tei, doc_file):
if doc_file:
temp_file = TemporaryFile()
with ZipFile(temp_file, mode='w', compression=ZIP_DEFLATED) as zf:
zf.writestr('meta.xml', tei)
zf.write(doc_file, 'doc.pdf')
temp_file.seek(0)
return temp_file, 'application/zip', 'meta.xml'
return tei, 'text/xml', 'meta.xml'
