Bump Rust edition to 2024 and MSRV to 1.85

Important, we need to release these changes with a new minor release.

Author: tillrohrmann

Cargo.toml

@@ -1,11 +1,11 @@
 [package]
 name = "restate-sdk"
 version = "0.7.0"
-edition = "2021"
+edition = "2024"
 description = "Restate SDK for Rust"
 license = "MIT"
 repository = "https://github.com/restatedev/sdk-rust"
-rust-version = "1.76.0"
+rust-version = "1.85.0"
 
 [[example]]
 name = "tracing"

examples/tracing.rs

@@ -1,7 +1,7 @@
 use restate_sdk::prelude::*;
 use std::time::Duration;
 use tracing::info;
-use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt, Layer};
+use tracing_subscriber::{Layer, layer::SubscriberExt, util::SubscriberInitExt};
 
 #[restate_sdk::service]
 trait Greeter {

macros/Cargo.toml

@@ -1,10 +1,11 @@
 [package]
 name = "restate-sdk-macros"
 version = "0.7.0"
-edition = "2021"
+edition = "2024"
 description = "Restate SDK for Rust macros"
 license = "MIT"
 repository = "https://github.com/restatedev/sdk-rust"
+rust-version = "1.85.0"
 
 [lib]
 proc-macro = true

macros/src/ast.rs

@@ -16,8 +16,8 @@ use syn::parse::{Parse, ParseStream};
 use syn::spanned::Spanned;
 use syn::token::Comma;
 use syn::{
-    braced, parenthesized, parse_quote, Attribute, Error, Expr, ExprLit, FnArg, GenericArgument,
-    Ident, Lit, Pat, PatType, Path, PathArguments, Result, ReturnType, Token, Type, Visibility,
+    Attribute, Error, Expr, ExprLit, FnArg, GenericArgument, Ident, Lit, Pat, PatType, Path,
+    PathArguments, Result, ReturnType, Token, Type, Visibility, braced, parenthesized, parse_quote,
 };
 
 /// Accumulates multiple errors into a result.
@@ -194,10 +194,12 @@ impl Parse for Handler {
         input.parse::<Token![;]>()?;
 
         let (ok_ty, err_ty) = match &return_type {
-            ReturnType::Default =>    return Err(Error::new(
-                return_type.span(),
-                "The return type cannot be empty, only Result or restate_sdk::prelude::HandlerResult is supported as return type",
-            )),
+            ReturnType::Default => {
+                return Err(Error::new(
+                    return_type.span(),
+                    "The return type cannot be empty, only Result or restate_sdk::prelude::HandlerResult is supported as return type",
+                ));
+            }
             ReturnType::Type(_, ty) => {
                 if let Some((ok_ty, err_ty)) = extract_handler_result_parameter(ty) {
                     (ok_ty, err_ty)
@@ -251,7 +253,7 @@ fn read_literal_attribute_name(attr: &Attribute) -> Result<Option<String>> {
         .filter(|val| val.path.require_ident().is_ok_and(|i| i == "name"))
         .map(|val| {
             if let Expr::Lit(ExprLit {
-                lit: Lit::Str(ref literal),
+                lit: Lit::Str(literal),
                 ..
             }) = &val.value
             {

macros/src/gen.rs macros/src/generator.rsmacros/src/gen.rs renamed to macros/src/generator.rs

@@ -1,7 +1,7 @@
 use crate::ast::{Handler, Object, Service, ServiceInner, ServiceType, Workflow};
 use proc_macro2::TokenStream as TokenStream2;
 use proc_macro2::{Ident, Literal};
-use quote::{format_ident, quote, ToTokens};
+use quote::{ToTokens, format_ident, quote};
 use syn::{Attribute, PatType, Visibility};
 
 pub(crate) struct ServiceGenerator<'a> {
@@ -386,7 +386,7 @@ impl<'a> ServiceGenerator<'a> {
     }
 }
 
-impl<'a> ToTokens for ServiceGenerator<'a> {
+impl ToTokens for ServiceGenerator<'_> {
     fn to_tokens(&self, output: &mut TokenStream2) {
         output.extend(vec![
             self.trait_service(),

macros/src/lib.rs

@@ -14,10 +14,10 @@
 extern crate proc_macro;
 
 mod ast;
-mod gen;
+mod generator;
 
 use crate::ast::{Object, Service, Workflow};
-use crate::gen::ServiceGenerator;
+use crate::generator::ServiceGenerator;
 use proc_macro::TokenStream;
 use quote::ToTokens;
 use syn::parse_macro_input;

rust-toolchain.toml

@@ -1,4 +1,4 @@
 [toolchain]
-channel = "1.82.0"
+channel = "1.85.0"
 profile = "minimal"
 components = ["rustfmt", "clippy"]

src/context/mod.rs

@@ -26,7 +26,7 @@ pub struct Context<'ctx> {
     inner: &'ctx ContextInternal,
 }
 
-impl<'ctx> Context<'ctx> {
+impl Context<'_> {
     /// Get request headers.
     pub fn headers(&self) -> &HeaderMap {
         &self.headers
@@ -60,7 +60,7 @@ pub struct SharedObjectContext<'ctx> {
     pub(crate) inner: &'ctx ContextInternal,
 }
 
-impl<'ctx> SharedObjectContext<'ctx> {
+impl SharedObjectContext<'_> {
     /// Get object key.
     pub fn key(&self) -> &str {
         &self.key
@@ -100,7 +100,7 @@ pub struct ObjectContext<'ctx> {
     pub(crate) inner: &'ctx ContextInternal,
 }
 
-impl<'ctx> ObjectContext<'ctx> {
+impl ObjectContext<'_> {
     /// Get object key.
     pub fn key(&self) -> &str {
         &self.key
@@ -153,7 +153,7 @@ impl<'ctx> From<(&'ctx ContextInternal, InputMetadata)> for SharedWorkflowContex
     }
 }
 
-impl<'ctx> SharedWorkflowContext<'ctx> {
+impl SharedWorkflowContext<'_> {
     /// Get workflow key.
     pub fn key(&self) -> &str {
         &self.key
@@ -193,7 +193,7 @@ impl<'ctx> From<(&'ctx ContextInternal, InputMetadata)> for WorkflowContext<'ctx
     }
 }
 
-impl<'ctx> WorkflowContext<'ctx> {
+impl WorkflowContext<'_> {
     /// Get workflow key.
     pub fn key(&self) -> &str {
         &self.key
@@ -832,13 +832,13 @@ pub trait ContextReadState<'ctx>: private::SealedContext<'ctx> {
     /// Get state
     fn get<T: Deserialize + 'static>(
         &self,
-        key: &str,
+        key: &'ctx str,
     ) -> impl Future<Output = Result<Option<T>, TerminalError>> + 'ctx {
         self.inner_context().get(key)
     }
 
     /// Get state keys
-    fn get_keys(&self) -> impl Future<Output = Result<Vec<String>, TerminalError>> + 'ctx {
+    fn get_keys(&'ctx self) -> impl Future<Output = Result<Vec<String>, TerminalError>> + 'ctx {
         self.inner_context().get_keys()
     }
 }
@@ -923,15 +923,15 @@ pub trait ContextPromises<'ctx>: private::SealedContext<'ctx> {
     /// Create a promise
     fn promise<T: Deserialize + 'static>(
         &'ctx self,
-        key: &str,
+        key: &'ctx str,
     ) -> impl DurableFuture<Output = Result<T, TerminalError>> + 'ctx {
         self.inner_context().promise(key)
     }
 
     /// Peek a promise
     fn peek_promise<T: Deserialize + 'static>(
         &self,
-        key: &str,
+        key: &'ctx str,
     ) -> impl Future<Output = Result<Option<T>, TerminalError>> + 'ctx {
         self.inner_context().peek_promise(key)
     }

src/context/select.rs

@@ -76,7 +76,8 @@ macro_rules! select {
         let handles = vec![$(
             $crate::count_field!(futures_init.$($skip)*).handle()
         ,)+];
-        let select_fut = futures_init.0.inner_context().select(handles);
+        let inner_context = futures_init.0.inner_context();
+        let select_fut = inner_context.select(handles);
 
         match select_fut.await {
             $(

src/endpoint/context.rs

@@ -16,16 +16,16 @@ use futures::{FutureExt, TryFutureExt};
 use pin_project_lite::pin_project;
 use restate_sdk_shared_core::{
     CoreVM, DoProgressResponse, Error as CoreError, Header, NonEmptyValue, NotificationHandle,
-    RetryPolicy, RunExitResult, TakeOutputResult, Target, TerminalFailure, Value, VM,
+    RetryPolicy, RunExitResult, TakeOutputResult, Target, TerminalFailure, VM, Value,
 };
 use std::borrow::Cow;
 use std::collections::HashMap;
-use std::future::{ready, Future};
+use std::future::{Future, ready};
 use std::marker::PhantomData;
 use std::mem;
 use std::pin::Pin;
 use std::sync::{Arc, Mutex};
-use std::task::{ready, Context, Poll};
+use std::task::{Context, Poll, ready};
 use std::time::{Duration, Instant, SystemTime};
 
 pub struct ContextInternalInner {