grpc

Connect-JSON unary RPC client (+ optional server)

Crate	sova-grpc 0.1.2
Plugin id	grpc
Category	APIs

Install

cargo add sova --features grpc

Features

Feature	What you get
grpc	Connect-JSON unary RPC client (req.grpc(), FakeGrpc).

Overview

Connect-JSON unary RPC for Sova — client first, optional server.

 use sova_grpc::{FakeGrpc, Grpc, GrpcExt};
 use serde::{Deserialize, Serialize};

 #[derive(Serialize)]
 struct HelloIn { name: String }
 #[derive(Deserialize)]
 struct HelloOut { message: String }

 let fake = FakeGrpc::new().stub_json("hello.Greeter/SayHello", serde_json::json!({
     "message": "hi"
 }));
 app.install(Grpc::fake(fake));

 let out: HelloOut = req.grpc().call("hello.Greeter/SayHello", &HelloIn { name: "a".into() }).await?;

Quick start

Audience: app authors calling unary RPC over Connect-JSON (no tonic / .proto required).

Modes

Mode	Install	Handler API
Client only	Grpc::client(url) / Grpc::fake(...)	req.grpc()
Server only	Grpc::server().unary(...)	mount/bind only — use req.try_grpc()
Composite	Grpc::server().unary(...).client(url)	serve + req.grpc()

Errors use a Connect-style JSON envelope: { "code", "message" }.

Client

sova = { version = "0.1", features = ["grpc", "testing"] }

use sova::{FakeGrpc, Grpc, GrpcExt};
use serde::{Deserialize, Serialize};
use serde_json::json;

#[derive(Serialize)]
struct HelloIn { name: String }
#[derive(Deserialize)]
struct HelloOut { message: String }

let fake = FakeGrpc::new().stub_json(
    "hello.Greeter/SayHello",
    json!({ "message": "hi" }),
);
app.install(Grpc::fake(fake));

let out: HelloOut = req.grpc()
    .call("hello.Greeter/SayHello", &HelloIn { name: "a".into() })
    .await?;

Live: Grpc::client("http://127.0.0.1:50051") or [grpc] client_url=… / GRPC_URL.

Server (optional)

Mount unary handlers on the main HTTP app (paths /pkg.Service/Method), optionally .bind("127.0.0.1:50051") as a BackgroundService:

app.install(
    Grpc::server()
        .unary("hello.Greeter/SayHello", |req: HelloIn| async move {
            Ok(HelloOut { message: format!("hi {}", req.name) })
        })
        .unary_with_request("hello.Greeter/AuthHello", |http, req: HelloIn| async move {
            let user = http.header("x-user").unwrap_or("anon");
            Ok(HelloOut { message: format!("hi {} ({})", req.name, user) })
        })
        .client_from_env(),
);

Examples

• examples/api/api_grpc

Related

http · graphql