diff options
| author | Roey Prat <roey.prat@redislabs.com> | 2018-10-03 11:33:24 +0300 |
|---|---|---|
| committer | Roey Prat <roey.prat@redislabs.com> | 2018-10-28 12:12:53 +0200 |
| commit | f1ece6b139d7cf4a7900526ff1d53b1387d89c68 (patch) | |
| tree | cf8a85a62d81a436cbc75af69a9d7ebe83344b34 /tests/test_commands.py | |
| parent | 7efb71bd81e365e94669ad1b1fff65c5f83b0508 (diff) | |
| download | redis-py-f1ece6b139d7cf4a7900526ff1d53b1387d89c68.tar.gz | |
Implements XINFO
Diffstat (limited to 'tests/test_commands.py')
| -rw-r--r-- | tests/test_commands.py | 18 |
1 files changed, 10 insertions, 8 deletions
diff --git a/tests/test_commands.py b/tests/test_commands.py index e6b727a..946934d 100644 --- a/tests/test_commands.py +++ b/tests/test_commands.py @@ -1615,7 +1615,7 @@ class TestStrictCommands(object): assert stamp1 != stamp2 milli, offset = stamp2.decode('utf-8').split('-') - new_id = "{}-0".format(int(milli) + 10000).encode('utf-8') + new_id = "{0}-0".format(int(milli) + 10000).encode('utf-8') stamp3 = sr.xadd(varname, id=new_id, foo="bar") assert sr.xlen(varname) == 3 assert stamp3 == new_id @@ -1670,21 +1670,23 @@ class TestStrictCommands(object): stream_name = 'xgroup_test_stream' sr.delete(stream_name) group_name = 'xgroup_test_group' - try: - sr.xgroup_destroy(name=stream_name, groupname=group_name) - except redis.ResponseError: - pass - with pytest.raises(redis.ResponseError): - sr.xgroup_create(name=stream_name, groupname=group_name, id='$') - stamp1 = sr.xadd(stream_name, name="marco", other="polo") + stamp1 = sr.xadd(stream_name, name="boaty", other="mcboatface") + assert stamp1 in sr.xinfo_stream(name=stream_name)[b('first-entry')] + + assert sr.xinfo_groups(name=stream_name) == [] assert sr.xgroup_create(name=stream_name, groupname=group_name, id='$') + assert sr.xinfo_groups(name=stream_name)[0][b('name')] == b(group_name) with pytest.raises(redis.ResponseError): sr.xgroup_setid(name='nosuchstream', groupname=group_name, id='0') with pytest.raises(redis.ResponseError): sr.xgroup_setid(name=stream_name, groupname='nosuchgroup', id='0') + assert sr.xinfo_groups(name=stream_name)[0][b('last-delivered-id')] \ + == b(stamp1) assert sr.xgroup_setid(name=stream_name, groupname=group_name, id='0') + assert sr.xinfo_groups(name=stream_name)[0][b('last-delivered-id')]\ + == b('0-0') # TODO: test xgroup_delconsumer after implementing XREADGROUP |