New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

@injectivelabs/indexer-proto-ts

Package Overview
Dependencies
Maintainers
9
Versions
80
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@injectivelabs/indexer-proto-ts - npm Package Compare versions

Comparing version 1.10.8-rc.4 to 1.11.1

92

cjs/event_provider_api.d.ts
import { grpc } from "@injectivelabs/grpc-web";
import _m0 from "protobufjs/minimal";
import { Observable } from "rxjs";
export declare const protobufPackage = "event_provider_api";

@@ -7,6 +8,8 @@ export interface GetLatestHeightRequest {

export interface GetLatestHeightResponse {
/** Response version. */
v: string;
/** Status of the response. */
s: string;
/** Error message. */
errmsg: string;
e: string;
data: LatestBlockHeight | undefined;

@@ -18,2 +21,26 @@ }

}
export interface StreamBlockEventsRequest {
/** Select backend processor */
backend: string;
height: number;
}
export interface StreamBlockEventsResponse {
blocks: Block[];
}
export interface Block {
height: string;
version: string;
/** Processed block events in the block */
events: BlockEvent[];
/** Indicates whether the block is the latest one available in the event provider */
inSync: boolean;
}
export interface BlockEvent {
/** Event type */
typeUrl: string;
/** Event data */
value: Uint8Array;
/** TX hash */
txHash: Uint8Array;
}
export interface GetBlockEventsRPCRequest {

@@ -25,6 +52,8 @@ /** Select backend processor */

export interface GetBlockEventsRPCResponse {
/** Response version. */
v: string;
/** Status of the response. */
s: string;
/** Error message. */
errmsg: string;
e: string;
data: BlockEventsRPC | undefined;

@@ -38,3 +67,11 @@ }

events: Uint8Array[];
/** Map of event index - tx hash */
txHashes: {
[key: number]: Uint8Array;
};
}
export interface BlockEventsRPC_TxHashesEntry {
key: number;
value: Uint8Array;
}
export interface GetCustomEventsRPCRequest {

@@ -48,6 +85,8 @@ /** Select backend processor */

export interface GetCustomEventsRPCResponse {
/** Response version. */
v: string;
/** Status of the response. */
s: string;
/** Error message. */
errmsg: string;
e: string;
data: BlockEventsRPC | undefined;

@@ -79,2 +118,34 @@ }

};
export declare const StreamBlockEventsRequest: {
encode(message: StreamBlockEventsRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): StreamBlockEventsRequest;
fromJSON(object: any): StreamBlockEventsRequest;
toJSON(message: StreamBlockEventsRequest): unknown;
create(base?: DeepPartial<StreamBlockEventsRequest>): StreamBlockEventsRequest;
fromPartial(object: DeepPartial<StreamBlockEventsRequest>): StreamBlockEventsRequest;
};
export declare const StreamBlockEventsResponse: {
encode(message: StreamBlockEventsResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): StreamBlockEventsResponse;
fromJSON(object: any): StreamBlockEventsResponse;
toJSON(message: StreamBlockEventsResponse): unknown;
create(base?: DeepPartial<StreamBlockEventsResponse>): StreamBlockEventsResponse;
fromPartial(object: DeepPartial<StreamBlockEventsResponse>): StreamBlockEventsResponse;
};
export declare const Block: {
encode(message: Block, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): Block;
fromJSON(object: any): Block;
toJSON(message: Block): unknown;
create(base?: DeepPartial<Block>): Block;
fromPartial(object: DeepPartial<Block>): Block;
};
export declare const BlockEvent: {
encode(message: BlockEvent, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): BlockEvent;
fromJSON(object: any): BlockEvent;
toJSON(message: BlockEvent): unknown;
create(base?: DeepPartial<BlockEvent>): BlockEvent;
fromPartial(object: DeepPartial<BlockEvent>): BlockEvent;
};
export declare const GetBlockEventsRPCRequest: {

@@ -104,2 +175,10 @@ encode(message: GetBlockEventsRPCRequest, writer?: _m0.Writer): _m0.Writer;

};
export declare const BlockEventsRPC_TxHashesEntry: {
encode(message: BlockEventsRPC_TxHashesEntry, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): BlockEventsRPC_TxHashesEntry;
fromJSON(object: any): BlockEventsRPC_TxHashesEntry;
toJSON(message: BlockEventsRPC_TxHashesEntry): unknown;
create(base?: DeepPartial<BlockEventsRPC_TxHashesEntry>): BlockEventsRPC_TxHashesEntry;
fromPartial(object: DeepPartial<BlockEventsRPC_TxHashesEntry>): BlockEventsRPC_TxHashesEntry;
};
export declare const GetCustomEventsRPCRequest: {

@@ -125,2 +204,4 @@ encode(message: GetCustomEventsRPCRequest, writer?: _m0.Writer): _m0.Writer;

GetLatestHeight(request: DeepPartial<GetLatestHeightRequest>, metadata?: grpc.Metadata): Promise<GetLatestHeightResponse>;
/** Stream processed block events for selected backend */
StreamBlockEvents(request: DeepPartial<StreamBlockEventsRequest>, metadata?: grpc.Metadata): Observable<StreamBlockEventsResponse>;
/** Get processed block events for selected backend */

@@ -135,2 +216,3 @@ GetBlockEventsRPC(request: DeepPartial<GetBlockEventsRPCRequest>, metadata?: grpc.Metadata): Promise<GetBlockEventsRPCResponse>;

GetLatestHeight(request: DeepPartial<GetLatestHeightRequest>, metadata?: grpc.Metadata): Promise<GetLatestHeightResponse>;
StreamBlockEvents(request: DeepPartial<StreamBlockEventsRequest>, metadata?: grpc.Metadata): Observable<StreamBlockEventsResponse>;
GetBlockEventsRPC(request: DeepPartial<GetBlockEventsRPCRequest>, metadata?: grpc.Metadata): Promise<GetBlockEventsRPCResponse>;

@@ -143,2 +225,3 @@ GetCustomEventsRPC(request: DeepPartial<GetCustomEventsRPCRequest>, metadata?: grpc.Metadata): Promise<GetCustomEventsRPCResponse>;

export declare const EventProviderAPIGetLatestHeightDesc: UnaryMethodDefinitionish;
export declare const EventProviderAPIStreamBlockEventsDesc: UnaryMethodDefinitionish;
export declare const EventProviderAPIGetBlockEventsRPCDesc: UnaryMethodDefinitionish;

@@ -153,2 +236,3 @@ export declare const EventProviderAPIGetCustomEventsRPCDesc: UnaryMethodDefinitionish;

unary<T extends UnaryMethodDefinitionish>(methodDesc: T, request: any, metadata: grpc.Metadata | undefined): Promise<any>;
invoke<T extends UnaryMethodDefinitionish>(methodDesc: T, request: any, metadata: grpc.Metadata | undefined): Observable<any>;
}

@@ -160,2 +244,3 @@ export declare class GrpcWebImpl {

transport?: grpc.TransportFactory;
streamingTransport?: grpc.TransportFactory;
debug?: boolean;

@@ -166,2 +251,3 @@ metadata?: grpc.Metadata;

unary<T extends UnaryMethodDefinitionish>(methodDesc: T, _request: any, metadata: grpc.Metadata | undefined): Promise<any>;
invoke<T extends UnaryMethodDefinitionish>(methodDesc: T, _request: any, metadata: grpc.Metadata | undefined): Observable<any>;
}

@@ -168,0 +254,0 @@ declare var tsProtoGlobalThis: any;

506

cjs/event_provider_api.js

@@ -6,3 +6,3 @@ "use strict";

Object.defineProperty(exports, "__esModule", { value: true });
exports.GrpcWebError = exports.GrpcWebImpl = exports.EventProviderAPIGetCustomEventsRPCDesc = exports.EventProviderAPIGetBlockEventsRPCDesc = exports.EventProviderAPIGetLatestHeightDesc = exports.EventProviderAPIDesc = exports.EventProviderAPIClientImpl = exports.GetCustomEventsRPCResponse = exports.GetCustomEventsRPCRequest = exports.BlockEventsRPC = exports.GetBlockEventsRPCResponse = exports.GetBlockEventsRPCRequest = exports.LatestBlockHeight = exports.GetLatestHeightResponse = exports.GetLatestHeightRequest = exports.protobufPackage = void 0;
exports.GrpcWebError = exports.GrpcWebImpl = exports.EventProviderAPIGetCustomEventsRPCDesc = exports.EventProviderAPIGetBlockEventsRPCDesc = exports.EventProviderAPIStreamBlockEventsDesc = exports.EventProviderAPIGetLatestHeightDesc = exports.EventProviderAPIDesc = exports.EventProviderAPIClientImpl = exports.GetCustomEventsRPCResponse = exports.GetCustomEventsRPCRequest = exports.BlockEventsRPC_TxHashesEntry = exports.BlockEventsRPC = exports.GetBlockEventsRPCResponse = exports.GetBlockEventsRPCRequest = exports.BlockEvent = exports.Block = exports.StreamBlockEventsResponse = exports.StreamBlockEventsRequest = exports.LatestBlockHeight = exports.GetLatestHeightResponse = exports.GetLatestHeightRequest = exports.protobufPackage = void 0;
/* eslint-disable */

@@ -13,2 +13,4 @@ const grpc_web_1 = require("@injectivelabs/grpc-web");

const minimal_1 = __importDefault(require("protobufjs/minimal"));
const rxjs_1 = require("rxjs");
const operators_1 = require("rxjs/operators");
exports.protobufPackage = "event_provider_api";

