♻️ refactor: refactor to the Gateway Class and add tests

Author: arvinxx

.prettierignore

@@ -59,6 +59,5 @@ Dockerfile*
 
 # misc
 # add other ignore file below
-tests
 .env.example
 .env

package.json

@@ -22,8 +22,9 @@
     "prettier": "prettier -c --write \"**/**\"",
     "release": "semantic-release",
     "start": "vercel dev",
-    "test": "vitest --passWithNoTests",
-    "test:coverage": "vitest --coverage  --passWithNoTests",
+    "test": "vitest",
+    "test:coverage": "vitest --coverage",
+    "test:update": "vitest -u",
     "type-check": "tsc --noEmit"
   },
   "lint-staged": {
@@ -58,7 +59,7 @@
     "@commitlint/cli": "^17",
     "@lobehub/lint": "latest",
     "@vercel/node": "^2",
-    "@vitest/coverage-v8": "latest",
+    "@vitest/coverage-v8": "0.34.6",
     "commitlint": "^17",
     "cross-env": "^7",
     "eslint": "^8",
@@ -71,7 +72,7 @@
     "semantic-release": "^21",
     "typescript": "^5",
     "vercel": "^28.20.0",
-    "vitest": "latest"
+    "vitest": "0.34.6"
   },
   "publishConfig": {
     "access": "public",

src/edge.ts

@@ -0,0 +1,43 @@
+import {
+  PluginErrorType,
+  PluginRequestPayload,
+  createErrorResponse,
+  getPluginSettingsFromRequest,
+} from '@lobehub/chat-plugin-sdk';
+
+import cors, { CorsOptions } from './cors';
+import { Gateway, GatewayErrorResponse, GatewayOptions } from './gateway';
+
+export interface EdgeRuntimeGatewayOptions extends GatewayOptions {
+  cors?: CorsOptions;
+}
+
+/**
+ * create Gateway Edge Function with plugins index url
+ * @param options {EdgeRuntimeGatewayOptions}
+ */
+export const createGatewayOnEdgeRuntime = (options: EdgeRuntimeGatewayOptions = {}) => {
+  const gateway = new Gateway(options);
+
+  const handler = async (req: Request): Promise<Response> => {
+    // ==========  1. 校验请求方法 ========== //
+    if (req.method !== 'POST')
+      return createErrorResponse(PluginErrorType.MethodNotAllowed, {
+        message: '[gateway] only allow POST method',
+      });
+
+    const requestPayload = (await req.json()) as PluginRequestPayload;
+    const settings = getPluginSettingsFromRequest(req);
+
+    try {
+      const res = await gateway.execute(requestPayload, settings);
+      return new Response(res.data);
+    } catch (error) {
+      const { errorType, body } = error as GatewayErrorResponse;
+
+      return createErrorResponse(errorType, body);
+    }
+  };
+
+  return async (req: Request) => cors(req, await handler(req), options.cors);
+};