Merge pull request #141 from DanGould/contextv2-api

Include ohttp ctx in session ctx
payjoin · Dec 14, 2023 · d23ed51 · d23ed51
2 parents b39d7e7 + 489c18b
commit d23ed51
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/payjoin-cli/src/app.rs b/payjoin-cli/src/app.rs
@@ -197,7 +197,7 @@ impl App {
     #[cfg(feature = "v2")]
     async fn long_poll_post(&self, req_ctx: &payjoin::send::RequestContext) -> Result<Psbt> {
         loop {
-            let (req, ctx, ohttp) = req_ctx.extract_v2(&self.config.ohttp_proxy)?;
+            let (req, ctx) = req_ctx.extract_v2(&self.config.ohttp_proxy)?;
             println!("Sending fallback request to {}", &req.url);
             let http = http_agent()?;
             let response = spawn_blocking(move || {
@@ -209,7 +209,7 @@ impl App {
             .await??;
 
             println!("Sent fallback transaction");
-            let psbt = ctx.process_response(&mut response.into_reader(), ohttp)?;
+            let psbt = ctx.process_response(&mut response.into_reader())?;
             if let Some(psbt) = psbt {
                 return Ok(psbt);
             } else {

diff --git a/payjoin/src/send/mod.rs b/payjoin/src/send/mod.rs
@@ -430,7 +430,7 @@ impl RequestContext {
     pub fn extract_v2(
         &self,
         ohttp_proxy_url: &str,
-    ) -> Result<(Request, ContextV2, ohttp::ClientResponse), CreateRequestError> {
+    ) -> Result<(Request, ContextV2), CreateRequestError> {
         let rs_base64 = crate::v2::subdir(self.endpoint.as_str()).to_string();
         log::debug!("rs_base64: {:?}", rs_base64);
         let b64_config =
@@ -471,8 +471,8 @@ impl RequestContext {
                     min_fee_rate: self.min_fee_rate,
                 },
                 e: self.e,
+                ohttp_res,
             },
-            ohttp_res,
         ))
     }
 }
@@ -654,6 +654,7 @@ pub struct ContextV1 {
 pub struct ContextV2 {
     context_v1: ContextV1,
     e: bitcoin::secp256k1::SecretKey,
+    ohttp_res: ohttp::ClientResponse,
 }
 
 macro_rules! check_eq {
@@ -686,11 +687,10 @@ impl ContextV2 {
     pub fn process_response(
         self,
         response: &mut impl std::io::Read,
-        ohttp_ctx: ohttp::ClientResponse,
     ) -> Result<Option<Psbt>, ValidationError> {
         let mut res_buf = Vec::new();
         response.read_to_end(&mut res_buf).map_err(InternalValidationError::Io)?;
-        let mut res_buf = crate::v2::ohttp_decapsulate(ohttp_ctx, &res_buf)
+        let mut res_buf = crate::v2::ohttp_decapsulate(self.ohttp_res, &res_buf)
             .map_err(InternalValidationError::V2)?;
         let psbt = crate::v2::decrypt_message_b(&mut res_buf, self.e)
             .map_err(InternalValidationError::V2)?;

diff --git a/payjoin/tests/integration.rs b/payjoin/tests/integration.rs
@@ -247,7 +247,7 @@ mod integration {
             // Create a funded PSBT (not broadcasted) to address with amount given in the pj_uri
             let psbt = build_original_psbt(&sender, &pj_uri)?;
             debug!("Original psbt: {:#?}", psbt);
-            let (send_req, send_ctx, ohttp) = RequestBuilder::from_psbt_and_uri(psbt, pj_uri)?
+            let (send_req, send_ctx) = RequestBuilder::from_psbt_and_uri(psbt, pj_uri)?
                 .build_with_additional_fee(Amount::from_sat(10000), None, FeeRate::ZERO, false)?
                 .extract_v2(OH_RELAY_URL)?;
             log::info!("send fallback v2");
@@ -298,7 +298,7 @@ mod integration {
             })
             .await??;
             let checked_payjoin_proposal_psbt =
-                send_ctx.process_response(&mut response.into_reader(), ohttp)?.unwrap();
+                send_ctx.process_response(&mut response.into_reader())?.unwrap();
             let payjoin_tx = extract_pj_tx(&sender, checked_payjoin_proposal_psbt)?;
             sender.send_raw_transaction(&payjoin_tx)?;
             log::info!("sent");