Add pulp_rust CLI impl + tests

CHANGES/+rust-cli.feature

@@ -0,0 +1 @@
+Added CLI support for the unreleased / tech-preview "pulp_rust" plugin, for creating local private registries and mirrors of public registries (i.e. crates.io) for Rust package content.

pulp-glue/src/pulp_glue/rust/context.py

@@ -0,0 +1,63 @@
+from pulp_glue.common.context import (
+    PluginRequirement,
+    PulpContentContext,
+    PulpDistributionContext,
+    PulpRemoteContext,
+    PulpRepositoryContext,
+    PulpRepositoryVersionContext,
+)
+from pulp_glue.common.i18n import get_translation
+
+translation = get_translation(__package__)
+_ = translation.gettext
+
+
+class PulpRustContentContext(PulpContentContext):
+    PLUGIN = "rust"
+    RESOURCE_TYPE = "packages"
+    ENTITY = _("rust package")
+    ENTITIES = _("rust packages")
+    HREF = "rust_rust_package_content_href"
+    ID_PREFIX = "content_rust_packages"
+    NEEDS_PLUGINS = [PluginRequirement("rust")]
+
+
+class PulpRustDistributionContext(PulpDistributionContext):
+    PLUGIN = "rust"
+    RESOURCE_TYPE = "rust"
+    ENTITY = _("rust distribution")
+    ENTITIES = _("rust distributions")
+    HREF = "rust_rust_distribution_href"
+    ID_PREFIX = "distributions_rust_rust"
+    NEEDS_PLUGINS = [PluginRequirement("rust")]
+
+
+class PulpRustRemoteContext(PulpRemoteContext):
+    PLUGIN = "rust"
+    RESOURCE_TYPE = "rust"
+    ENTITY = _("rust remote")
+    ENTITIES = _("rust remotes")
+    HREF = "rust_rust_remote_href"
+    ID_PREFIX = "remotes_rust_rust"
+    NEEDS_PLUGINS = [PluginRequirement("rust")]
+
+
+class PulpRustRepositoryVersionContext(PulpRepositoryVersionContext):
+    HREF = "rust_rust_repository_version_href"
+    ID_PREFIX = "repositories_rust_rust_versions"
+    NEEDS_PLUGINS = [PluginRequirement("rust")]
+
+
+class PulpRustRepositoryContext(PulpRepositoryContext):
+    PLUGIN = "rust"
+    RESOURCE_TYPE = "rust"
+    HREF = "rust_rust_repository_href"
+    ENTITY = _("rust repository")
+    ENTITIES = _("rust repositories")
+    ID_PREFIX = "repositories_rust_rust"
+    VERSION_CONTEXT = PulpRustRepositoryVersionContext
+    CAPABILITIES = {
+        "sync": [PluginRequirement("rust")],
+    }
+    NULLABLES = PulpRepositoryContext.NULLABLES | {"remote"}
+    NEEDS_PLUGINS = [PluginRequirement("rust")]

pyproject.toml

@@ -51,6 +51,7 @@ core = "pulpcore.cli.core"
 file = "pulpcore.cli.file"
 python = "pulpcore.cli.python"
 rpm = "pulpcore.cli.rpm"
+rust = "pulpcore.cli.rust"
 
 [tool.setuptools.packages.find]
 # This section is managed by the cookiecutter templates.

src/pulpcore/cli/rust/__init__.py

@@ -0,0 +1,27 @@
+import typing as t
+
+import click
+
+from pulp_glue.common.i18n import get_translation
+
+from pulp_cli.generic import pulp_group
+from pulpcore.cli.rust.content import content
+from pulpcore.cli.rust.distribution import distribution
+from pulpcore.cli.rust.remote import remote
+from pulpcore.cli.rust.repository import repository
+
+translation = get_translation(__package__)
+_ = translation.gettext
+
+
+@pulp_group(name="rust")
+def rust_group() -> None:
+    pass
+
+
+def mount(main: click.Group, **kwargs: t.Any) -> None:
+    rust_group.add_command(repository)
+    rust_group.add_command(remote)
+    rust_group.add_command(distribution)
+    rust_group.add_command(content)
+    main.add_command(rust_group)

src/pulpcore/cli/rust/content.py

@@ -0,0 +1,50 @@
+import click
+
+from pulp_glue.common.i18n import get_translation
+from pulp_glue.rust.context import PulpRustContentContext
+
+from pulp_cli.generic import (
+    PulpCLIContext,
+    content_filter_options,
+    href_option,
+    list_command,
+    pass_pulp_context,
+    pulp_group,
+    show_command,
+)
+
+translation = get_translation(__package__)
+_ = translation.gettext
+
+
+@pulp_group()
+@click.option(
+    "-t",
+    "--type",
+    "content_type",
+    type=click.Choice(["rust"], case_sensitive=False),
+    default="rust",
+)
+@pass_pulp_context
+@click.pass_context
+def content(ctx: click.Context, pulp_ctx: PulpCLIContext, /, content_type: str) -> None:
+    if content_type == "rust":
+        ctx.obj = PulpRustContentContext(pulp_ctx)
+    else:
+        raise NotImplementedError()
+
+
+lookup_options = [
+    href_option,
+]
+
+content.add_command(
+    list_command(
+        decorators=[
+            click.option("--name"),
+            click.option("--vers"),
+            *content_filter_options,
+        ]
+    )
+)
+content.add_command(show_command(decorators=lookup_options))

