plebdevs/src/hooks/useNostr.js

import { useState, useEffect, useRef } from "react";
import { SimplePool, relayInit, nip19 } from "nostr-tools";
import { useDispatch } from "react-redux";
import { addResource, addCourse, addWorkshop, addStream } from "@/redux/reducers/eventsReducer";
import { initialRelays } from "@/redux/reducers/userReducer";

export const useNostr = () => {
    const [relays, setRelays] = useState(initialRelays);
    const [relayStatuses, setRelayStatuses] = useState({});

    const dispatch = useDispatch();

    const pool = useRef(new SimplePool({ seenOnEnabled: true }));
    const subscriptions = useRef([]);

    const getRelayStatuses = () => {
        if (pool.current && pool.current._conn) {
            const statuses = {};

            for (const url in pool.current._conn) {
                const relay = pool.current._conn[url];
                statuses[url] = relay.status; // Assuming 'status' is an accessible field in Relay object
            }

            setRelayStatuses(statuses);
        }
    };

    const updateRelays = async (newRelays) => {
        // Set new relays
        setRelays(newRelays);

        // Ensure the relays are connected before using them
        await Promise.all(newRelays.map(relay => pool.current.ensureRelay(relay)));
    };

    const fetchKind0 = async (criteria, params) => {
        return new Promise((resolve, reject) => {
            const events = [];
            const timeoutDuration = 1000;

            const sub = pool.current.subscribeMany(relays, criteria, {
                ...params,
                onevent: (event) => {
                    events.push(event);
                },
                onerror: (error) => {
                    reject(error);
                }
            });

            // Set a timeout to sort and resolve with the most recent event
            setTimeout(() => {
                if (events.length === 0) {
                    resolve(null);  // or reject based on your needs
                } else {
                    events.sort((a, b) => b.created_at - a.created_at); // Sort in descending order
                    const mostRecentEventContent = JSON.parse(events[0].content);
                    resolve(mostRecentEventContent);
                }
            }, timeoutDuration);
        });
    };

    const fetchResources = async () => {
        const filter = [{kinds: [30023], authors: ["f33c8a9617cb15f705fc70cd461cfd6eaf22f9e24c33eabad981648e5ec6f741"]}];
    
        const params = {seenOnEnabled: true};
    
        const hasRequiredTags = (eventData) => {
            return eventData.some(([tag, value]) => tag === "t" && value === "plebdevs") && eventData.some(([tag, value]) => tag === "t" && value === "resource");
        };
    
        const sub = pool.current.subscribeMany(relays, filter, {
            ...params,
            onevent: (event) => {
                if (hasRequiredTags(event.tags)) {
                    dispatch(addResource(event));
                }
            },
            onerror: (error) => {
                console.error("Error fetching resources:", error);
            },
            oneose: () => {
                console.log("Subscription closed");
                sub.close();
            }
        });
    }

    const fetchWorkshops = async () => {
        const filter = [{kinds: [30023], authors: ["f33c8a9617cb15f705fc70cd461cfd6eaf22f9e24c33eabad981648e5ec6f741"]}];
    
        const params = {seenOnEnabled: true};
    
        const hasRequiredTags = (eventData) => {
            return eventData.some(([tag, value]) => tag === "t" && value === "plebdevs") && eventData.some(([tag, value]) => tag === "t" && value === "workshop");
        };
    
        const sub = pool.current.subscribeMany(relays, filter, {
            ...params,
            onevent: (event) => {
                if (hasRequiredTags(event.tags)) {
                    dispatch(addWorkshop(event));
                }
            },
            onerror: (error) => {
                console.error("Error fetching workshops:", error);
            },
            oneose: () => {
                console.log("Subscription closed");
                sub.close();
            }
        });
    }

    const fetchCourses = async () => {
        const filter = [{kinds: [30023], authors: ["f33c8a9617cb15f705fc70cd461cfd6eaf22f9e24c33eabad981648e5ec6f741"]}];
    
        const params = {seenOnEnabled: true};
    
        const hasRequiredTags = (eventData) => {
            return eventData.some(([tag, value]) => tag === "t" && value === "plebdevs") && eventData.some(([tag, value]) => tag === "t" && value === "course");
        };
    
        const sub = pool.current.subscribeMany(relays, filter, {
            ...params,
            onevent: (event) => {
                if (hasRequiredTags(event.tags)) {
                    dispatch(addCourse(event));
                }
            },
            onerror: (error) => {
                console.error("Error fetching courses:", error);
            },
            oneose: () => {
                console.log("Subscription closed");
                sub.close();
            }
        });
    }

    const fetchStreams = async () => {
        const filter = [{kinds: [30311], authors: ["f33c8a9617cb15f705fc70cd461cfd6eaf22f9e24c33eabad981648e5ec6f741"]}];
    
        const params = {seenOnEnabled: true};
    
        const hasRequiredTags = (eventData) => {
            return eventData.some(([tag, value]) => tag === "t" && value === "plebdevs");
        };
    
        const sub = pool.current.subscribeMany(relays, filter, {
            ...params,
            onevent: (event) => {
                if (hasRequiredTags(event.tags)) {
                    dispatch(addStream(event));
                }
            },
            onerror: (error) => {
                console.error("Error fetching streams:", error);
            },
            oneose: () => {
                console.log("Subscription closed");
                sub.close();
            }
        });
    }

    const fetchSingleEvent = async (id) => {
        return new Promise((resolve, reject) => {
            const sub = pool.current.subscribeMany(relays, [{ ids: [id] }], {
                onevent: (event) => {
                    resolve(event);
                },
                onerror: (error) => {
                    reject(error);
                },
                oneose: () => {
                    console.log("Subscription closed");
                    sub.close();
                }
            });
        });
    };

    const publishEvent = async (event) => {
        try {
            const publishPromises = pool.current.publish(relays, event);
            await Promise.all(publishPromises);
        } catch (error) {
            console.error("Error publishing event:", error);
        }
    };

    useEffect(() => {
        getRelayStatuses(); // Get initial statuses on mount

        // Copy current subscriptions to a local variable inside the effect
        const currentSubscriptions = subscriptions.current;

        return () => {
            // Use the local variable in the cleanup function
            currentSubscriptions.forEach((sub) => sub.unsub());
        };
    }, []);

    return {
        updateRelays,
        fetchSingleEvent,
        publishEvent,
        fetchKind0,
        fetchResources,
        fetchCourses,
        fetchWorkshops,
        getRelayStatuses,
    };
};