1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
import { test } from "./vendor/https/deno.land/std/testing/mod.ts";import { assertEquals } from "./vendor/https/deno.land/std/testing/asserts.ts";import { connect } from "./redis.ts";import { RedisPubSubMessage } from "./pubsub.ts";
const addr = {  hostname: "127.0.0.1",  port: 6379};
async function wait(duration) {  return new Promise(resolve => {    setTimeout(resolve, duration);  });}
test(async function testSubscribe() {  const redis = await connect(addr);  const sub = await redis.subscribe("subsc");  //const hoge = await redis.get("hoge");  const unsub = await sub.unsubscribe("subsc");  await sub.close();  assertEquals(sub.isClosed, true);  redis.close();});
test(async function testSubscribe2() {  const redis = await connect(addr);  const pub = await connect(addr);  const sub = await redis.subscribe("subsc2");  let message: RedisPubSubMessage;  const p = (async function() {    const it = sub.receive();    message = (await it.next()).value;  })();  await pub.publish("subsc2", "wayway");  await p;  assertEquals(message, {    channel: "subsc2",    message: "wayway"  });  await sub.close();  const a = await redis.get("aaa");  assertEquals(a, void 0);  pub.close();  redis.close();});
test(async function testPsubscribe() {  const redis = await connect(addr);  const pub = await connect(addr);  const sub = await redis.psubscribe("ps*");  let message1;  let message2;  const it = sub.receive();  const p = (async function() {    message1 = (await it.next()).value;    message2 = (await it.next()).value;  })();  await pub.publish("psub", "wayway");  await pub.publish("psubs", "heyhey");  await p;  assertEquals(message1, {    pattern: "ps*",    channel: "psub",    message: "wayway"  });  assertEquals(message2, {    pattern: "ps*",    channel: "psubs",    message: "heyhey"  });  await sub.close();  pub.close();  redis.close();});