Stop polling on completion/fail #77

Merged
ic3w0lf22 merged 2 commits from issue-74 into staging 2025-04-03 22:12:34 +00:00

@ -1,6 +1,6 @@
"use client"; "use client";
import { useEffect, useState } from "react"; import { useEffect, useState, useRef } from "react";
import { useParams, useRouter } from "next/navigation"; import { useParams, useRouter } from "next/navigation";
import { CircularProgress, Typography, Card, CardContent, Button } from "@mui/material"; import { CircularProgress, Typography, Card, CardContent, Button } from "@mui/material";
import Webpage from "@/app/_components/webpage"; import Webpage from "@/app/_components/webpage";
@ -17,11 +17,14 @@ interface Operation {
} }
export default function OperationStatusPage() { export default function OperationStatusPage() {
const { operationId } = useParams();
const router = useRouter(); const router = useRouter();
const [operation, setOperation] = useState<Operation | null>(null); const { operationId } = useParams();
const [loading, setLoading] = useState(true); const [loading, setLoading] = useState(true);
const [error, setError] = useState<string | null>(null); const [error, setError] = useState<string | null>(null);
const [operation, setOperation] = useState<Operation | null>(null);
const intervalRef = useRef<NodeJS.Timeout | null>(null);
useEffect(() => { useEffect(() => {
if (!operationId) return; if (!operationId) return;
@ -32,8 +35,13 @@ export default function OperationStatusPage() {
if (!response.ok) throw new Error("Failed to fetch operation"); if (!response.ok) throw new Error("Failed to fetch operation");
const data = await response.json(); const data: Operation = await response.json();
setOperation(data); setOperation(data);
if (data.Status !== 0 && intervalRef.current) {
clearInterval(intervalRef.current);
intervalRef.current = null;
}
} catch (err: unknown) { } catch (err: unknown) {
if (err instanceof Error) { if (err instanceof Error) {
setError(err.message); setError(err.message);
@ -46,23 +54,16 @@ export default function OperationStatusPage() {
}; };
fetchOperation(); fetchOperation();
const interval = setInterval(fetchOperation, 5000); if (!intervalRef.current) {
intervalRef.current = setInterval(fetchOperation, 1000);
}
return () => clearInterval(interval); return () => {
}, [operationId]); if (intervalRef.current) {
clearInterval(intervalRef.current);
const getStatusClass = (status: number) => {
switch (status) {
case 0:
return "created";
case 1:
return "completed";
case 2:
return "failed";
default:
return "";
} }
}; };
}, [operationId]);
const getStatusText = (status: number) => { const getStatusText = (status: number) => {
switch (status) { switch (status) {
@ -77,6 +78,8 @@ export default function OperationStatusPage() {
} }
}; };
const getStatusClass = (status: number) => getStatusText(status).toLowerCase();
return ( return (
<Webpage> <Webpage>
<main className="operation-status"> <main className="operation-status">