resp_003.py

def _parse_bulk_string(self) -> RESPBulkString:
    # Find the length marker
    pos = self.buffer.find(b'\r\n')
    if pos == -1:
        raise IncompleteResponseError()
    
    # Parse length (excluding the '$' prefix)
    length = int(self.buffer[1:pos])
    
    # Handle null strings
    if length == -1:
        self.buffer = self.buffer[pos + 2:]
        return RESPBulkString(value=None)
    
    # Calculate string boundaries
    string_start = pos + 2
    string_end = string_start + length
    
    # Ensure we have the complete string
    if len(self.buffer) < string_end + 2:
        raise IncompleteResponseError()
    
    value = self.buffer[string_start:string_end].decode('utf-8')
    self.buffer = self.buffer[string_end + 2:]
    
    return RESPBulkString(value=value)