Update Wasmtime to 29.0.1

This commit updates Wasmtime from 25.0.3 to 29.0.1, the latest release
of Wasmtime. This update is accompanied with few minor changes around
bindings generation such as traits no longer needing `#[async_trait]`.

Otherwise one of the main features is that the WITs included with
Wasmtime's WASI implementation have been updated to 0.2.3 as well. This
should continue to still work with guests using 0.2.2 and prior, though.

Signed-off-by: Alex Crichton <[email protected]>

Author: alexcrichton

Cargo.lock

@@ -151,9 +151,9 @@ wasi-common-preview1 = { version = "25.0.0", package = "wasi-common", features =
 ] }
 wasm-pkg-common = "0.8"
 wasm-pkg-client = "0.8"
-wasmtime = "25.0.3"
-wasmtime-wasi = "25.0.0"
-wasmtime-wasi-http = "25.0.0"
+wasmtime = "29.0.1"
+wasmtime-wasi = "29.0.1"
+wasmtime-wasi-http = "29.0.1"
 
 spin-componentize = { path = "crates/componentize" }
 

Cargo.toml

@@ -108,7 +108,7 @@ impl Default for Config {
                 )
                 .max_core_instances_per_component(env("SPIN_WASMTIME_CORE_INSTANCE_COUNT", 200))
                 .max_tables_per_component(env("SPIN_WASMTIME_INSTANCE_TABLES", 20))
-                .table_elements(env("SPIN_WASMTIME_INSTANCE_TABLE_ELEMENTS", 100_000))
+                .table_elements(env("SPIN_WASMTIME_INSTANCE_TABLE_ELEMENTS", 100_000) as usize)
                 // The number of memories an instance can have effectively limits the number of inner components
                 // a composed component can have (since each inner component has its own memory). We default to 32 for now, and
                 // we'll see how often this limit gets reached.
@@ -175,7 +175,7 @@ fn use_pooling_allocator_by_default() -> bool {
         // If the env var isn't set then perform the dynamic runtime probe
         let mut config = wasmtime::Config::new();
         config.wasm_memory64(true);
-        config.static_memory_maximum_size(1 << BITS_TO_TEST);
+        config.memory_reservation(1 << BITS_TO_TEST);
 
         match wasmtime::Engine::new(&config) {
             Ok(engine) => {

crates/core/src/lib.rs

@@ -7,7 +7,7 @@ use wasmtime::ResourceLimiterAsync;
 #[derive(Default)]
 pub struct StoreLimitsAsync {
     max_memory_size: Option<usize>,
-    max_table_elements: Option<u32>,
+    max_table_elements: Option<usize>,
     memory_consumed: u64,
 }
 
@@ -33,9 +33,9 @@ impl ResourceLimiterAsync for StoreLimitsAsync {
 
     async fn table_growing(
         &mut self,
-        _current: u32,
-        desired: u32,
-        _maximum: Option<u32>,
+        _current: usize,
+        desired: usize,
+        _maximum: Option<usize>,
     ) -> Result<bool> {
         let can_grow = if let Some(limit) = self.max_table_elements {
             desired <= limit
@@ -47,7 +47,7 @@ impl ResourceLimiterAsync for StoreLimitsAsync {
 }
 
 impl StoreLimitsAsync {
-    pub fn new(max_memory_size: Option<usize>, max_table_elements: Option<u32>) -> Self {
+    pub fn new(max_memory_size: Option<usize>, max_table_elements: Option<usize>) -> Self {
         Self {
             max_memory_size,
             max_table_elements,

crates/core/src/limits.rs

@@ -103,10 +103,8 @@ impl KeyValueDispatch {
     }
 }
 
-#[async_trait]
 impl key_value::Host for KeyValueDispatch {}
 
-#[async_trait]
 impl key_value::HostStore for KeyValueDispatch {
     #[instrument(name = "spin_key_value.open", skip(self), err(level = Level::INFO), fields(otel.kind = "client", kv.backend=self.manager.summary(&name).unwrap_or("unknown".to_string())))]
     async fn open(&mut self, name: String) -> Result<Result<Resource<key_value::Store>, Error>> {
@@ -191,7 +189,6 @@ fn to_wasi_err(e: Error) -> wasi_keyvalue::store::Error {
     }
 }
 
-#[async_trait]
 impl wasi_keyvalue::store::Host for KeyValueDispatch {
     async fn open(
         &mut self,
@@ -219,7 +216,6 @@ impl wasi_keyvalue::store::Host for KeyValueDispatch {
 }
 
 use wasi_keyvalue::store::Bucket;
-#[async_trait]
 impl wasi_keyvalue::store::HostBucket for KeyValueDispatch {
     async fn get(
         &mut self,
@@ -281,7 +277,6 @@ impl wasi_keyvalue::store::HostBucket for KeyValueDispatch {
     }
 }
 
-#[async_trait]
 impl wasi_keyvalue::batch::Host for KeyValueDispatch {
     #[instrument(name = "spin_key_value.get_many", skip(self, bucket, keys), err(level = Level::INFO), fields(otel.kind = "client"))]
     async fn get_many(
@@ -323,7 +318,6 @@ impl wasi_keyvalue::batch::Host for KeyValueDispatch {
     }
 }
 
-#[async_trait]
 impl wasi_keyvalue::atomics::HostCas for KeyValueDispatch {
     async fn new(
         &mut self,
@@ -363,7 +357,6 @@ impl wasi_keyvalue::atomics::HostCas for KeyValueDispatch {
     }
 }
 
-#[async_trait]
 impl wasi_keyvalue::atomics::Host for KeyValueDispatch {
     fn convert_cas_error(
         &mut self,
@@ -439,7 +432,6 @@ fn to_legacy_error(value: key_value::Error) -> LegacyError {
     }
 }
 
-#[async_trait]
 impl spin_world::v1::key_value::Host for KeyValueDispatch {
     async fn open(&mut self, name: String) -> Result<Result<u32, LegacyError>> {
         let result = <Self as key_value::HostStore>::open(self, name).await?;

crates/factor-key-value/src/host.rs

@@ -1,12 +1,10 @@
-use async_trait::async_trait;
 use spin_world::v1::llm::{self as v1};
 use spin_world::v2::llm::{self as v2};
 use tracing::field::Empty;
 use tracing::{instrument, Level};
 
 use crate::InstanceState;
 
-#[async_trait]
 impl v2::Host for InstanceState {
     #[instrument(name = "spin_llm.infer", skip(self, prompt), err(level = Level::INFO), fields(otel.kind = "client", llm.backend = Empty))]
     async fn infer(
@@ -55,7 +53,6 @@ impl v2::Host for InstanceState {
     }
 }
 
-#[async_trait]
 impl v1::Host for InstanceState {
     async fn infer(
         &mut self,

crates/factor-llm/src/host.rs

@@ -1,16 +1,12 @@
 use http_body_util::BodyExt;
-use spin_world::{
-    async_trait,
-    v1::{
-        http as spin_http,
-        http_types::{self, HttpError, Method, Request, Response},
-    },
+use spin_world::v1::{
+    http as spin_http,
+    http_types::{self, HttpError, Method, Request, Response},
 };
 use tracing::{field::Empty, instrument, Level, Span};
 
 use crate::intercept::InterceptOutcome;
 
-#[async_trait]
 impl spin_http::Host for crate::InstanceState {
     #[instrument(name = "spin_outbound_http.send_request", skip_all, err(level = Level::INFO),
         fields(otel.kind = "client", url.full = Empty, http.request.method = Empty,

crates/factor-outbound-http/src/spin.rs

@@ -8,9 +8,7 @@ mod bindings {
 
     wasmtime::component::bindgen!({
         path: "../../wit",
-        interfaces: r#"
-            include wasi:http/[email protected];
-        "#,
+        world: "wasi:http/[email protected]",
         async: {
             // Only need async exports
             only_imports: [],

crates/factor-outbound-http/src/wasi_2023_10_18.rs

@@ -11,9 +11,7 @@ mod bindings {
 
     wasmtime::component::bindgen!({
         path: "../../wit",
-        interfaces: r#"
-            include wasi:http/[email protected];
-        "#,
+        world: "wasi:http/[email protected]",
         async: {
             // Only need async exports
             only_imports: [],

crates/factor-outbound-http/src/wasi_2023_11_10.rs

@@ -63,7 +63,6 @@ impl v2::Host for InstanceState {
     }
 }
 
-#[async_trait]
 impl v2::HostConnection for InstanceState {
     #[instrument(name = "spin_outbound_mqtt.open_connection", skip(self, password), err(level = Level::INFO), fields(otel.kind = "client"))]
     async fn open(