kjuulh/dagger-rs
1
0
Fork 0
mirror of https://github.com/kjuulh/dagger-rs.git synced 2025-07-26 03:19:21 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(sdk): move to &str instead of String and introduce builder.

Browse Source 
This will make the api much easier to use, as we can now rely on ""
instead of "".into() for normal string values.

Introduced builder as well, which makes it much easier to use *Opts, as
it can handle the building of that, and get the benefits from String ->
&str, as that is currently not allowed for optional values
This commit is contained in:
Kasper Juul Hermansen
2023-02-19 17:21:40 +01:00
committed by Kasper Juul Hermansen
parent 6e2292cf11
commit 94336d0637
18 changed files with 505 additions and 304 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
crates/dagger-sdk/Cargo.toml
View File

@@ -20,6 +20,7 @@ gql_client = "1.0.7"
serde = { version = "1.0.152", features = ["derive"] }
serde_json = "1.0.93"
tokio = { version = "1.25.0", features = ["full"] }
derive_builder = "0.12.0"
[dev-dependencies]
pretty_assertions = "1.3.0"

27
crates/dagger-sdk/examples/build-the-application/main.rs
View File

@@ -4,37 +4,30 @@ fn main() -> eyre::Result<()> {
let client = dagger_sdk::connect()?;
let host_source_dir = client.host().directory(
"examples/build-the-application/app".into(),
"examples/build-the-application/app",
Some(HostDirectoryOpts {
exclude: Some(vec!["node_modules".into(), "ci/".into()]),
include: None,
marker: std::marker::PhantomData,
}),
);
let source = client
.container(None)
.from("node:16".into())
.with_mounted_directory("/src".into(), host_source_dir.id()?);
.from("node:16")
.with_mounted_directory("/src", host_source_dir.id()?);
let runner = source
.with_workdir("/src".into())
.with_exec(vec!["npm".into(), "install".into()], None);
.with_workdir("/src")
.with_exec(vec!["npm", "install"], None);
let test = runner.with_exec(
vec![
"npm".into(),
"test".into(),
"--".into(),
"--watchAll=false".into(),
],
None,
);
let test = runner.with_exec(vec!["npm", "test", "--", "--watchAll=false"], None);
let build_dir = test
.with_exec(vec!["npm".into(), "run".into(), "build".into()], None)
.directory("./build".into());
.with_exec(vec!["npm", "run", "build"], None)
.directory("./build");
let _ = build_dir.export("./build".into());
let _ = build_dir.export("./build");
let entries = build_dir.entries(None);

42
crates/dagger-sdk/examples/caching/main.rs
View File

@@ -1,49 +1,41 @@
use dagger_sdk::HostDirectoryOpts;
use rand::Rng;
fn main() -> eyre::Result<()> {
let client = dagger_sdk::connect()?;
let host_source_dir = client.host().directory(
"./examples/caching/app".into(),
Some(HostDirectoryOpts {
exclude: Some(vec!["node_modules".into(), "ci/".into()]),
include: None,
}),
"./examples/caching/app",
Some(
dagger_sdk::HostDirectoryOptsBuilder::default()
.exclude(vec!["node_modules", "ci/"])
.build()?,
),
);
let node_cache = client.cache_volume("node".into()).id()?;
let node_cache = client.cache_volume("node").id()?;
let source = client
.container(None)
.from("node:16".into())
.with_mounted_directory("/src".into(), host_source_dir.id()?)
.with_mounted_cache("/src/node_modules".into(), node_cache, None);
.from("node:16")
.with_mounted_directory("/src", host_source_dir.id()?)
.with_mounted_cache("/src/node_modules", node_cache, None);
let runner = source
.with_workdir("/src".into())
.with_exec(vec!["npm".into(), "install".into()], None);
.with_workdir("/src")
.with_exec(vec!["npm", "install"], None);
let test = runner.with_exec(
vec![
"npm".into(),
"test".into(),
"--".into(),
"--watchAll=false".into(),
],
None,
);
let test = runner.with_exec(vec!["npm", "test", "--", "--watchAll=false"], None);
let build_dir = test
.with_exec(vec!["npm".into(), "run".into(), "build".into()], None)
.directory("./build".into());
.with_exec(vec!["npm", "run", "build"], None)
.directory("./build");
let mut rng = rand::thread_rng();
let ref_ = client
.container(None)
.from("nginx".into())
.with_directory("/usr/share/nginx/html".into(), build_dir.id()?, None)
.from("nginx")
.with_directory("/usr/share/nginx/html", build_dir.id()?, None)
.publish(
format!("ttl.sh/hello-dagger-rs-{}:1h", rng.gen::<u64>()),
None,

2
crates/dagger-sdk/examples/existing-dockerfile/main.rs
View File

@@ -7,7 +7,7 @@ fn main() -> eyre::Result<()> {
let context_dir = client
.host()
.directory("./examples/existing-dockerfile/app".into(), None);
.directory("./examples/existing-dockerfile/app", None);
let ref_ = client
.container(None)

4
crates/dagger-sdk/examples/first-pipeline/main.rs
View File

@@ -3,8 +3,8 @@ fn main() -> eyre::Result<()> {
let version = client
.container(None)
.from("golang:1.19".into())
.with_exec(vec!["go".into(), "version".into()], None)
.from("golang:1.19")
.with_exec(vec!["go", "version".into()], None)
.stdout()?;
println!("Hello from Dagger and {}", version.trim());

31
crates/dagger-sdk/examples/multi-stage-build/main.rs
View File

@@ -5,42 +5,35 @@ fn main() -> eyre::Result<()> {
let client = dagger_sdk::connect()?;
let host_source_dir = client.host().directory(
"examples/publish-the-application/app".into(),
"examples/publish-the-application/app",
Some(HostDirectoryOpts {
exclude: Some(vec!["node_modules".into(), "ci/".into()]),
exclude: Some(vec!["node_modules", "ci/"]),
include: None,
marker: std::marker::PhantomData,
}),
);
let source = client
.container(None)
.from("node:16".into())
.with_mounted_directory("/src".into(), host_source_dir.id()?);
.from("node:16")
.with_mounted_directory("/src", host_source_dir.id()?);
let runner = source
.with_workdir("/src".into())
.with_exec(vec!["npm".into(), "install".into()], None);
.with_workdir("/src")
.with_exec(vec!["npm", "install"], None);
let test = runner.with_exec(
vec![
"npm".into(),
"test".into(),
"--".into(),
"--watchAll=false".into(),
],
None,
);
let test = runner.with_exec(vec!["npm", "test", "--", "--watchAll=false"], None);
let build_dir = test
.with_exec(vec!["npm".into(), "run".into(), "build".into()], None)
.directory("./build".into());
.with_exec(vec!["npm", "run", "build"], None)
.directory("./build");
let mut rng = rand::thread_rng();
let ref_ = client
.container(None)
.from("nginx".into())
.with_directory("/usr/share/nginx/html".into(), build_dir.id()?, None)
.from("nginx")
.with_directory("/usr/share/nginx/html", build_dir.id()?, None)
.publish(
format!("ttl.sh/hello-dagger-rs-{}:1h", rng.gen::<u64>()),
None,

35
crates/dagger-sdk/examples/publish-the-application/main.rs
View File

@@ -6,45 +6,38 @@ fn main() -> eyre::Result<()> {
let output = "examples/publish-the-application/app/build";
let host_source_dir = client.host().directory(
"examples/publish-the-application/app".into(),
"examples/publish-the-application/app",
Some(HostDirectoryOpts {
exclude: Some(vec!["node_modules".into(), "ci/".into()]),
exclude: Some(vec!["node_modules", "ci/"]),
include: None,
marker: std::marker::PhantomData,
}),
);
let source = client
.container(None)
.from("node:16".into())
.with_mounted_directory("/src".into(), host_source_dir.id()?);
.from("node:16")
.with_mounted_directory("/src", host_source_dir.id()?);
let runner = source
.with_workdir("/src".into())
.with_exec(vec!["npm".into(), "install".into()], None);
.with_workdir("/src")
.with_exec(vec!["npm", "install"], None);
let test = runner.with_exec(
vec![
"npm".into(),
"test".into(),
"--".into(),
"--watchAll=false".into(),
],
None,
);
let test = runner.with_exec(vec!["npm", "test", "--", "--watchAll=false"], None);
let _ = test
.with_exec(vec!["npm".into(), "run".into(), "build".into()], None)
.directory("./build".into())
.export(output.into());
.with_exec(vec!["npm", "run", "build"], None)
.directory("./build")
.export(output);
let mut rng = rand::thread_rng();
let ref_ = client
.container(None)
.from("nginx".into())
.from("nginx")
.with_directory(
"/usr/share/nginx/html".into(),
client.host().directory(output.into(), None).id()?,
"/usr/share/nginx/html",
client.host().directory(output, None).id()?,
None,
)
.publish(

23
crates/dagger-sdk/examples/test-the-application/main.rs
View File

@@ -4,32 +4,25 @@ fn main() -> eyre::Result<()> {
let client = dagger_sdk::connect()?;
let host_source_dir = client.host().directory(
"examples/test-the-application/app".into(),
"examples/test-the-application/app",
Some(HostDirectoryOpts {
exclude: Some(vec!["node_modules".into(), "ci/".into()]),
exclude: Some(vec!["node_modules", "ci/"]),
include: None,
marker: std::marker::PhantomData,
}),
);
let source = client
.container(None)
.from("node:16".into())
.with_mounted_directory("/src".into(), host_source_dir.id()?);
.from("node:16")
.with_mounted_directory("/src", host_source_dir.id()?);
let runner = source
.with_workdir("/src".into())
.with_exec(vec!["npm".into(), "install".into()], None);
.with_workdir("/src")
.with_exec(vec!["npm", "install"], None);
let out = runner
.with_exec(
vec![
"npm".into(),
"test".into(),
"--".into(),
"--watchAll=false".into(),
],
None,
)
.with_exec(vec!["npm", "test", "--", "--watchAll=false"], None)
.stderr()?;
println!("{}", out);

453
crates/dagger-sdk/src/gen.rs
View File

@@ -1,25 +1,26 @@
use crate::client::graphql_client;
use crate::querybuilder::Selection;
use dagger_core::connect_params::ConnectParams;
use derive_builder::Builder;
use serde::{Deserialize, Serialize};
use std::process::Child;
use std::sync::Arc;
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
pub struct CacheId(String);
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
pub struct ContainerId(String);
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
pub struct DirectoryId(String);
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
pub struct FileId(String);
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
pub struct Platform(String);
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
pub struct SecretId(String);
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
pub struct SocketId(String);
#[derive(Serialize, Deserialize)]
#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)]
pub struct BuildArg {
pub name: String,
pub value: String,
@@ -43,49 +44,83 @@ pub struct Container {
pub conn: ConnectParams,
}
pub struct ContainerBuildOpts {
pub dockerfile: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerBuildOpts<'a> {
#[builder(setter(into, strip_option))]
pub dockerfile: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub build_args: Option<Vec<BuildArg>>,
pub target: Option<String>,
#[builder(setter(into, strip_option))]
pub target: Option<&'a str>,
}
pub struct ContainerExecOpts {
pub args: Option<Vec<String>>,
pub stdin: Option<String>,
pub redirect_stdout: Option<String>,
pub redirect_stderr: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerExecOpts<'a> {
#[builder(setter(into, strip_option))]
pub args: Option<Vec<&'a str>>,
#[builder(setter(into, strip_option))]
pub stdin: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub redirect_stdout: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub redirect_stderr: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub experimental_privileged_nesting: Option<bool>,
}
pub struct ContainerExportOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerExportOpts<'a> {
#[builder(setter(into, strip_option))]
pub platform_variants: Option<Vec<ContainerId>>,
}
pub struct ContainerPipelineOpts {
pub description: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerPipelineOpts<'a> {
#[builder(setter(into, strip_option))]
pub description: Option<&'a str>,
}
pub struct ContainerPublishOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerPublishOpts<'a> {
#[builder(setter(into, strip_option))]
pub platform_variants: Option<Vec<ContainerId>>,
}
pub struct ContainerWithDefaultArgsOpts {
pub args: Option<Vec<String>>,
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerWithDefaultArgsOpts<'a> {
#[builder(setter(into, strip_option))]
pub args: Option<Vec<&'a str>>,
}
pub struct ContainerWithDirectoryOpts {
pub exclude: Option<Vec<String>>,
pub include: Option<Vec<String>>,
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerWithDirectoryOpts<'a> {
#[builder(setter(into, strip_option))]
pub exclude: Option<Vec<&'a str>>,
#[builder(setter(into, strip_option))]
pub include: Option<Vec<&'a str>>,
}
pub struct ContainerWithExecOpts {
pub stdin: Option<String>,
pub redirect_stdout: Option<String>,
pub redirect_stderr: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerWithExecOpts<'a> {
#[builder(setter(into, strip_option))]
pub stdin: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub redirect_stdout: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub redirect_stderr: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub experimental_privileged_nesting: Option<bool>,
}
pub struct ContainerWithFileOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerWithFileOpts<'a> {
#[builder(setter(into, strip_option))]
pub permissions: Option<isize>,
}
pub struct ContainerWithMountedCacheOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerWithMountedCacheOpts<'a> {
#[builder(setter(into, strip_option))]
pub source: Option<DirectoryId>,
#[builder(setter(into, strip_option))]
pub sharing: Option<CacheSharingMode>,
}
pub struct ContainerWithNewFileOpts {
pub contents: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct ContainerWithNewFileOpts<'a> {
#[builder(setter(into, strip_option))]
pub contents: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub permissions: Option<isize>,
}
@@ -117,10 +152,10 @@ impl Container {
query.execute(&graphql_client(&self.conn))
}
pub fn directory(&self, path: String) -> Directory {
pub fn directory(&self, path: impl Into<String>) -> Directory {
let mut query = self.selection.select("directory");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Directory {
proc: self.proc.clone(),
@@ -133,10 +168,10 @@ impl Container {
query.execute(&graphql_client(&self.conn))
}
pub fn env_variable(&self, name: String) -> eyre::Result<String> {
pub fn env_variable(&self, name: impl Into<String>) -> eyre::Result<String> {
let mut query = self.selection.select("envVariable");
query = query.arg("name", name);
query = query.arg("name", name.into());
query.execute(&graphql_client(&self.conn))
}
@@ -184,10 +219,14 @@ impl Container {
query.execute(&graphql_client(&self.conn))
}
pub fn export(&self, path: String, opts: Option<ContainerExportOpts>) -> eyre::Result<bool> {
pub fn export(
&self,
path: impl Into<String>,
opts: Option<ContainerExportOpts>,
) -> eyre::Result<bool> {
let mut query = self.selection.select("export");
query = query.arg("path", path);
query = query.arg("path", path.into());
if let Some(opts) = opts {
if let Some(platform_variants) = opts.platform_variants {
query = query.arg("platformVariants", platform_variants);
@@ -196,10 +235,10 @@ impl Container {
query.execute(&graphql_client(&self.conn))
}
pub fn file(&self, path: String) -> File {
pub fn file(&self, path: impl Into<String>) -> File {
let mut query = self.selection.select("file");
query = query.arg("path", path);
query = query.arg("path", path.into());
return File {
proc: self.proc.clone(),
@@ -207,10 +246,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn from(&self, address: String) -> Container {
pub fn from(&self, address: impl Into<String>) -> Container {
let mut query = self.selection.select("from");
query = query.arg("address", address);
query = query.arg("address", address.into());
return Container {
proc: self.proc.clone(),
@@ -232,10 +271,10 @@ impl Container {
query.execute(&graphql_client(&self.conn))
}
pub fn label(&self, name: String) -> eyre::Result<String> {
pub fn label(&self, name: impl Into<String>) -> eyre::Result<String> {
let mut query = self.selection.select("label");
query = query.arg("name", name);
query = query.arg("name", name.into());
query.execute(&graphql_client(&self.conn))
}
@@ -253,10 +292,14 @@ impl Container {
query.execute(&graphql_client(&self.conn))
}
pub fn pipeline(&self, name: String, opts: Option<ContainerPipelineOpts>) -> Container {
pub fn pipeline(
&self,
name: impl Into<String>,
opts: Option<ContainerPipelineOpts>,
) -> Container {
let mut query = self.selection.select("pipeline");
query = query.arg("name", name);
query = query.arg("name", name.into());
if let Some(opts) = opts {
if let Some(description) = opts.description {
query = query.arg("description", description);
@@ -276,12 +319,12 @@ impl Container {
}
pub fn publish(
&self,
address: String,
address: impl Into<String>,
opts: Option<ContainerPublishOpts>,
) -> eyre::Result<String> {
let mut query = self.selection.select("publish");
query = query.arg("address", address);
query = query.arg("address", address.into());
if let Some(opts) = opts {
if let Some(platform_variants) = opts.platform_variants {
query = query.arg("platformVariants", platform_variants);
@@ -331,13 +374,13 @@ impl Container {
}
pub fn with_directory(
&self,
path: String,
path: impl Into<String>,
directory: DirectoryId,
opts: Option<ContainerWithDirectoryOpts>,
) -> Container {
let mut query = self.selection.select("withDirectory");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("directory", directory);
if let Some(opts) = opts {
if let Some(exclude) = opts.exclude {
@@ -354,10 +397,13 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_entrypoint(&self, args: Vec<String>) -> Container {
pub fn with_entrypoint(&self, args: Vec<impl Into<String>>) -> Container {
let mut query = self.selection.select("withEntrypoint");
query = query.arg("args", args);
query = query.arg(
"args",
args.into_iter().map(|i| i.into()).collect::<Vec<String>>(),
);
return Container {
proc: self.proc.clone(),
@@ -365,11 +411,15 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_env_variable(&self, name: String, value: String) -> Container {
pub fn with_env_variable(
&self,
name: impl Into<String>,
value: impl Into<String>,
) -> Container {
let mut query = self.selection.select("withEnvVariable");
query = query.arg("name", name);
query = query.arg("value", value);
query = query.arg("name", name.into());
query = query.arg("value", value.into());
return Container {
proc: self.proc.clone(),
@@ -377,10 +427,17 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_exec(&self, args: Vec<String>, opts: Option<ContainerWithExecOpts>) -> Container {
pub fn with_exec(
&self,
args: Vec<impl Into<String>>,
opts: Option<ContainerWithExecOpts>,
) -> Container {
let mut query = self.selection.select("withExec");
query = query.arg("args", args);
query = query.arg(
"args",
args.into_iter().map(|i| i.into()).collect::<Vec<String>>(),
);
if let Some(opts) = opts {
if let Some(stdin) = opts.stdin {
query = query.arg("stdin", stdin);
@@ -418,13 +475,13 @@ impl Container {
}
pub fn with_file(
&self,
path: String,
path: impl Into<String>,
source: FileId,
opts: Option<ContainerWithFileOpts>,
) -> Container {
let mut query = self.selection.select("withFile");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("source", source);
if let Some(opts) = opts {
if let Some(permissions) = opts.permissions {
@@ -438,11 +495,11 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_label(&self, name: String, value: String) -> Container {
pub fn with_label(&self, name: impl Into<String>, value: impl Into<String>) -> Container {
let mut query = self.selection.select("withLabel");
query = query.arg("name", name);
query = query.arg("value", value);
query = query.arg("name", name.into());
query = query.arg("value", value.into());
return Container {
proc: self.proc.clone(),
@@ -452,13 +509,13 @@ impl Container {
}
pub fn with_mounted_cache(
&self,
path: String,
path: impl Into<String>,
cache: CacheId,
opts: Option<ContainerWithMountedCacheOpts>,
) -> Container {
let mut query = self.selection.select("withMountedCache");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("cache", cache);
if let Some(opts) = opts {
if let Some(source) = opts.source {
@@ -475,10 +532,14 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_mounted_directory(&self, path: String, source: DirectoryId) -> Container {
pub fn with_mounted_directory(
&self,
path: impl Into<String>,
source: DirectoryId,
) -> Container {
let mut query = self.selection.select("withMountedDirectory");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("source", source);
return Container {
@@ -487,10 +548,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_mounted_file(&self, path: String, source: FileId) -> Container {
pub fn with_mounted_file(&self, path: impl Into<String>, source: FileId) -> Container {
let mut query = self.selection.select("withMountedFile");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("source", source);
return Container {
@@ -499,10 +560,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_mounted_secret(&self, path: String, source: SecretId) -> Container {
pub fn with_mounted_secret(&self, path: impl Into<String>, source: SecretId) -> Container {
let mut query = self.selection.select("withMountedSecret");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("source", source);
return Container {
@@ -511,10 +572,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_mounted_temp(&self, path: String) -> Container {
pub fn with_mounted_temp(&self, path: impl Into<String>) -> Container {
let mut query = self.selection.select("withMountedTemp");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Container {
proc: self.proc.clone(),
@@ -522,10 +583,14 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_new_file(&self, path: String, opts: Option<ContainerWithNewFileOpts>) -> Container {
pub fn with_new_file(
&self,
path: impl Into<String>,
opts: Option<ContainerWithNewFileOpts>,
) -> Container {
let mut query = self.selection.select("withNewFile");
query = query.arg("path", path);
query = query.arg("path", path.into());
if let Some(opts) = opts {
if let Some(contents) = opts.contents {
query = query.arg("contents", contents);
@@ -543,14 +608,14 @@ impl Container {
}
pub fn with_registry_auth(
&self,
address: String,
username: String,
address: impl Into<String>,
username: impl Into<String>,
secret: SecretId,
) -> Container {
let mut query = self.selection.select("withRegistryAuth");
query = query.arg("address", address);
query = query.arg("username", username);
query = query.arg("address", address.into());
query = query.arg("username", username.into());
query = query.arg("secret", secret);
return Container {
@@ -570,10 +635,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_secret_variable(&self, name: String, secret: SecretId) -> Container {
pub fn with_secret_variable(&self, name: impl Into<String>, secret: SecretId) -> Container {
let mut query = self.selection.select("withSecretVariable");
query = query.arg("name", name);
query = query.arg("name", name.into());
query = query.arg("secret", secret);
return Container {
@@ -582,10 +647,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_unix_socket(&self, path: String, source: SocketId) -> Container {
pub fn with_unix_socket(&self, path: impl Into<String>, source: SocketId) -> Container {
let mut query = self.selection.select("withUnixSocket");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("source", source);
return Container {
@@ -594,10 +659,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_user(&self, name: String) -> Container {
pub fn with_user(&self, name: impl Into<String>) -> Container {
let mut query = self.selection.select("withUser");
query = query.arg("name", name);
query = query.arg("name", name.into());
return Container {
proc: self.proc.clone(),
@@ -605,10 +670,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn with_workdir(&self, path: String) -> Container {
pub fn with_workdir(&self, path: impl Into<String>) -> Container {
let mut query = self.selection.select("withWorkdir");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Container {
proc: self.proc.clone(),
@@ -616,10 +681,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn without_env_variable(&self, name: String) -> Container {
pub fn without_env_variable(&self, name: impl Into<String>) -> Container {
let mut query = self.selection.select("withoutEnvVariable");
query = query.arg("name", name);
query = query.arg("name", name.into());
return Container {
proc: self.proc.clone(),
@@ -627,10 +692,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn without_label(&self, name: String) -> Container {
pub fn without_label(&self, name: impl Into<String>) -> Container {
let mut query = self.selection.select("withoutLabel");
query = query.arg("name", name);
query = query.arg("name", name.into());
return Container {
proc: self.proc.clone(),
@@ -638,10 +703,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn without_mount(&self, path: String) -> Container {
pub fn without_mount(&self, path: impl Into<String>) -> Container {
let mut query = self.selection.select("withoutMount");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Container {
proc: self.proc.clone(),
@@ -649,10 +714,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn without_registry_auth(&self, address: String) -> Container {
pub fn without_registry_auth(&self, address: impl Into<String>) -> Container {
let mut query = self.selection.select("withoutRegistryAuth");
query = query.arg("address", address);
query = query.arg("address", address.into());
return Container {
proc: self.proc.clone(),
@@ -660,10 +725,10 @@ impl Container {
conn: self.conn.clone(),
};
}
pub fn without_unix_socket(&self, path: String) -> Container {
pub fn without_unix_socket(&self, path: impl Into<String>) -> Container {
let mut query = self.selection.select("withoutUnixSocket");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Container {
proc: self.proc.clone(),
@@ -683,29 +748,47 @@ pub struct Directory {
pub conn: ConnectParams,
}
pub struct DirectoryDockerBuildOpts {
pub dockerfile: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct DirectoryDockerBuildOpts<'a> {
#[builder(setter(into, strip_option))]
pub dockerfile: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub platform: Option<Platform>,
#[builder(setter(into, strip_option))]
pub build_args: Option<Vec<BuildArg>>,
pub target: Option<String>,
#[builder(setter(into, strip_option))]
pub target: Option<&'a str>,
}
pub struct DirectoryEntriesOpts {
pub path: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct DirectoryEntriesOpts<'a> {
#[builder(setter(into, strip_option))]
pub path: Option<&'a str>,
}
pub struct DirectoryPipelineOpts {
pub description: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct DirectoryPipelineOpts<'a> {
#[builder(setter(into, strip_option))]
pub description: Option<&'a str>,
}
pub struct DirectoryWithDirectoryOpts {
pub exclude: Option<Vec<String>>,
pub include: Option<Vec<String>>,
#[derive(Builder, Debug, PartialEq)]
pub struct DirectoryWithDirectoryOpts<'a> {
#[builder(setter(into, strip_option))]
pub exclude: Option<Vec<&'a str>>,
#[builder(setter(into, strip_option))]
pub include: Option<Vec<&'a str>>,
}
pub struct DirectoryWithFileOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct DirectoryWithFileOpts<'a> {
#[builder(setter(into, strip_option))]
pub permissions: Option<isize>,
}
pub struct DirectoryWithNewDirectoryOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct DirectoryWithNewDirectoryOpts<'a> {
#[builder(setter(into, strip_option))]
pub permissions: Option<isize>,
}
pub struct DirectoryWithNewFileOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct DirectoryWithNewFileOpts<'a> {
#[builder(setter(into, strip_option))]
pub permissions: Option<isize>,
}
@@ -721,10 +804,10 @@ impl Directory {
conn: self.conn.clone(),
};
}
pub fn directory(&self, path: String) -> Directory {
pub fn directory(&self, path: impl Into<String>) -> Directory {
let mut query = self.selection.select("directory");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Directory {
proc: self.proc.clone(),
@@ -767,17 +850,17 @@ impl Directory {
query.execute(&graphql_client(&self.conn))
}
pub fn export(&self, path: String) -> eyre::Result<bool> {
pub fn export(&self, path: impl Into<String>) -> eyre::Result<bool> {
let mut query = self.selection.select("export");
query = query.arg("path", path);
query = query.arg("path", path.into());
query.execute(&graphql_client(&self.conn))
}
pub fn file(&self, path: String) -> File {
pub fn file(&self, path: impl Into<String>) -> File {
let mut query = self.selection.select("file");
query = query.arg("path", path);
query = query.arg("path", path.into());
return File {
proc: self.proc.clone(),
@@ -790,10 +873,10 @@ impl Directory {
query.execute(&graphql_client(&self.conn))
}
pub fn load_project(&self, config_path: String) -> Project {
pub fn load_project(&self, config_path: impl Into<String>) -> Project {
let mut query = self.selection.select("loadProject");
query = query.arg("configPath", config_path);
query = query.arg("configPath", config_path.into());
return Project {
proc: self.proc.clone(),
@@ -801,10 +884,14 @@ impl Directory {
conn: self.conn.clone(),
};
}
pub fn pipeline(&self, name: String, opts: Option<DirectoryPipelineOpts>) -> Directory {
pub fn pipeline(
&self,
name: impl Into<String>,
opts: Option<DirectoryPipelineOpts>,
) -> Directory {
let mut query = self.selection.select("pipeline");
query = query.arg("name", name);
query = query.arg("name", name.into());
if let Some(opts) = opts {
if let Some(description) = opts.description {
query = query.arg("description", description);
@@ -819,13 +906,13 @@ impl Directory {
}
pub fn with_directory(
&self,
path: String,
path: impl Into<String>,
directory: DirectoryId,
opts: Option<DirectoryWithDirectoryOpts>,
) -> Directory {
let mut query = self.selection.select("withDirectory");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("directory", directory);
if let Some(opts) = opts {
if let Some(exclude) = opts.exclude {
@@ -844,13 +931,13 @@ impl Directory {
}
pub fn with_file(
&self,
path: String,
path: impl Into<String>,
source: FileId,
opts: Option<DirectoryWithFileOpts>,
) -> Directory {
let mut query = self.selection.select("withFile");
query = query.arg("path", path);
query = query.arg("path", path.into());
query = query.arg("source", source);
if let Some(opts) = opts {
if let Some(permissions) = opts.permissions {
@@ -866,12 +953,12 @@ impl Directory {
}
pub fn with_new_directory(
&self,
path: String,
path: impl Into<String>,
opts: Option<DirectoryWithNewDirectoryOpts>,
) -> Directory {
let mut query = self.selection.select("withNewDirectory");
query = query.arg("path", path);
query = query.arg("path", path.into());
if let Some(opts) = opts {
if let Some(permissions) = opts.permissions {
query = query.arg("permissions", permissions);
@@ -886,14 +973,14 @@ impl Directory {
}
pub fn with_new_file(
&self,
path: String,
contents: String,
path: impl Into<String>,
contents: impl Into<String>,
opts: Option<DirectoryWithNewFileOpts>,
) -> Directory {
let mut query = self.selection.select("withNewFile");
query = query.arg("path", path);
query = query.arg("contents", contents);
query = query.arg("path", path.into());
query = query.arg("contents", contents.into());
if let Some(opts) = opts {
if let Some(permissions) = opts.permissions {
query = query.arg("permissions", permissions);
@@ -917,10 +1004,10 @@ impl Directory {
conn: self.conn.clone(),
};
}
pub fn without_directory(&self, path: String) -> Directory {
pub fn without_directory(&self, path: impl Into<String>) -> Directory {
let mut query = self.selection.select("withoutDirectory");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Directory {
proc: self.proc.clone(),
@@ -928,10 +1015,10 @@ impl Directory {
conn: self.conn.clone(),
};
}
pub fn without_file(&self, path: String) -> Directory {
pub fn without_file(&self, path: impl Into<String>) -> Directory {
let mut query = self.selection.select("withoutFile");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Directory {
proc: self.proc.clone(),
@@ -970,10 +1057,10 @@ impl File {
query.execute(&graphql_client(&self.conn))
}
pub fn export(&self, path: String) -> eyre::Result<bool> {
pub fn export(&self, path: impl Into<String>) -> eyre::Result<bool> {
let mut query = self.selection.select("export");
query = query.arg("path", path);
query = query.arg("path", path.into());
query.execute(&graphql_client(&self.conn))
}
@@ -1014,8 +1101,11 @@ pub struct GitRef {
pub conn: ConnectParams,
}
pub struct GitRefTreeOpts {
pub ssh_known_hosts: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct GitRefTreeOpts<'a> {
#[builder(setter(into, strip_option))]
pub ssh_known_hosts: Option<&'a str>,
#[builder(setter(into, strip_option))]
pub ssh_auth_socket: Option<SocketId>,
}
@@ -1051,10 +1141,10 @@ pub struct GitRepository {
}
impl GitRepository {
pub fn branch(&self, name: String) -> GitRef {
pub fn branch(&self, name: impl Into<String>) -> GitRef {
let mut query = self.selection.select("branch");
query = query.arg("name", name);
query = query.arg("name", name.into());
return GitRef {
proc: self.proc.clone(),
@@ -1067,10 +1157,10 @@ impl GitRepository {
query.execute(&graphql_client(&self.conn))
}
pub fn commit(&self, id: String) -> GitRef {
pub fn commit(&self, id: impl Into<String>) -> GitRef {
let mut query = self.selection.select("commit");
query = query.arg("id", id);
query = query.arg("id", id.into());
return GitRef {
proc: self.proc.clone(),
@@ -1078,10 +1168,10 @@ impl GitRepository {
conn: self.conn.clone(),
};
}
pub fn tag(&self, name: String) -> GitRef {
pub fn tag(&self, name: impl Into<String>) -> GitRef {
let mut query = self.selection.select("tag");
query = query.arg("name", name);
query = query.arg("name", name.into());
return GitRef {
proc: self.proc.clone(),
@@ -1101,20 +1191,26 @@ pub struct Host {
pub conn: ConnectParams,
}
pub struct HostDirectoryOpts {
pub exclude: Option<Vec<String>>,
pub include: Option<Vec<String>>,
#[derive(Builder, Debug, PartialEq)]
pub struct HostDirectoryOpts<'a> {
#[builder(setter(into, strip_option))]
pub exclude: Option<Vec<&'a str>>,
#[builder(setter(into, strip_option))]
pub include: Option<Vec<&'a str>>,
}
pub struct HostWorkdirOpts {
pub exclude: Option<Vec<String>>,
pub include: Option<Vec<String>>,
#[derive(Builder, Debug, PartialEq)]
pub struct HostWorkdirOpts<'a> {
#[builder(setter(into, strip_option))]
pub exclude: Option<Vec<&'a str>>,
#[builder(setter(into, strip_option))]
pub include: Option<Vec<&'a str>>,
}
impl Host {
pub fn directory(&self, path: String, opts: Option<HostDirectoryOpts>) -> Directory {
pub fn directory(&self, path: impl Into<String>, opts: Option<HostDirectoryOpts>) -> Directory {
let mut query = self.selection.select("directory");
query = query.arg("path", path);
query = query.arg("path", path.into());
if let Some(opts) = opts {
if let Some(exclude) = opts.exclude {
query = query.arg("exclude", exclude);
@@ -1130,10 +1226,10 @@ impl Host {
conn: self.conn.clone(),
};
}
pub fn env_variable(&self, name: String) -> HostVariable {
pub fn env_variable(&self, name: impl Into<String>) -> HostVariable {
let mut query = self.selection.select("envVariable");
query = query.arg("name", name);
query = query.arg("name", name.into());
return HostVariable {
proc: self.proc.clone(),
@@ -1141,10 +1237,10 @@ impl Host {
conn: self.conn.clone(),
};
}
pub fn unix_socket(&self, path: String) -> Socket {
pub fn unix_socket(&self, path: impl Into<String>) -> Socket {
let mut query = self.selection.select("unixSocket");
query = query.arg("path", path);
query = query.arg("path", path.into());
return Socket {
proc: self.proc.clone(),
@@ -1263,28 +1359,39 @@ pub struct Query {
pub conn: ConnectParams,
}
pub struct QueryContainerOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct QueryContainerOpts<'a> {
#[builder(setter(into, strip_option))]
pub id: Option<ContainerId>,
#[builder(setter(into, strip_option))]
pub platform: Option<Platform>,
}
pub struct QueryDirectoryOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct QueryDirectoryOpts<'a> {
#[builder(setter(into, strip_option))]
pub id: Option<DirectoryId>,
}
pub struct QueryGitOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct QueryGitOpts<'a> {
#[builder(setter(into, strip_option))]
pub keep_git_dir: Option<bool>,
}
pub struct QueryPipelineOpts {
pub description: Option<String>,
#[derive(Builder, Debug, PartialEq)]
pub struct QueryPipelineOpts<'a> {
#[builder(setter(into, strip_option))]
pub description: Option<&'a str>,
}
pub struct QuerySocketOpts {
#[derive(Builder, Debug, PartialEq)]
pub struct QuerySocketOpts<'a> {
#[builder(setter(into, strip_option))]
pub id: Option<SocketId>,
}
impl Query {
pub fn cache_volume(&self, key: String) -> CacheVolume {
pub fn cache_volume(&self, key: impl Into<String>) -> CacheVolume {
let mut query = self.selection.select("cacheVolume");
query = query.arg("key", key);
query = query.arg("key", key.into());
return CacheVolume {
proc: self.proc.clone(),
@@ -1341,10 +1448,10 @@ impl Query {
conn: self.conn.clone(),
};
}
pub fn git(&self, url: String, opts: Option<QueryGitOpts>) -> GitRepository {
pub fn git(&self, url: impl Into<String>, opts: Option<QueryGitOpts>) -> GitRepository {
let mut query = self.selection.select("git");
query = query.arg("url", url);
query = query.arg("url", url.into());
if let Some(opts) = opts {
if let Some(keep_git_dir) = opts.keep_git_dir {
query = query.arg("keepGitDir", keep_git_dir);
@@ -1366,10 +1473,10 @@ impl Query {
conn: self.conn.clone(),
};
}
pub fn http(&self, url: String) -> File {
pub fn http(&self, url: impl Into<String>) -> File {
let mut query = self.selection.select("http");
query = query.arg("url", url);
query = query.arg("url", url.into());
return File {
proc: self.proc.clone(),
@@ -1377,10 +1484,10 @@ impl Query {
conn: self.conn.clone(),
};
}
pub fn pipeline(&self, name: String, opts: Option<QueryPipelineOpts>) -> Query {
pub fn pipeline(&self, name: impl Into<String>, opts: Option<QueryPipelineOpts>) -> Query {
let mut query = self.selection.select("pipeline");
query = query.arg("name", name);
query = query.arg("name", name.into());
if let Some(opts) = opts {
if let Some(description) = opts.description {
query = query.arg("description", description);
@@ -1393,10 +1500,10 @@ impl Query {
conn: self.conn.clone(),
};
}
pub fn project(&self, name: String) -> Project {
pub fn project(&self, name: impl Into<String>) -> Project {
let mut query = self.selection.select("project");
query = query.arg("name", name);
query = query.arg("name", name.into());
return Project {
proc: self.proc.clone(),
@@ -1462,7 +1569,7 @@ impl Socket {
query.execute(&graphql_client(&self.conn))
}
}
#[derive(Serialize)]
#[derive(Serialize, Clone, PartialEq, Debug)]
pub enum CacheSharingMode {
SHARED,
PRIVATE,

17
crates/dagger-sdk/tests/mod.rs
View File

@@ -1,19 +1,18 @@
use dagger_sdk::{connect, ContainerExecOpts};
use dagger_sdk::{connect, ContainerExecOptsBuilder};
#[test]
fn test_example_container() {
let client = connect().unwrap();
let alpine = client.container(None).from("alpine:3.16.2".into());
let alpine = client.container(None).from("alpine:3.16.2");
let out = alpine
.exec(Some(ContainerExecOpts {
args: Some(vec!["cat".into(), "/etc/alpine-release".into()]),
stdin: None,
redirect_stdout: None,
redirect_stderr: None,
experimental_privileged_nesting: None,
}))
.exec(Some(
ContainerExecOptsBuilder::default()
.args(vec!["cat", "/etc/alpine-release"])
.build()
.unwrap(),
))
.stdout()
.unwrap();