src/pulpcore/cli/rust/distribution.py

@@ -0,0 +1,106 @@
+import click
+
+from pulp_glue.common.i18n import get_translation
+from pulp_glue.rust.context import (
+    PulpRustDistributionContext,
+    PulpRustRemoteContext,
+    PulpRustRepositoryContext,
+)
+
+from pulp_cli.generic import (
+    PulpCLIContext,
+    common_distribution_create_options,
+    content_guard_option,
+    create_command,
+    destroy_command,
+    distribution_filter_options,
+    distribution_lookup_option,
+    href_option,
+    label_command,
+    list_command,
+    name_option,
+    pass_pulp_context,
+    pulp_group,
+    pulp_labels_option,
+    pulp_option,
+    resource_option,
+    show_command,
+    update_command,
+)
+
+translation = get_translation(__package__)
+_ = translation.gettext
+
+
+repository_option = resource_option(
+    "--repository",
+    default_plugin="rust",
+    default_type="rust",
+    context_table={"rust:rust": PulpRustRepositoryContext},
+    href_pattern=PulpRustRepositoryContext.HREF_PATTERN,
+    help=_(
+        "Repository to be used for auto-distributing."
+        " Specified as '[[<plugin>:]<type>:]<name>' or as href."
+    ),
+)
+
+
+@pulp_group()
+@click.option(
+    "-t",
+    "--type",
+    "distribution_type",
+    type=click.Choice(["rust"], case_sensitive=False),
+    default="rust",
+)
+@pass_pulp_context
+@click.pass_context
+def distribution(ctx: click.Context, pulp_ctx: PulpCLIContext, /, distribution_type: str) -> None:
+    if distribution_type == "rust":
+        ctx.obj = PulpRustDistributionContext(pulp_ctx)
+    else:
+        raise NotImplementedError()
+
+
+lookup_options = [href_option, name_option, distribution_lookup_option]
+nested_lookup_options = [distribution_lookup_option]
+update_options = [
+    repository_option,
+    pulp_option(
+        "--version",
+        type=int,
+        help=_(
+            "The repository version number to distribute."
+            " When unset, the latest version of the repository will be auto-distributed."
+        ),
+    ),
+    resource_option(
+        "--remote",
+        default_plugin="rust",
+        default_type="rust",
+        context_table={"rust:rust": PulpRustRemoteContext},
+        href_pattern=PulpRustRemoteContext.HREF_PATTERN,
+        help=_(
+            "Remote to use for pull-through caching."
+            " Specified as '[[<plugin>:]<type>:]<name>' or as href."
+        ),
+    ),
+    content_guard_option,
+    pulp_labels_option,
+    pulp_option(
+        "--allow-uploads/--no-allow-uploads",
+        is_flag=True,
+        default=None,
+        help=_("Allow publishing crates via ``cargo publish``."),
+    ),
+]
+create_options = common_distribution_create_options + update_options
+
+distribution.add_command(list_command(decorators=distribution_filter_options))
+distribution.add_command(show_command(decorators=lookup_options))
+distribution.add_command(create_command(decorators=create_options))
+distribution.add_command(
+    update_command(decorators=lookup_options + update_options + [click.option("--base-path")])
+)
+distribution.add_command(destroy_command(decorators=lookup_options))
+distribution.add_command(label_command(decorators=nested_lookup_options))

src/pulpcore/cli/rust/remote.py

@@ -0,0 +1,60 @@
+import click
+
+from pulp_glue.common.i18n import get_translation
+from pulp_glue.rust.context import PulpRustRemoteContext
+
+from pulp_cli.generic import (
+    PulpCLIContext,
+    common_remote_create_options,
+    common_remote_update_options,
+    create_command,
+    destroy_command,
+    href_option,
+    label_command,
+    list_command,
+    name_option,
+    pass_pulp_context,
+    pulp_group,
+    remote_filter_options,
+    remote_lookup_option,
+    show_command,
+    update_command,
+)
+
+translation = get_translation(__package__)
+_ = translation.gettext
+
+
+@pulp_group()
+@click.option(
+    "-t",
+    "--type",
+    "remote_type",
+    type=click.Choice(["rust"], case_sensitive=False),
+    default="rust",
+)
+@pass_pulp_context
+@click.pass_context
+def remote(ctx: click.Context, pulp_ctx: PulpCLIContext, /, remote_type: str) -> None:
+    if remote_type == "rust":
+        ctx.obj = PulpRustRemoteContext(pulp_ctx)
+    else:
+        raise NotImplementedError()
+
+
+lookup_options = [href_option, name_option, remote_lookup_option]
+nested_lookup_options = [remote_lookup_option]
+rust_remote_options = [
+    click.option(
+        "--policy", type=click.Choice(["immediate", "on_demand", "streamed"], case_sensitive=False)
+    ),
+]
+
+remote.add_command(list_command(decorators=remote_filter_options))
+remote.add_command(show_command(decorators=lookup_options))
+remote.add_command(create_command(decorators=common_remote_create_options + rust_remote_options))
+remote.add_command(
+    update_command(decorators=lookup_options + common_remote_update_options + rust_remote_options)
+)
+remote.add_command(destroy_command(decorators=lookup_options))
+remote.add_command(label_command(decorators=nested_lookup_options))