indexation class: add indexation property to IlsRecord

* Adds indexation class property to IlsRecord

Co-Authored-by: Peter Weber <[email protected]>

rero_ils/modules/api.py

@@ -106,6 +106,7 @@ class IlsRecord(Record):
     fetcher = None
     provider = None
     object_type = 'rec'
+    indexer = IlsRecordIndexer
 
     @classmethod
     def create(cls, data, id_=None, delete_pid=False,
@@ -274,14 +275,14 @@ def dbcommit(self, reindex=False, forceindex=False):
     def reindex(self, forceindex=False):
         """Reindex record."""
         if forceindex:
-            RecordIndexer(version_type="external_gte").index(self)
+            self.indexer(version_type="external_gte").index(self)
         else:
-            RecordIndexer().index(self)
+            self.indexer().index(self)
 
     def delete_from_index(self):
         """Delete record from index."""
         try:
-            RecordIndexer().delete(self)
+            self.indexer().delete(self)
         except NotFoundError:
             pass
 

rero_ils/modules/items/api.py

@@ -183,6 +183,7 @@ class Item(IlsRecord):
     minter = item_id_minter
     fetcher = item_id_fetcher
     provider = ItemProvider
+    indexer = ItemsIndexer
 
     statuses = {
         'ITEM_ON_LOAN': 'on_loan',
@@ -482,13 +483,6 @@ def actions(self):
         #     actions.add('lose')
         return actions
 
-    def reindex(self, forceindex=False):
-        """Reindex record."""
-        if forceindex:
-            ItemsIndexer(version_type="external_gte").index(self)
-        else:
-            ItemsIndexer().index(self)
-
     def status_update(self, dbcommit=False, reindex=False, forceindex=False):
         """Update item status."""
         loan = get_loan_for_item(self.pid)

tests/ui/test_api.py

@@ -182,6 +182,19 @@ def test_ilsrecord(app, es_default_index, ils_record, ils_record_2):
     with pytest.raises(IlsRecordError.NotDeleted):
         record = record.undelete()
 
+    """Test IlsRecord es search."""
+    search_all = list(
+        SearchTest().filter('match_all').source().scan()
+    )
+    assert len(search_all) == 3
+    search = list(
+        SearchTest()
+        .filter('term', pid='ilsrecord_pid_2')
+        .source(includes=['pid'])
+        .scan()
+    )
+    assert search[0]['pid'] == 'ilsrecord_pid_2'
+
     """Test IlsRecord update."""
     record = RecordTest.get_record_by_pid('ilsrecord_pid')
     record.delete(delindex=True)
@@ -195,16 +208,3 @@ def test_ilsrecord(app, es_default_index, ils_record, ils_record_2):
     record.delete(delindex=True)
     assert len(RecordTest.get_all_pids()) == 0
     assert len(RecordTest.get_all_ids()) == 0
-
-    """Test IlsRecord es search."""
-    search_all = list(
-        SearchTest().filter('match_all').source().scan()
-    )
-    assert len(search_all) == 3
-    search = list(
-        SearchTest()
-        .filter('term', pid='ilsrecord_pid_2')
-        .source(includes=['pid'])
-        .scan()
-    )
-    assert search[0]['pid'] == 'ilsrecord_pid_2'