fix: ci

Author: akitaSummer

core/langchain-decorator/test/fixtures/modules/langgraph/Graph.ts

@@ -3,10 +3,10 @@ import { Annotation, MemorySaver } from '@langchain/langgraph';
 import { ChatOpenAI } from '@langchain/openai';
 import { z } from 'zod';
 import { Inject, SingletonProto } from '@eggjs/core-decorator';
-import { BaseMessage } from '@langchain/core/dist/messages/base';
+import { BaseMessage } from '@langchain/core/messages/base';
 import { AccessLevel, ToolArgs } from '@eggjs/tegg-types';
 import { ToolArgsSchema } from '@eggjs/controller-decorator';
-import { AIMessage } from '@langchain/core/dist/messages/ai';
+import { AIMessage } from '@langchain/core/messages/ai';
 
 export enum FooGraphNodeName {
   START = '__start__',

core/mcp-client/test/HttpMCPClient.test.ts

@@ -1,14 +1,17 @@
 import assert from 'node:assert/strict';
 import { randomUUID } from 'node:crypto';
-import { HttpMCPClient } from '../src/HttpMCPClient';
-import { startSSEServer, stopSSEServer } from './fixtures/sse-mcp-server/http';
-import { startStreamableServer, stopStreamableServer } from './fixtures/streamable-mcp-server/http';
 const majorVersion = parseInt(process.versions.node.split('.')[0], 10);
 
 describe('test/HttpMCPClient.test.ts', () => {
   if (majorVersion < 18) {
     return;
   }
+  // eslint-disable-next-line @typescript-eslint/no-var-requires
+  const { HttpMCPClient } = require('../src/HttpMCPClient');
+  // eslint-disable-next-line @typescript-eslint/no-var-requires
+  const { startSSEServer, stopSSEServer } = require('./fixtures/sse-mcp-server/http');
+  // eslint-disable-next-line @typescript-eslint/no-var-requires
+  const { startStreamableServer, stopStreamableServer } = require('./fixtures/streamable-mcp-server/http');
   it('should work', async () => {
     await startStreamableServer();
     const client = new HttpMCPClient({

plugin/langchain/test/fixtures/apps/langchain/tsconfig.json

@@ -0,0 +1,13 @@
+{
+  "compilerOptions": {
+    "outDir": "dist",
+    "module": "nodenext",
+    "moduleResolution": "nodenext",
+    "baseUrl": "./"
+  },
+  "exclude": [
+    "dist",
+    "node_modules",
+    "test"
+  ]
+}

plugin/langchain/test/llm.test.ts

@@ -1,11 +1,12 @@
 import mm from 'egg-mock';
 import path from 'path';
 import assert from 'assert';
-import { startSSEServer, stopSSEServer } from './fixtures/sse-mcp-server/http';
 
 
 describe('plugin/langchain/test/llm.test.ts', () => {
   if (parseInt(process.version.slice(1, 3)) > 17) {
+    // eslint-disable-next-line @typescript-eslint/no-var-requires
+    const { startSSEServer, stopSSEServer } = require('./fixtures/sse-mcp-server/http');
     // eslint-disable-next-line @typescript-eslint/no-var-requires
     const { ChatOpenAIModel } = require('../lib/ChatOpenAI');
     // eslint-disable-next-line @typescript-eslint/no-var-requires

plugin/mcp-client/lib/EggHttpStaticMCPClient.ts

@@ -51,7 +51,7 @@ import assert from 'node:assert';
       });
   },
 })
-export class EggVipStaticMCPClient extends EggHttpMCPClient {
+export class EggHttpStaticMCPClient extends EggHttpMCPClient {
   constructor(
     @Inject() moduleConfig: ModuleConfig,
     @Inject() logger: Logger,
@@ -73,7 +73,7 @@ export class EggVipStaticMCPClient extends EggHttpMCPClient {
       transportType: mcpServerSubConfig.transportType as any,
       url: mcpServerSubConfig.url,
       logger,
-      fetch: FetchFactory.fetch,
+      fetch: FetchFactory?.fetch,
     });
   }
 

plugin/mcp-client/test/mcpclient.test.ts

@@ -1,11 +1,13 @@
 import mm from 'egg-mock';
 import path from 'path';
 import assert from 'assert';
-import { startSSEServer, stopSSEServer } from './fixtures/sse-mcp-server/http';
-import { startStreamableServer, stopStreamableServer } from './fixtures/streamable-mcp-server/http';
 
 describe('plugin/mcp-client/test/mcpclient.test.ts', () => {
   if (parseInt(process.version.slice(1, 3)) > 17) {
+    // eslint-disable-next-line @typescript-eslint/no-var-requires
+    const { startSSEServer, stopSSEServer } = require('./fixtures/sse-mcp-server/http');
+    // eslint-disable-next-line @typescript-eslint/no-var-requires
+    const { startStreamableServer, stopStreamableServer } = require('./fixtures/streamable-mcp-server/http');
     let app;
 
     before(async () => {