diff --git a/importer_invenio/indico_importer_invenio/importer.py b/importer_invenio/indico_importer_invenio/importer.py index 17c769b..c908dda 100644 --- a/importer_invenio/indico_importer_invenio/importer.py +++ b/importer_invenio/indico_importer_invenio/importer.py @@ -12,13 +12,23 @@ # General Public License for more details. # # You should have received a copy of the GNU General Public License -# along with Indico;if not, see . +# along with Indico; if not, see . + +from flask_pluginengine import current_plugin from indico_importer import ImporterEngineBase +from .connector import InvenioConnector +from .converters import InvenioRecordConverter + class InvenioImporter(ImporterEngineBase): """Fetches and converts data from CDS Invenio""" _id = 'invenio' name = 'CDS Invenio' + + def import_data(self, query, size): + url = current_plugin.settings.get('server_url') + registers = InvenioConnector(url).search(p=query, rg=size) + return InvenioRecordConverter.convert(registers)