/** * Generated by the protoc-gen-ts. DO NOT EDIT! * compiler version: 3.21.12 * source: txpool/transaction_pool.proto * git: https://github.com/thesayyn/protoc-gen-ts */ import * as dependency_1 from "./../common/transaction"; import * as dependency_2 from "./../common/request"; import * as pb_1 from "google-protobuf"; export namespace txpool { export enum SignalType { NO_EVENT = 0, TRANSACTION_INCOME = 1, BLOCK_PROPOSE = 2 } export enum TxType { UNKNOWN_TYPE = 0, CONFIG_TX = 1, COMMON_TX = 2, ALL_TYPE = 3 } export enum TxStage { UNKNOWN_STAGE = 0, IN_QUEUE = 1, IN_PENDING = 2, ALL_STAGE = 3 } export enum TxPoolMsgType { SINGLE_TX = 0, BATCH_TX = 1, RECOVER_REQ = 2, RECOVER_RESP = 3 } export class TxPoolSignal extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { signal_type?: SignalType; chain_id?: string; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("signal_type" in data && data.signal_type != undefined) { this.signal_type = data.signal_type; } if ("chain_id" in data && data.chain_id != undefined) { this.chain_id = data.chain_id; } } } get signal_type() { return pb_1.Message.getFieldWithDefault(this, 1, SignalType.NO_EVENT) as SignalType; } set signal_type(value: SignalType) { pb_1.Message.setField(this, 1, value); } get chain_id() { return pb_1.Message.getFieldWithDefault(this, 2, "") as string; } set chain_id(value: string) { pb_1.Message.setField(this, 2, value); } static fromObject(data: { signal_type?: SignalType; chain_id?: string; }): TxPoolSignal { const message = new TxPoolSignal({}); if (data.signal_type != null) { message.signal_type = data.signal_type; } if (data.chain_id != null) { message.chain_id = data.chain_id; } return message; } toObject() { const data: { signal_type?: SignalType; chain_id?: string; } = {}; if (this.signal_type != null) { data.signal_type = this.signal_type; } if (this.chain_id != null) { data.chain_id = this.chain_id; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.signal_type != SignalType.NO_EVENT) writer.writeEnum(1, this.signal_type); if (this.chain_id.length) writer.writeString(2, this.chain_id); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxPoolSignal { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxPoolSignal(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.signal_type = reader.readEnum(); break; case 2: message.chain_id = reader.readString(); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxPoolSignal { return TxPoolSignal.deserialize(bytes); } } export class TxPoolStatus extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { config_tx_pool_size?: number; common_tx_pool_size?: number; config_tx_num_in_queue?: number; config_tx_num_in_pending?: number; common_tx_num_in_queue?: number; common_tx_num_in_pending?: number; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("config_tx_pool_size" in data && data.config_tx_pool_size != undefined) { this.config_tx_pool_size = data.config_tx_pool_size; } if ("common_tx_pool_size" in data && data.common_tx_pool_size != undefined) { this.common_tx_pool_size = data.common_tx_pool_size; } if ("config_tx_num_in_queue" in data && data.config_tx_num_in_queue != undefined) { this.config_tx_num_in_queue = data.config_tx_num_in_queue; } if ("config_tx_num_in_pending" in data && data.config_tx_num_in_pending != undefined) { this.config_tx_num_in_pending = data.config_tx_num_in_pending; } if ("common_tx_num_in_queue" in data && data.common_tx_num_in_queue != undefined) { this.common_tx_num_in_queue = data.common_tx_num_in_queue; } if ("common_tx_num_in_pending" in data && data.common_tx_num_in_pending != undefined) { this.common_tx_num_in_pending = data.common_tx_num_in_pending; } } } get config_tx_pool_size() { return pb_1.Message.getFieldWithDefault(this, 1, 0) as number; } set config_tx_pool_size(value: number) { pb_1.Message.setField(this, 1, value); } get common_tx_pool_size() { return pb_1.Message.getFieldWithDefault(this, 2, 0) as number; } set common_tx_pool_size(value: number) { pb_1.Message.setField(this, 2, value); } get config_tx_num_in_queue() { return pb_1.Message.getFieldWithDefault(this, 3, 0) as number; } set config_tx_num_in_queue(value: number) { pb_1.Message.setField(this, 3, value); } get config_tx_num_in_pending() { return pb_1.Message.getFieldWithDefault(this, 4, 0) as number; } set config_tx_num_in_pending(value: number) { pb_1.Message.setField(this, 4, value); } get common_tx_num_in_queue() { return pb_1.Message.getFieldWithDefault(this, 5, 0) as number; } set common_tx_num_in_queue(value: number) { pb_1.Message.setField(this, 5, value); } get common_tx_num_in_pending() { return pb_1.Message.getFieldWithDefault(this, 6, 0) as number; } set common_tx_num_in_pending(value: number) { pb_1.Message.setField(this, 6, value); } static fromObject(data: { config_tx_pool_size?: number; common_tx_pool_size?: number; config_tx_num_in_queue?: number; config_tx_num_in_pending?: number; common_tx_num_in_queue?: number; common_tx_num_in_pending?: number; }): TxPoolStatus { const message = new TxPoolStatus({}); if (data.config_tx_pool_size != null) { message.config_tx_pool_size = data.config_tx_pool_size; } if (data.common_tx_pool_size != null) { message.common_tx_pool_size = data.common_tx_pool_size; } if (data.config_tx_num_in_queue != null) { message.config_tx_num_in_queue = data.config_tx_num_in_queue; } if (data.config_tx_num_in_pending != null) { message.config_tx_num_in_pending = data.config_tx_num_in_pending; } if (data.common_tx_num_in_queue != null) { message.common_tx_num_in_queue = data.common_tx_num_in_queue; } if (data.common_tx_num_in_pending != null) { message.common_tx_num_in_pending = data.common_tx_num_in_pending; } return message; } toObject() { const data: { config_tx_pool_size?: number; common_tx_pool_size?: number; config_tx_num_in_queue?: number; config_tx_num_in_pending?: number; common_tx_num_in_queue?: number; common_tx_num_in_pending?: number; } = {}; if (this.config_tx_pool_size != null) { data.config_tx_pool_size = this.config_tx_pool_size; } if (this.common_tx_pool_size != null) { data.common_tx_pool_size = this.common_tx_pool_size; } if (this.config_tx_num_in_queue != null) { data.config_tx_num_in_queue = this.config_tx_num_in_queue; } if (this.config_tx_num_in_pending != null) { data.config_tx_num_in_pending = this.config_tx_num_in_pending; } if (this.common_tx_num_in_queue != null) { data.common_tx_num_in_queue = this.common_tx_num_in_queue; } if (this.common_tx_num_in_pending != null) { data.common_tx_num_in_pending = this.common_tx_num_in_pending; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.config_tx_pool_size != 0) writer.writeInt32(1, this.config_tx_pool_size); if (this.common_tx_pool_size != 0) writer.writeInt32(2, this.common_tx_pool_size); if (this.config_tx_num_in_queue != 0) writer.writeInt32(3, this.config_tx_num_in_queue); if (this.config_tx_num_in_pending != 0) writer.writeInt32(4, this.config_tx_num_in_pending); if (this.common_tx_num_in_queue != 0) writer.writeInt32(5, this.common_tx_num_in_queue); if (this.common_tx_num_in_pending != 0) writer.writeInt32(6, this.common_tx_num_in_pending); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxPoolStatus { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxPoolStatus(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.config_tx_pool_size = reader.readInt32(); break; case 2: message.common_tx_pool_size = reader.readInt32(); break; case 3: message.config_tx_num_in_queue = reader.readInt32(); break; case 4: message.config_tx_num_in_pending = reader.readInt32(); break; case 5: message.common_tx_num_in_queue = reader.readInt32(); break; case 6: message.common_tx_num_in_pending = reader.readInt32(); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxPoolStatus { return TxPoolStatus.deserialize(bytes); } } export class TxPoolMsg extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { type?: TxPoolMsgType; payload?: Uint8Array; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("type" in data && data.type != undefined) { this.type = data.type; } if ("payload" in data && data.payload != undefined) { this.payload = data.payload; } } } get type() { return pb_1.Message.getFieldWithDefault(this, 1, TxPoolMsgType.SINGLE_TX) as TxPoolMsgType; } set type(value: TxPoolMsgType) { pb_1.Message.setField(this, 1, value); } get payload() { return pb_1.Message.getFieldWithDefault(this, 2, new Uint8Array(0)) as Uint8Array; } set payload(value: Uint8Array) { pb_1.Message.setField(this, 2, value); } static fromObject(data: { type?: TxPoolMsgType; payload?: Uint8Array; }): TxPoolMsg { const message = new TxPoolMsg({}); if (data.type != null) { message.type = data.type; } if (data.payload != null) { message.payload = data.payload; } return message; } toObject() { const data: { type?: TxPoolMsgType; payload?: Uint8Array; } = {}; if (this.type != null) { data.type = this.type; } if (this.payload != null) { data.payload = this.payload; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.type != TxPoolMsgType.SINGLE_TX) writer.writeEnum(1, this.type); if (this.payload.length) writer.writeBytes(2, this.payload); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxPoolMsg { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxPoolMsg(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.type = reader.readEnum(); break; case 2: message.payload = reader.readBytes(); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxPoolMsg { return TxPoolMsg.deserialize(bytes); } } export class TxBatch extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { batch_id?: string; size?: number; txs?: dependency_1.common.Transaction[]; tx_ids_map?: Map; endorsement?: dependency_2.common.EndorsementEntry; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [4], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("batch_id" in data && data.batch_id != undefined) { this.batch_id = data.batch_id; } if ("size" in data && data.size != undefined) { this.size = data.size; } if ("txs" in data && data.txs != undefined) { this.txs = data.txs; } if ("tx_ids_map" in data && data.tx_ids_map != undefined) { this.tx_ids_map = data.tx_ids_map; } if ("endorsement" in data && data.endorsement != undefined) { this.endorsement = data.endorsement; } } if (!this.tx_ids_map) this.tx_ids_map = new Map(); } get batch_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set batch_id(value: string) { pb_1.Message.setField(this, 1, value); } get size() { return pb_1.Message.getFieldWithDefault(this, 3, 0) as number; } set size(value: number) { pb_1.Message.setField(this, 3, value); } get txs() { return pb_1.Message.getRepeatedWrapperField(this, dependency_1.common.Transaction, 4) as dependency_1.common.Transaction[]; } set txs(value: dependency_1.common.Transaction[]) { pb_1.Message.setRepeatedWrapperField(this, 4, value); } get tx_ids_map() { return pb_1.Message.getField(this, 5) as any as Map; } set tx_ids_map(value: Map) { pb_1.Message.setField(this, 5, value as any); } get endorsement() { return pb_1.Message.getWrapperField(this, dependency_2.common.EndorsementEntry, 6) as dependency_2.common.EndorsementEntry; } set endorsement(value: dependency_2.common.EndorsementEntry) { pb_1.Message.setWrapperField(this, 6, value); } get has_endorsement() { return pb_1.Message.getField(this, 6) != null; } static fromObject(data: { batch_id?: string; size?: number; txs?: ReturnType[]; tx_ids_map?: { [key: string]: number; }; endorsement?: ReturnType; }): TxBatch { const message = new TxBatch({}); if (data.batch_id != null) { message.batch_id = data.batch_id; } if (data.size != null) { message.size = data.size; } if (data.txs != null) { message.txs = data.txs.map(item => dependency_1.common.Transaction.fromObject(item)); } if (typeof data.tx_ids_map == "object") { message.tx_ids_map = new Map(Object.entries(data.tx_ids_map)); } if (data.endorsement != null) { message.endorsement = dependency_2.common.EndorsementEntry.fromObject(data.endorsement); } return message; } toObject() { const data: { batch_id?: string; size?: number; txs?: ReturnType[]; tx_ids_map?: { [key: string]: number; }; endorsement?: ReturnType; } = {}; if (this.batch_id != null) { data.batch_id = this.batch_id; } if (this.size != null) { data.size = this.size; } if (this.txs != null) { data.txs = this.txs.map((item: dependency_1.common.Transaction) => item.toObject()); } if (this.tx_ids_map != null) { data.tx_ids_map = (Object.fromEntries)(this.tx_ids_map); } if (this.endorsement != null) { data.endorsement = this.endorsement.toObject(); } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.batch_id.length) writer.writeString(1, this.batch_id); if (this.size != 0) writer.writeInt32(3, this.size); if (this.txs.length) writer.writeRepeatedMessage(4, this.txs, (item: dependency_1.common.Transaction) => item.serialize(writer)); for (const [key, value] of this.tx_ids_map) { writer.writeMessage(5, this.tx_ids_map, () => { writer.writeString(1, key); writer.writeInt32(2, value); }); } if (this.has_endorsement) writer.writeMessage(6, this.endorsement, () => this.endorsement.serialize(writer)); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxBatch { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxBatch(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.batch_id = reader.readString(); break; case 3: message.size = reader.readInt32(); break; case 4: reader.readMessage(message.txs, () => pb_1.Message.addToRepeatedWrapperField(message, 4, dependency_1.common.Transaction.deserialize(reader), dependency_1.common.Transaction)); break; case 5: reader.readMessage(message, () => pb_1.Map.deserializeBinary(message.tx_ids_map as any, reader, reader.readString, reader.readInt32)); break; case 6: reader.readMessage(message.endorsement, () => message.endorsement = dependency_2.common.EndorsementEntry.deserialize(reader)); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxBatch { return TxBatch.deserialize(bytes); } } export class TxRecoverRequest extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { node_id?: string; height?: number; tx_ids?: string[]; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [3], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("node_id" in data && data.node_id != undefined) { this.node_id = data.node_id; } if ("height" in data && data.height != undefined) { this.height = data.height; } if ("tx_ids" in data && data.tx_ids != undefined) { this.tx_ids = data.tx_ids; } } } get node_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set node_id(value: string) { pb_1.Message.setField(this, 1, value); } get height() { return pb_1.Message.getFieldWithDefault(this, 2, 0) as number; } set height(value: number) { pb_1.Message.setField(this, 2, value); } get tx_ids() { return pb_1.Message.getFieldWithDefault(this, 3, []) as string[]; } set tx_ids(value: string[]) { pb_1.Message.setField(this, 3, value); } static fromObject(data: { node_id?: string; height?: number; tx_ids?: string[]; }): TxRecoverRequest { const message = new TxRecoverRequest({}); if (data.node_id != null) { message.node_id = data.node_id; } if (data.height != null) { message.height = data.height; } if (data.tx_ids != null) { message.tx_ids = data.tx_ids; } return message; } toObject() { const data: { node_id?: string; height?: number; tx_ids?: string[]; } = {}; if (this.node_id != null) { data.node_id = this.node_id; } if (this.height != null) { data.height = this.height; } if (this.tx_ids != null) { data.tx_ids = this.tx_ids; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.node_id.length) writer.writeString(1, this.node_id); if (this.height != 0) writer.writeUint64(2, this.height); if (this.tx_ids.length) writer.writeRepeatedString(3, this.tx_ids); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxRecoverRequest { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxRecoverRequest(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.node_id = reader.readString(); break; case 2: message.height = reader.readUint64(); break; case 3: pb_1.Message.addToRepeatedField(message, 3, reader.readString()); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxRecoverRequest { return TxRecoverRequest.deserialize(bytes); } } export class TxRecoverResponse extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { node_id?: string; height?: number; txs?: dependency_1.common.Transaction[]; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [3], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("node_id" in data && data.node_id != undefined) { this.node_id = data.node_id; } if ("height" in data && data.height != undefined) { this.height = data.height; } if ("txs" in data && data.txs != undefined) { this.txs = data.txs; } } } get node_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set node_id(value: string) { pb_1.Message.setField(this, 1, value); } get height() { return pb_1.Message.getFieldWithDefault(this, 2, 0) as number; } set height(value: number) { pb_1.Message.setField(this, 2, value); } get txs() { return pb_1.Message.getRepeatedWrapperField(this, dependency_1.common.Transaction, 3) as dependency_1.common.Transaction[]; } set txs(value: dependency_1.common.Transaction[]) { pb_1.Message.setRepeatedWrapperField(this, 3, value); } static fromObject(data: { node_id?: string; height?: number; txs?: ReturnType[]; }): TxRecoverResponse { const message = new TxRecoverResponse({}); if (data.node_id != null) { message.node_id = data.node_id; } if (data.height != null) { message.height = data.height; } if (data.txs != null) { message.txs = data.txs.map(item => dependency_1.common.Transaction.fromObject(item)); } return message; } toObject() { const data: { node_id?: string; height?: number; txs?: ReturnType[]; } = {}; if (this.node_id != null) { data.node_id = this.node_id; } if (this.height != null) { data.height = this.height; } if (this.txs != null) { data.txs = this.txs.map((item: dependency_1.common.Transaction) => item.toObject()); } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.node_id.length) writer.writeString(1, this.node_id); if (this.height != 0) writer.writeUint64(2, this.height); if (this.txs.length) writer.writeRepeatedMessage(3, this.txs, (item: dependency_1.common.Transaction) => item.serialize(writer)); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxRecoverResponse { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxRecoverResponse(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.node_id = reader.readString(); break; case 2: message.height = reader.readUint64(); break; case 3: reader.readMessage(message.txs, () => pb_1.Message.addToRepeatedWrapperField(message, 3, dependency_1.common.Transaction.deserialize(reader), dependency_1.common.Transaction)); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxRecoverResponse { return TxRecoverResponse.deserialize(bytes); } } export class TxBatchRecoverRequest extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { node_id?: string; height?: number; batch_ids?: string[]; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [3], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("node_id" in data && data.node_id != undefined) { this.node_id = data.node_id; } if ("height" in data && data.height != undefined) { this.height = data.height; } if ("batch_ids" in data && data.batch_ids != undefined) { this.batch_ids = data.batch_ids; } } } get node_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set node_id(value: string) { pb_1.Message.setField(this, 1, value); } get height() { return pb_1.Message.getFieldWithDefault(this, 2, 0) as number; } set height(value: number) { pb_1.Message.setField(this, 2, value); } get batch_ids() { return pb_1.Message.getFieldWithDefault(this, 3, []) as string[]; } set batch_ids(value: string[]) { pb_1.Message.setField(this, 3, value); } static fromObject(data: { node_id?: string; height?: number; batch_ids?: string[]; }): TxBatchRecoverRequest { const message = new TxBatchRecoverRequest({}); if (data.node_id != null) { message.node_id = data.node_id; } if (data.height != null) { message.height = data.height; } if (data.batch_ids != null) { message.batch_ids = data.batch_ids; } return message; } toObject() { const data: { node_id?: string; height?: number; batch_ids?: string[]; } = {}; if (this.node_id != null) { data.node_id = this.node_id; } if (this.height != null) { data.height = this.height; } if (this.batch_ids != null) { data.batch_ids = this.batch_ids; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.node_id.length) writer.writeString(1, this.node_id); if (this.height != 0) writer.writeUint64(2, this.height); if (this.batch_ids.length) writer.writeRepeatedString(3, this.batch_ids); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxBatchRecoverRequest { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxBatchRecoverRequest(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.node_id = reader.readString(); break; case 2: message.height = reader.readUint64(); break; case 3: pb_1.Message.addToRepeatedField(message, 3, reader.readString()); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxBatchRecoverRequest { return TxBatchRecoverRequest.deserialize(bytes); } } export class TxBatchRecoverResponse extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { node_id?: string; height?: number; tx_batches?: TxBatch[]; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [3], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("node_id" in data && data.node_id != undefined) { this.node_id = data.node_id; } if ("height" in data && data.height != undefined) { this.height = data.height; } if ("tx_batches" in data && data.tx_batches != undefined) { this.tx_batches = data.tx_batches; } } } get node_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set node_id(value: string) { pb_1.Message.setField(this, 1, value); } get height() { return pb_1.Message.getFieldWithDefault(this, 2, 0) as number; } set height(value: number) { pb_1.Message.setField(this, 2, value); } get tx_batches() { return pb_1.Message.getRepeatedWrapperField(this, TxBatch, 3) as TxBatch[]; } set tx_batches(value: TxBatch[]) { pb_1.Message.setRepeatedWrapperField(this, 3, value); } static fromObject(data: { node_id?: string; height?: number; tx_batches?: ReturnType[]; }): TxBatchRecoverResponse { const message = new TxBatchRecoverResponse({}); if (data.node_id != null) { message.node_id = data.node_id; } if (data.height != null) { message.height = data.height; } if (data.tx_batches != null) { message.tx_batches = data.tx_batches.map(item => TxBatch.fromObject(item)); } return message; } toObject() { const data: { node_id?: string; height?: number; tx_batches?: ReturnType[]; } = {}; if (this.node_id != null) { data.node_id = this.node_id; } if (this.height != null) { data.height = this.height; } if (this.tx_batches != null) { data.tx_batches = this.tx_batches.map((item: TxBatch) => item.toObject()); } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.node_id.length) writer.writeString(1, this.node_id); if (this.height != 0) writer.writeUint64(2, this.height); if (this.tx_batches.length) writer.writeRepeatedMessage(3, this.tx_batches, (item: TxBatch) => item.serialize(writer)); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TxBatchRecoverResponse { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new TxBatchRecoverResponse(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.node_id = reader.readString(); break; case 2: message.height = reader.readUint64(); break; case 3: reader.readMessage(message.tx_batches, () => pb_1.Message.addToRepeatedWrapperField(message, 3, TxBatch.deserialize(reader), TxBatch)); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): TxBatchRecoverResponse { return TxBatchRecoverResponse.deserialize(bytes); } } export class GetPoolStatusRequest extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { chain_id?: string; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("chain_id" in data && data.chain_id != undefined) { this.chain_id = data.chain_id; } } } get chain_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set chain_id(value: string) { pb_1.Message.setField(this, 1, value); } static fromObject(data: { chain_id?: string; }): GetPoolStatusRequest { const message = new GetPoolStatusRequest({}); if (data.chain_id != null) { message.chain_id = data.chain_id; } return message; } toObject() { const data: { chain_id?: string; } = {}; if (this.chain_id != null) { data.chain_id = this.chain_id; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.chain_id.length) writer.writeString(1, this.chain_id); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetPoolStatusRequest { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new GetPoolStatusRequest(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.chain_id = reader.readString(); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): GetPoolStatusRequest { return GetPoolStatusRequest.deserialize(bytes); } } export class GetTxIdsByTypeAndStageRequest extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { chain_id?: string; tx_type?: TxType; tx_stage?: TxStage; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("chain_id" in data && data.chain_id != undefined) { this.chain_id = data.chain_id; } if ("tx_type" in data && data.tx_type != undefined) { this.tx_type = data.tx_type; } if ("tx_stage" in data && data.tx_stage != undefined) { this.tx_stage = data.tx_stage; } } } get chain_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set chain_id(value: string) { pb_1.Message.setField(this, 1, value); } get tx_type() { return pb_1.Message.getFieldWithDefault(this, 2, TxType.UNKNOWN_TYPE) as TxType; } set tx_type(value: TxType) { pb_1.Message.setField(this, 2, value); } get tx_stage() { return pb_1.Message.getFieldWithDefault(this, 3, TxStage.UNKNOWN_STAGE) as TxStage; } set tx_stage(value: TxStage) { pb_1.Message.setField(this, 3, value); } static fromObject(data: { chain_id?: string; tx_type?: TxType; tx_stage?: TxStage; }): GetTxIdsByTypeAndStageRequest { const message = new GetTxIdsByTypeAndStageRequest({}); if (data.chain_id != null) { message.chain_id = data.chain_id; } if (data.tx_type != null) { message.tx_type = data.tx_type; } if (data.tx_stage != null) { message.tx_stage = data.tx_stage; } return message; } toObject() { const data: { chain_id?: string; tx_type?: TxType; tx_stage?: TxStage; } = {}; if (this.chain_id != null) { data.chain_id = this.chain_id; } if (this.tx_type != null) { data.tx_type = this.tx_type; } if (this.tx_stage != null) { data.tx_stage = this.tx_stage; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.chain_id.length) writer.writeString(1, this.chain_id); if (this.tx_type != TxType.UNKNOWN_TYPE) writer.writeEnum(2, this.tx_type); if (this.tx_stage != TxStage.UNKNOWN_STAGE) writer.writeEnum(3, this.tx_stage); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetTxIdsByTypeAndStageRequest { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new GetTxIdsByTypeAndStageRequest(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.chain_id = reader.readString(); break; case 2: message.tx_type = reader.readEnum(); break; case 3: message.tx_stage = reader.readEnum(); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): GetTxIdsByTypeAndStageRequest { return GetTxIdsByTypeAndStageRequest.deserialize(bytes); } } export class GetTxIdsByTypeAndStageResponse extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { tx_ids?: string[]; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [1], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("tx_ids" in data && data.tx_ids != undefined) { this.tx_ids = data.tx_ids; } } } get tx_ids() { return pb_1.Message.getFieldWithDefault(this, 1, []) as string[]; } set tx_ids(value: string[]) { pb_1.Message.setField(this, 1, value); } static fromObject(data: { tx_ids?: string[]; }): GetTxIdsByTypeAndStageResponse { const message = new GetTxIdsByTypeAndStageResponse({}); if (data.tx_ids != null) { message.tx_ids = data.tx_ids; } return message; } toObject() { const data: { tx_ids?: string[]; } = {}; if (this.tx_ids != null) { data.tx_ids = this.tx_ids; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.tx_ids.length) writer.writeRepeatedString(1, this.tx_ids); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetTxIdsByTypeAndStageResponse { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new GetTxIdsByTypeAndStageResponse(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: pb_1.Message.addToRepeatedField(message, 1, reader.readString()); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): GetTxIdsByTypeAndStageResponse { return GetTxIdsByTypeAndStageResponse.deserialize(bytes); } } export class GetTxsInPoolByTxIdsRequest extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { chain_id?: string; tx_ids?: string[]; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [2], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("chain_id" in data && data.chain_id != undefined) { this.chain_id = data.chain_id; } if ("tx_ids" in data && data.tx_ids != undefined) { this.tx_ids = data.tx_ids; } } } get chain_id() { return pb_1.Message.getFieldWithDefault(this, 1, "") as string; } set chain_id(value: string) { pb_1.Message.setField(this, 1, value); } get tx_ids() { return pb_1.Message.getFieldWithDefault(this, 2, []) as string[]; } set tx_ids(value: string[]) { pb_1.Message.setField(this, 2, value); } static fromObject(data: { chain_id?: string; tx_ids?: string[]; }): GetTxsInPoolByTxIdsRequest { const message = new GetTxsInPoolByTxIdsRequest({}); if (data.chain_id != null) { message.chain_id = data.chain_id; } if (data.tx_ids != null) { message.tx_ids = data.tx_ids; } return message; } toObject() { const data: { chain_id?: string; tx_ids?: string[]; } = {}; if (this.chain_id != null) { data.chain_id = this.chain_id; } if (this.tx_ids != null) { data.tx_ids = this.tx_ids; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.chain_id.length) writer.writeString(1, this.chain_id); if (this.tx_ids.length) writer.writeRepeatedString(2, this.tx_ids); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetTxsInPoolByTxIdsRequest { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new GetTxsInPoolByTxIdsRequest(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.chain_id = reader.readString(); break; case 2: pb_1.Message.addToRepeatedField(message, 2, reader.readString()); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): GetTxsInPoolByTxIdsRequest { return GetTxsInPoolByTxIdsRequest.deserialize(bytes); } } export class GetTxsInPoolByTxIdsResponse extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { txs?: dependency_1.common.Transaction[]; tx_ids?: string[]; }) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [1, 2], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("txs" in data && data.txs != undefined) { this.txs = data.txs; } if ("tx_ids" in data && data.tx_ids != undefined) { this.tx_ids = data.tx_ids; } } } get txs() { return pb_1.Message.getRepeatedWrapperField(this, dependency_1.common.Transaction, 1) as dependency_1.common.Transaction[]; } set txs(value: dependency_1.common.Transaction[]) { pb_1.Message.setRepeatedWrapperField(this, 1, value); } get tx_ids() { return pb_1.Message.getFieldWithDefault(this, 2, []) as string[]; } set tx_ids(value: string[]) { pb_1.Message.setField(this, 2, value); } static fromObject(data: { txs?: ReturnType[]; tx_ids?: string[]; }): GetTxsInPoolByTxIdsResponse { const message = new GetTxsInPoolByTxIdsResponse({}); if (data.txs != null) { message.txs = data.txs.map(item => dependency_1.common.Transaction.fromObject(item)); } if (data.tx_ids != null) { message.tx_ids = data.tx_ids; } return message; } toObject() { const data: { txs?: ReturnType[]; tx_ids?: string[]; } = {}; if (this.txs != null) { data.txs = this.txs.map((item: dependency_1.common.Transaction) => item.toObject()); } if (this.tx_ids != null) { data.tx_ids = this.tx_ids; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.txs.length) writer.writeRepeatedMessage(1, this.txs, (item: dependency_1.common.Transaction) => item.serialize(writer)); if (this.tx_ids.length) writer.writeRepeatedString(2, this.tx_ids); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetTxsInPoolByTxIdsResponse { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new GetTxsInPoolByTxIdsResponse(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: reader.readMessage(message.txs, () => pb_1.Message.addToRepeatedWrapperField(message, 1, dependency_1.common.Transaction.deserialize(reader), dependency_1.common.Transaction)); break; case 2: pb_1.Message.addToRepeatedField(message, 2, reader.readString()); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): GetTxsInPoolByTxIdsResponse { return GetTxsInPoolByTxIdsResponse.deserialize(bytes); } } }