/**
* 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);
};
}
}