saulteafarmer/plebdevs
1
0
Fork 0
mirror of https://github.com/AustinKelsay/plebdevs.git synced 2025-06-06 18:31:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added timeout to zap subscription to have 0 zap events zaps load faster

Browse Source
This commit is contained in:
austinkelsay 2024-08-26 16:10:08 -05:00
parent 49a65a1db1
commit 371cbf269c
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/hooks/nostrQueries/zaps/useZapsSubscription.js
View File

@ -18,6 +18,7 @@ export function useZapsSubscription({ event }) {
useEffect(() => { useEffect(() => {
let subscription; let subscription;
const zapIds = new Set(); const zapIds = new Set();
let timeoutId;
async function subscribeToZaps() { async function subscribeToZaps() {
if (!event || !ndk) return; if (!event || !ndk) return;
@ -38,14 +39,26 @@ export function useZapsSubscription({ event }) {
zapIds.add(zapEvent.id); zapIds.add(zapEvent.id);
addZap(zapEvent); addZap(zapEvent);
setZapsLoading(false); setZapsLoading(false);
clearTimeout(timeoutId);
} }
}); });
subscription.on('close', () => {
setZapsLoading(false);
})
subscription.on('eose', () => { subscription.on('eose', () => {
console.log("eose in hook")
setZapsLoading(false); setZapsLoading(false);
}); });
await subscription.start(); await subscription.start();
// Set a 4-second timeout to stop loading state if no zaps are received
timeoutId = setTimeout(() => {
setZapsLoading(false);
}, 4000);
} catch (error) { } catch (error) {
console.error("Error subscribing to zaps:", error); console.error("Error subscribing to zaps:", error);
setZapsError(error.message); setZapsError(error.message);
@ -62,6 +75,7 @@ export function useZapsSubscription({ event }) {
if (subscription) { if (subscription) {
subscription.stop(); subscription.stop();
} }
clearTimeout(timeoutId);
}; };
}, [event, ndk, addZap]); }, [event, ndk, addZap]);