BOSS backend

Pipfile

@@ -15,6 +15,7 @@ pylint = "*"
 [packages]
 aiohttp = "*"
 async-lru = "*"
+blosc = "*"
 compressed-segmentation = ">=1.0.0"
 jpeg4py = "*"
 numpy = "*"

benchmarks/decode_jpg.py

@@ -3,18 +3,18 @@
 import numpy as np
 from aiohttp import ClientSession
 
-from wkconnect.backends.neuroglancer.backend import NeuroglancerBackend
+from wkconnect.backends.neuroglancer.backend import Neuroglancer
 from wkconnect.utils.types import Vec3D
 
-neuroglancer: NeuroglancerBackend
+neuroglancer: Neuroglancer
 data: np.ndarray
 
 
 async def setup() -> None:
     global neuroglancer
     global data
     http_client = await ClientSession().__aenter__()
-    neuroglancer = NeuroglancerBackend({}, http_client)
+    neuroglancer = Neuroglancer({}, http_client)
 
     data_url = "https://storage.googleapis.com/neuroglancer-public-data/kasthuri2011/image/24_24_30/896-960_1152-1216_1472-1536"
 

data/datasets.json

@@ -1,4 +1,22 @@
 {
+    "boss": {
+        "Connectomics_Department": {
+            "ara": {
+                "domain": "https://api.boss.neurodata.io",
+                "collection": "ara_2016",
+                "experiment": "sagittal_50um",
+                "username": "jstriebel",
+                "password": "{,vEzT7J?-5_"
+            },
+            "kasthuri2011-neurodata-io": {
+                "domain": "https://api.boss.neurodata.io",
+                "collection": "kasthuri",
+                "experiment": "kasthuri11",
+                "username": "jstriebel",
+                "password": "{,vEzT7J?-5_"
+            }
+        }
+    },
     "neuroglancer": {
         "Connectomics_Department": {
             "fafb_v14": {

stubs/compressed_segmentation.pyi

@@ -1,6 +1,7 @@
-import numpy as np
 from typing import Tuple
 
+import numpy as np
+
 def decompress(
     encoded: bytes,
     volume_size: Tuple[int, int, int],

wkconnect/__main__.py

@@ -12,7 +12,8 @@
 from uvloop import Loop
 
 from .backends.backend import Backend
-from .backends.neuroglancer.backend import NeuroglancerBackend as Neuroglancer
+from .backends.boss.backend import Boss
+from .backends.neuroglancer.backend import Neuroglancer
 from .repository import Repository
 from .routes import routes
 from .utils.scheduler import repeat_every_seconds
@@ -29,7 +30,7 @@ def __init__(self) -> None:
         self.repository: Repository
         self.webknossos: WebKnossos
         self.backends: Dict[str, Backend]
-        self.available_backends: List[Type[Backend]] = [Neuroglancer]
+        self.available_backends: List[Type[Backend]] = [Boss, Neuroglancer]
 
     async def add_dataset(
         self,
@@ -80,14 +81,13 @@ async def load_persisted_datasets(self) -> None:
 async def setup(app: Server, loop: Loop) -> None:
     def instanciate_backend(backend_class: Type[Backend]) -> Tuple[str, Backend]:
         backend_name = backend_class.name()
-        config = app.config["backends"][backend_name]
+        config = app.config["backends"].get(backend_name, {})
         return (backend_name, backend_class(config, app.http_client))
 
     app.http_client = await ClientSession(raise_for_status=True).__aenter__()
     app.repository = Repository()
     app.webknossos = WebKnossos(app.config, app.http_client)
     app.backends = dict(map(instanciate_backend, app.available_backends))
-    # await app.load_persisted_datasets()
 
 
 @app.listener("before_server_stop")

wkconnect/backends/backend.py

@@ -19,9 +19,8 @@ def to_webknossos(self) -> WKDataSource:
 
 class Backend(metaclass=ABCMeta):
     @classmethod
-    @abstractmethod
     def name(cls) -> str:
-        pass
+        return cls.__name__.lower()
 
     @abstractmethod
     def __init__(self, config: Dict, http_client: ClientSession) -> None: