feat: add cache clear CLI command

Author: aleks-iv

README.md

@@ -36,6 +36,14 @@ None at present
 ckanext.iso19115.misc.cache_dir = /var/data/iso19115_cache
 ```
 
+## CLI
+
+Clear compiled schema caches:
+
+```sh
+ckan -c /path/to/ckan.ini iso19115 cache clear
+```
+
 ## Usage
 
 Customize the way of mapping dataset into ISO 19115 by implementing `IIso18115` interface.

ckanext/iso19115/cli.py

@@ -81,6 +81,52 @@ def build_example(
     click.echo(example)
 
 
+@iso19115.group()
+def cache():
+    """Cache management."""
+    pass
+
+
+@cache.command("clear")
+def cache_clear():
+    """Remove compiled schema cache files."""
+    cache_dir = utils.get_cache_dir(create=False)
+    persistent_dir = tk.config.get(utils.CONFIG_CACHE_DIR)
+
+    if not persistent_dir:
+        click.echo(
+            f"Persistent cache directory is not configured "
+            f"({utils.CONFIG_CACHE_DIR}). Using temporary path: {cache_dir}"
+        )
+
+    if not cache_dir.exists():
+        click.echo(f"Cache directory {cache_dir} does not exist.")
+        return
+
+    if not cache_dir.is_dir():
+        raise click.ClickException(f"Cache path {cache_dir} is not a directory.")
+
+    removed = 0
+    errors = []
+    for cache_file in cache_dir.glob("*.pickle"):
+        try:
+            cache_file.unlink()
+            removed += 1
+        except OSError as exc:
+            errors.append((cache_file, exc))
+
+    for path, exc in errors:
+        tk.error_shout(f"Failed to remove {path}: {exc}")
+
+    if errors:
+        raise click.ClickException("Unable to clear cache completely.")
+
+    if removed:
+        click.secho(f"Removed {removed} cache file(s) from {cache_dir}", fg="green")
+    else:
+        click.echo(f"No cache files found in {cache_dir}")
+
+
 @iso19115.group()
 def validate():
     """Validate data agains ISO 19115 schema."""

ckanext/iso19115/utils.py

@@ -85,9 +85,15 @@
     ), f"Schema {f} does not exists. Have you extracted namespaces.zip?"
 
 
-def _get_cache_path(name):
+def get_cache_dir(create: bool = True) -> Path:
     cache_dir = Path(tk.config.get(CONFIG_CACHE_DIR) or _tempdir)
-    cache_dir.mkdir(parents=True, exist_ok=True)
+    if create:
+        cache_dir.mkdir(parents=True, exist_ok=True)
+    return cache_dir
+
+
+def _get_cache_path(name):
+    cache_dir = get_cache_dir()
     return cache_dir / f"{name}.pickle"
 
 

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "ckanext-iso19115"
-version = "0.2.1"
+version = "0.2.2"
 description = ""
 classifiers = [ "Development Status :: 4 - Beta", "License :: OSI Approved :: GNU Affero General Public License v3 or later (AGPLv3+)", "Programming Language :: Python :: 3.7", "Programming Language :: Python :: 3.8", "Programming Language :: Python :: 3.9", "Programming Language :: Python :: 3.10",]
 keywords = [ "CKAN",]