From c9d6a38c5637934ffd58c172d461dd7074a114c7 Mon Sep 17 00:00:00 2001 From: winprn Date: Tue, 17 Dec 2024 11:39:44 +0700 Subject: [PATCH] fix: update proto stuff --- .../node/src/proto/drp/node/v1/rpc_grpc_pb.js | 56 ++++++++++++------- packages/node/src/rpc/index.ts | 9 +-- 2 files changed, 41 insertions(+), 24 deletions(-) diff --git a/packages/node/src/proto/drp/node/v1/rpc_grpc_pb.js b/packages/node/src/proto/drp/node/v1/rpc_grpc_pb.js index 62562741..c80475cb 100644 --- a/packages/node/src/proto/drp/node/v1/rpc_grpc_pb.js +++ b/packages/node/src/proto/drp/node/v1/rpc_grpc_pb.js @@ -1,62 +1,78 @@ import * as node_src_proto_rpc_pb from './rpc_pb.js'; function serialize_drp_node_GetDRPHashGraphRequest(arg) { - let encoded = node_src_proto_rpc_pb.GetDRPHashGraphRequest.encode(arg).finish() - return Buffer.from(encoded); + let encoded = + node_src_proto_rpc_pb.GetDRPHashGraphRequest.encode(arg).finish(); + return Buffer.from(encoded); } function deserialize_drp_node_GetDRPHashGraphRequest(buffer_arg) { - return node_src_proto_rpc_pb.GetDRPHashGraphRequest.decode(new Uint8Array(buffer_arg)); + return node_src_proto_rpc_pb.GetDRPHashGraphRequest.decode( + new Uint8Array(buffer_arg) + ); } function serialize_drp_node_GetDRPHashGraphResponse(arg) { - let encoded = node_src_proto_rpc_pb.GetDRPHashGraphResponse.encode(arg).finish() - return Buffer.from(encoded); + let encoded = + node_src_proto_rpc_pb.GetDRPHashGraphResponse.encode(arg).finish(); + return Buffer.from(encoded); } function deserialize_drp_node_GetDRPHashGraphResponse(buffer_arg) { - return node_src_proto_rpc_pb.GetDRPHashGraphResponse.decode(new Uint8Array(buffer_arg)); + return node_src_proto_rpc_pb.GetDRPHashGraphResponse.decode( + new Uint8Array(buffer_arg) + ); } function serialize_drp_node_SubscribeDRPRequest(arg) { - let encoded = node_src_proto_rpc_pb.SubscribeDRPRequest.encode(arg).finish() - return Buffer.from(encoded); + let encoded = node_src_proto_rpc_pb.SubscribeDRPRequest.encode(arg).finish(); + return Buffer.from(encoded); } function deserialize_drp_node_SubscribeDRPRequest(buffer_arg) { - return node_src_proto_rpc_pb.SubscribeDRPRequest.decode(new Uint8Array(buffer_arg)); + return node_src_proto_rpc_pb.SubscribeDRPRequest.decode( + new Uint8Array(buffer_arg) + ); } function serialize_drp_node_SubscribeDRPResponse(arg) { - let encoded = node_src_proto_rpc_pb.SubscribeDRPResponse.encode(arg).finish() + let encoded = node_src_proto_rpc_pb.SubscribeDRPResponse.encode(arg).finish(); return Buffer.from(encoded); } function deserialize_drp_node_SubscribeDRPResponse(buffer_arg) { - return node_src_proto_rpc_pb.SubscribeDRPResponse.decode(new Uint8Array(buffer_arg)); + return node_src_proto_rpc_pb.SubscribeDRPResponse.decode( + new Uint8Array(buffer_arg) + ); } function serialize_drp_node_UnsubscribeDRPRequest(arg) { - let encoded = node_src_proto_rpc_pb.UnsubscribeDRPRequest.encode(arg).finish() - return Buffer.from(encoded); + let encoded = + node_src_proto_rpc_pb.UnsubscribeDRPRequest.encode(arg).finish(); + return Buffer.from(encoded); } function deserialize_drp_node_UnsubscribeDRPRequest(buffer_arg) { - return node_src_proto_rpc_pb.UnsubscribeDRPRequest.decode(new Uint8Array(buffer_arg)); + return node_src_proto_rpc_pb.UnsubscribeDRPRequest.decode( + new Uint8Array(buffer_arg) + ); } function serialize_drp_node_UnsubscribeDRPResponse(arg) { - let encoded = node_src_proto_rpc_pb.UnsubscribeDRPResponse.encode(arg).finish() - return Buffer.from(encoded); + let encoded = + node_src_proto_rpc_pb.UnsubscribeDRPResponse.encode(arg).finish(); + return Buffer.from(encoded); } function deserialize_drp_node_UnsubscribeDRPResponse(buffer_arg) { - return node_src_proto_rpc_pb.UnsubscribeDRPResponse.decode(new Uint8Array(buffer_arg)); + return node_src_proto_rpc_pb.UnsubscribeDRPResponse.decode( + new Uint8Array(buffer_arg) + ); } export const DRPRpcService = { subscribeDRP: { - path: '/drp.node.drpRpc/subscribeDRP', + path: '/drp.node.v1.DrpRpcService/SubscribeDRP', requestStream: false, responseStream: false, requestType: node_src_proto_rpc_pb.SubscribeDRPRequest, @@ -67,7 +83,7 @@ export const DRPRpcService = { responseDeserialize: deserialize_drp_node_SubscribeDRPResponse, }, unsubscribeDRP: { - path: '/drp.node.drpRpc/unsubscribeDRP', + path: '/drp.node.v1.DrpRpcService/UnsubscribeDRP', requestStream: false, responseStream: false, requestType: node_src_proto_rpc_pb.UnsubscribeDRPRequest, @@ -78,7 +94,7 @@ export const DRPRpcService = { responseDeserialize: deserialize_drp_node_UnsubscribeDRPResponse, }, getDRPHashGraph: { - path: '/drp.node.drpRpc/getDRPHashGraph', + path: '/drp.node.v1.DrpRpcService/GetDRPHashGraph', requestStream: false, responseStream: false, requestType: node_src_proto_rpc_pb.GetDRPHashGraphRequest, diff --git a/packages/node/src/rpc/index.ts b/packages/node/src/rpc/index.ts index b7b5156c..3c0bce33 100644 --- a/packages/node/src/rpc/index.ts +++ b/packages/node/src/rpc/index.ts @@ -15,9 +15,6 @@ import type { UnsubscribeDRPRequest, UnsubscribeDRPResponse, } from "../proto/drp/node/v1/rpc_pb.js"; -const __filename = fileURLToPath(import.meta.url); -const __dirname = dirname(__filename); -const PROTO_PATH = path.resolve(__dirname, "../proto/topology/node/rpc.proto"); export function init(node: DRPNode) { function subscribeDRP( @@ -77,7 +74,11 @@ export function init(node: DRPNode) { callback(null, response); } - const packageDefinition = protoLoader.loadSync(PROTO_PATH); + const protoPath = path.resolve( + dirname(fileURLToPath(import.meta.url)), + "../proto/drp/node/v1/rpc.proto", + ); + const packageDefinition = protoLoader.loadSync(protoPath); const reflectionService = new reflection.ReflectionService(packageDefinition); const server = new grpc.Server();