fix: fix wrong return message for rpc unsubscribe

topology-foundation · Oct 8, 2024 · 6f0f918 · 6f0f918
1 parent 0cfee7f
commit 6f0f918
Show file tree

Hide file tree

Showing 3 changed files with 368 additions and 359 deletions.
diff --git a/packages/node/src/proto/rpc.proto b/packages/node/src/proto/rpc.proto
@@ -3,7 +3,7 @@ package topology.node;
 
 service TopologyRpc {
 	rpc subscribeCro    (SubscribeCroRequest    ) returns (SubscribeCroResponse    );
-	rpc unsubscribeCro  (UnsubscribeCroRequest  ) returns (UnsubscribeCroRequest   );
+	rpc unsubscribeCro  (UnsubscribeCroRequest  ) returns (UnsubscribeCroResponse  );
 	rpc getCroHashGraph (GetCroHashGraphRequest ) returns (GetCroHashGraphResponse );
 }
 

diff --git a/packages/node/src/proto/rpc_grpc_pb.js b/packages/node/src/proto/rpc_grpc_pb.js
@@ -45,6 +45,15 @@ function deserialize_topology_node_UnsubscribeCroRequest(buffer_arg) {
   return node_src_proto_rpc_pb.UnsubscribeCroRequest.decode(new Uint8Array(buffer_arg));
 }
 
+function serialize_topology_node_UnsubscribeCroResponse(arg) {
+	let encoded = node_src_proto_rpc_pb.UnsubscribeCroResponse.encode(arg).finish()
+	return Buffer.from(encoded);
+}
+
+function deserialize_topology_node_UnsubscribeCroResponse(buffer_arg) {
+  return node_src_proto_rpc_pb.UnsubscribeCroResponse.decode(new Uint8Array(buffer_arg));
+}
+
 export const TopologyRpcService = {
   subscribeCro: {
     path: '/topology.node.TopologyRpc/subscribeCro',
@@ -62,11 +71,11 @@ export const TopologyRpcService = {
     requestStream: false,
     responseStream: false,
     requestType: node_src_proto_rpc_pb.UnsubscribeCroRequest,
-    responseType: node_src_proto_rpc_pb.UnsubscribeCroRequest,
+    responseType: node_src_proto_rpc_pb.UnsubscribeCroResponse,
     requestSerialize: serialize_topology_node_UnsubscribeCroRequest,
     requestDeserialize: deserialize_topology_node_UnsubscribeCroRequest,
-    responseSerialize: serialize_topology_node_UnsubscribeCroRequest,
-    responseDeserialize: deserialize_topology_node_UnsubscribeCroRequest,
+    responseSerialize: serialize_topology_node_UnsubscribeCroResponse,
+    responseDeserialize: deserialize_topology_node_UnsubscribeCroResponse,
   },
   getCroHashGraph: {
     path: '/topology.node.TopologyRpc/getCroHashGraph',