chore(deps): upgrade langchain dependencies to v1.x

package.json

@@ -41,6 +41,10 @@
       "type": "./dist/sub-modules/providers/groq/index.d.ts",
       "default": "./dist/sub-modules/providers/groq/index.js"
     },
+    "./openrouter": {
+      "type": "./dist/sub-modules/providers/openrouter/index.d.ts",
+      "default": "./dist/sub-modules/providers/openrouter/index.js"
+    },
     "./pg": {
       "type": "./dist/sub-modules/providers/pg/index.d.ts",
       "default": "./dist/sub-modules/providers/pg/index.js"
@@ -77,6 +81,9 @@
       "groq": [
         "dist/sub-modules/providers/groq/index.d.ts"
       ],
+      "openrouter": [
+        "dist/sub-modules/providers/openrouter/index.d.ts"
+      ],
       "pg": [
         "dist/sub-modules/providers/pg/index.d.ts"
       ],
@@ -124,59 +131,61 @@
     "!*/__tests__"
   ],
   "peerDependencies": {
-    "@loopback/core": "^6.1.11"
+    "@loopback/core": "^7.0.11"
   },
   "dependencies": {
-    "@langchain/community": "^0.3.50",
-    "@langchain/core": "^0.3.80",
-    "@langchain/langgraph": "^0.4.4",
-    "@loopback/repository": "^7.0.14",
-    "@sourceloop/chat-service": "15.0.3",
-    "@sourceloop/core": "17.0.3",
-    "@sourceloop/file-utils": "0.3.7",
-    "langchain": "^0.3.37",
-    "loopback4-authentication": "^12.2.0",
-    "loopback4-authorization": "^7.0.3",
-    "tslib": "^2.8.0",
-    "winston": "^3.15.0"
+    "@langchain/community": "^1.1.27",
+    "@langchain/core": "^1.1.40",
+    "@langchain/langgraph": "^1.2.8",
+    "@loopback/repository": "^8.0.11",
+    "@loopback/sequelize": "^0.8.8",
+    "@sourceloop/chat-service": "^17.0.6",
+    "@sourceloop/core": "^20.0.6",
+    "@sourceloop/file-utils": "^0.5.6",
+    "langchain": "^1.3.3",
+    "loopback4-authentication": "^13.0.4",
+    "loopback4-authorization": "^8.1.3",
+    "tslib": "^2.8.1",
+    "winston": "^3.19.0"
   },
   "devDependencies": {
-    "@commitlint/cli": "^19.8.1",
-    "@commitlint/config-conventional": "^16.2.1",
+    "@commitlint/cli": "^20.5.0",
+    "@commitlint/config-conventional": "^20.5.0",
     "@google/generative-ai": "^0.24.1",
     "@istanbuljs/nyc-config-typescript": "^1.0.2",
-    "@langchain/anthropic": "^0.3.26",
-    "@langchain/aws": "^0.1.13",
-    "@langchain/cerebras": "^0.0.2",
-    "@langchain/google-genai": "^0.2.16",
-    "@langchain/groq": "^0.2.3",
-    "@langchain/ollama": "^0.2.3",
-    "@langchain/openai": "^0.6.11",
-    "@langfuse/core": "^4.4.2",
-    "@langfuse/langchain": "^4.4.2",
-    "@loopback/build": "^11.0.9",
-    "@loopback/eslint-config": "^15.0.5",
-    "@loopback/testlab": "^7.0.9",
+    "@langchain/anthropic": "^1.3.26",
+    "@langchain/aws": "^1.3.5",
+    "@langchain/cerebras": "^1.0.4",
+    "@langchain/google-genai": "^2.1.27",
+    "@langchain/groq": "^1.2.0",
+    "@langchain/ollama": "^1.2.6",
+    "@langchain/openai": "^1.4.4",
+    "@langchain/openrouter": "^0.2.2",
+    "@langfuse/core": "^5.1.0",
+    "@langfuse/langchain": "^5.1.0",
+    "@loopback/build": "^12.0.11",
+    "@loopback/eslint-config": "^16.0.1",
+    "@loopback/testlab": "^8.0.11",
     "@semantic-release/changelog": "^6.0.3",
     "@semantic-release/commit-analyzer": "^13.0.1",
     "@semantic-release/git": "^10.0.1",
-    "@semantic-release/github": "^12.0.1",
-    "@semantic-release/npm": "^13.1.1",
-    "@semantic-release/release-notes-generator": "^14.0.3",
-    "@types/dotenv": "^8.2.0",
+    "@semantic-release/github": "^12.0.6",
+    "@semantic-release/npm": "^13.1.5",
+    "@semantic-release/release-notes-generator": "^14.1.0",
+    "@types/dotenv": "^8.2.3",
     "@types/jsonwebtoken": "^9.0.10",
-    "@types/node": "^20.16.14",
+    "@types/node": "^25.6.0",
     "commitizen": "^4.3.1",
-    "cz-format-extension": "1.5.0",
+    "cz-format-extension": "1.6.0",
     "db-migrate": "^1.0.0-beta.21",
     "dotenv": "^16.6.1",
     "eslint": "^8.57.1",
     "husky": "^9.1.7",
-    "jsonwebtoken": "^9.0.2",
+    "jsonwebtoken": "^9.0.3",
     "loopback-connector-sqlite3": "^3.0.0",
-    "mochawesome": "^7.1.3",
-    "pg": "^8.16.3",
-    "semantic-release": "^25.0.1",
+    "mochawesome": "^7.1.4",
+    "pg": "^8.20.0",
+    "semantic-release": "^25.0.3",
     "source-map-support": "^0.5.21",
     "ts-node": "^10.9.2",
     "typescript": "^5.6.3"
@@ -186,7 +195,7 @@
     "jws": "3.2.3",
     "node-forge": "1.4.0",
     "validator": "13.15.22",
-    "axios": "1.13.6",
+    "axios": "1.15.0",
     "fast-xml-parser": "5.5.8",
     "simple-git": "3.33.0",
     "flatted": "3.4.2",
@@ -197,6 +206,12 @@
     "tar": "7.5.12",
     "minimatch": "10.2.4",
     "undici": "6.24.1",
+    "@loopback/context": {
+      "uuid": "^9.0.1"
+    },
+    "@sourceloop/file-utils": {
+      "@loopback/context": "7.0.14"
+    },
     "swagger-stats": {
       "send": "^1.1.0"
     },

src/components/db-query/providers/datasets.retriever.ts

@@ -1,8 +1,9 @@
+import {Document} from '@langchain/core/documents';
 import {BaseRetriever} from '@langchain/core/retrievers';
 import {VectorStore} from '@langchain/core/vectorstores';
 import {inject, Provider, ValueOrPromise} from '@loopback/core';
 import {AnyObject} from '@loopback/repository';
-import {MemoryVectorStore} from 'langchain/vectorstores/memory';
+import {MemoryVectorStore} from '@langchain/classic/vectorstores/memory';
 import {AiIntegrationBindings} from '../../../keys';
 import {DbQueryStoredTypes} from '../types';
 import {AuthenticationBindings} from 'loopback4-authentication';
@@ -19,7 +20,7 @@ export class DatasetRetriever implements Provider<BaseRetriever> {
     if (this.vectorStore instanceof MemoryVectorStore) {
       return this.vectorStore.asRetriever({
         k: 5,
-        filter: doc =>
+        filter: (doc: Document) =>
           doc.metadata.type === DbQueryStoredTypes.DataSet &&
           doc.metadata.tenantId === this.user.tenantId,
         searchType: 'similarity',

src/components/db-query/providers/templates.retriever.ts

@@ -1,8 +1,9 @@
+import {Document} from '@langchain/core/documents';
 import {BaseRetriever} from '@langchain/core/retrievers';
 import {VectorStore} from '@langchain/core/vectorstores';
 import {inject, Provider, ValueOrPromise} from '@loopback/core';
 import {AnyObject} from '@loopback/repository';
-import {MemoryVectorStore} from 'langchain/vectorstores/memory';
+import {MemoryVectorStore} from '@langchain/classic/vectorstores/memory';
 import {AiIntegrationBindings} from '../../../keys';
 import {DbQueryStoredTypes} from '../types';
 import {AuthenticationBindings} from 'loopback4-authentication';
@@ -19,7 +20,7 @@ export class TemplateRetriever implements Provider<BaseRetriever> {
     if (this.vectorStore instanceof MemoryVectorStore) {
       return this.vectorStore.asRetriever({
         k: 5,
-        filter: doc =>
+        filter: (doc: Document) =>
           doc.metadata.type === DbQueryStoredTypes.Template &&
           doc.metadata.tenantId === this.user.tenantId,
         searchType: 'similarity',

src/graphs/chat/nodes/context-compression.node.ts

@@ -1,4 +1,4 @@
-import {trimMessages} from '@langchain/core/messages';
+import {BaseMessage, trimMessages} from '@langchain/core/messages';
 import {inject} from '@loopback/core';
 import {DEFAULT_MAX_TOKEN_COUNT} from '../../../constant';
 import {graphNode} from '../../../decorators';
@@ -36,7 +36,11 @@ export class ContextCompressionNode implements IGraphNode<ChatState> {
       const trimmed = await trimMessages(state.messages, {
         maxTokens: maxTokenCount,
         strategy: 'last',
-        tokenCounter: approxTokenCounter,
+        tokenCounter: (messages: BaseMessage[]) =>
+          messages.reduce(
+            (count, message) => count + approxTokenCounter(message.content),
+            0,
+          ),
         includeSystem: true,
       });
       return {

src/graphs/chat/nodes/init-session.node.ts

@@ -1,18 +1,14 @@
-import {
-  BaseMessage,
-  HumanMessage,
-  SystemMessage,
-} from '@langchain/core/messages';
+import {HumanMessage, SystemMessage} from '@langchain/core/messages';
 import {LangGraphRunnableConfig} from '@langchain/langgraph';
 import {inject, service} from '@loopback/core';
 import {graphNode} from '../../../decorators';
+import {AiIntegrationBindings} from '../../../keys';
 import {Message} from '../../../models';
 import {LLMStreamEventType} from '../../event.types';
 import {ChatState} from '../../state';
-import {IGraphNode} from '../../types';
+import {IGraphNode, SavedMessage} from '../../types';
 import {ChatStore} from '../chat.store';
 import {ChatNodes} from '../nodes.enum';
-import {AiIntegrationBindings} from '../../../keys';
 const debug = require('debug')('ai-integration:chat:init-session.node');
 @graphNode(ChatNodes.InitSession)
 export class InitSessionNode implements IGraphNode<ChatState> {
@@ -67,15 +63,15 @@ export class InitSessionNode implements IGraphNode<ChatState> {
     };
   }
 
-  private async _formatMessage(messages: Message[]): Promise<BaseMessage[]> {
+  private async _formatMessage(messages: Message[]): Promise<SavedMessage[]> {
     if (!messages) {
       return [];
     }
     const graphMessages = await Promise.all(
       messages.map(message => this.chatStore.toMessage(message)),
     );
     return graphMessages.filter(
-      (message): message is BaseMessage => message !== undefined,
+      (message): message is SavedMessage => message !== undefined,
     );
   }
 }

src/graphs/chat/nodes/run-tool.node.ts

@@ -33,13 +33,8 @@ export class RunToolNode implements IGraphNode<ChatState> {
     }
     const newMessages: ToolMessage[] = [];
     const tools = this.tools.map;
-    const lastMessage = state.messages[state.messages.length - 1] as AIMessage &
-      ToolMessage;
-    if (
-      !lastMessage ||
-      lastMessage.tool_call_id ||
-      !lastMessage.tool_calls?.length
-    ) {
+    const lastMessage = state.messages[state.messages.length - 1] as AIMessage;
+    if (!lastMessage?.tool_calls?.length) {
       return state;
     }
     const toolCalls = lastMessage.tool_calls!;

src/graphs/chat/nodes/summarise-file.node.ts

@@ -1,4 +1,4 @@
-import {HumanMessage} from '@langchain/core/messages';
+import {ContentBlock, HumanMessage} from '@langchain/core/messages';
 import {PromptTemplate} from '@langchain/core/prompts';
 import {RunnableSequence} from '@langchain/core/runnables';
 import {LangGraphRunnableConfig, Messages} from '@langchain/langgraph';
@@ -76,7 +76,7 @@ export class SummariseFileNode implements IGraphNode<ChatState> {
               type: 'text',
               text: state.prompt,
             },
-            fileContent,
+            fileContent as unknown as ContentBlock,
           ],
         },
       ];

src/graphs/types.ts

@@ -5,6 +5,8 @@ import {LangGraphRunnableConfig} from '@langchain/langgraph';
 import {AnyObject, Command} from '@loopback/repository';
 import {LLMStreamEvent} from './event.types';
 
+export type {LangGraphRunnableConfig} from '@langchain/langgraph';
+
 export type RunnableConfig = LangGraphRunnableConfig & {
   writer?: (event: LLMStreamEvent) => void;
 };

src/providers/vector-stores/inmemory.vector.ts

@@ -1,5 +1,5 @@
 import {inject, Provider, ValueOrPromise} from '@loopback/core';
-import {MemoryVectorStore} from 'langchain/vectorstores/memory';
+import {MemoryVectorStore} from '@langchain/classic/vectorstores/memory';
 import {AiIntegrationBindings} from '../../keys';
 import {EmbeddingProvider} from '../../types';
 import {AnyObject} from '@loopback/repository';

src/sub-modules/providers/openrouter/index.ts

@@ -0,0 +1 @@
+export * from './llms';

src/sub-modules/providers/openrouter/llms/index.ts

@@ -0,0 +1 @@
+export * from './openrouter.provider';

src/sub-modules/providers/openrouter/llms/openrouter.provider.ts

@@ -0,0 +1,30 @@
+import {Provider} from '@loopback/core';
+import {ChatOpenRouter} from '@langchain/openrouter';
+import {LLMProvider} from '../../../../types';
+import {OpenRouterInstanceConfig} from '../types';
+
+export class OpenRouter implements Provider<LLMProvider> {
+  static createInstance(config: OpenRouterInstanceConfig): ChatOpenRouter {
+    return new ChatOpenRouter({
+      model: config.model,
+      ...config.config,
+    });
+  }
+  value(): LLMProvider {
+    if (!process.env.OPENROUTER_MODEL || !process.env.OPENROUTER_API_KEY) {
+      throw new Error(
+        'OPENROUTER_MODEL and OPENROUTER_API_KEY environment variables must be set.',
+      );
+    }
+    return OpenRouter.createInstance({
+      model: process.env.OPENROUTER_MODEL,
+      config: {
+        apiKey: process.env.OPENROUTER_API_KEY,
+        temperature: Number.parseFloat(
+          process.env.OPENROUTER_TEMPERATURE ?? '0',
+        ),
+        baseURL: process.env.OPENROUTER_BASE_URL,
+      },
+    });
+  }
+}

src/sub-modules/providers/openrouter/types.ts

@@ -0,0 +1,6 @@
+import {ChatOpenRouterInput} from '@langchain/openrouter';
+
+export type OpenRouterInstanceConfig = {
+  model: string;
+  config: Omit<ChatOpenRouterInput, 'model'>;
+};

src/types.ts

@@ -12,6 +12,7 @@ import {Provider} from '@loopback/core';
 import {AnyObject} from '@loopback/repository';
 import {IGraphTool} from './graphs/types';
 import {ChatGroq} from '@langchain/groq';
+import {ChatOpenRouter} from '@langchain/openrouter';
 
 export enum SupportedDBs {
   PostgreSQL = 'PostgreSQL',
@@ -43,7 +44,8 @@ export type LLMProviderType =
   | ChatAnthropic
   | ChatBedrockConverse
   | ChatGoogleGenerativeAI
-  | ChatGroq;
+  | ChatGroq
+  | ChatOpenRouter;
 
 export type LLMProvider = LLMProviderType & {
   getFile?: FileMessageBuilder;

tsconfig.json

@@ -3,7 +3,8 @@
   "extends": "@loopback/build/config/tsconfig.common.json",
   "compilerOptions": {
     "outDir": "dist",
-    "rootDir": "src"
+    "rootDir": "src",
+    "lib": ["es2022"]
   },
   "include": ["src"]
 }