infrawatch / sg-core / 20776676603

51%

master: 50%

push

github

Add configurable buffer size and tests for large message handling

Made buffer size configurable via bufferSize parameter (default 65535,
min 1024, max 10MB) to handle different message size requirements.

Fixed TCP socket handling to properly receive messages larger than the
buffer by implementing multi-read logic that:
- Peeks at message length header to determine total message size
- Reads additional data in chunks until complete message is received
- Validates messages don't exceed 100MB max size
- Properly combines remaining data from previous reads

Improved error handling to distinguish between TCP (can read more) and
UDP/Unix datagram sockets (message gets truncated by OS).

Added comprehensive tests with 1500-byte buffers for all socket types
(TCP, UDP, Unix) to verify correct handling of messages within buffer,
exceeding buffer, and multiple message scenarios.

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>

53 of 68 new or added lines in 1 file covered. (77.94%)

972 of 1910 relevant lines covered (50.89%)

0.57 hits per line