Add PayjoinHandler

  Add two new structs `PayjoinHandler` and `PayjoinReceiver`.  The first
  is public and holds the later as a property and can be used in order to
  serve incoming payjoin transactions.

  `PayjoinReceiver` implemented `lightning_payjoin::Receiver` trait to
  allow us to receive payjoin transactions or open a channel.

Author: jbesraa

Cargo.toml

@@ -28,15 +28,23 @@ panic = 'abort'     # Abort on panic
 default = []
 
 [dependencies]
-lightning = { version = "0.0.121", features = ["std"] }
-lightning-invoice = { version = "0.29.0" }
-lightning-net-tokio = { version = "0.0.121" }
-lightning-persister = { version = "0.0.121" }
-lightning-background-processor = { version = "0.0.121", features = ["futures"] }
-lightning-rapid-gossip-sync = { version = "0.0.121" }
-lightning-transaction-sync = { version = "0.0.121", features = ["esplora-async-https", "time"] }
-lightning-liquidity = { version = "0.1.0-alpha.1", features = ["std"] }
-
+# lightning = { version = "0.0.121", features = ["std"] }
+# lightning-invoice = { version = "0.29.0" }
+# lightning-net-tokio = { version = "0.0.121" }
+# lightning-persister = { version = "0.0.121" }
+# lightning-background-processor = { version = "0.0.121", features = ["futures"] }
+# lightning-rapid-gossip-sync = { version = "0.0.121" }
+# lightning-transaction-sync = { version = "0.0.121", features = ["esplora-async-https", "time"] }
+# lightning-liquidity = { version = "0.1.0-alpha.1", features = ["std"] }
+lightning = { git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a", features = ["std"] }
+lightning-invoice = {git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a"}
+lightning-net-tokio = {git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a"}
+lightning-persister = {git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a"}
+lightning-background-processor = {  git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a", features = ["futures"] }
+lightning-rapid-gossip-sync = { git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a" }
+lightning-transaction-sync = { git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a", features = ["esplora-async-https", "time"] }
+lightning-liquidity = { git = "https://github.com/jbesraa/lightning-liquidity.git", rev = "0588dd4", version = "0.1.0-alpha.1", features = ["std"] }
+lightning-payjoin = { path = "./lightning-payjoin" }
 #lightning = { git = "https://github.com/lightningdevkit/rust-lightning", branch="main", features = ["std"] }
 #lightning-invoice = { git = "https://github.com/lightningdevkit/rust-lightning", branch="main" }
 #lightning-net-tokio = { git = "https://github.com/lightningdevkit/rust-lightning", branch="main" }
@@ -54,7 +62,6 @@ lightning-liquidity = { version = "0.1.0-alpha.1", features = ["std"] }
 #lightning-rapid-gossip-sync = { path = "../rust-lightning/lightning-rapid-gossip-sync" }
 #lightning-transaction-sync = { path = "../rust-lightning/lightning-transaction-sync", features = ["esplora-async"] }
 #lightning-liquidity = { path = "../lightning-liquidity", features = ["std"] }
-
 bdk = { version = "0.29.0", default-features = false, features = ["std", "async-interface", "use-esplora-async", "sqlite-bundled", "keys-bip39"]}
 
 reqwest = { version = "0.11", default-features = false, features = ["json", "rustls-tls"] }
@@ -78,7 +85,8 @@ prost = { version = "0.11.6", default-features = false}
 winapi = { version = "0.3", features = ["winbase"] }
 
 [dev-dependencies]
-lightning = { version = "0.0.121", features = ["std", "_test_utils"] }
+lightning = { git = "https://github.com/jbesraa/rust-lightning.git", rev = "d3e2d5a", features = ["std", "_test_utils"] }
+# lightning = { version = "0.0.121", features = ["std", "_test_utils"] }
 #lightning = { git = "https://github.com/lightningdevkit/rust-lightning", branch="main", features = ["std", "_test_utils"] }
 electrum-client = { version = "0.15.1", default-features = true }
 bitcoincore-rpc = { version = "0.17.0", default-features = false }

src/error.rs

@@ -139,3 +139,19 @@ impl From<lightning_transaction_sync::TxSyncError> for Error {
 		Self::TxSyncFailed
 	}
 }
+
+impl From<Error> for lightning_payjoin::error::Error {
+	fn from(e: Error) -> Self {
+		match e {
+			Error::WalletOperationFailed => lightning_payjoin::error::Error::Internal(
+				lightning_payjoin::error::InternalError::WalletOperationFailed,
+			),
+			Error::OnchainTxSigningFailed => lightning_payjoin::error::Error::Internal(
+				lightning_payjoin::error::InternalError::OnchainTxSigningFailed,
+			),
+			_ => lightning_payjoin::error::Error::Internal(
+				lightning_payjoin::error::InternalError::NodeFailed,
+			),
+		}
+	}
+}

src/lib.rs

@@ -108,6 +108,7 @@ use error::Error;
 
 pub use event::Event;
 pub use types::{BestBlock, ChannelConfig};
+mod payjoin_handler;
 
 pub use io::utils::generate_entropy_mnemonic;
 

src/payjoin_handler.rs

@@ -0,0 +1,98 @@
+use crate::types::{ChannelManager, Wallet};
+use bdk::SignOptions;
+use bitcoin::address::NetworkChecked;
+use bitcoin::psbt::Psbt;
+use bitcoin::secp256k1::PublicKey;
+use bitcoin::ScriptBuf;
+use lightning::ln::ChannelId;
+use lightning::util::persist::KVStore;
+use lightning_payjoin::error::Error as PayjoinError;
+use lightning_payjoin::scheduler::ChannelScheduler;
+use lightning_payjoin::{LightningPayjoin, Receiver};
+use std::sync::Arc;
+use tokio::sync::Mutex;
+
+#[derive(Clone)]
+pub(crate) struct PayjoinHandler<K: KVStore + Sync + Send + 'static> {
+	inner: Arc<Mutex<LightningPayjoin<PayjoinReceiver<K>>>>,
+}
+
+impl<K: KVStore + Sync + Send + 'static> PayjoinHandler<K> {
+	pub(crate) fn new(
+		wallet: Arc<Wallet>, channel_manager: Arc<ChannelManager<K>>,
+		scheduler: Arc<Mutex<ChannelScheduler>>, payjoin_directory: lightning_payjoin::Url,
+		payjoin_relay: lightning_payjoin::Url,
+	) -> Self {
+		let payjoin_receiver = PayjoinReceiver::new(wallet, channel_manager);
+		let lightning_payjoin =
+			LightningPayjoin::new(payjoin_receiver, scheduler, payjoin_directory, payjoin_relay);
+		let inner = Arc::new(Mutex::new(lightning_payjoin));
+		Self { inner }
+	}
+
+	pub(crate) async fn process_request(&self) -> Result<(), PayjoinError> {
+		self.inner.lock().await.process_request().await
+	}
+
+	pub(crate) async fn payjoin_uri(&self, amount: bitcoin::Amount) -> String {
+		self.inner.lock().await.construct_payjoin_uri(amount)
+	}
+}
+
+struct PayjoinReceiver<K: KVStore + Sync + Send> {
+	channel_manager: Arc<ChannelManager<K>>,
+	wallet: Arc<Wallet>,
+}
+
+impl<K> std::ops::Deref for PayjoinReceiver<K>
+where
+	K: KVStore + Sync + Send + 'static,
+{
+	type Target = dyn Receiver;
+
+	fn deref(&self) -> &Self::Target {
+		self
+	}
+}
+
+impl<K: KVStore + Sync + Send> PayjoinReceiver<K> {
+	fn new(wallet: Arc<Wallet>, channel_manager: Arc<ChannelManager<K>>) -> Self {
+		Self { wallet, channel_manager }
+	}
+}
+
+impl<K: KVStore + Sync + Send> Receiver for PayjoinReceiver<K> {
+	fn get_new_address(&self) -> Result<bitcoin::Address<NetworkChecked>, PayjoinError> {
+		Ok(self.wallet.get_new_address()?)
+	}
+
+	fn check_inputs_not_owned(&self, script: &ScriptBuf) -> Result<bool, PayjoinError> {
+		Ok(self.wallet.is_mine(script)?)
+	}
+
+	fn identify_my_outputs(&self, script: &ScriptBuf) -> Result<bool, PayjoinError> {
+		Ok(self.wallet.is_mine(script)?)
+	}
+
+	fn funding_transaction_generated(
+		&self, temporary_channel_id: &ChannelId, counterparty_node_id: PublicKey,
+		funding_tx: bitcoin::Transaction,
+	) -> Result<(), PayjoinError> {
+		Ok(self.channel_manager.funding_transaction_generated(
+			temporary_channel_id,
+			&counterparty_node_id,
+			funding_tx,
+		)?)
+	}
+
+	fn sign_tx(&self, psbt: &Psbt) -> Result<Psbt, PayjoinError> {
+		let mut sign_options = SignOptions::default();
+		sign_options.try_finalize = false;
+		Ok(self.wallet.sign_tx(psbt, Some(sign_options))?)
+	}
+
+	fn can_broadcast(&self, _transaction: &bitcoin::Transaction) -> Result<bool, PayjoinError> {
+		// unimplemented!()
+		Ok(true)
+	}
+}