feat(transport): add rate limiting for messages and connections#776

Merged

sirtimid merged 24 commits intomainfrom

sirtimid/add-rate-limiting-v2

Jan 29, 2026

Commits on Jan 29, 2026

feat(transport): add rate limiting for messages and connections

sirtimid
and
claude
committed
test(transport): add unit tests for rate limiter

sirtimid
and
claude
committed
fix: add rate limit types to ResourceLimitError

sirtimid
and
claude
committed
fix(transport): record message rate after send, rate limit reconnections

sirtimid
and
claude
committed
test(e2e): fix queue limit test to avoid rate limit interference

sirtimid
and
claude
committed
fix(transport): avoid duplicate getCurrentCount calls in rate limit error

sirtimid
and
claude
committed
refactor(transport): move rate limiter constants to constants.ts

sirtimid
and
claude
committed
fix(transport): use atomic checkAndRecord to prevent TOCTOU race

sirtimid
and
claude
committed
fix(transport): preserve retry quota on rate limit, close rejected channels

sirtimid
and
claude
committed
fix(transport): add input validation and optimize rate limiter

sirtimid
and
claude
committed
fix(transport): distinguish rate limit from connection limit errors

sirtimid
and
claude
committed
refactor(kernel-errors): add ResourceLimitType and ResourceLimitErrorData types

sirtimid
and
claude
committed
fix(transport): reject NaN and Infinity in rate limiter constructor

sirtimid
and
claude
committed
fix(transport): handle connection limit errors as retryable during reconnection

sirtimid
and
claude
committed
refactor(kernel-errors): add isResourceLimitError type guard

sirtimid
and
claude
committed
fix(transport): preserve ResourceLimitError when closeChannel fails

sirtimid
and
claude
committed
refactor(transport): deduplicate wouldExceedLimit by reusing getCurrentCount

sirtimid
and
claude
committed
fix(kernel-errors): add isResourceLimitError to exports test

sirtimid
and
claude
committed
fix(transport): add missing isResourceLimitError mock to tests

sirtimid
and
claude
committed
refactor(transport): extract closeRejectedChannel helper

sirtimid
and
claude
committed
test(reconnection-lifecycle): add explicit call count assertions

sirtimid
and
claude
committed
simplify
sirtimid
committed
test(reconnection-lifecycle): add flushPromises to prevent test flakiness

sirtimid
and
claude
committed
fix(transport): close channel when connection limit exceeded after dial

sirtimid
and
claude
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(transport): add rate limiting for messages and connections#776

feat(transport): add rate limiting for messages and connections#776
sirtimid merged 24 commits intomainfrom
sirtimid/add-rate-limiting-v2

Commits on Jan 29, 2026

feat(transport): add rate limiting for messages and connections

test(transport): add unit tests for rate limiter

fix: add rate limit types to ResourceLimitError

fix(transport): record message rate after send, rate limit reconnections

test(e2e): fix queue limit test to avoid rate limit interference

fix(transport): avoid duplicate getCurrentCount calls in rate limit error

refactor(transport): move rate limiter constants to constants.ts

fix(transport): use atomic checkAndRecord to prevent TOCTOU race

fix(transport): preserve retry quota on rate limit, close rejected channels

fix(transport): add input validation and optimize rate limiter

fix(transport): distinguish rate limit from connection limit errors

refactor(kernel-errors): add ResourceLimitType and ResourceLimitErrorData types

fix(transport): reject NaN and Infinity in rate limiter constructor

fix(transport): handle connection limit errors as retryable during reconnection

refactor(kernel-errors): add isResourceLimitError type guard

fix(transport): preserve ResourceLimitError when closeChannel fails

refactor(transport): deduplicate wouldExceedLimit by reusing getCurrentCount

fix(kernel-errors): add isResourceLimitError to exports test

fix(transport): add missing isResourceLimitError mock to tests

refactor(transport): extract closeRejectedChannel helper

test(reconnection-lifecycle): add explicit call count assertions

simplify

test(reconnection-lifecycle): add flushPromises to prevent test flakiness

fix(transport): close channel when connection limit exceeded after dial