Skip to content

Commit c6784b7

Browse files
committed
Remove service namespace from the RPC
1 parent 068785c commit c6784b7

File tree

5 files changed

+18
-7
lines changed

5 files changed

+18
-7
lines changed

guest-agent/rpc/build.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,6 @@ fn main() {
66
.disable_package_emission()
77
.enable_serde_extension()
88
.disable_service_name_emission()
9-
.keep_service_name("Tappd")
10-
.keep_service_name("Worker")
119
.compile_dir("./proto")
1210
.expect("failed to compile proto files");
1311
}

guest-agent/src/main.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ async fn run_internal_v0(state: AppState, figment: Figment) -> Result<()> {
4848
let rocket = rocket::custom(figment)
4949
.mount(
5050
"/prpc/",
51-
ra_rpc::prpc_routes!(AppState, InternalRpcHandlerV0),
51+
ra_rpc::prpc_routes!(AppState, InternalRpcHandlerV0, trim: "Tappd."),
5252
)
5353
.manage(state);
5454
let ignite = rocket
@@ -98,7 +98,10 @@ async fn run_internal(state: AppState, figment: Figment) -> Result<()> {
9898
async fn run_external(state: AppState, figment: Figment) -> Result<()> {
9999
let rocket = rocket::custom(figment)
100100
.mount("/", http_routes::external_routes(state.config()))
101-
.mount("/prpc", ra_rpc::prpc_routes!(AppState, ExternalRpcHandler))
101+
.mount(
102+
"/prpc",
103+
ra_rpc::prpc_routes!(AppState, ExternalRpcHandler, trim: "Worker."),
104+
)
102105
.attach(AdHoc::on_response("Add app version header", |_req, res| {
103106
Box::pin(async move {
104107
res.set_raw_header("X-App-Version", app_version());

kms/rpc/build.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ fn main() {
55
.build_scale_ext(false)
66
.disable_package_emission()
77
.enable_serde_extension()
8+
.disable_service_name_emission()
89
.compile_dir("./proto")
910
.expect("failed to compile proto files");
1011
}

kms/src/main.rs

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,10 @@ async fn run_onboard_service(kms_config: KmsConfig, figment: Figment) -> Result<
6262

6363
let _ = rocket::custom(figment)
6464
.mount("/", rocket::routes![index, finish])
65-
.mount("/prpc", ra_rpc::prpc_routes!(OnboardState, OnboardHandler))
65+
.mount(
66+
"/prpc",
67+
ra_rpc::prpc_routes!(OnboardState, OnboardHandler, trim: "Onboard."),
68+
)
6669
.manage(state)
6770
.launch()
6871
.await
@@ -107,7 +110,10 @@ async fn main() -> Result<()> {
107110
res.set_raw_header("X-App-Version", app_version());
108111
})
109112
}))
110-
.mount("/prpc", ra_rpc::prpc_routes!(KmsState, RpcHandler))
113+
.mount(
114+
"/prpc",
115+
ra_rpc::prpc_routes!(KmsState, RpcHandler, trim: "KMS."),
116+
)
111117
.manage(state);
112118

113119
let verifier = QuoteVerifier::new(pccs_url);

vmm/src/main.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,10 @@ async fn run_external_api(app: App, figment: Figment, api_auth: ApiToken) -> Res
4747
.mount("/", main_routes::routes())
4848
.mount("/guest", ra_rpc::prpc_routes!(App, GuestApiHandler))
4949
.mount("/api", ra_rpc::prpc_routes!(App, HostApiHandler))
50-
.mount("/prpc", ra_rpc::prpc_routes!(App, RpcHandler, trim: "Teepod."))
50+
.mount(
51+
"/prpc",
52+
ra_rpc::prpc_routes!(App, RpcHandler, trim: "Teepod."),
53+
)
5154
.manage(app)
5255
.manage(api_auth)
5356
.attach(AdHoc::on_response("Add app rev header", |_req, res| {

0 commit comments

Comments
 (0)