Skip to content

Commit 72407b4

Browse files
aarmoaaarmoa
authored
Merge pull request #318 from InjectiveLabs/feat/ibc_core_channel_module_queries
feat/ibc_core_channel_module_queries
2 parents 3165d58 + 5207456 commit 72407b4

38 files changed

Lines changed: 1464 additions & 9 deletions

‎examples/chain_client/ibc/channel/query/10_PacketAcknowledgements.py‎

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.client.model.pagination import PaginationOption
7+
from pyinjective.core.network import Network
8+
9+
10+
async def main() -> None:
11+
network = Network.testnet()
12+
client = AsyncClient(network)
13+
14+
port_id = "transfer"
15+
channel_id = "channel-126"
16+
sequences = [1, 2]
17+
pagination = PaginationOption(skip=2, limit=4)
18+
19+
acknowledgements = await client.fetch_ibc_packet_acknowledgements(
20+
port_id=port_id,
21+
channel_id=channel_id,
22+
packet_commitment_sequences=sequences,
23+
pagination=pagination,
24+
)
25+
print(acknowledgements)
26+
27+
28+
if __name__ == "__main__":
29+
symbol_db = symbol_database.Default()
30+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/11_UnreceivedPackets.py‎

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.core.network import Network
7+
8+
9+
async def main() -> None:
10+
network = Network.testnet()
11+
client = AsyncClient(network)
12+
13+
port_id = "transfer"
14+
channel_id = "channel-126"
15+
sequences = [1, 2]
16+
17+
packets = await client.fetch_ibc_unreceived_packets(
18+
port_id=port_id, channel_id=channel_id, packet_commitment_sequences=sequences
19+
)
20+
print(packets)
21+
22+
23+
if __name__ == "__main__":
24+
symbol_db = symbol_database.Default()
25+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/12_UnreceivedAcks.py‎

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.core.network import Network
7+
8+
9+
async def main() -> None:
10+
network = Network.testnet()
11+
client = AsyncClient(network)
12+
13+
port_id = "transfer"
14+
channel_id = "channel-126"
15+
16+
acks = await client.fetch_ibc_unreceived_acks(
17+
port_id=port_id,
18+
channel_id=channel_id,
19+
)
20+
print(acks)
21+
22+
23+
if __name__ == "__main__":
24+
symbol_db = symbol_database.Default()
25+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/13_NextSequenceReceive.py‎

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.core.network import Network
7+
8+
9+
async def main() -> None:
10+
network = Network.testnet()
11+
client = AsyncClient(network)
12+
13+
port_id = "transfer"
14+
channel_id = "channel-126"
15+
16+
sequence = await client.fetch_next_sequence_receive(
17+
port_id=port_id,
18+
channel_id=channel_id,
19+
)
20+
print(sequence)
21+
22+
23+
if __name__ == "__main__":
24+
symbol_db = symbol_database.Default()
25+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/1_Channel.py‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.core.network import Network
7+
8+
9+
async def main() -> None:
10+
network = Network.testnet()
11+
client = AsyncClient(network)
12+
13+
port_id = "transfer"
14+
channel_id = "channel-126"
15+
16+
channel = await client.fetch_ibc_channel(port_id=port_id, channel_id=channel_id)
17+
print(channel)
18+
19+
20+
if __name__ == "__main__":
21+
symbol_db = symbol_database.Default()
22+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/2_Channels.py‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.client.model.pagination import PaginationOption
7+
from pyinjective.core.network import Network
8+
9+
10+
async def main() -> None:
11+
network = Network.testnet()
12+
client = AsyncClient(network)
13+
14+
pagination = PaginationOption(skip=2, limit=4)
15+
16+
channels = await client.fetch_ibc_channels(pagination=pagination)
17+
print(channels)
18+
19+
20+
if __name__ == "__main__":
21+
symbol_db = symbol_database.Default()
22+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/3_ConnectionChannels.py‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.client.model.pagination import PaginationOption
7+
from pyinjective.core.network import Network
8+
9+
10+
async def main() -> None:
11+
network = Network.testnet()
12+
client = AsyncClient(network)
13+
14+
connection = "connection-182"
15+
pagination = PaginationOption(skip=2, limit=4)
16+
17+
channels = await client.fetch_ibc_connection_channels(connection=connection, pagination=pagination)
18+
print(channels)
19+
20+
21+
if __name__ == "__main__":
22+
symbol_db = symbol_database.Default()
23+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/4_ChannelClientState.py‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.core.network import Network
7+
8+
9+
async def main() -> None:
10+
network = Network.testnet()
11+
client = AsyncClient(network)
12+
13+
port_id = "transfer"
14+
channel_id = "channel-126"
15+
16+
state = await client.fetch_ibc_channel_client_state(port_id=port_id, channel_id=channel_id)
17+
print(state)
18+
19+
20+
if __name__ == "__main__":
21+
symbol_db = symbol_database.Default()
22+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/5_ChannelConsensusState.py‎

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.core.network import Network
7+
8+
9+
async def main() -> None:
10+
network = Network.testnet()
11+
client = AsyncClient(network)
12+
13+
port_id = "transfer"
14+
channel_id = "channel-126"
15+
revision_number = 1
16+
revision_height = 7990906
17+
18+
state = await client.fetch_ibc_channel_consensus_state(
19+
port_id=port_id, channel_id=channel_id, revision_number=revision_number, revision_height=revision_height
20+
)
21+
print(state)
22+
23+
24+
if __name__ == "__main__":
25+
symbol_db = symbol_database.Default()
26+
asyncio.get_event_loop().run_until_complete(main())

‎examples/chain_client/ibc/channel/query/6_PacketCommitment.py‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
import asyncio
2+
3+
from google.protobuf import symbol_database
4+
5+
from pyinjective.async_client import AsyncClient
6+
from pyinjective.core.network import Network
7+
8+
9+
async def main() -> None:
10+
network = Network.testnet()
11+
client = AsyncClient(network)
12+
13+
port_id = "transfer"
14+
channel_id = "channel-126"
15+
sequence = 1
16+
17+
commitment = await client.fetch_ibc_packet_commitment(port_id=port_id, channel_id=channel_id, sequence=sequence)
18+
print(commitment)
19+
20+
21+
if __name__ == "__main__":
22+
symbol_db = symbol_database.Default()
23+
asyncio.get_event_loop().run_until_complete(main())

0 commit comments

Comments
 (0)