@connectrpc/connect-node

Connect is a family of libraries for building and consuming APIs on different languages and platforms, and @connectrpc/connect brings type-safe APIs with Protobuf to TypeScript.

@connectrpc/connect-node provides the following adapters for Node.js:

createConnectTransport()

Lets your clients running on Node.js talk to a server with the Connect protocol:

1import { createClient } from "@connectrpc/connect";
2+ import { createConnectTransport } from "@connectrpc/connect-node";
3import { ElizaService } from "./gen/eliza_connect.js";
4
5+ // A transport for clients using the Connect protocol with Node.js `http` module
6+ const transport = createConnectTransport({
7+   baseUrl: "https://demo.connectrpc.com",
8+   httpVersion: "1.1"
9+ });
10
11const client = createClient(ElizaService, transport);
12const { sentence } = await client.say({ sentence: "I feel happy." });
13console.log(sentence) // you said: I feel happy.

createGrpcTransport()

Lets your clients running on Node.js talk to a server with the gRPC protocol:

1import { createClient } from "@connectrpc/connect";
2+ import { createGrpcTransport } from "@connectrpc/connect-node";
3import { ElizaService } from "./gen/eliza_connect.js";
4
5+ // A transport for clients using the gRPC protocol with Node.js `http2` module
6+ const transport = createGrpcTransport({
7+   baseUrl: "https://demo.connectrpc.com",
8+ });
9
10const client = createClient(ElizaService, transport);
11const { sentence } = await client.say({ sentence: "I feel happy." });
12console.log(sentence) // you said: I feel happy.

createGrpcWebTransport()

Lets your clients running on Node.js talk to a server with the gRPC-web protocol:

1import { createClient } from "@connectrpc/connect";
2+ import { createGrpcWebTransport } from "@connectrpc/connect-node";
3import { ElizaService } from "./gen/eliza_connect.js";
4
5+ // A transport for clients using the Connect protocol with Node.js `http` module
6+ const transport = createGrpcWebTransport({
7+   baseUrl: "https://demo.connectrpc.com",
8+   httpVersion: "1.1"
9+ });
10
11const client = createClient(ElizaService, transport);
12const { sentence } = await client.say({ sentence: "I feel happy." });
13console.log(sentence) // you said: I feel happy.

connectNodeAdapter()

Run your Connect RPCs on the Node.js http, https, or http2 modules.

1// connect.ts
2import { ConnectRouter } from "@connectrpc/connect";
3
4export default function (router: ConnectRouter) {
5  // implement rpc Say(SayRequest) returns (SayResponse)
6  router.rpc(ElizaService, ElizaService.methods.say, async (req) => ({
7    sentence: `you said: ${req.sentence}`,
8  }));
9}

1// server.ts
2import * as http2 from "http2";
3+ import routes from "connect";
4+ import { connectNodeAdapter } from "@connectrpc/connect-node";
5
6http2.createServer(
7+ connectNodeAdapter({ routes }) // responds with 404 for other requests
8).listen(8080);

With that server running, you can make requests with any gRPC, gRPC-Web, or Connect client.

buf curl with the gRPC protocol:

1buf curl --schema buf.build/connectrpc/eliza \
2  --protocol grpc --http2-prior-knowledge \
3  -d '{"sentence": "I feel happy."}' \
4  http://localhost:8080/connectrpc.eliza.v1.ElizaService/Say

curl with the Connect protocol:

1curl \
2    --header "Content-Type: application/json" \
3    --data '{"sentence": "I feel happy."}' \
4     --http2-prior-knowledge \
5    http://localhost:8080/connectrpc.eliza.v1.ElizaService/Say

Node.js with the gRPC protocol:

1import { createClient } from "@connectrpc/connect";
2import { createGrpcTransport } from "@connectrpc/connect-node";
3import { ElizaService } from "./gen/eliza_connect.js";
4
5const transport = createGrpcTransport({
6  baseUrl: "http://localhost:8080",
7});
8
9const client = createClient(ElizaService, transport);
10const { sentence } = await client.say({ sentence: "I feel happy." });
11console.log(sentence); // you said: I feel happy.

A client for the web browser actually looks identical to this example - it would simply use createConnectTransport from @connectrpc/connect-web instead.

Getting started

To get started with Connect, head over to the docs for a tutorial, or take a look at our example.