-
-
Notifications
You must be signed in to change notification settings - Fork 44
/
Copy pathredis_test.ts
103 lines (96 loc) · 2.82 KB
/
redis_test.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
import { connect } from "./redis.ts";
import { test } from "https://deno.land/[email protected]/testing/mod.ts";
import { assertEquals } from "https://deno.land/[email protected]/testing/asserts.ts";
// can be substituted with env variable
const addr = "127.0.0.1:6379";
test(async function beforeAll() {
const redis = await connect(addr);
await redis.del(
"incr",
"incrby",
"decr",
"decryby",
"get",
"getset",
"del1",
"del2"
);
});
test(async function testExists() {
const redis = await connect(addr);
const none = await redis.exists("none", "none2");
assertEquals(none, 0);
await redis.set("exists", "aaa");
const exists = await redis.exists("exists", "none");
assertEquals(exists, 1);
redis.close();
});
test(async function testGetWhenNil() {
const redis = await connect(addr);
const hoge = await redis.get("none");
assertEquals(hoge, void 0);
redis.close();
});
test(async function testSet() {
const redis = await connect(addr);
const s = await redis.set("get", "fuga你好こんにちは");
assertEquals(s, "OK");
const fuga = await redis.get("get");
assertEquals(fuga, "fuga你好こんにちは");
redis.close();
});
test(async function testGetSet() {
const redis = await connect(addr);
await redis.set("getset", "val");
const v = await redis.getset("getset", "lav");
assertEquals(v, "val");
assertEquals(await redis.get("getset"), "lav");
redis.close();
});
test(async function testMget() {
const redis = await connect(addr);
await redis.set("mget1", "val1");
await redis.set("mget2", "val2");
await redis.set("mget3", "val3");
const v = await redis.mget("mget1", "mget2", "mget3");
assertEquals(v, ["val1", "val2", "val3"]);
redis.close();
});
test(async function testDel() {
const redis = await connect(addr);
let s = await redis.set("del1", "fuga");
assertEquals(s, "OK");
s = await redis.set("del2", "fugaaa");
assertEquals(s, "OK");
const deleted = await redis.del("del1", "del2");
assertEquals(deleted, 2);
redis.close();
});
test(async function testIncr() {
const redis = await connect(addr);
const rep = await redis.incr("incr");
assertEquals(rep, 1);
assertEquals(await redis.get("incr"), "1");
redis.close();
});
test(async function testIncrby() {
const redis = await connect(addr);
const rep = await redis.incrby("incrby", 101);
assertEquals(rep, 101);
assertEquals(await redis.get("incrby"), "101");
redis.close();
});
test(async function testDecr() {
const redis = await connect(addr);
const rep = await redis.decr("decr");
assertEquals(rep, -1);
assertEquals(await redis.get("decr"), "-1");
redis.close();
});
test(async function testDecrby() {
const redis = await connect(addr);
const rep = await redis.decrby("decryby", 101);
assertEquals(rep, -101);
assertEquals(await redis.get("decryby"), "-101");
redis.close();
});