merge main

Author: Phil Cummins

src/lib.rs

@@ -11,9 +11,7 @@ use {
     serde::Deserialize,
     std::{
         collections::HashMap,
-        env, fs,
-        io::Cursor,
-        iter,
+        fs, iter,
         ops::Deref,
         path::{Path, PathBuf},
         str,
@@ -34,6 +32,7 @@ mod abi;
 mod bindgen;
 mod bindings;
 pub mod command;
+mod link;
 mod prelink;
 #[cfg(feature = "pyo3")]
 mod python;
@@ -326,29 +325,7 @@ pub async fn componentize(
         dl_openable: false,
     });
 
-    // Link all the libraries (including any native extensions) into a single component.
-    let mut linker = wit_component::Linker::default()
-        .validate(true)
-        .use_built_in_libdl(true);
-
-    for Library {
-        name,
-        module,
-        dl_openable,
-    } in &libraries
-    {
-        linker = linker.library(name, module, *dl_openable)?;
-    }
-
-    linker = linker.adapter(
-        "wasi_snapshot_preview1",
-        &zstd::decode_all(Cursor::new(include_bytes!(concat!(
-            env!("OUT_DIR"),
-            "/wasi_snapshot_preview1.reactor.wasm.zst"
-        ))))?,
-    )?;
-
-    let component = linker.encode()?;
+    let component = link::link_libraries(&libraries)?;
 
     let stubbed_component = if stub_wasi {
         stubwasi::link_stub_modules(libraries)?

src/link.rs

@@ -0,0 +1,30 @@
+use std::io::Cursor;
+
+use anyhow::{anyhow, Error};
+
+use crate::Library;
+
+pub fn link_libraries(libraries: &[Library]) -> Result<Vec<u8>, Error> {
+    let mut linker = wit_component::Linker::default()
+        .validate(true)
+        .use_built_in_libdl(true);
+
+    for Library {
+        name,
+        module,
+        dl_openable,
+    } in libraries
+    {
+        linker = linker.library(name, module, *dl_openable)?;
+    }
+
+    linker = linker.adapter(
+        "wasi_snapshot_preview1",
+        &zstd::decode_all(Cursor::new(include_bytes!(concat!(
+            env!("OUT_DIR"),
+            "/wasi_snapshot_preview1.reactor.wasm.zst"
+        ))))?,
+    )?;
+
+    return linker.encode().map_err(|e| anyhow!(e));
+}

src/prelink.rs

@@ -8,7 +8,7 @@ use std::{
     path::{Path, PathBuf},
 };
 
-use anyhow::{anyhow, bail, Context, Result};
+use anyhow::{anyhow, bail, Context, Error, Result};
 use indexmap::IndexMap;
 use tar::Archive;
 use tempfile::TempDir;
@@ -21,7 +21,7 @@ static NATIVE_EXTENSION_SUFFIX: &str = ".cpython-312-wasm32-wasi.so";
 type ConfigsMatchedWorlds<'a> =
     IndexMap<String, (ConfigContext<ComponentizePyConfig>, Option<&'a str>)>;
 
-pub fn embedded_python_standard_library() -> Result<TempDir, io::Error> {
+pub fn embedded_python_standard_library() -> Result<TempDir, Error> {
     // Untar the embedded copy of the Python standard library into a temporary directory
     let stdlib = tempfile::tempdir()?;
 
@@ -50,8 +50,8 @@ pub fn embedded_helper_utils() -> Result<TempDir, io::Error> {
 }
 
 pub fn bundle_libraries(
-    library_path: Vec<(&str, Vec<PathBuf>)>,
-) -> Result<Vec<Library>, anyhow::Error> {
+    library_path: Vec<(&str, Vec<std::path::PathBuf>)>,
+) -> Result<Vec<Library>, Error> {
     let mut libraries = vec![
         Library {
             name: "libcomponentize_py_runtime.so".into(),
@@ -152,9 +152,10 @@ pub fn search_for_libraries_and_configs<'a>(
     python_path: &'a Vec<&'a str>,
     module_worlds: &'a [(&'a str, &'a str)],
     world: Option<&'a str>,
-) -> Result<(ConfigsMatchedWorlds<'a>, Vec<Library>), anyhow::Error> {
-    let mut raw_configs: Vec<ConfigContext<RawComponentizePyConfig>> = Vec::new();
-    let mut library_path: Vec<(&str, Vec<PathBuf>)> = Vec::with_capacity(python_path.len());
+) -> Result<(ConfigsMatchedWorlds<'a>, Vec<Library>), Error> {
+    let mut raw_configs: Vec<crate::ConfigContext<crate::RawComponentizePyConfig>> = Vec::new();
+    let mut library_path: Vec<(&str, Vec<std::path::PathBuf>)> =
+        Vec::with_capacity(python_path.len());
     for path in python_path {
         let mut libraries = Vec::new();
         search_directory(
@@ -219,7 +220,7 @@ fn search_directory(
     libraries: &mut Vec<PathBuf>,
     configs: &mut Vec<ConfigContext<RawComponentizePyConfig>>,
     modules_seen: &mut HashSet<String>,
-) -> Result<(), anyhow::Error> {
+) -> Result<(), Error> {
     if path.is_dir() {
         for entry in fs::read_dir(path).with_context(|| path.display().to_string())? {
             search_directory(root, &entry?.path(), libraries, configs, modules_seen)?;