Function new_engine_client_test

app/src/grpc/mod.rs:89–114

(mut client: Option<DuplexStream>)

    use tower::service_fn;

    pub async fn new_engine_client_test(mut client: Option<DuplexStream>) -> GrpcEngineClient {
        let channel = Endpoint::try_from("http://[::]:50051")
            .unwrap()
            .connect_with_connector(service_fn(move |_: Uri| {
                let client = client.take();

                async move {
                    if let Some(client) = client {
                        Ok(hyper_util::rt::TokioIo::new(client))
                    } else {
                        Err(std::io::Error::other("Client already taken"))
                    }
                }
            }))
            .await
            .unwrap();

        let channel = ServiceBuilder::new()
            .layer(InterceptorLayer::new(QoveryInterceptor {
                token: AsciiMetadataValue::from_static(""),
                cluster_id: AsciiMetadataValue::from_static(""),
            }))
            .service(channel);

        EngineClient::new(channel)
    }
}