5aa9b29d8c
Change-Id: I0d917a9a308227b13d096def22945db917830d18 Reviewed-on: https://cl.tvl.fyi/c/depot/+/10629 Reviewed-by: raitobezarius <tvl@lahfa.xyz> Autosubmit: flokli <flokli@flokli.de> Tested-by: BuildkiteCI
28 lines
724 B
Rust
28 lines
724 B
Rust
use tonic::{async_trait, transport::Channel};
|
|
|
|
use crate::proto::{build_service_client::BuildServiceClient, Build, BuildRequest};
|
|
|
|
use super::BuildService;
|
|
|
|
pub struct GRPCBuildService {
|
|
client: BuildServiceClient<Channel>,
|
|
}
|
|
|
|
impl GRPCBuildService {
|
|
#[allow(dead_code)]
|
|
pub fn from_client(client: BuildServiceClient<Channel>) -> Self {
|
|
Self { client }
|
|
}
|
|
}
|
|
|
|
#[async_trait]
|
|
impl BuildService for GRPCBuildService {
|
|
async fn do_build(&self, request: BuildRequest) -> std::io::Result<Build> {
|
|
let mut client = self.client.clone();
|
|
client
|
|
.do_build(request)
|
|
.await
|
|
.map(|resp| resp.into_inner())
|
|
.map_err(std::io::Error::other)
|
|
}
|
|
}
|