feat: add db option and remove a deprecated option (#32)

resolves: #30

Author: suguru03

redis.ts

@@ -1548,6 +1548,7 @@ export type RedisConnectOptions = {
   hostname: string;
   port?: number | string;
   tls?: boolean;
+  db?: number;
 };
 
 /**
@@ -1557,44 +1558,27 @@ export type RedisConnectOptions = {
  *  const conn = connect({hostname: "127.0.0.1", port: 6379})// -> tcp, 127.0.0.1:6379
  *  const conn = connect({hostname: "redis.proxy", port: 443, tls: true}) // -> TLS, redis.proxy:443
  */
-export async function connect(
-  opts: string | RedisConnectOptions
-): Promise<Redis> {
-  let conn: Deno.Conn;
-  if (typeof opts === "string") {
-    console.warn(
-      yellow(
-        "deno-redis: connect(addr) is now deprecated and will be removed in v0.5.0 (now v0.4.x)"
-      )
-    );
-    const [h, p] = opts.split(":");
-    if (!p) {
-      throw new Error("redis: port must be specified");
-    }
-    const dialOptions: DialOptions = { port: parseInt(p) };
-    if (h) {
-      dialOptions.hostname = h;
-    }
-    conn = await Deno.dial(dialOptions);
-  } else {
-    const { hostname } = opts;
-    const port = parseInt(`${opts.port}`);
-    if (!Number.isSafeInteger(port)) {
-      throw new Error("deno-redis: opts.port is invalid");
-    }
-    if (opts.tls) {
-      conn = await Deno.dialTLS({
-        hostname,
-        port
-      });
-    } else {
-      conn = await Deno.dial({
-        hostname,
-        port
-      });
-    }
+export async function connect({
+  hostname,
+  port,
+  tls,
+  db,
+}: RedisConnectOptions): Promise<Redis> {
+  const dialOpts: DialOptions = {
+    hostname,
+    port: typeof port === "string" ? parseInt(port) : port ?? 6379
+  };
+  if (!Number.isSafeInteger(dialOpts.port)) {
+    throw new Error("deno-redis: opts.port is invalid");
+  }
+  const conn: Deno.Conn = tls
+    ? await Deno.dialTLS(dialOpts)
+    : await Deno.dial(dialOpts);
+  const client = await create(conn, conn, conn);
+  if (db) {
+    await client.select(db);
   }
-  return create(conn, conn, conn);
+  return client;
 }
 
 export function create(

redis_test.ts

@@ -128,6 +128,26 @@ test(async function testConcurrent() {
   assertEquals(c, "c");
 });
 
+test(async function testDb0Option() {
+  const key = "exists";
+  await redis.set(key, "aaa");
+  const exists1 = await redis.exists(key);
+  assertEquals(exists1, 1);
+  const client2 = await connect({ ...addr, db: 0 });
+  const exists2 = await client2.exists(key);
+  assertEquals(exists2, 1);
+});
+
+test(async function testDb1Option() {
+  const key = "exists";
+  await redis.set(key, "aaa");
+  const exists1 = await redis.exists(key);
+  assertEquals(exists1, 1);
+  const client2 = await connect({ ...addr, db: 1 });
+  const exists2 = await client2.exists(key);
+  assertEquals(exists2, 0);
+});
+
 [Infinity, NaN, "", "port"].forEach(v => {
   test(`invalid port: ${v}`, () => {
     assertThrowsAsync(