@@ -52,14 +54,17 @@ function createBaseGetLatestHeightRequest() {

function createBaseGetLatestHeightResponse() {
return { s: "", errmsg: "", data: undefined };
return { v: "", s: "", e: "", data: undefined };
}
exports.GetLatestHeightResponse = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.v !== "") {
writer.uint32(10).string(message.v);
}
if (message.s !== "") {
writer.uint32(10).string(message.s);
writer.uint32(18).string(message.s);
}
if (message.errmsg !== "") {
writer.uint32(18).string(message.errmsg);
if (message.e !== "") {
writer.uint32(26).string(message.e);
}
if (message.data !== undefined) {
exports.LatestBlockHeight.encode(message.data, writer.uint32(26).fork()).ldelim();
exports.LatestBlockHeight.encode(message.data, writer.uint32(34).fork()).ldelim();
}

@@ -76,8 +81,11 @@ return writer;

case 1:
message.s = reader.string();
message.v = reader.string();
break;
case 2:
message.errmsg = reader.string();
message.s = reader.string();
break;
case 3:
message.e = reader.string();
break;
case 4:
message.data = exports.LatestBlockHeight.decode(reader, reader.uint32());

@@ -94,4 +102,5 @@ break;

return {
v: isSet(object.v) ? String(object.v) : "",
s: isSet(object.s) ? String(object.s) : "",
errmsg: isSet(object.errmsg) ? String(object.errmsg) : "",
e: isSet(object.e) ? String(object.e) : "",
data: isSet(object.data) ? exports.LatestBlockHeight.fromJSON(object.data) : undefined,

@@ -102,4 +111,5 @@ };

const obj = {};
message.v !== undefined && (obj.v = message.v);
message.s !== undefined && (obj.s = message.s);
message.errmsg !== undefined && (obj.errmsg = message.errmsg);
message.e !== undefined && (obj.e = message.e);
message.data !== undefined && (obj.data = message.data ? exports.LatestBlockHeight.toJSON(message.data) : undefined);

@@ -112,6 +122,7 @@ return obj;

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseGetLatestHeightResponse();
message.s = (_a = object.s) !== null && _a !== void 0 ? _a : "";
message.errmsg = (_b = object.errmsg) !== null && _b !== void 0 ? _b : "";
message.v = (_a = object.v) !== null && _a !== void 0 ? _a : "";
message.s = (_b = object.s) !== null && _b !== void 0 ? _b : "";
message.e = (_c = object.e) !== null && _c !== void 0 ? _c : "";
message.data = (object.data !== undefined && object.data !== null)

@@ -168,2 +179,254 @@ ? exports.LatestBlockHeight.fromPartial(object.data)

};
function createBaseStreamBlockEventsRequest() {
return { backend: "", height: 0 };
}
exports.StreamBlockEventsRequest = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.backend !== "") {
writer.uint32(10).string(message.backend);
}
if (message.height !== 0) {
writer.uint32(16).sint32(message.height);
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamBlockEventsRequest();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.backend = reader.string();
break;
case 2:
message.height = reader.sint32();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
backend: isSet(object.backend) ? String(object.backend) : "",
height: isSet(object.height) ? Number(object.height) : 0,
};
},
toJSON(message) {
const obj = {};
message.backend !== undefined && (obj.backend = message.backend);
message.height !== undefined && (obj.height = Math.round(message.height));
return obj;
},
create(base) {
return exports.StreamBlockEventsRequest.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b;
const message = createBaseStreamBlockEventsRequest();
message.backend = (_a = object.backend) !== null && _a !== void 0 ? _a : "";
message.height = (_b = object.height) !== null && _b !== void 0 ? _b : 0;
return message;
},
};
function createBaseStreamBlockEventsResponse() {
return { blocks: [] };
}
exports.StreamBlockEventsResponse = {
encode(message, writer = minimal_1.default.Writer.create()) {
for (const v of message.blocks) {
exports.Block.encode(v, writer.uint32(10).fork()).ldelim();
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamBlockEventsResponse();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.blocks.push(exports.Block.decode(reader, reader.uint32()));
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return { blocks: Array.isArray(object === null || object === void 0 ? void 0 : object.blocks) ? object.blocks.map((e) => exports.Block.fromJSON(e)) : [] };
},
toJSON(message) {
const obj = {};
if (message.blocks) {
obj.blocks = message.blocks.map((e) => e ? exports.Block.toJSON(e) : undefined);
}
else {
obj.blocks = [];
}
return obj;
},
create(base) {
return exports.StreamBlockEventsResponse.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a;
const message = createBaseStreamBlockEventsResponse();
message.blocks = ((_a = object.blocks) === null || _a === void 0 ? void 0 : _a.map((e) => exports.Block.fromPartial(e))) || [];
return message;
},
};
function createBaseBlock() {
return { height: "0", version: "", events: [], inSync: false };
}
exports.Block = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.height !== "0") {
writer.uint32(8).sint64(message.height);
}
if (message.version !== "") {
writer.uint32(18).string(message.version);
}
for (const v of message.events) {
exports.BlockEvent.encode(v, writer.uint32(26).fork()).ldelim();
}
if (message.inSync === true) {
writer.uint32(32).bool(message.inSync);
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseBlock();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.height = longToString(reader.sint64());
break;
case 2:
message.version = reader.string();
break;
case 3:
message.events.push(exports.BlockEvent.decode(reader, reader.uint32()));
break;
case 4:
message.inSync = reader.bool();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
height: isSet(object.height) ? String(object.height) : "0",
version: isSet(object.version) ? String(object.version) : "",
events: Array.isArray(object === null || object === void 0 ? void 0 : object.events) ? object.events.map((e) => exports.BlockEvent.fromJSON(e)) : [],
inSync: isSet(object.inSync) ? Boolean(object.inSync) : false,
};
},
toJSON(message) {
const obj = {};
message.height !== undefined && (obj.height = message.height);
message.version !== undefined && (obj.version = message.version);
if (message.events) {
obj.events = message.events.map((e) => e ? exports.BlockEvent.toJSON(e) : undefined);
}
else {
obj.events = [];
}
message.inSync !== undefined && (obj.inSync = message.inSync);
return obj;
},
create(base) {
return exports.Block.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b, _c, _d;
const message = createBaseBlock();
message.height = (_a = object.height) !== null && _a !== void 0 ? _a : "0";
message.version = (_b = object.version) !== null && _b !== void 0 ? _b : "";
message.events = ((_c = object.events) === null || _c === void 0 ? void 0 : _c.map((e) => exports.BlockEvent.fromPartial(e))) || [];
message.inSync = (_d = object.inSync) !== null && _d !== void 0 ? _d : false;
return message;
},
};
function createBaseBlockEvent() {
return { typeUrl: "", value: new Uint8Array(), txHash: new Uint8Array() };
}
exports.BlockEvent = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.typeUrl !== "") {
writer.uint32(10).string(message.typeUrl);
}
if (message.value.length !== 0) {
writer.uint32(18).bytes(message.value);
}
if (message.txHash.length !== 0) {
writer.uint32(26).bytes(message.txHash);
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseBlockEvent();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.typeUrl = reader.string();
break;
case 2:
message.value = reader.bytes();
break;
case 3:
message.txHash = reader.bytes();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
typeUrl: isSet(object.typeUrl) ? String(object.typeUrl) : "",
value: isSet(object.value) ? bytesFromBase64(object.value) : new Uint8Array(),
txHash: isSet(object.txHash) ? bytesFromBase64(object.txHash) : new Uint8Array(),
};
},
toJSON(message) {
const obj = {};
message.typeUrl !== undefined && (obj.typeUrl = message.typeUrl);
message.value !== undefined &&
(obj.value = base64FromBytes(message.value !== undefined ? message.value : new Uint8Array()));
message.txHash !== undefined &&
(obj.txHash = base64FromBytes(message.txHash !== undefined ? message.txHash : new Uint8Array()));
return obj;
},
create(base) {
return exports.BlockEvent.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b, _c;
const message = createBaseBlockEvent();
message.typeUrl = (_a = object.typeUrl) !== null && _a !== void 0 ? _a : "";
message.value = (_b = object.value) !== null && _b !== void 0 ? _b : new Uint8Array();
message.txHash = (_c = object.txHash) !== null && _c !== void 0 ? _c : new Uint8Array();
return message;
},
};
function createBaseGetBlockEventsRPCRequest() {

@@ -226,14 +489,17 @@ return { backend: "", height: 0 };

function createBaseGetBlockEventsRPCResponse() {
return { s: "", errmsg: "", data: undefined };
return { v: "", s: "", e: "", data: undefined };
}
exports.GetBlockEventsRPCResponse = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.v !== "") {
writer.uint32(10).string(message.v);
}
if (message.s !== "") {
writer.uint32(10).string(message.s);
writer.uint32(18).string(message.s);
}
if (message.errmsg !== "") {
writer.uint32(18).string(message.errmsg);
if (message.e !== "") {
writer.uint32(26).string(message.e);
}
if (message.data !== undefined) {
exports.BlockEventsRPC.encode(message.data, writer.uint32(26).fork()).ldelim();
exports.BlockEventsRPC.encode(message.data, writer.uint32(34).fork()).ldelim();
}

@@ -250,8 +516,11 @@ return writer;

case 1:
message.s = reader.string();
message.v = reader.string();
break;
case 2:
message.errmsg = reader.string();
message.s = reader.string();
break;
case 3:
message.e = reader.string();
break;
case 4:
message.data = exports.BlockEventsRPC.decode(reader, reader.uint32());

@@ -268,4 +537,5 @@ break;

return {
v: isSet(object.v) ? String(object.v) : "",
s: isSet(object.s) ? String(object.s) : "",
errmsg: isSet(object.errmsg) ? String(object.errmsg) : "",
e: isSet(object.e) ? String(object.e) : "",
data: isSet(object.data) ? exports.BlockEventsRPC.fromJSON(object.data) : undefined,

@@ -276,4 +546,5 @@ };

const obj = {};
message.v !== undefined && (obj.v = message.v);
message.s !== undefined && (obj.s = message.s);
message.errmsg !== undefined && (obj.errmsg = message.errmsg);
message.e !== undefined && (obj.e = message.e);
message.data !== undefined && (obj.data = message.data ? exports.BlockEventsRPC.toJSON(message.data) : undefined);

@@ -286,6 +557,7 @@ return obj;

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseGetBlockEventsRPCResponse();
message.s = (_a = object.s) !== null && _a !== void 0 ? _a : "";
message.errmsg = (_b = object.errmsg) !== null && _b !== void 0 ? _b : "";
message.v = (_a = object.v) !== null && _a !== void 0 ? _a : "";
message.s = (_b = object.s) !== null && _b !== void 0 ? _b : "";
message.e = (_c = object.e) !== null && _c !== void 0 ? _c : "";
message.data = (object.data !== undefined && object.data !== null)

@@ -298,3 +570,3 @@ ? exports.BlockEventsRPC.fromPartial(object.data)

function createBaseBlockEventsRPC() {
return { types: [], events: [] };
return { types: [], events: [], txHashes: {} };
}

@@ -309,2 +581,5 @@ exports.BlockEventsRPC = {

}
Object.entries(message.txHashes).forEach(([key, value]) => {
exports.BlockEventsRPC_TxHashesEntry.encode({ key: key, value }, writer.uint32(26).fork()).ldelim();
});
return writer;

@@ -325,2 +600,8 @@ },

break;
case 3:
const entry3 = exports.BlockEventsRPC_TxHashesEntry.decode(reader, reader.uint32());
if (entry3.value !== undefined) {
message.txHashes[entry3.key] = entry3.value;
}
break;
default:

@@ -337,2 +618,8 @@ reader.skipType(tag & 7);

events: Array.isArray(object === null || object === void 0 ? void 0 : object.events) ? object.events.map((e) => bytesFromBase64(e)) : [],
txHashes: isObject(object.txHashes)
? Object.entries(object.txHashes).reduce((acc, [key, value]) => {
acc[Number(key)] = bytesFromBase64(value);
return acc;
}, {})
: {},
};

@@ -354,2 +641,8 @@ },

}
obj.txHashes = {};
if (message.txHashes) {
Object.entries(message.txHashes).forEach(([k, v]) => {
obj.txHashes[k] = base64FromBytes(v);
});
}
return obj;

