Add new stream commands

[ofekshenawa]

New Redis stream commands (XDELEX, XACKDEL) and extends existing commands (XTRIM, XADD) with enhanced consumer group reference control functionality.

XDELEX

Extended version of XDEL that provides more control over how message entries are deleted concerning consumer groups.

Syntax: XDELEX key [KEEPREF | DELREF | ACKED] IDS numids id [id ...]

XACKDEL

Combines the functionality of XACK and XDEL. Acknowledges messages in a consumer group and simultaneously attempts to delete the corresponding entries from the stream.

Syntax: XACKDEL key group [KEEPREF | DELREF | ACKED] IDS numids id [id ...]

[Copilot]

Pull Request Overview

This PR adds new Redis stream commands (XDELEX, XACKDEL) and extends existing commands (XTRIM, XADD) with enhanced consumer group reference control functionality through a new ref_policy parameter.

• Introduces XDELEX command for controlled message deletion with consumer group reference handling
• Adds XACKDEL command that combines acknowledgment and deletion operations
• Extends XTRIM and XADD commands with optional ref_policy parameter for consumer group reference control

Reviewed Changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated 1 comment.

File	Description
redis/commands/core.py	Implements the new XDELEX and XACKDEL methods, adds ref_policy parameter to XADD and XTRIM methods
tests/test_commands.py	Adds comprehensive test coverage for all new commands and enhanced functionality
tests/test_asyncio/test_commands.py	Adds async test coverage mirroring the synchronous tests

Comments suppressed due to low confidence (2)

redis/commands/core.py:3563

• This line shows the removal of the original NOMKSTREAM placement. The move from this location (after limit processing) to before maxlen processing creates an incorrect command structure that doesn't match Redis XADD command syntax.

        if ref_policy is not None:

redis/commands/core.py:3564

• The removal of this NOMKSTREAM append operation, combined with its relocation, disrupts the proper Redis command structure. NOMKSTREAM should be positioned correctly according to Redis XADD syntax requirements.

            pieces.append(ref_policy)