123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
import { test } from "https://deno.land/std@v0.7.0/testing/mod.ts";import { assertEquals } from "https://deno.land/std@v0.7.0/testing/asserts.ts";import { connect } from "./redis.ts";
const addr = "127.0.0.1:6379";test(async function testPipeline() {  const redis = await connect(addr);  const pl = redis.pipeline();  await Promise.all([    pl.ping(),    pl.ping(),    pl.set("set1", "value1"),    pl.set("set2", "value2"),    pl.mget("set1", "set2"),    pl.del("set1"),    pl.del("set2")  ]);  const ret = await pl.flush();  assertEquals(ret, [    ["status", "PONG"],    ["status", "PONG"],    ["status", "OK"],    ["status", "OK"],    ["array", ["value1", "value2"]],    ["integer", 1],    ["integer", 1]  ]);});
test(async function testTx() {  const redis = await connect(addr);  const tx1 = redis.tx();  const tx2 = redis.tx();  const tx3 = redis.tx();  await redis.del("key");  await Promise.all<any>([    tx1.get("key"),    tx1.incr("key"),    tx1.incr("key"),    tx1.incr("key"),    tx1.get("key"),    //    tx2.get("key"),    tx2.incr("key"),    tx2.incr("key"),    tx2.incr("key"),    tx2.get("key"),    //    tx3.get("key"),    tx3.incr("key"),    tx3.incr("key"),    tx3.incr("key"),    tx3.get("key")  ]);  const rep1 = await tx1.flush();  const rep2 = await tx2.flush();  const rep3 = await tx3.flush();  console.log(rep1);  assertEquals(    parseInt(rep1[4][1] as string),    parseInt(rep1[0][1] as string) + 3  );  assertEquals(    parseInt(rep2[4][1] as string),    parseInt(rep2[0][1] as string) + 3  );  assertEquals(    parseInt(rep3[4][1] as string),    parseInt(rep3[0][1] as string) + 3  );});