fix(cli,web): команды аккаунтов в CLI и повтор запросов при 429
- deploy/glchat-cli.sh: reset-password/make-admin/remove-admin больше не заглушки «появится в фазе 1» (AGENT.md 10.7), добавлены totp-setup, totp-reset и delete-user; подкоманды обслуживания идут через общий app_cli - cmd/glchat: команда delete-user (мягкое удаление как в админ-панели, защита от удаления инстанс-админа и подтверждение --yes), исправлен потерянный комментарий cliCleanup - deploy/install.sh: убраны устаревшие формулировки про фазу 1 - web: политика повторов запросов — 429 повторяется с паузой retry_after_ms (до двух раз, не дольше 5 с), 4xx не повторяются; тесты web/tests/queryRetry.test.ts - scripts/test-install.sh: проверка, что заглушек в CLI не осталось
This commit is contained in:
@@ -1,18 +1,97 @@
|
||||
import { QueryClient } from '@tanstack/react-query';
|
||||
|
||||
import { ApiError, apiErrorField } from '@/api/client';
|
||||
|
||||
/**
|
||||
* Единый QueryClient приложения. Живёт в модуле (а не в main.tsx), чтобы
|
||||
* не-React код — например стор шлюза — мог инвалидировать кэш REST-запросов.
|
||||
*/
|
||||
let client: QueryClient | null = null;
|
||||
|
||||
/**
|
||||
* Сколько раз повторять запрос, упёршийся в лимит частоты (429). Сервер вместе
|
||||
* с ошибкой присылает `retry_after_ms`, поэтому повтор не «долбит» лимит, а
|
||||
* ждёт назначенную паузу: под нагрузкой матрицы 11.6 списки (участники, звуки,
|
||||
* эмодзи) иначе остаются пустыми до ручного «Повторить».
|
||||
*/
|
||||
const RATE_LIMIT_RETRIES = 2;
|
||||
|
||||
/**
|
||||
* Предел паузы, которую имеет смысл выждать внутри запроса. Если сервер просит
|
||||
* больше (например, минутный лимит загрузок), повтор не делаем: пользователю
|
||||
* полезнее сразу увидеть понятную ошибку с кнопкой «Повторить», чем ждать.
|
||||
*/
|
||||
const MAX_RATE_LIMIT_WAIT_MS = 5_000;
|
||||
|
||||
/** Запас к паузе сервера: часы клиента и сервера расходятся, окно скользящее. */
|
||||
const RATE_LIMIT_MARGIN_MS = 250;
|
||||
|
||||
/** Повторы «обычных» сбоев (сеть, 5xx) — как было: одна попытка. */
|
||||
const TRANSIENT_RETRIES = 1;
|
||||
|
||||
function errorStatus(error: unknown): number | null {
|
||||
if (error instanceof ApiError) {
|
||||
return error.status;
|
||||
}
|
||||
const status = (error as { status?: unknown } | null)?.status;
|
||||
return typeof status === 'number' ? status : null;
|
||||
}
|
||||
|
||||
function isAbort(error: unknown): boolean {
|
||||
return error instanceof DOMException && error.name === 'AbortError';
|
||||
}
|
||||
|
||||
/**
|
||||
* Пауза из ответа 429 (`retry_after_ms`) плюс небольшой запас. `null` — сервер
|
||||
* паузу не назвал: тогда работает обычная выдержка с удвоением.
|
||||
*/
|
||||
function rateLimitWaitMs(error: unknown): number | null {
|
||||
const value = apiErrorField(error, 'retry_after_ms');
|
||||
if (typeof value !== 'number' || !Number.isFinite(value) || value <= 0) {
|
||||
return null;
|
||||
}
|
||||
return Math.round(value) + RATE_LIMIT_MARGIN_MS;
|
||||
}
|
||||
|
||||
/**
|
||||
* Политика повторов для запросов: 4xx (кроме 429) повторять бессмысленно —
|
||||
* ответ не изменится; 429 повторяем с паузой сервера; сеть и 5xx — один раз.
|
||||
*/
|
||||
export function shouldRetryQuery(failureCount: number, error: unknown): boolean {
|
||||
if (isAbort(error)) {
|
||||
return false;
|
||||
}
|
||||
const status = errorStatus(error);
|
||||
if (status === 429) {
|
||||
if (failureCount >= RATE_LIMIT_RETRIES) {
|
||||
return false;
|
||||
}
|
||||
const wait = rateLimitWaitMs(error);
|
||||
return wait === null || wait <= MAX_RATE_LIMIT_WAIT_MS;
|
||||
}
|
||||
if (status !== null && status < 500) {
|
||||
return false;
|
||||
}
|
||||
return failureCount < TRANSIENT_RETRIES;
|
||||
}
|
||||
|
||||
/** Задержка перед повтором: пауза сервера для 429, иначе удвоение с потолком. */
|
||||
export function queryRetryDelay(failureCount: number, error: unknown): number {
|
||||
const wait = rateLimitWaitMs(error);
|
||||
if (wait !== null) {
|
||||
return Math.min(wait, MAX_RATE_LIMIT_WAIT_MS);
|
||||
}
|
||||
return Math.min(1_000 * 2 ** failureCount, 8_000);
|
||||
}
|
||||
|
||||
export function getQueryClient(): QueryClient {
|
||||
client ??= new QueryClient({
|
||||
defaultOptions: {
|
||||
queries: {
|
||||
staleTime: 30_000,
|
||||
refetchOnWindowFocus: false,
|
||||
retry: 1,
|
||||
retry: shouldRetryQuery,
|
||||
retryDelay: queryRetryDelay,
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
@@ -0,0 +1,96 @@
|
||||
import { QueryClient } from '@tanstack/react-query';
|
||||
import { describe, expect, it, vi } from 'vitest';
|
||||
|
||||
import { ApiError } from '@/api/client';
|
||||
import {
|
||||
getQueryClient,
|
||||
queryRetryDelay,
|
||||
setQueryClient,
|
||||
shouldRetryQuery,
|
||||
} from '@/lib/queryClient';
|
||||
|
||||
/** Ошибка лимита частоты в том виде, в каком её отдаёт `request()`. */
|
||||
function rateLimited(retryAfterMs: number): ApiError {
|
||||
const error = new ApiError(429, 'rate_limited', 'too many requests');
|
||||
Object.defineProperty(error, 'apiError', {
|
||||
value: { code: 'rate_limited', message: 'too many requests', retry_after_ms: retryAfterMs },
|
||||
enumerable: false,
|
||||
});
|
||||
return error;
|
||||
}
|
||||
|
||||
describe('повторы запросов при лимите частоты', () => {
|
||||
it('повторяет 429 с паузой из ответа сервера', () => {
|
||||
const error = rateLimited(1_200);
|
||||
expect(shouldRetryQuery(0, error)).toBe(true);
|
||||
expect(shouldRetryQuery(1, error)).toBe(true);
|
||||
expect(queryRetryDelay(0, error)).toBe(1_450);
|
||||
});
|
||||
|
||||
it('после двух повторов сдаётся: ошибку видит пользователь', () => {
|
||||
expect(shouldRetryQuery(2, rateLimited(500))).toBe(false);
|
||||
});
|
||||
|
||||
it('не ждёт паузу длиннее предела — сразу показывает ошибку', () => {
|
||||
// Минутный лимит загрузок: ждать внутри запроса бессмысленно.
|
||||
expect(shouldRetryQuery(0, rateLimited(60_000))).toBe(false);
|
||||
expect(queryRetryDelay(0, rateLimited(60_000))).toBe(5_000);
|
||||
});
|
||||
|
||||
it('429 без retry_after_ms повторяет с обычной выдержкой', () => {
|
||||
const error = new ApiError(429, 'rate_limited', 'too many requests');
|
||||
expect(shouldRetryQuery(0, error)).toBe(true);
|
||||
expect(queryRetryDelay(0, error)).toBe(1_000);
|
||||
expect(queryRetryDelay(1, error)).toBe(2_000);
|
||||
});
|
||||
|
||||
it('не повторяет отказы, которые не изменятся: 403, 404, 422', () => {
|
||||
for (const status of [400, 403, 404, 422]) {
|
||||
const error = new ApiError(status, 'validation.failed', 'no');
|
||||
expect(shouldRetryQuery(0, error)).toBe(false);
|
||||
}
|
||||
});
|
||||
|
||||
it('повторяет сетевые сбои и 5xx по одному разу', () => {
|
||||
expect(shouldRetryQuery(0, new TypeError('Failed to fetch'))).toBe(true);
|
||||
expect(shouldRetryQuery(1, new TypeError('Failed to fetch'))).toBe(false);
|
||||
expect(shouldRetryQuery(0, new ApiError(503, 'internal.error', 'later'))).toBe(true);
|
||||
expect(shouldRetryQuery(1, new ApiError(503, 'internal.error', 'later'))).toBe(false);
|
||||
});
|
||||
|
||||
it('не повторяет отменённый запрос', () => {
|
||||
expect(shouldRetryQuery(0, new DOMException('aborted', 'AbortError'))).toBe(false);
|
||||
});
|
||||
|
||||
it('общий клиент приложения использует эту политику', () => {
|
||||
const options = getQueryClient().getDefaultOptions().queries;
|
||||
expect(options?.retry).toBe(shouldRetryQuery);
|
||||
expect(options?.retryDelay).toBe(queryRetryDelay);
|
||||
});
|
||||
|
||||
it('запрос действительно переживает 429 и отдаёт данные', async () => {
|
||||
const queryClient = new QueryClient({
|
||||
defaultOptions: {
|
||||
queries: { retry: shouldRetryQuery, retryDelay: () => 1 },
|
||||
},
|
||||
});
|
||||
setQueryClient(queryClient);
|
||||
const loader = vi
|
||||
.fn<() => Promise<string>>()
|
||||
.mockRejectedValueOnce(rateLimited(1))
|
||||
.mockRejectedValueOnce(rateLimited(1))
|
||||
.mockResolvedValue('участники');
|
||||
|
||||
await expect(
|
||||
queryClient.fetchQuery({ queryKey: ['members-ok'], queryFn: loader }),
|
||||
).resolves.toBe('участники');
|
||||
expect(loader).toHaveBeenCalledTimes(3);
|
||||
|
||||
// Третьего повтора нет: следующий 429 доходит до вызывающего кода.
|
||||
const failing = vi.fn<() => Promise<string>>().mockRejectedValue(rateLimited(1));
|
||||
await expect(
|
||||
queryClient.fetchQuery({ queryKey: ['members-fail'], queryFn: failing }),
|
||||
).rejects.toThrow('too many requests');
|
||||
expect(failing).toHaveBeenCalledTimes(3);
|
||||
});
|
||||
});
|
||||
Reference in New Issue
Block a user