Replace hand-rolled sleep/doWork with node:timers/promises in examples

setTimeout from node:timers/promises accepts { signal } natively —
no need to reimplement abort handling manually in every example.

Author: polRk

examples/coordination/election.js

@@ -1,3 +1,5 @@
+import { setTimeout as sleep } from 'node:timers/promises'
+
 import { CoordinationClient } from '@ydbjs/coordination'
 import { Driver } from '@ydbjs/core'
 
@@ -30,14 +32,14 @@ async function runLeader(signal) {
 			console.log('[leader] elected — publishing endpoint')
 
 			// Simulate startup time before the real endpoint is known.
-			await sleep(300, session.signal)
+			await sleep(300, undefined, { signal: session.signal })
 
 			// Update leader data without re-election — all observers see it immediately.
 			await leadership.proclaim(utf8.encode('worker-a:8080'))
 			console.log('[leader] proclaimed endpoint: worker-a:8080')
 
 			// Hold leadership until the session dies or external signal fires.
-			await sleep(2_000, leadership.signal)
+			await sleep(2_000, undefined, { signal: leadership.signal })
 
 			console.log('[leader] resigning')
 			// await using → resign() called automatically here
@@ -148,24 +150,6 @@ async function main() {
 	}
 }
 
-function sleep(ms, signal) {
-	return new Promise((resolve, reject) => {
-		if (signal?.aborted) {
-			return reject(signal.reason)
-		}
-
-		let timer = setTimeout(resolve, ms)
-		signal?.addEventListener(
-			'abort',
-			() => {
-				clearTimeout(timer)
-				reject(signal.reason)
-			},
-			{ once: true }
-		)
-	})
-}
-
 main().catch((error) => {
 	if (error?.message === 'example timeout') return
 	console.error(error)

examples/coordination/mutex.js

@@ -1,3 +1,5 @@
+import { setTimeout as sleep } from 'node:timers/promises'
+
 import { CoordinationClient } from '@ydbjs/coordination'
 import { Driver } from '@ydbjs/core'
 
@@ -26,7 +28,7 @@ async function runWorker(id, signal) {
 			await using lock = await mutex.lock()
 
 			console.log(`[worker-${id}] lock acquired — doing exclusive work`)
-			await sleep(500, lock.signal)
+			await sleep(500, undefined, { signal: lock.signal })
 			console.log(`[worker-${id}] work done, releasing`)
 
 			// await using → lock.release() called automatically here
@@ -61,7 +63,7 @@ async function tryWork(signal) {
 
 	try {
 		console.log('[tryLock] lock acquired — doing optional work')
-		await sleep(200, lock.signal)
+		await sleep(200, undefined, { signal: lock.signal })
 		console.log('[tryLock] optional work done')
 	} finally {
 		await lock.release()
@@ -97,24 +99,6 @@ async function main() {
 	}
 }
 
-function sleep(ms, signal) {
-	return new Promise((resolve, reject) => {
-		if (signal?.aborted) {
-			return reject(signal.reason)
-		}
-
-		let timer = setTimeout(resolve, ms)
-		signal?.addEventListener(
-			'abort',
-			() => {
-				clearTimeout(timer)
-				reject(signal.reason)
-			},
-			{ once: true }
-		)
-	})
-}
-
 main().catch((error) => {
 	console.error(error)
 	process.exit(1)

examples/coordination/resource-management.js

@@ -17,6 +17,8 @@
  * `await using` equivalent so the difference is unmistakable.
  */
 
+import { setTimeout as sleep } from 'node:timers/promises'
+
 import { CoordinationClient } from '@ydbjs/coordination'
 import { Driver } from '@ydbjs/core'
 
@@ -65,7 +67,7 @@ async function oldLockUsage(signal) {
 		let lock = await mutex.lock()
 		try {
 			console.log('[old] lock acquired, doing work')
-			await doWork(signal)
+			await sleep(200, undefined, { signal })
 		} finally {
 			await lock.release()
 		}
@@ -81,7 +83,7 @@ async function newLockUsage(signal) {
 	await using _lock = await session.mutex('job').lock()
 
 	console.log('[new] lock acquired, doing work')
-	await doWork(signal)
+	await sleep(200, undefined, { signal })
 	// lock.release()  ← called automatically
 	// session.close() ← called automatically, after lock is released
 }
@@ -129,7 +131,7 @@ async function oldMultiResource(signal) {
 			let lease = await session.semaphore('quota').acquire({ count: 1 })
 			try {
 				console.log('[old] all resources acquired')
-				await doWork(signal)
+				await sleep(200, undefined, { signal })
 			} finally {
 				await lease.release()
 			}
@@ -150,7 +152,7 @@ async function newMultiResource(signal) {
 	await using _lease = await session.semaphore('quota').acquire({ count: 1 })
 
 	console.log('[new] all resources acquired')
-	await doWork(signal)
+	await sleep(200, undefined, { signal })
 	// lease.release()  ← first
 	// lock.release()   ← second
 	// session.close()  ← last
@@ -171,7 +173,7 @@ async function campaignExample(signal) {
 			await using leadership = await election.campaign(utf8.encode('worker-a'))
 
 			console.log('[leader] elected — doing leader work')
-			await doWork(leadership.signal)
+			await sleep(200, undefined, { signal: leadership.signal })
 
 			// leadership.resign() called automatically when the block exits —
 			// whether by normal return, exception, or session expiry.
@@ -239,21 +241,6 @@ async function main() {
 	}
 }
 
-function doWork(signal) {
-	return new Promise((resolve, reject) => {
-		if (signal?.aborted) return reject(signal.reason)
-		let timer = setTimeout(resolve, 200)
-		signal?.addEventListener(
-			'abort',
-			() => {
-				clearTimeout(timer)
-				reject(signal.reason)
-			},
-			{ once: true }
-		)
-	})
-}
-
 main().catch((error) => {
 	console.error(error)
 	process.exit(1)

examples/coordination/shared-config.js

@@ -1,3 +1,5 @@
+import { setTimeout as sleep } from 'node:timers/promises'
+
 import { CoordinationClient } from '@ydbjs/coordination'
 import { Driver } from '@ydbjs/core'
 
@@ -105,30 +107,12 @@ async function publishUpdates(signal) {
 
 	for (let config of configs) {
 		// oxlint-disable-next-line no-await-in-loop
-		await sleep(500, signal)
+		await sleep(500, undefined, { signal })
 		// oxlint-disable-next-line no-await-in-loop
 		await publishConfig(config, signal)
 	}
 }
 
-function sleep(ms, signal) {
-	return new Promise((resolve, reject) => {
-		if (signal?.aborted) {
-			return reject(signal.reason)
-		}
-
-		let timer = setTimeout(resolve, ms)
-		signal?.addEventListener(
-			'abort',
-			() => {
-				clearTimeout(timer)
-				reject(signal.reason)
-			},
-			{ once: true }
-		)
-	})
-}
-
 main().catch((error) => {
 	console.error(error)
 	process.exit(1)