From 1e183247cfe110ccbc227889b161bd9aa980265f Mon Sep 17 00:00:00 2001
From: lyc8503 <me@lyc8503.site>
Date: Sat, 6 Jan 2024 20:17:13 +0800
Subject: [PATCH] should fix #4: add a missing withTimeout

---
 worker/src/monitor.ts | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/worker/src/monitor.ts b/worker/src/monitor.ts
index b0c2779..b97506d 100644
--- a/worker/src/monitor.ts
+++ b/worker/src/monitor.ts
@@ -22,7 +22,7 @@ export async function getStatus(
       const socket = connect({ hostname: hostname, port: Number(port) })
       const writer = socket.writable.getWriter()
       const reader = socket.readable.getReader()
-      await writer.write(new TextEncoder().encode('PING\n'))
+      await withTimeout(monitor.timeout || 10000, writer.write(new TextEncoder().encode('PING\n')))
       await withTimeout(monitor.timeout || 10000, reader.read())
       await socket.close()
 
@@ -63,9 +63,8 @@ export async function getStatus(
       if (monitor.expectedCodes) {
         if (!monitor.expectedCodes.includes(response.status)) {
           status.up = false
-          status.err = `Expected codes: ${JSON.stringify(monitor.expectedCodes)}, Got: ${
-            response.status
-          }`
+          status.err = `Expected codes: ${JSON.stringify(monitor.expectedCodes)}, Got: ${response.status
+            }`
           return status
         }
       } else {