middleware base

Cargo.toml

@@ -7,6 +7,8 @@ members = [
     "contracts/processor",
     "contracts/testing/*",
     "contracts/program-registry",
+    "contracts/middleware/type-registries/osmosis/osmo-26-0-0",
+    "contracts/middleware/broker",
     "packages/*",
     "program-manager",
     "local-interchaintest",
@@ -73,6 +75,11 @@ valence-osmosis-gamm-lper            = { path = "contracts/libraries/osmosis-gam
 valence-osmosis-gamm-withdrawer      = { path = "contracts/libraries/osmosis-gamm-withdrawer", features = ["library"] }
 valence-osmosis-cl-lper              = { path = "contracts/libraries/osmosis-cl-lper", features = ["library"] }
 valence-osmosis-cl-withdrawer        = { path = "contracts/libraries/osmosis-cl-withdrawer", features = ["library"] }
+valence-neutron-icq-querier          = { path = "contracts/libraries/neutron-icq-querier", features = ["library"] }
+
+# middleware
+valence-middleware-osmosis      = { path = "contracts/middleware/type-registries/osmosis/osmo-26-0-0", features = ["library"] }
+valence-middleware-broker       = { path = "contracts/middleware/broker", features = ["library"] }
 
 # our packages
 valence-account-utils          = { path = "packages/account-utils" }
@@ -89,6 +96,7 @@ valence-library-utils          = { path = "packages/library-utils" }
 valence-program-registry-utils = { path = "packages/program-registry-utils" }
 valence-program-manager        = { path = "program-manager" }
 valence-program-registry       = { path = "contracts/program-registry", features = ["library"] }
+valence-middleware-utils       = { path = "packages/middleware-utils" }
 
 # dev-dependencies
 cw-multi-test        = { version = "2.1.1", features = ["cosmwasm_1_4"] }
@@ -102,3 +110,6 @@ tokio                = "1.40.0"
 osmosis-test-tube    = "26.0.1"
 env_logger           = "0.11.5"
 log                  = "0.4.22"
+prost                = "0.13.3"
+prost-types          = "0.13.3"
+semver               = "1.0.24"

contracts/libraries/neutron-icq-querier/.cargo/config.toml

@@ -0,0 +1,3 @@
+[alias]
+wasm = "build --release --lib --target wasm32-unknown-unknown"
+schema = "run --bin schema"

contracts/libraries/neutron-icq-querier/Cargo.toml

@@ -0,0 +1,32 @@
+[package]
+name       = "valence-neutron-icq-querier"
+authors    = { workspace = true }
+edition    = { workspace = true }
+license    = { workspace = true }
+version    = { workspace = true }
+repository = { workspace = true }
+
+[lib]
+crate-type = ["cdylib", "rlib"]
+
+[features]
+# use library feature to disable all instantiate/execute/query exports
+library = []
+
+[dependencies]
+cosmwasm-std                = { workspace = true }
+cosmwasm-schema             = { workspace = true }
+cw-ownable                  = { workspace = true }
+valence-macros              = { workspace = true }
+valence-library-utils       = { workspace = true }
+valence-library-base        = { workspace = true }
+neutron-sdk                 = { workspace = true }
+serde-json-wasm             = { version = "1.0.0", default-features = false }
+cw-storage-plus             = { workspace = true }
+thiserror                   = { workspace = true }
+valence-middleware-broker   = { workspace = true }
+valence-middleware-utils    = { workspace = true }
+cw2                         = { workspace = true }
+
+[dev-dependencies]
+cw20 = { workspace = true }

contracts/libraries/neutron-icq-querier/README.md

@@ -0,0 +1,35 @@
+# Neutron ICQ-querier library
+
+**Neutron ICQ Querier library** allows registering and receiving results for KV-based queries.
+This library is effectively a wrapper around the `interchainqueries` module on Neutron. 
+
+## Prerequisites
+
+### Active Neutron ICQ relayer
+
+This library requires active [neutron icq relayers](https://github.com/neutron-org/neutron-query-relayer) operating on the specified routes.
+
+### Valence Middleware broker
+
+Each KV-based query requires a correctly encoded key in order to be registered.
+This library obtains the query keys from [Valence Middleware brokers](../../middleware/README.md).
+For a given KV-query to be performed, the select broker must have that type enabled.
+
+## Flow
+
+Queries can be registered by submitting the following message:
+
+```rust
+RegisterKvQuery {
+    broker_addr: String,
+    registry_version: Option<String>,
+    type_id: String,
+    connection_id: String,
+    update_period: Uint64,
+    params: BTreeMap<String, Binary>,
+},
+```
+
+After a query result is fetched, sudo `SudoMsg::KVQueryResult` is triggered.
+That will, in turn, decode the response and parse it into the respective `ValenceType`,
+object of which is then encoded as a json binary and stored in storage.