Implement XGROUP DELCONSUMER, XGROUP CREATECONSUMER, and `XINFO C…

…ONSUMERS`

Fix #162
Fix #163
Fix #167

docs/redis-commands/Redis.md

@@ -1482,6 +1482,14 @@ Returns the number of messages after removing them from a stream.
 
 Creates a consumer group.
 
+### [XGROUP CREATECONSUMER](https://redis.io/commands/xgroup-createconsumer/)
+
+Creates a consumer in a consumer group.
+
+### [XGROUP DELCONSUMER](https://redis.io/commands/xgroup-delconsumer/)
+
+Deletes a consumer from a consumer group.
+
 ### [XGROUP DESTROY](https://redis.io/commands/xgroup-destroy/)
 
 Destroys a consumer group.
@@ -1490,6 +1498,10 @@ Destroys a consumer group.
 
 Sets the last-delivered ID of a consumer group.
 
+### [XINFO CONSUMERS](https://redis.io/commands/xinfo-consumers/)
+
+Returns a list of the consumers in a consumer group.
+
 ### [XINFO GROUPS](https://redis.io/commands/xinfo-groups/)
 
 Returns a list of the consumer groups of a stream.
@@ -1534,14 +1546,6 @@ Changes, or acquires, ownership of a message in a consumer group, as if the mess
 
 A container for consumer groups commands.
 
-#### [XGROUP CREATECONSUMER](https://redis.io/commands/xgroup-createconsumer/) <small>(not implemented)</small>
-
-Creates a consumer in a consumer group.
-
-#### [XGROUP DELCONSUMER](https://redis.io/commands/xgroup-delconsumer/) <small>(not implemented)</small>
-
-Deletes a consumer from a consumer group.
-
 #### [XGROUP HELP](https://redis.io/commands/xgroup-help/) <small>(not implemented)</small>
 
 Returns helpful text about the different subcommands.
@@ -1550,10 +1554,6 @@ Returns helpful text about the different subcommands.
 
 A container for stream introspection commands.
 
-#### [XINFO CONSUMERS](https://redis.io/commands/xinfo-consumers/) <small>(not implemented)</small>
-
-Returns a list of the consumers in a consumer group.
-
 #### [XINFO HELP](https://redis.io/commands/xinfo-help/) <small>(not implemented)</small>
 
 Returns helpful text about the different subcommands.

fakeredis/_stream.py

@@ -31,7 +31,8 @@ def format_record(self):
         return [self.key.encode(), results]
 
 
-current_time = lambda: int(time.time() * 1000)
+def current_time():
+    return int(time.time() * 1000)
 
 
 @dataclass

test/test_mixins/test_streams_commands.py

@@ -296,7 +296,7 @@ def test_xgroup_destroy(r: redis.Redis):
 
 
 @pytest.mark.max_server('6.3')
-def test_xgroup_setid_redis6(r: redis.Redis):
+def test_xgroup_create_redis6(r: redis.Redis):
     stream, group = "stream", "group"
     message_id = r.xadd(stream, {"foo": "bar"})
     r.xgroup_create(stream, group, message_id)
@@ -310,7 +310,7 @@ def test_xgroup_setid_redis6(r: redis.Redis):
 
 
 @pytest.mark.min_server('7')
-def test_xgroup_setid_redis7(r: redis.Redis):
+def test_xgroup_create_redis7(r: redis.Redis):
     stream, group = "stream", "group"
     message_id = r.xadd(stream, {"foo": "bar"})
     r.xgroup_create(stream, group, message_id)