feat: oracle signed context - full stack (Phases 3-7)

crates/common/src/add_order.rs

@@ -22,8 +22,9 @@ use rain_interpreter_eval::{
 };
 use rain_interpreter_parser::{Parser2, ParserError, ParserV2};
 use rain_metadata::{
-    types::dotrain::gui_state_v1::DotrainGuiStateV1, ContentEncoding, ContentLanguage, ContentType,
-    Error as RainMetaError, KnownMagic, RainMetaDocumentV1Item,
+    types::dotrain::gui_state_v1::DotrainGuiStateV1,
+    types::raindex_signed_context_oracle::RaindexSignedContextOracleV1, ContentEncoding,
+    ContentLanguage, ContentType, Error as RainMetaError, KnownMagic, RainMetaDocumentV1Item,
 };
 use rain_metadata_bindings::MetaBoard::emitMetaCall;
 use rain_orderbook_app_settings::deployment::DeploymentCfg;
@@ -130,6 +131,21 @@ impl AddOrderArgs {
             });
         }
 
+        // If the order has an oracle URL, add a RaindexSignedContextOracleV1 meta item
+        let additional_meta = {
+            let mut meta = additional_meta.unwrap_or_default();
+            if let Some(ref oracle_url) = deployment.order.oracle_url {
+                let oracle = RaindexSignedContextOracleV1::parse(oracle_url)
+                    .map_err(AddOrderArgsError::RainMetaError)?;
+                meta.push(oracle.to_meta_item());
+            }
+            if meta.is_empty() {
+                None
+            } else {
+                Some(meta)
+            }
+        };
+
         Ok(AddOrderArgs {
             dotrain: dotrain.to_string(),
             inputs,
@@ -683,6 +699,7 @@ price: 2e18;
             network: network_arc.clone(),
             deployer: None,
             orderbook: None,
+            oracle_url: None,
         };
         let deployment = DeploymentCfg {
             document: Arc::new(RwLock::new(StrictYaml::String("".to_string()))),
@@ -803,6 +820,7 @@ _ _: 0 0;
             network: network_arc.clone(),
             deployer: None,
             orderbook: None,
+            oracle_url: None,
         };
         let deployment = DeploymentCfg {
             document: Arc::new(RwLock::new(StrictYaml::String("".to_string()))),
@@ -966,6 +984,7 @@ _ _: 0 0;
             network: network_arc.clone(),
             deployer: None,
             orderbook: None,
+            oracle_url: None,
         };
         let deployment = DeploymentCfg {
             document: Arc::new(RwLock::new(StrictYaml::String("".to_string()))),
@@ -1307,6 +1326,7 @@ _ _: 16 52;
             network: network_arc.clone(),
             deployer: None,
             orderbook: None,
+            oracle_url: None,
         };
         DeploymentCfg {
             document: default_document(),

crates/common/src/lib.rs

@@ -7,6 +7,7 @@ pub mod erc20;
 pub mod fuzz;
 pub mod local_db;
 pub mod meta;
+pub mod oracle;
 pub mod parsed_meta;
 pub mod raindex_client;
 pub mod rainlang;

crates/common/src/oracle.rs

@@ -0,0 +1,3 @@
+// Re-export oracle types and functions from the quote crate.
+// This maintains backward compatibility for code in common that uses oracle functionality.
+pub use rain_orderbook_quote::oracle::*;

crates/common/src/parsed_meta.rs

@@ -1,5 +1,8 @@
 use rain_metadata::{
-    types::dotrain::{gui_state_v1::DotrainGuiStateV1, source_v1::DotrainSourceV1},
+    types::{
+        dotrain::{gui_state_v1::DotrainGuiStateV1, source_v1::DotrainSourceV1},
+        raindex_signed_context_oracle::RaindexSignedContextOracleV1,
+    },
     KnownMagic, RainMetaDocumentV1Item,
 };
 use serde::{Deserialize, Serialize};
@@ -13,6 +16,7 @@ use wasm_bindgen_utils::{impl_wasm_traits, prelude::*};
 pub enum ParsedMeta {
     DotrainGuiStateV1(DotrainGuiStateV1),
     DotrainSourceV1(DotrainSourceV1),
+    RaindexSignedContextOracleV1(RaindexSignedContextOracleV1),
 }
 #[cfg(target_family = "wasm")]
 impl_wasm_traits!(ParsedMeta);
@@ -34,6 +38,10 @@ impl ParsedMeta {
                 let source = DotrainSourceV1::try_from(item.clone())?;
                 Ok(Some(ParsedMeta::DotrainSourceV1(source)))
             }
+            KnownMagic::RaindexSignedContextOracleV1 => {
+                let oracle = RaindexSignedContextOracleV1::try_from(item.clone())?;
+                Ok(Some(ParsedMeta::RaindexSignedContextOracleV1(oracle)))
+            }
             // Filter out all other metadata types - they're not needed for the frontend
             _ => Ok(None),
         }
@@ -198,4 +206,67 @@ mod tests {
         assert!(matches!(&parsed[0], ParsedMeta::DotrainSourceV1(s) if s.0 == source.0));
         assert!(matches!(&parsed[1], ParsedMeta::DotrainGuiStateV1(g) if g == &gui));
     }
+
+    #[test]
+    fn test_from_meta_item_raindex_signed_context_oracle_v1() {
+        let oracle =
+            RaindexSignedContextOracleV1::parse("https://oracle.example.com/prices/eth-usd")
+                .unwrap();
+        let item = oracle.to_meta_item();
+        let result = ParsedMeta::from_meta_item(&item).unwrap();
+        match result.unwrap() {
+            ParsedMeta::RaindexSignedContextOracleV1(parsed_oracle) => {
+                assert_eq!(
+                    parsed_oracle.url(),
+                    "https://oracle.example.com/prices/eth-usd"
+                );
+            }
+            _ => panic!("Expected RaindexSignedContextOracleV1"),
+        }
+    }
+
+    #[test]
+    fn test_parse_multiple_with_oracle() {
+        let source = get_default_dotrain_source();
+        let oracle =
+            RaindexSignedContextOracleV1::parse("https://oracle.example.com/feed").unwrap();
+
+        let items = vec![
+            RainMetaDocumentV1Item::from(source.clone()),
+            oracle.to_meta_item(),
+        ];
+
+        let results = ParsedMeta::parse_multiple(&items).unwrap();
+        assert_eq!(results.len(), 2);
+
+        match &results[0] {
+            ParsedMeta::DotrainSourceV1(parsed_source) => {
+                assert_eq!(parsed_source.0, source.0);
+            }
+            _ => panic!("Expected DotrainSourceV1"),
+        }
+
+        match &results[1] {
+            ParsedMeta::RaindexSignedContextOracleV1(parsed_oracle) => {
+                assert_eq!(parsed_oracle.url(), "https://oracle.example.com/feed");
+            }
+            _ => panic!("Expected RaindexSignedContextOracleV1"),
+        }
+    }
+
+    #[test]
+    fn test_parse_from_bytes_with_oracle() {
+        let oracle =
+            RaindexSignedContextOracleV1::parse("https://oracle.example.com/prices/eth-usd")
+                .unwrap();
+        let items = vec![oracle.to_meta_item()];
+        let bytes = RainMetaDocumentV1Item::cbor_encode_seq(&items, KnownMagic::RainMetaDocumentV1)
+            .unwrap();
+
+        let parsed = ParsedMeta::parse_from_bytes(&bytes).unwrap();
+        assert_eq!(parsed.len(), 1);
+        assert!(
+            matches!(&parsed[0], ParsedMeta::RaindexSignedContextOracleV1(o) if o.url() == "https://oracle.example.com/prices/eth-usd")
+        );
+    }
 }

