RDBC-780 IndexesFromClientTest::getTerms

Author: poissoncorp

ravendb/documents/indexes/stats.py

@@ -2,8 +2,14 @@
 from datetime import datetime
 from typing import Dict, Any
 
-from ravendb.documents.indexes.definitions import IndexState, IndexPriority, IndexLockMode, IndexType, IndexSourceType, \
-    IndexRunningStatus
+from ravendb.documents.indexes.definitions import (
+    IndexState,
+    IndexPriority,
+    IndexLockMode,
+    IndexType,
+    IndexSourceType,
+    IndexRunningStatus,
+)
 from ravendb.tools.utils import Utils
 
 

ravendb/documents/operations/indexes.py

@@ -6,8 +6,13 @@
 
 from ravendb.exceptions import exceptions
 from ravendb.exceptions.exceptions import ErrorResponseException
-from ravendb.documents.indexes.definitions import IndexDefinition, IndexErrors, IndexLockMode, IndexPriority, \
-    IndexRunningStatus
+from ravendb.documents.indexes.definitions import (
+    IndexDefinition,
+    IndexErrors,
+    IndexLockMode,
+    IndexPriority,
+    IndexRunningStatus,
+)
 from ravendb.documents.operations.definitions import MaintenanceOperation, VoidMaintenanceOperation
 from ravendb.http.raven_command import RavenCommand, VoidRavenCommand
 from ravendb.http.server_node import ServerNode
@@ -282,9 +287,7 @@ def from_json(cls, json_dict: dict) -> IndexStatus:
 
 
 class IndexingStatus:
-    def __init__(
-        self, status: IndexRunningStatus = None, indexes: List[IndexStatus] = None
-    ):
+    def __init__(self, status: IndexRunningStatus = None, indexes: List[IndexStatus] = None):
         self.status = status
         self.indexes = indexes
 

ravendb/tests/jvm_migrated_tests/client_tests/indexing_tests/test_indexes_from_client.py

@@ -16,10 +16,18 @@
     StartIndexingOperation,
     StopIndexOperation,
     GetIndexesOperation,
-    GetIndexStatisticsOperation, SetIndexesLockOperation, SetIndexesPriorityOperation,
+    GetIndexStatisticsOperation,
+    SetIndexesLockOperation,
+    SetIndexesPriorityOperation,
+    GetTermsOperation,
+)
+from ravendb.documents.indexes.definitions import (
+    FieldIndexing,
+    FieldStorage,
+    IndexLockMode,
+    IndexRunningStatus,
+    IndexPriority,
 )
-from ravendb.documents.indexes.definitions import FieldIndexing, FieldStorage, IndexLockMode, IndexRunningStatus, \
-    IndexPriority
 from ravendb.documents.indexes.abstract_index_creation_tasks import AbstractIndexCreationTask
 from ravendb.infrastructure.entities import User, Post
 from ravendb.tests.test_base import TestBase
@@ -271,9 +279,37 @@ def test_set_lock_mode_and_set_priority(self):
         self.assertEqual(stats.priority, IndexPriority.NORMAL)
 
         self.store.maintenance.send(SetIndexesLockOperation(IndexLockMode.LOCKED_IGNORE, index.name))
-        self.store.maintenance.send(SetIndexesPriorityOperation(IndexPriority.LOW,index.name ))
+        self.store.maintenance.send(SetIndexesPriorityOperation(IndexPriority.LOW, index.name))
 
         stats = self.store.maintenance.send(GetIndexStatisticsOperation(index.name))
 
         self.assertEqual(IndexLockMode.LOCKED_IGNORE, stats.lock_mode)
         self.assertEqual(IndexPriority.LOW, stats.priority)
+
+    def test_get_terms(self):
+        with self.store.open_session() as session:
+            session.store(User(name="Fitzchak"))
+            session.store(User(name="Arek"))
+            session.save_changes()
+
+        with self.store.open_session() as session:
+            stats: Optional[QueryStatistics] = None
+
+            def _stats(s: QueryStatistics):
+                nonlocal stats
+                stats = s
+
+            users = list(
+                session.query(object_type=User)
+                .wait_for_non_stale_results()
+                .statistics(_stats)
+                .where_equals("name", "Arek")
+            )
+            index_name = stats.index_name
+
+        terms = self.store.maintenance.send(GetTermsOperation(index_name, "name", None, 128))
+
+        self.assertEqual(2, len(terms))
+
+        self.assertIn("arek", terms)
+        self.assertIn("fitzchak", terms)