Use api_deploy.create_distribution to avoid circular import

Author: Tahoora-Tabassum

databusclient/cli.py

@@ -4,6 +4,7 @@
 from typing import List
 
 import click
+import re
 
 import databusclient.api.deploy as api_deploy
 from databusclient.api.delete import delete as api_delete
@@ -213,5 +214,51 @@ def delete(databusuris: List[str], databus_key: str, dry_run: bool, force: bool)
     )
 
 
+@app.command()
+@click.argument("url")
+@click.option("--cv", "cvs", multiple=True, help="Content variant like key=value (repeatable). Keys must not contain '|' or '_'")
+@click.option("--format", "file_format", help="Format extension (e.g. ttl)")
+@click.option("--compression", help="Compression (e.g. gzip)")
+@click.option("--sha-length", help="sha256:length (64 hex chars followed by ':' and integer length)")
+@click.option("--json-output", is_flag=True, help="Output JSON distribution object instead of plain string")
+def mkdist(url, cvs, file_format, compression, sha_length, json_output):
+    """Create a distribution string from components."""
+    # Validate CVs
+    cvs_dict = {}
+    for cv in cvs:
+        if "=" not in cv:
+            raise click.BadParameter(f"Invalid content variant '{cv}': expected key=value")
+        key, val = cv.split("=", 1)
+        if any(ch in key for ch in ("|", "_")):
+            raise click.BadParameter("Invalid characters in content-variant key (forbidden: '|' and '_')")
+        if key in cvs_dict:
+            raise click.BadParameter(f"Duplicate content-variant key '{key}'")
+        cvs_dict[key] = val
+
+    # Validate sha-length
+    sha_tuple = None
+    if sha_length:
+        if not re.match(r'^[A-Fa-f0-9]{64}:\d+$', sha_length):
+            raise click.BadParameter("Invalid --sha-length; expected SHA256HEX:length")
+        sha, length = sha_length.split(":", 1)
+        sha_tuple = (sha, int(length))
+
+    # Deterministic ordering
+    sorted_cvs = {k: cvs_dict[k] for k in sorted(cvs_dict)}
+
+    dist = api_deploy.create_distribution(url=url, cvs=sorted_cvs, file_format=file_format, compression=compression, sha256_length_tuple=sha_tuple)
+    if json_output:
+        import json as _json
+        click.echo(_json.dumps({"distribution": dist}))
+    else:
+        click.echo(dist)
+
+
+@app.command()
+@click.argument("shell", type=click.Choice(["bash","zsh","fish","powershell"]), required=False)
+def completion(shell="bash"):
+    click.echo(f"Run: eval \"$(_DATABUSCLIENT_COMPLETE=source_{shell} python -m databusclient)\"")
+
+
 if __name__ == "__main__":
     app()