Reference

message MsgRegisterInterchainQuery {
  string query_type = 1;                 // Either "kv" or "tx"
  repeated KVKey keys = 2;               // KV keys (for KV queries only)
  string transactions_filter = 3;        // TX filter (for TX queries only)
  string connection_id = 4;              // IBC connection ID
  uint64 update_period = 5;              // Minimum blocks between updates
  string sender = 6;                     // Message sender address
}

message KVKey {
  string path = 1;                       // Store path (e.g., "bank", "staking")
  bytes key = 2;                         // Key bytes
}

message MsgRegisterInterchainQueryResponse {
  uint64 id = 1;                         // Assigned query ID
}

[
  {"field": "transfer.recipient", "op": "eq", "value": "cosmos1..."},
  {"field": "tx.height", "op": "gte", "value": 1000000}
]

message MsgSubmitQueryResult {
  uint64 query_id = 1;                   // Query ID
  string sender = 2;                     // Message sender
  string client_id = 3;                  // IBC client ID (deprecated)
  QueryResult result = 4;                // Query result with proofs
}

message QueryResult {
  repeated StorageValue kv_results = 1;  // KV results
  Block block = 2;                       // TX block data
  uint64 height = 3;                     // Remote chain height
  uint64 revision = 4;                   // Chain revision
  bool allow_kv_callbacks = 5;           // Enable KV callbacks
}

message StorageValue {
  string storage_prefix = 1;             // Store name (e.g., "bank")
  bytes key = 2;                         // Key bytes
  bytes value = 3;                       // Value bytes
  tendermint.crypto.ProofOps Proof = 4;  // Merkle proof
}

message MsgRemoveInterchainQueryRequest {
  uint64 query_id = 1;                   // Query ID to remove
  string sender = 2;                     // Message sender
}

message MsgRemoveInterchainQueryResponse {}

message MsgUpdateInterchainQueryRequest {
  uint64 query_id = 1;                   // Query ID to update
  repeated KVKey new_keys = 2;           // New KV keys
  uint64 new_update_period = 3;          // New update period
  string new_transactions_filter = 4;    // New TX filter
  string sender = 5;                     // Message sender
}

message MsgUpdateInterchainQueryResponse {}

message MsgUpdateParams {
  string authority = 1;                  // Module authority address
  Params params = 2;                     // New parameters
}

message MsgUpdateParamsResponse {}

message QueryParamsRequest {}

message QueryParamsResponse {
  Params params = 1;
}

message QueryRegisteredQueriesRequest {
  repeated string owners = 1;            // Filter by owners
  string connection_id = 2;              // Filter by connection ID
  cosmos.base.query.v1beta1.PageRequest pagination = 3;
}

message QueryRegisteredQueriesResponse {
  repeated RegisteredQuery registered_queries = 1;
  cosmos.base.query.v1beta1.PageResponse pagination = 2;
}

message QueryRegisteredQueryRequest {
  uint64 query_id = 1;                   // Query ID
}

message QueryRegisteredQueryResponse {
  RegisteredQuery registered_query = 1;
}

message QueryRegisteredQueryResultRequest {
  uint64 query_id = 1;                   // Query ID
}

message QueryRegisteredQueryResultResponse {
  QueryResult result = 1;
}

message QueryLastRemoteHeight {
  string connection_id = 1;              // IBC connection ID
}

message QueryLastRemoteHeightResponse {
  uint64 height = 1;                     // Remote chain height
  uint64 revision = 2;                   // Chain revision
}

message Params {
  uint64 query_submit_timeout = 1;
  repeated cosmos.base.v1beta1.Coin query_deposit = 2;
  uint64 tx_query_removal_limit = 3;
  uint64 max_kv_query_keys_count = 4;
  uint64 max_transactions_filters = 5;
}

message RegisteredQuery {
  uint64 id = 1;                         // Unique query ID
  string owner = 2;                      // Query owner address
  string query_type = 3;                 // "kv" or "tx"
  repeated KVKey keys = 4;               // KV keys
  string transactions_filter = 5;        // TX filter
  string connection_id = 6;              // IBC connection ID
  uint64 update_period = 7;              // Update period
  uint64 last_submitted_result_local_height = 8;    // Last local height
  ibc.core.client.v1.Height last_submitted_result_remote_height = 9;  // Last remote height
  repeated cosmos.base.v1beta1.Coin deposit = 10;   // Deposit amount
  uint64 submit_timeout = 11;            // Submit timeout
  uint64 registered_at_height = 12;      // Registration height
}

# Get module parameters
neutrond query interchainqueries params

# List all registered queries
neutrond query interchainqueries registered-queries \
  --owners neutron1... \
  --connection_id connection-0

# Get specific query details
neutrond query interchainqueries registered-query [query-id]

# Get query result (KV queries only)
neutrond query interchainqueries query-result [query-id]

# Get last remote height
neutrond query interchainqueries query-last-remote-height [connection-id]

# Submit query result
neutrond tx interchainqueries submit-query-result [query-id] [result-file] \
  --from [key-name] \
  --gas 10000000

# Remove interchain query
neutrond tx interchainqueries remove-interchain-query [query-id] \
  --from [key-name]

use neutron_sdk::sudo::msg::SudoMsg;

#[entry_point]
pub fn sudo(deps: DepsMut, env: Env, msg: SudoMsg) -> StdResult<Response> {
    match msg {
        SudoMsg::KVQueryResult { query_id } => {
            // Query result is available in module state
            // Use QueryResult endpoint to retrieve it
        }
        // ...
    }
}

#[entry_point]
pub fn sudo(deps: DepsMut, env: Env, msg: SudoMsg) -> StdResult<Response> {
    match msg {
        SudoMsg::TxQueryResult { query_id, height, data } => {
            // TX data is passed directly in the callback
            // Verify transactions match your filter criteria
        }
        // ...
    }
}

use neutron_sdk::bindings::msg::NeutronMsg;

// Register KV query
let msg = NeutronMsg::RegisterInterchainQuery {
    query_type: "kv".to_string(),
    keys: vec![KVKey {
        path: "bank".to_string(),
        key: Binary::from(key_bytes),
    }],
    transactions_filter: "".to_string(),
    connection_id: "connection-0".to_string(),
    update_period: 100,
};