272 lines
8.3 KiB
Python
272 lines
8.3 KiB
Python
def test_client_setname(judge_command):
|
|
judge_command(
|
|
"CLIENT SETNAME foobar", {"command": "CLIENT SETNAME", "value": "foobar"}
|
|
)
|
|
|
|
|
|
def test_client_unblock(judge_command):
|
|
judge_command(
|
|
"CLIENT UNBLOCK 33 TIMEOUT",
|
|
{"command": "CLIENT UNBLOCK", "clientid": "33", "error": "TIMEOUT"},
|
|
)
|
|
judge_command("CLIENT UNBLOCK 33", {"command": "CLIENT UNBLOCK", "clientid": "33"})
|
|
|
|
|
|
def test_flushdb(judge_command):
|
|
judge_command("FLUSHDB async", {"command": "FLUSHDB", "async": "async"})
|
|
judge_command("FLUSHDB", {"command": "FLUSHDB"})
|
|
judge_command("FLUSHDB ASYNC", {"command": "FLUSHDB", "async": "ASYNC"})
|
|
judge_command("FLUSHALL ASYNC", {"command": "FLUSHALL", "async": "ASYNC"})
|
|
|
|
|
|
def test_client_list(judge_command):
|
|
judge_command("client list", {"command": "client list"})
|
|
judge_command("client list TYPE REPLICA1", None)
|
|
judge_command(
|
|
"client list type master",
|
|
{"command": "client list", "type_const": "type", "conntype": "master"},
|
|
)
|
|
judge_command(
|
|
"client list TYPE REPLICA",
|
|
{"command": "client list", "type_const": "TYPE", "conntype": "REPLICA"},
|
|
)
|
|
|
|
judge_command(
|
|
"client list TYPE REPLICA id 1 2 3",
|
|
{
|
|
"command": "client list",
|
|
"type_const": "TYPE",
|
|
"conntype": "REPLICA",
|
|
"clientids": "1 2 3",
|
|
},
|
|
)
|
|
judge_command(
|
|
"client list ID 1 2 3",
|
|
{"command": "client list", "clientids": "1 2 3"},
|
|
)
|
|
|
|
|
|
def test_configset(judge_command):
|
|
judge_command(
|
|
"config set foo bar",
|
|
{"command": "config set", "parameter": "foo", "value": "bar"},
|
|
)
|
|
judge_command(
|
|
"config set requirepass ''",
|
|
{"command": "config set", "parameter": "requirepass", "value": "''"},
|
|
)
|
|
|
|
|
|
def test_shutdown(judge_command):
|
|
judge_command("shutdown save", {"command": "shutdown", "shutdown": "save"})
|
|
judge_command("shutdown NOSAVE", {"command": "shutdown", "shutdown": "NOSAVE"})
|
|
|
|
|
|
def test_clientpause(judge_command):
|
|
judge_command("client pause 3000", {"command": "client pause", "timeout": "3000"})
|
|
|
|
|
|
def test_client_reply(judge_command):
|
|
judge_command("client reply on", {"command": "client reply", "switch": "on"})
|
|
|
|
|
|
def test_client_kill(judge_command):
|
|
judge_command(
|
|
"CLIENT KILL addr 127.0.0.1:12345 type pubsub",
|
|
{
|
|
"command": "CLIENT KILL",
|
|
"addr": "addr",
|
|
"ip_port": "127.0.0.1:12345",
|
|
"type_const": "type",
|
|
"conntype": "pubsub",
|
|
},
|
|
)
|
|
judge_command(
|
|
"CLIENT KILL 127.0.0.1:12345 ",
|
|
{"command": "CLIENT KILL", "ip_port": "127.0.0.1:12345"},
|
|
)
|
|
judge_command(
|
|
"CLIENT KILL ADDR 127.0.0.1:12345 ",
|
|
{"command": "CLIENT KILL", "ip_port": "127.0.0.1:12345", "addr": "ADDR"},
|
|
)
|
|
judge_command(
|
|
"CLIENT KILL LADDR 127.0.0.1:12345 ",
|
|
{"command": "CLIENT KILL", "ip_port": "127.0.0.1:12345", "laddr": "LADDR"},
|
|
)
|
|
judge_command(
|
|
"CLIENT KILL USER myuser",
|
|
{"command": "CLIENT KILL", "const_user": "USER", "username": "myuser"},
|
|
)
|
|
judge_command(
|
|
"CLIENT KILL id 123455 type pubsub skipme no",
|
|
{
|
|
"command": "CLIENT KILL",
|
|
"const_id": "id",
|
|
"clientid": "123455",
|
|
"type_const": "type",
|
|
"conntype": "pubsub",
|
|
"skipme": "skipme",
|
|
"yes": "no",
|
|
},
|
|
)
|
|
|
|
|
|
def test_client_kill_username(judge_command):
|
|
"""since redis-server 6.0"""
|
|
judge_command(
|
|
"client kill USER default",
|
|
{"command": "client kill", "const_user": "USER", "username": "default"},
|
|
)
|
|
|
|
|
|
def test_client_kill_unordered_arguments(judge_command):
|
|
judge_command(
|
|
"CLIENT KILL type pubsub addr 127.0.0.1:12345",
|
|
{
|
|
"command": "CLIENT KILL",
|
|
"addr": "addr",
|
|
"ip_port": "127.0.0.1:12345",
|
|
"type_const": "type",
|
|
"conntype": "pubsub",
|
|
},
|
|
)
|
|
|
|
|
|
def test_psync(judge_command):
|
|
judge_command(
|
|
"PSYNC abc 123", {"command": "PSYNC", "replicationid": "abc", "offset": "123"}
|
|
)
|
|
judge_command("PSYNC", None)
|
|
|
|
|
|
def test_latency_graph(judge_command):
|
|
judge_command(
|
|
"latency graph command", {"command": "latency graph", "graphevent": "command"}
|
|
)
|
|
judge_command(
|
|
"latency graph fork", {"command": "latency graph", "graphevent": "fork"}
|
|
)
|
|
judge_command("latency graph", None)
|
|
|
|
|
|
def test_latency_reset(judge_command):
|
|
judge_command(
|
|
"latency reset command fork aof-fsync-always",
|
|
{"command": "latency reset", "graphevent": "aof-fsync-always"},
|
|
)
|
|
judge_command(
|
|
"latency reset fork", {"command": "latency reset", "graphevent": "fork"}
|
|
)
|
|
judge_command("latency reset", {"command": "latency reset"})
|
|
|
|
|
|
def test_lolwut(judge_command):
|
|
judge_command("lolwut", {"command": "lolwut"})
|
|
# only works before redis 6
|
|
judge_command("lolwut 5", {"command": "lolwut", "any": "5"})
|
|
judge_command("lolwut 5 1", {"command": "lolwut", "any": "5 1"})
|
|
# redis 6
|
|
judge_command(
|
|
"lolwut VERSION 5 5",
|
|
{"command": "lolwut", "version": "VERSION", "version_num": "5", "any": "5"},
|
|
)
|
|
|
|
|
|
def test_info(judge_command):
|
|
judge_command("info cpu", {"command": "info", "section": "cpu"})
|
|
judge_command("info", {"command": "info"})
|
|
judge_command("info all", {"command": "info", "section": "all"})
|
|
judge_command("info CPU", {"command": "info", "section": "CPU"})
|
|
|
|
|
|
def test_bgsave(judge_command):
|
|
judge_command("bgsave", {"command": "bgsave"})
|
|
judge_command("bgsave schedule", {"command": "bgsave", "schedule": "schedule"})
|
|
judge_command("BGSAVE SCHEDULE", {"command": "BGSAVE", "schedule": "SCHEDULE"})
|
|
|
|
|
|
def test_acl_cat(judge_command):
|
|
judge_command("acl cat", {"command": "acl cat"})
|
|
judge_command("acl CAT", {"command": "acl CAT"})
|
|
judge_command(
|
|
"ACL CAT scripting", {"command": "ACL CAT", "categoryname": "scripting"}
|
|
)
|
|
judge_command("ACL CAT WATCH", {"command": "ACL CAT", "categoryname": "WATCH"})
|
|
|
|
|
|
def test_acl_deluser(judge_command):
|
|
judge_command(
|
|
"acl deluser laixintao", {"command": "acl deluser", "username": "laixintao"}
|
|
)
|
|
judge_command(
|
|
"acl deluser laixintao antirez",
|
|
{"command": "acl deluser", "username": "antirez"},
|
|
)
|
|
|
|
|
|
def test_acl_log(judge_command):
|
|
judge_command("acl log 2", {"command": "acl log", "count": "2"})
|
|
judge_command("acl log reset", {"command": "acl log", "reset_const": "reset"})
|
|
judge_command("acl log ", {"command": "acl log"})
|
|
|
|
|
|
def test_acl_setuser(judge_command):
|
|
judge_command("ACL SETUSER alice", {"command": "ACL SETUSER", "username": "alice"})
|
|
judge_command(
|
|
"ACL SETUSER alice on >p1pp0 ~cached:* +get",
|
|
{"command": "ACL SETUSER", "username": "alice", "rule": "+get"},
|
|
)
|
|
judge_command(
|
|
"ACL SETUSER alan allkeys +@string +@set -SADD >alanpassword",
|
|
{"command": "ACL SETUSER", "username": "alan", "rule": ">alanpassword"},
|
|
)
|
|
|
|
|
|
def test_acl_getuser(judge_command):
|
|
judge_command("acl getuser alan", {"command": "acl getuser", "username": "alan"})
|
|
judge_command("acl getuser", None)
|
|
|
|
|
|
def test_failover(judge_command):
|
|
judge_command(
|
|
"failover to 10.0.0.5 7379 abort timeout 101",
|
|
{
|
|
"command": "failover",
|
|
"to_const": "to",
|
|
"host": "10.0.0.5",
|
|
"port": "7379",
|
|
"abort_const": "abort",
|
|
"timeout_const": "timeout",
|
|
"millisecond": "101",
|
|
},
|
|
)
|
|
judge_command(
|
|
"failover abort timeout 101",
|
|
{
|
|
"command": "failover",
|
|
"abort_const": "abort",
|
|
"timeout_const": "timeout",
|
|
"millisecond": "101",
|
|
},
|
|
)
|
|
judge_command(
|
|
"failover timeout 101",
|
|
{
|
|
"command": "failover",
|
|
"timeout_const": "timeout",
|
|
"millisecond": "101",
|
|
},
|
|
)
|
|
judge_command(
|
|
"failover to 10.0.0.5 7379 force abort timeout 101",
|
|
{
|
|
"command": "failover",
|
|
"to_const": "to",
|
|
"force": "force",
|
|
"host": "10.0.0.5",
|
|
"port": "7379",
|
|
"abort_const": "abort",
|
|
"timeout_const": "timeout",
|
|
"millisecond": "101",
|
|
},
|
|
)
|