refactor(x/oracle): move to time based prices

Signed-off-by: Artur Troian <troian@users.noreply.github.com>

Author: troian

_docs/pyth-integration.md

@@ -693,12 +693,12 @@ cat > oracle-params-proposal.json << 'EOF'
   "summary": "Add the pyth contract address to authorized sources and configure oracle parameters for Pyth integration.",
   "messages": [
     {
-      "@type": "/akash.oracle.v1.MsgUpdateParams",
+      "@type": "/akash.oracle.v2.MsgUpdateParams",
       "authority": "akash10d07y265gmmuvt4z0w9aw880jnsr700jhe7z0f",
       "params": {
         "sources": ["<pyth-contract-address>"],
         "min_price_sources": 1,
-        "max_price_staleness_blocks": 60,
+        "max_price_staleness_period": 60,
         "twap_window": 180,
         "max_price_deviation_bps": 150,
         "feed_contracts_params": [
@@ -734,7 +734,7 @@ akash tx gov submit-proposal oracle-params-proposal.json \
 |------------------------------|----------|----------------------------------|-----------------|
 | `sources`                    | []String | Authorized contract addresses    | `[]`            |
 | `min_price_sources`          | u32      | Minimum sources for valid price  | `1`             |
-| `max_price_staleness_blocks` | i64      | Max age in blocks (~6s/block)    | `60` (~6 min)   |
+| `max_price_staleness_period` | i64      | Max age in seconds (~6s/block)   | `60`            |
 | `twap_window`                | i64      | TWAP calculation window (blocks) | `180` (~18 min) |
 | `max_price_deviation_bps`    | u64      | Max deviation in basis points    | `150` (1.5%)    |
 
@@ -757,7 +757,7 @@ cat > guardian-update-proposal.json << 'EOF'
   "summary": "Update guardian addresses to Wormhole Guardian Set 5",
   "messages": [
     {
-      "@type": "/akash.oracle.v1.MsgUpdateParams",
+      "@type": "/akash.oracle.v2.MsgUpdateParams",
       "authority": "akash10d07y265gmmuvt4z0w9aw880jnsr700jhe7z0f",
       "params": {
         "feed_contracts_params": [

_run/init.sh

@@ -109,9 +109,12 @@ configure_genesis() {
 		| jq -M '.app_state.wasm.params.instantiate_default_permission = "Everybody"' \
 		| jq -M --argjson guardians "$guardian_json" --arg feed_id "$AKT_PRICE_FEED_ID" '
 			.app_state.oracle.params.min_price_sources = 1 |
-			.app_state.oracle.params.max_price_staleness_blocks = 100 |
+			.app_state.oracle.params.max_price_staleness_period = 30 |
 			.app_state.oracle.params.twap_window = 50 |
-			.app_state.oracle.params.max_price_deviation_bps = 1000' \
+			.app_state.oracle.params.max_price_deviation_bps = 1000 |
+			.app_state.oracle.params.price_retention = "86400s" |
+			.app_state.oracle.params.prune_epoch = "hour" |
+			.app_state.oracle.params.max_prune_per_epoch = 1000' \
 	> "${GENESIS_PATH}"
 
 	log "Genesis configuration complete"
@@ -236,7 +239,7 @@ EOF
 {
 	"admin": "$admin_addr",
 	"wormhole_contract": "$wormhole_addr",
-	"update_fee": "1000000",
+	"update_fee": "1000",
 	"price_feed_id": "$AKT_PRICE_FEED_ID",
 	"data_sources": [
 		{
@@ -258,8 +261,8 @@ EOF
 	pyth_addr=$(akash query wasm list-contract-by-code "$pyth_code_id" -o json | jq -r '.contracts[-1]')
 	log "Pyth contract address: $pyth_addr"
 
-	# Register Pyth as authorized oracle source
-	register_oracle_source "$pyth_addr"
+	# Register Pyth as authorized oracle source and fund BME vault via gov proposal
+	register_oracle_source "$pyth_addr" "$admin_addr"
 
 	# Write configuration for Hermes
 	write_hermes_config "$pyth_addr"
@@ -271,37 +274,37 @@ EOF
 
 register_oracle_source() {
 	local pyth_addr=$1
-	log "Registering Pyth contract as authorized oracle source..."
+	local admin_addr=$2
+	log "Registering Pyth contract as authorized oracle source and funding BME vault..."
 
-	# Build guardian addresses JSON array for the proposal
-	local guardian_json="["
-	for i in "${!GUARDIAN_ADDRESSES[@]}"; do
-		if [ "$i" -gt 0 ]; then
-			guardian_json+=","
-		fi
-		guardian_json+="\"${GUARDIAN_ADDRESSES[$i]}\""
-	done
-	guardian_json+="]"
-
-	# Create proposal JSON
+	# Create proposal JSON with both oracle params and BME vault funding
 	cat > /tmp/oracle-params.json <<EOF
 {
 	"messages": [
 		{
-			"@type": "/akash.oracle.v1.MsgUpdateParams",
+			"@type": "/akash.oracle.v2.MsgUpdateParams",
 			"authority": "akash10d07y265gmmuvt4z0w9aw880jnsr700jhe7z0f",
 			"params": {
 				"sources": ["$pyth_addr"],
 				"min_price_sources": 1,
-				"max_price_staleness_blocks": 100,
+				"max_price_staleness_period": 30,
 				"twap_window": 50,
-				"max_price_deviation_bps": 1000
+				"max_price_deviation_bps": 1000,
+				"price_retention": "86400s",
+				"prune_epoch": "hour",
+				"max_prune_per_epoch": 1000
 			}
+		},
+		{
+			"@type": "/akash.bme.v1.MsgFundVault",
+			"authority": "akash10d07y265gmmuvt4z0w9aw880jnsr700jhe7z0f",
+			"amount": {"denom": "${CHAIN_TOKEN_DENOM}", "amount": "1000000000000"},
+			"source": "$admin_addr"
 		}
 	],
 	"deposit": "10000000uakt",
-	"title": "Register Pyth Contract",
-	"summary": "Authorize pyth contract as oracle source"
+	"title": "Register Pyth Contract and Fund BME Vault",
+	"summary": "Authorize pyth contract as oracle source and seed BME vault with initial AKT"
 }
 EOF
 

_run/node/prop.json

@@ -1,22 +1,19 @@
 {
     "messages": [
         {
-            "@type": "/akash.oracle.v1.MsgUpdateParams",
+            "@type": "/akash.oracle.v2.MsgUpdateParams",
             "authority": "akash10d07y265gmmuvt4z0w9aw880jnsr700jhe7z0f",
             "params": {
                 "sources": [
                     "akash1xcfl5u6g2yprvpr4q8j2pp5h6l5ys3nuf529qa"
                 ],
                 "min_price_sources": 1,
-                "max_price_staleness_blocks": "60",
+                "max_price_staleness_period": "30",
                 "twap_window": "50",
                 "max_price_deviation_bps": "150",
-                "feed_contracts_params": [
-                    {
-                        "@type": "/akash.oracle.v1.PythContractParams",
-                        "akt_price_feed_id": "0x4ea5bb4d2f5900cc2e97ba534240950740b4d3b89fe712a94a7304fd2fd92702"
-                    }
-                ]
+                "price_retention": "86400s",
+                "prune_epoch": "hour",
+                "max_prune_per_epoch": "1000"
             }
         }
     ],

app/types/app.go

@@ -70,7 +70,7 @@ import (
 	etypes "pkg.akt.dev/go/node/escrow/module"
 	mtypes "pkg.akt.dev/go/node/market/v1"
 	mvbeta "pkg.akt.dev/go/node/market/v1beta5"
-	otypes "pkg.akt.dev/go/node/oracle/v1"
+	otypes "pkg.akt.dev/go/node/oracle/v2"
 	ptypes "pkg.akt.dev/go/node/provider/v1beta4"
 	wtypes "pkg.akt.dev/go/node/wasm/v1"
 	"pkg.akt.dev/go/sdkutil"
@@ -420,12 +420,14 @@ func (app *App) InitNormalKeepers(
 	app.Keepers.Akash.Oracle = okeeper.NewKeeper(
 		cdc,
 		app.keys[otypes.StoreKey],
+		app.tkeys[otypes.TStoreKey],
 		authtypes.NewModuleAddress(govtypes.ModuleName).String(),
 	)
 
 	app.Keepers.Akash.Bme = bmekeeper.NewKeeper(
 		cdc,
 		app.keys[bmetypes.StoreKey],
+		app.tkeys[bmetypes.TStoreKey],
 		app.AC,
 		authtypes.NewModuleAddress(govtypes.ModuleName).String(),
 		app.Keepers.Cosmos.Acct,
@@ -570,7 +572,9 @@ func (app *App) SetupHooks() {
 	app.Keepers.Akash.Escrow.AddOnAccountClosedHook(hook.OnEscrowAccountClosed)
 	app.Keepers.Akash.Escrow.AddOnPaymentClosedHook(hook.OnEscrowPaymentClosed)
 
-	app.Keepers.Akash.Epochs.SetHooks(epochstypes.NewMultiEpochHooks())
+	app.Keepers.Akash.Epochs.SetHooks(epochstypes.NewMultiEpochHooks(
+		okeeper.EpochHooksFor(app.Keepers.Akash.Oracle),
+	))
 }
 
 // initParamsKeeper init params keeper and its subspaces
@@ -634,6 +638,8 @@ func kvStoreKeys() []string {
 func transientStoreKeys() []string {
 	return []string{
 		paramstypes.TStoreKey,
+		bmetypes.TStoreKey,
+		otypes.TStoreKey,
 	}
 }
 

contracts/pyth/src/contract.rs

@@ -254,11 +254,10 @@ pub fn execute_update_price_feed(
         });
     }
 
-    // Update contract storage only if price is actually newer.
-    // When publish_time == stored, skip the storage write but still
-    // forward to x/oracle below to refresh the block height and
-    // prevent the oracle price from going stale.
-    if publish_time > price_feed.publish_time {
+    // Update contract storage for same or newer timestamps.
+    // Pyth may submit multiple prices within the same timestamp
+    // but from different slots — all should be accepted.
+    if publish_time >= price_feed.publish_time {
         price_feed.prev_publish_time = price_feed.publish_time;
         price_feed.price = price;
         price_feed.conf = conf;
@@ -286,7 +285,7 @@ pub fn execute_update_price_feed(
 
     // Create Any message to submit price to x/oracle module
     let oracle_cosmos_msg: CosmosMsg = CosmosMsg::Any(AnyMsg {
-        type_url: "/akash.oracle.v1.MsgAddPriceEntry".to_string(),
+        type_url: "/akash.oracle.v2.MsgAddPriceEntry".to_string(),
         value: oracle_data.clone(),
     });
 

contracts/pyth/src/integration_tests.rs

@@ -252,9 +252,9 @@ fn e2e_oracle_message_encoding() {
 
     assert_eq!(msg.id.denom, "akt");
     assert_eq!(msg.id.base_denom, "usd");
-    assert_eq!(msg.price.price, "1234567890000000000");
-    assert_eq!(msg.price.timestamp_seconds, 1700000000);
-    assert_eq!(msg.price.timestamp_nanos, 0);
+    assert_eq!(msg.price, "1234567890000000000");
+    assert_eq!(msg.timestamp_seconds, 1700000000);
+    assert_eq!(msg.timestamp_nanos, 0);
 
     let binary = msg.encode_to_protobuf();
     assert!(!binary.is_empty());
@@ -366,7 +366,8 @@ fn e2e_protobuf_encoding_verification() {
     // Verify structure:
     // Field 1 (signer): tag 0x0a, length, "akash1test"
     // Field 2 (id): tag 0x12, length, DataID submessage
-    // Field 3 (price): tag 0x1a, length, PriceDataState submessage
+    // Field 3 (price): tag 0x1a, length, cosmos.Dec string
+    // Field 4 (timestamp): tag 0x22, length, google.protobuf.Timestamp
 
     assert_eq!(binary[0], 0x0a); // Field 1 tag