Merge pull request #74 from AustinKelsay/bugfix/update-bitcoin-connect-integration

Bugfix/update bitcoin connect integration
This commit is contained in:
Austin Kelsay 2025-05-13 12:11:52 -05:00 committed by GitHub
commit d906625168
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 109 additions and 37 deletions

View File

@ -5,31 +5,65 @@ const Button = dynamic(() => import('@getalby/bitcoin-connect-react').then(mod =
ssr: false, ssr: false,
}); });
// Module-level state
let initialized = false; let initialized = false;
let initializationPromise = null;
let bitcoinConnectClient = null;
export async function initializeBitcoinConnect() { export async function initializeBitcoinConnect() {
if (!initialized) { if (initialized) return bitcoinConnectClient; // fast path
if (initializationPromise) return initializationPromise; // someone else is already doing the work
initializationPromise = (async () => {
try { try {
const { init } = await import('@getalby/bitcoin-connect-react'); // Import the required modules
// Check if custom elements are already registered const bc = await import('@getalby/bitcoin-connect-react');
if (!customElements.get('bc-balance')) { const sdkModule = await import('@getalby/sdk');
init({
appName: 'PlebDevs', // Initialize with the config options
filters: ['nwc'], bc.init({
showBalance: false, appName: 'PlebDevs',
}); filters: ['nwc'],
initialized = true; showBalance: false,
});
// Store the client for use in components
bitcoinConnectClient = bc.client;
// Export NWC functionality directly
if (!bitcoinConnectClient) {
console.log('Creating backup NWC client instance');
// Create fallback if client isn't available
bitcoinConnectClient = {
nwc: sdkModule.nwc,
webln: sdkModule.webln
};
} }
initialized = true;
console.log('Bitcoin Connect initialized successfully, client:', bitcoinConnectClient);
return bitcoinConnectClient;
} catch (error) { } catch (error) {
// If the error is about custom element already being defined, we can ignore it // If the error is about custom element already being defined, we can ignore it
// as it means the component is already initialized // as it means the component is already initialized
if (!error.message?.includes('has already been defined as a custom element')) { if (!error.message?.includes('has already been defined as a custom element')) {
console.error('Error initializing Bitcoin Connect:', error); console.error('Error initializing Bitcoin Connect:', error);
} }
throw error; // re-throw so callers see the failure
} finally {
initializationPromise = null; // allow retry after failure
} }
} })();
return initializationPromise;
} }
// Export the SDK for direct usage
export const getSDK = async () => {
return import('@getalby/sdk');
};
const BitcoinConnectButton = () => { const BitcoinConnectButton = () => {
useEffect(() => { useEffect(() => {
initializeBitcoinConnect(); initializeBitcoinConnect();

View File

@ -1,10 +1,9 @@
import React, { useState, useEffect } from 'react'; import React, { useState, useEffect } from 'react';
import { track } from '@vercel/analytics'; import { track } from '@vercel/analytics';
import { initializeBitcoinConnect } from './BitcoinConnect'; import { initializeBitcoinConnect, getSDK } from './BitcoinConnect';
import { LightningAddress } from '@getalby/lightning-tools'; import { LightningAddress } from '@getalby/lightning-tools';
import { useToast } from '@/hooks/useToast'; import { useToast } from '@/hooks/useToast';
import { useSession } from 'next-auth/react'; import { useSession } from 'next-auth/react';
import { webln, nwc } from '@getalby/sdk';
import { useRouter } from 'next/router'; import { useRouter } from 'next/router';
import { Divider } from 'primereact/divider'; import { Divider } from 'primereact/divider';
import dynamic from 'next/dynamic'; import dynamic from 'next/dynamic';
@ -38,23 +37,28 @@ const SubscriptionPaymentButtons = ({
const amount = 50000; const amount = 50000;
useEffect(() => { useEffect(() => {
initializeBitcoinConnect(); // Initialize Bitcoin Connect as early as possible
initializeBitcoinConnect().catch(err => {
console.error("Error initializing Bitcoin Connect:", err);
});
}, []); }, []);
useEffect(() => { useEffect(() => {
let intervalId; let intervalId;
if (invoice) { if (invoice) {
intervalId = setInterval(async () => { intervalId = setInterval(async () => {
const paid = await invoice.verifyPayment(); try {
const paid = await invoice.verifyPayment();
if (paid && invoice.preimage) { if (paid) {
clearInterval(intervalId);
// handle success
onSuccess();
}
} catch (error) {
console.error("Error verifying payment:", error);
clearInterval(intervalId); clearInterval(intervalId);
// handle success
onSuccess();
} }
}, 1000); }, 1000);
} else {
console.error('no invoice');
} }
return () => { return () => {
@ -62,7 +66,7 @@ const SubscriptionPaymentButtons = ({
clearInterval(intervalId); clearInterval(intervalId);
} }
}; };
}, [invoice]); }, [invoice, onSuccess]);
const fetchInvoice = async () => { const fetchInvoice = async () => {
try { try {
@ -94,12 +98,22 @@ const SubscriptionPaymentButtons = ({
}; };
const handleRecurringSubscription = async () => { const handleRecurringSubscription = async () => {
setIsProcessing(true); if (!setIsProcessing) {
const newNwc = nwc.NWCClient.withNewSecret(); console.warn("setIsProcessing is not defined");
const yearFromNow = new Date(); } else {
yearFromNow.setFullYear(yearFromNow.getFullYear() + 1); setIsProcessing(true);
}
try { try {
// Get SDK directly to avoid client issues
const sdk = await getSDK();
// Create NWC client
const newNwc = sdk.nwc.NWCClient.withNewSecret();
const yearFromNow = new Date();
yearFromNow.setFullYear(yearFromNow.getFullYear() + 1);
const initNwcOptions = { const initNwcOptions = {
name: 'plebdevs.com', name: 'plebdevs.com',
requestMethods: ['pay_invoice'], requestMethods: ['pay_invoice'],
@ -108,31 +122,44 @@ const SubscriptionPaymentButtons = ({
budgetRenewal: 'monthly', budgetRenewal: 'monthly',
expiresAt: yearFromNow, expiresAt: yearFromNow,
}; };
console.log("Initializing NWC with options:", initNwcOptions);
// Initialize NWC
await newNwc.initNWC(initNwcOptions); await newNwc.initNWC(initNwcOptions);
showToast('info', 'Alby', 'Alby connection window opened.'); showToast('info', 'Alby', 'Alby connection window opened.');
// Get NWC URL
const newNWCUrl = newNwc.getNostrWalletConnectUrl(); const newNWCUrl = newNwc.getNostrWalletConnectUrl();
if (newNWCUrl) { if (newNWCUrl) {
const nwc = new webln.NostrWebLNProvider({ const nwcProvider = new sdk.webln.NostrWebLNProvider({
nostrWalletConnectUrl: newNWCUrl, nostrWalletConnectUrl: newNWCUrl,
}); });
await nwc.enable(); await nwcProvider.enable();
console.log("NWC provider enabled");
const invoice = await fetchInvoice(); const invoice = await fetchInvoice();
console.log("Invoice fetched for recurring payment:", !!invoice);
if (!invoice || !invoice.paymentRequest) { if (!invoice || !invoice.paymentRequest) {
showToast('error', 'NWC', `Failed to fetch invoice from ${lnAddress}`); showToast('error', 'NWC', `Failed to fetch invoice from ${lnAddress}`);
if (setIsProcessing) setIsProcessing(false);
return; return;
} }
const paymentResponse = await nwc.sendPayment(invoice.paymentRequest); console.log("Sending payment with NWC provider");
const paymentResponse = await nwcProvider.sendPayment(invoice.paymentRequest);
console.log("Payment response:", paymentResponse?.preimage);
if (!paymentResponse || !paymentResponse?.preimage) { if (!paymentResponse || !paymentResponse?.preimage) {
showToast('error', 'NWC', 'Payment failed'); showToast('error', 'NWC', 'Payment failed');
if (setIsProcessing) setIsProcessing(false);
return; return;
} }
console.log("Updating subscription in API");
const subscriptionResponse = await axios.put('/api/users/subscription', { const subscriptionResponse = await axios.put('/api/users/subscription', {
userId: session.user.id, userId: session.user.id,
isSubscribed: true, isSubscribed: true,
@ -154,7 +181,7 @@ const SubscriptionPaymentButtons = ({
showToast('error', 'Subscription Setup Failed', `Error: ${error.message}`); showToast('error', 'Subscription Setup Failed', `Error: ${error.message}`);
if (onError) onError(error); if (onError) onError(error);
} finally { } finally {
setIsProcessing(false); if (setIsProcessing) setIsProcessing(false);
} }
}; };
@ -164,29 +191,40 @@ const SubscriptionPaymentButtons = ({
return; return;
} }
setIsProcessing(true); if (setIsProcessing) setIsProcessing(true);
try { try {
const nwc = new webln.NostrWebLNProvider({ const sdk = await getSDK();
const nwc = new sdk.webln.NostrWebLNProvider({
nostrWalletConnectUrl: nwcInput, nostrWalletConnectUrl: nwcInput,
}); });
await nwc.enable(); await nwc.enable();
console.log("Manual NWC provider enabled");
const invoice = await fetchInvoice(); const invoice = await fetchInvoice();
console.log("Invoice fetched for manual NWC:", !!invoice);
if (!invoice || !invoice.paymentRequest) { if (!invoice || !invoice.paymentRequest) {
showToast('error', 'NWC', `Failed to fetch invoice from ${lnAddress}`); showToast('error', 'NWC', `Failed to fetch invoice from ${lnAddress}`);
if (setIsProcessing) setIsProcessing(false);
return; return;
} }
console.log("Sending payment with manual NWC");
const payResponse = await nwc.sendPayment(invoice.paymentRequest); const payResponse = await nwc.sendPayment(invoice.paymentRequest);
console.log("Payment response:", payResponse?.preimage);
if (!payResponse || !payResponse.preimage) { if (!payResponse || !payResponse.preimage) {
showToast('error', 'NWC', 'Payment failed'); showToast('error', 'NWC', 'Payment failed');
if (setIsProcessing) setIsProcessing(false);
return; return;
} }
showToast('success', 'NWC', 'Payment successful!'); showToast('success', 'NWC', 'Payment successful!');
try { try {
console.log("Updating subscription in API (manual)");
const subscriptionResponse = await axios.put('/api/users/subscription', { const subscriptionResponse = await axios.put('/api/users/subscription', {
userId: session.user.id, userId: session.user.id,
isSubscribed: true, isSubscribed: true,
@ -210,7 +248,7 @@ const SubscriptionPaymentButtons = ({
showToast('error', 'NWC', `An error occurred: ${error.message}`); showToast('error', 'NWC', `An error occurred: ${error.message}`);
if (onError) onError(error); if (onError) onError(error);
} finally { } finally {
setIsProcessing(false); if (setIsProcessing) setIsProcessing(false);
} }
}; };

View File

@ -127,7 +127,7 @@ export default function CourseDetails({
if (session?.user && session.user?.role?.subscribed && decryptionPerformed) { if (session?.user && session.user?.role?.subscribed && decryptionPerformed) {
return ( return (
<GenericButton <GenericButton
tooltipOptions={{ position: 'top' }} tooltipOptions={{ position: 'right' }}
tooltip={`You are subscribed so you can access all paid content`} tooltip={`You are subscribed so you can access all paid content`}
icon="pi pi-check" icon="pi pi-check"
label="Subscribed" label="Subscribed"
@ -154,7 +154,7 @@ export default function CourseDetails({
outlined outlined
size="small" size="small"
tooltip={`You paid ${processedEvent.price} sats to access this course (or potentially less if a discount was applied)`} tooltip={`You paid ${processedEvent.price} sats to access this course (or potentially less if a discount was applied)`}
tooltipOptions={{ position: 'top' }} tooltipOptions={{ position: 'right' }}
className="cursor-default hover:opacity-100 hover:bg-transparent focus:ring-0" className="cursor-default hover:opacity-100 hover:bg-transparent focus:ring-0"
/> />
); );
@ -163,7 +163,7 @@ export default function CourseDetails({
if (paidCourse && author && processedEvent?.pubkey === session?.user?.pubkey) { if (paidCourse && author && processedEvent?.pubkey === session?.user?.pubkey) {
return ( return (
<GenericButton <GenericButton
tooltipOptions={{ position: 'top' }} tooltipOptions={{ position: 'right' }}
tooltip={`You created this paid course, users must pay ${processedEvent.price} sats to access it`} tooltip={`You created this paid course, users must pay ${processedEvent.price} sats to access it`}
icon="pi pi-check" icon="pi pi-check"
label={`Price ${processedEvent.price} sats`} label={`Price ${processedEvent.price} sats`}