123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
import {test, assert} from "https://deno.land/x/std@v0.2.11/testing/mod.ts";import {connect} from "./redis.ts";import {RedisPubSubMessage} from "./pubsub.ts";
const addr = "127.0.0.1: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();    assert.equal(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;    (async function () {        const it = sub.receive();        message = (await it.next()).value;    })();    await pub.publish("subsc2", "wayway");    await sub.close();    await wait(100);    assert.equal(message, {        channel: "subsc2",        message: "wayway"    });    const a = await redis.get("aaa");    assert.equal(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;    (async function () {        const it = sub.receive();        message1 = (await it.next()).value;        message2 = (await it.next()).value;    })();    await pub.publish("psub", "wayway");    await pub.publish("psubs", "heyhey");    await sub.close();    await wait(100);    assert.equal(message1, {        pattern: "ps*",        channel: "psub",        message: "wayway"    });    assert.equal(message2, {        pattern: "ps*",        channel: "psubs",        message: "heyhey"    });    pub.close();    redis.close()});