diff --git a/.deepsource.toml b/.deepsource.toml deleted file mode 100644 index ad064263d9..0000000000 --- a/.deepsource.toml +++ /dev/null @@ -1,7 +0,0 @@ -version = 1 - -exclude_patterns = ["**/gen/**", "**/types/**"] - -[[analyzers]] -name = "javascript" -enabled = true \ No newline at end of file diff --git a/packages/cli/templates/starknet/abis/starknet/sepolia/VoteContract-0x00cf88f7ecf1bf36e9262333879e2937611cd81758db64a169776a2710464391.json b/packages/cli/templates/starknet/abis/starknet/sepolia/VoteContract-0x00cf88f7ecf1bf36e9262333879e2937611cd81758db64a169776a2710464391.json new file mode 100644 index 0000000000..a4c6c0c8db --- /dev/null +++ b/packages/cli/templates/starknet/abis/starknet/sepolia/VoteContract-0x00cf88f7ecf1bf36e9262333879e2937611cd81758db64a169776a2710464391.json @@ -0,0 +1,65 @@ +[ + { + "type": "impl", + "name": "VotingContractImpl", + "interface_name": "contracts::IVotingContract" + }, + { + "type": "interface", + "name": "contracts::IVotingContract", + "items": [ + { + "type": "function", + "name": "vote", + "inputs": [ + { + "name": "vote", + "type": "core::felt252" + } + ], + "outputs": [], + "state_mutability": "external" + }, + { + "type": "function", + "name": "get_votes", + "inputs": [], + "outputs": [ + { + "type": "(core::felt252, core::felt252)" + } + ], + "state_mutability": "view" + } + ] + }, + { + "type": "event", + "name": "contracts::VotingContract::VoteEvent", + "kind": "struct", + "members": [ + { + "name": "voter", + "type": "core::starknet::contract_address::ContractAddress", + "kind": "key" + }, + { + "name": "vote", + "type": "core::felt252", + "kind": "data" + } + ] + }, + { + "type": "event", + "name": "contracts::VotingContract::Event", + "kind": "enum", + "variants": [ + { + "name": "VoteEvent", + "type": "contracts::VotingContract::VoteEvent", + "kind": "nested" + } + ] + } +] diff --git a/packages/protos/package.json b/packages/protos/package.json index 779e2b26d0..9f775fe3dd 100644 --- a/packages/protos/package.json +++ b/packages/protos/package.json @@ -4,9 +4,7 @@ "license": "Apache-2.0", "type": "module", "exports": { - ".": "./lib/index.js", - "./price": "./lib/service/price/protos/price.js", - "./chainquery": "./lib/chainquery/protos/chainquery.js" + ".": "./lib/index.js" }, "files": [ "{lib,src}" diff --git a/packages/protos/src/chainquery/protos/chainquery.ts b/packages/protos/src/chainquery/protos/chainquery.ts deleted file mode 100644 index 40be55a3a4..0000000000 --- a/packages/protos/src/chainquery/protos/chainquery.ts +++ /dev/null @@ -1,2126 +0,0 @@ -/* eslint-disable */ -import Long from "long"; -import type { CallContext, CallOptions } from "nice-grpc-common"; -import _m0 from "protobufjs/minimal.js"; - -export interface AptosGetTxnsByFunctionRequest { - network: string; - fromVersion: bigint; - toVersion: bigint; - function: string; - matchAll: boolean; - typedArguments: string[]; - includeChanges: boolean; - resourceChangesMoveTypePrefix: string; -} - -export interface AptosGetTxnsByVersionRequest { - network: string; - fromVersion: bigint; - toVersion: bigint; - headerOnly?: boolean | undefined; -} - -export interface AptosGetTxnsByEventRequest { - network: string; - fromVersion: bigint; - toVersion: bigint; - address: string; - type: string; - includeAllEvents: boolean; - includeChanges: boolean; - resourceChangesMoveTypePrefix: string; -} - -export interface AptosSQLQueryRequest { - network: string; - fromVersion: bigint; - toVersion: bigint; - sql: string; - arbitraryRange: boolean; -} - -export interface QueryPhaseSummary { - name: string; - timeTookMs: bigint; -} - -export interface QueryExecutionSummary { - timeTookMs: bigint; - resultNumRows?: bigint | undefined; - resultNumBytes?: bigint | undefined; - numPartitionsWithMaterializedView?: bigint | undefined; - numPartitionsWithoutMaterializedView?: bigint | undefined; - numPartitions?: bigint | undefined; - phases: QueryPhaseSummary[]; - qcacheSignature?: string | undefined; - qcacheHit?: boolean | undefined; -} - -export interface AptosGetTxnsResponse { - documents: Uint8Array[]; - executionSummary?: QueryExecutionSummary | undefined; -} - -export interface AptosRefreshRequest { -} - -export interface VoidResponse { -} - -export interface EvmSQLQueryRequest { - network: string; - sql: string; - nocache?: boolean | undefined; -} - -export interface EvmGetHeaderRequest { - network: string; - fromBlock?: bigint | undefined; - toBlock?: bigint | undefined; - blockNumbers: bigint[]; -} - -export interface EvmQueryResponse { - rows: Uint8Array[]; - executionSummary?: QueryExecutionSummary | undefined; -} - -export interface SuiGetCheckpointTimeRequest { - network: string; - checkpointSequenceNumber: bigint; -} - -export interface SuiGetCheckpointTimeResponse { - checkpointTimestampMs?: bigint | undefined; - transactionMinTimestampMs?: bigint | undefined; - transactionMaxTimestampMs?: bigint | undefined; -} - -export interface RemoteResultRequest { - token: string; - position: number; - keepAlive: boolean; -} - -export interface RemoteResultResponse { - rows: Uint8Array[]; -} - -function createBaseAptosGetTxnsByFunctionRequest(): AptosGetTxnsByFunctionRequest { - return { - network: "", - fromVersion: BigInt("0"), - toVersion: BigInt("0"), - function: "", - matchAll: false, - typedArguments: [], - includeChanges: false, - resourceChangesMoveTypePrefix: "", - }; -} - -export const AptosGetTxnsByFunctionRequest = { - encode(message: AptosGetTxnsByFunctionRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.network !== "") { - writer.uint32(10).string(message.network); - } - if (message.fromVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.fromVersion) !== message.fromVersion) { - throw new globalThis.Error("value provided for field message.fromVersion of type uint64 too large"); - } - writer.uint32(16).uint64(message.fromVersion.toString()); - } - if (message.toVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.toVersion) !== message.toVersion) { - throw new globalThis.Error("value provided for field message.toVersion of type uint64 too large"); - } - writer.uint32(24).uint64(message.toVersion.toString()); - } - if (message.function !== "") { - writer.uint32(34).string(message.function); - } - if (message.matchAll !== false) { - writer.uint32(40).bool(message.matchAll); - } - for (const v of message.typedArguments) { - writer.uint32(50).string(v!); - } - if (message.includeChanges !== false) { - writer.uint32(56).bool(message.includeChanges); - } - if (message.resourceChangesMoveTypePrefix !== "") { - writer.uint32(66).string(message.resourceChangesMoveTypePrefix); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): AptosGetTxnsByFunctionRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseAptosGetTxnsByFunctionRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.network = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.fromVersion = longToBigint(reader.uint64() as Long); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.toVersion = longToBigint(reader.uint64() as Long); - continue; - case 4: - if (tag !== 34) { - break; - } - - message.function = reader.string(); - continue; - case 5: - if (tag !== 40) { - break; - } - - message.matchAll = reader.bool(); - continue; - case 6: - if (tag !== 50) { - break; - } - - message.typedArguments.push(reader.string()); - continue; - case 7: - if (tag !== 56) { - break; - } - - message.includeChanges = reader.bool(); - continue; - case 8: - if (tag !== 66) { - break; - } - - message.resourceChangesMoveTypePrefix = reader.string(); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): AptosGetTxnsByFunctionRequest { - return { - network: isSet(object.network) ? globalThis.String(object.network) : "", - fromVersion: isSet(object.fromVersion) ? BigInt(object.fromVersion) : BigInt("0"), - toVersion: isSet(object.toVersion) ? BigInt(object.toVersion) : BigInt("0"), - function: isSet(object.function) ? globalThis.String(object.function) : "", - matchAll: isSet(object.matchAll) ? globalThis.Boolean(object.matchAll) : false, - typedArguments: globalThis.Array.isArray(object?.typedArguments) - ? object.typedArguments.map((e: any) => globalThis.String(e)) - : [], - includeChanges: isSet(object.includeChanges) ? globalThis.Boolean(object.includeChanges) : false, - resourceChangesMoveTypePrefix: isSet(object.resourceChangesMoveTypePrefix) - ? globalThis.String(object.resourceChangesMoveTypePrefix) - : "", - }; - }, - - toJSON(message: AptosGetTxnsByFunctionRequest): unknown { - const obj: any = {}; - if (message.network !== "") { - obj.network = message.network; - } - if (message.fromVersion !== BigInt("0")) { - obj.fromVersion = message.fromVersion.toString(); - } - if (message.toVersion !== BigInt("0")) { - obj.toVersion = message.toVersion.toString(); - } - if (message.function !== "") { - obj.function = message.function; - } - if (message.matchAll !== false) { - obj.matchAll = message.matchAll; - } - if (message.typedArguments?.length) { - obj.typedArguments = message.typedArguments; - } - if (message.includeChanges !== false) { - obj.includeChanges = message.includeChanges; - } - if (message.resourceChangesMoveTypePrefix !== "") { - obj.resourceChangesMoveTypePrefix = message.resourceChangesMoveTypePrefix; - } - return obj; - }, - - create(base?: DeepPartial): AptosGetTxnsByFunctionRequest { - return AptosGetTxnsByFunctionRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): AptosGetTxnsByFunctionRequest { - const message = createBaseAptosGetTxnsByFunctionRequest(); - message.network = object.network ?? ""; - message.fromVersion = object.fromVersion ?? BigInt("0"); - message.toVersion = object.toVersion ?? BigInt("0"); - message.function = object.function ?? ""; - message.matchAll = object.matchAll ?? false; - message.typedArguments = object.typedArguments?.map((e) => e) || []; - message.includeChanges = object.includeChanges ?? false; - message.resourceChangesMoveTypePrefix = object.resourceChangesMoveTypePrefix ?? ""; - return message; - }, -}; - -function createBaseAptosGetTxnsByVersionRequest(): AptosGetTxnsByVersionRequest { - return { network: "", fromVersion: BigInt("0"), toVersion: BigInt("0"), headerOnly: undefined }; -} - -export const AptosGetTxnsByVersionRequest = { - encode(message: AptosGetTxnsByVersionRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.network !== "") { - writer.uint32(10).string(message.network); - } - if (message.fromVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.fromVersion) !== message.fromVersion) { - throw new globalThis.Error("value provided for field message.fromVersion of type uint64 too large"); - } - writer.uint32(16).uint64(message.fromVersion.toString()); - } - if (message.toVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.toVersion) !== message.toVersion) { - throw new globalThis.Error("value provided for field message.toVersion of type uint64 too large"); - } - writer.uint32(24).uint64(message.toVersion.toString()); - } - if (message.headerOnly !== undefined) { - writer.uint32(32).bool(message.headerOnly); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): AptosGetTxnsByVersionRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseAptosGetTxnsByVersionRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.network = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.fromVersion = longToBigint(reader.uint64() as Long); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.toVersion = longToBigint(reader.uint64() as Long); - continue; - case 4: - if (tag !== 32) { - break; - } - - message.headerOnly = reader.bool(); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): AptosGetTxnsByVersionRequest { - return { - network: isSet(object.network) ? globalThis.String(object.network) : "", - fromVersion: isSet(object.fromVersion) ? BigInt(object.fromVersion) : BigInt("0"), - toVersion: isSet(object.toVersion) ? BigInt(object.toVersion) : BigInt("0"), - headerOnly: isSet(object.headerOnly) ? globalThis.Boolean(object.headerOnly) : undefined, - }; - }, - - toJSON(message: AptosGetTxnsByVersionRequest): unknown { - const obj: any = {}; - if (message.network !== "") { - obj.network = message.network; - } - if (message.fromVersion !== BigInt("0")) { - obj.fromVersion = message.fromVersion.toString(); - } - if (message.toVersion !== BigInt("0")) { - obj.toVersion = message.toVersion.toString(); - } - if (message.headerOnly !== undefined) { - obj.headerOnly = message.headerOnly; - } - return obj; - }, - - create(base?: DeepPartial): AptosGetTxnsByVersionRequest { - return AptosGetTxnsByVersionRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): AptosGetTxnsByVersionRequest { - const message = createBaseAptosGetTxnsByVersionRequest(); - message.network = object.network ?? ""; - message.fromVersion = object.fromVersion ?? BigInt("0"); - message.toVersion = object.toVersion ?? BigInt("0"); - message.headerOnly = object.headerOnly ?? undefined; - return message; - }, -}; - -function createBaseAptosGetTxnsByEventRequest(): AptosGetTxnsByEventRequest { - return { - network: "", - fromVersion: BigInt("0"), - toVersion: BigInt("0"), - address: "", - type: "", - includeAllEvents: false, - includeChanges: false, - resourceChangesMoveTypePrefix: "", - }; -} - -export const AptosGetTxnsByEventRequest = { - encode(message: AptosGetTxnsByEventRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.network !== "") { - writer.uint32(10).string(message.network); - } - if (message.fromVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.fromVersion) !== message.fromVersion) { - throw new globalThis.Error("value provided for field message.fromVersion of type uint64 too large"); - } - writer.uint32(16).uint64(message.fromVersion.toString()); - } - if (message.toVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.toVersion) !== message.toVersion) { - throw new globalThis.Error("value provided for field message.toVersion of type uint64 too large"); - } - writer.uint32(24).uint64(message.toVersion.toString()); - } - if (message.address !== "") { - writer.uint32(34).string(message.address); - } - if (message.type !== "") { - writer.uint32(42).string(message.type); - } - if (message.includeAllEvents !== false) { - writer.uint32(48).bool(message.includeAllEvents); - } - if (message.includeChanges !== false) { - writer.uint32(56).bool(message.includeChanges); - } - if (message.resourceChangesMoveTypePrefix !== "") { - writer.uint32(66).string(message.resourceChangesMoveTypePrefix); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): AptosGetTxnsByEventRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseAptosGetTxnsByEventRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.network = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.fromVersion = longToBigint(reader.uint64() as Long); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.toVersion = longToBigint(reader.uint64() as Long); - continue; - case 4: - if (tag !== 34) { - break; - } - - message.address = reader.string(); - continue; - case 5: - if (tag !== 42) { - break; - } - - message.type = reader.string(); - continue; - case 6: - if (tag !== 48) { - break; - } - - message.includeAllEvents = reader.bool(); - continue; - case 7: - if (tag !== 56) { - break; - } - - message.includeChanges = reader.bool(); - continue; - case 8: - if (tag !== 66) { - break; - } - - message.resourceChangesMoveTypePrefix = reader.string(); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): AptosGetTxnsByEventRequest { - return { - network: isSet(object.network) ? globalThis.String(object.network) : "", - fromVersion: isSet(object.fromVersion) ? BigInt(object.fromVersion) : BigInt("0"), - toVersion: isSet(object.toVersion) ? BigInt(object.toVersion) : BigInt("0"), - address: isSet(object.address) ? globalThis.String(object.address) : "", - type: isSet(object.type) ? globalThis.String(object.type) : "", - includeAllEvents: isSet(object.includeAllEvents) ? globalThis.Boolean(object.includeAllEvents) : false, - includeChanges: isSet(object.includeChanges) ? globalThis.Boolean(object.includeChanges) : false, - resourceChangesMoveTypePrefix: isSet(object.resourceChangesMoveTypePrefix) - ? globalThis.String(object.resourceChangesMoveTypePrefix) - : "", - }; - }, - - toJSON(message: AptosGetTxnsByEventRequest): unknown { - const obj: any = {}; - if (message.network !== "") { - obj.network = message.network; - } - if (message.fromVersion !== BigInt("0")) { - obj.fromVersion = message.fromVersion.toString(); - } - if (message.toVersion !== BigInt("0")) { - obj.toVersion = message.toVersion.toString(); - } - if (message.address !== "") { - obj.address = message.address; - } - if (message.type !== "") { - obj.type = message.type; - } - if (message.includeAllEvents !== false) { - obj.includeAllEvents = message.includeAllEvents; - } - if (message.includeChanges !== false) { - obj.includeChanges = message.includeChanges; - } - if (message.resourceChangesMoveTypePrefix !== "") { - obj.resourceChangesMoveTypePrefix = message.resourceChangesMoveTypePrefix; - } - return obj; - }, - - create(base?: DeepPartial): AptosGetTxnsByEventRequest { - return AptosGetTxnsByEventRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): AptosGetTxnsByEventRequest { - const message = createBaseAptosGetTxnsByEventRequest(); - message.network = object.network ?? ""; - message.fromVersion = object.fromVersion ?? BigInt("0"); - message.toVersion = object.toVersion ?? BigInt("0"); - message.address = object.address ?? ""; - message.type = object.type ?? ""; - message.includeAllEvents = object.includeAllEvents ?? false; - message.includeChanges = object.includeChanges ?? false; - message.resourceChangesMoveTypePrefix = object.resourceChangesMoveTypePrefix ?? ""; - return message; - }, -}; - -function createBaseAptosSQLQueryRequest(): AptosSQLQueryRequest { - return { network: "", fromVersion: BigInt("0"), toVersion: BigInt("0"), sql: "", arbitraryRange: false }; -} - -export const AptosSQLQueryRequest = { - encode(message: AptosSQLQueryRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.network !== "") { - writer.uint32(10).string(message.network); - } - if (message.fromVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.fromVersion) !== message.fromVersion) { - throw new globalThis.Error("value provided for field message.fromVersion of type uint64 too large"); - } - writer.uint32(16).uint64(message.fromVersion.toString()); - } - if (message.toVersion !== BigInt("0")) { - if (BigInt.asUintN(64, message.toVersion) !== message.toVersion) { - throw new globalThis.Error("value provided for field message.toVersion of type uint64 too large"); - } - writer.uint32(24).uint64(message.toVersion.toString()); - } - if (message.sql !== "") { - writer.uint32(34).string(message.sql); - } - if (message.arbitraryRange !== false) { - writer.uint32(40).bool(message.arbitraryRange); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): AptosSQLQueryRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseAptosSQLQueryRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.network = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.fromVersion = longToBigint(reader.uint64() as Long); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.toVersion = longToBigint(reader.uint64() as Long); - continue; - case 4: - if (tag !== 34) { - break; - } - - message.sql = reader.string(); - continue; - case 5: - if (tag !== 40) { - break; - } - - message.arbitraryRange = reader.bool(); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): AptosSQLQueryRequest { - return { - network: isSet(object.network) ? globalThis.String(object.network) : "", - fromVersion: isSet(object.fromVersion) ? BigInt(object.fromVersion) : BigInt("0"), - toVersion: isSet(object.toVersion) ? BigInt(object.toVersion) : BigInt("0"), - sql: isSet(object.sql) ? globalThis.String(object.sql) : "", - arbitraryRange: isSet(object.arbitraryRange) ? globalThis.Boolean(object.arbitraryRange) : false, - }; - }, - - toJSON(message: AptosSQLQueryRequest): unknown { - const obj: any = {}; - if (message.network !== "") { - obj.network = message.network; - } - if (message.fromVersion !== BigInt("0")) { - obj.fromVersion = message.fromVersion.toString(); - } - if (message.toVersion !== BigInt("0")) { - obj.toVersion = message.toVersion.toString(); - } - if (message.sql !== "") { - obj.sql = message.sql; - } - if (message.arbitraryRange !== false) { - obj.arbitraryRange = message.arbitraryRange; - } - return obj; - }, - - create(base?: DeepPartial): AptosSQLQueryRequest { - return AptosSQLQueryRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): AptosSQLQueryRequest { - const message = createBaseAptosSQLQueryRequest(); - message.network = object.network ?? ""; - message.fromVersion = object.fromVersion ?? BigInt("0"); - message.toVersion = object.toVersion ?? BigInt("0"); - message.sql = object.sql ?? ""; - message.arbitraryRange = object.arbitraryRange ?? false; - return message; - }, -}; - -function createBaseQueryPhaseSummary(): QueryPhaseSummary { - return { name: "", timeTookMs: BigInt("0") }; -} - -export const QueryPhaseSummary = { - encode(message: QueryPhaseSummary, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.name !== "") { - writer.uint32(10).string(message.name); - } - if (message.timeTookMs !== BigInt("0")) { - if (BigInt.asUintN(64, message.timeTookMs) !== message.timeTookMs) { - throw new globalThis.Error("value provided for field message.timeTookMs of type uint64 too large"); - } - writer.uint32(16).uint64(message.timeTookMs.toString()); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): QueryPhaseSummary { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseQueryPhaseSummary(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.name = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.timeTookMs = longToBigint(reader.uint64() as Long); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): QueryPhaseSummary { - return { - name: isSet(object.name) ? globalThis.String(object.name) : "", - timeTookMs: isSet(object.timeTookMs) ? BigInt(object.timeTookMs) : BigInt("0"), - }; - }, - - toJSON(message: QueryPhaseSummary): unknown { - const obj: any = {}; - if (message.name !== "") { - obj.name = message.name; - } - if (message.timeTookMs !== BigInt("0")) { - obj.timeTookMs = message.timeTookMs.toString(); - } - return obj; - }, - - create(base?: DeepPartial): QueryPhaseSummary { - return QueryPhaseSummary.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): QueryPhaseSummary { - const message = createBaseQueryPhaseSummary(); - message.name = object.name ?? ""; - message.timeTookMs = object.timeTookMs ?? BigInt("0"); - return message; - }, -}; - -function createBaseQueryExecutionSummary(): QueryExecutionSummary { - return { - timeTookMs: BigInt("0"), - resultNumRows: undefined, - resultNumBytes: undefined, - numPartitionsWithMaterializedView: undefined, - numPartitionsWithoutMaterializedView: undefined, - numPartitions: undefined, - phases: [], - qcacheSignature: undefined, - qcacheHit: undefined, - }; -} - -export const QueryExecutionSummary = { - encode(message: QueryExecutionSummary, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.timeTookMs !== BigInt("0")) { - if (BigInt.asUintN(64, message.timeTookMs) !== message.timeTookMs) { - throw new globalThis.Error("value provided for field message.timeTookMs of type uint64 too large"); - } - writer.uint32(8).uint64(message.timeTookMs.toString()); - } - if (message.resultNumRows !== undefined) { - if (BigInt.asUintN(64, message.resultNumRows) !== message.resultNumRows) { - throw new globalThis.Error("value provided for field message.resultNumRows of type uint64 too large"); - } - writer.uint32(16).uint64(message.resultNumRows.toString()); - } - if (message.resultNumBytes !== undefined) { - if (BigInt.asUintN(64, message.resultNumBytes) !== message.resultNumBytes) { - throw new globalThis.Error("value provided for field message.resultNumBytes of type uint64 too large"); - } - writer.uint32(24).uint64(message.resultNumBytes.toString()); - } - if (message.numPartitionsWithMaterializedView !== undefined) { - if (BigInt.asUintN(64, message.numPartitionsWithMaterializedView) !== message.numPartitionsWithMaterializedView) { - throw new globalThis.Error( - "value provided for field message.numPartitionsWithMaterializedView of type uint64 too large", - ); - } - writer.uint32(32).uint64(message.numPartitionsWithMaterializedView.toString()); - } - if (message.numPartitionsWithoutMaterializedView !== undefined) { - if ( - BigInt.asUintN(64, message.numPartitionsWithoutMaterializedView) !== - message.numPartitionsWithoutMaterializedView - ) { - throw new globalThis.Error( - "value provided for field message.numPartitionsWithoutMaterializedView of type uint64 too large", - ); - } - writer.uint32(40).uint64(message.numPartitionsWithoutMaterializedView.toString()); - } - if (message.numPartitions !== undefined) { - if (BigInt.asUintN(64, message.numPartitions) !== message.numPartitions) { - throw new globalThis.Error("value provided for field message.numPartitions of type uint64 too large"); - } - writer.uint32(48).uint64(message.numPartitions.toString()); - } - for (const v of message.phases) { - QueryPhaseSummary.encode(v!, writer.uint32(58).fork()).ldelim(); - } - if (message.qcacheSignature !== undefined) { - writer.uint32(66).string(message.qcacheSignature); - } - if (message.qcacheHit !== undefined) { - writer.uint32(72).bool(message.qcacheHit); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): QueryExecutionSummary { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseQueryExecutionSummary(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 8) { - break; - } - - message.timeTookMs = longToBigint(reader.uint64() as Long); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.resultNumRows = longToBigint(reader.uint64() as Long); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.resultNumBytes = longToBigint(reader.uint64() as Long); - continue; - case 4: - if (tag !== 32) { - break; - } - - message.numPartitionsWithMaterializedView = longToBigint(reader.uint64() as Long); - continue; - case 5: - if (tag !== 40) { - break; - } - - message.numPartitionsWithoutMaterializedView = longToBigint(reader.uint64() as Long); - continue; - case 6: - if (tag !== 48) { - break; - } - - message.numPartitions = longToBigint(reader.uint64() as Long); - continue; - case 7: - if (tag !== 58) { - break; - } - - message.phases.push(QueryPhaseSummary.decode(reader, reader.uint32())); - continue; - case 8: - if (tag !== 66) { - break; - } - - message.qcacheSignature = reader.string(); - continue; - case 9: - if (tag !== 72) { - break; - } - - message.qcacheHit = reader.bool(); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): QueryExecutionSummary { - return { - timeTookMs: isSet(object.timeTookMs) ? BigInt(object.timeTookMs) : BigInt("0"), - resultNumRows: isSet(object.resultNumRows) ? BigInt(object.resultNumRows) : undefined, - resultNumBytes: isSet(object.resultNumBytes) ? BigInt(object.resultNumBytes) : undefined, - numPartitionsWithMaterializedView: isSet(object.numPartitionsWithMaterializedView) - ? BigInt(object.numPartitionsWithMaterializedView) - : undefined, - numPartitionsWithoutMaterializedView: isSet(object.numPartitionsWithoutMaterializedView) - ? BigInt(object.numPartitionsWithoutMaterializedView) - : undefined, - numPartitions: isSet(object.numPartitions) ? BigInt(object.numPartitions) : undefined, - phases: globalThis.Array.isArray(object?.phases) - ? object.phases.map((e: any) => QueryPhaseSummary.fromJSON(e)) - : [], - qcacheSignature: isSet(object.qcacheSignature) ? globalThis.String(object.qcacheSignature) : undefined, - qcacheHit: isSet(object.qcacheHit) ? globalThis.Boolean(object.qcacheHit) : undefined, - }; - }, - - toJSON(message: QueryExecutionSummary): unknown { - const obj: any = {}; - if (message.timeTookMs !== BigInt("0")) { - obj.timeTookMs = message.timeTookMs.toString(); - } - if (message.resultNumRows !== undefined) { - obj.resultNumRows = message.resultNumRows.toString(); - } - if (message.resultNumBytes !== undefined) { - obj.resultNumBytes = message.resultNumBytes.toString(); - } - if (message.numPartitionsWithMaterializedView !== undefined) { - obj.numPartitionsWithMaterializedView = message.numPartitionsWithMaterializedView.toString(); - } - if (message.numPartitionsWithoutMaterializedView !== undefined) { - obj.numPartitionsWithoutMaterializedView = message.numPartitionsWithoutMaterializedView.toString(); - } - if (message.numPartitions !== undefined) { - obj.numPartitions = message.numPartitions.toString(); - } - if (message.phases?.length) { - obj.phases = message.phases.map((e) => QueryPhaseSummary.toJSON(e)); - } - if (message.qcacheSignature !== undefined) { - obj.qcacheSignature = message.qcacheSignature; - } - if (message.qcacheHit !== undefined) { - obj.qcacheHit = message.qcacheHit; - } - return obj; - }, - - create(base?: DeepPartial): QueryExecutionSummary { - return QueryExecutionSummary.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): QueryExecutionSummary { - const message = createBaseQueryExecutionSummary(); - message.timeTookMs = object.timeTookMs ?? BigInt("0"); - message.resultNumRows = object.resultNumRows ?? undefined; - message.resultNumBytes = object.resultNumBytes ?? undefined; - message.numPartitionsWithMaterializedView = object.numPartitionsWithMaterializedView ?? undefined; - message.numPartitionsWithoutMaterializedView = object.numPartitionsWithoutMaterializedView ?? undefined; - message.numPartitions = object.numPartitions ?? undefined; - message.phases = object.phases?.map((e) => QueryPhaseSummary.fromPartial(e)) || []; - message.qcacheSignature = object.qcacheSignature ?? undefined; - message.qcacheHit = object.qcacheHit ?? undefined; - return message; - }, -}; - -function createBaseAptosGetTxnsResponse(): AptosGetTxnsResponse { - return { documents: [], executionSummary: undefined }; -} - -export const AptosGetTxnsResponse = { - encode(message: AptosGetTxnsResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - for (const v of message.documents) { - writer.uint32(10).bytes(v!); - } - if (message.executionSummary !== undefined) { - QueryExecutionSummary.encode(message.executionSummary, writer.uint32(18).fork()).ldelim(); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): AptosGetTxnsResponse { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseAptosGetTxnsResponse(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.documents.push(reader.bytes()); - continue; - case 2: - if (tag !== 18) { - break; - } - - message.executionSummary = QueryExecutionSummary.decode(reader, reader.uint32()); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): AptosGetTxnsResponse { - return { - documents: globalThis.Array.isArray(object?.documents) - ? object.documents.map((e: any) => bytesFromBase64(e)) - : [], - executionSummary: isSet(object.executionSummary) - ? QueryExecutionSummary.fromJSON(object.executionSummary) - : undefined, - }; - }, - - toJSON(message: AptosGetTxnsResponse): unknown { - const obj: any = {}; - if (message.documents?.length) { - obj.documents = message.documents.map((e) => base64FromBytes(e)); - } - if (message.executionSummary !== undefined) { - obj.executionSummary = QueryExecutionSummary.toJSON(message.executionSummary); - } - return obj; - }, - - create(base?: DeepPartial): AptosGetTxnsResponse { - return AptosGetTxnsResponse.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): AptosGetTxnsResponse { - const message = createBaseAptosGetTxnsResponse(); - message.documents = object.documents?.map((e) => e) || []; - message.executionSummary = (object.executionSummary !== undefined && object.executionSummary !== null) - ? QueryExecutionSummary.fromPartial(object.executionSummary) - : undefined; - return message; - }, -}; - -function createBaseAptosRefreshRequest(): AptosRefreshRequest { - return {}; -} - -export const AptosRefreshRequest = { - encode(_: AptosRefreshRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): AptosRefreshRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseAptosRefreshRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(_: any): AptosRefreshRequest { - return {}; - }, - - toJSON(_: AptosRefreshRequest): unknown { - const obj: any = {}; - return obj; - }, - - create(base?: DeepPartial): AptosRefreshRequest { - return AptosRefreshRequest.fromPartial(base ?? {}); - }, - fromPartial(_: DeepPartial): AptosRefreshRequest { - const message = createBaseAptosRefreshRequest(); - return message; - }, -}; - -function createBaseVoidResponse(): VoidResponse { - return {}; -} - -export const VoidResponse = { - encode(_: VoidResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): VoidResponse { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseVoidResponse(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(_: any): VoidResponse { - return {}; - }, - - toJSON(_: VoidResponse): unknown { - const obj: any = {}; - return obj; - }, - - create(base?: DeepPartial): VoidResponse { - return VoidResponse.fromPartial(base ?? {}); - }, - fromPartial(_: DeepPartial): VoidResponse { - const message = createBaseVoidResponse(); - return message; - }, -}; - -function createBaseEvmSQLQueryRequest(): EvmSQLQueryRequest { - return { network: "", sql: "", nocache: undefined }; -} - -export const EvmSQLQueryRequest = { - encode(message: EvmSQLQueryRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.network !== "") { - writer.uint32(10).string(message.network); - } - if (message.sql !== "") { - writer.uint32(18).string(message.sql); - } - if (message.nocache !== undefined) { - writer.uint32(24).bool(message.nocache); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): EvmSQLQueryRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseEvmSQLQueryRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.network = reader.string(); - continue; - case 2: - if (tag !== 18) { - break; - } - - message.sql = reader.string(); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.nocache = reader.bool(); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): EvmSQLQueryRequest { - return { - network: isSet(object.network) ? globalThis.String(object.network) : "", - sql: isSet(object.sql) ? globalThis.String(object.sql) : "", - nocache: isSet(object.nocache) ? globalThis.Boolean(object.nocache) : undefined, - }; - }, - - toJSON(message: EvmSQLQueryRequest): unknown { - const obj: any = {}; - if (message.network !== "") { - obj.network = message.network; - } - if (message.sql !== "") { - obj.sql = message.sql; - } - if (message.nocache !== undefined) { - obj.nocache = message.nocache; - } - return obj; - }, - - create(base?: DeepPartial): EvmSQLQueryRequest { - return EvmSQLQueryRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): EvmSQLQueryRequest { - const message = createBaseEvmSQLQueryRequest(); - message.network = object.network ?? ""; - message.sql = object.sql ?? ""; - message.nocache = object.nocache ?? undefined; - return message; - }, -}; - -function createBaseEvmGetHeaderRequest(): EvmGetHeaderRequest { - return { network: "", fromBlock: undefined, toBlock: undefined, blockNumbers: [] }; -} - -export const EvmGetHeaderRequest = { - encode(message: EvmGetHeaderRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.network !== "") { - writer.uint32(10).string(message.network); - } - if (message.fromBlock !== undefined) { - if (BigInt.asUintN(64, message.fromBlock) !== message.fromBlock) { - throw new globalThis.Error("value provided for field message.fromBlock of type uint64 too large"); - } - writer.uint32(16).uint64(message.fromBlock.toString()); - } - if (message.toBlock !== undefined) { - if (BigInt.asUintN(64, message.toBlock) !== message.toBlock) { - throw new globalThis.Error("value provided for field message.toBlock of type uint64 too large"); - } - writer.uint32(24).uint64(message.toBlock.toString()); - } - writer.uint32(34).fork(); - for (const v of message.blockNumbers) { - if (BigInt.asUintN(64, v) !== v) { - throw new globalThis.Error("a value provided in array field blockNumbers of type uint64 is too large"); - } - writer.uint64(v.toString()); - } - writer.ldelim(); - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): EvmGetHeaderRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseEvmGetHeaderRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.network = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.fromBlock = longToBigint(reader.uint64() as Long); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.toBlock = longToBigint(reader.uint64() as Long); - continue; - case 4: - if (tag === 32) { - message.blockNumbers.push(longToBigint(reader.uint64() as Long)); - - continue; - } - - if (tag === 34) { - const end2 = reader.uint32() + reader.pos; - while (reader.pos < end2) { - message.blockNumbers.push(longToBigint(reader.uint64() as Long)); - } - - continue; - } - - break; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): EvmGetHeaderRequest { - return { - network: isSet(object.network) ? globalThis.String(object.network) : "", - fromBlock: isSet(object.fromBlock) ? BigInt(object.fromBlock) : undefined, - toBlock: isSet(object.toBlock) ? BigInt(object.toBlock) : undefined, - blockNumbers: globalThis.Array.isArray(object?.blockNumbers) - ? object.blockNumbers.map((e: any) => BigInt(e)) - : [], - }; - }, - - toJSON(message: EvmGetHeaderRequest): unknown { - const obj: any = {}; - if (message.network !== "") { - obj.network = message.network; - } - if (message.fromBlock !== undefined) { - obj.fromBlock = message.fromBlock.toString(); - } - if (message.toBlock !== undefined) { - obj.toBlock = message.toBlock.toString(); - } - if (message.blockNumbers?.length) { - obj.blockNumbers = message.blockNumbers.map((e) => e.toString()); - } - return obj; - }, - - create(base?: DeepPartial): EvmGetHeaderRequest { - return EvmGetHeaderRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): EvmGetHeaderRequest { - const message = createBaseEvmGetHeaderRequest(); - message.network = object.network ?? ""; - message.fromBlock = object.fromBlock ?? undefined; - message.toBlock = object.toBlock ?? undefined; - message.blockNumbers = object.blockNumbers?.map((e) => e) || []; - return message; - }, -}; - -function createBaseEvmQueryResponse(): EvmQueryResponse { - return { rows: [], executionSummary: undefined }; -} - -export const EvmQueryResponse = { - encode(message: EvmQueryResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - for (const v of message.rows) { - writer.uint32(10).bytes(v!); - } - if (message.executionSummary !== undefined) { - QueryExecutionSummary.encode(message.executionSummary, writer.uint32(18).fork()).ldelim(); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): EvmQueryResponse { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseEvmQueryResponse(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.rows.push(reader.bytes()); - continue; - case 2: - if (tag !== 18) { - break; - } - - message.executionSummary = QueryExecutionSummary.decode(reader, reader.uint32()); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): EvmQueryResponse { - return { - rows: globalThis.Array.isArray(object?.rows) ? object.rows.map((e: any) => bytesFromBase64(e)) : [], - executionSummary: isSet(object.executionSummary) - ? QueryExecutionSummary.fromJSON(object.executionSummary) - : undefined, - }; - }, - - toJSON(message: EvmQueryResponse): unknown { - const obj: any = {}; - if (message.rows?.length) { - obj.rows = message.rows.map((e) => base64FromBytes(e)); - } - if (message.executionSummary !== undefined) { - obj.executionSummary = QueryExecutionSummary.toJSON(message.executionSummary); - } - return obj; - }, - - create(base?: DeepPartial): EvmQueryResponse { - return EvmQueryResponse.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): EvmQueryResponse { - const message = createBaseEvmQueryResponse(); - message.rows = object.rows?.map((e) => e) || []; - message.executionSummary = (object.executionSummary !== undefined && object.executionSummary !== null) - ? QueryExecutionSummary.fromPartial(object.executionSummary) - : undefined; - return message; - }, -}; - -function createBaseSuiGetCheckpointTimeRequest(): SuiGetCheckpointTimeRequest { - return { network: "", checkpointSequenceNumber: BigInt("0") }; -} - -export const SuiGetCheckpointTimeRequest = { - encode(message: SuiGetCheckpointTimeRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.network !== "") { - writer.uint32(10).string(message.network); - } - if (message.checkpointSequenceNumber !== BigInt("0")) { - if (BigInt.asUintN(64, message.checkpointSequenceNumber) !== message.checkpointSequenceNumber) { - throw new globalThis.Error( - "value provided for field message.checkpointSequenceNumber of type uint64 too large", - ); - } - writer.uint32(16).uint64(message.checkpointSequenceNumber.toString()); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): SuiGetCheckpointTimeRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseSuiGetCheckpointTimeRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.network = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.checkpointSequenceNumber = longToBigint(reader.uint64() as Long); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): SuiGetCheckpointTimeRequest { - return { - network: isSet(object.network) ? globalThis.String(object.network) : "", - checkpointSequenceNumber: isSet(object.checkpointSequenceNumber) - ? BigInt(object.checkpointSequenceNumber) - : BigInt("0"), - }; - }, - - toJSON(message: SuiGetCheckpointTimeRequest): unknown { - const obj: any = {}; - if (message.network !== "") { - obj.network = message.network; - } - if (message.checkpointSequenceNumber !== BigInt("0")) { - obj.checkpointSequenceNumber = message.checkpointSequenceNumber.toString(); - } - return obj; - }, - - create(base?: DeepPartial): SuiGetCheckpointTimeRequest { - return SuiGetCheckpointTimeRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): SuiGetCheckpointTimeRequest { - const message = createBaseSuiGetCheckpointTimeRequest(); - message.network = object.network ?? ""; - message.checkpointSequenceNumber = object.checkpointSequenceNumber ?? BigInt("0"); - return message; - }, -}; - -function createBaseSuiGetCheckpointTimeResponse(): SuiGetCheckpointTimeResponse { - return { - checkpointTimestampMs: undefined, - transactionMinTimestampMs: undefined, - transactionMaxTimestampMs: undefined, - }; -} - -export const SuiGetCheckpointTimeResponse = { - encode(message: SuiGetCheckpointTimeResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.checkpointTimestampMs !== undefined) { - if (BigInt.asUintN(64, message.checkpointTimestampMs) !== message.checkpointTimestampMs) { - throw new globalThis.Error("value provided for field message.checkpointTimestampMs of type uint64 too large"); - } - writer.uint32(8).uint64(message.checkpointTimestampMs.toString()); - } - if (message.transactionMinTimestampMs !== undefined) { - if (BigInt.asUintN(64, message.transactionMinTimestampMs) !== message.transactionMinTimestampMs) { - throw new globalThis.Error( - "value provided for field message.transactionMinTimestampMs of type uint64 too large", - ); - } - writer.uint32(16).uint64(message.transactionMinTimestampMs.toString()); - } - if (message.transactionMaxTimestampMs !== undefined) { - if (BigInt.asUintN(64, message.transactionMaxTimestampMs) !== message.transactionMaxTimestampMs) { - throw new globalThis.Error( - "value provided for field message.transactionMaxTimestampMs of type uint64 too large", - ); - } - writer.uint32(24).uint64(message.transactionMaxTimestampMs.toString()); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): SuiGetCheckpointTimeResponse { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseSuiGetCheckpointTimeResponse(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 8) { - break; - } - - message.checkpointTimestampMs = longToBigint(reader.uint64() as Long); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.transactionMinTimestampMs = longToBigint(reader.uint64() as Long); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.transactionMaxTimestampMs = longToBigint(reader.uint64() as Long); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): SuiGetCheckpointTimeResponse { - return { - checkpointTimestampMs: isSet(object.checkpointTimestampMs) ? BigInt(object.checkpointTimestampMs) : undefined, - transactionMinTimestampMs: isSet(object.transactionMinTimestampMs) - ? BigInt(object.transactionMinTimestampMs) - : undefined, - transactionMaxTimestampMs: isSet(object.transactionMaxTimestampMs) - ? BigInt(object.transactionMaxTimestampMs) - : undefined, - }; - }, - - toJSON(message: SuiGetCheckpointTimeResponse): unknown { - const obj: any = {}; - if (message.checkpointTimestampMs !== undefined) { - obj.checkpointTimestampMs = message.checkpointTimestampMs.toString(); - } - if (message.transactionMinTimestampMs !== undefined) { - obj.transactionMinTimestampMs = message.transactionMinTimestampMs.toString(); - } - if (message.transactionMaxTimestampMs !== undefined) { - obj.transactionMaxTimestampMs = message.transactionMaxTimestampMs.toString(); - } - return obj; - }, - - create(base?: DeepPartial): SuiGetCheckpointTimeResponse { - return SuiGetCheckpointTimeResponse.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): SuiGetCheckpointTimeResponse { - const message = createBaseSuiGetCheckpointTimeResponse(); - message.checkpointTimestampMs = object.checkpointTimestampMs ?? undefined; - message.transactionMinTimestampMs = object.transactionMinTimestampMs ?? undefined; - message.transactionMaxTimestampMs = object.transactionMaxTimestampMs ?? undefined; - return message; - }, -}; - -function createBaseRemoteResultRequest(): RemoteResultRequest { - return { token: "", position: 0, keepAlive: false }; -} - -export const RemoteResultRequest = { - encode(message: RemoteResultRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - if (message.token !== "") { - writer.uint32(10).string(message.token); - } - if (message.position !== 0) { - writer.uint32(16).int32(message.position); - } - if (message.keepAlive !== false) { - writer.uint32(24).bool(message.keepAlive); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): RemoteResultRequest { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseRemoteResultRequest(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.token = reader.string(); - continue; - case 2: - if (tag !== 16) { - break; - } - - message.position = reader.int32(); - continue; - case 3: - if (tag !== 24) { - break; - } - - message.keepAlive = reader.bool(); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): RemoteResultRequest { - return { - token: isSet(object.token) ? globalThis.String(object.token) : "", - position: isSet(object.position) ? globalThis.Number(object.position) : 0, - keepAlive: isSet(object.keepAlive) ? globalThis.Boolean(object.keepAlive) : false, - }; - }, - - toJSON(message: RemoteResultRequest): unknown { - const obj: any = {}; - if (message.token !== "") { - obj.token = message.token; - } - if (message.position !== 0) { - obj.position = Math.round(message.position); - } - if (message.keepAlive !== false) { - obj.keepAlive = message.keepAlive; - } - return obj; - }, - - create(base?: DeepPartial): RemoteResultRequest { - return RemoteResultRequest.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): RemoteResultRequest { - const message = createBaseRemoteResultRequest(); - message.token = object.token ?? ""; - message.position = object.position ?? 0; - message.keepAlive = object.keepAlive ?? false; - return message; - }, -}; - -function createBaseRemoteResultResponse(): RemoteResultResponse { - return { rows: [] }; -} - -export const RemoteResultResponse = { - encode(message: RemoteResultResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer { - for (const v of message.rows) { - writer.uint32(10).bytes(v!); - } - return writer; - }, - - decode(input: _m0.Reader | Uint8Array, length?: number): RemoteResultResponse { - const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input); - let end = length === undefined ? reader.len : reader.pos + length; - const message = createBaseRemoteResultResponse(); - while (reader.pos < end) { - const tag = reader.uint32(); - switch (tag >>> 3) { - case 1: - if (tag !== 10) { - break; - } - - message.rows.push(reader.bytes()); - continue; - } - if ((tag & 7) === 4 || tag === 0) { - break; - } - reader.skipType(tag & 7); - } - return message; - }, - - fromJSON(object: any): RemoteResultResponse { - return { rows: globalThis.Array.isArray(object?.rows) ? object.rows.map((e: any) => bytesFromBase64(e)) : [] }; - }, - - toJSON(message: RemoteResultResponse): unknown { - const obj: any = {}; - if (message.rows?.length) { - obj.rows = message.rows.map((e) => base64FromBytes(e)); - } - return obj; - }, - - create(base?: DeepPartial): RemoteResultResponse { - return RemoteResultResponse.fromPartial(base ?? {}); - }, - fromPartial(object: DeepPartial): RemoteResultResponse { - const message = createBaseRemoteResultResponse(); - message.rows = object.rows?.map((e) => e) || []; - return message; - }, -}; - -export type AptosQueryDefinition = typeof AptosQueryDefinition; -export const AptosQueryDefinition = { - name: "AptosQuery", - fullName: "chainquery.AptosQuery", - methods: { - aptosGetTxnsByFunction: { - name: "AptosGetTxnsByFunction", - requestType: AptosGetTxnsByFunctionRequest, - requestStream: false, - responseType: AptosGetTxnsResponse, - responseStream: false, - options: {}, - }, - aptosGetTxnsByFunctionStream: { - name: "AptosGetTxnsByFunctionStream", - requestType: AptosGetTxnsByFunctionRequest, - requestStream: false, - responseType: AptosGetTxnsResponse, - responseStream: true, - options: {}, - }, - aptosGetTxnsByVersion: { - name: "AptosGetTxnsByVersion", - requestType: AptosGetTxnsByVersionRequest, - requestStream: false, - responseType: AptosGetTxnsResponse, - responseStream: false, - options: {}, - }, - aptosGetTxnsByEvent: { - name: "AptosGetTxnsByEvent", - requestType: AptosGetTxnsByEventRequest, - requestStream: false, - responseType: AptosGetTxnsResponse, - responseStream: false, - options: {}, - }, - aptosGetTxnsByEventStream: { - name: "AptosGetTxnsByEventStream", - requestType: AptosGetTxnsByEventRequest, - requestStream: false, - responseType: AptosGetTxnsResponse, - responseStream: true, - options: {}, - }, - aptosRefresh: { - name: "AptosRefresh", - requestType: AptosRefreshRequest, - requestStream: false, - responseType: VoidResponse, - responseStream: false, - options: {}, - }, - aptosSQLQuery: { - name: "AptosSQLQuery", - requestType: AptosSQLQueryRequest, - requestStream: false, - responseType: AptosGetTxnsResponse, - responseStream: false, - options: {}, - }, - }, -} as const; - -export interface AptosQueryServiceImplementation { - aptosGetTxnsByFunction( - request: AptosGetTxnsByFunctionRequest, - context: CallContext & CallContextExt, - ): Promise>; - aptosGetTxnsByFunctionStream( - request: AptosGetTxnsByFunctionRequest, - context: CallContext & CallContextExt, - ): ServerStreamingMethodResult>; - aptosGetTxnsByVersion( - request: AptosGetTxnsByVersionRequest, - context: CallContext & CallContextExt, - ): Promise>; - aptosGetTxnsByEvent( - request: AptosGetTxnsByEventRequest, - context: CallContext & CallContextExt, - ): Promise>; - aptosGetTxnsByEventStream( - request: AptosGetTxnsByEventRequest, - context: CallContext & CallContextExt, - ): ServerStreamingMethodResult>; - aptosRefresh(request: AptosRefreshRequest, context: CallContext & CallContextExt): Promise>; - aptosSQLQuery( - request: AptosSQLQueryRequest, - context: CallContext & CallContextExt, - ): Promise>; -} - -export interface AptosQueryClient { - aptosGetTxnsByFunction( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; - aptosGetTxnsByFunctionStream( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): AsyncIterable; - aptosGetTxnsByVersion( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; - aptosGetTxnsByEvent( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; - aptosGetTxnsByEventStream( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): AsyncIterable; - aptosRefresh( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; - aptosSQLQuery( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; -} - -export type EvmQueryDefinition = typeof EvmQueryDefinition; -export const EvmQueryDefinition = { - name: "EvmQuery", - fullName: "chainquery.EvmQuery", - methods: { - evmSQLQuery: { - name: "EvmSQLQuery", - requestType: EvmSQLQueryRequest, - requestStream: false, - responseType: EvmQueryResponse, - responseStream: true, - options: {}, - }, - evmGetHeader: { - name: "EvmGetHeader", - requestType: EvmGetHeaderRequest, - requestStream: false, - responseType: EvmQueryResponse, - responseStream: false, - options: {}, - }, - evmHintHeaderCache: { - name: "EvmHintHeaderCache", - requestType: EvmGetHeaderRequest, - requestStream: false, - responseType: VoidResponse, - responseStream: false, - options: {}, - }, - }, -} as const; - -export interface EvmQueryServiceImplementation { - evmSQLQuery( - request: EvmSQLQueryRequest, - context: CallContext & CallContextExt, - ): ServerStreamingMethodResult>; - evmGetHeader( - request: EvmGetHeaderRequest, - context: CallContext & CallContextExt, - ): Promise>; - evmHintHeaderCache( - request: EvmGetHeaderRequest, - context: CallContext & CallContextExt, - ): Promise>; -} - -export interface EvmQueryClient { - evmSQLQuery( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): AsyncIterable; - evmGetHeader( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; - evmHintHeaderCache( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; -} - -export type SuiQueryDefinition = typeof SuiQueryDefinition; -export const SuiQueryDefinition = { - name: "SuiQuery", - fullName: "chainquery.SuiQuery", - methods: { - suiSQLQuery: { - name: "SuiSQLQuery", - requestType: EvmSQLQueryRequest, - requestStream: false, - responseType: EvmQueryResponse, - responseStream: true, - options: {}, - }, - getCheckpointTime: { - name: "GetCheckpointTime", - requestType: SuiGetCheckpointTimeRequest, - requestStream: false, - responseType: SuiGetCheckpointTimeResponse, - responseStream: false, - options: {}, - }, - }, -} as const; - -export interface SuiQueryServiceImplementation { - suiSQLQuery( - request: EvmSQLQueryRequest, - context: CallContext & CallContextExt, - ): ServerStreamingMethodResult>; - getCheckpointTime( - request: SuiGetCheckpointTimeRequest, - context: CallContext & CallContextExt, - ): Promise>; -} - -export interface SuiQueryClient { - suiSQLQuery( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): AsyncIterable; - getCheckpointTime( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; -} - -export type RemoteResultTransferServiceDefinition = typeof RemoteResultTransferServiceDefinition; -export const RemoteResultTransferServiceDefinition = { - name: "RemoteResultTransferService", - fullName: "chainquery.RemoteResultTransferService", - methods: { - getResult: { - name: "GetResult", - requestType: RemoteResultRequest, - requestStream: false, - responseType: RemoteResultResponse, - responseStream: false, - options: {}, - }, - destroyResult: { - name: "DestroyResult", - requestType: RemoteResultRequest, - requestStream: false, - responseType: VoidResponse, - responseStream: false, - options: {}, - }, - }, -} as const; - -export interface RemoteResultTransferServiceImplementation { - getResult( - request: RemoteResultRequest, - context: CallContext & CallContextExt, - ): Promise>; - destroyResult( - request: RemoteResultRequest, - context: CallContext & CallContextExt, - ): Promise>; -} - -export interface RemoteResultTransferServiceClient { - getResult( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; - destroyResult( - request: DeepPartial, - options?: CallOptions & CallOptionsExt, - ): Promise; -} - -function bytesFromBase64(b64: string): Uint8Array { - if ((globalThis as any).Buffer) { - return Uint8Array.from(globalThis.Buffer.from(b64, "base64")); - } else { - const bin = globalThis.atob(b64); - const arr = new Uint8Array(bin.length); - for (let i = 0; i < bin.length; ++i) { - arr[i] = bin.charCodeAt(i); - } - return arr; - } -} - -function base64FromBytes(arr: Uint8Array): string { - if ((globalThis as any).Buffer) { - return globalThis.Buffer.from(arr).toString("base64"); - } else { - const bin: string[] = []; - arr.forEach((byte) => { - bin.push(globalThis.String.fromCharCode(byte)); - }); - return globalThis.btoa(bin.join("")); - } -} - -type Builtin = Date | Function | Uint8Array | string | number | boolean | bigint | undefined; - -type DeepPartial = T extends Builtin ? T - : T extends globalThis.Array ? globalThis.Array> - : T extends ReadonlyArray ? ReadonlyArray> - : T extends {} ? { [K in keyof T]?: DeepPartial } - : Partial; - -function longToBigint(long: Long) { - return BigInt(long.toString()); -} - -if (_m0.util.Long !== Long) { - _m0.util.Long = Long as any; - _m0.configure(); -} - -function isSet(value: any): boolean { - return value !== null && value !== undefined; -} - -export type ServerStreamingMethodResult = { [Symbol.asyncIterator](): AsyncIterator }; diff --git a/packages/runtime/src/endpoints.ts b/packages/runtime/src/endpoints.ts index 0415fa0976..ca9eb3ded6 100644 --- a/packages/runtime/src/endpoints.ts +++ b/packages/runtime/src/endpoints.ts @@ -2,7 +2,6 @@ export class Endpoints { static INSTANCE: Endpoints = new Endpoints() concurrency = 8 - chainQueryAPI = '' priceFeedAPI = '' chainServer = new Map() diff --git a/packages/runtime/src/processor-runner.ts b/packages/runtime/src/processor-runner.ts index 4164dfc415..dbe5399bb8 100644 --- a/packages/runtime/src/processor-runner.ts +++ b/packages/runtime/src/processor-runner.ts @@ -37,7 +37,6 @@ const optionDefinitions = [ type: String, defaultValue: 'chains-config.json' }, - { name: 'chainquery-server', type: String, defaultValue: '' }, { name: 'pricefeed-server', type: String, defaultValue: '' }, { name: 'log-format', type: String, defaultValue: 'console' }, { name: 'debug', type: Boolean, defaultValue: false }, @@ -67,7 +66,6 @@ const batchCountOverride = process.env['OVERRIDE_BATCH_COUNT'] Endpoints.INSTANCE.concurrency = concurrencyOverride ?? options.concurrency Endpoints.INSTANCE.batchCount = batchCountOverride ?? options['batch-count'] -Endpoints.INSTANCE.chainQueryAPI = options['chainquery-server'] Endpoints.INSTANCE.priceFeedAPI = options['pricefeed-server'] for (const [id, config] of Object.entries(chainsConfig)) {