feat(sequencer): integrate connect oracle and vote extension logic

charts/sequencer/Chart.yaml

@@ -15,7 +15,7 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 1.0.0
+version: 1.0.1
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.

charts/sequencer/files/cometbft/config/genesis.json

@@ -119,9 +119,24 @@
       {{- if $index }},{{- end }}
       {{ include "sequencer.address" $value }}
       {{- end }}
-    ]
+    ],
     {{- if not .Values.global.dev }}
     {{- else }}
+    "connect": {
+      "marketMap": {
+        "marketMap": {
+          "markets": {}
+        },
+        "params": {
+          "marketAuthorities": [],
+          "admin": "{{ .Values.genesis.marketAdminAddress }}"
+        }
+      },
+      "oracle": {
+        "currencyPairGenesis": [],
+        "nextId": "0"
+      }
+    }
     {{- end}}
   },
   "chain_id": "{{ .Values.genesis.chainId }}",
@@ -142,7 +157,16 @@
     },
     "version": {
       "app": "0"
+    },
+    {{- if not .Values.global.dev }}
+    "abci": {
+      "vote_extensions_enable_height": "0"
     }
+    {{- else }}
+    "abci": {
+      "vote_extensions_enable_height": "1"
+    }
+    {{- end}}
   },
   "genesis_time": "{{ .Values.genesis.genesisTime }}",
   "initial_height": "0",

charts/sequencer/templates/configmaps.yaml

@@ -73,7 +73,10 @@ data:
   OTEL_EXPORTER_OTLP_HEADERS: "{{ .Values.sequencer.otel.otlpHeaders }}"
   OTEL_EXPORTER_OTLP_TRACE_HEADERS: "{{ .Values.sequencer.otel.traceHeaders }}"
   OTEL_SERVICE_NAME: "{{ tpl .Values.sequencer.otel.serviceName . }}"
+  ASTRIA_SEQUENCER_ORACLE_GRPC_ADDR: "http://127.0.0.1:{{ .Values.ports.oracleGrpc }}"
+  ASTRIA_SEQUENCER_ORACLE_CLIENT_TIMEOUT_MILLISECONDS: "{{ .Values.sequencer.oracle.clientTimeout }}"
   {{- if not .Values.global.dev }}
   {{- else }}
+  ASTRIA_SEQUENCER_NO_ORACLE: "true"
   {{- end }}
 ---

charts/sequencer/values.yaml

@@ -34,6 +34,7 @@ genesis:
     base: "astria"
     ibcCompat: "astriacompat"
   authoritySudoAddress: ""
+  marketAdminAddress: ""
   allowedFeeAssets: []
     # - nria
   ibc:
@@ -108,6 +109,8 @@ sequencer:
   mempool:
     parked:
       maxTxCount: 200
+  oracle:
+    clientTimeout: 1000
   metrics:
     enabled: false
   otel:
@@ -271,9 +274,11 @@ ports:
   cometbftRpc: 26657
   cometbftMetrics: 26660
   sequencerABCI: 26658
+  # note: the oracle sidecar also uses 8080 by default but can be changed with --port
   sequencerGrpc: 8080
   relayerRpc: 2450
   sequencerMetrics: 9000
+  oracleGrpc: 8081
 
 # ServiceMonitor configuration
 serviceMonitor:

crates/astria-core/Cargo.toml

@@ -36,6 +36,7 @@ penumbra-ibc = { workspace = true }
 penumbra-proto = { workspace = true }
 prost = { workspace = true }
 rand = { workspace = true }
+regex = { workspace = true }
 serde = { workspace = true, features = ["derive"], optional = true }
 sha2 = { workspace = true }
 tendermint = { workspace = true }

crates/astria-core/src/connect/abci.rs

@@ -0,0 +1,74 @@
+pub mod v2 {
+    use bytes::Bytes;
+    use indexmap::IndexMap;
+
+    use crate::{
+        connect::types::v2::{
+            CurrencyPairId,
+            Price,
+        },
+        generated::connect::abci::v2 as raw,
+    };
+
+    #[derive(Debug, thiserror::Error)]
+    #[error(transparent)]
+    pub struct OracleVoteExtensionError(#[from] OracleVoteExtensionErrorKind);
+
+    #[derive(Debug, thiserror::Error)]
+    #[error("failed to validate connect.abci.v2.OracleVoteExtension")]
+    enum OracleVoteExtensionErrorKind {
+        #[error("failed decoding price value in .prices field for key `{id}`")]
+        DecodePrice {
+            id: u64,
+            source: crate::connect::types::v2::DecodePriceError,
+        },
+    }
+
+    #[derive(Debug, Clone, PartialEq, Eq)]
+    pub struct OracleVoteExtension {
+        pub prices: IndexMap<CurrencyPairId, Price>,
+    }
+
+    impl OracleVoteExtension {
+        /// Converts an on-wire [`raw::OracleVoteExtension`] to a validated domain type
+        /// [`OracleVoteExtension`].
+        ///
+        /// # Errors
+        /// Returns an error if a value in the `.prices` map could not be validated.
+        pub fn try_from_raw(
+            raw: raw::OracleVoteExtension,
+        ) -> Result<Self, OracleVoteExtensionError> {
+            let prices = raw
+                .prices
+                .into_iter()
+                .map(|(id, price)| {
+                    let price = Price::try_from(price).map_err(|source| {
+                        OracleVoteExtensionErrorKind::DecodePrice {
+                            id,
+                            source,
+                        }
+                    })?;
+                    Ok::<_, OracleVoteExtensionErrorKind>((CurrencyPairId::new(id), price))
+                })
+                .collect::<Result<_, _>>()?;
+            Ok(Self {
+                prices,
+            })
+        }
+
+        #[must_use]
+        pub fn into_raw(self) -> raw::OracleVoteExtension {
+            fn encode_price(input: Price) -> Bytes {
+                Bytes::copy_from_slice(&input.get().to_be_bytes())
+            }
+
+            raw::OracleVoteExtension {
+                prices: self
+                    .prices
+                    .into_iter()
+                    .map(|(id, price)| (id.get(), encode_price(price)))
+                    .collect(),
+            }
+        }
+    }
+}