crates/common/src/raindex_client/order_quotes.rs

@@ -120,8 +120,10 @@ impl RaindexOrder {
     ) -> Result<Vec<RaindexOrderQuote>, RaindexError> {
         let gas_amount = gas.map(|v| v.parse::<u64>()).transpose()?;
         let rpcs = self.get_rpc_urls()?;
+        let sg_order = self.clone().into_sg_order()?;
+
         let order_quotes = get_order_quotes(
-            vec![self.clone().into_sg_order()?],
+            vec![sg_order],
             block_number,
             rpcs.iter().map(|s| s.to_string()).collect(),
             gas_amount,

crates/common/src/raindex_client/orders.rs

@@ -272,6 +272,14 @@ impl RaindexOrder {
             _ => None,
         })
     }
+    /// Returns the signed context oracle URL if this order has oracle metadata.
+    #[wasm_bindgen(getter = oracleUrl)]
+    pub fn oracle_url(&self) -> Option<String> {
+        self.parsed_meta().into_iter().find_map(|meta| match meta {
+            ParsedMeta::RaindexSignedContextOracleV1(oracle) => Some(oracle.0),
+            _ => None,
+        })
+    }
     #[wasm_bindgen(getter)]
     pub fn transaction(&self) -> Option<RaindexTransaction> {
         self.transaction.clone()
@@ -300,6 +308,16 @@ impl RaindexOrder {
     pub fn inputs_outputs_list(&self) -> RaindexVaultsList {
         RaindexVaultsList::new(get_io_by_type(self, RaindexVaultType::InputOutput))
     }
+
+    /// Extract oracle URL from raw meta bytes.
+    /// 
+    /// Takes raw meta bytes, CBOR decodes them as RainMetaDocumentV1Items,
+    /// and finds RaindexSignedContextOracleV1 by magic number.
+    /// Returns the oracle URL if found, None otherwise.
+    #[wasm_bindgen(js_name = extractOracleUrl)]
+    pub fn extract_oracle_url_wasm(meta_bytes: &[u8]) -> Option<String> {
+        RaindexOrder::extract_oracle_url(meta_bytes)
+    }
 }
 #[cfg(not(target_family = "wasm"))]
 impl RaindexOrder {
@@ -348,6 +366,13 @@ impl RaindexOrder {
             _ => None,
         })
     }
