fixed http pipe error

Dockerfile

@@ -4,14 +4,14 @@ EXPOSE 80
 WORKDIR /app
 ENV IN_DOCKER=true
 
+RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
+
 RUN apt update && apt upgrade -y
 RUN apt install curl nginx -y
 
 RUN curl -fsSL https://deb.nodesource.com/setup_18.x | bash
 RUN apt install nodejs -y
 
-RUN touch ./docker
-
 COPY ["./assets","./assets"]
 COPY ["./src","./src"]
 COPY ["./package.json","./package.json"]

docker-compose.yml

@@ -11,6 +11,7 @@ services:
             dockerfile: Dockerfile
         restart: always
         volumes:
+            - .:/app
             - /usr/bin/docker:/usr/bin/docker
             - /var/run/docker.sock:/var/run/docker.sock
         user: root

package.json

@@ -6,9 +6,9 @@
   "type": "module",
   "dependencies": {
     "dotenv": "^16.4.5",
+    "moment": "^2.30.1",
     "pejs": "^0.6.5"
   },
-  "devDependencies": {},
   "scripts": {
     "restore": "npm install",
     "start": "node ./src/main.js"

src/core/app.js

@@ -1,6 +1,7 @@
 import fs from 'fs'
 import http from 'http'
 import path from 'path'
+import moment from 'moment'
 import { pathToFileURL } from 'url'
 import { Group } from './group.js'
 import { Middleware } from './middleware.js'
@@ -14,18 +15,22 @@ export class App {
         this.middlewares = []
         this.actions = []
         this.logger = logger
-        this.server = http.createServer((req, res) => {
+
+        this.server = http.createServer(async (req, res) => {
             this.logger.info(`${new Date()}\n${req.method} ${req.url}`)
+            let start = moment()
 
-            this.pipeline.invoke(
+            await this.pipeline.invoke(
                 Request.object(req, this.host),
                 Response.object(res),
                 this.pipeline
             )
+
+            this.logger.info(moment().diff(start) + "ms\n")
         })
     }
 
-    #endpoint(req, res) {
+    async #endpoint(req, res) {
         let action = this.actions
             .filter(i => new RegExp(`^${i.path}$`).test(req.pathname))
             .sort((a, b) => b.path.length - a.path.length)
@@ -36,7 +41,7 @@ export class App {
             return
         }
 
-        action.invoke(req, res).catch(err => {
+        await action.invoke(req, res).catch(err => {
             this.logger.error(err)
             res.error('Server Error')
         })
@@ -75,7 +80,7 @@ export class App {
                         try {
                             callback(req, res)
                             resolve()
-                        } 
+                        }
                         catch (err) { reject(err) }
                     })
                 })
@@ -123,15 +128,14 @@ export class App {
     }
 
     build() {
-
         this.middlewares.forEach((middleware, index) => {
             if (index >= this.middlewares.length - 1) return
             middleware.next = this.middlewares[index + 1]
         })
 
         this.middlewares[this.middlewares.length - 1].next = {
-            handler: (req, res, _) => {
-                this.#endpoint(req, res)
+            handler: async (req, res, _) => {
+                await this.#endpoint(req, res)
             }
         }
 

src/core/middleware.js

@@ -4,9 +4,9 @@ export class Middleware {
         this.next = undefined
     }
 
-    invoke(req, res, middleware) {
-        middleware.handler(req, res, (req, res) =>
-            this.invoke(req, res, middleware.next)
+    async invoke(req, res, middleware) {
+        await middleware.handler(req, res, async (req, res) =>
+            await this.invoke(req, res, middleware.next)
         )
     }
 }

src/main.js

@@ -8,14 +8,6 @@ config()
 const app = new App()
 const ttyd = new TTYD()
 
-// Compute the api response time
-
-app.use((req, res, next) => {
-    console.time()
-    next(req, res)
-    console.timeEnd()
-})
-
 // Map Static file
 app.use(new StaticFile('/wwwroot'))
 app.use(new Cors())

src/middlewares/cors.js

@@ -3,7 +3,7 @@ import { Middleware } from '../core/middleware.js';
 export class Cors extends Middleware {
 
     constructor() {
-        let func = (req, res, next) => {
+        let func = async (req, res, next) => {
             res.setHeader('Access-Control-Allow-Origin', '*')
             res.setHeader('Access-Control-Allow-Methods', '*')
             res.setHeader('Access-Control-Allow-Headers', '*')
@@ -13,7 +13,7 @@ export class Cors extends Middleware {
                 return;
             }
 
-            next(req, res)
+            await next(req, res)
         }
 
         super(func)

src/middlewares/pathbase.js

@@ -3,12 +3,12 @@ import { Middleware } from "../core/middleware.js";
 export class PathBase extends Middleware {
 
     constructor(basePath) {
-        let func = (req, res, next) => {
+        let func = async (req, res, next) => {
             if (req.pathname.startsWith(basePath)) {
                 req.pathname = req.pathname.replace(basePath, '')
             }
 
-            next(req, res)
+            await next(req, res)
         }
 
         super(func)

src/middlewares/staticfile.js

@@ -6,13 +6,13 @@ import { Middleware } from "../core/middleware.js";
 export class StaticFile extends Middleware {
 
     constructor(wwwroot) {
-        let func = (req, res, next) => {
+        let func = async (req, res, next) => {
 
             let pathname = new URL(req.url, 'http://localhost').pathname
             let fileName = path.join(process.cwd(), 'src', wwwroot, pathname)
 
             if (!fs.existsSync(fileName) || !fs.lstatSync(fileName).isFile()) {
-                next(req, res)
+                await next(req, res)
                 return
             }