feat: resolve pr issues

Author: keepview

Diff for: packages/cli/plugin-bff/package.json

@@ -21,12 +21,12 @@
   "main": "./dist/cjs/cli.js",
   "module": "./dist/esm/cli.js",
   "exports": {
+    "./types": "./types.d.ts",
     ".": {
       "types": "./dist/types/cli.d.ts",
       "jsnext:source": "./src/cli.ts",
       "default": "./dist/cjs/cli.js"
     },
-    "./types": "./types/index.d.ts",
     "./cli": {
       "types": "./dist/types/cli.d.ts",
       "jsnext:source": "./src/cli.ts",
@@ -87,7 +87,6 @@
     "@modern-js/server-utils": "workspace:*",
     "@modern-js/utils": "workspace:*",
     "type-is": "^1.6.18",
-    "formidable": "^1.2.2",
     "@swc/helpers": "0.5.13"
   },
   "devDependencies": {
@@ -103,7 +102,6 @@
     "@types/jest": "^29",
     "@types/node": "^14",
     "@types/type-is": "^1.6.3",
-    "@types/formidable": "^1.2.3",
     "jest": "^29",
     "memfs": "^3.5.1",
     "ts-jest": "^29.1.0",

Diff for: packages/cli/plugin-bff/src/runtime/hono/adapter.ts

@@ -76,7 +76,10 @@ export class HonoAdapter {
         before,
         handler: async (c: Context, next: Next) => {
           if (this.apiServer) {
-            const response = await this.apiServer.fetch(c.req.raw, c.env);
+            const response = await this.apiServer.fetch(
+              c.req as unknown as Request,
+              c.env,
+            );
 
             if (response.status !== 404) {
               return new Response(response.body, response);

Diff for: packages/cli/plugin-bff/src/utils/createHonoRoutes.ts

@@ -1,5 +1,3 @@
-import type { IncomingMessage } from 'node:http';
-import { Readable } from 'node:stream';
 import type { APIHandlerInfo } from '@modern-js/bff-core';
 import {
   HttpMetadata,
@@ -8,7 +6,6 @@ import {
   ValidationError,
   isWithMetaHandler,
 } from '@modern-js/bff-core';
-import formidable from 'formidable';
 import type { Context, Next } from 'hono';
 import typeIs from 'type-is';
 
@@ -67,7 +64,7 @@ export const createHonoHandler = (handler: Handler) => {
           if (response) {
             return response;
           }
-          if (c.env?.node?.res?.headersSent) return;
+          if (c.finalized) return;
 
           const result = await handler(input);
           return result && typeof result === 'object'
@@ -87,7 +84,7 @@ export const createHonoHandler = (handler: Handler) => {
         const args = Object.values(input.params).concat(input);
         try {
           const body = await handler(...args);
-          if (c.env?.node?.res?.headersSent) {
+          if (c.finalized) {
             return await Promise.resolve();
           }
 
@@ -118,8 +115,7 @@ const getHonoInput = async (c: Context) => {
     if (typeIs.is(contentType, ['application/json'])) {
       draft.data = await c.req.json();
     } else if (typeIs.is(contentType, ['multipart/form-data'])) {
-      const nodeStream = await webStreamToNodeStream(c);
-      draft.formData = await resolveFormData(nodeStream);
+      draft.formData = await c.req.parseBody();
     } else if (typeIs.is(contentType, ['application/x-www-form-urlencoded'])) {
       draft.formUrlencoded = await c.req.parseBody();
     } else {
@@ -131,51 +127,4 @@ const getHonoInput = async (c: Context) => {
   return draft;
 };
 
-async function webStreamToNodeStream(c: Context) {
-  const reader = (c.req.raw.body as ReadableStream<Uint8Array>).getReader();
-  const nodeStream = new Readable({
-    async read() {
-      try {
-        const { done, value } = await reader.read();
-        if (done) {
-          this.push(null);
-        } else {
-          this.push(value);
-        }
-      } catch (err) {
-        this.destroy(err as any);
-      }
-    },
-    destroy(err, callback) {
-      reader.cancel(err).finally(() => callback(err));
-    },
-  }) as IncomingMessage;
-
-  const headers = {
-    'content-type': c.req.header('content-type') || 'multipart/form-data',
-    'content-length': c.req.header('content-length') || '0',
-  };
-
-  nodeStream.headers = headers;
-  return nodeStream;
-}
-
-const resolveFormData = (
-  request: IncomingMessage,
-): Promise<Record<string, any>> => {
-  const form = formidable({ multiples: true });
-  return new Promise((resolve, reject) => {
-    form.parse(request, (err, fields, files) => {
-      if (err) {
-        reject(err);
-      }
-
-      resolve({
-        ...fields,
-        ...files,
-      });
-    });
-  });
-};
-
 export default createHonoRoutes;

Diff for: packages/cli/plugin-bff/types/index.d.ts renamed to packages/cli/plugin-bff/types.d.ts

@@ -5,7 +5,6 @@ export { AGGRED_DIR } from './constants';
 export type { ServerBase, ServerBaseOptions } from './serverBase';
 export { createServerBase } from './serverBase';
 export { useHonoContext } from './context';
-export { CustomServer } from './plugins/customServer';
 
 export type {
   Middleware,

Diff for: packages/server/core/src/index.ts

@@ -186,14 +186,6 @@ export class ServerBase<E extends Env = any> {
     return this.app.notFound.bind(this.app);
   }
 
-  get routes() {
-    return this.app.routes;
-  }
-
-  get route() {
-    return this.app.route.bind(this.app);
-  }
-
   get onError() {
     return this.app.onError.bind(this.app);
   }

Diff for: packages/server/core/src/serverBase.ts

@@ -102,7 +102,7 @@ export const createVercelPreset: CreatePreset = (
         });
 
         await fse.writeJSON(path.join(funcsDirectory, '.vc-config.json'), {
-          runtime: 'nodejs20.x',
+          runtime: 'nodejs16.x',
           handler: 'index.js',
           launcherType: 'Nodejs',
           shouldAddHelpers: false,

Diff for: packages/solutions/app-tools/src/plugins/deploy/platforms/vercel.ts

@@ -1,5 +1,2 @@
-import type { IncomingMessage, ServerResponse } from 'node:http';
-import type { Http2ServerRequest, Http2ServerResponse } from 'node:http2';
-
 export type NodeRequest = IncomingMessage | Http2ServerRequest;
 export type NodeResponse = ServerResponse | Http2ServerResponse;