@@ -361,9 +654,72 @@ },

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseBlockEventsRPC();
message.types = ((_a = object.types) === null || _a === void 0 ? void 0 : _a.map((e) => e)) || [];
message.events = ((_b = object.events) === null || _b === void 0 ? void 0 : _b.map((e) => e)) || [];
message.txHashes = Object.entries((_c = object.txHashes) !== null && _c !== void 0 ? _c : {}).reduce((acc, [key, value]) => {
if (value !== undefined) {
acc[Number(key)] = value;
}
return acc;
}, {});
return message;
},
};
function createBaseBlockEventsRPC_TxHashesEntry() {
return { key: 0, value: new Uint8Array() };
}
exports.BlockEventsRPC_TxHashesEntry = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.key !== 0) {
writer.uint32(8).sint32(message.key);
}
if (message.value.length !== 0) {
writer.uint32(18).bytes(message.value);
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseBlockEventsRPC_TxHashesEntry();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.key = reader.sint32();
break;
case 2:
message.value = reader.bytes();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
key: isSet(object.key) ? Number(object.key) : 0,
value: isSet(object.value) ? bytesFromBase64(object.value) : new Uint8Array(),
};
},
toJSON(message) {
const obj = {};
message.key !== undefined && (obj.key = Math.round(message.key));
message.value !== undefined &&
(obj.value = base64FromBytes(message.value !== undefined ? message.value : new Uint8Array()));
return obj;
},
create(base) {
return exports.BlockEventsRPC_TxHashesEntry.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b;
const message = createBaseBlockEventsRPC_TxHashesEntry();
message.key = (_a = object.key) !== null && _a !== void 0 ? _a : 0;
message.value = (_b = object.value) !== null && _b !== void 0 ? _b : new Uint8Array();
return message;
},
};
function createBaseGetCustomEventsRPCRequest() {

@@ -435,14 +791,17 @@ return { backend: "", height: 0, events: "" };

function createBaseGetCustomEventsRPCResponse() {
return { s: "", errmsg: "", data: undefined };
return { v: "", s: "", e: "", data: undefined };
}
exports.GetCustomEventsRPCResponse = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.v !== "") {
writer.uint32(10).string(message.v);
}
if (message.s !== "") {
writer.uint32(10).string(message.s);
writer.uint32(18).string(message.s);
}
if (message.errmsg !== "") {
writer.uint32(18).string(message.errmsg);
if (message.e !== "") {
writer.uint32(26).string(message.e);
}
if (message.data !== undefined) {
exports.BlockEventsRPC.encode(message.data, writer.uint32(26).fork()).ldelim();
exports.BlockEventsRPC.encode(message.data, writer.uint32(34).fork()).ldelim();
}

@@ -459,8 +818,11 @@ return writer;

case 1:
message.s = reader.string();
message.v = reader.string();
break;
case 2:
message.errmsg = reader.string();
message.s = reader.string();
break;
case 3:
message.e = reader.string();
break;
case 4:
message.data = exports.BlockEventsRPC.decode(reader, reader.uint32());

@@ -477,4 +839,5 @@ break;

return {
v: isSet(object.v) ? String(object.v) : "",
s: isSet(object.s) ? String(object.s) : "",
errmsg: isSet(object.errmsg) ? String(object.errmsg) : "",
e: isSet(object.e) ? String(object.e) : "",
data: isSet(object.data) ? exports.BlockEventsRPC.fromJSON(object.data) : undefined,

@@ -485,4 +848,5 @@ };

const obj = {};
message.v !== undefined && (obj.v = message.v);
message.s !== undefined && (obj.s = message.s);
message.errmsg !== undefined && (obj.errmsg = message.errmsg);
message.e !== undefined && (obj.e = message.e);
message.data !== undefined && (obj.data = message.data ? exports.BlockEventsRPC.toJSON(message.data) : undefined);

@@ -495,6 +859,7 @@ return obj;

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseGetCustomEventsRPCResponse();
message.s = (_a = object.s) !== null && _a !== void 0 ? _a : "";
message.errmsg = (_b = object.errmsg) !== null && _b !== void 0 ? _b : "";
message.v = (_a = object.v) !== null && _a !== void 0 ? _a : "";
message.s = (_b = object.s) !== null && _b !== void 0 ? _b : "";
message.e = (_c = object.e) !== null && _c !== void 0 ? _c : "";
message.data = (object.data !== undefined && object.data !== null)

@@ -510,2 +875,3 @@ ? exports.BlockEventsRPC.fromPartial(object.data)

this.GetLatestHeight = this.GetLatestHeight.bind(this);
this.StreamBlockEvents = this.StreamBlockEvents.bind(this);
this.GetBlockEventsRPC = this.GetBlockEventsRPC.bind(this);

@@ -517,2 +883,5 @@ this.GetCustomEventsRPC = this.GetCustomEventsRPC.bind(this);

}
StreamBlockEvents(request, metadata) {
return this.rpc.invoke(exports.EventProviderAPIStreamBlockEventsDesc, exports.StreamBlockEventsRequest.fromPartial(request), metadata);
}
GetBlockEventsRPC(request, metadata) {

@@ -546,2 +915,21 @@ return this.rpc.unary(exports.EventProviderAPIGetBlockEventsRPCDesc, exports.GetBlockEventsRPCRequest.fromPartial(request), metadata);

};
exports.EventProviderAPIStreamBlockEventsDesc = {
methodName: "StreamBlockEvents",
service: exports.EventProviderAPIDesc,
requestStream: false,
responseStream: true,
requestType: {
serializeBinary() {
return exports.StreamBlockEventsRequest.encode(this).finish();
},
},
responseType: {
deserializeBinary(data) {
const value = exports.StreamBlockEventsResponse.decode(data);
return Object.assign(Object.assign({}, value), { toObject() {
return value;
} });
},
},
};
exports.EventProviderAPIGetBlockEventsRPCDesc = {

@@ -615,2 +1003,39 @@ methodName: "GetBlockEventsRPC",

}
invoke(methodDesc, _request, metadata) {
var _a;
const upStreamCodes = this.options.upStreamRetryCodes || [];
const DEFAULT_TIMEOUT_TIME = 3000;
const request = Object.assign(Object.assign({}, _request), methodDesc.requestType);
const maybeCombinedMetadata = metadata && this.options.metadata
? new browser_headers_1.BrowserHeaders(Object.assign(Object.assign({}, (_a = this.options) === null || _a === void 0 ? void 0 : _a.metadata.headersMap), metadata === null || metadata === void 0 ? void 0 : metadata.headersMap))
: metadata || this.options.metadata;
return new rxjs_1.Observable((observer) => {
const upStream = (() => {
const client = grpc_web_1.grpc.invoke(methodDesc, {
host: this.host,
request,
transport: this.options.streamingTransport || this.options.transport,
metadata: maybeCombinedMetadata,
debug: this.options.debug,
onMessage: (next) => observer.next(next),
onEnd: (code, message, trailers) => {
if (code === 0) {
observer.complete();
}
else if (upStreamCodes.includes(code)) {
setTimeout(upStream, DEFAULT_TIMEOUT_TIME);
}
else {
const err = new Error(message);
err.code = code;
err.metadata = trailers;
observer.error(err);
}
},
});
observer.add(() => client.close());
});
upStream();
}).pipe((0, operators_1.share)());
}
}

@@ -665,2 +1090,5 @@ exports.GrpcWebImpl = GrpcWebImpl;

}
function isObject(value) {
return typeof value === "object" && value !== null;
}
function isSet(value) {

@@ -667,0 +1095,0 @@ return value !== null && value !== undefined;

81

cjs/injective_explorer_rpc.d.ts

@@ -8,3 +8,5 @@ import { grpc } from "@injectivelabs/grpc-web";

address: string;
/** Return transactions before this block number */
before: string;
/** Return transactions after this block number */
after: string;

@@ -528,2 +530,4 @@ limit: number;

skip: string;
/** Label of the contract */
label: string;
}

@@ -680,2 +684,43 @@ export interface GetWasmContractsResponse {

}
export interface GetBankTransfersRequest {
/** Transfer sender address */
senders: string[];
/** Transfer recipient address */
recipients: string[];
/**
* Returns transfers with the community pool address as either sender or
* recipient
*/
isCommunityPoolRelated: boolean;
limit: number;
skip: string;
/**
* The starting timestamp in UNIX milliseconds that the transfers must be equal
* or older than
*/
startTime: string;
/**
* The ending timestamp in UNIX milliseconds that the transfers must be equal
* or younger than
*/
endTime: string;
}
export interface GetBankTransfersResponse {
paging: Paging | undefined;
data: BankTransfer[];
}
/** Bank transfer represents a transfer */
export interface BankTransfer {
sender: string;
recipient: string;
/** Amounts transferred */
amounts: Coin[];
blockNumber: string;
blockTimestamp: string;
}
export interface Coin {
/** Denom of the coin */
denom: string;
amount: string;
}
export interface StreamTxsRequest {

@@ -1228,2 +1273,34 @@ }

};
export declare const GetBankTransfersRequest: {
encode(message: GetBankTransfersRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): GetBankTransfersRequest;
fromJSON(object: any): GetBankTransfersRequest;
toJSON(message: GetBankTransfersRequest): unknown;
create(base?: DeepPartial<GetBankTransfersRequest>): GetBankTransfersRequest;
fromPartial(object: DeepPartial<GetBankTransfersRequest>): GetBankTransfersRequest;
};
export declare const GetBankTransfersResponse: {
encode(message: GetBankTransfersResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): GetBankTransfersResponse;
fromJSON(object: any): GetBankTransfersResponse;
toJSON(message: GetBankTransfersResponse): unknown;
create(base?: DeepPartial<GetBankTransfersResponse>): GetBankTransfersResponse;
fromPartial(object: DeepPartial<GetBankTransfersResponse>): GetBankTransfersResponse;
};
export declare const BankTransfer: {
encode(message: BankTransfer, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): BankTransfer;
fromJSON(object: any): BankTransfer;
toJSON(message: BankTransfer): unknown;
create(base?: DeepPartial<BankTransfer>): BankTransfer;
fromPartial(object: DeepPartial<BankTransfer>): BankTransfer;
};
export declare const Coin: {
encode(message: Coin, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): Coin;
fromJSON(object: any): Coin;
toJSON(message: Coin): unknown;
create(base?: DeepPartial<Coin>): Coin;
fromPartial(object: DeepPartial<Coin>): Coin;
};
export declare const StreamTxsRequest: {

@@ -1311,2 +1388,4 @@ encode(_: StreamTxsRequest, writer?: _m0.Writer): _m0.Writer;

Relayers(request: DeepPartial<RelayersRequest>, metadata?: grpc.Metadata): Promise<RelayersResponse>;
/** GetBankTransfers returns bank transfers. */
GetBankTransfers(request: DeepPartial<GetBankTransfersRequest>, metadata?: grpc.Metadata): Promise<GetBankTransfersResponse>;
/** StreamTxs returns transactions based upon the request params */

@@ -1338,2 +1417,3 @@ StreamTxs(request: DeepPartial<StreamTxsRequest>, metadata?: grpc.Metadata): Observable<StreamTxsResponse>;

Relayers(request: DeepPartial<RelayersRequest>, metadata?: grpc.Metadata): Promise<RelayersResponse>;
GetBankTransfers(request: DeepPartial<GetBankTransfersRequest>, metadata?: grpc.Metadata): Promise<GetBankTransfersResponse>;
StreamTxs(request: DeepPartial<StreamTxsRequest>, metadata?: grpc.Metadata): Observable<StreamTxsResponse>;

@@ -1363,2 +1443,3 @@ StreamBlocks(request: DeepPartial<StreamBlocksRequest>, metadata?: grpc.Metadata): Observable<StreamBlocksResponse>;

export declare const InjectiveExplorerRPCRelayersDesc: UnaryMethodDefinitionish;
export declare const InjectiveExplorerRPCGetBankTransfersDesc: UnaryMethodDefinitionish;
export declare const InjectiveExplorerRPCStreamTxsDesc: UnaryMethodDefinitionish;

@@ -1365,0 +1446,0 @@ export declare const InjectiveExplorerRPCStreamBlocksDesc: UnaryMethodDefinitionish;

51

cjs/injective_meta_rpc.d.ts

@@ -55,2 +55,25 @@ import { grpc } from "@injectivelabs/grpc-web";

}
export interface TokenMetadataRequest {
denoms: string[];
}
export interface TokenMetadataResponse {
/** tokens and their metadata list */
tokens: TokenMetadataElement[];
}
export interface TokenMetadataElement {
/** Token's Ethereum address, not all token have this information */
ethereumAddress: string;
/** Token's CoinGecko id for price references */
coingeckoId: string;
/** Token's denom on injective chain */
denom: string;
/** Token name */
name: string;
/** Token symbol */
symbol: string;
/** Number of decimal places used to represent the token's smallest unit */
decimals: number;
/** Token logo URL */
logo: string;
}
export declare const PingRequest: {

@@ -136,2 +159,26 @@ encode(_: PingRequest, writer?: _m0.Writer): _m0.Writer;

};
export declare const TokenMetadataRequest: {
encode(message: TokenMetadataRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): TokenMetadataRequest;
fromJSON(object: any): TokenMetadataRequest;
toJSON(message: TokenMetadataRequest): unknown;
create(base?: DeepPartial<TokenMetadataRequest>): TokenMetadataRequest;
fromPartial(object: DeepPartial<TokenMetadataRequest>): TokenMetadataRequest;
};
export declare const TokenMetadataResponse: {
encode(message: TokenMetadataResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): TokenMetadataResponse;
fromJSON(object: any): TokenMetadataResponse;
toJSON(message: TokenMetadataResponse): unknown;
create(base?: DeepPartial<TokenMetadataResponse>): TokenMetadataResponse;
fromPartial(object: DeepPartial<TokenMetadataResponse>): TokenMetadataResponse;
};
export declare const TokenMetadataElement: {
encode(message: TokenMetadataElement, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): TokenMetadataElement;
fromJSON(object: any): TokenMetadataElement;
toJSON(message: TokenMetadataElement): unknown;
create(base?: DeepPartial<TokenMetadataElement>): TokenMetadataElement;
fromPartial(object: DeepPartial<TokenMetadataElement>): TokenMetadataElement;
};
/** InjectiveMetaRPC is a special API subset to get info about server. */

@@ -150,2 +197,4 @@ export interface InjectiveMetaRPC {

StreamKeepalive(request: DeepPartial<StreamKeepaliveRequest>, metadata?: grpc.Metadata): Observable<StreamKeepaliveResponse>;
/** Get tokens metadata. Can be filtered by denom */
TokenMetadata(request: DeepPartial<TokenMetadataRequest>, metadata?: grpc.Metadata): Promise<TokenMetadataResponse>;
}

@@ -159,2 +208,3 @@ export declare class InjectiveMetaRPCClientImpl implements InjectiveMetaRPC {

StreamKeepalive(request: DeepPartial<StreamKeepaliveRequest>, metadata?: grpc.Metadata): Observable<StreamKeepaliveResponse>;
TokenMetadata(request: DeepPartial<TokenMetadataRequest>, metadata?: grpc.Metadata): Promise<TokenMetadataResponse>;
}

