rename scribe.elasticsearch -> hub.elastic_sync

hub/elastic_sync/__init__.py

@@ -0,0 +1,2 @@
+from hub.elastic_sync.search import SearchIndex
+from hub.elastic_sync.notifier_protocol import ElasticNotifierClientProtocol

hub/elastic_sync/__main__.py

@@ -3,8 +3,8 @@ import logging
 import traceback
 import argparse
 from hub.common import setup_logging
-from hub.elasticsearch.env import ElasticEnv
-from hub.elasticsearch.service import ElasticSyncService
+from hub.elastic_sync.env import ElasticEnv
+from hub.elastic_sync.service import ElasticSyncService
 
 
 def main():

hub/elastic_sync/search.py

@@ -14,7 +14,7 @@ from hub.schema.url import normalize_name
 from hub.error import TooManyClaimSearchParametersError
 from hub.common import LRUCache
 from hub.db.common import CLAIM_TYPES, STREAM_TYPES
-from hub.elasticsearch.constants import INDEX_DEFAULT_SETTINGS, REPLACEMENTS, FIELDS, TEXT_FIELDS,  RANGE_FIELDS
+from hub.elastic_sync.constants import INDEX_DEFAULT_SETTINGS, REPLACEMENTS, FIELDS, TEXT_FIELDS,  RANGE_FIELDS
 from hub.db.common import ResolveResult
 if TYPE_CHECKING:
     from hub.db import HubDB

hub/elastic_sync/service.py

@@ -9,12 +9,12 @@ from hub.schema.result import Censor
 from hub.service import BlockchainReaderService
 from hub.db.revertable import RevertableOp
 from hub.db.common import TrendingNotification, DB_PREFIXES
-from hub.elasticsearch.notifier_protocol import ElasticNotifierProtocol
-from hub.elasticsearch.search import IndexVersionMismatch, expand_query
-from hub.elasticsearch.constants import ALL_FIELDS, INDEX_DEFAULT_SETTINGS
-from hub.elasticsearch.fast_ar_trending import FAST_AR_TRENDING_SCRIPT
+from hub.elastic_sync.notifier_protocol import ElasticNotifierProtocol
+from hub.elastic_sync.search import IndexVersionMismatch, expand_query
+from hub.elastic_sync.constants import ALL_FIELDS, INDEX_DEFAULT_SETTINGS
+from hub.elastic_sync.fast_ar_trending import FAST_AR_TRENDING_SCRIPT
 if typing.TYPE_CHECKING:
-    from hub.elasticsearch.env import ElasticEnv
+    from hub.elastic_sync.env import ElasticEnv
 
 
 class ElasticSyncService(BlockchainReaderService):

hub/elasticsearch/__init__.py

@@ -1,2 +0,0 @@
-from hub.elasticsearch.search import SearchIndex
-from hub.elasticsearch.notifier_protocol import ElasticNotifierClientProtocol

hub/herald/service.py

@@ -6,7 +6,7 @@ from hub.herald.session import SessionManager
 from hub.herald.mempool import HubMemPool
 from hub.herald.udp import StatusServer
 from hub.service import BlockchainReaderService
-from hub.elasticsearch import ElasticNotifierClientProtocol
+from hub.elastic_sync import ElasticNotifierClientProtocol
 if typing.TYPE_CHECKING:
     from hub.herald.env import ServerEnv
 

hub/herald/session.py

@@ -20,7 +20,7 @@ from hub.error import ResolveCensoredError, TooManyClaimSearchParametersError
 from hub import __version__, PROMETHEUS_NAMESPACE
 from hub.herald import PROTOCOL_MIN, PROTOCOL_MAX, HUB_PROTOCOL_VERSION
 from hub.build_info import BUILD, COMMIT_HASH, DOCKER_TAG
-from hub.elasticsearch import SearchIndex
+from hub.elastic_sync import SearchIndex
 from hub.common import sha256, hash_to_hex_str, hex_str_to_hash, HASHX_LEN, version_string, formatted_time
 from hub.common import protocol_version, RPCError, DaemonError, TaskGroup, HISTOGRAM_BUCKETS
 from hub.herald.jsonrpc import JSONRPCAutoDetect, JSONRPCConnection, JSONRPCv2, JSONRPC