Install a curated registry of crates with libraries

This largely mirrors the approach taken by major Linux distributions
like Ubuntu and Fedora. We can curate the crates in a way that should
allow us to use them in downstream package builds within this colcon
workspace or downstream workspaces.

This change doesn't yet add the code necessary to instruct cargo to use
our curated registry.

Author: cottsay

colcon_cargo/task/cargo/build.py

@@ -10,6 +10,7 @@
 from colcon_core.logging import colcon_logger
 from colcon_core.plugin_system import satisfies_version
 from colcon_core.shell import create_environment_hook, get_command_environment
+from colcon_core.task import install
 from colcon_core.task import run
 from colcon_core.task import TaskExtensionPoint
 
@@ -96,6 +97,11 @@ async def build(  # noqa: D102
             if rc and rc.returncode:
                 return rc.returncode
 
+        if self._has_libraries(metadata, pkg.name):
+            self.progress('package')
+            await self._install_package(
+                metadata['packages'][0]['version'], env)
+
         if not skip_hook_creation:
             create_environment_scripts(
                 pkg, args, additional_hooks=additional_hooks)
@@ -197,3 +203,79 @@ def _has_binaries(metadata, package_name):
         # If no binary target exists in the whole package, then skip running
         # cargo install because it would produce an error.
         return False
+
+    # Identify if there are any libraries to install for the current package
+    @staticmethod
+    def _has_libraries(metadata, package_name):
+        for package in metadata.get('packages', {}):
+            # If the package is part of a cargo workspace, the metadata
+            # contains all members. We're only interested in our target
+            # package - ignore the other workspace members here.
+            if package.get('name') != package_name:
+                continue
+            for target in package.get('targets', {}):
+                if {
+                    'lib',
+                    'rlib',
+                    'proc-macro',
+                }.intersection(target.get('crate_types', ())):
+                    # If any one binary exists in the package then we
+                    # should go ahead and install the extracted crate
+                    return True
+
+        # If no library target exists in the whole package, then skip extracted
+        # crate installation because it isn't useful.
+        return False
+
+    # Determine what files would be part of a packaged crate
+    async def _get_crate_contents(self, env):
+        pkg = self.context.pkg
+        cmd = [
+            CARGO_EXECUTABLE,
+            'package',
+            '--list',
+            '--allow-dirty',
+            '--quiet',
+            '--package', pkg.name,
+        ]
+
+        rc = await run(
+            self.context,
+            cmd,
+            cwd=self.context.pkg.path,
+            capture_output=True,
+            env=env
+        )
+        if rc is None or rc.returncode != 0:
+            raise RuntimeError(
+                "Could not inspect package using 'cargo package'"
+            )
+
+        if rc.stdout is None:
+            raise RuntimeError(
+                "Failed to capture stdout from 'cargo package'"
+            )
+
+        contents = set(rc.stdout.decode().splitlines())
+        contents.difference_update({
+            # Ignore stuff that we wouldn't want to copy
+            '',
+            None,
+            'Cargo.lock',
+            'Cargo.toml.orig',
+            '.cargo_vcs_info.json',
+        })
+        return contents
+
+    async def _install_package(self, version, env):
+        contents = await self._get_crate_contents(env)
+        crate_path = Path(
+            'share', 'cargo', 'registry', f'{self.context.pkg.name}-{version}')
+        crate_path.mkdir(parents=True, exist_ok=True)
+
+        for file in contents:
+            dst = crate_path / file
+            install(self.context.args, file, dst)
+
+        (crate_path / '.cargo-checksum.json').write_text(
+            '{"files":{},"package":""}\n')

test/spell_check.words

@@ -2,6 +2,7 @@ apache
 argcomplete
 asyncio
 autouse
+checksum
 colcon
 completers
 cwpd
@@ -26,6 +27,7 @@ pydocstyle
 pytest
 returncode
 rglob
+rlib
 rmtree
 rtype
 rustfmt

test/test_build.py

@@ -166,6 +166,7 @@ def test_build_and_test_package():
                                       path=str(test_project_path),
                                       build_base=str(tmpdir / 'build'),
                                       install_base=str(tmpdir / 'install'),
+                                      symlink_install=False,
                                       clean_build=None,
                                       cargo_args=None,
                                   ),
@@ -232,6 +233,7 @@ def test_skip_pure_library_package():
                                       path=str(pure_library_path),
                                       build_base=str(tmpdir / 'build'),
                                       install_base=str(tmpdir / 'install'),
+                                      symlink_install=False,
                                       clean_build=None,
                                       cargo_args=None,
                                   ),
@@ -286,6 +288,7 @@ def test_workspace_with_package():
                                       path=str(workspace_project_path),
                                       build_base=str(tmpdir / 'build'),
                                       install_base=str(tmpdir / 'install'),
+                                      symlink_install=False,
                                       clean_build=None,
                                       cargo_args=None,
                                   ),
@@ -311,5 +314,12 @@ def test_workspace_with_package():
             # members didn't get installed as well
             assert len(tuple((install_base / 'bin').iterdir())) == 1
 
+            # There should also be an unpacked library create
+            registry_path = install_base / 'share' / 'cargo' / 'registry'
+            crate_path = registry_path / f'{WORKSPACE_PACKAGE_NAME}-0.1.0'
+            assert tuple(registry_path.iterdir()) == (crate_path,)
+            assert (crate_path / 'Cargo.toml').is_file()
+            assert (crate_path / 'src' / 'lib.rs').is_file()
+
     finally:
         event_loop.close()