mirror of
https://github.com/hydralauncher/hydra.git
synced 2026-01-27 12:51:03 +00:00
Merge pull request #1896 from hydralauncher/fix/peak-download-speed
Fix: peak download speed using current network speed fix
This commit is contained in:
@@ -420,7 +420,9 @@
|
|||||||
"delete_archive_title": "Would you like to delete {{fileName}}?",
|
"delete_archive_title": "Would you like to delete {{fileName}}?",
|
||||||
"delete_archive_description": "The file has been successfully extracted and it's no longer needed.",
|
"delete_archive_description": "The file has been successfully extracted and it's no longer needed.",
|
||||||
"yes": "Yes",
|
"yes": "Yes",
|
||||||
"no": "No"
|
"no": "No",
|
||||||
|
"network": "NETWORK",
|
||||||
|
"peak": "PEAK"
|
||||||
},
|
},
|
||||||
"settings": {
|
"settings": {
|
||||||
"downloads_path": "Downloads path",
|
"downloads_path": "Downloads path",
|
||||||
|
|||||||
@@ -408,7 +408,9 @@
|
|||||||
"delete_archive_title": "Deseja deletar {{fileName}}?",
|
"delete_archive_title": "Deseja deletar {{fileName}}?",
|
||||||
"delete_archive_description": "O arquivo foi extraído com sucesso e não é mais necessário.",
|
"delete_archive_description": "O arquivo foi extraído com sucesso e não é mais necessário.",
|
||||||
"yes": "Sim",
|
"yes": "Sim",
|
||||||
"no": "Não"
|
"no": "Não",
|
||||||
|
"network": "REDE",
|
||||||
|
"peak": "PICO"
|
||||||
},
|
},
|
||||||
"settings": {
|
"settings": {
|
||||||
"downloads_path": "Diretório dos downloads",
|
"downloads_path": "Diretório dos downloads",
|
||||||
|
|||||||
@@ -12,6 +12,8 @@ export interface DownloadState {
|
|||||||
gameId: string | null;
|
gameId: string | null;
|
||||||
gamesWithDeletionInProgress: string[];
|
gamesWithDeletionInProgress: string[];
|
||||||
extraction: ExtractionInfo | null;
|
extraction: ExtractionInfo | null;
|
||||||
|
peakSpeeds: Record<string, number>;
|
||||||
|
speedHistory: Record<string, number[]>;
|
||||||
}
|
}
|
||||||
|
|
||||||
const initialState: DownloadState = {
|
const initialState: DownloadState = {
|
||||||
@@ -19,6 +21,8 @@ const initialState: DownloadState = {
|
|||||||
gameId: null,
|
gameId: null,
|
||||||
gamesWithDeletionInProgress: [],
|
gamesWithDeletionInProgress: [],
|
||||||
extraction: null,
|
extraction: null,
|
||||||
|
peakSpeeds: {},
|
||||||
|
speedHistory: {},
|
||||||
};
|
};
|
||||||
|
|
||||||
export const downloadSlice = createSlice({
|
export const downloadSlice = createSlice({
|
||||||
@@ -28,6 +32,27 @@ export const downloadSlice = createSlice({
|
|||||||
setLastPacket: (state, action: PayloadAction<DownloadProgress | null>) => {
|
setLastPacket: (state, action: PayloadAction<DownloadProgress | null>) => {
|
||||||
state.lastPacket = action.payload;
|
state.lastPacket = action.payload;
|
||||||
if (!state.gameId && action.payload) state.gameId = action.payload.gameId;
|
if (!state.gameId && action.payload) state.gameId = action.payload.gameId;
|
||||||
|
|
||||||
|
// Track peak speed and speed history atomically when packet arrives
|
||||||
|
if (action.payload?.gameId && action.payload.downloadSpeed != null) {
|
||||||
|
const { gameId, downloadSpeed } = action.payload;
|
||||||
|
|
||||||
|
// Update peak speed if this is higher
|
||||||
|
const currentPeak = state.peakSpeeds[gameId] || 0;
|
||||||
|
if (downloadSpeed > currentPeak) {
|
||||||
|
state.peakSpeeds[gameId] = downloadSpeed;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Update speed history for chart
|
||||||
|
if (!state.speedHistory[gameId]) {
|
||||||
|
state.speedHistory[gameId] = [];
|
||||||
|
}
|
||||||
|
state.speedHistory[gameId].push(downloadSpeed);
|
||||||
|
// Keep only last 120 entries
|
||||||
|
if (state.speedHistory[gameId].length > 120) {
|
||||||
|
state.speedHistory[gameId].shift();
|
||||||
|
}
|
||||||
|
}
|
||||||
},
|
},
|
||||||
clearDownload: (state) => {
|
clearDownload: (state) => {
|
||||||
state.lastPacket = null;
|
state.lastPacket = null;
|
||||||
@@ -62,6 +87,20 @@ export const downloadSlice = createSlice({
|
|||||||
clearExtraction: (state) => {
|
clearExtraction: (state) => {
|
||||||
state.extraction = null;
|
state.extraction = null;
|
||||||
},
|
},
|
||||||
|
updatePeakSpeed: (
|
||||||
|
state,
|
||||||
|
action: PayloadAction<{ gameId: string; speed: number }>
|
||||||
|
) => {
|
||||||
|
const { gameId, speed } = action.payload;
|
||||||
|
const currentPeak = state.peakSpeeds[gameId] || 0;
|
||||||
|
if (speed > currentPeak) {
|
||||||
|
state.peakSpeeds[gameId] = speed;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
clearPeakSpeed: (state, action: PayloadAction<string>) => {
|
||||||
|
state.peakSpeeds[action.payload] = 0;
|
||||||
|
state.speedHistory[action.payload] = [];
|
||||||
|
},
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -72,4 +111,6 @@ export const {
|
|||||||
removeGameFromDeleting,
|
removeGameFromDeleting,
|
||||||
setExtractionProgress,
|
setExtractionProgress,
|
||||||
clearExtraction,
|
clearExtraction,
|
||||||
|
updatePeakSpeed,
|
||||||
|
clearPeakSpeed,
|
||||||
} = downloadSlice.actions;
|
} = downloadSlice.actions;
|
||||||
|
|||||||
@@ -412,10 +412,12 @@ function HeroDownloadView({
|
|||||||
</div>
|
</div>
|
||||||
)}
|
)}
|
||||||
|
|
||||||
{game.download?.downloader && (
|
{game.download?.downloader !== undefined && (
|
||||||
<div className="download-group__stat-item">
|
<div className="download-group__stat-item">
|
||||||
<div className="download-group__stat-content">
|
<div className="download-group__stat-content">
|
||||||
<Badge>{DOWNLOADER_NAME[game.download.downloader]}</Badge>
|
<Badge>
|
||||||
|
{DOWNLOADER_NAME[Number(game.download.downloader)]}
|
||||||
|
</Badge>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
)}
|
)}
|
||||||
@@ -512,8 +514,9 @@ export function DownloadGroup({
|
|||||||
|
|
||||||
const { formatDistance } = useDate();
|
const { formatDistance } = useDate();
|
||||||
|
|
||||||
const [peakSpeeds, setPeakSpeeds] = useState<Record<string, number>>({});
|
// Get speed history and peak speeds from Redux (centralized state)
|
||||||
const speedHistoryRef = useRef<Record<string, number[]>>({});
|
const speedHistory = useAppSelector((state) => state.download.speedHistory);
|
||||||
|
const peakSpeeds = useAppSelector((state) => state.download.peakSpeeds);
|
||||||
const [dominantColors, setDominantColors] = useState<Record<string, string>>(
|
const [dominantColors, setDominantColors] = useState<Record<string, string>>(
|
||||||
{}
|
{}
|
||||||
);
|
);
|
||||||
@@ -576,68 +579,8 @@ export function DownloadGroup({
|
|||||||
});
|
});
|
||||||
}, [library, lastPacket?.gameId]);
|
}, [library, lastPacket?.gameId]);
|
||||||
|
|
||||||
useEffect(() => {
|
// Speed history and peak speeds are now tracked in Redux (in setLastPacket reducer)
|
||||||
if (lastPacket?.gameId && lastPacket.downloadSpeed !== undefined) {
|
// No local effect needed - data is updated atomically when packets arrive
|
||||||
const gameId = lastPacket.gameId;
|
|
||||||
|
|
||||||
const currentPeak = peakSpeeds[gameId] || 0;
|
|
||||||
if (lastPacket.downloadSpeed > currentPeak) {
|
|
||||||
setPeakSpeeds((prev) => ({
|
|
||||||
...prev,
|
|
||||||
[gameId]: lastPacket.downloadSpeed,
|
|
||||||
}));
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!speedHistoryRef.current[gameId]) {
|
|
||||||
speedHistoryRef.current[gameId] = [];
|
|
||||||
}
|
|
||||||
|
|
||||||
speedHistoryRef.current[gameId].push(lastPacket.downloadSpeed);
|
|
||||||
|
|
||||||
if (speedHistoryRef.current[gameId].length > 120) {
|
|
||||||
speedHistoryRef.current[gameId].shift();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}, [lastPacket?.gameId, lastPacket?.downloadSpeed, peakSpeeds]);
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
for (const game of library) {
|
|
||||||
if (
|
|
||||||
game.download &&
|
|
||||||
game.download.progress < 0.01 &&
|
|
||||||
game.download.status !== "paused"
|
|
||||||
) {
|
|
||||||
// Fresh download - clear any old data
|
|
||||||
if (speedHistoryRef.current[game.id]?.length > 0) {
|
|
||||||
speedHistoryRef.current[game.id] = [];
|
|
||||||
setPeakSpeeds((prev) => ({ ...prev, [game.id]: 0 }));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}, [library]);
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
const timeouts: NodeJS.Timeout[] = [];
|
|
||||||
|
|
||||||
for (const game of library) {
|
|
||||||
if (
|
|
||||||
game.download?.progress === 1 &&
|
|
||||||
speedHistoryRef.current[game.id]?.length > 0
|
|
||||||
) {
|
|
||||||
const timeout = setTimeout(() => {
|
|
||||||
speedHistoryRef.current[game.id] = [];
|
|
||||||
setPeakSpeeds((prev) => ({ ...prev, [game.id]: 0 }));
|
|
||||||
}, 10_000);
|
|
||||||
timeouts.push(timeout);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return () => {
|
|
||||||
for (const timeout of timeouts) {
|
|
||||||
clearTimeout(timeout);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}, [library]);
|
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (library.length > 0 && title === t("download_in_progress")) {
|
if (library.length > 0 && title === t("download_in_progress")) {
|
||||||
@@ -842,7 +785,14 @@ export function DownloadGroup({
|
|||||||
? (lastPacket?.downloadSpeed ?? 0)
|
? (lastPacket?.downloadSpeed ?? 0)
|
||||||
: 0;
|
: 0;
|
||||||
const finalDownloadSize = getFinalDownloadSize(game);
|
const finalDownloadSize = getFinalDownloadSize(game);
|
||||||
const peakSpeed = peakSpeeds[game.id] || 0;
|
// Use lastPacket.gameId for lookup since that's the key used to store the data
|
||||||
|
// Fall back to game.id if lastPacket is not available
|
||||||
|
const dataKey = lastPacket?.gameId ?? game.id;
|
||||||
|
const gameSpeedHistory = speedHistory[dataKey] ?? [];
|
||||||
|
const storedPeak = peakSpeeds[dataKey];
|
||||||
|
// Use stored peak if available and > 0, otherwise use current speed as initial value
|
||||||
|
const peakSpeed =
|
||||||
|
storedPeak !== undefined && storedPeak > 0 ? storedPeak : downloadSpeed;
|
||||||
|
|
||||||
let currentProgress = game.download?.progress || 0;
|
let currentProgress = game.download?.progress || 0;
|
||||||
if (isGameExtracting) {
|
if (isGameExtracting) {
|
||||||
@@ -864,7 +814,7 @@ export function DownloadGroup({
|
|||||||
currentProgress={currentProgress}
|
currentProgress={currentProgress}
|
||||||
dominantColor={dominantColor}
|
dominantColor={dominantColor}
|
||||||
lastPacket={lastPacket}
|
lastPacket={lastPacket}
|
||||||
speedHistory={speedHistoryRef.current[game.id] || []}
|
speedHistory={gameSpeedHistory}
|
||||||
formatSpeed={formatSpeed}
|
formatSpeed={formatSpeed}
|
||||||
calculateETA={calculateETA}
|
calculateETA={calculateETA}
|
||||||
pauseDownload={pauseDownload}
|
pauseDownload={pauseDownload}
|
||||||
@@ -908,7 +858,9 @@ export function DownloadGroup({
|
|||||||
</button>
|
</button>
|
||||||
<div className="download-group__simple-meta">
|
<div className="download-group__simple-meta">
|
||||||
<div className="download-group__simple-meta-row">
|
<div className="download-group__simple-meta-row">
|
||||||
<Badge>{DOWNLOADER_NAME[game.download!.downloader]}</Badge>
|
<Badge>
|
||||||
|
{DOWNLOADER_NAME[Number(game.download!.downloader)]}
|
||||||
|
</Badge>
|
||||||
</div>
|
</div>
|
||||||
<div className="download-group__simple-meta-row">
|
<div className="download-group__simple-meta-row">
|
||||||
{extraction?.visibleId === game.id ? (
|
{extraction?.visibleId === game.id ? (
|
||||||
|
|||||||
Reference in New Issue
Block a user