Add support for JSON commands in Async Cluster

[motybz]

It seems that the .json() ability is supported in the Cluster client but not in Async Cluster client.

from redis.asyncio.cluster import RedisCluster
client = RedisCluster()
await client.json().get("test")

AttributeError: 'RedisCluster' object has no attribute 'json'

[chayim]

Supported in 4.4.0.

[baltika10]

This doesn't seem to work still
AttributeError: 'RedisCluster' object has no attribute 'json'
when using redis.asyncio.cluster.RedisCluster (version 4.5.1)

[chayim]

@dvora-h can you double check this?

[bharatbots]

This still doesn't work with redis.asyncio. I'm using the latest version(4.5.5)

[the-wondersmith]

@chayim I can confirm @bharatbots's findings, FWIW

[the-wondersmith]

@chayim @bharatbots

Did some more digging / testing. Long story short, the comments in PR #2423 are correct - redis.commands.redismodules.AsyncRedisModuleCommands needs to be added to the inherited classes for redis.asyncio.cluster.RedisCluster and redis.asyncio.cluster.ClusterPipeline.

ALSO, an implementation of set_response_callback needs to be added to the cluster pipeline class that propagates the supplied callback to the bound client's associated Node's.

From my testing, this seems to work just fine:

def set_response_callback(self, command: str, callback: Callable[..., Any]) -> None:
    """Set a custom response callback."""
    self._client.set_response_callback(command, callback)

    for node in self._client.nodes_manager.nodes_cache.values():
        node.response_callbacks[command] = callback