@@ -168,2 +218,3 @@ export declare const InjectiveMetaRPCDesc: {

export declare const InjectiveMetaRPCStreamKeepaliveDesc: UnaryMethodDefinitionish;
export declare const InjectiveMetaRPCTokenMetadataDesc: UnaryMethodDefinitionish;
interface UnaryMethodDefinitionishR extends grpc.UnaryMethodDefinition<any, any> {

@@ -170,0 +221,0 @@ requestStream: any;

228

cjs/injective_meta_rpc.js

@@ -6,3 +6,3 @@ "use strict";

Object.defineProperty(exports, "__esModule", { value: true });
exports.GrpcWebError = exports.GrpcWebImpl = exports.InjectiveMetaRPCStreamKeepaliveDesc = exports.InjectiveMetaRPCInfoDesc = exports.InjectiveMetaRPCVersionDesc = exports.InjectiveMetaRPCPingDesc = exports.InjectiveMetaRPCDesc = exports.InjectiveMetaRPCClientImpl = exports.StreamKeepaliveResponse = exports.StreamKeepaliveRequest = exports.InfoResponse_BuildEntry = exports.InfoResponse = exports.InfoRequest = exports.VersionResponse_BuildEntry = exports.VersionResponse = exports.VersionRequest = exports.PingResponse = exports.PingRequest = exports.protobufPackage = void 0;
exports.GrpcWebError = exports.GrpcWebImpl = exports.InjectiveMetaRPCTokenMetadataDesc = exports.InjectiveMetaRPCStreamKeepaliveDesc = exports.InjectiveMetaRPCInfoDesc = exports.InjectiveMetaRPCVersionDesc = exports.InjectiveMetaRPCPingDesc = exports.InjectiveMetaRPCDesc = exports.InjectiveMetaRPCClientImpl = exports.TokenMetadataElement = exports.TokenMetadataResponse = exports.TokenMetadataRequest = exports.StreamKeepaliveResponse = exports.StreamKeepaliveRequest = exports.InfoResponse_BuildEntry = exports.InfoResponse = exports.InfoRequest = exports.VersionResponse_BuildEntry = exports.VersionResponse = exports.VersionRequest = exports.PingResponse = exports.PingRequest = exports.protobufPackage = void 0;
/* eslint-disable */

@@ -551,2 +551,205 @@ const grpc_web_1 = require("@injectivelabs/grpc-web");

};
function createBaseTokenMetadataRequest() {
return { denoms: [] };
}
exports.TokenMetadataRequest = {
encode(message, writer = minimal_1.default.Writer.create()) {
for (const v of message.denoms) {
writer.uint32(10).string(v);
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseTokenMetadataRequest();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.denoms.push(reader.string());
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return { denoms: Array.isArray(object === null || object === void 0 ? void 0 : object.denoms) ? object.denoms.map((e) => String(e)) : [] };
},
toJSON(message) {
const obj = {};
if (message.denoms) {
obj.denoms = message.denoms.map((e) => e);
}
else {
obj.denoms = [];
}
return obj;
},
create(base) {
return exports.TokenMetadataRequest.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a;
const message = createBaseTokenMetadataRequest();
message.denoms = ((_a = object.denoms) === null || _a === void 0 ? void 0 : _a.map((e) => e)) || [];
return message;
},
};
function createBaseTokenMetadataResponse() {
return { tokens: [] };
}
exports.TokenMetadataResponse = {
encode(message, writer = minimal_1.default.Writer.create()) {
for (const v of message.tokens) {
exports.TokenMetadataElement.encode(v, writer.uint32(10).fork()).ldelim();
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseTokenMetadataResponse();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.tokens.push(exports.TokenMetadataElement.decode(reader, reader.uint32()));
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
tokens: Array.isArray(object === null || object === void 0 ? void 0 : object.tokens) ? object.tokens.map((e) => exports.TokenMetadataElement.fromJSON(e)) : [],
};
},
toJSON(message) {
const obj = {};
if (message.tokens) {
obj.tokens = message.tokens.map((e) => e ? exports.TokenMetadataElement.toJSON(e) : undefined);
}
else {
obj.tokens = [];
}
return obj;
},
create(base) {
return exports.TokenMetadataResponse.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a;
const message = createBaseTokenMetadataResponse();
message.tokens = ((_a = object.tokens) === null || _a === void 0 ? void 0 : _a.map((e) => exports.TokenMetadataElement.fromPartial(e))) || [];
return message;
},
};
function createBaseTokenMetadataElement() {
return { ethereumAddress: "", coingeckoId: "", denom: "", name: "", symbol: "", decimals: 0, logo: "" };
}
exports.TokenMetadataElement = {
encode(message, writer = minimal_1.default.Writer.create()) {
if (message.ethereumAddress !== "") {
writer.uint32(10).string(message.ethereumAddress);
}
if (message.coingeckoId !== "") {
writer.uint32(18).string(message.coingeckoId);
}
if (message.denom !== "") {
writer.uint32(26).string(message.denom);
}
if (message.name !== "") {
writer.uint32(34).string(message.name);
}
if (message.symbol !== "") {
writer.uint32(42).string(message.symbol);
}
if (message.decimals !== 0) {
writer.uint32(48).sint32(message.decimals);
}
if (message.logo !== "") {
writer.uint32(58).string(message.logo);
}
return writer;
},
decode(input, length) {
const reader = input instanceof minimal_1.default.Reader ? input : new minimal_1.default.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseTokenMetadataElement();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.ethereumAddress = reader.string();
break;
case 2:
message.coingeckoId = reader.string();
break;
case 3:
message.denom = reader.string();
break;
case 4:
message.name = reader.string();
break;
case 5:
message.symbol = reader.string();
break;
case 6:
message.decimals = reader.sint32();
break;
case 7:
message.logo = reader.string();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
ethereumAddress: isSet(object.ethereumAddress) ? String(object.ethereumAddress) : "",
coingeckoId: isSet(object.coingeckoId) ? String(object.coingeckoId) : "",
denom: isSet(object.denom) ? String(object.denom) : "",
name: isSet(object.name) ? String(object.name) : "",
symbol: isSet(object.symbol) ? String(object.symbol) : "",
decimals: isSet(object.decimals) ? Number(object.decimals) : 0,
logo: isSet(object.logo) ? String(object.logo) : "",
};
},
toJSON(message) {
const obj = {};
message.ethereumAddress !== undefined && (obj.ethereumAddress = message.ethereumAddress);
message.coingeckoId !== undefined && (obj.coingeckoId = message.coingeckoId);
message.denom !== undefined && (obj.denom = message.denom);
message.name !== undefined && (obj.name = message.name);
message.symbol !== undefined && (obj.symbol = message.symbol);
message.decimals !== undefined && (obj.decimals = Math.round(message.decimals));
message.logo !== undefined && (obj.logo = message.logo);
return obj;
},
create(base) {
return exports.TokenMetadataElement.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b, _c, _d, _e, _f, _g;
const message = createBaseTokenMetadataElement();
message.ethereumAddress = (_a = object.ethereumAddress) !== null && _a !== void 0 ? _a : "";
message.coingeckoId = (_b = object.coingeckoId) !== null && _b !== void 0 ? _b : "";
message.denom = (_c = object.denom) !== null && _c !== void 0 ? _c : "";
message.name = (_d = object.name) !== null && _d !== void 0 ? _d : "";
message.symbol = (_e = object.symbol) !== null && _e !== void 0 ? _e : "";
message.decimals = (_f = object.decimals) !== null && _f !== void 0 ? _f : 0;
message.logo = (_g = object.logo) !== null && _g !== void 0 ? _g : "";
return message;
},
};
class InjectiveMetaRPCClientImpl {

@@ -559,2 +762,3 @@ constructor(rpc) {

this.StreamKeepalive = this.StreamKeepalive.bind(this);
this.TokenMetadata = this.TokenMetadata.bind(this);
}

@@ -573,2 +777,5 @@ Ping(request, metadata) {

}
TokenMetadata(request, metadata) {
return this.rpc.unary(exports.InjectiveMetaRPCTokenMetadataDesc, exports.TokenMetadataRequest.fromPartial(request), metadata);
}
}

@@ -653,2 +860,21 @@ exports.InjectiveMetaRPCClientImpl = InjectiveMetaRPCClientImpl;

};
exports.InjectiveMetaRPCTokenMetadataDesc = {
methodName: "TokenMetadata",
service: exports.InjectiveMetaRPCDesc,
requestStream: false,
responseStream: false,
requestType: {
serializeBinary() {
return exports.TokenMetadataRequest.encode(this).finish();
},
},
responseType: {
deserializeBinary(data) {
const value = exports.TokenMetadataResponse.decode(data);
return Object.assign(Object.assign({}, value), { toObject() {
return value;
} });
},
},
};
class GrpcWebImpl {

@@ -655,0 +881,0 @@ constructor(host, options) {

96

cjs/injective_spot_exchange_rpc.d.ts

@@ -196,2 +196,4 @@ import { grpc } from "@injectivelabs/grpc-web";

subaccountTotalOrders: boolean;
/** TradeId of the order we want to fetch */
tradeId: string;
}

@@ -230,2 +232,4 @@ export interface OrdersResponse {

updatedAt: string;
/** Transaction Hash where order is created. Not all orders have this field */
txHash: string;
}

@@ -270,2 +274,4 @@ /** Paging defines the structure for required params for handling pagination */

subaccountTotalOrders: boolean;
/** TradeId of the order we want to fetch */
tradeId: string;
}

@@ -437,2 +443,6 @@ export interface StreamOrdersResponse {

marketIds: string[];
/** TradeId of the order we want to fetch */
tradeId: string;
/** Return only orders for active markets */
activeMarketsOnly: boolean;
}

@@ -473,2 +483,4 @@ export interface OrdersHistoryResponse {

direction: string;
/** Transaction Hash where order is created. Not all orders have this field */
txHash: string;
}

@@ -496,2 +508,50 @@ export interface StreamOrdersHistoryRequest {

}
export interface AtomicSwapHistoryRequest {
/** sender of the atomic swap */
address: string;
/** atomic swap contract address to filter */
contractAddress: string;
/** skip some swaps */
skip: number;
/** limit number of swaps returned by this API */
limit: number;
/** lowerbound of atomic swap index */
fromNumber: number;
/** upperbound of atomic swap index */
toNumber: number;
}
export interface AtomicSwapHistoryResponse {
/** Paging indicates total number of records with this filter */
paging: Paging | undefined;
/** swap data */
data: AtomicSwap[];
}
export interface AtomicSwap {
/** executor of the swap */
sender: string;
/** swap route */
route: string;
/** source coin */
sourceCoin: Coin | undefined;
/** destination received coin */
destCoin: Coin | undefined;
/** fees of each steps in route */
fees: Coin[];
/** contract address that executes to make this swap */
contractAddress: string;
/** Numerical index by sender to use in pagination from_number and to_number */
indexBySender: number;
/**
* Numerical index by sender + acontract to use in pagination from_number and
* to_number, that support contract filter
*/
indexBySenderContract: number;
/** transaction hash of the swap */
txHash: string;
}
export interface Coin {
/** Denom of the coin */
denom: string;
amount: string;
}
export declare const MarketsRequest: {

@@ -825,2 +885,34 @@ encode(message: MarketsRequest, writer?: _m0.Writer): _m0.Writer;

};
export declare const AtomicSwapHistoryRequest: {
encode(message: AtomicSwapHistoryRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): AtomicSwapHistoryRequest;
fromJSON(object: any): AtomicSwapHistoryRequest;
toJSON(message: AtomicSwapHistoryRequest): unknown;
create(base?: DeepPartial<AtomicSwapHistoryRequest>): AtomicSwapHistoryRequest;
fromPartial(object: DeepPartial<AtomicSwapHistoryRequest>): AtomicSwapHistoryRequest;
};
export declare const AtomicSwapHistoryResponse: {
encode(message: AtomicSwapHistoryResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): AtomicSwapHistoryResponse;
fromJSON(object: any): AtomicSwapHistoryResponse;
toJSON(message: AtomicSwapHistoryResponse): unknown;
create(base?: DeepPartial<AtomicSwapHistoryResponse>): AtomicSwapHistoryResponse;
fromPartial(object: DeepPartial<AtomicSwapHistoryResponse>): AtomicSwapHistoryResponse;
};
export declare const AtomicSwap: {
encode(message: AtomicSwap, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): AtomicSwap;
fromJSON(object: any): AtomicSwap;
toJSON(message: AtomicSwap): unknown;
create(base?: DeepPartial<AtomicSwap>): AtomicSwap;
fromPartial(object: DeepPartial<AtomicSwap>): AtomicSwap;
};
export declare const Coin: {
encode(message: Coin, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): Coin;
fromJSON(object: any): Coin;
toJSON(message: Coin): unknown;
create(base?: DeepPartial<Coin>): Coin;
fromPartial(object: DeepPartial<Coin>): Coin;
};
/** InjectiveSpotExchangeRPC defines gRPC API of Spot Exchange provider. */

