Added reindex_version for the latest version of the gobbler backend.

Author: LTLA

src/pygobbler/__init__.py

@@ -34,6 +34,7 @@
 from .remove_asset import remove_asset
 from .remove_version import remove_version
 from .clone_version import clone_version
+from .reindex_version import reindex_version
 from .service_info import service_info
 from .version_path import version_path
 from .refresh_latest import refresh_latest

src/pygobbler/reindex_version.py

@@ -0,0 +1,28 @@
+from . import _utils as ut
+
+
+def reindex_version(project: str, asset: str, version: str, staging: str, url: str):
+    """
+    Reindex a version of a project asset in the registry.
+    This regenerates all of the internal ``..manifest`` and ``..links`` files.
+
+    Args:
+        project:
+            The name of the project.
+
+        asset:
+            The name of the asset of the ``project``.
+
+        version:
+            The name of the version of the ``asset`` to remove.
+
+        staging:
+            Path to the staging directory.
+
+        url:
+            URL to the Gobbler REST API.
+
+    Returns:
+        The requested version is reindexed.
+    """
+    ut.dump_request(staging, url, "reindex_version", { "project": project, "asset": asset, "version": version })

src/pygobbler/start_gobbler.py

@@ -14,7 +14,7 @@ def start_gobbler(
     registry: Optional[str] = None,
     port: Optional[int] = None,
     wait: float = 1,
-    version: str = "0.3.7",
+    version: str = "0.3.8",
     overwrite: bool = False) -> Tuple[bool, str, str, str]:
     """
     Start a test Gobbler service.

tests/test_reindex_version.py

@@ -0,0 +1,30 @@
+import pygobbler as pyg
+import tempfile
+import os
+import time
+import pytest
+
+
+def test_reindex_version():
+    _, staging, registry, url = pyg.start_gobbler()
+
+    pyg.remove_project("test-reindex", staging=staging, url=url)
+    pyg.create_project("test-reindex", staging=staging, url=url)
+
+    src = pyg.allocate_upload_directory(staging)
+    with open(os.path.join(src, "foo"), "w") as handle:
+        handle.write("BAR")
+    pyg.upload_directory("test-reindex", "simple", "v1", src, staging=staging, url=url)
+
+    # Adding another file directly to the registry.
+    with open(os.path.join(registry, "test-reindex", "simple", "v1", "whee"), "w") as handle:
+        handle.write("stuff")
+
+    # This does not show up in the manifest...
+    man = pyg.fetch_manifest("test-reindex", "simple", "v1", registry=registry, url=url)
+    assert list(man.keys()) == ["foo"]
+
+    # until we reindex the version.
+    pyg.reindex_version("test-reindex", "simple", "v1", staging=staging, url=url)
+    man = pyg.fetch_manifest("test-reindex", "simple", "v1", registry=registry, url=url)
+    assert sorted(list(man.keys())) == ["foo", "whee"]