feat: update dagger 0.11.7

Signed-off-by: kjuulh <contact@kjuulh.io>

examples/gitea-cuddle-file-cuddle-please/src/main.rs

@@ -2,18 +2,21 @@ use dagger_cuddle_please::{models::CuddlePleaseSrcArgs, DaggerCuddlePleaseAction
 
 #[tokio::main]
 pub async fn main() -> eyre::Result<()> {
-    let client = dagger_sdk::connect().await?;
+    dagger_sdk::connect(|client| async move {
+        DaggerCuddlePleaseAction::dagger(client.clone())
+            .execute_src(&CuddlePleaseSrcArgs {
+                cuddle_image: "kasperhermansen/cuddle-please:main-1691504183".into(),
+                server: dagger_cuddle_please::models::SrcServer::Gitea {
+                    token: std::env::var("CUDDLE_PLEASE_TOKEN")
+                        .expect("CUDDLE_PLEASE_TOKEN to be present"),
+                },
+                log_level: Some(dagger_cuddle_please::models::LogLevel::Debug),
+            })
+            .await?;
 
-    DaggerCuddlePleaseAction::dagger(client.clone())
-        .execute_src(&CuddlePleaseSrcArgs {
-            cuddle_image: "kasperhermansen/cuddle-please:main-1691504183".into(),
-            server: dagger_cuddle_please::models::SrcServer::Gitea {
-                token: std::env::var("CUDDLE_PLEASE_TOKEN")
-                    .expect("CUDDLE_PLEASE_TOKEN to be present"),
-            },
-            log_level: Some(dagger_cuddle_please::models::LogLevel::Debug),
-        })
-        .await?;
+        Ok(())
+    })
+    .await?;
 
     Ok(())
 }

examples/gitea-cuddle-please/src/main.rs

@@ -2,25 +2,27 @@ use dagger_cuddle_please::{models::CuddlePleaseArgs, DaggerCuddlePleaseAction};
 
 #[tokio::main]
 pub async fn main() -> eyre::Result<()> {
-    let client = dagger_sdk::connect().await?;
-
-    DaggerCuddlePleaseAction::dagger(client)
-        .execute(&CuddlePleaseArgs {
-            repository: "dagger-components".into(),
-            owner: "kjuulh".into(),
-            branch: "main".into(),
-            cuddle_image: "kasperhermansen/cuddle-please:latest".into(),
-            server: dagger_cuddle_please::models::Server::Gitea {
-                url: "https://git.front.kjuulh.io".into(),
-                user: "git".into(),
-                token: std::env::var("CUDDLE_PLEASE_TOKEN")
-                    .expect("CUDDLE_PLEASE_TOKEN to be present"),
-                insecure: None,
-            },
-            log_level: None,
-            use_ssh_socket: false,
-        })
-        .await?;
+    dagger_sdk::connect(|client| async move {
+        DaggerCuddlePleaseAction::dagger(client)
+            .execute(&CuddlePleaseArgs {
+                repository: "dagger-components".into(),
+                owner: "kjuulh".into(),
+                branch: "main".into(),
+                cuddle_image: "kasperhermansen/cuddle-please:latest".into(),
+                server: dagger_cuddle_please::models::Server::Gitea {
+                    url: "https://git.front.kjuulh.io".into(),
+                    user: "git".into(),
+                    token: std::env::var("CUDDLE_PLEASE_TOKEN")
+                        .expect("CUDDLE_PLEASE_TOKEN to be present"),
+                    insecure: None,
+                },
+                log_level: None,
+                use_ssh_socket: false,
+            })
+            .await?;
 
+        Ok(())
+    })
+    .await?;
     Ok(())
 }

examples/htmx/src/main.rs

@@ -2,15 +2,17 @@ use std::path::PathBuf;
 
 #[tokio::main]
 pub async fn main() -> eyre::Result<()> {
-    let client = dagger_sdk::connect().await?;
+    dagger_sdk::connect(|client| async move {
+        let crates = ["some-crate"];
+        let dag = dagger_rust::source::RustSource::new(client.clone());
+        let (_src, _rust_src) = dag.get_rust_src(None::<PathBuf>, crates).await?;
 
-    let crates = ["some-crate"];
-    let dag = dagger_rust::source::RustSource::new(client.clone());
-    let (_src, _rust_src) = dag.get_rust_src(None::<PathBuf>, crates).await?;
-
-    let _full_src = dag
-        .get_rust_target_src(&PathBuf::from("."), client.container(), crates)
-        .await?;
+        let _full_src = dag
+            .get_rust_target_src(&PathBuf::from("."), client.container(), crates)
+            .await?;
 
+        Ok(())
+    })
+    .await?;
     Ok(())
 }

examples/leptos-build/src/main.rs

@@ -2,61 +2,63 @@ use dagger_rust::build::{RustVersion, SlimImage};
 
 #[tokio::main]
 pub async fn main() -> eyre::Result<()> {
-    let client = dagger_sdk::connect().await?;
+    dagger_sdk::connect(|client| async move {
+        let rust_build = dagger_rust::leptos::LeptosBuild::new(client.clone());
 
-    let rust_build = dagger_rust::leptos::LeptosBuild::new(client.clone());
-
-    let containers = rust_build
-        .build_release(
-            Some("testdata"),
-            RustVersion::Nightly,
-            &["crates/*"],
-            &[
-                "openssl",
-                "libssl-dev",
-                "pkg-config",
-                "musl-tools",
-                "ca-certificates",
-            ],
-            vec![SlimImage::Debian {
-                image: "debian:bullseye".into(),
-                deps: vec![
-                    "openssl".into(),
-                    "libssl-dev".into(),
-                    "pkg-config".into(),
-                    "musl-tools".into(),
-                    "ca-certificates".into(),
+        let containers = rust_build
+            .build_release(
+                Some("testdata"),
+                RustVersion::Nightly,
+                &["crates/*"],
+                &[
+                    "openssl",
+                    "libssl-dev",
+                    "pkg-config",
+                    "musl-tools",
+                    "ca-certificates",
                 ],
-                architecture: dagger_rust::build::BuildArchitecture::Amd64,
-            }],
-            "hackernews_axum",
-        )
-        .await?;
+                vec![SlimImage::Debian {
+                    image: "debian:bullseye".into(),
+                    deps: vec![
+                        "openssl".into(),
+                        "libssl-dev".into(),
+                        "pkg-config".into(),
+                        "musl-tools".into(),
+                        "ca-certificates".into(),
+                    ],
+                    architecture: dagger_rust::build::BuildArchitecture::Amd64,
+                }],
+                "hackernews_axum",
+            )
+            .await?;
 
-    let container = containers.first().unwrap();
+        let container = containers.first().unwrap();
 
-    container.directory("/mnt/app").export("output").await?;
+        container.directory("/mnt/app").export("output").await?;
 
-    let tunnel = client.host().tunnel(
-        container
-            .with_env_variable("LEPTOS_SITE_ADDR", "0.0.0.0:8080")
-            .with_exec(vec!["/mnt/app/hackernews_axum"])
-            .as_service(),
-    );
+        let tunnel = client.host().tunnel(
+            container
+                .with_env_variable("LEPTOS_SITE_ADDR", "0.0.0.0:8080")
+                .with_exec(vec!["/mnt/app/hackernews_axum"])
+                .as_service(),
+        );
 
-    tunnel.start().await?;
+        tunnel.start().await?;
 
-    let endpoint = tunnel
-        .endpoint_opts(
-            dagger_sdk::ServiceEndpointOptsBuilder::default()
-                .scheme("http")
-                .build()?,
-        )
-        .await?;
+        let endpoint = tunnel
+            .endpoint_opts(
+                dagger_sdk::ServiceEndpointOptsBuilder::default()
+                    .scheme("http")
+                    .build()?,
+            )
+            .await?;
 
-    println!("running on: {endpoint}, press enter to stop");
+        println!("running on: {endpoint}, press enter to stop");
 
-    std::io::stdin().read_line(&mut String::new()).unwrap();
+        std::io::stdin().read_line(&mut String::new()).unwrap();
 
+        Ok(())
+    })
+    .await?;
     Ok(())
 }

examples/rust-build/src/main.rs

@@ -2,28 +2,30 @@ use dagger_rust::build::{RustVersion, SlimImage};
 
 #[tokio::main]
 pub async fn main() -> eyre::Result<()> {
-    let client = dagger_sdk::connect().await?;
+    dagger_sdk::connect(|client| async move {
+        let rust_build = dagger_rust::build::RustBuild::new(client.clone());
 
-    let rust_build = dagger_rust::build::RustBuild::new(client.clone());
+        let containers = rust_build
+            .build_release(
+                Some("testdata"),
+                RustVersion::Nightly,
+                &["crates/*"],
+                &["openssl"],
+                vec![SlimImage::Debian {
+                    image: "debian:bookworm".into(),
+                    deps: vec!["openssl".into()],
+                    architecture: dagger_rust::build::BuildArchitecture::Amd64,
+                }],
+                "example_bin",
+            )
+            .await?;
 
-    let containers = rust_build
-        .build_release(
-            Some("testdata"),
-            RustVersion::Nightly,
-            &["crates/*"],
-            &["openssl"],
-            vec![SlimImage::Debian {
-                image: "debian:bookworm".into(),
-                deps: vec!["openssl".into()],
-                architecture: dagger_rust::build::BuildArchitecture::Amd64,
-            }],
-            "example_bin",
-        )
-        .await?;
-
-    for container in containers {
-        container.sync().await?;
-    }
+        for container in containers {
+            container.sync().await?;
+        }
 
+        Ok(())
+    })
+    .await?;
     Ok(())
 }

examples/rust-src/src/main.rs

@@ -2,15 +2,17 @@ use std::path::PathBuf;
 
 #[tokio::main]
 pub async fn main() -> eyre::Result<()> {
-    let client = dagger_sdk::connect().await?;
+    dagger_sdk::connect(|client| async move {
+        let crates = ["some-crate"];
+        let dag = dagger_rust::source::RustSource::new(client.clone());
+        let (_src, _rust_src) = dag.get_rust_src(None::<PathBuf>, crates).await?;
 
-    let crates = ["some-crate"];
-    let dag = dagger_rust::source::RustSource::new(client.clone());
-    let (_src, _rust_src) = dag.get_rust_src(None::<PathBuf>, crates).await?;
-
-    let _full_src = dag
-        .get_rust_target_src(&PathBuf::from("."), client.container(), crates)
-        .await?;
+        let _full_src = dag
+            .get_rust_target_src(&PathBuf::from("."), client.container(), crates)
+            .await?;
 
+        Ok(())
+    })
+    .await?;
     Ok(())
 }

examples/rust-test/src/main.rs

@@ -2,15 +2,19 @@ use dagger_rust::{build::RustVersion, test::RustTest};
 
 #[tokio::main]
 pub async fn main() -> eyre::Result<()> {
-    let client = dagger_sdk::connect().await?;
-    RustTest::new(client.clone())
-        .test(
-            Some("testdata"),
-            RustVersion::Nightly,
-            &["crates/*"],
-            &["openssl"],
-        )
-        .await?;
+    dagger_sdk::connect(|client| async move {
+        RustTest::new(client.clone())
+            .test(
+                Some("testdata"),
+                RustVersion::Nightly,
+                &["crates/*"],
+                &["openssl"],
+            )
+            .await?;
+
+        Ok(())
+    })
+    .await?;
 
     Ok(())
 }