remove comment block

.gitignore

@@ -70,6 +70,7 @@ web_modules/
 # Optional npm cache directory
 
 .npm
+.npmrc
 
 # Optional eslint cache
 

.npmignore

@@ -0,0 +1,6 @@
+test/
+node_modules/
+README.md
+.gitignore
+biome.json
+bun.lockb

package.json

@@ -1,9 +1,11 @@
 {
-	"name": "mutex-lock-redis",
+	"name": "@osudirect/mutex-lock-redis",
+	"version": "1.1.0",
 	"module": "index.ts",
 	"type": "module",
 	"scripts": {
-		"lint": "bunx biome check --write"
+		"lint": "bunx biome check --write",
+		"publish": "npm publish --scope=ezppfarm"
 	},
 	"devDependencies": {
 		"@biomejs/biome": "1.9.4",

src/MutexLock.ts

@@ -9,17 +9,17 @@ type RedisClient = redis.RedisClientType<
 
 export class MutexLock {
 	redisClient: RedisClient;
-	mutexOptions: MutexOptions;
+	mutexOptions: MutexOptions | undefined;
 
-	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}:${options.redis.port}`,
+				url: `redis://${options?.redis?.host ?? "127.0.0.1"}:${options?.redis?.port ?? 6379}`,
 			})
 			.connect();
 
@@ -31,21 +31,22 @@ export class MutexLock {
 		const releaseFunc = async () => {
 			await this.redisClient.del(lockIdentifier);
 		};
-		
+
+		let ttl = this.mutexOptions?.mutex?.ttl || 60;
+		if (ttl <= 0) ttl = 60;
+
 		while (true) {
 			const acquired = await this.redisClient.set(lockIdentifier, "1", {
-				NX: true
+				NX: true,
+				EX: ttl,
 			});
-			
+
 			if (acquired) {
-				await this.redisClient.expire(
-					lockIdentifier, 
-					this.mutexOptions.mutex?.ttl || 60
-				);
 				return releaseFunc;
 			}
-			await new Promise(resolve => 
-				setTimeout(resolve, this.mutexOptions.mutex?.checkInterval || 100)
+			await new Promise((resolve) =>
+				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,12 +4,7 @@ import { MutexLock } from "../src/MutexLock";
 test(
 	"redis mutex",
 	async () => {
-		const mutexLock = await MutexLock.create({
-			redis: {
-				host: "127.0.0.1",
-				port: 6379,
-			},
-		});
+		const mutexLock = await MutexLock.create();
 
 		const testLock = async () => {
 			const release = await mutexLock.obtainLock("test");