feat: enhance HonoHttpServer listen method with port retry logic and logging

Author: hotlong

packages/plugins/plugin-hono-server/src/adapter.ts

@@ -113,19 +113,43 @@ export class HonoHttpServer implements IHttpServer {
 
 
     async listen(port: number) {
-        return new Promise<void>((resolve) => {
-            if (this.staticRoot) {
-                this.app.get('/*', serveStatic({ root: this.staticRoot }));
+        if (this.staticRoot) {
+            this.app.get('/*', serveStatic({ root: this.staticRoot }));
+        }
+
+        const targetPort = port || this.port;
+        const maxRetries = 20;
+
+        for (let attempt = 0; attempt < maxRetries; attempt++) {
+            const tryPort = targetPort + attempt;
+            try {
+                await this.tryListen(tryPort);
+                return;
+            } catch (err: any) {
+                if (err.code === 'EADDRINUSE' && attempt < maxRetries - 1) {
+                    if (this.server && typeof this.server.close === 'function') {
+                        this.server.close();
+                    }
+                    continue;
+                }
+                throw err;
             }
-            
-            const targetPort = port || this.port;
-            this.server = serve({
+        }
+    }
+
+    private tryListen(port: number): Promise<void> {
+        return new Promise<void>((resolve, reject) => {
+            const server = serve({
                 fetch: this.app.fetch,
-                port: targetPort
+                port
             }, (info) => {
                 this.listeningPort = info.port;
                 resolve();
             });
+            this.server = server;
+            server.on('error', (err: any) => {
+                reject(err);
+            });
         });
     }
 

packages/plugins/plugin-hono-server/src/hono-plugin.ts

@@ -234,11 +234,14 @@ export class HonoServerPlugin implements Plugin {
             ctx.logger.debug('Starting HTTP server', { port });
 
             await this.server.listen(port);
-            
+
             const actualPort = this.server.getPort();
-            ctx.logger.info('HTTP server started successfully', { 
-                port: actualPort, 
-                url: `http://localhost:${actualPort}` 
+            if (actualPort !== port) {
+                ctx.logger.warn(`Port ${port} is in use, using port ${actualPort} instead`);
+            }
+            ctx.logger.info('HTTP server started successfully', {
+                port: actualPort,
+                url: `http://localhost:${actualPort}`
             });
         });
     }