Add basic NWC payments

stackernews · Jan 20, 2024 · acb3e8e · acb3e8e
1 parent eacc60f
commit acb3e8e
Show file tree

Hide file tree

Showing 2 changed files with 55 additions and 3 deletions.
diff --git a/components/webln/index.js b/components/webln/index.js
@@ -52,13 +52,13 @@ export function useWebLN (key) {
 
   if (!key) {
     // TODO pick preferred enabled WebLN provider here
-    key = 'lnbits'
+    key = 'nwc'
   }
 
   const p = provider[key]
   const { config, enabled } = p
   const setConfig = (config) => _setConfig(key, config)
   const clearConfig = () => _clearConfig(key)
 
-  return { name: key, config, setConfig, clearConfig, enabled, sendPayment: p.sendPayment?.bind(p) }
+  return { name: key, config, setConfig, clearConfig, enabled, sendPayment: p.sendPayment.bind(p) }
 }
diff --git a/components/webln/nwc.js b/components/webln/nwc.js
@@ -1,6 +1,6 @@
 // https://github.com/getAlby/js-sdk/blob/master/src/webln/NostrWeblnProvider.ts
 
-import { Relay, nip04 } from 'nostr-tools'
+import { Relay, finalizeEvent, nip04 } from 'nostr-tools'
 
 function parseWalletConnectUrl (walletConnectUrl) {
   walletConnectUrl = walletConnectUrl
@@ -80,6 +80,58 @@ export default {
     const decrypted = await nip04.decrypt(this._secret, pubkey, content)
     return decrypted
   },
+  async sendPayment (bolt11) {
+    const relayUrl = this._relayUrl
+    const walletPubkey = this._walletPubkey
+    const secret = this._secret
+    return new Promise(function (resolve, reject) {
+      (async function () {
+        // need big timeout since NWC is async (user needs to confirm payment in wallet)
+        const timeout = 60000
+        let timer
+        const resetTimer = () => {
+          clearTimeout(timer)
+          timer = setTimeout(() => reject(new Error('timeout')), timeout)
+        }
+        resetTimer()
+        const relay = await Relay.connect(relayUrl)
+        const payload = {
+          method: 'pay_invoice',
+          params: { invoice: bolt11 }
+        }
+        const content = await nip04.encrypt(secret, walletPubkey, JSON.stringify(payload))
+        const request = finalizeEvent({
+          pubkey: walletPubkey,
+          kind: 23194,
+          created_at: Math.floor(Date.now() / 1000),
+          tags: [],
+          content
+        }, secret)
+        await relay.publish(request)
+        const sub = relay.subscribe([
+          {
+            kinds: [23195],
+            authors: [walletPubkey],
+            '#e': [request.id]
+          }
+        ], {
+          async onevent (response) {
+            resetTimer()
+            try {
+              const content = JSON.parse(await nip04.decrypt(secret, walletPubkey, response.content))
+              if (content.error) return reject(new Error(content.error.message))
+              if (content.result) return resolve(content.result.preimage)
+            } catch (err) {
+              return reject(err)
+            } finally {
+              clearTimeout(timer)
+              sub.close()
+            }
+          }
+        })
+      })().catch(reject)
+    })
+  },
   // WebLN compatible response
   // TODO: use NIP-47 get_info call
   async getInfo () {