+    /// Returns the signed context oracle URL if this order has oracle metadata.
+    pub fn oracle_url(&self) -> Option<String> {
+        self.parsed_meta().into_iter().find_map(|meta| match meta {
+            ParsedMeta::RaindexSignedContextOracleV1(oracle) => Some(oracle.0),
+            _ => None,
+        })
+    }
     pub fn transaction(&self) -> Option<RaindexTransaction> {
         self.transaction.clone()
     }
@@ -369,6 +394,19 @@ impl RaindexOrder {
     pub fn inputs_outputs_list(&self) -> RaindexVaultsList {
         RaindexVaultsList::new(get_io_by_type(self, RaindexVaultType::InputOutput))
     }
+
+    /// Extract oracle URL from raw meta bytes.
+    /// 
+    /// Takes raw meta bytes, CBOR decodes them as RainMetaDocumentV1Items,
+    /// and finds RaindexSignedContextOracleV1 by magic number.
+    /// Returns the oracle URL if found, None otherwise.
+    pub fn extract_oracle_url(meta_bytes: &[u8]) -> Option<String> {
+        use rain_metadata::{types::raindex_signed_context_oracle::RaindexSignedContextOracleV1, RainMetaDocumentV1Item};
+
+        let items = RainMetaDocumentV1Item::cbor_decode(meta_bytes).ok()?;
+        let oracle = RaindexSignedContextOracleV1::find_in_items(&items).ok()??;
+        Some(oracle.url().to_string())
+    }
 }
 
 fn get_vaults_with_type(
@@ -661,6 +699,7 @@ impl RaindexOrder {
             &rpc_urls,
             Some(block_number),
             sell_token,
+            self.oracle_url(),
         )
         .await
     }

crates/common/src/raindex_client/take_orders/single.rs

@@ -54,6 +54,7 @@ pub fn build_candidate_from_quote(
         output_io_index,
         max_output: data.max_output,
         ratio: data.ratio,
+        signed_context: vec![],
     }))
 }
 
@@ -102,6 +103,7 @@ pub fn estimate_take_order(
     ))
 }
 
+#[allow(clippy::too_many_arguments)]
 pub async fn execute_single_take(
     candidate: TakeOrderCandidate,
     mode: ParsedTakeOrdersMode,
@@ -110,7 +112,25 @@ pub async fn execute_single_take(
     rpc_urls: &[Url],
     block_number: Option<u64>,
     sell_token: Address,
+    oracle_url: Option<String>,
 ) -> Result<TakeOrdersCalldataResult, RaindexError> {
+    // Fetch signed context from oracle if URL provided
+    let mut candidate = candidate;
+    if let Some(url) = oracle_url {
+        let body = crate::oracle::encode_oracle_body(
+            &candidate.order,
+            candidate.input_io_index,
+            candidate.output_io_index,
+            taker,
+        );
+        match crate::oracle::fetch_signed_context(&url, body).await {
+            Ok(ctx) => candidate.signed_context = vec![ctx],
+            Err(e) => {
+                tracing::warn!("Failed to fetch oracle data from {}: {}", url, e);
+            }
+        }
+    }
+
     let zero = Float::zero()?;
 
     if candidate.ratio.gt(price_cap)? {