Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ clean-all:
$(call clean_repos)

clone-injective-indexer:
git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.20.89 --depth 1 --single-branch
git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.20.167 --depth 1 --single-branch

clone-all: clone-injective-indexer

Expand Down
6 changes: 3 additions & 3 deletions buf.gen.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,13 @@ inputs:
- git_repo: https://github.com/InjectiveLabs/ibc-go
tag: v8.7.0-inj.4
- git_repo: https://github.com/InjectiveLabs/wasmd
tag: v0.53.3-inj.3
tag: v0.54.10-inj.2
- git_repo: https://github.com/InjectiveLabs/cometbft
tag: v1.0.1-inj.9
- git_repo: https://github.com/InjectiveLabs/cosmos-sdk
tag: v0.50.14-inj.11
tag: v0.50.15-inj.1
- git_repo: https://github.com/InjectiveLabs/injective-core
tag: v1.20.3
tag: v1.20.4-beta
subdir: proto
# - git_repo: https://github.com/InjectiveLabs/injective-core
# branch: c-655/add_chainlink_data_streams_oracle
Expand Down
76 changes: 49 additions & 27 deletions pyinjective/proto/cosmwasm/wasm/v1/query_pb2.py

Large diffs are not rendered by default.

91 changes: 90 additions & 1 deletion pyinjective/proto/cosmwasm/wasm/v1/query_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,11 @@ def __init__(self, channel):
request_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodesRequest.SerializeToString,
response_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodesResponse.FromString,
_registered_method=True)
self.CodeInfo = channel.unary_unary(
'/cosmwasm.wasm.v1.Query/CodeInfo',
request_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodeInfoRequest.SerializeToString,
response_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodeInfoResponse.FromString,
_registered_method=True)
self.PinnedCodes = channel.unary_unary(
'/cosmwasm.wasm.v1.Query/PinnedCodes',
request_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryPinnedCodesRequest.SerializeToString,
Expand All @@ -70,6 +75,11 @@ def __init__(self, channel):
request_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryContractsByCreatorRequest.SerializeToString,
response_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryContractsByCreatorResponse.FromString,
_registered_method=True)
self.WasmLimitsConfig = channel.unary_unary(
'/cosmwasm.wasm.v1.Query/WasmLimitsConfig',
request_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryWasmLimitsConfigRequest.SerializeToString,
response_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryWasmLimitsConfigResponse.FromString,
_registered_method=True)
self.BuildAddress = channel.unary_unary(
'/cosmwasm.wasm.v1.Query/BuildAddress',
request_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryBuildAddressRequest.SerializeToString,
Expand Down Expand Up @@ -124,7 +134,7 @@ def SmartContractState(self, request, context):
raise NotImplementedError('Method not implemented!')

def Code(self, request, context):
"""Code gets the binary code and metadata for a singe wasm code
"""Code gets the binary code and metadata for a single wasm code
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
Expand All @@ -137,6 +147,13 @@ def Codes(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def CodeInfo(self, request, context):
"""CodeInfo gets the metadata for a single wasm code
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def PinnedCodes(self, request, context):
"""PinnedCodes gets the pinned code ids
"""
Expand All @@ -158,6 +175,14 @@ def ContractsByCreator(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def WasmLimitsConfig(self, request, context):
"""WasmLimitsConfig gets the configured limits for static validation of Wasm
files, encoded in JSON.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def BuildAddress(self, request, context):
"""BuildAddress builds a contract address
"""
Expand Down Expand Up @@ -208,6 +233,11 @@ def add_QueryServicer_to_server(servicer, server):
request_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodesRequest.FromString,
response_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodesResponse.SerializeToString,
),
'CodeInfo': grpc.unary_unary_rpc_method_handler(
servicer.CodeInfo,
request_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodeInfoRequest.FromString,
response_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodeInfoResponse.SerializeToString,
),
'PinnedCodes': grpc.unary_unary_rpc_method_handler(
servicer.PinnedCodes,
request_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryPinnedCodesRequest.FromString,
Expand All @@ -223,6 +253,11 @@ def add_QueryServicer_to_server(servicer, server):
request_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryContractsByCreatorRequest.FromString,
response_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryContractsByCreatorResponse.SerializeToString,
),
'WasmLimitsConfig': grpc.unary_unary_rpc_method_handler(
servicer.WasmLimitsConfig,
request_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryWasmLimitsConfigRequest.FromString,
response_serializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryWasmLimitsConfigResponse.SerializeToString,
),
'BuildAddress': grpc.unary_unary_rpc_method_handler(
servicer.BuildAddress,
request_deserializer=cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryBuildAddressRequest.FromString,
Expand Down Expand Up @@ -456,6 +491,33 @@ def Codes(request,
metadata,
_registered_method=True)

@staticmethod
def CodeInfo(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/cosmwasm.wasm.v1.Query/CodeInfo',
cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodeInfoRequest.SerializeToString,
cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryCodeInfoResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def PinnedCodes(request,
target,
Expand Down Expand Up @@ -537,6 +599,33 @@ def ContractsByCreator(request,
metadata,
_registered_method=True)

@staticmethod
def WasmLimitsConfig(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/cosmwasm.wasm.v1.Query/WasmLimitsConfig',
cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryWasmLimitsConfigRequest.SerializeToString,
cosmwasm_dot_wasm_dot_v1_dot_query__pb2.QueryWasmLimitsConfigResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def BuildAddress(request,
target,
Expand Down
26 changes: 23 additions & 3 deletions pyinjective/proto/exchange/injective_exchange_rpc_pb2.py

Large diffs are not rendered by default.

45 changes: 45 additions & 0 deletions pyinjective/proto/exchange/injective_exchange_rpc_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,11 @@ def __init__(self, channel):
request_serializer=exchange_dot_injective__exchange__rpc__pb2.PrepareFeeGrantRequest.SerializeToString,
response_deserializer=exchange_dot_injective__exchange__rpc__pb2.PrepareFeeGrantResponse.FromString,
_registered_method=True)
self.PrepareTxPrerequisites = channel.unary_unary(
'/injective_exchange_rpc.InjectiveExchangeRPC/PrepareTxPrerequisites',
request_serializer=exchange_dot_injective__exchange__rpc__pb2.PrepareTxPrerequisitesRequest.SerializeToString,
response_deserializer=exchange_dot_injective__exchange__rpc__pb2.PrepareTxPrerequisitesResponse.FromString,
_registered_method=True)


class InjectiveExchangeRPCServicer(object):
Expand Down Expand Up @@ -117,6 +122,14 @@ def PrepareFeeGrant(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def PrepareTxPrerequisites(self, request, context):
"""PrepareTxPrerequisites returns generic chain observations needed to
construct a transaction
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')


def add_InjectiveExchangeRPCServicer_to_server(servicer, server):
rpc_method_handlers = {
Expand Down Expand Up @@ -160,6 +173,11 @@ def add_InjectiveExchangeRPCServicer_to_server(servicer, server):
request_deserializer=exchange_dot_injective__exchange__rpc__pb2.PrepareFeeGrantRequest.FromString,
response_serializer=exchange_dot_injective__exchange__rpc__pb2.PrepareFeeGrantResponse.SerializeToString,
),
'PrepareTxPrerequisites': grpc.unary_unary_rpc_method_handler(
servicer.PrepareTxPrerequisites,
request_deserializer=exchange_dot_injective__exchange__rpc__pb2.PrepareTxPrerequisitesRequest.FromString,
response_serializer=exchange_dot_injective__exchange__rpc__pb2.PrepareTxPrerequisitesResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'injective_exchange_rpc.InjectiveExchangeRPC', rpc_method_handlers)
Expand Down Expand Up @@ -387,3 +405,30 @@ def PrepareFeeGrant(request,
timeout,
metadata,
_registered_method=True)

@staticmethod
def PrepareTxPrerequisites(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/injective_exchange_rpc.InjectiveExchangeRPC/PrepareTxPrerequisites',
exchange_dot_injective__exchange__rpc__pb2.PrepareTxPrerequisitesRequest.SerializeToString,
exchange_dot_injective__exchange__rpc__pb2.PrepareTxPrerequisitesResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
34 changes: 19 additions & 15 deletions pyinjective/proto/exchange/injective_explorer_rpc_pb2.py

Large diffs are not rendered by default.

44 changes: 44 additions & 0 deletions pyinjective/proto/exchange/injective_explorer_rpc_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -130,6 +130,11 @@ def __init__(self, channel):
request_serializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersRequest.SerializeToString,
response_deserializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersResponse.FromString,
_registered_method=True)
self.GetBankTransfersV2 = channel.unary_unary(
'/injective_explorer_rpc.InjectiveExplorerRPC/GetBankTransfersV2',
request_serializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersV2Request.SerializeToString,
response_deserializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersV2Response.FromString,
_registered_method=True)
self.StreamTxs = channel.unary_stream(
'/injective_explorer_rpc.InjectiveExplorerRPC/StreamTxs',
request_serializer=exchange_dot_injective__explorer__rpc__pb2.StreamTxsRequest.SerializeToString,
Expand Down Expand Up @@ -320,6 +325,13 @@ def GetBankTransfers(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def GetBankTransfersV2(self, request, context):
"""GetBankTransfersV2 returns bank transfers using cursor pagination.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def StreamTxs(self, request, context):
"""StreamTxs returns transactions based upon the request params
"""
Expand Down Expand Up @@ -459,6 +471,11 @@ def add_InjectiveExplorerRPCServicer_to_server(servicer, server):
request_deserializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersRequest.FromString,
response_serializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersResponse.SerializeToString,
),
'GetBankTransfersV2': grpc.unary_unary_rpc_method_handler(
servicer.GetBankTransfersV2,
request_deserializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersV2Request.FromString,
response_serializer=exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersV2Response.SerializeToString,
),
'StreamTxs': grpc.unary_stream_rpc_method_handler(
servicer.StreamTxs,
request_deserializer=exchange_dot_injective__explorer__rpc__pb2.StreamTxsRequest.FromString,
Expand Down Expand Up @@ -1107,6 +1124,33 @@ def GetBankTransfers(request,
metadata,
_registered_method=True)

@staticmethod
def GetBankTransfersV2(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/injective_explorer_rpc.InjectiveExplorerRPC/GetBankTransfersV2',
exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersV2Request.SerializeToString,
exchange_dot_injective__explorer__rpc__pb2.GetBankTransfersV2Response.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def StreamTxs(request,
target,
Expand Down
Loading
Loading