lgtm-cli 0.3.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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! Reusable LGTM backend with greeting and health RPC services.

pub mod database;
pub mod error;
pub mod extensions;
pub mod forge;
pub mod models;
pub mod rpc;
pub mod services;
pub mod utils;

use connectrpc::{Encodable, RequestContext, Response, Router, ServiceRequest, ServiceResult};
use connectrpc_health::{StaticChecker, install_static};
use std::sync::Arc;

/// Message types, service traits, and clients generated from the shared schema.
pub mod proto {
    connectrpc::include_generated!();
}

use proto::lgtm::v1::{
    GREETER_SERVICE_SERVICE_NAME, GreeterService, SayHelloRequest, SayHelloResponse,
};

struct Greeter;

impl GreeterService for Greeter {
    #[tracing::instrument(name = "rpc_request", skip_all, fields(rpc.method = "lgtm.v1.GreeterService/SayHello"))]
    async fn say_hello<'a>(
        &'a self,
        _context: RequestContext,
        request: ServiceRequest<'_, SayHelloRequest>,
    ) -> ServiceResult<impl Encodable<SayHelloResponse> + Send + use<'a>> {
        let name = request.name.trim();
        let name = if name.is_empty() { "World" } else { name };
        Response::ok(SayHelloResponse {
            message: format!("Hello, {name}!"),
            ..Default::default()
        })
    }
}

/// Construct the RPC router and its health status controller.
pub fn router() -> (Router, Arc<StaticChecker>) {
    install_static(
        Router::new().add_service(Arc::new(Greeter)),
        [GREETER_SERVICE_SERVICE_NAME],
    )
}

/// Construct a stateful API router sharing one database across all RPC services.
pub fn router_with_database(database: database::Database) -> (Router, Arc<StaticChecker>) {
    let api = Arc::new(rpc::Api::new(database));
    install_static(
        Router::new()
            .add_service(Arc::new(Greeter))
            .add_service::<rpc::Api, proto::lgtm::v1::IdentityServiceRegisterMarker>(api.clone())
            .add_service::<rpc::Api, proto::lgtm::v1::ReviewServiceRegisterMarker>(api.clone())
            .add_service::<rpc::Api, proto::lgtm::v1::DiffServiceRegisterMarker>(api),
        [
            GREETER_SERVICE_SERVICE_NAME,
            proto::lgtm::v1::IDENTITY_SERVICE_SERVICE_NAME,
            proto::lgtm::v1::REVIEW_SERVICE_SERVICE_NAME,
            proto::lgtm::v1::DIFF_SERVICE_SERVICE_NAME,
        ],
    )
}