feat: implement gRPC client support to allow outbound gRPC calls

Signed-off-by: Aditya <[email protected]>

Author: Aditya1404Sal

.gitignore

@@ -5,6 +5,7 @@ tests/output
 # Keep Wasm files for testing
 !tests/fixtures/*.wasm
 !crates/wasmcloud/tests/fixtures/*.wasm
+!crates/wash-runtime/tests/fixtures/*.wasm
 
 # Ignore IDE specific files
 .vscode

Cargo.lock

@@ -59,7 +59,7 @@ uuid = { workspace = true }
 wasm-metadata = { workspace = true }
 wasm-pkg-client = { workspace = true }
 wasm-pkg-core = { workspace = true }
-wash-runtime = { workspace = true, features = ["washlet", "oci", "wasi-config", "wasi-logging"] }
+wash-runtime = { workspace = true, features = ["washlet", "oci", "wasi-config", "wasi-logging", "grpc"] }
 wasmtime = { workspace = true }
 wasmtime-wasi = { workspace = true }
 which = { workspace = true }

Cargo.toml

@@ -13,6 +13,7 @@ path = "src/lib.rs"
 
 [features]
 default = ["wasi-config", "wasi-logging", "wasi-blobstore", "wasi-keyvalue", "washlet"]
+grpc = ["dep:once_cell"]
 oci = ["dep:oci-client", "dep:oci-wasm", "dep:docker_credential", "dep:sha2", "dep:wit-component"]
 washlet = ["oci"]
 wasi-config = []
@@ -73,6 +74,11 @@ oci-client = { workspace = true, optional = true, features = ["rustls-tls", "rus
 oci-wasm = { workspace = true, optional = true, features = ["rustls-tls"] }
 sha2 = { workspace = true, optional = true }
 wit-component = { workspace = true, optional = true }
+hyper-util = { version = "0.1.18", features = ["client-legacy", "http1", "http2", "tokio"] }
+http-body-util = "0.1.3"
+once_cell = { version = "1.19.0", optional = true }
+tower-service = "0.3.3"
+webpki-roots = "0.26"
 
 [build-dependencies]
 anyhow = { workspace = true, default-features = true }

crates/wash-runtime/Cargo.toml

@@ -1,5 +1,5 @@
 use std::env;
-use std::fs::{self};
+use std::fs;
 use std::path::PathBuf;
 
 fn workspace_dir() -> anyhow::Result<PathBuf> {
@@ -28,27 +28,45 @@ fn main() {
     let top_proto_dir = workspace_dir.join("proto");
     let proto_dir = top_proto_dir.join("wasmcloud/runtime/v2");
 
-    let proto_dir_files = fs::read_dir(proto_dir).expect("failed to list files in `proto_dir`");
-    let proto_files: Vec<PathBuf> = proto_dir_files
-        .into_iter()
-        .map(|file| file.unwrap().path())
-        .collect();
-
-    let descriptor_file = out_dir.join("runtime.bin");
-
-    tonic_prost_build::configure()
-        .compile_well_known_types(true)
-        .file_descriptor_set_path(&descriptor_file)
-        .extern_path(".google.protobuf", "::pbjson_types")
-        .compile_protos(&proto_files, &[top_proto_dir])
-        .expect("failed to compile protos");
-
-    // Generate serde bindings for the Runtime API
-    let descriptor_bytes = std::fs::read(descriptor_file).expect("failed to read descriptor file");
-
-    pbjson_build::Builder::new()
-        .register_descriptors(&descriptor_bytes)
-        .expect("failed to register descriptor")
-        .build(&[".wasmcloud.runtime.v2"])
-        .expect("failed to build final protos");
+    // Compile Runtime API protos if directory exists
+    if proto_dir.exists() {
+        let proto_dir_files =
+            fs::read_dir(&proto_dir).expect("failed to list files in `proto_dir`");
+        let proto_files: Vec<PathBuf> = proto_dir_files
+            .into_iter()
+            .map(|file| file.expect("failed to read proto file").path())
+            .collect();
+
+        let descriptor_file = out_dir.join("runtime.bin");
+
+        tonic_prost_build::configure()
+            .compile_well_known_types(true)
+            .file_descriptor_set_path(&descriptor_file)
+            .extern_path(".google.protobuf", "::pbjson_types")
+            .compile_protos(&proto_files, &[top_proto_dir])
+            .expect("failed to compile Runtime API protos");
+
+        // Generate serde bindings for the Runtime API
+        let descriptor_bytes =
+            std::fs::read(&descriptor_file).expect("failed to read descriptor file");
+
+        pbjson_build::Builder::new()
+            .register_descriptors(&descriptor_bytes)
+            .expect("failed to register descriptor")
+            .build(&[".wasmcloud.runtime.v2"])
+            .expect("failed to build Runtime API protos");
+    }
+
+    // Compile test proto files if they exist
+    let test_proto_file = workspace_dir.join("tests/proto/helloworld.proto");
+    if test_proto_file.exists() {
+        println!("cargo:rerun-if-changed={}", test_proto_file.display());
+
+        tonic_prost_build::configure()
+            .build_client(false)
+            .build_server(true)
+            .build_transport(true)
+            .compile_protos(&[&test_proto_file], &[&workspace_dir.join("tests/proto")])
+            .expect("failed to compile test protos");
+    }
 }