Stream commands (#636)

* feat: xadd

* Add xrange and xrange test

* fix: nested decoding

* Add tests for xrange

* Add tests for xadd

* Remove dependabot

* Add missing imports to entry file

* Format redis.ts

---------

Co-authored-by: chronark <dev@chronark.com>

pkg/commands/mod.ts

@@ -120,7 +120,6 @@ export * from "./touch.ts";
 export * from "./ttl.ts";
 export * from "./type.ts";
 export * from "./unlink.ts";
-export * from "./xadd.ts";
 export * from "./zadd.ts";
 export * from "./zcard.ts";
 export * from "./zcount.ts";
@@ -139,3 +138,5 @@ export * from "./zrevrank.ts";
 export * from "./zscan.ts";
 export * from "./zscore.ts";
 export * from "./zunionstore.ts";
+export * from "./xadd.ts";
+export * from "./xrange.ts";

pkg/redis.ts

@@ -124,6 +124,7 @@ import {
   TypeCommand,
   UnlinkCommand,
   XAddCommand,
+  XRangeCommand,
   ZAddCommand,
   ZAddCommandOptions,
   ZAddCommandOptionsWithIncr,
@@ -407,7 +408,9 @@ export class Redis {
     new BitOpCommand(
       [op as any, destinationKey, sourceKey, ...sourceKeys],
       this.opts,
-    ).exec(this.client);
+    ).exec(
+      this.client,
+    );
 
   /**
    * @see https://redis.io/commands/bitpos
@@ -1015,10 +1018,17 @@ export class Redis {
   unlink = (...args: CommandArgs<typeof UnlinkCommand>) =>
     new UnlinkCommand(args, this.opts).exec(this.client);
 
-  // /**
-  //  * @see https://redis.io/commands/xadd
-  //  */
-  // xadd =
+  /**
+   * @see https://redis.io/commands/xadd
+   */
+  xadd = (...args: CommandArgs<typeof XAddCommand>) =>
+    new XAddCommand(args, this.opts).exec(this.client);
+
+  /**
+   * @see https://redis.io/commands/xrange
+   */
+  xrange = (...args: CommandArgs<typeof XRangeCommand>) =>
+    new XRangeCommand(args, this.opts).exec(this.client);
 
   /**
    * @see https://redis.io/commands/zadd