Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
110 changes: 75 additions & 35 deletions apps/web/src/components/WebSocketConnectionSurface.tsx
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { type ReactNode, useEffect, useEffectEvent, useRef, useState } from "react";
import { type ReactNode, type RefObject, useEffect, useEffectEvent, useRef } from "react";

import { type SlowRpcAckRequest, useSlowRpcAckRequests } from "../rpc/requestLatencyState";
import {
Expand Down Expand Up @@ -53,6 +53,8 @@ function describeExhaustedToast(): string {
return "Retries exhausted trying to reconnect";
}

type ThreadToastId = ReturnType<typeof toastManager.add>;

function getConnectionDisplayName(status: WsConnectionStatus): string {
return status.connectionLabel?.trim() || "T3 Server";
}
Expand Down Expand Up @@ -90,6 +92,70 @@ function describeSlowRpcAckToast(requests: ReadonlyArray<SlowRpcAckRequest>): st
return `${count} request${count === 1 ? "" : "s"} waiting longer than ${thresholdSeconds}s.`;
}

function buildReconnectToast(
status: WsConnectionStatus,
nowMs: number,
triggerManualReconnect: () => void,
) {
return stackedThreadToast({
actionProps: {
children: "Retry now",
onClick: triggerManualReconnect,
},
data: {
hideCopyButton: true,
},
description:
status.nextRetryAt === null
? `Reconnecting... ${formatReconnectAttemptLabel(status)}`
: `Reconnecting in ${formatRetryCountdown(status.nextRetryAt, nowMs)}... ${formatReconnectAttemptLabel(status)}`,
timeout: 0,
title: buildReconnectTitle(status),
type: "loading",
});
}

function useReconnectToastCountdown(
status: WsConnectionStatus,
toastIdRef: RefObject<ThreadToastId | null>,
triggerManualReconnect: () => void,
) {
const nowMsRef = useRef(Date.now());

useEffect(() => {
if (status.reconnectPhase !== "waiting" || status.nextRetryAt === null) {
return;
}

const refreshReconnectToast = () => {
nowMsRef.current = Date.now();
const toastId = toastIdRef.current;
if (!toastId) {
return;
}

const currentStatus = getWsConnectionStatus();
if (getWsConnectionUiState(currentStatus) !== "reconnecting") {
return;
}

toastManager.update(
toastId,
buildReconnectToast(currentStatus, nowMsRef.current, triggerManualReconnect),
);
};

refreshReconnectToast();
const intervalId = window.setInterval(refreshReconnectToast, 1_000);

return () => {
window.clearInterval(intervalId);
};
}, [status.nextRetryAt, status.reconnectPhase, toastIdRef, triggerManualReconnect]);

return nowMsRef;
}

function SlowRpcAckRequestDetails({ requests }: { requests: ReadonlyArray<SlowRpcAckRequest> }) {
return (
<ul className="space-y-2.5 text-xs text-muted-foreground">
Expand Down Expand Up @@ -147,9 +213,8 @@ export function shouldRestartStalledReconnect(

export function WebSocketConnectionCoordinator() {
const status = useWsConnectionStatus();
const [nowMs, setNowMs] = useState(() => Date.now());
const lastForcedReconnectAtRef = useRef(0);
const toastIdRef = useRef<ReturnType<typeof toastManager.add> | null>(null);
const toastIdRef = useRef<ThreadToastId | null>(null);
const toastResetTimerRef = useRef<number | null>(null);
const previousUiStateRef = useRef<WsConnectionUiState>(getWsConnectionUiState(status));
const previousDisconnectedAtRef = useRef<string | null>(status.disconnectedAt);
Expand Down Expand Up @@ -200,6 +265,11 @@ export function WebSocketConnectionCoordinator() {

runReconnect(false);
});
const reconnectToastNowMsRef = useReconnectToastCountdown(
status,
toastIdRef,
triggerManualReconnect,
);

useEffect(() => {
const handleOnline = () => {
Expand All @@ -220,21 +290,6 @@ export function WebSocketConnectionCoordinator() {
};
}, []);

useEffect(() => {
if (status.reconnectPhase !== "waiting" || status.nextRetryAt === null) {
return;
}

setNowMs(Date.now());
const intervalId = window.setInterval(() => {
setNowMs(Date.now());
}, 1_000);

return () => {
window.clearInterval(intervalId);
};
}, [status.nextRetryAt, status.reconnectPhase]);

useEffect(() => {
if (
status.reconnectPhase !== "waiting" ||
Expand Down Expand Up @@ -308,22 +363,7 @@ export function WebSocketConnectionCoordinator() {
title: buildReconnectTitle(status),
type: "error",
})
: stackedThreadToast({
actionProps: {
children: "Retry now",
onClick: triggerManualReconnect,
},
data: {
hideCopyButton: true,
},
description:
status.nextRetryAt === null
? `Reconnecting... ${formatReconnectAttemptLabel(status)}`
: `Reconnecting in ${formatRetryCountdown(status.nextRetryAt, nowMs)}... ${formatReconnectAttemptLabel(status)}`,
timeout: 0,
title: buildReconnectTitle(status),
type: "loading",
});
: buildReconnectToast(status, reconnectToastNowMsRef.current, triggerManualReconnect);

if (toastIdRef.current) {
toastManager.update(toastIdRef.current, toastPayload);
Expand Down Expand Up @@ -365,7 +405,7 @@ export function WebSocketConnectionCoordinator() {

previousUiStateRef.current = uiState;
previousDisconnectedAtRef.current = status.disconnectedAt;
}, [nowMs, status]);
}, [reconnectToastNowMsRef, status]);

useEffect(() => {
return () => {
Expand Down
Binary file not shown.
Binary file not shown.
Loading