chore: update deps

Signed-off-by: Christian Stewart <christian@aperture.us>

Author: paralin

.protoc-manifest.json

@@ -1,22 +1,20 @@
 {
   "version": 2,
-  "protocFlagsHash": "1152cdb8a3e3d48a1e6178bbfe94a1c2035c3ac41634404c16e918bc13d51798",
-  "toolVersions": "protoc=embedded,protobuf-go-lite=v0.12.0,starpc=v0.44.0,protobuf-es-lite=^0.5.3",
+  "protocFlagsHash": "f83552054c9ab83accb174c598c8e5617f0a99a2f2d19e22d8c2123319065584",
+  "toolVersions": "protoc=embedded,protobuf-go-lite=v0.12.1,starpc=v0.46.1,protobuf-es-lite=^0.5.3",
   "packages": {
     "github.com/aperturerobotics/template/example": {
       "hash": "393780feb3fab0309f4e5d0feefd0fa62ad32558bc76972db319a4b24be97a92",
       "generatedFiles": [
-        "vendor/github.com/aperturerobotics/template/example/example.pb.cc",
-        "vendor/github.com/aperturerobotics/template/example/example.pb.go",
-        "vendor/github.com/aperturerobotics/template/example/example.pb.h",
-        "vendor/github.com/aperturerobotics/template/example/example.pb.ts",
-        "vendor/github.com/aperturerobotics/template/example/example_srpc.pb.go",
-        "vendor/github.com/aperturerobotics/template/example/example_srpc.pb.ts",
         "example/example.pb.cc",
+        "example/example_srpc.pb.cpp",
+        "example/example_srpc.pb.hpp",
         "example/example.pb.go",
         "example/example.pb.h",
+        "example/example.pb.rs",
         "example/example.pb.ts",
         "example/example_srpc.pb.go",
+        "example/example_srpc.pb.rs",
         "example/example_srpc.pb.ts"
       ],
       "protoFiles": [

example/example.pb.go

@@ -0,0 +1,9 @@
+// @generated
+// This file is @generated by prost-build.
+/// EchoMsg is the message body for Echo.
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
+pub struct EchoMsg {
+    #[prost(string, tag="1")]
+    pub body: ::prost::alloc::string::String,
+}
+// @@protoc_insertion_point(module)

example/example.pb.rs

@@ -0,0 +1,88 @@
+//go:build deps_only
+
+// Code generated by protoc-gen-starpc-cpp. DO NOT EDIT.
+// protoc-gen-starpc-cpp version: v0.46.1
+// source: github.com/aperturerobotics/template/example/example.proto
+
+#include "example_srpc.pb.hpp"
+
+namespace example {
+
+starpc::Error SRPCEchoerClientImpl::Echo(const example::EchoMsg& in, example::EchoMsg* out) {
+  return cc_->ExecCall(service_id_, "Echo", in, out);
+}
+
+std::pair<std::unique_ptr<SRPCEchoer_EchoServerStreamClient>, starpc::Error> SRPCEchoerClientImpl::EchoServerStream(const example::EchoMsg& in) {
+  auto [strm, err] = cc_->NewStream(service_id_, "EchoServerStream", &in);
+  if (err != starpc::Error::OK) {
+    return {nullptr, err};
+  }
+  err = strm->CloseSend();
+  if (err != starpc::Error::OK) {
+    return {nullptr, err};
+  }
+  return {std::make_unique<SRPCEchoer_EchoServerStreamClient>(std::move(strm)), starpc::Error::OK};
+}
+
+std::pair<std::unique_ptr<SRPCEchoer_EchoClientStreamClient>, starpc::Error> SRPCEchoerClientImpl::EchoClientStream() {
+  auto [strm, err] = cc_->NewStream(service_id_, "EchoClientStream", nullptr);
+  if (err != starpc::Error::OK) {
+    return {nullptr, err};
+  }
+  return {std::make_unique<SRPCEchoer_EchoClientStreamClient>(std::move(strm)), starpc::Error::OK};
+}
+
+std::pair<std::unique_ptr<SRPCEchoer_EchoBidiStreamClient>, starpc::Error> SRPCEchoerClientImpl::EchoBidiStream() {
+  auto [strm, err] = cc_->NewStream(service_id_, "EchoBidiStream", nullptr);
+  if (err != starpc::Error::OK) {
+    return {nullptr, err};
+  }
+  return {std::make_unique<SRPCEchoer_EchoBidiStreamClient>(std::move(strm)), starpc::Error::OK};
+}
+
+std::vector<std::string> SRPCEchoerHandler::GetMethodIDs() const {
+  return {
+    "Echo",
+    "EchoServerStream",
+    "EchoClientStream",
+    "EchoBidiStream",
+  };
+}
+
+std::pair<bool, starpc::Error> SRPCEchoerHandler::InvokeMethod(
+    const std::string& service_id,
+    const std::string& method_id,
+    starpc::Stream* strm) {
+  if (!service_id.empty() && service_id != service_id_) {
+    return {false, starpc::Error::OK};
+  }
+
+  if (method_id == "Echo") {
+    example::EchoMsg req;
+    starpc::Error err = strm->MsgRecv(&req);
+    if (err != starpc::Error::OK) return {true, err};
+    example::EchoMsg resp;
+    err = impl_->Echo(req, &resp);
+    if (err != starpc::Error::OK) return {true, err};
+    return {true, strm->MsgSend(resp)};
+  } else if (method_id == "EchoServerStream") {
+    example::EchoMsg req;
+    starpc::Error err = strm->MsgRecv(&req);
+    if (err != starpc::Error::OK) return {true, err};
+    SRPCEchoer_EchoServerStreamStream serverStrm(strm);
+    return {true, impl_->EchoServerStream(req, &serverStrm)};
+  } else if (method_id == "EchoClientStream") {
+    SRPCEchoer_EchoClientStreamStream clientStrm(strm);
+    example::EchoMsg resp;
+    starpc::Error err = impl_->EchoClientStream(&clientStrm, &resp);
+    if (err != starpc::Error::OK) return {true, err};
+    return {true, strm->MsgSend(resp)};
+  } else if (method_id == "EchoBidiStream") {
+    SRPCEchoer_EchoBidiStreamStream bidiStrm(strm);
+    return {true, impl_->EchoBidiStream(&bidiStrm)};
+  }
+
+  return {false, starpc::Error::OK};
+}
+
+}  // namespace example

example/example_srpc.pb.cpp

@@ -0,0 +1,237 @@
+//go:build deps_only && cgo
+
+// Code generated by protoc-gen-starpc-cpp. DO NOT EDIT.
+// protoc-gen-starpc-cpp version: v0.46.1
+// source: github.com/aperturerobotics/template/example/example.proto
+
+#pragma once
+
+#include <functional>
+#include <memory>
+#include <string>
+#include <utility>
+
+#include "srpc/starpc.hpp"
+
+#include "example.pb.h"
+
+namespace example {
+
+// Service ID for Echoer
+constexpr const char* kSRPCEchoerServiceID = "example.Echoer";
+
+class SRPCEchoer_EchoServerStreamClient;
+class SRPCEchoer_EchoServerStreamStream;
+class SRPCEchoer_EchoClientStreamClient;
+class SRPCEchoer_EchoClientStreamStream;
+class SRPCEchoer_EchoBidiStreamClient;
+class SRPCEchoer_EchoBidiStreamStream;
+
+// SRPCEchoerClient is the client API for Echoer service.
+class SRPCEchoerClient {
+ public:
+  virtual ~SRPCEchoerClient() = default;
+
+  // SRPCClient returns the underlying SRPC client.
+  virtual starpc::Client* SRPCClient() = 0;
+
+  // Echo
+  virtual starpc::Error Echo(const example::EchoMsg& in, example::EchoMsg* out) = 0;
+  // EchoServerStream
+  virtual std::pair<std::unique_ptr<SRPCEchoer_EchoServerStreamClient>, starpc::Error> EchoServerStream(const example::EchoMsg& in) = 0;
+  // EchoClientStream
+  virtual std::pair<std::unique_ptr<SRPCEchoer_EchoClientStreamClient>, starpc::Error> EchoClientStream() = 0;
+  // EchoBidiStream
+  virtual std::pair<std::unique_ptr<SRPCEchoer_EchoBidiStreamClient>, starpc::Error> EchoBidiStream() = 0;
+};
+
+// SRPCEchoerClientImpl implements SRPCEchoerClient.
+class SRPCEchoerClientImpl : public SRPCEchoerClient {
+ public:
+  explicit SRPCEchoerClientImpl(starpc::Client* cc, const std::string& service_id = "")
+      : cc_(cc), service_id_(service_id.empty() ? kSRPCEchoerServiceID : service_id) {}
+
+  starpc::Client* SRPCClient() override { return cc_; }
+
+  // Echo
+  virtual starpc::Error Echo(const example::EchoMsg& in, example::EchoMsg* out) override;
+  // EchoServerStream
+  virtual std::pair<std::unique_ptr<SRPCEchoer_EchoServerStreamClient>, starpc::Error> EchoServerStream(const example::EchoMsg& in) override;
+  // EchoClientStream
+  virtual std::pair<std::unique_ptr<SRPCEchoer_EchoClientStreamClient>, starpc::Error> EchoClientStream() override;
+  // EchoBidiStream
+  virtual std::pair<std::unique_ptr<SRPCEchoer_EchoBidiStreamClient>, starpc::Error> EchoBidiStream() override;
+
+ private:
+  starpc::Client* cc_;
+  std::string service_id_;
+};
+
+// NewSRPCEchoerClient creates a new client.
+inline std::unique_ptr<SRPCEchoerClient> NewSRPCEchoerClient(starpc::Client* cc) {
+  return std::make_unique<SRPCEchoerClientImpl>(cc);
+}
+
+// SRPCEchoerServer is the server API for Echoer service.
+class SRPCEchoerServer {
+ public:
+  virtual ~SRPCEchoerServer() = default;
+
+  // Echo
+  virtual starpc::Error Echo(const example::EchoMsg& req, example::EchoMsg* resp) = 0;
+  // EchoServerStream
+  virtual starpc::Error EchoServerStream(const example::EchoMsg& req, SRPCEchoer_EchoServerStreamStream* strm) = 0;
+  // EchoClientStream
+  virtual starpc::Error EchoClientStream(SRPCEchoer_EchoClientStreamStream* strm, example::EchoMsg* resp) = 0;
+  // EchoBidiStream
+  virtual starpc::Error EchoBidiStream(SRPCEchoer_EchoBidiStreamStream* strm) = 0;
+};
+
+// SRPCEchoerHandler implements starpc::Handler for Echoer.
+class SRPCEchoerHandler : public starpc::Handler {
+ public:
+  SRPCEchoerHandler(SRPCEchoerServer* impl, const std::string& service_id = "")
+      : impl_(impl), service_id_(service_id.empty() ? kSRPCEchoerServiceID : service_id) {}
+
+  const std::string& GetServiceID() const override { return service_id_; }
+  std::vector<std::string> GetMethodIDs() const override;
+  std::pair<bool, starpc::Error> InvokeMethod(
+      const std::string& service_id,
+      const std::string& method_id,
+      starpc::Stream* strm) override;
+
+ private:
+  SRPCEchoerServer* impl_;
+  std::string service_id_;
+};
+
+// NewSRPCEchoerHandler creates a new handler for the given implementation.
+inline std::unique_ptr<SRPCEchoerHandler> NewSRPCEchoerHandler(SRPCEchoerServer* impl) {
+  return std::make_unique<SRPCEchoerHandler>(impl);
+}
+
+// SRPCRegisterEchoer registers the server implementation with the mux.
+// The returned handler must outlive the mux registration.
+inline std::pair<std::unique_ptr<SRPCEchoerHandler>, starpc::Error> SRPCRegisterEchoer(starpc::Mux* mux, SRPCEchoerServer* impl) {
+  auto handler = NewSRPCEchoerHandler(impl);
+  starpc::Error err = mux->Register(handler.get());
+  if (err != starpc::Error::OK) {
+    return {nullptr, err};
+  }
+  return {std::move(handler), starpc::Error::OK};
+}
+
+// SRPCEchoer_EchoServerStreamClient is the client stream for EchoServerStream.
+class SRPCEchoer_EchoServerStreamClient {
+ public:
+  explicit SRPCEchoer_EchoServerStreamClient(std::unique_ptr<starpc::Stream> strm) : strm_(std::move(strm)) {}
+
+  starpc::Error Recv(example::EchoMsg* msg) {
+    return strm_->MsgRecv(msg);
+  }
+
+  starpc::Error CloseSend() { return strm_->CloseSend(); }
+  starpc::Error Close() { return strm_->Close(); }
+
+ private:
+  std::unique_ptr<starpc::Stream> strm_;
+};
+
+// SRPCEchoer_EchoServerStreamStream is the server stream for EchoServerStream.
+class SRPCEchoer_EchoServerStreamStream {
+ public:
+  explicit SRPCEchoer_EchoServerStreamStream(starpc::Stream* strm) : strm_(strm) {}
+
+  starpc::Error Send(const example::EchoMsg& msg) {
+    return strm_->MsgSend(msg);
+  }
+
+  starpc::Error SendAndClose(const example::EchoMsg& msg) {
+    starpc::Error err = strm_->MsgSend(msg);
+    if (err != starpc::Error::OK) return err;
+    return strm_->CloseSend();
+  }
+
+ private:
+  starpc::Stream* strm_;
+};
+
+// SRPCEchoer_EchoClientStreamClient is the client stream for EchoClientStream.
+class SRPCEchoer_EchoClientStreamClient {
+ public:
+  explicit SRPCEchoer_EchoClientStreamClient(std::unique_ptr<starpc::Stream> strm) : strm_(std::move(strm)) {}
+
+  starpc::Error Send(const example::EchoMsg& msg) {
+    return strm_->MsgSend(msg);
+  }
+
+  starpc::Error CloseAndRecv(example::EchoMsg* msg) {
+    starpc::Error err = strm_->CloseSend();
+    if (err != starpc::Error::OK) return err;
+    return strm_->MsgRecv(msg);
+  }
+
+  starpc::Error CloseSend() { return strm_->CloseSend(); }
+  starpc::Error Close() { return strm_->Close(); }
+
+ private:
+  std::unique_ptr<starpc::Stream> strm_;
+};
+
+// SRPCEchoer_EchoClientStreamStream is the server stream for EchoClientStream.
+class SRPCEchoer_EchoClientStreamStream {
+ public:
+  explicit SRPCEchoer_EchoClientStreamStream(starpc::Stream* strm) : strm_(strm) {}
+
+  starpc::Error Recv(example::EchoMsg* msg) {
+    return strm_->MsgRecv(msg);
+  }
+
+ private:
+  starpc::Stream* strm_;
+};
+
+// SRPCEchoer_EchoBidiStreamClient is the client stream for EchoBidiStream.
+class SRPCEchoer_EchoBidiStreamClient {
+ public:
+  explicit SRPCEchoer_EchoBidiStreamClient(std::unique_ptr<starpc::Stream> strm) : strm_(std::move(strm)) {}
+
+  starpc::Error Send(const example::EchoMsg& msg) {
+    return strm_->MsgSend(msg);
+  }
+
+  starpc::Error Recv(example::EchoMsg* msg) {
+    return strm_->MsgRecv(msg);
+  }
+
+  starpc::Error CloseSend() { return strm_->CloseSend(); }
+  starpc::Error Close() { return strm_->Close(); }
+
+ private:
+  std::unique_ptr<starpc::Stream> strm_;
+};
+
+// SRPCEchoer_EchoBidiStreamStream is the server stream for EchoBidiStream.
+class SRPCEchoer_EchoBidiStreamStream {
+ public:
+  explicit SRPCEchoer_EchoBidiStreamStream(starpc::Stream* strm) : strm_(strm) {}
+
+  starpc::Error Send(const example::EchoMsg& msg) {
+    return strm_->MsgSend(msg);
+  }
+
+  starpc::Error SendAndClose(const example::EchoMsg& msg) {
+    starpc::Error err = strm_->MsgSend(msg);
+    if (err != starpc::Error::OK) return err;
+    return strm_->CloseSend();
+  }
+
+  starpc::Error Recv(example::EchoMsg* msg) {
+    return strm_->MsgRecv(msg);
+  }
+
+ private:
+  starpc::Stream* strm_;
+};
+
+}  // namespace example