lgtm-cli 0.4.0

Run LGTM code reviews with a bundled web UI and gRPC server.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

//! Generated review client; command modules do not own transport details.
use crate::{
    backend::proto::lgtm::v1::{HelloReviewRequest, HelloReviewResponse, ReviewServiceClient},
    store::Store,
};
use anyhow::{Context, Result};
use connectrpc::{
    Protocol,
    client::{CallOptions, ClientConfig, HttpClient},
};
use std::time::Duration;

pub struct Client {
    endpoint_url: String,
}

impl Client {
    pub fn new(store: &Store) -> Result<Self> {
        let endpoint_url = std::env::var("LGTM_RPC_URL")
            .ok()
            .filter(|value| !value.trim().is_empty())
            .or_else(|| {
                store
                    .instance()
                    .map(|instance| format!("{}/rpc", instance.url()))
            })
            .context("LGTM backend is unavailable; run lgtm up --no-open or set LGTM_RPC_URL")?;
        Ok(Self { endpoint_url })
    }

    // Public ------------------------------------------------------------------

    pub async fn get_hello(&self, name: &str) -> Result<HelloReviewResponse> {
        let config = ClientConfig::new(self.endpoint_url.parse()?).with_protocol(Protocol::Connect);
        let response = ReviewServiceClient::new(HttpClient::plaintext(), config)
            .hello_review_with_options(
                HelloReviewRequest {
                    name: name.into(),
                    ..Default::default()
                },
                CallOptions::default().with_timeout(Duration::from_secs(5)),
            )
            .await?;
        Ok(response.into_owned())
    }
}