fix: ci

Author: akitaSummer

core/langchain-decorator/src/decorator/GraphNode.ts

@@ -13,6 +13,7 @@ import { GraphNodeInfoUtil } from '../util/GraphNodeInfoUtil';
 import { AnnotationRoot, StateDefinition, UpdateType } from '@langchain/langgraph';
 import { ConfigurableModel } from 'langchain/chat_models/universal';
 import { ToolNode } from '@langchain/langgraph/prebuilt';
+import { BaseChatOpenAI } from '@langchain/openai';
 
 export function GraphNode<S extends StateDefinition = StateDefinition>(params: IGraphNodeMetadata) {
   return (constructor: EggProtoImplClass<IGraphNode<S> | TeggToolNode>) => {
@@ -32,7 +33,7 @@ export interface IGraphNode<S extends StateDefinition = StateDefinition, T = any
   // execute(state: T extends AbstractStateGraph<infer S> ? GraphStateType<S> : never): Promise<GraphUpdateType<T> extends object ? GraphUpdateType<T> & Record<string, any> : GraphUpdateType<T>>;
   execute(state: AnnotationRoot<S>['State']): Promise<UpdateType<S> & Record<string, any>> | Promise<ToolNode<T>>;
 
-  build?: (tools: Parameters<ConfigurableModel['bindTools']>['0']) => Promise<ConfigurableModel>;
+  build?: (tools: Parameters<ConfigurableModel['bindTools']>['0']) => Promise<ReturnType<ConfigurableModel['bindTools']> | ReturnType<BaseChatOpenAI<any>['bindTools']>>;
 }
 
 export class TeggToolNode implements IGraphNode {

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';
 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';
 
 export enum FooGraphNodeName {
   START = '__start__',

core/langchain-decorator/test/tsconfig.json

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

core/langchain-decorator/tsconfig.json

@@ -8,7 +8,6 @@
   },
   "exclude": [
     "dist",
-    "node_modules",
-    "test"
+    "node_modules"
   ]
 }

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 && FetchFactory.fetch,
     });
   }
 

plugin/mcp-client/lib/HttpMCPClientFactory.ts

@@ -26,7 +26,7 @@ export class HttpMCPClientFactory {
     const httpMCPClient = new EggHttpMCPClient({
       clientName: clientInfo.name,
       clientVersion: clientInfo.version,
-      fetch: this.FetchFactory.fetch,
+      fetch: this.FetchFactory && this.FetchFactory.fetch,
       ...options as HttpClientOptions,
       logger: this.logger,
     });

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 () => {