@@ -858,2 +950,4 @@ export interface InjectiveSpotExchangeRPC {

StreamOrdersHistory(request: DeepPartial<StreamOrdersHistoryRequest>, metadata?: grpc.Metadata): Observable<StreamOrdersHistoryResponse>;
/** Get historical atomic swaps */
AtomicSwapHistory(request: DeepPartial<AtomicSwapHistoryRequest>, metadata?: grpc.Metadata): Promise<AtomicSwapHistoryResponse>;
}

@@ -878,2 +972,3 @@ export declare class InjectiveSpotExchangeRPCClientImpl implements InjectiveSpotExchangeRPC {

StreamOrdersHistory(request: DeepPartial<StreamOrdersHistoryRequest>, metadata?: grpc.Metadata): Observable<StreamOrdersHistoryResponse>;
AtomicSwapHistory(request: DeepPartial<AtomicSwapHistoryRequest>, metadata?: grpc.Metadata): Promise<AtomicSwapHistoryResponse>;
}

@@ -898,2 +993,3 @@ export declare const InjectiveSpotExchangeRPCDesc: {

export declare const InjectiveSpotExchangeRPCStreamOrdersHistoryDesc: UnaryMethodDefinitionish;
export declare const InjectiveSpotExchangeRPCAtomicSwapHistoryDesc: UnaryMethodDefinitionish;
interface UnaryMethodDefinitionishR extends grpc.UnaryMethodDefinition<any, any> {

@@ -900,0 +996,0 @@ requestStream: any;

92

esm/event_provider_api.d.ts
import { grpc } from "@injectivelabs/grpc-web";
import _m0 from "protobufjs/minimal";
import { Observable } from "rxjs";
export declare const protobufPackage = "event_provider_api";

@@ -7,6 +8,8 @@ export interface GetLatestHeightRequest {

export interface GetLatestHeightResponse {
/** Response version. */
v: string;
/** Status of the response. */
s: string;
/** Error message. */
errmsg: string;
e: string;
data: LatestBlockHeight | undefined;

@@ -18,2 +21,26 @@ }

}
export interface StreamBlockEventsRequest {
/** Select backend processor */
backend: string;
height: number;
}
export interface StreamBlockEventsResponse {
blocks: Block[];
}
export interface Block {
height: string;
version: string;
/** Processed block events in the block */
events: BlockEvent[];
/** Indicates whether the block is the latest one available in the event provider */
inSync: boolean;
}
export interface BlockEvent {
/** Event type */
typeUrl: string;
/** Event data */
value: Uint8Array;
/** TX hash */
txHash: Uint8Array;
}
export interface GetBlockEventsRPCRequest {

@@ -25,6 +52,8 @@ /** Select backend processor */

export interface GetBlockEventsRPCResponse {
/** Response version. */
v: string;
/** Status of the response. */
s: string;
/** Error message. */
errmsg: string;
e: string;
data: BlockEventsRPC | undefined;

@@ -38,3 +67,11 @@ }

events: Uint8Array[];
/** Map of event index - tx hash */
txHashes: {
[key: number]: Uint8Array;
};
}
export interface BlockEventsRPC_TxHashesEntry {
key: number;
value: Uint8Array;
}
export interface GetCustomEventsRPCRequest {

@@ -48,6 +85,8 @@ /** Select backend processor */

export interface GetCustomEventsRPCResponse {
/** Response version. */
v: string;
/** Status of the response. */
s: string;
/** Error message. */
errmsg: string;
e: string;
data: BlockEventsRPC | undefined;

@@ -79,2 +118,34 @@ }

};
export declare const StreamBlockEventsRequest: {
encode(message: StreamBlockEventsRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): StreamBlockEventsRequest;
fromJSON(object: any): StreamBlockEventsRequest;
toJSON(message: StreamBlockEventsRequest): unknown;
create(base?: DeepPartial<StreamBlockEventsRequest>): StreamBlockEventsRequest;
fromPartial(object: DeepPartial<StreamBlockEventsRequest>): StreamBlockEventsRequest;
};
export declare const StreamBlockEventsResponse: {
encode(message: StreamBlockEventsResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): StreamBlockEventsResponse;
fromJSON(object: any): StreamBlockEventsResponse;
toJSON(message: StreamBlockEventsResponse): unknown;
create(base?: DeepPartial<StreamBlockEventsResponse>): StreamBlockEventsResponse;
fromPartial(object: DeepPartial<StreamBlockEventsResponse>): StreamBlockEventsResponse;
};
export declare const Block: {
encode(message: Block, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): Block;
fromJSON(object: any): Block;
toJSON(message: Block): unknown;
create(base?: DeepPartial<Block>): Block;
fromPartial(object: DeepPartial<Block>): Block;
};
export declare const BlockEvent: {
encode(message: BlockEvent, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): BlockEvent;
fromJSON(object: any): BlockEvent;
toJSON(message: BlockEvent): unknown;
create(base?: DeepPartial<BlockEvent>): BlockEvent;
fromPartial(object: DeepPartial<BlockEvent>): BlockEvent;
};
export declare const GetBlockEventsRPCRequest: {

@@ -104,2 +175,10 @@ encode(message: GetBlockEventsRPCRequest, writer?: _m0.Writer): _m0.Writer;

};
export declare const BlockEventsRPC_TxHashesEntry: {
encode(message: BlockEventsRPC_TxHashesEntry, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): BlockEventsRPC_TxHashesEntry;
fromJSON(object: any): BlockEventsRPC_TxHashesEntry;
toJSON(message: BlockEventsRPC_TxHashesEntry): unknown;
create(base?: DeepPartial<BlockEventsRPC_TxHashesEntry>): BlockEventsRPC_TxHashesEntry;
fromPartial(object: DeepPartial<BlockEventsRPC_TxHashesEntry>): BlockEventsRPC_TxHashesEntry;
};
export declare const GetCustomEventsRPCRequest: {

@@ -125,2 +204,4 @@ encode(message: GetCustomEventsRPCRequest, writer?: _m0.Writer): _m0.Writer;

GetLatestHeight(request: DeepPartial<GetLatestHeightRequest>, metadata?: grpc.Metadata): Promise<GetLatestHeightResponse>;
/** Stream processed block events for selected backend */
StreamBlockEvents(request: DeepPartial<StreamBlockEventsRequest>, metadata?: grpc.Metadata): Observable<StreamBlockEventsResponse>;
/** Get processed block events for selected backend */

@@ -135,2 +216,3 @@ GetBlockEventsRPC(request: DeepPartial<GetBlockEventsRPCRequest>, metadata?: grpc.Metadata): Promise<GetBlockEventsRPCResponse>;

GetLatestHeight(request: DeepPartial<GetLatestHeightRequest>, metadata?: grpc.Metadata): Promise<GetLatestHeightResponse>;
StreamBlockEvents(request: DeepPartial<StreamBlockEventsRequest>, metadata?: grpc.Metadata): Observable<StreamBlockEventsResponse>;
GetBlockEventsRPC(request: DeepPartial<GetBlockEventsRPCRequest>, metadata?: grpc.Metadata): Promise<GetBlockEventsRPCResponse>;

@@ -143,2 +225,3 @@ GetCustomEventsRPC(request: DeepPartial<GetCustomEventsRPCRequest>, metadata?: grpc.Metadata): Promise<GetCustomEventsRPCResponse>;

export declare const EventProviderAPIGetLatestHeightDesc: UnaryMethodDefinitionish;
export declare const EventProviderAPIStreamBlockEventsDesc: UnaryMethodDefinitionish;
export declare const EventProviderAPIGetBlockEventsRPCDesc: UnaryMethodDefinitionish;

@@ -153,2 +236,3 @@ export declare const EventProviderAPIGetCustomEventsRPCDesc: UnaryMethodDefinitionish;

unary<T extends UnaryMethodDefinitionish>(methodDesc: T, request: any, metadata: grpc.Metadata | undefined): Promise<any>;
invoke<T extends UnaryMethodDefinitionish>(methodDesc: T, request: any, metadata: grpc.Metadata | undefined): Observable<any>;
}

@@ -160,2 +244,3 @@ export declare class GrpcWebImpl {

transport?: grpc.TransportFactory;
streamingTransport?: grpc.TransportFactory;
debug?: boolean;

@@ -166,2 +251,3 @@ metadata?: grpc.Metadata;

unary<T extends UnaryMethodDefinitionish>(methodDesc: T, _request: any, metadata: grpc.Metadata | undefined): Promise<any>;
invoke<T extends UnaryMethodDefinitionish>(methodDesc: T, _request: any, metadata: grpc.Metadata | undefined): Observable<any>;
}

@@ -168,0 +254,0 @@ declare var tsProtoGlobalThis: any;

504

esm/event_provider_api.js

@@ -6,2 +6,4 @@ /* eslint-disable */

import _m0 from "protobufjs/minimal";
import { Observable } from "rxjs";
import { share } from "rxjs/operators";
export const protobufPackage = "event_provider_api";

@@ -45,14 +47,17 @@ function createBaseGetLatestHeightRequest() {

function createBaseGetLatestHeightResponse() {
return { s: "", errmsg: "", data: undefined };
return { v: "", s: "", e: "", data: undefined };
}
export const GetLatestHeightResponse = {
encode(message, writer = _m0.Writer.create()) {
if (message.v !== "") {
writer.uint32(10).string(message.v);
}
if (message.s !== "") {
writer.uint32(10).string(message.s);
writer.uint32(18).string(message.s);
}
if (message.errmsg !== "") {
writer.uint32(18).string(message.errmsg);
if (message.e !== "") {
writer.uint32(26).string(message.e);
}
if (message.data !== undefined) {
LatestBlockHeight.encode(message.data, writer.uint32(26).fork()).ldelim();
LatestBlockHeight.encode(message.data, writer.uint32(34).fork()).ldelim();
}

@@ -69,8 +74,11 @@ return writer;

case 1:
message.s = reader.string();
message.v = reader.string();
break;
case 2:
message.errmsg = reader.string();
message.s = reader.string();
break;
case 3:
message.e = reader.string();
break;
case 4:
message.data = LatestBlockHeight.decode(reader, reader.uint32());

@@ -87,4 +95,5 @@ break;

return {
v: isSet(object.v) ? String(object.v) : "",
s: isSet(object.s) ? String(object.s) : "",
errmsg: isSet(object.errmsg) ? String(object.errmsg) : "",
e: isSet(object.e) ? String(object.e) : "",
data: isSet(object.data) ? LatestBlockHeight.fromJSON(object.data) : undefined,

@@ -95,4 +104,5 @@ };

const obj = {};
message.v !== undefined && (obj.v = message.v);
message.s !== undefined && (obj.s = message.s);
message.errmsg !== undefined && (obj.errmsg = message.errmsg);
message.e !== undefined && (obj.e = message.e);
message.data !== undefined && (obj.data = message.data ? LatestBlockHeight.toJSON(message.data) : undefined);

@@ -105,6 +115,7 @@ return obj;

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseGetLatestHeightResponse();
message.s = (_a = object.s) !== null && _a !== void 0 ? _a : "";
message.errmsg = (_b = object.errmsg) !== null && _b !== void 0 ? _b : "";
message.v = (_a = object.v) !== null && _a !== void 0 ? _a : "";
message.s = (_b = object.s) !== null && _b !== void 0 ? _b : "";
message.e = (_c = object.e) !== null && _c !== void 0 ? _c : "";
message.data = (object.data !== undefined && object.data !== null)

@@ -161,2 +172,254 @@ ? LatestBlockHeight.fromPartial(object.data)

};
function createBaseStreamBlockEventsRequest() {
return { backend: "", height: 0 };
}
export const StreamBlockEventsRequest = {
encode(message, writer = _m0.Writer.create()) {
if (message.backend !== "") {
writer.uint32(10).string(message.backend);
}
if (message.height !== 0) {
writer.uint32(16).sint32(message.height);
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamBlockEventsRequest();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.backend = reader.string();
break;
case 2:
message.height = reader.sint32();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
backend: isSet(object.backend) ? String(object.backend) : "",
height: isSet(object.height) ? Number(object.height) : 0,
};
},
toJSON(message) {
const obj = {};
message.backend !== undefined && (obj.backend = message.backend);
message.height !== undefined && (obj.height = Math.round(message.height));
return obj;
},
create(base) {
return StreamBlockEventsRequest.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b;
const message = createBaseStreamBlockEventsRequest();
message.backend = (_a = object.backend) !== null && _a !== void 0 ? _a : "";
message.height = (_b = object.height) !== null && _b !== void 0 ? _b : 0;
return message;
},
};
function createBaseStreamBlockEventsResponse() {
return { blocks: [] };
}
export const StreamBlockEventsResponse = {
encode(message, writer = _m0.Writer.create()) {
for (const v of message.blocks) {
Block.encode(v, writer.uint32(10).fork()).ldelim();
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamBlockEventsResponse();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.blocks.push(Block.decode(reader, reader.uint32()));
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return { blocks: Array.isArray(object === null || object === void 0 ? void 0 : object.blocks) ? object.blocks.map((e) => Block.fromJSON(e)) : [] };
},
toJSON(message) {
const obj = {};
if (message.blocks) {
obj.blocks = message.blocks.map((e) => e ? Block.toJSON(e) : undefined);
}
else {
obj.blocks = [];
}
return obj;
},
create(base) {
return StreamBlockEventsResponse.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a;
const message = createBaseStreamBlockEventsResponse();
message.blocks = ((_a = object.blocks) === null || _a === void 0 ? void 0 : _a.map((e) => Block.fromPartial(e))) || [];
return message;
},
};
function createBaseBlock() {
return { height: "0", version: "", events: [], inSync: false };
}
export const Block = {
encode(message, writer = _m0.Writer.create()) {
if (message.height !== "0") {
writer.uint32(8).sint64(message.height);
}
if (message.version !== "") {
writer.uint32(18).string(message.version);
}
for (const v of message.events) {
BlockEvent.encode(v, writer.uint32(26).fork()).ldelim();
}
if (message.inSync === true) {
writer.uint32(32).bool(message.inSync);
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseBlock();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.height = longToString(reader.sint64());
break;
case 2:
message.version = reader.string();
break;
case 3:
message.events.push(BlockEvent.decode(reader, reader.uint32()));
break;
case 4:
message.inSync = reader.bool();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
height: isSet(object.height) ? String(object.height) : "0",
version: isSet(object.version) ? String(object.version) : "",
events: Array.isArray(object === null || object === void 0 ? void 0 : object.events) ? object.events.map((e) => BlockEvent.fromJSON(e)) : [],
inSync: isSet(object.inSync) ? Boolean(object.inSync) : false,
};
},
toJSON(message) {
const obj = {};
message.height !== undefined && (obj.height = message.height);
message.version !== undefined && (obj.version = message.version);
if (message.events) {
obj.events = message.events.map((e) => e ? BlockEvent.toJSON(e) : undefined);
}
else {
obj.events = [];
}
message.inSync !== undefined && (obj.inSync = message.inSync);
return obj;
},
create(base) {
return Block.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b, _c, _d;
const message = createBaseBlock();
message.height = (_a = object.height) !== null && _a !== void 0 ? _a : "0";
message.version = (_b = object.version) !== null && _b !== void 0 ? _b : "";
message.events = ((_c = object.events) === null || _c === void 0 ? void 0 : _c.map((e) => BlockEvent.fromPartial(e))) || [];
message.inSync = (_d = object.inSync) !== null && _d !== void 0 ? _d : false;
return message;
},
};
function createBaseBlockEvent() {
return { typeUrl: "", value: new Uint8Array(), txHash: new Uint8Array() };
}
export const BlockEvent = {
encode(message, writer = _m0.Writer.create()) {
if (message.typeUrl !== "") {
writer.uint32(10).string(message.typeUrl);
}
if (message.value.length !== 0) {
writer.uint32(18).bytes(message.value);
}
if (message.txHash.length !== 0) {
writer.uint32(26).bytes(message.txHash);
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseBlockEvent();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.typeUrl = reader.string();
break;
case 2:
message.value = reader.bytes();
break;
case 3:
message.txHash = reader.bytes();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
typeUrl: isSet(object.typeUrl) ? String(object.typeUrl) : "",
value: isSet(object.value) ? bytesFromBase64(object.value) : new Uint8Array(),
txHash: isSet(object.txHash) ? bytesFromBase64(object.txHash) : new Uint8Array(),
};
},
toJSON(message) {
const obj = {};
message.typeUrl !== undefined && (obj.typeUrl = message.typeUrl);
message.value !== undefined &&
(obj.value = base64FromBytes(message.value !== undefined ? message.value : new Uint8Array()));
message.txHash !== undefined &&
(obj.txHash = base64FromBytes(message.txHash !== undefined ? message.txHash : new Uint8Array()));
return obj;
},
create(base) {
return BlockEvent.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b, _c;
const message = createBaseBlockEvent();
message.typeUrl = (_a = object.typeUrl) !== null && _a !== void 0 ? _a : "";
message.value = (_b = object.value) !== null && _b !== void 0 ? _b : new Uint8Array();
message.txHash = (_c = object.txHash) !== null && _c !== void 0 ? _c : new Uint8Array();
return message;
},
};
function createBaseGetBlockEventsRPCRequest() {

@@ -219,14 +482,17 @@ return { backend: "", height: 0 };

function createBaseGetBlockEventsRPCResponse() {
return { s: "", errmsg: "", data: undefined };
return { v: "", s: "", e: "", data: undefined };
}
export const GetBlockEventsRPCResponse = {
encode(message, writer = _m0.Writer.create()) {
if (message.v !== "") {
writer.uint32(10).string(message.v);
}
if (message.s !== "") {
writer.uint32(10).string(message.s);
writer.uint32(18).string(message.s);
}
if (message.errmsg !== "") {
writer.uint32(18).string(message.errmsg);
if (message.e !== "") {
writer.uint32(26).string(message.e);
}
if (message.data !== undefined) {
BlockEventsRPC.encode(message.data, writer.uint32(26).fork()).ldelim();
BlockEventsRPC.encode(message.data, writer.uint32(34).fork()).ldelim();
}

@@ -243,8 +509,11 @@ return writer;

case 1:
message.s = reader.string();
message.v = reader.string();
break;
case 2:
message.errmsg = reader.string();
message.s = reader.string();
break;
case 3:
message.e = reader.string();
break;
case 4:
message.data = BlockEventsRPC.decode(reader, reader.uint32());

@@ -261,4 +530,5 @@ break;

return {
v: isSet(object.v) ? String(object.v) : "",
s: isSet(object.s) ? String(object.s) : "",
errmsg: isSet(object.errmsg) ? String(object.errmsg) : "",
e: isSet(object.e) ? String(object.e) : "",
data: isSet(object.data) ? BlockEventsRPC.fromJSON(object.data) : undefined,

@@ -269,4 +539,5 @@ };

const obj = {};
message.v !== undefined && (obj.v = message.v);
message.s !== undefined && (obj.s = message.s);
message.errmsg !== undefined && (obj.errmsg = message.errmsg);
message.e !== undefined && (obj.e = message.e);
message.data !== undefined && (obj.data = message.data ? BlockEventsRPC.toJSON(message.data) : undefined);

@@ -279,6 +550,7 @@ return obj;

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseGetBlockEventsRPCResponse();
message.s = (_a = object.s) !== null && _a !== void 0 ? _a : "";
message.errmsg = (_b = object.errmsg) !== null && _b !== void 0 ? _b : "";
message.v = (_a = object.v) !== null && _a !== void 0 ? _a : "";
message.s = (_b = object.s) !== null && _b !== void 0 ? _b : "";
message.e = (_c = object.e) !== null && _c !== void 0 ? _c : "";
message.data = (object.data !== undefined && object.data !== null)

@@ -291,3 +563,3 @@ ? BlockEventsRPC.fromPartial(object.data)

function createBaseBlockEventsRPC() {
return { types: [], events: [] };
return { types: [], events: [], txHashes: {} };
}

@@ -302,2 +574,5 @@ export const BlockEventsRPC = {

}
Object.entries(message.txHashes).forEach(([key, value]) => {
BlockEventsRPC_TxHashesEntry.encode({ key: key, value }, writer.uint32(26).fork()).ldelim();
});
return writer;

@@ -318,2 +593,8 @@ },

break;
case 3:
const entry3 = BlockEventsRPC_TxHashesEntry.decode(reader, reader.uint32());
if (entry3.value !== undefined) {
message.txHashes[entry3.key] = entry3.value;
}
break;
default:

@@ -330,2 +611,8 @@ reader.skipType(tag & 7);

events: Array.isArray(object === null || object === void 0 ? void 0 : object.events) ? object.events.map((e) => bytesFromBase64(e)) : [],
txHashes: isObject(object.txHashes)
? Object.entries(object.txHashes).reduce((acc, [key, value]) => {
acc[Number(key)] = bytesFromBase64(value);
return acc;
}, {})
: {},
};

@@ -347,2 +634,8 @@ },

}
obj.txHashes = {};
if (message.txHashes) {
Object.entries(message.txHashes).forEach(([k, v]) => {
obj.txHashes[k] = base64FromBytes(v);
});
}
return obj;

@@ -354,9 +647,72 @@ },

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseBlockEventsRPC();
message.types = ((_a = object.types) === null || _a === void 0 ? void 0 : _a.map((e) => e)) || [];
message.events = ((_b = object.events) === null || _b === void 0 ? void 0 : _b.map((e) => e)) || [];
message.txHashes = Object.entries((_c = object.txHashes) !== null && _c !== void 0 ? _c : {}).reduce((acc, [key, value]) => {
if (value !== undefined) {
acc[Number(key)] = value;
}
return acc;
}, {});
return message;
},
};
function createBaseBlockEventsRPC_TxHashesEntry() {
return { key: 0, value: new Uint8Array() };
}
export const BlockEventsRPC_TxHashesEntry = {
encode(message, writer = _m0.Writer.create()) {
if (message.key !== 0) {
writer.uint32(8).sint32(message.key);
}
if (message.value.length !== 0) {
writer.uint32(18).bytes(message.value);
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseBlockEventsRPC_TxHashesEntry();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.key = reader.sint32();
break;
case 2:
message.value = reader.bytes();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
key: isSet(object.key) ? Number(object.key) : 0,
value: isSet(object.value) ? bytesFromBase64(object.value) : new Uint8Array(),
};
},
toJSON(message) {
const obj = {};
message.key !== undefined && (obj.key = Math.round(message.key));
message.value !== undefined &&
(obj.value = base64FromBytes(message.value !== undefined ? message.value : new Uint8Array()));
return obj;
},
create(base) {
return BlockEventsRPC_TxHashesEntry.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b;
const message = createBaseBlockEventsRPC_TxHashesEntry();
message.key = (_a = object.key) !== null && _a !== void 0 ? _a : 0;
message.value = (_b = object.value) !== null && _b !== void 0 ? _b : new Uint8Array();
return message;
},
};
function createBaseGetCustomEventsRPCRequest() {

@@ -428,14 +784,17 @@ return { backend: "", height: 0, events: "" };

function createBaseGetCustomEventsRPCResponse() {
return { s: "", errmsg: "", data: undefined };
return { v: "", s: "", e: "", data: undefined };
}
export const GetCustomEventsRPCResponse = {
encode(message, writer = _m0.Writer.create()) {
if (message.v !== "") {
writer.uint32(10).string(message.v);
}
if (message.s !== "") {
writer.uint32(10).string(message.s);
writer.uint32(18).string(message.s);
}
if (message.errmsg !== "") {
writer.uint32(18).string(message.errmsg);
if (message.e !== "") {
writer.uint32(26).string(message.e);
}
if (message.data !== undefined) {
BlockEventsRPC.encode(message.data, writer.uint32(26).fork()).ldelim();
BlockEventsRPC.encode(message.data, writer.uint32(34).fork()).ldelim();
}

@@ -452,8 +811,11 @@ return writer;

case 1:
message.s = reader.string();
message.v = reader.string();
break;
case 2:
message.errmsg = reader.string();
message.s = reader.string();
break;
case 3:
message.e = reader.string();
break;
case 4:
message.data = BlockEventsRPC.decode(reader, reader.uint32());

@@ -470,4 +832,5 @@ break;

return {
v: isSet(object.v) ? String(object.v) : "",
s: isSet(object.s) ? String(object.s) : "",
errmsg: isSet(object.errmsg) ? String(object.errmsg) : "",
e: isSet(object.e) ? String(object.e) : "",
data: isSet(object.data) ? BlockEventsRPC.fromJSON(object.data) : undefined,

@@ -478,4 +841,5 @@ };

const obj = {};
message.v !== undefined && (obj.v = message.v);
message.s !== undefined && (obj.s = message.s);
message.errmsg !== undefined && (obj.errmsg = message.errmsg);
message.e !== undefined && (obj.e = message.e);
message.data !== undefined && (obj.data = message.data ? BlockEventsRPC.toJSON(message.data) : undefined);

@@ -488,6 +852,7 @@ return obj;

fromPartial(object) {
var _a, _b;
var _a, _b, _c;
const message = createBaseGetCustomEventsRPCResponse();
message.s = (_a = object.s) !== null && _a !== void 0 ? _a : "";
message.errmsg = (_b = object.errmsg) !== null && _b !== void 0 ? _b : "";
message.v = (_a = object.v) !== null && _a !== void 0 ? _a : "";
message.s = (_b = object.s) !== null && _b !== void 0 ? _b : "";
message.e = (_c = object.e) !== null && _c !== void 0 ? _c : "";
message.data = (object.data !== undefined && object.data !== null)

@@ -503,2 +868,3 @@ ? BlockEventsRPC.fromPartial(object.data)

this.GetLatestHeight = this.GetLatestHeight.bind(this);
this.StreamBlockEvents = this.StreamBlockEvents.bind(this);
this.GetBlockEventsRPC = this.GetBlockEventsRPC.bind(this);

@@ -510,2 +876,5 @@ this.GetCustomEventsRPC = this.GetCustomEventsRPC.bind(this);

}
StreamBlockEvents(request, metadata) {
return this.rpc.invoke(EventProviderAPIStreamBlockEventsDesc, StreamBlockEventsRequest.fromPartial(request), metadata);
}
GetBlockEventsRPC(request, metadata) {

@@ -538,2 +907,21 @@ return this.rpc.unary(EventProviderAPIGetBlockEventsRPCDesc, GetBlockEventsRPCRequest.fromPartial(request), metadata);

};
export const EventProviderAPIStreamBlockEventsDesc = {
methodName: "StreamBlockEvents",
service: EventProviderAPIDesc,
requestStream: false,
responseStream: true,
requestType: {
serializeBinary() {
return StreamBlockEventsRequest.encode(this).finish();
},
},
responseType: {
deserializeBinary(data) {
const value = StreamBlockEventsResponse.decode(data);
return Object.assign(Object.assign({}, value), { toObject() {
return value;
} });
},
},
};
export const EventProviderAPIGetBlockEventsRPCDesc = {

@@ -607,2 +995,39 @@ methodName: "GetBlockEventsRPC",

}
invoke(methodDesc, _request, metadata) {
var _a;
const upStreamCodes = this.options.upStreamRetryCodes || [];
const DEFAULT_TIMEOUT_TIME = 3000;
const request = Object.assign(Object.assign({}, _request), methodDesc.requestType);
const maybeCombinedMetadata = metadata && this.options.metadata
? new BrowserHeaders(Object.assign(Object.assign({}, (_a = this.options) === null || _a === void 0 ? void 0 : _a.metadata.headersMap), metadata === null || metadata === void 0 ? void 0 : metadata.headersMap))
: metadata || this.options.metadata;
return new Observable((observer) => {
const upStream = (() => {
const client = grpc.invoke(methodDesc, {
host: this.host,
request,
transport: this.options.streamingTransport || this.options.transport,
metadata: maybeCombinedMetadata,
debug: this.options.debug,
onMessage: (next) => observer.next(next),
onEnd: (code, message, trailers) => {
if (code === 0) {
observer.complete();
}
else if (upStreamCodes.includes(code)) {
setTimeout(upStream, DEFAULT_TIMEOUT_TIME);
}
else {
const err = new Error(message);
err.code = code;
err.metadata = trailers;
observer.error(err);
}
},
});
observer.add(() => client.close());
});
upStream();
}).pipe(share());
}
}

@@ -656,2 +1081,5 @@ var tsProtoGlobalThis = (() => {

}
function isObject(value) {
return typeof value === "object" && value !== null;
}
function isSet(value) {

@@ -658,0 +1086,0 @@ return value !== null && value !== undefined;

81

esm/injective_explorer_rpc.d.ts

@@ -8,3 +8,5 @@ import { grpc } from "@injectivelabs/grpc-web";

address: string;
/** Return transactions before this block number */
before: string;
/** Return transactions after this block number */
after: string;

@@ -528,2 +530,4 @@ limit: number;

skip: string;
/** Label of the contract */
label: string;
}

@@ -680,2 +684,43 @@ export interface GetWasmContractsResponse {

}
export interface GetBankTransfersRequest {
/** Transfer sender address */
senders: string[];
/** Transfer recipient address */
recipients: string[];
/**
* Returns transfers with the community pool address as either sender or
* recipient
*/
isCommunityPoolRelated: boolean;
limit: number;
skip: string;
/**
* The starting timestamp in UNIX milliseconds that the transfers must be equal
* or older than
*/
startTime: string;
/**
* The ending timestamp in UNIX milliseconds that the transfers must be equal
* or younger than
*/
endTime: string;
}
export interface GetBankTransfersResponse {
paging: Paging | undefined;
data: BankTransfer[];
}
/** Bank transfer represents a transfer */
export interface BankTransfer {
sender: string;
recipient: string;
/** Amounts transferred */
amounts: Coin[];
blockNumber: string;
blockTimestamp: string;
}
export interface Coin {
/** Denom of the coin */
denom: string;
amount: string;
}
export interface StreamTxsRequest {

@@ -1228,2 +1273,34 @@ }

};
export declare const GetBankTransfersRequest: {
encode(message: GetBankTransfersRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): GetBankTransfersRequest;
fromJSON(object: any): GetBankTransfersRequest;
toJSON(message: GetBankTransfersRequest): unknown;
create(base?: DeepPartial<GetBankTransfersRequest>): GetBankTransfersRequest;
fromPartial(object: DeepPartial<GetBankTransfersRequest>): GetBankTransfersRequest;
};
export declare const GetBankTransfersResponse: {
encode(message: GetBankTransfersResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): GetBankTransfersResponse;
fromJSON(object: any): GetBankTransfersResponse;
toJSON(message: GetBankTransfersResponse): unknown;
create(base?: DeepPartial<GetBankTransfersResponse>): GetBankTransfersResponse;
fromPartial(object: DeepPartial<GetBankTransfersResponse>): GetBankTransfersResponse;
};
export declare const BankTransfer: {
encode(message: BankTransfer, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): BankTransfer;
fromJSON(object: any): BankTransfer;
toJSON(message: BankTransfer): unknown;
create(base?: DeepPartial<BankTransfer>): BankTransfer;
fromPartial(object: DeepPartial<BankTransfer>): BankTransfer;
};
export declare const Coin: {
encode(message: Coin, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): Coin;
fromJSON(object: any): Coin;
toJSON(message: Coin): unknown;
create(base?: DeepPartial<Coin>): Coin;
fromPartial(object: DeepPartial<Coin>): Coin;
};
export declare const StreamTxsRequest: {

@@ -1311,2 +1388,4 @@ encode(_: StreamTxsRequest, writer?: _m0.Writer): _m0.Writer;

Relayers(request: DeepPartial<RelayersRequest>, metadata?: grpc.Metadata): Promise<RelayersResponse>;
/** GetBankTransfers returns bank transfers. */
GetBankTransfers(request: DeepPartial<GetBankTransfersRequest>, metadata?: grpc.Metadata): Promise<GetBankTransfersResponse>;
/** StreamTxs returns transactions based upon the request params */

@@ -1338,2 +1417,3 @@ StreamTxs(request: DeepPartial<StreamTxsRequest>, metadata?: grpc.Metadata): Observable<StreamTxsResponse>;

Relayers(request: DeepPartial<RelayersRequest>, metadata?: grpc.Metadata): Promise<RelayersResponse>;
GetBankTransfers(request: DeepPartial<GetBankTransfersRequest>, metadata?: grpc.Metadata): Promise<GetBankTransfersResponse>;
StreamTxs(request: DeepPartial<StreamTxsRequest>, metadata?: grpc.Metadata): Observable<StreamTxsResponse>;

@@ -1363,2 +1443,3 @@ StreamBlocks(request: DeepPartial<StreamBlocksRequest>, metadata?: grpc.Metadata): Observable<StreamBlocksResponse>;

export declare const InjectiveExplorerRPCRelayersDesc: UnaryMethodDefinitionish;
export declare const InjectiveExplorerRPCGetBankTransfersDesc: UnaryMethodDefinitionish;
export declare const InjectiveExplorerRPCStreamTxsDesc: UnaryMethodDefinitionish;

@@ -1365,0 +1446,0 @@ export declare const InjectiveExplorerRPCStreamBlocksDesc: UnaryMethodDefinitionish;

51

esm/injective_meta_rpc.d.ts

@@ -55,2 +55,25 @@ import { grpc } from "@injectivelabs/grpc-web";

}
export interface TokenMetadataRequest {
denoms: string[];
}
export interface TokenMetadataResponse {
/** tokens and their metadata list */
tokens: TokenMetadataElement[];
}
export interface TokenMetadataElement {
/** Token's Ethereum address, not all token have this information */
ethereumAddress: string;
/** Token's CoinGecko id for price references */
coingeckoId: string;
/** Token's denom on injective chain */
denom: string;
/** Token name */
name: string;
/** Token symbol */
symbol: string;
/** Number of decimal places used to represent the token's smallest unit */
decimals: number;
/** Token logo URL */
logo: string;
}
export declare const PingRequest: {

@@ -136,2 +159,26 @@ encode(_: PingRequest, writer?: _m0.Writer): _m0.Writer;

};
export declare const TokenMetadataRequest: {
encode(message: TokenMetadataRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): TokenMetadataRequest;
fromJSON(object: any): TokenMetadataRequest;
toJSON(message: TokenMetadataRequest): unknown;
create(base?: DeepPartial<TokenMetadataRequest>): TokenMetadataRequest;
fromPartial(object: DeepPartial<TokenMetadataRequest>): TokenMetadataRequest;
};
export declare const TokenMetadataResponse: {
encode(message: TokenMetadataResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): TokenMetadataResponse;
fromJSON(object: any): TokenMetadataResponse;
toJSON(message: TokenMetadataResponse): unknown;
create(base?: DeepPartial<TokenMetadataResponse>): TokenMetadataResponse;
fromPartial(object: DeepPartial<TokenMetadataResponse>): TokenMetadataResponse;
};
export declare const TokenMetadataElement: {
encode(message: TokenMetadataElement, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): TokenMetadataElement;
fromJSON(object: any): TokenMetadataElement;
toJSON(message: TokenMetadataElement): unknown;
create(base?: DeepPartial<TokenMetadataElement>): TokenMetadataElement;
fromPartial(object: DeepPartial<TokenMetadataElement>): TokenMetadataElement;
};
/** InjectiveMetaRPC is a special API subset to get info about server. */

@@ -150,2 +197,4 @@ export interface InjectiveMetaRPC {

StreamKeepalive(request: DeepPartial<StreamKeepaliveRequest>, metadata?: grpc.Metadata): Observable<StreamKeepaliveResponse>;
/** Get tokens metadata. Can be filtered by denom */
TokenMetadata(request: DeepPartial<TokenMetadataRequest>, metadata?: grpc.Metadata): Promise<TokenMetadataResponse>;
}

@@ -159,2 +208,3 @@ export declare class InjectiveMetaRPCClientImpl implements InjectiveMetaRPC {

StreamKeepalive(request: DeepPartial<StreamKeepaliveRequest>, metadata?: grpc.Metadata): Observable<StreamKeepaliveResponse>;
TokenMetadata(request: DeepPartial<TokenMetadataRequest>, metadata?: grpc.Metadata): Promise<TokenMetadataResponse>;
}

@@ -168,2 +218,3 @@ export declare const InjectiveMetaRPCDesc: {

export declare const InjectiveMetaRPCStreamKeepaliveDesc: UnaryMethodDefinitionish;
export declare const InjectiveMetaRPCTokenMetadataDesc: UnaryMethodDefinitionish;
interface UnaryMethodDefinitionishR extends grpc.UnaryMethodDefinition<any, any> {

@@ -170,0 +221,0 @@ requestStream: any;

226

esm/injective_meta_rpc.js

@@ -544,2 +544,205 @@ /* eslint-disable */

};
function createBaseTokenMetadataRequest() {
return { denoms: [] };
}
export const TokenMetadataRequest = {
encode(message, writer = _m0.Writer.create()) {
for (const v of message.denoms) {
writer.uint32(10).string(v);
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseTokenMetadataRequest();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.denoms.push(reader.string());
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return { denoms: Array.isArray(object === null || object === void 0 ? void 0 : object.denoms) ? object.denoms.map((e) => String(e)) : [] };
},
toJSON(message) {
const obj = {};
if (message.denoms) {
obj.denoms = message.denoms.map((e) => e);
}
else {
obj.denoms = [];
}
return obj;
},
create(base) {
return TokenMetadataRequest.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a;
const message = createBaseTokenMetadataRequest();
message.denoms = ((_a = object.denoms) === null || _a === void 0 ? void 0 : _a.map((e) => e)) || [];
return message;
},
};
function createBaseTokenMetadataResponse() {
return { tokens: [] };
}
export const TokenMetadataResponse = {
encode(message, writer = _m0.Writer.create()) {
for (const v of message.tokens) {
TokenMetadataElement.encode(v, writer.uint32(10).fork()).ldelim();
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseTokenMetadataResponse();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.tokens.push(TokenMetadataElement.decode(reader, reader.uint32()));
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
tokens: Array.isArray(object === null || object === void 0 ? void 0 : object.tokens) ? object.tokens.map((e) => TokenMetadataElement.fromJSON(e)) : [],
};
},
toJSON(message) {
const obj = {};
if (message.tokens) {
obj.tokens = message.tokens.map((e) => e ? TokenMetadataElement.toJSON(e) : undefined);
}
else {
obj.tokens = [];
}
return obj;
},
create(base) {
return TokenMetadataResponse.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a;
const message = createBaseTokenMetadataResponse();
message.tokens = ((_a = object.tokens) === null || _a === void 0 ? void 0 : _a.map((e) => TokenMetadataElement.fromPartial(e))) || [];
return message;
},
};
function createBaseTokenMetadataElement() {
return { ethereumAddress: "", coingeckoId: "", denom: "", name: "", symbol: "", decimals: 0, logo: "" };
}
export const TokenMetadataElement = {
encode(message, writer = _m0.Writer.create()) {
if (message.ethereumAddress !== "") {
writer.uint32(10).string(message.ethereumAddress);
}
if (message.coingeckoId !== "") {
writer.uint32(18).string(message.coingeckoId);
}
if (message.denom !== "") {
writer.uint32(26).string(message.denom);
}
if (message.name !== "") {
writer.uint32(34).string(message.name);
}
if (message.symbol !== "") {
writer.uint32(42).string(message.symbol);
}
if (message.decimals !== 0) {
writer.uint32(48).sint32(message.decimals);
}
if (message.logo !== "") {
writer.uint32(58).string(message.logo);
}
return writer;
},
decode(input, length) {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseTokenMetadataElement();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.ethereumAddress = reader.string();
break;
case 2:
message.coingeckoId = reader.string();
break;
case 3:
message.denom = reader.string();
break;
case 4:
message.name = reader.string();
break;
case 5:
message.symbol = reader.string();
break;
case 6:
message.decimals = reader.sint32();
break;
case 7:
message.logo = reader.string();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromJSON(object) {
return {
ethereumAddress: isSet(object.ethereumAddress) ? String(object.ethereumAddress) : "",
coingeckoId: isSet(object.coingeckoId) ? String(object.coingeckoId) : "",
denom: isSet(object.denom) ? String(object.denom) : "",
name: isSet(object.name) ? String(object.name) : "",
symbol: isSet(object.symbol) ? String(object.symbol) : "",
decimals: isSet(object.decimals) ? Number(object.decimals) : 0,
logo: isSet(object.logo) ? String(object.logo) : "",
};
},
toJSON(message) {
const obj = {};
message.ethereumAddress !== undefined && (obj.ethereumAddress = message.ethereumAddress);
message.coingeckoId !== undefined && (obj.coingeckoId = message.coingeckoId);
message.denom !== undefined && (obj.denom = message.denom);
message.name !== undefined && (obj.name = message.name);
message.symbol !== undefined && (obj.symbol = message.symbol);
message.decimals !== undefined && (obj.decimals = Math.round(message.decimals));
message.logo !== undefined && (obj.logo = message.logo);
return obj;
},
create(base) {
return TokenMetadataElement.fromPartial(base !== null && base !== void 0 ? base : {});
},
fromPartial(object) {
var _a, _b, _c, _d, _e, _f, _g;
const message = createBaseTokenMetadataElement();
message.ethereumAddress = (_a = object.ethereumAddress) !== null && _a !== void 0 ? _a : "";
message.coingeckoId = (_b = object.coingeckoId) !== null && _b !== void 0 ? _b : "";
message.denom = (_c = object.denom) !== null && _c !== void 0 ? _c : "";
message.name = (_d = object.name) !== null && _d !== void 0 ? _d : "";
message.symbol = (_e = object.symbol) !== null && _e !== void 0 ? _e : "";
message.decimals = (_f = object.decimals) !== null && _f !== void 0 ? _f : 0;
message.logo = (_g = object.logo) !== null && _g !== void 0 ? _g : "";
return message;
},
};
export class InjectiveMetaRPCClientImpl {

@@ -552,2 +755,3 @@ constructor(rpc) {

this.StreamKeepalive = this.StreamKeepalive.bind(this);
this.TokenMetadata = this.TokenMetadata.bind(this);
}

@@ -566,2 +770,5 @@ Ping(request, metadata) {

}
TokenMetadata(request, metadata) {
return this.rpc.unary(InjectiveMetaRPCTokenMetadataDesc, TokenMetadataRequest.fromPartial(request), metadata);
}
}

@@ -645,2 +852,21 @@ export const InjectiveMetaRPCDesc = { serviceName: "injective_meta_rpc.InjectiveMetaRPC" };

};
export const InjectiveMetaRPCTokenMetadataDesc = {
methodName: "TokenMetadata",
service: InjectiveMetaRPCDesc,
requestStream: false,
responseStream: false,
requestType: {
serializeBinary() {
return TokenMetadataRequest.encode(this).finish();
},
},
responseType: {
deserializeBinary(data) {
const value = TokenMetadataResponse.decode(data);
return Object.assign(Object.assign({}, value), { toObject() {
return value;
} });
},
},
};
export class GrpcWebImpl {

@@ -647,0 +873,0 @@ constructor(host, options) {

96

esm/injective_spot_exchange_rpc.d.ts

@@ -196,2 +196,4 @@ import { grpc } from "@injectivelabs/grpc-web";

subaccountTotalOrders: boolean;
/** TradeId of the order we want to fetch */
tradeId: string;
}

@@ -230,2 +232,4 @@ export interface OrdersResponse {

updatedAt: string;
/** Transaction Hash where order is created. Not all orders have this field */
txHash: string;
}

@@ -270,2 +274,4 @@ /** Paging defines the structure for required params for handling pagination */

subaccountTotalOrders: boolean;
/** TradeId of the order we want to fetch */
tradeId: string;
}

@@ -437,2 +443,6 @@ export interface StreamOrdersResponse {

marketIds: string[];
/** TradeId of the order we want to fetch */
tradeId: string;
/** Return only orders for active markets */
activeMarketsOnly: boolean;
}

@@ -473,2 +483,4 @@ export interface OrdersHistoryResponse {

direction: string;
/** Transaction Hash where order is created. Not all orders have this field */
txHash: string;
}

@@ -496,2 +508,50 @@ export interface StreamOrdersHistoryRequest {

}
export interface AtomicSwapHistoryRequest {
/** sender of the atomic swap */
address: string;
/** atomic swap contract address to filter */
contractAddress: string;
/** skip some swaps */
skip: number;
/** limit number of swaps returned by this API */
limit: number;
/** lowerbound of atomic swap index */
fromNumber: number;
/** upperbound of atomic swap index */
toNumber: number;
}
export interface AtomicSwapHistoryResponse {
/** Paging indicates total number of records with this filter */
paging: Paging | undefined;
/** swap data */
data: AtomicSwap[];
}
export interface AtomicSwap {
/** executor of the swap */
sender: string;
/** swap route */
route: string;
/** source coin */
sourceCoin: Coin | undefined;
/** destination received coin */
destCoin: Coin | undefined;
/** fees of each steps in route */
fees: Coin[];
/** contract address that executes to make this swap */
contractAddress: string;
/** Numerical index by sender to use in pagination from_number and to_number */
indexBySender: number;
/**
* Numerical index by sender + acontract to use in pagination from_number and
* to_number, that support contract filter
*/
indexBySenderContract: number;
/** transaction hash of the swap */
txHash: string;
}
export interface Coin {
/** Denom of the coin */
denom: string;
amount: string;
}
export declare const MarketsRequest: {

@@ -825,2 +885,34 @@ encode(message: MarketsRequest, writer?: _m0.Writer): _m0.Writer;

};
export declare const AtomicSwapHistoryRequest: {
encode(message: AtomicSwapHistoryRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): AtomicSwapHistoryRequest;
fromJSON(object: any): AtomicSwapHistoryRequest;
toJSON(message: AtomicSwapHistoryRequest): unknown;
create(base?: DeepPartial<AtomicSwapHistoryRequest>): AtomicSwapHistoryRequest;
fromPartial(object: DeepPartial<AtomicSwapHistoryRequest>): AtomicSwapHistoryRequest;
};
export declare const AtomicSwapHistoryResponse: {
encode(message: AtomicSwapHistoryResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): AtomicSwapHistoryResponse;
fromJSON(object: any): AtomicSwapHistoryResponse;
toJSON(message: AtomicSwapHistoryResponse): unknown;
create(base?: DeepPartial<AtomicSwapHistoryResponse>): AtomicSwapHistoryResponse;
fromPartial(object: DeepPartial<AtomicSwapHistoryResponse>): AtomicSwapHistoryResponse;
};
export declare const AtomicSwap: {
encode(message: AtomicSwap, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): AtomicSwap;
fromJSON(object: any): AtomicSwap;
toJSON(message: AtomicSwap): unknown;
create(base?: DeepPartial<AtomicSwap>): AtomicSwap;
fromPartial(object: DeepPartial<AtomicSwap>): AtomicSwap;
};
export declare const Coin: {
encode(message: Coin, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): Coin;
fromJSON(object: any): Coin;
toJSON(message: Coin): unknown;
create(base?: DeepPartial<Coin>): Coin;
fromPartial(object: DeepPartial<Coin>): Coin;
};
/** InjectiveSpotExchangeRPC defines gRPC API of Spot Exchange provider. */

@@ -858,2 +950,4 @@ export interface InjectiveSpotExchangeRPC {

StreamOrdersHistory(request: DeepPartial<StreamOrdersHistoryRequest>, metadata?: grpc.Metadata): Observable<StreamOrdersHistoryResponse>;
/** Get historical atomic swaps */
AtomicSwapHistory(request: DeepPartial<AtomicSwapHistoryRequest>, metadata?: grpc.Metadata): Promise<AtomicSwapHistoryResponse>;
}

@@ -878,2 +972,3 @@ export declare class InjectiveSpotExchangeRPCClientImpl implements InjectiveSpotExchangeRPC {

StreamOrdersHistory(request: DeepPartial<StreamOrdersHistoryRequest>, metadata?: grpc.Metadata): Observable<StreamOrdersHistoryResponse>;
AtomicSwapHistory(request: DeepPartial<AtomicSwapHistoryRequest>, metadata?: grpc.Metadata): Promise<AtomicSwapHistoryResponse>;
}

@@ -898,2 +993,3 @@ export declare const InjectiveSpotExchangeRPCDesc: {

export declare const InjectiveSpotExchangeRPCStreamOrdersHistoryDesc: UnaryMethodDefinitionish;
export declare const InjectiveSpotExchangeRPCAtomicSwapHistoryDesc: UnaryMethodDefinitionish;
interface UnaryMethodDefinitionishR extends grpc.UnaryMethodDefinition<any, any> {

@@ -900,0 +996,0 @@ requestStream: any;

2

package.json
{
"name": "@injectivelabs/indexer-proto-ts",
"version": "1.10.8-rc.4",
"version": "1.11.1",
"description": "Injective Indexer API client with generated gRPC bindings.",

@@ -5,0 +5,0 @@ "sideEffects": "false",

cjs/injective_derivative_exchange_rpc.d.ts

Sorry, the diff of this file is too big to display

cjs/injective_derivative_exchange_rpc.js

Sorry, the diff of this file is too big to display

cjs/injective_explorer_rpc.js

Sorry, the diff of this file is too big to display

cjs/injective_spot_exchange_rpc.js

Sorry, the diff of this file is too big to display

esm/injective_derivative_exchange_rpc.d.ts

Sorry, the diff of this file is too big to display

esm/injective_derivative_exchange_rpc.js

Sorry, the diff of this file is too big to display

esm/injective_explorer_rpc.js

Sorry, the diff of this file is too big to display

esm/injective_spot_exchange_rpc.js

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc