Merge pull request #11 from fibonacci1729/async

feat: support async handlers

Author: fibonacci1729

Cargo.lock

@@ -2,7 +2,7 @@ use spin_cron_sdk::{cron_component, Error, Metadata};
 use spin_sdk::variables;
 
 #[cron_component]
-fn handle_cron_event(metadata: Metadata) -> Result<(), Error> {
+async fn handle_cron_event(metadata: Metadata) -> Result<(), Error> {
     let key = variables::get("something").unwrap_or_default();
     println!(
         "[{}] Hello this is me running every {}",

guest-rust/Cargo.lock

@@ -10,5 +10,6 @@ include = ["../cron.wit"]
 name = "spin_cron_sdk"
 
 [dependencies]
+spin-executor = "3.0.1"
 spin-cron-macro = { path = "macro" }
-wit-bindgen = { workspace = true }
+wit-bindgen = { workspace = true }

guest-rust/src/lib.rs

@@ -10,10 +10,6 @@ name = "spin_cron_macro"
 proc-macro = true
 
 [dependencies]
-anyhow = "1"
-bytes = "1"
-http = "0.2"
 proc-macro2 = "1"
 quote = "1.0"
-syn = { version = "1.0", features = ["full"] }
-wit-bindgen = { workspace = true }
+syn = { version = "1.0", features = ["full"] }

sdk/Cargo.toml

@@ -7,6 +7,7 @@ const WIT_PATH: &str = concat!(env!("CARGO_MANIFEST_DIR"), "/../../cron.wit");
 pub fn cron_component(_attr: TokenStream, item: TokenStream) -> TokenStream {
     let func = syn::parse_macro_input!(item as syn::ItemFn);
     let func_name = &func.sig.ident;
+    let await_postfix = func.sig.asyncness.map(|_| quote!(.await));
     let preamble = preamble();
 
     quote!(
@@ -17,13 +18,15 @@ pub fn cron_component(_attr: TokenStream, item: TokenStream) -> TokenStream {
             }
             impl self::preamble::Guest for preamble::Cron {
                 fn handle_cron_event(metadata: ::spin_cron_sdk::Metadata) -> ::std::result::Result<(), ::spin_cron_sdk::Error> {
-                    match super::#func_name(metadata) {
-                        ::std::result::Result::Ok(()) => ::std::result::Result::Ok(()),
-                        ::std::result::Result::Err(e) => {
-                            eprintln!("{}", e);
-                            ::std::result::Result::Err(::spin_cron_sdk::Error::Other(e.to_string()))
-                        },
-                    }
+                    ::spin_cron_sdk::executor::run(async move {
+                        match super::#func_name(metadata)#await_postfix {
+                            ::std::result::Result::Ok(()) => ::std::result::Result::Ok(()),
+                            ::std::result::Result::Err(e) => {
+                                eprintln!("{}", e);
+                                ::std::result::Result::Err(::spin_cron_sdk::Error::Other(e.to_string()))
+                            },
+                        }
+                    })
                 }
             }
         }

sdk/macro/Cargo.toml

@@ -1,5 +1,8 @@
 pub use spin_cron_macro::cron_component;
 
+#[doc(hidden)]
+pub use spin_executor as executor;
+
 #[doc(hidden)]
 pub mod wit {
     #![allow(missing_docs)]