generated rpc pb

buf.gen.yaml

@@ -2,9 +2,14 @@ version: v2
 managed:
   enabled: true
 plugins:
-  - local: ./node_modules/ts-proto/protoc-gen-ts_proto
-    strategy: directory
+  - remote: buf.build/community/stephenh-ts-proto
     out: ./packages
     opt:
       - esModuleInterop=true
       - fileSuffix=_pb
+inputs:
+  - directory: ./packages
+    exclude_paths:
+      - packages/node/node_modules
+      - packages/network/node_modules
+      - packages/object/node_modules

buf.yaml

@@ -1,14 +1,11 @@
 version: v2
 modules:
-  - path: packages
-  - includes:
-      - packages/network
-      - packages/object
-  - excludes:
-      - node_modules
+  - path: packages/node
+    excludes:
+      - packages/node/node_modules
+  - path: packages/network
+    excludes:
       - packages/network/node_modules
+  - path: packages/object
+    excludes:
       - packages/object/node_modules
-      - examples/canvas/node_modules
-      - examples/chat/node_modules
-deps:
-  - buf.build/googleapis/googleapis

packages/node/package.json

@@ -29,6 +29,7 @@
   "test": "vitest"
  },
  "devDependencies": {
+  "@bufbuild/protobuf": "^2.0.0",
   "@types/node": "^22.5.4",
   "tsx": "4.19.0",
   "typescript": "^5.5.4",

packages/node/src/proto/rpc.proto

@@ -1,18 +1,10 @@
 syntax = "proto3";
 package topology.rpc;
-import "google/api/http.proto";
-import "google/api/annotations.proto";
 
 service Rpc {
-	rpc subscribeCro    (SubscribeCroRequest    ) returns (SubscribeCroResponse    ) {
-		option (google.api.http).get = "/topopology/cro/subscribe/{cro_id}";
-	};
-	rpc unsubscribeCro  (UnsubscribeCroRequest  ) returns (UnsubscribeCroRequest   ) {
-		option (google.api.http).get = "/topopology/cro/subscribe/{cro_id}";
-	};
-	rpc getCroHashGraph (GetCroHashGraphRequest ) returns (GetCroHashGraphResponse ) {
-		option (google.api.http).get = "/topopology/cro/subscribe/{cro_id}";
-	};
+	rpc subscribeCro    (SubscribeCroRequest    ) returns (SubscribeCroResponse    );
+	rpc unsubscribeCro  (UnsubscribeCroRequest  ) returns (UnsubscribeCroRequest   );
+	rpc getCroHashGraph (GetCroHashGraphRequest ) returns (GetCroHashGraphResponse );
 }
 
 message SubscribeCroRequest {
@@ -21,7 +13,7 @@ message SubscribeCroRequest {
 
 message SubscribeCroResponse {
 	// can return error codes if different than 0
-	int return_code = 1;
+	int32 return_code = 1;
 }
 
 message UnsubscribeCroRequest {
@@ -30,14 +22,14 @@ message UnsubscribeCroRequest {
 
 message UnsubscribeCroResponse {
 	// can return error codes if different than 0
-	int return_code = 1;
+	int32 return_code = 1;
 }
 
-message getCroHashGraphRequest {
+message GetCroHashGraphRequest {
 	string cro_id = 1;
 }
 
-message getCroHashGraphResponse {
+message GetCroHashGraphResponse {
 	// linearized vertices hashes
 	repeated string vertices_hashes = 1;
 }