Package Exports

@hyperttp/inflight
@hyperttp/inflight/index.js

This package does not declare an exports field, so the exports above have been automatically detected and optimized by JSPM instead. If any package subpath is missing, it is recommended to post an issue to the original package (@hyperttp/inflight) to support the "exports" field. If that is not possible, create a JSPM override to customize the exports field for this package.

Readme

@hyperttp/inflight

Плагин дедупликации (схлопывания) параллельных запросов для HTTP-клиента Hyperttp. Если приложение одновременно выполняет несколько одинаковых GET-запросов к одному и тому же эндпоинту, плагин объединяет их, выполняет только один сетевой запрос и распределяет единый результат между всеми вызывающими сторонами (Request Collapsing).

Особенности

🏎️ Защита от "лавины" (Cache Stampede): Предотвращает перегрузку сервера идентичными конкурентными запросами.
🎯 Умное освобождение памяти: Ссылка на промис хранится в Map ровно до тех пор, пока запрос находится в обработке, и автоматически удаляется через finally.
🎛️ Гибкое управление: Поддержка флага req.meta.skipInflight для принудительного обхода дедупликации.
⚡ Нулевой оверхед: Работает на фазе PREPARE, не создает лишних оберток и не требует внешних зависимостей.

Установка

# С использованием bun
bun add @hyperttp/inflight

# С использованием npm/pnpm
npm install @hyperttp/inflight

Использование

Инициализация клиента

Плагин по умолчанию включен (enabled !== false), если подключен к сборщику. При необходимости его можно явно сконфигурировать или отключить.

import { HyperClient } from "@hyperttp/core";

const client = new HyperClient({
  verbose: true,
  inflight: {
    enabled: true // Можно передать false, чтобы отключить плагин
  }
});

// Запросы отправляются одновременно
const [res1, res2, res3] = await Promise.all([
  client.get("https://api.example.com/slow-endpoint"),
  client.get("https://api.example.com/slow-endpoint"),
  client.get("https://api.example.com/slow-endpoint")
]);

// Вкладка Network покажет ровно ОДИН реальный HTTP-запрос.
// Все три переменные получат один и тот же результат.

Обход дедупликации

Если вам необходимо гарантированно отправить отдельный сетевой запрос, используйте свойство meta внутри конфигурации запроса:

const freshData = await client.get("https://api.example.com/slow-endpoint", {
  meta: { skipInflight: true }
});

Как это работает (Архитектура)

Плагин перехватывает цепочку выполнения на фазе PREPARE:

graph TD
    Req1[Запрос 1 к /api] --> Phase[PREPARE Phase]
    Req2[Запрос 2 к /api] --> Phase
    
    Phase --> Check{Промис в Map?}
    
    Check -- Нет --> Exec[Выполнить сетевой запрос]
    Exec --> Save[Сохранить промис в Map]
    Save --> Return1[Возврат результата]
    
    Check -- Да --> Return2[Вернуть текущий активный промис]
    
    Exec -. Выполнение завершено .-> Delete[Удалить из Map через .finally]