From 4230db90586fd9967f7e75f0d2a2becf82b48bc8 Mon Sep 17 00:00:00 2001
From: zixu <admin@shenzilong.cn>
Date: Thu, 29 Aug 2024 10:00:22 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/app.ts               | 4 ++--
 backend/server/server.ts     | 1 +
 backend/server/tcp_server.ts | 8 +++-----
 3 files changed, 6 insertions(+), 7 deletions(-)

diff --git a/backend/app.ts b/backend/app.ts
index 46a8269..f64d5ac 100644
--- a/backend/app.ts
+++ b/backend/app.ts
@@ -19,7 +19,8 @@ const logMiddleware: cMiddleware = async (req, res, next) => {
   const t1 = Date.now();
   const r = await next(req, res);
   const t2 = Date.now();
-  console.log(`[${t2 - t1}ms] ${req.url.split("?")[0]}`);
+  const url = new URL(req.url);
+  console.log(`[${t2 - t1}ms] ${url.pathname}`);
   return r;
 };
 
@@ -130,7 +131,6 @@ const fontApiMiddleware: cMiddleware = async (req, res, next) => {
 const server = new SimpleHttpServer({ port: 8087 });
 server.use(
   logMiddleware,
-  // limitMiddleware,
   corsMiddleware,
   fontApiMiddleware,
   staticFileMiddleware,
diff --git a/backend/server/server.ts b/backend/server/server.ts
index 0f52e56..63b5077 100644
--- a/backend/server/server.ts
+++ b/backend/server/server.ts
@@ -73,6 +73,7 @@ async function connectionHandle(
   },
   handle: cNext,
 ) {
+  // connection.readable.
   const { header, body } = await createStreamAfterTarget(connection.readable, target);
   if (!header) {
     return;
diff --git a/backend/server/tcp_server.ts b/backend/server/tcp_server.ts
index edc62f5..0142e5b 100644
--- a/backend/server/tcp_server.ts
+++ b/backend/server/tcp_server.ts
@@ -14,14 +14,12 @@ export function createTcpServer(
         socket.on("data", (chunk) => {
           controller.enqueue(new Uint8Array(chunk));
         });
-
-        socket.on("end", () => {
-          controller.close();
-        });
-
         socket.on("error", (err) => {
           controller.error(err);
         });
+        socket.on("close", () => {
+          controller.close();
+        });
       },
       cancel() {
         socket.destroy();