import { Tx } from "./tx"; import { PageRequest, PageResponse } from "../../base/query/v1beta1/pagination"; import { TxResponse, GasInfo, Result } from "../../base/abci/v1beta1/abci"; import { BlockID } from "../../../tendermint/types/types"; import { Block } from "../../../tendermint/types/block"; import { Rpc } from "@osmonauts/helpers"; import * as _m0 from "protobufjs/minimal"; import { SimulateRequest, SimulateResponse, GetTxRequest, GetTxResponse, BroadcastTxRequest, BroadcastTxResponse, GetTxsEventRequest, GetTxsEventResponse, GetBlockWithTxsRequest, GetBlockWithTxsResponse } from "./service"; /** Service defines the RPC service */ export interface Service { simulate(request: SimulateRequest): Promise; /*Simulate simulates executing a transaction for estimating gas usage.*/ getTx(request: GetTxRequest): Promise; /*GetTx fetches a tx by hash.*/ broadcastTx(request: BroadcastTxRequest): Promise; /*BroadcastTx broadcast transaction.*/ getTxsEvent(request: GetTxsEventRequest): Promise; /*GetTxsEvent fetches txs by event.*/ getBlockWithTxs(request: GetBlockWithTxsRequest): Promise; /*GetBlockWithTxs fetches a block with decoded txs. Since: cosmos-sdk 0.45.2*/ } export class ServiceClientImpl implements Service { private readonly rpc: Rpc; constructor(rpc: Rpc) { this.rpc = rpc; this.simulate = this.simulate.bind(this); this.getTx = this.getTx.bind(this); this.broadcastTx = this.broadcastTx.bind(this); this.getTxsEvent = this.getTxsEvent.bind(this); this.getBlockWithTxs = this.getBlockWithTxs.bind(this); } simulate(request: SimulateRequest): Promise { const data = SimulateRequest.encode(request).finish(); const promise = this.rpc.request("cosmos.tx.v1beta1.Service", "Simulate", data); return promise.then(data => SimulateResponse.decode(new _m0.Reader(data))); } getTx(request: GetTxRequest): Promise { const data = GetTxRequest.encode(request).finish(); const promise = this.rpc.request("cosmos.tx.v1beta1.Service", "GetTx", data); return promise.then(data => GetTxResponse.decode(new _m0.Reader(data))); } broadcastTx(request: BroadcastTxRequest): Promise { const data = BroadcastTxRequest.encode(request).finish(); const promise = this.rpc.request("cosmos.tx.v1beta1.Service", "BroadcastTx", data); return promise.then(data => BroadcastTxResponse.decode(new _m0.Reader(data))); } getTxsEvent(request: GetTxsEventRequest): Promise { const data = GetTxsEventRequest.encode(request).finish(); const promise = this.rpc.request("cosmos.tx.v1beta1.Service", "GetTxsEvent", data); return promise.then(data => GetTxsEventResponse.decode(new _m0.Reader(data))); } getBlockWithTxs(request: GetBlockWithTxsRequest): Promise { const data = GetBlockWithTxsRequest.encode(request).finish(); const promise = this.rpc.request("cosmos.tx.v1beta1.Service", "GetBlockWithTxs", data); return promise.then(data => GetBlockWithTxsResponse.decode(new _m0.Reader(data))); } }