Add typesense dependency

pyproject.toml

@@ -96,6 +96,7 @@ all = [
     "xarray",
     "zarr",
     "zstandard",
+    "typesense",
 ]
 # These are needed by the client and server to transmit/receive arrays.
 array = [

tiled/catalog/adapter.py

@@ -12,6 +12,7 @@
 from urllib.parse import quote_plus, urlparse
 
 import anyio
+import typesense
 from fastapi import HTTPException
 from sqlalchemy import delete, event, func, not_, or_, select, text, type_coerce, update
 from sqlalchemy.dialects.postgresql import JSONB, REGCONFIG
@@ -1167,6 +1168,7 @@ def in_memory(
     readable_storage=None,
     echo=DEFAULT_ECHO,
     adapters_by_mimetype=None,
+    typesenseClient=None,
 ):
     uri = "sqlite+aiosqlite:///:memory:"
     return from_uri(
@@ -1178,6 +1180,7 @@ def in_memory(
         readable_storage=readable_storage,
         echo=echo,
         adapters_by_mimetype=adapters_by_mimetype,
+        typesenseClient=typesenseClient,
     )
 
 
@@ -1192,6 +1195,7 @@ def from_uri(
     init_if_not_exists=False,
     echo=DEFAULT_ECHO,
     adapters_by_mimetype=None,
+    typesenseClient=None,
 ):
     uri = str(uri)
     if init_if_not_exists:
@@ -1213,6 +1217,13 @@ def from_uri(
     engine = create_async_engine(uri, echo=echo, json_serializer=json_serializer)
     if engine.dialect.name == "sqlite":
         event.listens_for(engine.sync_engine, "connect")(_set_sqlite_pragma)
+    if typesenseClient:
+        typesenseClient = typesense.client(
+            typesenseClient["host"],
+            typesenseClient["port"],
+            typesenseClient["protocol"],
+            typesenseClient["api_key"],
+        )
     return CatalogContainerAdapter(
         Context(engine, writable_storage, readable_storage, adapters_by_mimetype),
         RootNode(metadata, specs, access_policy),