/** * Generated by the protoc-gen-ts. DO NOT EDIT! * compiler version: 3.21.12 * source: api/rpc_node.proto * git: https://github.com/thesayyn/protoc-gen-ts */ import * as dependency_1 from "./../common/request"; import * as dependency_2 from "./../common/result"; import * as dependency_3 from "./../config/local_config"; import * as dependency_4 from "./../config/log_config"; import * as dependency_5 from "./../config/chainmaker_server"; import * as dependency_6 from "./../google/api/annotations"; import * as dependency_7 from "./../txpool/transaction_pool"; import * as dependency_8 from "./../google/protobuf/wrappers"; import * as dependency_9 from "./../consensus/consensus"; import * as dependency_10 from "./../sync/sync"; export namespace api { interface GrpcUnaryServiceInterface { (message: P, metadata: grpc_1.Metadata, options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; (message: P, metadata: grpc_1.Metadata, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; (message: P, options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; (message: P, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; } interface GrpcStreamServiceInterface { (message: P, metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): grpc_1.ClientReadableStream; (message: P, options?: grpc_1.CallOptions): grpc_1.ClientReadableStream; } interface GrpWritableServiceInterface { (metadata: grpc_1.Metadata, options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; (metadata: grpc_1.Metadata, callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; (options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; (callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; } interface GrpcChunkServiceInterface { (metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream; (options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream; } interface GrpcPromiseServiceInterface { (message: P, metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): Promise; (message: P, options?: grpc_1.CallOptions): Promise; } export abstract class UnimplementedRpcNodeService { static definition = { SendRequest: { path: "/api.RpcNode/SendRequest", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.common.TxRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.common.TxRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_2.common.TxResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_2.common.TxResponse.deserialize(new Uint8Array(bytes)) }, SendRequestSync: { path: "/api.RpcNode/SendRequestSync", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.common.TxRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.common.TxRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_2.common.TxResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_2.common.TxResponse.deserialize(new Uint8Array(bytes)) }, Subscribe: { path: "/api.RpcNode/Subscribe", requestStream: false, responseStream: true, requestSerialize: (message: dependency_1.common.TxRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.common.TxRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_2.common.SubscribeResult) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_2.common.SubscribeResult.deserialize(new Uint8Array(bytes)) }, SubscribeWS: { path: "/api.RpcNode/SubscribeWS", requestStream: false, responseStream: true, requestSerialize: (message: dependency_1.common.RawTxRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.common.RawTxRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_2.common.SubscribeResult) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_2.common.SubscribeResult.deserialize(new Uint8Array(bytes)) }, UpdateDebugConfig: { path: "/api.RpcNode/UpdateDebugConfig", requestStream: false, responseStream: false, requestSerialize: (message: dependency_3.config.DebugConfigRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_3.config.DebugConfigRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_3.config.DebugConfigResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_3.config.DebugConfigResponse.deserialize(new Uint8Array(bytes)) }, RefreshLogLevelsConfig: { path: "/api.RpcNode/RefreshLogLevelsConfig", requestStream: false, responseStream: false, requestSerialize: (message: dependency_4.config.LogLevelsRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_4.config.LogLevelsRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_4.config.LogLevelsResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_4.config.LogLevelsResponse.deserialize(new Uint8Array(bytes)) }, GetChainMakerVersion: { path: "/api.RpcNode/GetChainMakerVersion", requestStream: false, responseStream: false, requestSerialize: (message: dependency_5.config.ChainMakerVersionRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_5.config.ChainMakerVersionRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_5.config.ChainMakerVersionResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_5.config.ChainMakerVersionResponse.deserialize(new Uint8Array(bytes)) }, CheckNewBlockChainConfig: { path: "/api.RpcNode/CheckNewBlockChainConfig", requestStream: false, responseStream: false, requestSerialize: (message: dependency_3.config.CheckNewBlockChainConfigRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_3.config.CheckNewBlockChainConfigRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_3.config.CheckNewBlockChainConfigResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_3.config.CheckNewBlockChainConfigResponse.deserialize(new Uint8Array(bytes)) }, GetPoolStatus: { path: "/api.RpcNode/GetPoolStatus", requestStream: false, responseStream: false, requestSerialize: (message: dependency_7.txpool.GetPoolStatusRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_7.txpool.GetPoolStatusRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_7.txpool.TxPoolStatus) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_7.txpool.TxPoolStatus.deserialize(new Uint8Array(bytes)) }, GetTxIdsByTypeAndStage: { path: "/api.RpcNode/GetTxIdsByTypeAndStage", requestStream: false, responseStream: false, requestSerialize: (message: dependency_7.txpool.GetTxIdsByTypeAndStageRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_7.txpool.GetTxIdsByTypeAndStageRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_7.txpool.GetTxIdsByTypeAndStageResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_7.txpool.GetTxIdsByTypeAndStageResponse.deserialize(new Uint8Array(bytes)) }, GetTxsInPoolByTxIds: { path: "/api.RpcNode/GetTxsInPoolByTxIds", requestStream: false, responseStream: false, requestSerialize: (message: dependency_7.txpool.GetTxsInPoolByTxIdsRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_7.txpool.GetTxsInPoolByTxIdsRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_7.txpool.GetTxsInPoolByTxIdsResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_7.txpool.GetTxsInPoolByTxIdsResponse.deserialize(new Uint8Array(bytes)) }, GetConsensusStateJSON: { path: "/api.RpcNode/GetConsensusStateJSON", requestStream: false, responseStream: false, requestSerialize: (message: dependency_9.consensus.GetConsensusStatusRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_9.consensus.GetConsensusStatusRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_8.google.protobuf.BytesValue) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_8.google.protobuf.BytesValue.deserialize(new Uint8Array(bytes)) }, GetConsensusValidators: { path: "/api.RpcNode/GetConsensusValidators", requestStream: false, responseStream: false, requestSerialize: (message: dependency_9.consensus.GetConsensusStatusRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_9.consensus.GetConsensusStatusRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_9.consensus.Validators) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_9.consensus.Validators.deserialize(new Uint8Array(bytes)) }, GetConsensusHeight: { path: "/api.RpcNode/GetConsensusHeight", requestStream: false, responseStream: false, requestSerialize: (message: dependency_9.consensus.GetConsensusStatusRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_9.consensus.GetConsensusStatusRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_8.google.protobuf.UInt64Value) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_8.google.protobuf.UInt64Value.deserialize(new Uint8Array(bytes)) }, GetSyncState: { path: "/api.RpcNode/GetSyncState", requestStream: false, responseStream: false, requestSerialize: (message: dependency_10.sync.GetSyncStateRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_10.sync.GetSyncStateRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: dependency_10.sync.SyncState) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => dependency_10.sync.SyncState.deserialize(new Uint8Array(bytes)) } }; [method: string]: grpc_1.UntypedHandleCall; abstract SendRequest(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SendRequestSync(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract Subscribe(call: grpc_1.ServerWritableStream): void; abstract SubscribeWS(call: grpc_1.ServerWritableStream): void; abstract UpdateDebugConfig(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract RefreshLogLevelsConfig(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetChainMakerVersion(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract CheckNewBlockChainConfig(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetPoolStatus(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetTxIdsByTypeAndStage(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetTxsInPoolByTxIds(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetConsensusStateJSON(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetConsensusValidators(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetConsensusHeight(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetSyncState(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; } export class RpcNodeClient extends grpc_1.makeGenericClientConstructor(UnimplementedRpcNodeService.definition, "RpcNode", {}) { constructor(address: string, credentials: grpc_1.ChannelCredentials, options?: Partial) { super(address, credentials, options); } SendRequest: GrpcUnaryServiceInterface = (message: dependency_1.common.TxRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.SendRequest(message, metadata, options, callback); }; SendRequestSync: GrpcUnaryServiceInterface = (message: dependency_1.common.TxRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.SendRequestSync(message, metadata, options, callback); }; Subscribe: GrpcStreamServiceInterface = (message: dependency_1.common.TxRequest, metadata?: grpc_1.Metadata | grpc_1.CallOptions, options?: grpc_1.CallOptions): grpc_1.ClientReadableStream => { return super.Subscribe(message, metadata, options); }; SubscribeWS: GrpcStreamServiceInterface = (message: dependency_1.common.RawTxRequest, metadata?: grpc_1.Metadata | grpc_1.CallOptions, options?: grpc_1.CallOptions): grpc_1.ClientReadableStream => { return super.SubscribeWS(message, metadata, options); }; UpdateDebugConfig: GrpcUnaryServiceInterface = (message: dependency_3.config.DebugConfigRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.UpdateDebugConfig(message, metadata, options, callback); }; RefreshLogLevelsConfig: GrpcUnaryServiceInterface = (message: dependency_4.config.LogLevelsRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.RefreshLogLevelsConfig(message, metadata, options, callback); }; GetChainMakerVersion: GrpcUnaryServiceInterface = (message: dependency_5.config.ChainMakerVersionRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetChainMakerVersion(message, metadata, options, callback); }; CheckNewBlockChainConfig: GrpcUnaryServiceInterface = (message: dependency_3.config.CheckNewBlockChainConfigRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.CheckNewBlockChainConfig(message, metadata, options, callback); }; GetPoolStatus: GrpcUnaryServiceInterface = (message: dependency_7.txpool.GetPoolStatusRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetPoolStatus(message, metadata, options, callback); }; GetTxIdsByTypeAndStage: GrpcUnaryServiceInterface = (message: dependency_7.txpool.GetTxIdsByTypeAndStageRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetTxIdsByTypeAndStage(message, metadata, options, callback); }; GetTxsInPoolByTxIds: GrpcUnaryServiceInterface = (message: dependency_7.txpool.GetTxsInPoolByTxIdsRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetTxsInPoolByTxIds(message, metadata, options, callback); }; GetConsensusStateJSON: GrpcUnaryServiceInterface = (message: dependency_9.consensus.GetConsensusStatusRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetConsensusStateJSON(message, metadata, options, callback); }; GetConsensusValidators: GrpcUnaryServiceInterface = (message: dependency_9.consensus.GetConsensusStatusRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetConsensusValidators(message, metadata, options, callback); }; GetConsensusHeight: GrpcUnaryServiceInterface = (message: dependency_9.consensus.GetConsensusStatusRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetConsensusHeight(message, metadata, options, callback); }; GetSyncState: GrpcUnaryServiceInterface = (message: dependency_10.sync.GetSyncStateRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetSyncState(message, metadata, options, callback); }; } }