chore: add custom reflection server for easy debug

Cargo.toml

@@ -16,6 +16,8 @@ tower = "0.4.13"
 hyper-util = {version = "0.1.3",features = ["tokio"]}
 http-body-util = "0.1.0"
 anyhow = "1.0.79"
+tokio-stream = "0.1.14"
+protox-parse = "0.6.0"
 
 [build-dependencies]
 tonic-build = "0.10.2"

build.rs

@@ -4,11 +4,4 @@ fn main() {
     let mut news = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
     news.push("news.proto");
     tonic_build::compile_protos(news).expect("Failed to compile protos");
-
-    let out_dir = PathBuf::from(std::env::var("OUT_DIR").unwrap());
-
-    tonic_build::configure()
-        .file_descriptor_set_path(out_dir.join("news_descriptor.bin"))
-        .compile(&["news.proto"], &["proto"])
-        .unwrap();
 }

renovate.json

@@ -1,6 +1,4 @@
 {
   "$schema": "https://docs.renovatebot.com/renovate-schema.json",
-  "extends": [
-    "config:recommended"
-  ]
+  "extends": ["config:recommended"]
 }

src/main.rs

@@ -1,16 +1,19 @@
-use tonic::{transport::Server as TonicServer, Response, Status};
+mod server;
 
 use crate::news::news_service_server::NewsServiceServer;
+use crate::server::Builder;
 use anyhow::Result;
 use news::news_service_server::NewsService;
 use news::{MultipleNewsId, News, NewsId, NewsList};
+use prost_types::FileDescriptorSet;
+use std::fs::File;
+use std::io::Read;
 use std::sync::{Arc, Mutex};
+use tonic::{transport::Server as TonicServer, Response, Status};
 use tower::make::Shared;
 
 pub mod news {
     tonic::include_proto!("news"); // The package name specified in your .proto
-    pub(crate) const FILE_DESCRIPTOR_SET: &[u8] =
-        tonic::include_file_descriptor_set!("news_descriptor");
 }
 
 #[derive(Debug, Default)]
@@ -152,16 +155,24 @@ async fn main() -> Result<()> {
     let addr = ([127, 0, 0, 1], 50051).into();
 
     let news_service = MyNewsService::new();
-    let service = tonic_reflection::server::Builder::configure()
-        .register_encoded_file_descriptor_set(news::FILE_DESCRIPTOR_SET)
-        .build()
-        .unwrap();
+
+    let mut file = File::open("news.proto")?;
+    let mut content = String::new();
+    file.read_to_string(&mut content)?;
+
+    let news = protox_parse::parse("news.proto", &content)?;
+    let mut news_descriptor_set = FileDescriptorSet::default();
+    news_descriptor_set.file.push(news);
+
+    let service = Builder::configure()
+        .register_file_descriptor_set(news_descriptor_set)
+        .build()?;
 
     println!("NewsService server listening on {}", addr);
 
     let tonic_service = TonicServer::builder()
-        .add_service(NewsServiceServer::new(news_service))
         .add_service(service)
+        .add_service(NewsServiceServer::new(news_service))
         .into_service();
     let make_svc = Shared::new(tonic_service);
     println!("Server listening on http://{}", addr);