feat(parser): авто-переподключение к SHiP с backoff (1.3.0) #12

2026-06-05T13:00:48Z

claude commented

2026-06-05 13:00:48 +00:00

ReconnectSupervisor подключён к циклу чтения: backoff при разрыве вместо долбёжки. Resume из Redis на каждом реконнекте, resetBackoff на прогрессе, чистый exit на мёртвой ноде. +8 unit (229). Релиз 1.3.0.

claude added 1 commit 2026-06-05 13:00:48 +00:00

feat(parser): авто-переподключение к SHiP через ReconnectSupervisor с backoff

CI / Lint (pull_request) Successful in 9m51s

Details

CI / Integration tests (pull_request) Successful in 9m46s

Details

CI / Build (pull_request) Successful in 9m25s

Details

CI / Typecheck (pull_request) Successful in 9m27s

Details

CI / Unit tests (pull_request) Successful in 9m33s

Details

92811c258f

ReconnectSupervisor был написан, протестирован и экспортнут, но НИГДЕ не
подключён к циклу чтения. Parser.start() имел голый for-await без try/catch:
падение ноды → ShipConnectionError наверх → темп переподключений целиком
зависел от внешнего супервизора процесса. Мёртвая нода = рестарт без пауз =
долбёжка ноды без ограничителей.

Что сделано:
- Цикл чтения вынесен в runStreamLoop (core/streamLoop.ts) с инъекцией
зависимостей — чтобы покрыть reconnect/resume юнит-тестами на фейках, без
реального Redis и SHiP.
- runStreamLoop оборачивает (пере)подключение в ReconnectSupervisor:
backoff 1→2→5→15→60с, после maxAttempts без прогресса — process.exit(1)
(оркестратор перезапустит штатно).
- Позиция возобновления перечитывается из Redis на КАЖДОМ подключении
(sync-hash пишется после каждого блока) — продолжаем ровно с последнего
записанного блока, без потерь и дублей.
- ReconnectSupervisor.run теперь передаёт fn callback resetBackoff: каждый
обработанный блок сбрасывает счётчик попыток, чтобы долгая стабильная сессия
после редкого разрыва не копила attempt до выхода.
- Штатная остановка (stop закрывает ws) ловится и не вызывает лишний backoff.
- Parser получил структурный логгер (opts.logger) для onAttempt/onGiveUp.

Тесты: +4 runStreamLoop (reconnect+resume, stop без reconnect, give-up на
мёртвой ноде, resetBackoff на прогрессе), +4 ReconnectSupervisor (resetBackoff).
Всего 229 unit. README: секция «Авто-переподключение к SHiP».

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

claude merged commit 2218c7c1b7 into main

2026-06-05 13:01:02 +00:00

Sign in to join this conversation.

1 Participants

Notifications

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: C9S/parser2#12