From 6ee4bc0b3a295ff38d206ae0733a47af1b88e22c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Alejandro=20Avil=C3=A9s?= <aavilesd@cern.ch>
Date: Wed, 29 Oct 2014 17:20:41 +0100
Subject: [PATCH] Implement importer engine

---
 importer_invenio/indico_importer_invenio/importer.py | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

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 <http://www.gnu.org/licenses/>.
+# along with Indico; if not, see <http://www.gnu.org/licenses/>.
+
+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)