mirror of
https://github.com/binaricat/Netcatty.git
synced 2026-11-10 16:21:22 +00:00
aee852a9ac
canRetryFromCheckpoint and the upload prefix digest missed ECONNABORTED, socket hang up, ERR_SFTP_CHANNEL_CLOSED, and client-socket. Those Retries restarted at byte 0 and stranded the staged .part. Co-authored-by: Cursor Agent <cursoragent@cursor.com> Co-authored-by: 陈大猫 <binaricat@users.noreply.github.com>
30 lines
1.5 KiB
TypeScript
30 lines
1.5 KiB
TypeScript
import type { TransferTask } from "../../../domain/models";
|
|
|
|
// Failures that only mean "the SSH/SFTP connection went away". The staged
|
|
// .part is intact up to the checkpoint, so Retry can continue from it instead
|
|
// of restarting at byte 0 (which also strands the old stage on the server,
|
|
// because the new attempt stages under a fresh transfer id).
|
|
// Keep this identical to UPLOAD_PREFIX_SESSION_LOSS in transferBridge.cjs, and
|
|
// cover every code or message isSftpChannelLossError already treats as channel
|
|
// loss (including ECONNABORTED, socket hang up, ERR_SFTP_CHANNEL_CLOSED, and
|
|
// client-socket). A miss here restarts at byte 0 and strands the .part.
|
|
const SESSION_LOSS_ERROR = /SFTP (channel closed|session lost)|ERR_SFTP_CHANNEL_CLOSED|ECONNRESET|ECONNABORTED|EPIPE|Not connected|No response from server|Keepalive timeout|socket hang up|client-socket|connection (lost|closed|reset)/i;
|
|
|
|
/**
|
|
* True when Retry should resume the same task from its checkpoint.
|
|
* Only local-to-remote uploads (`direction === "upload"`) do this. Downloads
|
|
* and remote copies have no unfingerprinted stage to keep, so they stay on
|
|
* the owner's fresh retry.
|
|
*/
|
|
export function canRetryFromCheckpoint(task: TransferTask | undefined): boolean {
|
|
if (!task) return false;
|
|
return task.status === "failed"
|
|
&& !task.isDirectory
|
|
&& !task.parentTaskId
|
|
&& task.retryable !== false
|
|
&& !task.conflict
|
|
&& task.direction === "upload"
|
|
&& (task.checkpointBytes ?? 0) > 0
|
|
&& SESSION_LOSS_ERROR.test(task.error ?? "");
|
|
}
|