chore: improve supported services example (#3)

Author: rsfreitas

examples/services/grpc/src/main.rs

@@ -1,34 +1,37 @@
+use std::sync::Arc;
+
 pub mod helloworld {
     include!("generated/helloworld.rs"); // Include generated code
 }
 
-use std::sync::Arc;
 use mikros::features;
-use mikros::service::{builder::ServiceBuilder, context, lifecycle};
+use mikros::service::{builder::ServiceBuilder, context};
 use tonic::{Request, Response, Status};
 
 use helloworld::greeter_server::{Greeter, GreeterServer};
 use helloworld::{HelloReply, HelloRequest};
 
 #[derive(Clone)]
 pub struct MyGreeter {
-    ctx: Arc<mikros::FutureMutex<Context>>
+    ctx: Arc<mikros::FutureMutex<Context>>,
 }
 
 impl MyGreeter {
     pub fn new(ctx: Arc<mikros::FutureMutex<Context>>) -> Self {
-        Self { 
-            ctx: ctx.clone()
-        }
+        Self { ctx: ctx.clone() }
     }
 }
 
 #[tonic::async_trait]
 impl Greeter for MyGreeter {
-    async fn say_hello(&self, request: Request<HelloRequest>) -> Result<Response<HelloReply>, Status> {
+    async fn say_hello(
+        &self,
+        request: Request<HelloRequest>,
+    ) -> Result<Response<HelloReply>, Status> {
         let ctx = context::from_request(&request);
         ctx.logger().info("say hello RPC called");
-        ctx.logger().info(format!("the inner value is: {}", self.ctx.lock().await.value).as_str());
+        ctx.logger()
+            .info(format!("the inner value is: {}", self.ctx.lock().await.value).as_str());
 
         let _ = features::example::retrieve(&ctx, |api| {
             api.do_something();
@@ -45,41 +48,25 @@ impl Greeter for MyGreeter {
 
 #[derive(Clone)]
 pub struct Context {
-    value: i32
-}
-
-#[tonic::async_trait]
-impl lifecycle::Lifecycle for Context {
-    async fn on_start(&mut self) -> mikros::errors::Result<()> {
-        println!("grpc on_start called");
-        self.value = 42;
-        Ok(())
-    }
-
-    async fn on_finish(&self) -> mikros::errors::Result<()> {
-        Ok(())
-    }
+    value: i32,
 }
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let ctx = Arc::new(mikros::FutureMutex::new(Context{ value: 0 }));
+    let ctx = Arc::new(mikros::FutureMutex::new(Context { value: 0 }));
     let greeter = Arc::new(MyGreeter::new(ctx.clone()));
     let greeter_service = GreeterServer::from_arc(greeter);
 
-    let svc = ServiceBuilder::default()
-//        .grpc(greeter_service)
-        .grpc_with_lifecycle(greeter_service, ctx.clone())
-        .build();
+    let svc = ServiceBuilder::default().grpc(greeter_service).build();
 
     match svc {
         Ok(mut svc) => {
             if let Err(e) = svc.start().await {
                 println!("application error: {}", e);
             }
-        },
-        Err(e) => panic!("{}", e.to_string())
+        }
+        Err(e) => panic!("{}", e.to_string()),
     }
 
     Ok(())
-}
+}

examples/services/grpc_with_lifecycle/Cargo.toml

@@ -0,0 +1,13 @@
+[package]
+name = "grpc_with_lifecycle"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+mikros = { path = "../../../" }
+prost = "0.13.3"
+tokio = { version = "1.41.1", features = ["full"] }
+tonic = "0.12.3"
+
+[build-dependencies]
+tonic-build = "0.12.3"

examples/services/grpc_with_lifecycle/build.rs

@@ -0,0 +1,8 @@
+fn main() {
+    tonic_build::configure()
+        .out_dir("src/generated")
+        .compile_protos(&["proto/helloworld.proto"], &["proto"])
+        .unwrap_or_else(|e| panic!("Failed to compile protos: {:?}", e));
+
+    println!("cargo:rerun-if-changed=proto/helloworld.proto");
+}

examples/services/grpc_with_lifecycle/proto/helloworld.proto

@@ -0,0 +1,20 @@
+// proto/helloworld.proto
+syntax = "proto3";
+
+package helloworld;
+
+// The greeting service definition.
+service Greeter {
+  // Sends a greeting
+  rpc SayHello (HelloRequest) returns (HelloReply);
+}
+
+// The request message containing the user's name.
+message HelloRequest {
+  string name = 1;
+}
+
+// The response message containing the greetings.
+message HelloReply {
+  string message = 1;
+}

examples/services/grpc_with_lifecycle/service.toml

@@ -0,0 +1,5 @@
+name = "grpc-example"
+version = "v0.1.0"
+language = "rust"
+product = "examples"
+types = ["grpc"]