Applied "Introduction of ItemSource interface" patch

.coveragerc

@@ -1,13 +0,0 @@
-[run]
-branch = True
-source = cellxgene_gateway
-
-[report]
-exclude_lines =
-    if self.debug:
-    pragma: no cover
-    raise NotImplementedError
-    if __name__ == .__main__.:
-ignore_errors = True
-omit =
-    tests/*

.github/workflows/codeql-analysis.yml

@@ -1,67 +0,0 @@
-# For most projects, this workflow file will not need changing; you simply need
-# to commit it to your repository.
-#
-# You may wish to alter this file to override the set of languages analyzed,
-# or to provide custom queries or build logic.
-#
-# ******** NOTE ********
-# We have attempted to detect the languages in your repository. Please check
-# the `language` matrix defined below to confirm you have the correct set of
-# supported CodeQL languages.
-#
-name: "CodeQL"
-
-on:
-  push:
-    branches: [ master ]
-  pull_request:
-    # The branches below must be a subset of the branches above
-    branches: [ master ]
-  schedule:
-    - cron: '18 6 * * 6'
-
-jobs:
-  analyze:
-    name: Analyze
-    runs-on: ubuntu-latest
-
-    strategy:
-      fail-fast: false
-      matrix:
-        language: [ 'javascript', 'python' ]
-        # CodeQL supports [ 'cpp', 'csharp', 'go', 'java', 'javascript', 'python' ]
-        # Learn more:
-        # https://docs.github.com/en/free-pro-team@latest/github/finding-security-vulnerabilities-and-errors-in-your-code/configuring-code-scanning#changing-the-languages-that-are-analyzed
-
-    steps:
-    - name: Checkout repository
-      uses: actions/checkout@v2
-
-    # Initializes the CodeQL tools for scanning.
-    - name: Initialize CodeQL
-      uses: github/codeql-action/init@v1
-      with:
-        languages: ${{ matrix.language }}
-        # If you wish to specify custom queries, you can do so here or in a config file.
-        # By default, queries listed here will override any specified in a config file.
-        # Prefix the list here with "+" to use these queries and those in the config file.
-        # queries: ./path/to/local/query, your-org/your-repo/queries@main
-
-    # Autobuild attempts to build any compiled languages  (C/C++, C#, or Java).
-    # If this step fails, then you should remove it and run the build manually (see below)
-    - name: Autobuild
-      uses: github/codeql-action/autobuild@v1
-
-    # ℹ️ Command-line programs to run using the OS shell.
-    # 📚 https://git.io/JvXDl
-
-    # ✏️ If the Autobuild fails above, remove it and uncomment the following three lines
-    #    and modify them (or add more) to build your code if your project
-    #    uses a compiled language
-
-    #- run: |
-    #   make bootstrap
-    #   make release
-
-    - name: Perform CodeQL Analysis
-      uses: github/codeql-action/analyze@v1

.github/workflows/pr-checks.yaml

@@ -1,67 +0,0 @@
-# Tests that run on every PR
-
-name: Pull Request Checks
-
-on: [push, pull_request]
-
-jobs:
-  black:
-    runs-on: ubuntu-18.04
-    steps:
-      - uses: actions/checkout@v2
-        name: Checkout repository
-
-      - uses: actions/setup-python@v2
-        name: Setup Python
-        with:
-          python-version: 3.9
-
-      - name: Install black
-        run: |
-          python -m pip install --upgrade pip
-          pip install black
-      - name: Run black
-        run: |
-          black . --check
-  # This job is copied over from `deploy.yaml`
-  run-tests:
-    runs-on: ubuntu-18.04
-    steps:
-      - uses: actions/checkout@v2
-
-      # See: https://github.com/marketplace/actions/setup-conda
-      - uses: s-weigand/setup-conda@v1
-        with:
-          conda-channels: "conda-forge"
-
-      - name: Build environment
-        run: |
-          conda env create -f environment.yml
-          eval "$(conda shell.bash hook)"
-          conda activate cellxgene-gateway
-          python setup.py install
-
-      - name: Run tests
-        run: |
-          eval "$(conda shell.bash hook)"
-          conda activate cellxgene-gateway
-          coverage run -m unittest discover tests
-
-      - name: Check coverage
-        run: |
-          eval "$(conda shell.bash hook)"
-          conda activate cellxgene-gateway
-          coverage report --fail-under 41
-          coverage xml -i
-
-      - name: "Upload coverage to Codecov"
-        uses: codecov/codecov-action@v1
-        with:
-          token: ${{ secrets.CODECOV_TOKEN }}
-          files: ./coverage.xml
-          flags: unittests
-          env_vars: OS,PYTHON
-          name: codecov-umbrella
-          fail_ci_if_error: true
-          path_to_write_report: ./codecov_report.txt
-          verbose: true

.gitignore

@@ -55,7 +55,6 @@ htmlcov/
 .nox/
 .coverage
 .coverage.*
-htmlcov
 .cache
 nosetests.xml
 coverage.xml

.pre-commit-config.yaml

@@ -7,6 +7,12 @@ repos:
       language: system
       types: [python]
       stages: [commit]
+    - id: flake8
+      name: flake8
+      language: system
+      entry: flake8
+      types: [python]
+      stages: [commit]
     - id: black
       language_version: python3.6+
       name: black

Changelog.md

@@ -1,24 +1,3 @@
-# 0.3.2
-
- * Fixed bug #45 affecting multi-level S3 folders
- * Added extra_scripts to cache_status page
-
-# 0.3.1
-
- * Added missing __init__.py
-
-# 0.3.0
-
- * Added support for itemsource interface, allowing s3 hosting
- * Removed support for http file uploads
- * Only set wsgi.url_scheme when EXTERNAL_PROTOCOL is set (see issue #43) 
- * Dropped flake8 due to conflicts with black
- * Added code coverage metrics
-
-# 0.2.3
-
- * Added support for ProxyFix
-
 # 0.2.2
 
   * Fixed bug with annotations (missing annotation.js asset)

README.md

@@ -2,8 +2,6 @@
 
 Cellxgene Gateway allows you to use the Cellxgene Server provided by the Chan Zuckerberg Institute (https://github.com/chanzuckerberg/cellxgene) with multiple datasets. It displays an index of available h5ad (anndata) files. When a user clicks on a file name, it launches a Cellxgene Server instance that loads that particular data file and once it is available  proxies requests to that server.
 
-[![codecov](https://codecov.io/gh/Novartis/cellxgene-gateway/branch/master/graph/badge.svg?token=ndEFSzRKJn)](https://codecov.io/gh/Novartis/cellxgene-gateway)
-
 # Running locally
 
 ## Prequisites
@@ -75,14 +73,7 @@ Optional environment variables:
 * `GATEWAY_PORT` - local port that the gateway should bind to, defaults to 5005
 * `GATEWAY_EXTRA_SCRIPTS` - JSON array of script paths, will be embedded into each page and forwarded with `--scripts` to cellxgene server
 * `GATEWAY_ENABLE_ANNOTATIONS` - Set to `true` or to `1` to enable cellxgene annotations. 
-* `GATEWAY_ENABLE_BACKED_MODE` - Set to `true` or to `1` to load AnnData in file-backed mode. This saves memory and speeds up launch time but may reduce overall performance.
-
-If any of the following optional variables are set, [ProxyFix](https://werkzeug.palletsprojects.com/en/1.0.x/middleware/proxy_fix/) will be used.
-* `PROXY_FIX_FOR` - Number of upstream proxies setting X-Forwarded-For
-* `PROXY_FIX_PROTO` - Number of upstream proxies setting X-Forwarded-Proto
-* `PROXY_FIX_HOST` - Number of upstream proxies setting X-Forwarded-Host
-* `PROXY_FIX_PORT` - Number of upstream proxies setting X-Forwarded-Port
-* `PROXY_FIX_PREFIX` - Number of upstream proxies setting X-Forwarded-Prefix
+* `GATEWAY_ENABLE_BACKED_MODE` - Set to `true` or to `1` to load AnnData in file-backed mode. This saves memory and speeds up launch time but may reduce overall performance.  
 
 The defaults should be fine if you set up a venv and cellxgene_data folder as above.
 
@@ -126,14 +117,6 @@ python setup.py develop
 
 For convenience, the code repo includes a `run.sh.example` shell script to run the gateway.
 
-4. Install pre-commit hooks
-
-```bash
-conda install -c conda-forge pre-commit
-pre-commit install
-```
-
-
 ## Running Tests
 
 [![Build Status](https://travis-ci.org/Novartis/cellxgene-gateway.svg?branch=master)](https://travis-ci.org/Novartis/cellxgene-gateway)
@@ -142,12 +125,6 @@ pre-commit install
     python -m unittest discover tests
 ```
 
-## Code Coverage
-```bash
-    coverage run -m unittest discover tests
-    coverage html
-```
-
 ## Running Linters
 
 pip install isort flake8 black

cellxgene_gateway/__init__.py

@@ -7,4 +7,4 @@
 # OR CONDITIONS OF ANY KIND, either express or implied. See the License for
 # the specific language governing permissions and limitations under the License.
 
-__version__ = "0.3.2"
+__version__ = "0.2.2"

cellxgene_gateway/backend_cache.py

@@ -9,7 +9,6 @@
 
 import time
 from threading import Thread
-from typing import List
 
 from flask_api import status
 
@@ -18,6 +17,7 @@ from cellxgene_gateway.cache_entry import CacheEntry, CacheEntryStatus
 from cellxgene_gateway.cache_key import CacheKey
 from cellxgene_gateway.cellxgene_exception import CellxgeneException
 from cellxgene_gateway.subprocess_backend import SubprocessBackend
+from typing import List
 
 process_backend = SubprocessBackend()
 

cellxgene_gateway/cache_entry.py

@@ -8,14 +8,13 @@
 # the specific language governing permissions and limitations under the License.
 import datetime
 import logging
-import re
 import urllib.parse
 from enum import Enum
 
 import psutil
 from flask import make_response, render_template, request
-from flask.wrappers import Response
 from requests import get, post, put
+import re
 
 from cellxgene_gateway import env
 from cellxgene_gateway.cellxgene_exception import CellxgeneException
@@ -111,7 +110,9 @@ class CacheEntry:
             except psutil.NoSuchProcess:
                 pass
 
-            logging.getLogger("cellxgene_gateway").info(f"terminated {terminated}")
+            logging.getLogger("cellxgene_gateway").info(
+                f"terminated {terminated}"
+            )
         self.status = CacheEntryStatus.terminated
 
     def rewrite_text_content(self, cellxgene_content):
@@ -119,22 +120,30 @@ class CacheEntry:
         gateway_content = (
             re.sub(
                 '(="|\()/static/',
-                f"\\1{self.key.gateway_basepath()}static/",
+                f"\\1{self.gateway_basepath()}static/",
                 cellxgene_content,
             )
             .replace("http://fonts.gstatic.com", "https://fonts.gstatic.com")
-            .replace(self.cellxgene_basepath(), self.key.gateway_basepath())
+            .replace(self.cellxgene_basepath(), self.gateway_basepath())
         )
         return gateway_content
 
+    def gateway_basepath(self):
+        source_path = (
+            f"/source/{urllib.parse.quote_plus(self.source_name)}"
+            if self.source_name
+            else ""
+        )
+        return f"{env.external_protocol}://{env.external_host}{source_path}/view/{self.key.descriptor}/"
+
     def cellxgene_basepath(self):
         return f"http://127.0.0.1:{self.port}"
 
     def serve_content(self, path):
-        gateway_basepath = self.key.gateway_basepath()
+        gateway_basepath = self.gateway_basepath()
         subpath = path[len(self.key.descriptor) :]  # noqa: E203
         if len(subpath) == 0:
-            r = make_response(f"Redirect to {gateway_basepath}\n", 302)
+            r = make_response(f"Redirect to {gateway_basepath}\n", 301)
             r.headers["location"] = gateway_basepath + querystring()
             return r
         elif self.status == CacheEntryStatus.loading:
@@ -184,7 +193,9 @@ class CacheEntry:
                 data=request.data,
             )
         else:
-            raise CellxgeneException(f"Unexpected method {request.method}", 400)
+            raise CellxgeneException(
+                f"Unexpected method {request.method}", 400
+            )
         content_type = cellxgene_response.headers["content-type"]
         if "text" in content_type:
             gateway_content = self.rewrite_text_content(

cellxgene_gateway/cache_key.py

@@ -15,7 +15,6 @@
 # 3) somedir/dataset_annotations: an annotation directory. The corresponding h5ad must exist, but the directory may not.
 #    in this case, descriptor == 'somedir/dataset_annotations', dataset == 'somedir/dataset.h5ad'
 
-from cellxgene_gateway import flask_util
 from cellxgene_gateway.items.item import Item
 from cellxgene_gateway.items.item_source import ItemSource, LookupResult
 
@@ -39,16 +38,6 @@ class CacheKey:
         else:
             return self.source.get_local_path(self.annotation_item)
 
-    def relaunch_url(self):
-        return flask_util.relaunch_url(self.descriptor, self.source_name)
-
-    def gateway_basepath(self):
-        return self.view_url + "/"
-
-    @property
-    def view_url(self):
-        return flask_util.view_url(self.descriptor, self.source_name)
-
     @property
     def source_name(self):
         return self.source.name

cellxgene_gateway/dir_util.py

@@ -62,8 +62,3 @@ def make_h5ad(el):
 
 def make_annotations(el):
     return el[:-5] + annotations_suffix
-
-
-def ensure_dir_exists(file_path):
-    if not os.path.exists(file_path):
-        os.makedirs(file_path)

cellxgene_gateway/env.py

@@ -12,7 +12,7 @@ import os
 import socket
 
 cellxgene_location = os.environ.get("CELLXGENE_LOCATION")
-cellxgene_data = os.environ.get("CELLXGENE_DATA", "")
+cellxgene_data = os.environ.get("CELLXGENE_DATA")
 cellxgene_args = os.environ.get("CELLXGENE_ARGS", None)
 gateway_port = int(os.environ.get("GATEWAY_PORT", "5005"))
 external_host = os.environ.get(
@@ -20,16 +20,20 @@ external_host = os.environ.get(
     os.environ.get("GATEWAY_HOST", f"localhost:{gateway_port}"),
 )
 external_protocol = os.environ.get(
-    "EXTERNAL_PROTOCOL", os.environ.get("GATEWAY_PROTOCOL", None)
+    "EXTERNAL_PROTOCOL", os.environ.get("GATEWAY_PROTOCOL", "http")
 )
 ip = os.environ.get("GATEWAY_IP")
 extra_scripts = os.environ.get("GATEWAY_EXTRA_SCRIPTS")
 ttl = os.environ.get("GATEWAY_TTL")
-enable_annotations = os.environ.get("GATEWAY_ENABLE_ANNOTATIONS", "").lower() in [
+enable_annotations = os.environ.get(
+    "GATEWAY_ENABLE_ANNOTATIONS", ""
+).lower() in [
     "true",
     "1",
 ]
-enable_backed_mode = os.environ.get("GATEWAY_ENABLE_BACKED_MODE", "").lower() in [
+enable_backed_mode = os.environ.get(
+    "GATEWAY_ENABLE_BACKED_MODE", ""
+).lower() in [
     "true",
     "1",
 ]
@@ -38,12 +42,6 @@ env_vars = {
     "CELLXGENE_LOCATION": cellxgene_location,
 }
 
-proxy_fix_for = int(os.environ.get("PROXY_FIX_FOR", "0"))
-proxy_fix_proto = int(os.environ.get("PROXY_FIX_PROTO", "0"))
-proxy_fix_host = int(os.environ.get("PROXY_FIX_HOST", "0"))
-proxy_fix_port = int(os.environ.get("PROXY_FIX_PORT", "0"))
-proxy_fix_prefix = int(os.environ.get("PROXY_FIX_PREFIX", "0"))
-
 optional_env_vars = {
     "EXTERNAL_HOST": external_host,
     "EXTERNAL_PROTOCOL": external_protocol,
@@ -55,11 +53,6 @@ optional_env_vars = {
     "GATEWAY_ENABLE_BACKED_MODE": enable_backed_mode,
     "CELLXGENE_ARGS": cellxgene_args,
     "CELLXGENE_DATA": cellxgene_data,
-    "PROXY_FIX_FOR": proxy_fix_for,
-    "PROXY_FIX_PROTO": proxy_fix_proto,
-    "PROXY_FIX_HOST": proxy_fix_host,
-    "PROXY_FIX_PORT": proxy_fix_port,
-    "PROXY_FIX_PREFIX": proxy_fix_prefix,
 }
 
 

cellxgene_gateway/extra_scripts.py

@@ -8,7 +8,6 @@
 # the specific language governing permissions and limitations under the License.
 
 from json import loads
-from json.decoder import JSONDecodeError
 
 from cellxgene_gateway import env
 
@@ -18,9 +17,4 @@ def get_extra_scripts():
     # ['https://www.googletagmanager.com/gtag/js?id=UA-123456-2',
     #  f"{env.external_protocol}://{env.external_host}/static/js/google_ua.js"]
     # where google_ua.js is a script you add to the static/js folder prior to deployment.
-    try:
-        return [] if env.extra_scripts is None else loads(env.extra_scripts)
-    except JSONDecodeError as exc:
-        raise Exception(
-            f'Error parsing GATEWAY_EXTRA_SCRIPTS, expected JSON array e.g. ["https://example.com/path/to/script.js"]'
-        ) from exc
+    return [] if env.extra_scripts is None else loads(env.extra_scripts)

cellxgene_gateway/filecrawl.py

@@ -10,20 +10,14 @@
 import os
 import urllib.parse
 
-from cellxgene_gateway import env, flask_util
-from cellxgene_gateway.cache_key import CacheKey
-from cellxgene_gateway.dir_util import annotations_suffix, make_annotations, make_h5ad
-
 
 def render_annotations(item, item_source):
-    url = flask_util.view_url(
-        item_source.get_annotations_subpath(item), item_source.name
-    )
-    new_annotation = f"<a class='new' href='{url}'>new</a>"
+    subpath = f"/source/{urllib.parse.quote_plus(item_source.name)}/view/"
+    new_annotation = f"<a class='new' href='{subpath}{item_source.get_annotations_subpath(item)}'>new</a>"
     annotations = (
         ", ".join(
             [
-                f"<a href='{CacheKey(item, item_source, a).view_url}/'>{a.name}</a>"
+                f"<a href='{subpath}{a.descriptor}/'>{a.name}</a>"
                 for a in item.annotations
             ]
         )
@@ -31,11 +25,13 @@ def render_annotations(item, item_source):
         if item.annotations
         else ""
     )
+
     return " | annotations: " + annotations + new_annotation
 
 
 def render_item(item, item_source):
-    item_string = f"<li> <a href='{ CacheKey(item, item_source).view_url }/'>{item.name}</a> {render_annotations(item, item_source)}</li>"
+    url = f"/source/{urllib.parse.quote_plus(item_source.name)}/view/{item.descriptor}/"
+    item_string = f"<li> <a href='{ url }'>{item.name}</a> {render_annotations(item, item_source)}</li>"
     return item_string
 
 
@@ -46,7 +42,9 @@ def render_item_tree(item_tree, item_source):
         else ""
     )
     branches = (
-        "\n".join([render_item_tree(b, item_source) for b in item_tree.branches])
+        "\n".join(
+            [render_item_tree(b, item_source) for b in item_tree.branches]
+        )
         if item_tree.branches
         else ""
     )
@@ -54,7 +52,11 @@ def render_item_tree(item_tree, item_source):
     if item_tree.descriptor:
         descriptor = item_tree.descriptor.lstrip("/")
         url = f"/filecrawl/{descriptor}?source={item_source.name}"
-        name = descriptor.rsplit("/")[1] if descriptor.find("/") >= 0 else descriptor
+        name = (
+            descriptor.rsplit("/")[1]
+            if descriptor.find("/") >= 0
+            else descriptor
+        )
         return f"<li><a href='{url}'>{name}</a>{html}</li>"
     else:
         return html
@@ -62,6 +64,5 @@ def render_item_tree(item_tree, item_source):
 
 def render_item_source(item_source, filter=None):
     item_tree = item_source.list_items(filter)
-    filterpart = "" if filter is None else ":" + filter
-    heading = f"<h6><a href='/filecrawl.html?source={urllib.parse.quote_plus(item_source.name)}'>{item_source.name}</a>{filterpart}</h6>"
+    heading = f"<h6><a href='/filecrawl.html?source={urllib.parse.quote_plus(item_source.name)}'>{item_source.name}</a></h6>"
     return heading + render_item_tree(item_tree, item_source)

cellxgene_gateway/flask_util.py

@@ -7,27 +7,9 @@
 # OR CONDITIONS OF ANY KIND, either express or implied. See the License for
 # the specific language governing permissions and limitations under the License.
 
-from flask import request, url_for
+from flask import request
 
 
 def querystring():
     qs = request.query_string.decode()
     return f"?{qs}" if len(qs) > 0 else ""
-
-
-include_source_in_url = False
-
-
-def url(endpoint, descriptor, source_name):
-    if include_source_in_url:
-        return url_for(endpoint, source_name=source_name, path=descriptor)
-    else:
-        return url_for(endpoint, path=descriptor)
-
-
-def view_url(descriptor, source_name):
-    return url("do_view", descriptor, source_name)
-
-
-def relaunch_url(descriptor, source_name):
-    return url("do_relaunch", descriptor, source_name)

cellxgene_gateway/gateway.py

@@ -23,13 +23,11 @@ from flask import (
     url_for,
 )
 from flask_api import status
-from werkzeug.middleware.proxy_fix import ProxyFix
 from werkzeug.utils import secure_filename
 
-from cellxgene_gateway import env, flask_util
+from cellxgene_gateway import env
 from cellxgene_gateway.backend_cache import BackendCache
 from cellxgene_gateway.cache_entry import CacheEntryStatus
-from cellxgene_gateway.cache_key import CacheKey
 from cellxgene_gateway.cellxgene_exception import CellxgeneException
 from cellxgene_gateway.dir_util import create_dir, is_subdir
 from cellxgene_gateway.extra_scripts import get_extra_scripts
@@ -37,6 +35,7 @@ from cellxgene_gateway.filecrawl import render_item_source
 from cellxgene_gateway.process_exception import ProcessException
 from cellxgene_gateway.prune_process_cache import PruneProcessCache
 from cellxgene_gateway.util import current_time_stamp
+from cellxgene_gateway.cache_key import CacheKey
 
 app = Flask(__name__)
 
@@ -46,31 +45,16 @@ default_item_source = None
 
 def _force_https(app):
     def wrapper(environ, start_response):
-        if env.external_protocol is not None:
-            environ["wsgi.url_scheme"] = env.external_protocol
+        environ["wsgi.url_scheme"] = env.external_protocol
         return app(environ, start_response)
 
     return wrapper
 
 
 app.wsgi_app = _force_https(app.wsgi_app)
-if (
-    env.proxy_fix_for > 0
-    or env.proxy_fix_proto > 0
-    or env.proxy_fix_host > 0
-    or env.proxy_fix_port > 0
-    or env.proxy_fix_prefix > 0
-):
-    app.wsgi_app = ProxyFix(
-        app.wsgi_app,
-        x_for=env.proxy_fix_for,
-        x_proto=env.proxy_fix_proto,
-        x_host=env.proxy_fix_host,
-        x_port=env.proxy_fix_port,
-        x_prefix=env.proxy_fix_prefix,
-    )
 
 cache = BackendCache()
+location = f"{env.external_protocol}://{env.external_host}"
 
 
 @app.errorhandler(CellxgeneException)
@@ -106,7 +90,7 @@ def handle_invalid_process(error):
             http_status=error.http_status,
             stdout=error.stdout,
             stderr=error.stderr,
-            relaunch_url=error.key.relaunch_url(),
+            dataset=error.key.h5ad_item.descriptor,
             annotation_file=error.key.annotation_descriptor,
         ),
         error.http_status,
@@ -217,11 +201,7 @@ def do_view(path, source_name=None):
 
 @app.route("/cache_status", methods=["GET"])
 def do_GET_status():
-    return render_template(
-        "cache_status.html",
-        entry_list=cache.entry_list,
-        extra_scripts=get_extra_scripts(),
-    )
+    return render_template("cache_status.html", entry_list=cache.entry_list)
 
 
 @app.route("/cache_status.json", methods=["GET"])
@@ -245,14 +225,15 @@ def do_GET_status_json():
 
 @app.route("/relaunch/<path:path>", methods=["GET"])
 def do_relaunch(path):
-    source_name = request.args.get("source_name") or default_item_source.name
+    source_name = request.args.get("source") or default_item_source.name
     source = matching_source(source_name)
     key = CacheKey.for_lookup(source, source.lookup(path))
     match = cache.check_entry(key)
     if not match is None:
         match.terminate()
+    qs = request.query_string.decode()
     return redirect(
-        key.view_url,
+        url_for("do_view", path=path) + (f"?{qs}" if len(qs) > 0 else ""),
         code=302,
     )
 
@@ -306,7 +287,6 @@ def main():
         default_item_source = "local"
     if len(item_sources) == 0:
         raise Exception("Please specify CELLXGENE_DATA or CELLXGENE_BUCKET")
-    flask_util.include_source_in_url = len(item_sources) > 1
 
     launch()
 

cellxgene_gateway/items/file/fileitem.py

@@ -18,11 +18,10 @@ class FileItem(Item):
     The Item superclass expects a 'name' and 'type'.
     """
 
-    def __init__(self, subpath: str, ext: str = "", *args, **kwargs):
+    def __init__(self, subpath: str, *args, **kwargs):
         super().__init__(*args, **kwargs)
         self.subpath = subpath
-        self.ext = ext
 
     @property
     def descriptor(self) -> str:
-        return os.path.join(self.subpath, self.name + self.ext).strip("/")
+        return os.path.join(self.subpath, self.name).strip("/")

cellxgene_gateway/items/file/fileitem_source.py

@@ -67,7 +67,9 @@ class FileItemSource(ItemSource):
         base_path = os.path.join(self.base_path, subpath)
 
         if not os.path.exists(base_path):
-            raise Exception(f"Path for local files '{base_path}' does not exist.")
+            raise Exception(
+                f"Path for local files '{base_path}' does not exist."
+            )
 
         filepath_map = dict(
             (filepath, os.path.join(base_path, filepath))
@@ -93,12 +95,14 @@ class FileItemSource(ItemSource):
         ]
 
         items = [
-            self.make_fileitem_from_path(filename, subpath) for filename in h5ad_paths
+            self.make_fileitem_from_path(filename, subpath)
+            for filename in h5ad_paths
         ]
         branches = None
         if len(subdirs) > 0:
             branches = [
-                self.scan_directory(os.path.join(subpath, subdir)) for subdir in subdirs
+                self.scan_directory(os.path.join(subpath, subdir))
+                for subdir in subdirs
             ]
 
         return ItemTree(subpath, items, branches)
@@ -124,13 +128,14 @@ class FileItemSource(ItemSource):
     def lookup(self, indescriptor: str) -> LookupResult:
         descriptor = indescriptor.strip("/")
         if descriptor.endswith(self.annotation_file_suffix):
-            annotation_item = self.shallowitem_from_descriptor(descriptor, True)
+            annotation_item = self.shallowitem_from_descriptor(
+                descriptor, True
+            )
             h5ad_descriptor = self.convert_annotation_path_to_h5ad(
                 annotation_item.subpath
             )
             item = self.lookup_item(h5ad_descriptor)
             if item is not None:
-                dir_util.ensure_dir_exists(self.full_path(annotation_item.subpath))
                 return LookupResult(item, annotation_item)
         else:
             item = self.lookup_item(descriptor)
@@ -150,16 +155,9 @@ class FileItemSource(ItemSource):
     def make_fileitem_from_path(
         self, filename, subpath, is_annotation=False, is_shallow=False
     ) -> FileItem:
-        if is_annotation and filename.endswith(self.annotation_file_suffix):
-            name = filename[: -len(self.annotation_file_suffix)]
-            ext = self.annotation_file_suffix
-        else:
-            name = filename
-            ext = ""
         item = FileItem(
             subpath=subpath,
-            name=name,
-            ext=ext,
+            name=filename,
             type=ItemType.annotation if is_annotation else ItemType.h5ad,
         )
 
@@ -174,10 +172,14 @@ class FileItemSource(ItemSource):
         annotations_fullpath = self.full_path(annotations_subpath)
         if os.path.isdir(annotations_fullpath):
             return [
-                self.make_fileitem_from_path(annotation, annotations_subpath, True)
+                self.make_fileitem_from_path(
+                    annotation, annotations_subpath, True
+                )
                 for annotation in sorted(os.listdir(annotations_fullpath))
                 if annotation.endswith(self.annotation_file_suffix)
-                and os.path.isfile(os.path.join(annotations_fullpath, annotation))
+                and os.path.isfile(
+                    os.path.join(annotations_fullpath, annotation)
+                )
             ]
         else:
             return None

cellxgene_gateway/items/item.py

@@ -18,7 +18,9 @@ class ItemType(Enum):
 
 
 class Item(ABC):
-    def __init__(self, name: str, type: ItemType, annotations: List["Item"] = None):
+    def __init__(
+        self, name: str, type: ItemType, annotations: List["Item"] = None
+    ):
         self.name = name
         self.type = type
         self.annotations = annotations

cellxgene_gateway/items/s3/s3item_source.py

@@ -7,15 +7,13 @@
 # OR CONDITIONS OF ANY KIND, either express or implied. See the License for
 # the specific language governing permissions and limitations under the License.
 
-from os.path import basename, dirname, join
 from typing import List
-
-import s3fs
-
+from os.path import join, dirname, basename
 from cellxgene_gateway import dir_util
+import s3fs
+from cellxgene_gateway.items.s3.s3item import S3Item
 from cellxgene_gateway.items.item import ItemTree, ItemType
 from cellxgene_gateway.items.item_source import ItemSource, LookupResult
-from cellxgene_gateway.items.s3.s3item import S3Item
 
 
 class S3ItemSource(ItemSource):
@@ -29,20 +27,13 @@ class S3ItemSource(ItemSource):
     ):
         self._name = name
         self.s3 = s3fs.S3FileSystem()
-        if bucket.startswith("s3://"):
-            raise Exception(
-                f"Bucket name should not include s3:// prefix, got {bucket}"
-            )
         self.bucket = bucket
         self.h5ad_suffix = h5ad_suffix
         self.annotation_dir_suffix = annotation_dir_suffix
         self.annotation_file_suffix = annotation_file_suffix
 
-    def url(self, key):
-        return "s3://" + self.bucket + "/" + key
-
-    def remove_bucket(self, filepath):
-        return filepath[len(self.bucket) :].lstrip("/")
+    def url(self, path):
+        return "s3://" + join(self.bucket, path)
 
     @property
     def name(self):
@@ -64,44 +55,51 @@ class S3ItemSource(ItemSource):
         return self.convert_h5ad_key_to_annotation(item.descriptor)
 
     def list_items(self, filter: str = None) -> ItemTree:
-        item_tree = self.scan_directory("" if filter is None else filter)
+        item_tree = self.scan_directory()
         return item_tree
 
-    def scan_directory(self, directory_key="") -> dict:
-        url = self.url(directory_key)
+    def scan_directory(self, subpath="") -> dict:
+        url = self.url(subpath)
 
         if not self.s3.exists(url):
             raise Exception(f"S3 url '{url}' does not exist.")
 
         s3key_map = dict(
-            (self.remove_bucket(filepath), "s3://" + filepath)
+            (filepath[len(self.bucket) :], "s3://" + filepath)
             for filepath in sorted(self.s3.ls(url))
         )
 
         def is_annotation_dir(dir_s3key):
             return (
                 dir_s3key.endswith(self.annotation_dir_suffix)
-                and self.convert_annotation_key_to_h5ad(dir_s3key) in h5ad_keys
+                and self.convert_annotation_key_to_h5ad(dir_s3key)
+                in h5ad_paths
             )
 
-        h5ad_keys = [
+        h5ad_paths = [
             filepath
             for filepath, item_url in s3key_map.items()
             if self.is_h5ad_url(item_url)
         ]
 
-        subdir_keys = [
+        subdirs = [
             filepath
             for filepath, item_url in s3key_map.items()
             if self.s3.isdir(item_url) and not is_annotation_dir(filepath)
         ]
 
-        items = [self.make_s3item_from_key(basename(key), key) for key in h5ad_keys]
+        items = [
+            self.make_s3item_from_key(filename, join(subpath, filename))
+            for filename in h5ad_paths
+        ]
         branches = None
-        if len(subdir_keys) > 0:
-            branches = [self.scan_directory(key) for key in subdir_keys]
+        if len(subdirs) > 0:
+            branches = [
+                self.scan_directory(join(subpath, subdir))
+                for subdir in subdirs
+            ]
 
-        return ItemTree(directory_key, items, branches)
+        return ItemTree(subpath, items, branches)
 
     def create_annotation(self, item: S3Item, name: str) -> S3Item:
         annotation = self.make_s3item_from_key(
@@ -121,7 +119,9 @@ class S3ItemSource(ItemSource):
     def lookup(self, indescriptor: str) -> LookupResult:
         descriptor = indescriptor.strip("/")
         if descriptor.endswith(self.annotation_file_suffix):
-            annotation_item = self.shallowitem_from_descriptor(descriptor, True)
+            annotation_item = self.shallowitem_from_descriptor(
+                descriptor, True
+            )
             if not self.s3.exists(self.url(annotation_item.s3key)):
                 with self.s3.open(self.url(annotation_item.s3key), "w") as f:
                     f.write("")
@@ -161,11 +161,11 @@ class S3ItemSource(ItemSource):
         if self.s3.isdir(annotations_fullpath):
             return [
                 self.make_s3item_from_key(
-                    basename(annotation), self.remove_bucket(annotation), True
+                    annotation, join(annotations_subpath, annotation), True
                 )
                 for annotation in sorted(self.s3.ls(annotations_fullpath))
                 if annotation.endswith(self.annotation_file_suffix)
-                and self.s3.isfile("s3://" + annotation)
+                and self.s3.isfile(join(annotations_fullpath, annotation))
             ]
         else:
             return None

cellxgene_gateway/prune_process_cache.py

@@ -10,15 +10,14 @@
 import logging
 import time
 
-from cellxgene_gateway import env, util
-
-logger = logging.getLogger(__name__)
+from cellxgene_gateway.env import ttl
+from cellxgene_gateway.util import current_time_stamp
 
 
 class PruneProcessCache:
     def __init__(self, cache):
         self.cache = cache
-        self.expire_seconds = 3600 if env.ttl is None else int(env.ttl)
+        self.expire_seconds = 3600 if ttl is None else int(ttl)
 
     def __call__(self):
         while True:
@@ -26,20 +25,24 @@ class PruneProcessCache:
             self.prune()
 
     def prune(self):
-        timestamp = util.current_time_stamp()
+        timestamp = current_time_stamp()
         cutoff = timestamp - self.expire_seconds
-        processes_to_delete = [p for p in self.cache.entry_list if p.timestamp < cutoff]
+        processes_to_delete = [
+            p for p in self.cache.entry_list if p.timestamp < cutoff
+        ]
         processes_to_keep = [
             p for p in self.cache.entry_list if not p.timestamp < cutoff
         ]
-
+        logger = logging.getLogger("cellxgene_gateway")
         logger.debug(
-            f"Cutoff {cutoff} = timestamp {timestamp} - expire seconds {self.expire_seconds} , keeping {processes_to_keep}, pruning {processes_to_delete}"
+            f"Cutoff {cutoff} = timestamp {timestamp} - expire seconds {self.expire_seconds} , keeping {processes_to_keep}"
         )
 
         for process in processes_to_delete:
             try:
-                logger.info(f"pruning process {process.pid} ({process.key.dataset})")
+                logger.info(
+                    f"pruning process {process.pid} ({process.key.dataset})"
+                )
                 self.cache.prune(process)
             except Exception:
                 logger.exception(

cellxgene_gateway/static/js/annotation.js

@@ -1,5 +1,5 @@
 // neandertal javascript
-// Annotations only work with file itemsources at the moment. If they work with others in the future we may need to revisit this.
+// TODO: rewrite this --
 const new_annotation_callback = (() =>{
     const suffix = `.csv`;
     return (e) => {

cellxgene_gateway/subprocess_backend.py

@@ -14,7 +14,11 @@ from flask_api import status
 
 from cellxgene_gateway.cache_entry import CacheEntryStatus
 from cellxgene_gateway.dir_util import make_annotations
-from cellxgene_gateway.env import cellxgene_args, enable_annotations, enable_backed_mode
+from cellxgene_gateway.env import (
+    enable_annotations,
+    enable_backed_mode,
+    cellxgene_args,
+)
 from cellxgene_gateway.process_exception import ProcessException
 
 
@@ -22,10 +26,14 @@ class SubprocessBackend:
     def __init__(self):
         pass
 
-    def create_cmd(self, cellxgene_loc, file_path, port, scripts, annotation_file_path):
+    def create_cmd(
+        self, cellxgene_loc, file_path, port, scripts, annotation_file_path
+    ):
         if enable_annotations and not annotation_file_path is None:
             if annotation_file_path == "":
-                extra_args = f" --annotations-dir {make_annotations(file_path)}"
+                extra_args = (
+                    f" --annotations-dir {make_annotations(file_path)}"
+                )
             else:
                 extra_args = f" --annotations-file {annotation_file_path}"
         else:

cellxgene_gateway/templates/cache_status.html

@@ -48,7 +48,7 @@
                <tr>
                     <td>{{ entry.pid }}</td>
                     <td><a
-                              href="{{ entry.key.view_url }}">{{ entry.key.h5ad_item.descriptor }}</a>
+                              href="{{ url_for('do_view', path=entry.key.descriptor, source_name=entry.key.source_name) }}">{{ entry.key.h5ad_item.descriptor }}</a>
                     </td>
                     <td>{{ entry.key.annotation_descriptor }}</td>
                     <td>{{ entry.source_name }}</td>

cellxgene_gateway/templates/cellxgene_error.html

@@ -28,11 +28,11 @@
           
      <h4>{{ message }}</h4>
 
-     <a href="{{ url_for('filecrawl') }}">
+     <a href="/filecrawl.html">
           Please click here to be redirected to the file directory.
      </a>
      <br>
-     <a href="{{ url_for('index') }}">
+     <a href="/">
           Please click here to return to the homepage.
      </a>
      </div>

cellxgene_gateway/templates/filecrawl.html

@@ -36,10 +36,10 @@
           Navigation:
      <ul>
      {% if path %}
-     <li><a href="{{ url_for('filecrawl') }}">top level</a></li>
+     <li><a href="/filecrawl.html">top level</a></li>
      {% else %}
      {% endif %}
-     <li><a href="{{ url_for('index') }}">homepage</a></li>
+     <li><a href="/">homepage</a></li>
      </ul>
      </p>
      <script>

cellxgene_gateway/templates/index.html

@@ -35,12 +35,12 @@
 		Links:	
 	</h1>
 	<div class="list-group" style="width:50%;padding-left:65px">
-	  <a href="{{ url_for('filecrawl') }}" class="list-group-item list-group-item-action">
+	  <a href="/filecrawl.html" class="list-group-item list-group-item-action">
 		  <u>File Crawler: Allows you to view all uploaded data.</u></a>
 		  
 	</div>
 	<div class="list-group" style="width:50%;padding-left:65px">
-		<a href="{{ url_for('do_GET_status') }}" class="list-group-item list-group-item-action">
+		<a href="/cache_status" class="list-group-item list-group-item-action">
 			<u>Cache Status: view status of launched cellxgene servers.</u></a>
 	</div>
 	

cellxgene_gateway/templates/loading.html

@@ -35,11 +35,11 @@
           The page will refresh shortly.
      </p>
 
-     <a href="{{ url_for('filecrawl') }}">
+     <a href="/filecrawl.html">
           Please click here to be redirected to the file directory.
      </a>
      <br>
-     <a href="{{ url_for('index') }}">
+     <a href="/">
           Please click here to return to the homepage.
      </a>
      </div>

cellxgene_gateway/templates/process_error.html

@@ -36,13 +36,13 @@
 <h4>Options</h4>
      Please choose one of the following, or use the back button:
      <ul>
-          <li><a href="{{ relaunch_url }}">
+          <li><a href="{{url_for('do_relaunch', path=dataset)}}">
                     Attempt to relaunch the cellxgene server.
                </a></li>
-          <li><a href="{{ url_for('filecrawl') }}">
+          <li><a href="/filecrawl.html">
                Return to the file directory.
           </a></li>
-          <li><a href="{{ url_for('index') }}">
+          <li><a href="/">
                Return to the homepage.
           </a></li>
      </ul>

environment.yml

@@ -7,7 +7,6 @@ dependencies:
 - flask
 - psutil
 - black
-- coverage
 - pip
 - pip:
   - flask-api

tests/items/file/test_fileitem_source.py

@@ -1,22 +0,0 @@
-import tempfile
-import unittest
-
-from cellxgene_gateway.items.file.fileitem_source import FileItemSource
-
-
-class TestFileItemSource(unittest.TestCase):
-    def test_make_fileitem_from_path_GIVEN_annotation_file_THEN_name_lacks_csv(
-        self,
-    ):
-        source = FileItemSource(tempfile.gettempdir(), "local")
-        item = source.make_fileitem_from_path(
-            "customanno.csv", "someh5ad_annotations", True
-        )
-        self.assertEqual(item.name, "customanno")
-        self.assertEqual(item.descriptor, "someh5ad_annotations/customanno.csv")
-
-    def test_make_fileitem_from_path_GIVEN_h5ad_file_THEN_returns_name(self):
-        source = FileItemSource(tempfile.gettempdir(), "local")
-        item = source.make_fileitem_from_path("someanalysis.h5ad", "studydir")
-        self.assertEqual(item.name, "someanalysis.h5ad")
-        self.assertEqual(item.descriptor, "studydir/someanalysis.h5ad")

tests/items/s3/test_s3item_source.py

@@ -1,169 +0,0 @@
-import unittest
-from unittest.mock import MagicMock, Mock, patch
-
-from cellxgene_gateway.items.item import ItemType
-from cellxgene_gateway.items.s3.s3item import S3Item
-from cellxgene_gateway.items.s3.s3item_source import S3ItemSource
-
-
-class TestScanDirectory(unittest.TestCase):
-    @patch("s3fs.S3FileSystem")
-    def test_GIVEN_invalid_bucket_THEN_throws_error(self, s3func):
-        class S3Mock:
-            def exists(path):
-                if path in ["s3://my-bucket/"]:
-                    return False
-
-        s3func.return_value = S3Mock
-        source = S3ItemSource("my-bucket")
-        with self.assertRaises(Exception) as context:
-            source.scan_directory()
-        self.assertEqual(
-            "S3 url 's3://my-bucket/' does not exist.",
-            str(context.exception),
-        )
-
-    @patch("s3fs.S3FileSystem")
-    def test__GIVEN_multilevel_bucket_THEN_properly_recurses_suburls(self, s3func):
-        class S3Mock:
-            def exists(path):
-                if path in [
-                    "s3://my-bucket/",
-                    "s3://my-bucket/pbmc3k.h5ad",
-                    "s3://my-bucket/lvl1",
-                    "s3://my-bucket/lvl1/pbmc3k_l1.h5ad",
-                    "s3://my-bucket/lvl1/lvl2",
-                    "s3://my-bucket/lvl1/lvl2/pbmc3k_l2.h5ad",
-                ]:
-                    return True
-                raise Exception("exists called with " + path)
-
-            def ls(path):
-                if path == "s3://my-bucket/":
-                    return [
-                        "my-bucket/lvl1",
-                        "my-bucket/pbmc3k.h5ad",
-                        "my-bucket/pbmc3k_annotations",
-                    ]
-                elif path == "s3://my-bucket/pbmc3k_annotations":
-                    return ["my-bucket/pbmc3k_annotations/annot.csv"]
-                elif path == "s3://my-bucket/lvl1":
-                    return ["my-bucket/lvl1/lvl2", "my-bucket/lvl1/pbmc3k_l1.h5ad"]
-                elif path == "s3://my-bucket/lvl1/lvl2":
-                    return ["my-bucket/lvl1/lvl2/pbmc3k_l2.h5ad"]
-
-                raise Exception("ls called with " + path)
-
-            def isdir(path):
-                if path in [
-                    "s3://my-bucket/lvl1",
-                    "s3://my-bucket/pbmc3k_annotations",
-                    "s3://my-bucket/lvl1/lvl2",
-                ]:
-                    return True
-                if path in [
-                    "s3://my-bucket/pbmc3k.h5ad",
-                    "s3://my-bucket/lvl1/pbmc3k_l1.h5ad",
-                    "s3://my-bucket/lvl1/pbmc3k_l1_annotations",
-                    "s3://my-bucket/lvl1/lvl2/pbmc3k_l2.h5ad",
-                    "s3://my-bucket/lvl1/lvl2/pbmc3k_l2_annotations",
-                ]:
-                    return False
-                raise Exception("isdir called with " + path)
-
-            def isfile(path):
-                if path in ["s3://my-bucket/pbmc3k_annotations/annot.csv"]:
-                    return True
-                if path in ["s3://my-bucket/pbmc3k_annotations"]:
-                    return False
-                raise Exception("isfile called with " + path)
-
-        s3func.return_value = S3Mock
-        source = S3ItemSource("my-bucket")
-        tree = source.scan_directory()
-
-        def s3item_compare(i1, i2, msg=""):
-            self.assertEqual(i1.name, i2.name, "name equals")
-            self.assertEqual(i1.type, i2.type, "type equals")
-            self.assertEqual(i1.s3key, i2.s3key, "s3key equals")
-            if i1.annotations is None:
-                self.assertEqual(i1.annotations, i2.annotations, "annotations equals")
-            else:
-                self.assertEqual(
-                    len(i1.annotations),
-                    len(i2.annotations),
-                    "annotations length equals",
-                )
-                for a1, a2 in zip(i1.annotations, i2.annotations):
-                    self.assertEqual(a1, a2)
-            return True
-
-        self.addTypeEqualityFunc(S3Item, s3item_compare)
-
-        def assertTree(t, descriptor, items):
-            self.assertEqual(t.descriptor, descriptor)
-            self.assertEqual(len(t.items), len(items))
-            for i1, i2 in zip(t.items, items):
-                self.assertEqual(i1, i2)
-
-        assertTree(
-            tree,
-            "",
-            [
-                S3Item(
-                    "pbmc3k.h5ad",
-                    name="pbmc3k.h5ad",
-                    type=ItemType.h5ad,
-                    annotations=[
-                        S3Item(
-                            "pbmc3k_annotations/annot.csv",
-                            name="annot.csv",
-                            type=ItemType.annotation,
-                        )
-                    ],
-                )
-            ],
-        )
-        self.assertEqual(len(tree.branches), 1)
-        lvl1 = tree.branches[0]
-        assertTree(
-            lvl1,
-            "lvl1",
-            [
-                S3Item(
-                    "lvl1/pbmc3k_l1.h5ad",
-                    name="pbmc3k_l1.h5ad",
-                    type=ItemType.h5ad,
-                    annotations=None,
-                )
-            ],
-        )
-        self.assertEqual(len(lvl1.branches), 1)
-        lvl2 = lvl1.branches[0]
-        assertTree(
-            lvl2,
-            "lvl1/lvl2",
-            [
-                S3Item(
-                    "lvl1/lvl2/pbmc3k_l2.h5ad",
-                    name="pbmc3k_l2.h5ad",
-                    type=ItemType.h5ad,
-                    annotations=None,
-                )
-            ],
-        )
-        self.assertEqual(lvl2.branches, None)
-
-
-class TestListItems(unittest.TestCase):
-    def test_GIVEN_filter_THEN_pass_filter_into_scan_directory(self):
-        source = S3ItemSource("my-bucket")
-        source.scan_directory = MagicMock()
-        tree = source.list_items("some-filter")
-        source.scan_directory.assert_called_once_with("some-filter")
-
-    def test_GIVEN_no_filter_THEN_pass_empty_string_into_scan_directory(self):
-        source = S3ItemSource("my-bucket")
-        source.scan_directory = MagicMock()
-        tree = source.list_items()
-        source.scan_directory.assert_called_once_with("")

tests/test_cache_entry.py

@@ -1,62 +1,33 @@
 import unittest
-
-from flask import Flask
-
-from cellxgene_gateway import flask_util
 from cellxgene_gateway.cache_entry import CacheEntry, CacheEntryStatus
 from cellxgene_gateway.cache_key import CacheKey
-from cellxgene_gateway.gateway import app
+from cellxgene_gateway.items.item import ItemType
 from cellxgene_gateway.items.file.fileitem import FileItem
 from cellxgene_gateway.items.file.fileitem_source import FileItemSource
-from cellxgene_gateway.items.item import ItemType
 
 key = CacheKey(
-    FileItem("/czi/", name="pbmc3k.h5ad", type=ItemType.h5ad),
+    FileItem("/czi/", "pbmc3k.h5ad", ItemType.h5ad),
     FileItemSource("/tmp", "local"),
 )
 
 
 class TestRenderEntry(unittest.TestCase):
-    def setUp(self):
-        self.app = app
-        self.app_context = self.app.test_request_context()
-        self.app_context.push()
-        self.client = self.app.test_client()
-
     def test_GIVEN_key_and_port_THEN_returns_loading_CacheEntry(self):
         entry = CacheEntry.for_key("some-key", 1)
         self.assertEqual(entry.status, CacheEntryStatus.loading)
 
     def test_GIVEN_absolute_static_url_THEN_include_path(self):
-        flask_util.include_source_in_url = False
         actual = CacheEntry.for_key(key, 8000).rewrite_text_content(
             "src:url(/static/assets/"
         )
-        expected = "src:url(/view/czi/pbmc3k.h5ad/static/assets/"
+        expected = "src:url(http://localhost:5005/source/local/view/czi/pbmc3k.h5ad/static/assets/"
         self.assertEqual(actual, expected)
 
     def test_GIVEN_absolute_src_THEN_include_path(self):
-        flask_util.include_source_in_url = False
         actual = CacheEntry.for_key(key, 8000).rewrite_text_content(
             '<link rel="shortcut icon" href="/static/assets/favicon.ico">'
         )
-        expected = '<link rel="shortcut icon" href="/view/czi/pbmc3k.h5ad/static/assets/favicon.ico">'
-        self.assertEqual(actual, expected)
-
-    def test_GIVEN_absolute_static_url_include_source_THEN_include_path(self):
-        flask_util.include_source_in_url = True
-        actual = CacheEntry.for_key(key, 8000).rewrite_text_content(
-            "src:url(/static/assets/"
-        )
-        expected = "src:url(/source/local/view/czi/pbmc3k.h5ad/static/assets/"
-        self.assertEqual(actual, expected)
-
-    def test_GIVEN_absolute_src_include_source_THEN_include_path(self):
-        flask_util.include_source_in_url = True
-        actual = CacheEntry.for_key(key, 8000).rewrite_text_content(
-            '<link rel="shortcut icon" href="/static/assets/favicon.ico">'
-        )
-        expected = '<link rel="shortcut icon" href="/source/local/view/czi/pbmc3k.h5ad/static/assets/favicon.ico">'
+        expected = '<link rel="shortcut icon" href="http://localhost:5005/source/local/view/czi/pbmc3k.h5ad/static/assets/favicon.ico">'
         self.assertEqual(actual, expected)
 
 

tests/test_extra_scripts.py

@@ -21,15 +21,6 @@ class TestExtraScripts(unittest.TestCase):
     def test_GIVEN_empty_string_THEN_returns_empty_array(self):
         self.assertEqual(get_extra_scripts(), [])
 
-    @patch("cellxgene_gateway.env.extra_scripts", new="'asdf'")
-    def test_GIVEN_bare_string_THEN_throws_Exception(self):
-        with self.assertRaises(Exception) as context:
-            self.assertEqual(get_extra_scripts(), [])
-        self.assertEqual(
-            'Error parsing GATEWAY_EXTRA_SCRIPTS, expected JSON array e.g. ["https://example.com/path/to/script.js"]',
-            str(context.exception),
-        )
-
 
 if __name__ == "__main__":
     unittest.main()

tests/test_filecrawl.py

@@ -1,17 +1,19 @@
 import unittest
 from unittest.mock import MagicMock, patch
 
-from cellxgene_gateway.filecrawl import render_item, render_item_source
+from cellxgene_gateway.filecrawl import render_item
+from cellxgene_gateway.items.item import ItemType
 from cellxgene_gateway.items.file.fileitem import FileItem
 from cellxgene_gateway.items.file.fileitem_source import FileItemSource
-from cellxgene_gateway.items.item import ItemTree, ItemType
 
 source = FileItemSource("/tmp")
 
 
 class TestRenderEntry(unittest.TestCase):
     def test_GIVEN_path_both_slash_THEN_view_has_single_slash(self):
-        entry = FileItem(subpath="/somepath/", name="entry", type=ItemType.h5ad)
+        entry = FileItem(
+            subpath="/somepath/", name="entry", type=ItemType.h5ad
+        )
         rendered = render_item(entry, source)
         self.assertIn("view/somepath/entry/'", rendered)
 
@@ -29,15 +31,3 @@ class TestRenderEntry(unittest.TestCase):
         entry = FileItem(subpath="somepath", name="entry", type=ItemType.h5ad)
         rendered = render_item(entry, source)
         self.assertIn("view/somepath/entry/'", rendered)
-
-
-class TestRenderItemSource(unittest.TestCase):
-    @patch("cellxgene_gateway.items.file.fileitem_source.FileItemSource")
-    def test_GIVEN_some_filter_THEN_includes_filterpart_in_heading(self, item_source):
-        item_source.name = "FakeSource"
-        item_source.list_items.return_value = ItemTree("rootdir", [], [])
-        rendered = render_item_source(item_source, "some_filter")
-        self.assertEqual(
-            rendered,
-            "<h6><a href='/filecrawl.html?source=FakeSource'>FakeSource</a>:some_filter</h6><li><a href='/filecrawl/rootdir?source=FakeSource'>rootdir</a><ul></ul></li>",
-        )

tests/test_subprocess_backend.py

@@ -1,42 +0,0 @@
-import unittest
-from unittest.mock import MagicMock, patch
-
-from cellxgene_gateway.backend_cache import BackendCache
-from cellxgene_gateway.cache_entry import CacheEntry
-from cellxgene_gateway.cache_key import CacheKey
-from cellxgene_gateway.items.file.fileitem import FileItem
-from cellxgene_gateway.items.file.fileitem_source import FileItemSource
-from cellxgene_gateway.items.item import ItemType
-from cellxgene_gateway.process_exception import ProcessException
-
-
-class TestSubprocessBackend(unittest.TestCase):
-    @patch("subprocess.Popen")
-    def test_launch_GIVEN_no_stdout_THEN_throw_ProcessException(self, popen):
-        subprocess = MagicMock()
-        subprocess.stdout.readline().decode.return_value = ""
-        subprocess.stderr.read().decode.return_value = "An unexpected error"
-        popen.return_value = subprocess
-
-        key = CacheKey(
-            FileItem("/czi/", name="pbmc3k.h5ad", type=ItemType.h5ad),
-            FileItemSource("/tmp", "local"),
-        )
-        entry = CacheEntry.for_key(key, 8000)
-        from cellxgene_gateway.subprocess_backend import SubprocessBackend
-
-        backend = SubprocessBackend()
-        cellxgene_loc = "/some/cellxgene"
-        scripts = ["http://example.com/script.js", "http://example.com/script2.js"]
-
-        with self.assertRaises(ProcessException) as context:
-            backend.launch(cellxgene_loc, scripts, entry)
-        popen.assert_called_once_with(
-            [
-                "yes | /some/cellxgene launch /tmp/czi/pbmc3k.h5ad --port 8000 --host 127.0.0.1 --disable-annotations --scripts http://example.com/script.js --scripts http://example.com/script2.js"
-            ],
-            shell=True,
-            stderr=-1,
-            stdout=-1,
-        )
-        self.assertEqual("An unexpected error", context.exception.stderr)