src/MutexLock.ts

@@ -9,17 +9,17 @@ type RedisClient = redis.RedisClientType<
 
 export class MutexLock {
 	redisClient: RedisClient;
-	mutexOptions: MutexOptions | undefined;
+	mutexOptions: MutexOptions;
 
-	constructor(redisClient: RedisClient, options?: MutexOptions) {
+	constructor(redisClient: RedisClient, options: MutexOptions) {
 		this.mutexOptions = options;
 		this.redisClient = redisClient;
 	}
 
-	static async create(options?: MutexOptions) {
+	static async create(options: MutexOptions) {
 		const redisClient = await redis
 			.createClient({
-				url: `redis://${options?.redis?.host ?? "127.0.0.1"}:${options?.redis?.port ?? 6379}`,
+				url: `redis://${options.redis.host}:${options.redis.port}`,
 			})
 			.connect();
 
@@ -40,12 +40,12 @@ export class MutexLock {
 			if (acquired) {
 				await this.redisClient.expire(
 					lockIdentifier, 
-					this.mutexOptions?.mutex?.ttl || 60
+					this.mutexOptions.mutex?.ttl || 60
 				);
 				return releaseFunc;
 			}
 			await new Promise(resolve => 
-				setTimeout(resolve, this.mutexOptions?.mutex?.checkInterval || 100)
+				setTimeout(resolve, this.mutexOptions.mutex?.checkInterval || 100)
 			);
 		}
 	}}

src/types.ts

@@ -1,7 +1,7 @@
 export type MutexOptions = {
-  redis?: {
-    host?: string;
-    port?: number;
+  redis: {
+    host: string;
+    port: number;
   };
   mutex?: {
     checkInterval?: number;

test/mutex.test.ts

@@ -4,7 +4,12 @@ import { MutexLock } from "../src/MutexLock";
 test(
 	"redis mutex",
 	async () => {
-		const mutexLock = await MutexLock.create();
+		const mutexLock = await MutexLock.create({
+			redis: {
+				host: "127.0.0.1",
+				port: 6379,
+			},
+		});
 
 		const testLock = async () => {
 			const release = await mutexLock.obtainLock("test");