Add ability to receive Payjoin tx

Implements the payjoin receiver part as describe in BIP77.

This would allow the on chain wallet linked to LDK node to receive payjoin
transactions.

Receiving a payjoin transaction requires first to enroll with the
configured Payjoin directory and listening to our enrolled subdirectory
for upcoming request. When a request received, we validate it as
specified in BIP78, prepare our Payjoin proposal and send it back to the
payjoin sender via the subdirectory.

Author: jbesraa

Cargo.toml

@@ -68,7 +68,7 @@ tokio = { version = "1", default-features = false, features = [ "rt-multi-thread
 esplora-client = { version = "0.6", default-features = false }
 libc = "0.2"
 uniffi = { version = "0.26.0", features = ["build"], optional = true }
-payjoin = { version = "0.16.0", default-features = false, features = ["send", "v2"] }
+payjoin = { version = "0.16.0", default-features = false, features = ["send", "receive", "v2"] }
 
 [target.'cfg(vss)'.dependencies]
 vss-client = "0.2"

bindings/ldk_node.udl

@@ -199,6 +199,9 @@ enum NodeError {
 	"PayjoinRequestCreationFailed",
 	"PayjoinResponseProcessingFailed",
 	"PayjoinRequestTimeout",
+	"PayjoinReceiverUnavailable",
+	"PayjoinReceiverRequestValidationFailed",
+	"PayjoinReceiverEnrollementFailed"
 };
 
 dictionary NodeStatus {

src/builder.rs

@@ -11,6 +11,7 @@ use crate::io::sqlite_store::SqliteStore;
 use crate::liquidity::LiquiditySource;
 use crate::logger::{log_error, log_info, FilesystemLogger, Logger};
 use crate::message_handler::NodeCustomMessageHandler;
+use crate::payjoin_receiver::PayjoinReceiver;
 use crate::payment::store::PaymentStore;
 use crate::peer_store::PeerStore;
 use crate::tx_broadcaster::TransactionBroadcaster;
@@ -1001,7 +1002,8 @@ fn build_with_store_internal(
 	let (stop_sender, _) = tokio::sync::watch::channel(());
 
 	let mut payjoin_sender = None;
-	if let Some((_payjoin_directory, payjoin_relay, _ohttp_keys)) = payjoin_config
+	let mut payjoin_receiver = None;
+	if let Some((payjoin_directory, payjoin_relay, ohttp_keys)) = payjoin_config
 		.as_ref()
 		.map(|pc| (pc.payjoin_directory.clone(), pc.payjoin_relay.clone(), pc.ohttp_keys.clone()))
 	{
@@ -1017,7 +1019,21 @@ fn build_with_store_internal(
 			Err(_) => {
 				return Err(BuildError::InvalidPayjoinConfig);
 			},
-		}
+		};
+		match PayjoinReceiver::new(
+			Arc::clone(&logger),
+			Arc::clone(&wallet),
+			&payjoin_directory,
+			&payjoin_relay,
+			ohttp_keys,
+		) {
+			Ok(payjoin_receiver_) => {
+				payjoin_receiver = Some(Arc::new(payjoin_receiver_));
+			},
+			Err(_) => {
+				return Err(BuildError::InvalidPayjoinConfig);
+			},
+		};
 	}
 
 	let is_listening = Arc::new(AtomicBool::new(false));
@@ -1041,6 +1057,7 @@ fn build_with_store_internal(
 		chain_monitor,
 		output_sweeper,
 		payjoin_sender,
+		payjoin_receiver,
 		peer_manager,
 		connection_manager,
 		keys_manager,

src/error.rs

@@ -101,6 +101,12 @@ pub enum Error {
 	PayjoinResponseProcessingFailed,
 	/// Payjoin request timed out.
 	PayjoinRequestTimeout,
+	/// Failed to access payjoin receiver object.
+	PayjoinReceiverUnavailable,
+	/// Failed to enroll payjoin receiver.
+	PayjoinReceiverEnrollementFailed,
+	/// Failed to validate an incoming payjoin request.
+	PayjoinReceiverRequestValidationFailed,
 }
 
 impl fmt::Display for Error {
@@ -186,6 +192,15 @@ impl fmt::Display for Error {
 					"Payjoin receiver did not respond to our request within the timeout period."
 				)
 			},
+			Self::PayjoinReceiverUnavailable => {
+				write!(f, "Failed to access payjoin receiver object. Make sure you have enabled Payjoin receiving support.")
+			},
+			Self::PayjoinReceiverRequestValidationFailed => {
+				write!(f, "Failed to validate an incoming payjoin request. Payjoin sender request didnt pass the payjoin validation steps.")
+			},
+			Self::PayjoinReceiverEnrollementFailed => {
+				write!(f, "Failed to enroll payjoin receiver. Make sure the configured Payjoin directory & Payjoin relay are available.")
+			},
 		}
 	}
 }

src/lib.rs

@@ -89,6 +89,7 @@ pub mod io;
 mod liquidity;
 mod logger;
 mod message_handler;
+mod payjoin_receiver;
 mod payjoin_sender;
 pub mod payment;
 mod peer_store;
@@ -110,6 +111,7 @@ pub use error::Error as NodeError;
 use error::Error;
 
 pub use event::Event;
+use payjoin_receiver::PayjoinReceiver;
 pub use types::ChannelConfig;
 
 pub use io::utils::generate_entropy_mnemonic;
@@ -189,6 +191,7 @@ pub struct Node {
 	peer_manager: Arc<PeerManager>,
 	connection_manager: Arc<ConnectionManager<Arc<FilesystemLogger>>>,
 	payjoin_sender: Option<Arc<PayjoinSender>>,
+	payjoin_receiver: Option<Arc<PayjoinReceiver>>,
 	keys_manager: Arc<KeysManager>,
 	network_graph: Arc<Graph>,
 	gossip_source: Arc<GossipSource>,
@@ -645,6 +648,30 @@ impl Node {
 			Arc::clone(&self.logger),
 		));
 
+		// Check every 5 seconds if we have received a payjoin transaction to our enrolled
+		// subdirectory with the configured Payjoin directory.
+		if let Some(payjoin_receiver) = &self.payjoin_receiver {
+			let mut stop_payjoin_server = self.stop_sender.subscribe();
+			let payjoin_receiver = Arc::clone(&payjoin_receiver);
+			let payjoin_check_interval = 5;
+			runtime.spawn(async move {
+				let mut payjoin_interval =
+					tokio::time::interval(Duration::from_secs(payjoin_check_interval));
+				payjoin_interval.reset();
+				payjoin_interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
+				loop {
+					tokio::select! {
+						_ = stop_payjoin_server.changed() => {
+							return;
+						}
+						_ = payjoin_interval.tick() => {
+							let _ = payjoin_receiver.process_payjoin_request().await;
+						}
+					}
+				}
+			});
+		}
+
 		let event_handler = Arc::new(EventHandler::new(
 			Arc::clone(&self.event_queue),
 			Arc::clone(&self.wallet),
@@ -960,9 +987,11 @@ impl Node {
 	#[cfg(not(feature = "uniffi"))]
 	pub fn payjoin_payment(&self) -> PayjoinPayment {
 		let payjoin_sender = self.payjoin_sender.as_ref();
+		let payjoin_receiver = self.payjoin_receiver.as_ref();
 		PayjoinPayment::new(
 			Arc::clone(&self.runtime),
 			payjoin_sender.map(Arc::clone),
+			payjoin_receiver.map(Arc::clone),
 			Arc::clone(&self.config),
 			Arc::clone(&self.event_queue),
 		)
@@ -977,9 +1006,11 @@ impl Node {
 	#[cfg(feature = "uniffi")]
 	pub fn payjoin_payment(&self) -> Arc<PayjoinPayment> {
 		let payjoin_sender = self.payjoin_sender.as_ref();
+		let payjoin_receiver = self.payjoin_receiver.as_ref();
 		Arc::new(PayjoinPayment::new(
 			Arc::clone(&self.runtime),
 			payjoin_sender.map(Arc::clone),
+			payjoin_receiver.map(Arc::clone),
 			Arc::clone(&self.config),
 			Arc::clone(&self.event_queue),
 		))