Remove absolute import paths, update uuid imports (langchain-ai#1142)

* Remove absolute import paths

* Fix abs import

* Update imports of uuid to be compatible with misconfigured environments

langchain/src/callbacks/base.ts

@@ -1,4 +1,4 @@
-import { v4 as uuidv4 } from "uuid";
+import * as uuid from "uuid";
 import {
   AgentAction,
   AgentFinish,
@@ -179,7 +179,7 @@ export abstract class BaseCallbackHandler
 
   static fromMethods(methods: CallbackHandlerMethods) {
     class Handler extends BaseCallbackHandler {
-      name = uuidv4();
+      name = uuid.v4();
 
       constructor() {
         super();

langchain/src/callbacks/tests/callbacks.test.ts

@@ -1,5 +1,5 @@
 import { test, expect } from "@jest/globals";
-import { v4 as uuidv4 } from "uuid";
+import * as uuid from "uuid";
 import { CallbackManager } from "../manager.js";
 import { BaseCallbackHandler, BaseCallbackHandlerInput } from "../base.js";
 import {
@@ -10,7 +10,7 @@ import {
 } from "../../schema/index.js";
 
 class FakeCallbackHandler extends BaseCallbackHandler {
-  name = `fake-${uuidv4()}`;
+  name = `fake-${uuid.v4()}`;
 
   starts = 0;
 

langchain/src/callbacks/tests/langchain_tracer.int.test.ts

@@ -1,5 +1,5 @@
-import { v4 as uuidv4 } from "uuid";
 /* eslint-disable no-process-env */
+import * as uuid from "uuid";
 import { test } from "@jest/globals";
 
 import { LangChainTracer } from "../handlers/tracers.js";
@@ -10,15 +10,15 @@ import { initializeAgentExecutorWithOptions } from "../../agents/index.js";
 
 test("Test LangChain tracer", async () => {
   const tracer = new LangChainTracer();
-  const chainRunId = uuidv4();
-  const toolRunId = uuidv4();
-  const llmRunId = uuidv4();
+  const chainRunId = uuid.v4();
+  const toolRunId = uuid.v4();
+  const llmRunId = uuid.v4();
   await tracer.handleChainStart({ name: "test" }, { foo: "bar" }, chainRunId);
   await tracer.handleToolStart({ name: "test" }, "test", toolRunId, chainRunId);
   await tracer.handleLLMStart({ name: "test" }, ["test"], llmRunId, toolRunId);
   await tracer.handleLLMEnd({ generations: [[]] }, llmRunId);
   await tracer.handleToolEnd("output", toolRunId);
-  const llmRunId2 = uuidv4();
+  const llmRunId2 = uuid.v4();
   await tracer.handleLLMStart(
     { name: "test2" },
     ["test"],
@@ -28,7 +28,7 @@ test("Test LangChain tracer", async () => {
   await tracer.handleLLMEnd({ generations: [[]] }, llmRunId2);
   await tracer.handleChainEnd({ foo: "bar" }, chainRunId);
 
-  const llmRunId3 = uuidv4();
+  const llmRunId3 = uuid.v4();
   await tracer.handleLLMStart({ name: "test" }, ["test"], llmRunId3);
   await tracer.handleLLMEnd({ generations: [[]] }, llmRunId3);
 });

langchain/src/callbacks/tests/tracer.test.ts

@@ -1,5 +1,5 @@
 import { test, expect, jest } from "@jest/globals";
-import { v4 as uuidv4 } from "uuid";
+import * as uuid from "uuid";
 import {
   BaseTracer,
   LLMRun,
@@ -57,7 +57,7 @@ class FakeTracer extends BaseTracer {
 test("Test LLMRun", async () => {
   const tracer = new FakeTracer();
   await tracer.newSession();
-  const runId = uuidv4();
+  const runId = uuid.v4();
   await tracer.handleLLMStart({ name: "test" }, ["test"], runId);
   await tracer.handleLLMEnd({ generations: [] }, runId);
   expect(tracer.runs.length).toBe(1);
@@ -80,7 +80,7 @@ test("Test LLMRun", async () => {
 test("Test LLM Run no start", async () => {
   const tracer = new FakeTracer();
   await tracer.newSession();
-  const runId = uuidv4();
+  const runId = uuid.v4();
   await expect(tracer.handleLLMEnd({ generations: [] }, runId)).rejects.toThrow(
     "No LLM run to end"
   );
@@ -89,7 +89,7 @@ test("Test LLM Run no start", async () => {
 test("Test Chain Run", async () => {
   const tracer = new FakeTracer();
   await tracer.newSession();
-  const runId = uuidv4();
+  const runId = uuid.v4();
   const compareRun: ChainRun = {
     uuid: runId,
     start_time: _DATE,
@@ -115,7 +115,7 @@ test("Test Chain Run", async () => {
 test("Test Tool Run", async () => {
   const tracer = new FakeTracer();
   await tracer.newSession();
-  const runId = uuidv4();
+  const runId = uuid.v4();
   const compareRun: ToolRun = {
     uuid: runId,
     start_time: _DATE,
@@ -142,15 +142,15 @@ test("Test Tool Run", async () => {
 test("Test nested runs", async () => {
   const tracer = new FakeTracer();
   await tracer.newSession();
-  const chainRunId = uuidv4();
-  const toolRunId = uuidv4();
-  const llmRunId = uuidv4();
+  const chainRunId = uuid.v4();
+  const toolRunId = uuid.v4();
+  const llmRunId = uuid.v4();
   await tracer.handleChainStart({ name: "test" }, { foo: "bar" }, chainRunId);
   await tracer.handleToolStart({ name: "test" }, "test", toolRunId, chainRunId);
   await tracer.handleLLMStart({ name: "test" }, ["test"], llmRunId, toolRunId);
   await tracer.handleLLMEnd({ generations: [[]] }, llmRunId);
   await tracer.handleToolEnd("output", toolRunId);
-  const llmRunId2 = uuidv4();
+  const llmRunId2 = uuid.v4();
   await tracer.handleLLMStart(
     { name: "test2" },
     ["test"],
@@ -239,7 +239,7 @@ test("Test nested runs", async () => {
   expect(tracer.runs.length).toBe(1);
   expect(tracer.runs[0]).toEqual(compareRun);
 
-  const llmRunId3 = uuidv4();
+  const llmRunId3 = uuid.v4();
   await tracer.handleLLMStart({ name: "test" }, ["test"], llmRunId3);
   await tracer.handleLLMEnd({ generations: [[]] }, llmRunId3);
   expect(tracer.runs.length).toBe(2);

langchain/src/chat_models/openai.ts

@@ -11,7 +11,7 @@ import {
   AzureOpenAIInput,
   OpenAICallOptions,
   OpenAIChatInput,
-} from "types/open-ai-types.js";
+} from "../types/open-ai-types.js";
 import fetchAdapter from "../util/axios-fetch-adapter.js";
 import type { StreamingAxiosConfiguration } from "../util/axios-types.js";
 import { BaseChatModel, BaseChatModelParams } from "./base.js";

langchain/src/llms/openai.ts

@@ -11,7 +11,7 @@ import {
   AzureOpenAIInput,
   OpenAICallOptions,
   OpenAIInput,
-} from "types/open-ai-types.js";
+} from "../types/open-ai-types.js";
 import type { StreamingAxiosConfiguration } from "../util/axios-types.js";
 import fetchAdapter from "../util/axios-fetch-adapter.js";
 import { chunkArray } from "../util/chunk.js";

langchain/src/retrievers/time_weighted.ts

@@ -1,4 +1,4 @@
-import { VectorStore } from "vectorstores/base.js";
+import { VectorStore } from "../vectorstores/base.js";
 import { Document } from "../document.js";
 import { BaseRetriever } from "../schema/index.js";
 

langchain/src/vectorstores/chroma.ts

@@ -1,4 +1,4 @@
-import { v4 as uuidv4 } from "uuid";
+import * as uuid from "uuid";
 import type { ChromaClient as ChromaClientT, Collection } from "chromadb";
 
 import { Embeddings } from "../embeddings/base.js";
@@ -182,7 +182,7 @@ export class Chroma extends VectorStore {
 
 function ensureCollectionName(collectionName?: string) {
   if (!collectionName) {
-    return `langchain-${uuidv4()}`;
+    return `langchain-${uuid.v4()}`;
   }
   return collectionName;
 }

langchain/src/vectorstores/milvus.ts

@@ -1,4 +1,4 @@
-import { v4 as uuidv4 } from "uuid";
+import * as uuid from "uuid";
 import { MilvusClient } from "@zilliz/milvus2-sdk-node";
 import {
   DataType,
@@ -487,7 +487,7 @@ function createFieldTypeForMetadata(documents: Document[]): FieldType[] {
 }
 
 function genCollectionName(): string {
-  return `${MILVUS_COLLECTION_NAME_PREFIX}_${uuidv4().replaceAll("-", "")}`;
+  return `${MILVUS_COLLECTION_NAME_PREFIX}_${uuid.v4().replaceAll("-", "")}`;
 }
 
 function getTextFieldMaxLength(documents: Document[]) {

langchain/src/vectorstores/myscale.ts

@@ -1,4 +1,4 @@
-import { v4 as uuid } from "uuid";
+import * as uuid from "uuid";
 import { ClickHouseClient, createClient } from "@clickhouse/client";
 
 import { Embeddings } from "../embeddings/base.js";
@@ -70,7 +70,7 @@ export class MyScaleStore extends VectorStore {
       host: `${args.protocol ?? "https://"}${args.host}:${args.port}`,
       username: args.username,
       password: args.password,
-      session_id: uuid(),
+      session_id: uuid.v4(),
     });
   }
 
@@ -190,7 +190,7 @@ export class MyScaleStore extends VectorStore {
       const vector = vectors[i];
       const document = documents[i];
       const item = [
-        `'${uuid()}'`,
+        `'${uuid.v4()}'`,
         `'${this.escapeString(document.pageContent)}'`,
         `[${vector}]`,
         `'${JSON.stringify(document.metadata)}'`,

langchain/src/vectorstores/opensearch.ts

@@ -1,5 +1,5 @@
 import { Client, RequestParams, errors } from "@opensearch-project/opensearch";
-import { v4 as uuid } from "uuid";
+import * as uuid from "uuid";
 import { Embeddings } from "../embeddings/base.js";
 import { Document } from "../document.js";
 import { VectorStore } from "./base.js";
@@ -75,7 +75,7 @@ export class OpenSearchVectorStore extends VectorStore {
       {
         index: {
           _index: this.indexName,
-          _id: uuid(),
+          _id: uuid.v4(),
         },
       },
       {

langchain/src/vectorstores/pinecone.ts

@@ -1,4 +1,4 @@
-import { v4 as uuidv4 } from "uuid";
+import * as uuid from "uuid";
 import flatten from "flat";
 
 import { VectorStore } from "./base.js";
@@ -54,7 +54,7 @@ export class PineconeStore extends VectorStore {
     documents: Document[],
     ids?: string[]
   ): Promise<void> {
-    const documentIds = ids == null ? documents.map(() => uuidv4()) : ids;
+    const documentIds = ids == null ? documents.map(() => uuid.v4()) : ids;
     const pineconeVectors = vectors.map((values, idx) => {
       // Pinecone doesn't support nested objects, so we flatten them
       const metadata: {

langchain/src/vectorstores/tests/pinecone.int.test.ts

@@ -3,7 +3,7 @@
 import { beforeEach, describe, expect, test } from "@jest/globals";
 import { faker } from "@faker-js/faker";
 import { PineconeClient } from "@pinecone-database/pinecone";
-import { v4 as uuidv4 } from "uuid";
+import * as uuid from "uuid";
 import { Document } from "../../document.js";
 import { OpenAIEmbeddings } from "../../embeddings/openai.js";
 import { PineconeStore } from "../pinecone.js";
@@ -25,7 +25,7 @@ describe("PineconeStore", () => {
   });
 
   test("user-provided ids", async () => {
-    const documentId = uuidv4();
+    const documentId = uuid.v4();
     const pageContent = faker.lorem.sentence(5);
 
     await pineconeStore.addDocuments(
@@ -54,21 +54,21 @@ describe("PineconeStore", () => {
 
   test("metadata filtering", async () => {
     const pageContent = faker.lorem.sentence(5);
-    const uuid = uuidv4();
+    const id = uuid.v4();
 
     await pineconeStore.addDocuments([
       { pageContent, metadata: { foo: "bar" } },
-      { pageContent, metadata: { foo: uuid } },
+      { pageContent, metadata: { foo: id } },
       { pageContent, metadata: { foo: "qux" } },
     ]);
 
     // If the filter wasn't working, we'd get all 3 documents back
     const results = await pineconeStore.similaritySearch(pageContent, 3, {
-      foo: uuid,
+      foo: id,
     });
 
     expect(results).toEqual([
-      new Document({ metadata: { foo: uuid }, pageContent }),
+      new Document({ metadata: { foo: id }, pageContent }),
     ]);
   });
 });

langchain/src/vectorstores/weaviate.ts

@@ -1,4 +1,4 @@
-import { v4 } from "uuid";
+import * as uuid from "uuid";
 import type {
   WeaviateObject,
   WeaviateClient,
@@ -103,7 +103,7 @@ export class WeaviateStore extends VectorStore {
       const flattenedMetadata = flattenObjectForWeaviate(document.metadata);
       return {
         class: this.indexName,
-        id: v4(),
+        id: uuid.v4(),
         vector: vectors[index],
         properties: {
           [this.textKey]: document.pageContent,

langchain/tsconfig.json

@@ -12,7 +12,6 @@
     "module": "ES2020",
     "moduleResolution": "nodenext",
     "esModuleInterop": true,
-    "baseUrl": "./src",
     "declaration": true,
     "noImplicitReturns": true,
     "noFallthroughCasesInSwitch": true,

test-exports-esm/src/index.js

@@ -7,13 +7,16 @@ import { HNSWLib } from "langchain/vectorstores/hnswlib";
 import { OpenAIEmbeddings } from "langchain/embeddings/openai";
 import { InMemoryDocstore, Document } from "langchain/docstore";
 import { CSVLoader } from "langchain/document_loaders/fs/csv";
+import { CallbackManager } from "langchain/callbacks";
 
 // Test exports
 assert(typeof OpenAI === "function");
 assert(typeof LLMChain === "function");
 assert(typeof loadPrompt === "function");
 assert(typeof ChatPromptTemplate === "function");
 assert(typeof HNSWLib === "function");
+assert(typeof OpenAIEmbeddings === "function");
+assert(typeof CallbackManager === "function");
 
 // Test dynamic imports of peer dependencies
 const { HierarchicalNSW } = await HNSWLib.imports();