微调接口

This commit is contained in:
zixu 2024-08-29 10:00:22 +08:00
parent c6372ea8c3
commit 4230db9058
3 changed files with 6 additions and 7 deletions

View File

@ -19,7 +19,8 @@ const logMiddleware: cMiddleware = async (req, res, next) => {
const t1 = Date.now(); const t1 = Date.now();
const r = await next(req, res); const r = await next(req, res);
const t2 = Date.now(); 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; return r;
}; };
@ -130,7 +131,6 @@ const fontApiMiddleware: cMiddleware = async (req, res, next) => {
const server = new SimpleHttpServer({ port: 8087 }); const server = new SimpleHttpServer({ port: 8087 });
server.use( server.use(
logMiddleware, logMiddleware,
// limitMiddleware,
corsMiddleware, corsMiddleware,
fontApiMiddleware, fontApiMiddleware,
staticFileMiddleware, staticFileMiddleware,

View File

@ -73,6 +73,7 @@ async function connectionHandle(
}, },
handle: cNext, handle: cNext,
) { ) {
// connection.readable.
const { header, body } = await createStreamAfterTarget(connection.readable, target); const { header, body } = await createStreamAfterTarget(connection.readable, target);
if (!header) { if (!header) {
return; return;

View File

@ -14,14 +14,12 @@ export function createTcpServer(
socket.on("data", (chunk) => { socket.on("data", (chunk) => {
controller.enqueue(new Uint8Array(chunk)); controller.enqueue(new Uint8Array(chunk));
}); });
socket.on("end", () => {
controller.close();
});
socket.on("error", (err) => { socket.on("error", (err) => {
controller.error(err); controller.error(err);
}); });
socket.on("close", () => {
controller.close();
});
}, },
cancel() { cancel() {
socket.destroy(); socket.destroy();