chore: fix lint

Author: calebboyd

package-lock.json

@@ -10,18 +10,6 @@
     }
   },
   "type": "module",
-  "jest": {
-    "resolver": "jest-ts-webcompat-resolver",
-    "preset": "ts-jest",
-    "testPathIgnorePatterns": [
-      ".*\\.js",
-      ".*\\.util\\.spec"
-    ]
-  },
-  "files": [
-    "lib",
-    "!**/*.spec.js"
-  ],
   "scripts": {
     "build": "rm -rf lib && npm run lint && npm run compile",
     "compile": "tsc && npm run compile:commonjs",
@@ -30,12 +18,23 @@
     "lint": "eslint \"src/**/*\" --fix --ext \"*.ts\"",
     "prepublishOnly": "npm run build",
     "coverage": "npm run test -- --collectCoverage",
-    "test": "jest --passWithNoTests",
+    "test": "npm run commitlint && jest",
     "watch:test": "jest --watchAll",
     "watch:typescript": "tsc -w"
   },
+  "files": [
+    "lib",
+    "!**/*.spec.js"
+  ],
+  "jest": {
+    "resolver": "jest-ts-webcompat-resolver",
+    "preset": "ts-jest",
+    "testPathIgnorePatterns": [
+      ".*\\.js",
+      ".*\\.util\\.spec"
+    ]
+  },
   "dependencies": {
-    "@calebboyd/async": "^2.0.1",
     "ioredis": "^4.19.4"
   },
   "peerDependencies": {

package.json

@@ -5,7 +5,7 @@ import { XBatchResult, XStreamResult } from './types.js'
 //eslint-disable-next-line @typescript-eslint/no-explicit-any
 type KindaAny = any
 
-function isNumber(num: any): num is number {
+function isNumber(num: number | string | undefined): num is number {
   return typeof num === 'number' && !Number.isNaN(num)
 }
 

src/redis.ts

@@ -1,4 +1,4 @@
-import { RedisClient } from './types.js'
+import { RedisClient, StreamEntry, XEntryResult } from './types.js'
 
 const delay = (ms: number): Promise<void> => new Promise((resolve) => setTimeout(resolve, ms)),
   times = <T>(count: number, fn: () => T): Array<T> => Array.from(Array(count), fn) as T[],
@@ -7,8 +7,8 @@ const delay = (ms: number): Promise<void> => new Promise((resolve) => setTimeout
     return new Promise((resolve) => client.once('end', resolve))
   },
   rand = (): string => Math.random().toString(36).slice(6),
-  drain = async (iterable: AsyncIterable<any>) => {
-    const results = new Map<string, any[]>()
+  drain = async (iterable: AsyncIterable<XEntryResult>): Promise<Map<string, StreamEntry[]>> => {
+    const results = new Map<string, StreamEntry[]>()
     for await (const [streamName, entry] of iterable) {
       const entries = results.get(streamName) || []
       entries.push(entry)