fix: multiple issues #510, #511, #515, #516

backend/src/controllers/stream.controller.ts

@@ -443,13 +443,6 @@ export const getUserStreamSummary = async (req: Request<{ address: string }>, re
       claimableInTotal += BigInt(claimable.claimableAmount);
     }
 
-    let claimableOutTotal = 0n;
-    for (const stream of outgoingStreams) {
-      // Outgoing streams also need to account for what the recipient can currently claim
-      const claimable = claimableAmountService.getClaimableAmount(stream as any, calculatedAt);
-      claimableOutTotal += BigInt(claimable.claimableAmount);
-    }
-
     const totalStreamsCreated = outgoingStreams.length;
     const totalStreamedOut = sumStringI128(outgoingStreams.map((stream: any) => stream.withdrawnAmount));
     const totalStreamedIn = sumStringI128(incomingStreams.map((stream: any) => stream.withdrawnAmount));

frontend/src/app/streams/[id]/page.tsx

@@ -96,31 +96,34 @@ export default function StreamDetailsPage() {
   });
 
   // Fetch stream data
-  const fetchStream = useCallback(async () => {
+  const fetchStream = useCallback(async (signal?: AbortSignal) => {
     if (!streamId) return;
     try {
-      const response = await fetch(`${API_BASE_URL}/streams/${streamId}`);
+      const response = await fetch(`${API_BASE_URL}/streams/${streamId}`, { signal });
       if (!response.ok) throw new Error("Stream not found");
       const data = await response.json();
       setStream(data);
     } catch (err) {
+      if (err instanceof Error && err.name === "AbortError") return;
       setError(err instanceof Error ? err.message : "Failed to fetch stream");
     }
   }, [streamId]);
 
   // Fetch events
-  const fetchEvents = useCallback(async (page: number) => {
+  const fetchEvents = useCallback(async (page: number, signal?: AbortSignal) => {
     if (!streamId) return;
     try {
       const response = await fetch(
-        `${API_BASE_URL}/streams/${streamId}/events?page=${page}&limit=${EVENTS_PER_PAGE}`
+        `${API_BASE_URL}/streams/${streamId}/events?page=${page}&limit=${EVENTS_PER_PAGE}`,
+        { signal }
       );
       if (response.ok) {
         const data = await response.json();
         setEvents(data.events || []);
         setEventsTotal(data.total || 0);
       }
     } catch (err) {
+      if (err instanceof Error && err.name === "AbortError") return;
       console.error("Failed to fetch events:", err);
     }
   }, [streamId]);
@@ -129,20 +132,26 @@ export default function StreamDetailsPage() {
   useEffect(() => {
     if (!isHydrated) return;
 
+    const controller = new AbortController();
+
     const loadData = async () => {
       setLoading(true);
-      await Promise.all([fetchStream(), fetchEvents(1)]);
+      await Promise.all([fetchStream(controller.signal), fetchEvents(1, controller.signal)]);
       setLoading(false);
     };
 
     loadData();
+
+    return () => controller.abort();
   }, [isHydrated, fetchStream, fetchEvents]);
 
   // Handle SSE events
   useEffect(() => {
     if (streamEvents.length > 0) {
-      fetchStream();
-      fetchEvents(eventsPage);
+      const controller = new AbortController();
+      fetchStream(controller.signal);
+      fetchEvents(eventsPage, controller.signal);
+      return () => controller.abort();
     }
   }, [streamEvents, fetchStream, fetchEvents, eventsPage]);
 

frontend/src/utils/csvExport.ts

@@ -41,5 +41,6 @@ export const downloadCSV = <T extends CsvRow>(data: T[], filename: string) => {
         document.body.appendChild(link);
         link.click();
         document.body.removeChild(link);
+        URL.revokeObjectURL(url);
     }
 };