pub mod pb { tonic::include_proto!("/grpc.examples.unaryecho"); } use hyper::Uri; use hyper_util::{client::legacy::connect::HttpConnector, rt::TokioExecutor}; use occlum_ratls::prelude::*; use occlum_ratls::RaTlsConfigBuilder; use occlum_sgx::SGXMeasurement; use pb::{echo_client::EchoClient, EchoRequest}; use tokio_rustls::rustls::ClientConfig; #[tokio::main] async fn main() -> Result<(), Box> { let mrsigner_hex = "83D719E77DEACA1470F6BAF62A4D774303C899DB69020F9C70EE1DFC08C7CE9E"; let mut mrsigner = [0u8; 32]; hex::decode_to_slice(mrsigner_hex, &mut mrsigner).expect("mrsigner decoding failed"); let config = RaTlsConfig::new().allow_instance_measurement( InstanceMeasurement::new().with_mrsigners(vec![SGXMeasurement::new(mrsigner)]), ); let tls = ClientConfig::from_ratls_config(config) .map_err(|e| std::io::Error::new(std::io::ErrorKind::Other, format!("{}", e)))?; let mut http = HttpConnector::new(); http.enforce_http(false); // We have to do some wrapping here to map the request type from // `https://example.com` -> `https://[::1]:50051` because `rustls` // doesn't accept ip's as `ServerName`. let connector = tower::ServiceBuilder::new() .layer_fn(move |s| { let tls = tls.clone(); hyper_rustls::HttpsConnectorBuilder::new() .with_tls_config(tls) .https_or_http() .enable_http2() .wrap_connector(s) }) // Since our cert is signed with `example.com` but we actually want to connect // to a local server we will override the Uri passed from the `HttpsConnector` // and map it to the correct `Uri` that will connect us directly to the local server. .map_request(|_| Uri::from_static("https://[::1]:50051")) .service(http); let client = hyper_util::client::legacy::Client::builder(TokioExecutor::new()).build(connector); // Using `with_origin` will let the codegenerated client set the `scheme` and // `authority` from the provided `Uri`. let uri = Uri::from_static("https://example.com"); let mut client = EchoClient::with_origin(client, uri); let request = tonic::Request::new(EchoRequest { message: "hello".into(), }); let response = client.unary_echo(request).await?; println!("RESPONSE={:?}", response); Ok(()) }