chore(core, sequencer): rename connect oracle to price feed

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

@@ -122,11 +122,11 @@
     ],
     {{- if not .Values.global.dev }}
     {{- else }}
-    "connect": {
+    "price_feed": {
       "marketMap": {
         "marketMap": {
           "markets": {
-            {{- range $index, $market := .Values.sequencer.oracle.markets }}
+            {{- range $index, $market := .Values.sequencer.priceFeed.markets }}
             {{- if $index }},{{- end }}
             "{{ $market.name }}": {
               "providerConfigs": [
@@ -158,9 +158,9 @@
           }
         },
         "params": {
-          "admin": "{{ .Values.genesis.oracle.marketAdminAddress }}",
+          "admin": "{{ .Values.genesis.priceFeed.marketAdminAddress }}",
           "marketAuthorities": [
-            {{- range $index, $authority := .Values.genesis.oracle.marketAuthorities }}
+            {{- range $index, $authority := .Values.genesis.priceFeed.marketAuthorities }}
             {{- if $index }},{{- end }}
             "{{ $authority }}"
             {{- end }}
@@ -169,7 +169,7 @@
       },
       "oracle": {
         "currencyPairGenesis": [
-          {{- range $index, $genesis := .Values.sequencer.oracle.currencyPairGenesis }}
+          {{- range $index, $genesis := .Values.sequencer.priceFeed.currencyPairGenesis }}
           {{- if $index }},{{- end }}
           {
             "currencyPair": {
@@ -186,7 +186,7 @@
           }
           {{- end }}
         ],
-        "nextId": "{{ .Values.sequencer.oracle.nextId }}"
+        "nextId": "{{ .Values.sequencer.priceFeed.nextId }}"
       }
     }
   },

charts/sequencer/templates/_helpers.tpl

@@ -11,8 +11,8 @@ Namepsace to deploy elements into.
 {{- define "cometBFT.image" -}}
 {{ .Values.images.cometBFT.repo }}:{{ if .Values.global.dev }}{{ .Values.images.cometBFT.devTag }}{{ else }}{{ .Values.images.cometBFT.tag }}{{ end }}
 {{- end }}
-{{- define "connect.image" -}}
-{{ .Values.images.connect.repo }}:{{ if .Values.global.dev }}{{ .Values.images.connect.devTag }}{{ else }}{{ .Values.images.connect.tag }}{{ end }}
+{{- define "priceFeed.image" -}}
+{{ .Values.images.priceFeed.repo }}:{{ if .Values.global.dev }}{{ .Values.images.priceFeed.devTag }}{{ else }}{{ .Values.images.priceFeed.tag }}{{ end }}
 {{- end }}
 
 {{/*

charts/sequencer/templates/configmaps.yaml

@@ -91,8 +91,8 @@ data:
   {{- else }}
   ASTRIA_SEQUENCER_UPGRADES_FILEPATH: "/sequencer-upgrades/upgrades.json"
   ASTRIA_SEQUENCER_COMETBFT_RPC_ADDR: "http://127.0.0.1:{{ .Values.ports.cometbftRpc }}"
-  ASTRIA_SEQUENCER_NO_ORACLE: "{{ not .Values.sequencer.oracle.enabled }}"
-  ASTRIA_SEQUENCER_ORACLE_GRPC_ADDR: "http://127.0.0.1:{{ .Values.ports.oracleGrpc }}"
-  ASTRIA_SEQUENCER_ORACLE_CLIENT_TIMEOUT_MILLISECONDS: "{{ .Values.sequencer.oracle.clientTimeout }}"
+  ASTRIA_SEQUENCER_NO_PRICE_FEED: "{{ not .Values.sequencer.priceFeed.enabled }}"
+  ASTRIA_SEQUENCER_PRICE_FEED_GRPC_ADDR: "http://127.0.0.1:{{ .Values.ports.priceFeedGrpc }}"
+  ASTRIA_SEQUENCER_PRICE_FEED_CLIENT_TIMEOUT_MILLISECONDS: "{{ .Values.sequencer.priceFeed.clientTimeout }}"
   {{- end }}
 ---

charts/sequencer/templates/service.yaml

@@ -47,7 +47,7 @@ spec:
       port: {{ .Values.ports.sequencerGrpc }}
       targetPort: sequencer-grpc
 ---
-{{- if .Values.serviceMonitor.enabled }} 
+{{- if .Values.serviceMonitor.enabled }}
 kind: Service
 apiVersion: v1
 metadata:
@@ -66,10 +66,10 @@ spec:
     - name: seq-metric
       port: {{ .Values.ports.sequencerMetrics }}
       targetPort: seq-metric
-    {{- if .Values.sequencer.oracle.metrics.enabled }}
-    - name: oracle-metric
-      port: {{ .Values.ports.oracleMetrics }}
-      targetPort: oracle-metric
+    {{- if .Values.sequencer.priceFeed.metrics.enabled }}
+    - name: price-fd-metric
+      port: {{ .Values.ports.priceFeedMetrics }}
+      targetPort: price-fd-metric
     {{- end }}
     {{- end }}
 {{- end }}

charts/sequencer/templates/servicemonitor.yaml

@@ -34,8 +34,8 @@ spec:
       {{- with .Values.serviceMonitor.scrapeTimeout  }}
       scrapeTimeout: {{ . }}
       {{- end }}
-    {{- if .Values.sequencer.oracle.metrics.enabled }}
-    - port: oracle-metric
+    {{- if .Values.sequencer.priceFeed.metrics.enabled }}
+    - port: price-fd-metric
       path: /
       {{- with .Values.serviceMonitor.interval }}
       interval: {{ . }}

charts/sequencer/templates/statefulsets.yaml

@@ -102,9 +102,9 @@ spec:
             limits:
               cpu: {{ .Values.resources.cometbft.limits.cpu }}
               memory: {{ .Values.resources.cometbft.limits.memory }}
-        - name: connect
-          image: "{{ include "connect.image" . }}"
-          imagePullPolicy: {{ .Values.images.connect.pullPolicy }}
+        - name: price-feed
+          image: "{{ include "priceFeed.image" . }}"
+          imagePullPolicy: {{ .Values.images.priceFeed.pullPolicy }}
           volumeMounts:
             - mountPath: /scripts
               name: cometbft-init-scripts-volume
@@ -113,12 +113,12 @@ spec:
           - "--market-map-endpoint"
           - "127.0.0.1:{{ .Values.ports.sequencerGrpc }}"
           - "--port"
-          - "{{ .Values.ports.oracleGrpc }}"
+          - "{{ .Values.ports.priceFeedGrpc }}"
           ports:
-            - containerPort: {{ .Values.ports.oracleGrpc }}
-              name: oracle-grpc
-            - containerPort: {{ .Values.ports.oracleMetrics }}
-              name: oracle-metric
+            - containerPort: {{ .Values.ports.priceFeedGrpc }}
+              name: price-feed-grpc
+            - containerPort: {{ .Values.ports.priceFeedMetrics }}
+              name: price-fd-metric
       volumes:
         - name: cometbft-config-volume
           configMap:

charts/sequencer/values.yaml

@@ -35,7 +35,7 @@ images:
     pullPolicy: IfNotPresent
     tag: 1.0.0
     devTag: pr-1866
-  connect:
+  priceFeed:
     repo: ghcr.io/skip-mev/connect-sidecar
     pullPolicy: IfNotPresent
     tag: v2
@@ -49,7 +49,7 @@ genesis:
     base: "astria"
     ibcCompat: "astriacompat"
   authoritySudoAddress: ""
-  oracle:
+  priceFeed:
     marketAdminAddress: "astria1rsxyjrcm255ds9euthjx6yc3vrjt9sxrm9cfgm"
     marketAuthorities:
       - "astria1rsxyjrcm255ds9euthjx6yc3vrjt9sxrm9cfgm"
@@ -130,7 +130,7 @@ sequencer:
   mempool:
     parked:
       maxTxCount: 200
-  oracle:
+  priceFeed:
     enabled: true
     clientTimeout: 1000
     markets: []
@@ -299,12 +299,12 @@ ports:
   cometbftRpc: 26657
   cometbftMetrics: 26660
   sequencerABCI: 26658
-  # note: the oracle sidecar also uses 8080 by default but can be changed with --port
+  # note: the price feed sidecar also uses 8080 by default but can be changed with --port
   sequencerGrpc: 8080
   relayerRpc: 2450
   sequencerMetrics: 9000
-  oracleGrpc: 8081
-  oracleMetrics: 8002
+  priceFeedGrpc: 8081
+  priceFeedMetrics: 8002
 
 # ServiceMonitor configuration
 serviceMonitor:

crates/astria-conductor/src/celestia/block_verifier.rs

@@ -322,7 +322,7 @@ mod tests {
     }
 
     fn make_test_extended_commit_info_bytes() -> Vec<u8> {
-        use astria_core::generated::protocol::connect::v1::ExtendedCommitInfoWithCurrencyPairMapping;
+        use astria_core::generated::protocol::price_feed::v1::ExtendedCommitInfoWithCurrencyPairMapping;
 
         let extended_commit_info: tendermint_proto::abci::ExtendedCommitInfo =
             tendermint::abci::types::ExtendedCommitInfo {

crates/astria-conductor/src/celestia/mod.rs

@@ -6,7 +6,7 @@ use std::{
 
 use astria_core::{
     primitive::v1::RollupId,
-    protocol::connect::v1::ExtendedCommitInfoWithCurrencyPairMapping,
+    protocol::price_feed::v1::ExtendedCommitInfoWithCurrencyPairMapping,
     sequencerblock::v1::block::{
         self,
         SequencerBlockHeader,

crates/astria-conductor/src/executor/mod.rs

@@ -6,12 +6,12 @@ use astria_core::{
         CommitmentState,
     },
     primitive::v1::RollupId,
-    protocol::connect::v1::ExtendedCommitInfoWithCurrencyPairMapping,
+    protocol::price_feed::v1::ExtendedCommitInfoWithCurrencyPairMapping,
     sequencerblock::v1::block::{
         self,
         FilteredSequencerBlock,
         FilteredSequencerBlockParts,
-        OracleData,
+        PriceFeedData,
         RollupData,
     },
 };
@@ -709,7 +709,7 @@ impl ExecutableBlock {
         } = block;
         let timestamp = convert_tendermint_time_to_protobuf_timestamp(header.time());
         let transactions =
-            insert_oracle_data_into_transactions_if_exists(transactions, extended_commit_info);
+            insert_price_feed_data_into_transactions_if_exists(transactions, extended_commit_info);
         Self {
             hash: block_hash,
             height: header.height(),
@@ -734,7 +734,7 @@ impl ExecutableBlock {
             .unwrap_or_default();
 
         let transactions =
-            insert_oracle_data_into_transactions_if_exists(transactions, extended_commit_info);
+            insert_price_feed_data_into_transactions_if_exists(transactions, extended_commit_info);
         Self {
             hash: block_hash,
             height,
@@ -744,23 +744,26 @@ impl ExecutableBlock {
     }
 }
 
-fn insert_oracle_data_into_transactions_if_exists(
+fn insert_price_feed_data_into_transactions_if_exists(
     transactions: Vec<Bytes>,
     extended_commit_info: Option<ExtendedCommitInfoWithCurrencyPairMapping>,
 ) -> Vec<Bytes> {
     use prost::Message as _;
 
     if let Some(extended_commit_info) = extended_commit_info {
-        let Ok(prices) = astria_core::connect::utils::calculate_prices_from_vote_extensions(
-            &extended_commit_info.extended_commit_info,
-            &extended_commit_info.id_to_currency_pair,
-        ) else {
+        let Ok(prices) =
+            astria_core::oracles::price_feed::utils::calculate_prices_from_vote_extensions(
+                &extended_commit_info.extended_commit_info,
+                &extended_commit_info.id_to_currency_pair,
+            )
+        else {
             debug!(
-                "failed to calculate prices from vote extensions; continuing without oracle data"
+                "failed to calculate prices from vote extensions; continuing without price feed \
+                 data"
             );
             return transactions;
         };
-        let rollup_data = RollupData::OracleData(Box::new(OracleData::new(prices)));
+        let rollup_data = RollupData::PriceFeedData(Box::new(PriceFeedData::new(prices)));
         std::iter::once(rollup_data.into_raw().encode_to_vec().into())
             .chain(transactions)
             .collect()

crates/astria-conductor/tests/blackbox/helpers/macros.rs

@@ -282,7 +282,7 @@ macro_rules! mount_executed_block {
             ::serde_json::json!({
                 "prevBlockHash": BASE64_STANDARD.encode($parent),
                 "transactions": [
-                    {"oracleData": {}},
+                    {"priceFeedData": {}},
                     {"sequencedData": BASE64_STANDARD.encode($crate::helpers::data())}
                 ],
             }),
@@ -414,7 +414,7 @@ macro_rules! mount_execute_block_tonic_code {
             ::serde_json::json!({
                 "prevBlockHash": BASE64_STANDARD.encode($parent),
                 "transactions": [
-                    {"oracleData": {}},
+                    {"priceFeedData": {}},
                     {"sequencedData": BASE64_STANDARD.encode($crate::helpers::data())}
                 ],
             }),