diff --git a/examples/agent/multi_document_agent.ts b/examples/agent/multi_document_agent.ts index ecdd805b82d8f728e6e6263760ea3b54f02a84e2..0a70ecacb865c4eadbea5fff725ee1921ebe0653 100644 --- a/examples/agent/multi_document_agent.ts +++ b/examples/agent/multi_document_agent.ts @@ -145,4 +145,4 @@ async function main() { }); } -main(); +void main(); diff --git a/examples/agent/openai.ts b/examples/agent/openai.ts index 58eb11a0aa9cd85df53af8a203e7b6aff299ef28..62b8e35cfc55f4022152d65a8f67d6506f0b5816 100644 --- a/examples/agent/openai.ts +++ b/examples/agent/openai.ts @@ -71,6 +71,6 @@ async function main() { console.log(String(response)); } -main().then(() => { +void main().then(() => { console.log("Done"); }); diff --git a/examples/agent/query_openai_agent.ts b/examples/agent/query_openai_agent.ts index f3da8592ad40c84ed6e5eafa5de24459d465ecea..69281f4b5c3ce0f368524382433bcd3cdbe67309 100644 --- a/examples/agent/query_openai_agent.ts +++ b/examples/agent/query_openai_agent.ts @@ -41,6 +41,6 @@ async function main() { console.log(String(response)); } -main().then(() => { +void main().then(() => { console.log("Done"); }); diff --git a/examples/agent/react_agent.ts b/examples/agent/react_agent.ts index 1df04fffbc3e13dcb574ab2295da97b6316d21cf..bfd8b82219e74166e42bcc1f0926965c5cb970ec 100644 --- a/examples/agent/react_agent.ts +++ b/examples/agent/react_agent.ts @@ -77,6 +77,6 @@ async function main() { console.log(String(response)); } -main().then(() => { +void main().then(() => { console.log("Done"); }); diff --git a/examples/agent/step_wise_openai.ts b/examples/agent/step_wise_openai.ts index abbc273c5f634dd1d63769887c31a5d19c9a7804..853b577fe1ac17bf793b8a77736b7fcf51b20728 100644 --- a/examples/agent/step_wise_openai.ts +++ b/examples/agent/step_wise_openai.ts @@ -90,6 +90,6 @@ async function main() { } } -main().then(() => { +void main().then(() => { console.log("Done"); }); diff --git a/examples/agent/step_wise_query_tool.ts b/examples/agent/step_wise_query_tool.ts index d7a17295a54bb72c208bdce5a95aee5c6a158015..4b8d4db19263b1b66941370f2cbfb6d6be73d988 100644 --- a/examples/agent/step_wise_query_tool.ts +++ b/examples/agent/step_wise_query_tool.ts @@ -59,6 +59,6 @@ async function main() { } } -main().then(() => { +void main().then(() => { console.log("Done"); }); diff --git a/examples/agent/step_wise_react.ts b/examples/agent/step_wise_react.ts index 4230db586f9f33863771f4e89f0bca66fe48785b..4e9280ceae4a137a729b2e288e645257acbcd5da 100644 --- a/examples/agent/step_wise_react.ts +++ b/examples/agent/step_wise_react.ts @@ -85,6 +85,6 @@ async function main() { } } -main().then(() => { +void main().then(() => { console.log("Done"); }); diff --git a/examples/agent/stream_openai_agent.ts b/examples/agent/stream_openai_agent.ts index 3693381f32d7fc75c313a42c94f06ae69ed9316b..2190370640dddc6c56a0a654964f59f7a8754e2d 100644 --- a/examples/agent/stream_openai_agent.ts +++ b/examples/agent/stream_openai_agent.ts @@ -72,6 +72,6 @@ async function main() { } } -main().then(() => { +void main().then(() => { console.log("\nDone"); }); diff --git a/examples/agent/wikipedia-tool.ts b/examples/agent/wikipedia-tool.ts index 3cb961733bc3893760bdd6b6c6ab18383258eb8a..1a5e82fc116bf37b583b60187c1871b93fd051ff 100644 --- a/examples/agent/wikipedia-tool.ts +++ b/examples/agent/wikipedia-tool.ts @@ -18,6 +18,6 @@ async function main() { console.log(response); } -main().then(() => { +void main().then(() => { console.log("Done"); }); diff --git a/examples/astradb/example.ts b/examples/astradb/example.ts index 67b0170bc9728aa222549a6d9d64d2d41a634ec4..92831d89051792c03727f411f15621af3790d0eb 100644 --- a/examples/astradb/example.ts +++ b/examples/astradb/example.ts @@ -55,4 +55,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/astradb/load.ts b/examples/astradb/load.ts index d1982505b0bdf62bd17caa78cf6994e0fe5e9986..bc306e633e464f56843eb1b4fdf365014cf02ed8 100644 --- a/examples/astradb/load.ts +++ b/examples/astradb/load.ts @@ -27,4 +27,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/astradb/query.ts b/examples/astradb/query.ts index 546920a8bf931b0b41ea493e02ec8946f4b95705..ff8cb98f4f6d4f4ab6929c34df9cf40fd1253510 100644 --- a/examples/astradb/query.ts +++ b/examples/astradb/query.ts @@ -23,4 +23,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/chromadb/preFilters.ts b/examples/chromadb/preFilters.ts index df5da1c869c8131da0adbecbf52d0681fe764167..5265e201d121ec658d9f7aa776eae83ad3081e70 100644 --- a/examples/chromadb/preFilters.ts +++ b/examples/chromadb/preFilters.ts @@ -54,4 +54,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/chromadb/test.ts b/examples/chromadb/test.ts index c901e82b36bb127183f0e98476b4c93e781e96ce..f1084566ec7f31dc3b29068b5942c26390c67fef 100644 --- a/examples/chromadb/test.ts +++ b/examples/chromadb/test.ts @@ -37,4 +37,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/evaluation/correctness.ts b/examples/evaluation/correctness.ts index 4d920a062a25bb02c1b9c9c9cc65b5bb38e2edfd..f9f9b7cbbc932da4e9e28b8d140175d478599774 100644 --- a/examples/evaluation/correctness.ts +++ b/examples/evaluation/correctness.ts @@ -22,4 +22,4 @@ However, general relativity, published in 1915, extended these ideas to include console.log(result); } -main(); +void main(); diff --git a/examples/evaluation/faithfulness.ts b/examples/evaluation/faithfulness.ts index 8456e3f47a338e24558643b1566bd3c5b317f0a3..f5b48288f3a30e7bbc8763e6dfc6a74b9c3728ff 100644 --- a/examples/evaluation/faithfulness.ts +++ b/examples/evaluation/faithfulness.ts @@ -36,4 +36,4 @@ async function main() { console.log(result); } -main(); +void main(); diff --git a/examples/evaluation/relevancy.ts b/examples/evaluation/relevancy.ts index 2467d66fdb71b5fd18a646417a10ba943abc3cca..91360783cdcc30a78a0ddae81b897d33c2002604 100644 --- a/examples/evaluation/relevancy.ts +++ b/examples/evaluation/relevancy.ts @@ -37,4 +37,4 @@ async function main() { console.log(result); } -main(); +void main(); diff --git a/examples/milvus/load.ts b/examples/milvus/load.ts index cb4bd19ba0a2176c964459a3a88461cbd4c2f662..38a62080ef99728591622523079e88c7b6c16071 100644 --- a/examples/milvus/load.ts +++ b/examples/milvus/load.ts @@ -23,4 +23,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/milvus/query.ts b/examples/milvus/query.ts index 38ad3a7b1c64d21a875495c088732faf8515be3f..ff33fc69a70affe0ac654f4aa2d769a2b5fa9589 100644 --- a/examples/milvus/query.ts +++ b/examples/milvus/query.ts @@ -22,4 +22,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/mongo.ts b/examples/mongo.ts index 6cabbfe35abbf2c74ca69ba66e86f4aeb53cbd10..24f245ea3a9a37c77c9faabf3bb4fa77b9caf755 100644 --- a/examples/mongo.ts +++ b/examples/mongo.ts @@ -61,4 +61,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/mongodb/1_import.ts b/examples/mongodb/1_import.ts index 73d6a3a871afc9d57f23493a0c0fdae96e9bc4a4..a24d16c9f518640a9e1ed2649843afbf101d21d8 100644 --- a/examples/mongodb/1_import.ts +++ b/examples/mongodb/1_import.ts @@ -31,4 +31,4 @@ async function importJsonToMongo() { } // Run the import function -importJsonToMongo(); +void importJsonToMongo(); diff --git a/examples/mongodb/3_query.ts b/examples/mongodb/3_query.ts index 9585d90a8c91543b2c28c730a3a9a3add1501fff..d8158dc496796f98e35a06004d81b3421183a009 100644 --- a/examples/mongodb/3_query.ts +++ b/examples/mongodb/3_query.ts @@ -27,4 +27,4 @@ async function query() { await client.close(); } -query(); +void query(); diff --git a/examples/multimodal/clip.ts b/examples/multimodal/clip.ts index 6d02b7ea9622c40de6eac9f599666df26daddef5..f3eaa984d6c8a0119fe355a249558b9ade9b9c0b 100644 --- a/examples/multimodal/clip.ts +++ b/examples/multimodal/clip.ts @@ -30,4 +30,4 @@ async function main() { console.log(`Similarity between "${text2}" and the image is ${sim2}`); } -main(); +void main(); diff --git a/examples/nodeParser/MarkdownNodeParser.ts b/examples/nodeParser/MarkdownNodeParser.ts index 3ff7b4d99b21f105b2e48edc196b2f009c03616a..acb3146e784dade6cc6b3647b5fd6af4b991ce8a 100644 --- a/examples/nodeParser/MarkdownNodeParser.ts +++ b/examples/nodeParser/MarkdownNodeParser.ts @@ -21,4 +21,4 @@ Sub-header content console.log(splits); } -main(); +void main(); diff --git a/examples/pg-vector-store/load-docs.ts b/examples/pg-vector-store/load-docs.ts index 829bb39b81d5047594e512efa750c0eb86a1096c..32e140041d832b8d4b27608767366d6a0f42b5b8 100755 --- a/examples/pg-vector-store/load-docs.ts +++ b/examples/pg-vector-store/load-docs.ts @@ -32,7 +32,7 @@ async function main(args: any) { console.log(`Found ${count} files`); console.log(`Importing contents from ${count} files in ${sourceDir}`); - var fileName = ""; + const fileName = ""; try { // Passing callback fn to the ctor here // will enable looging to console. @@ -42,7 +42,7 @@ async function main(args: any) { const pgvs = new PGVectorStore(); pgvs.setCollection(sourceDir); - pgvs.clearCollection(); + await pgvs.clearCollection(); const ctx = await storageContextFromDefaults({ vectorStore: pgvs }); @@ -65,4 +65,4 @@ async function main(args: any) { process.exit(0); } -main(process.argv).catch((err) => console.error(err)); +void main(process.argv).catch((err) => console.error(err)); diff --git a/examples/pinecone-vector-store/load-docs.ts b/examples/pinecone-vector-store/load-docs.ts index 12a50f54649408e75b7a9963abfd9f158aa0495f..d5d485021919e99a7f481a844db425e4d14a28b9 100755 --- a/examples/pinecone-vector-store/load-docs.ts +++ b/examples/pinecone-vector-store/load-docs.ts @@ -32,7 +32,7 @@ async function main(args: any) { console.log(`Found ${count} files`); console.log(`Importing contents from ${count} files in ${sourceDir}`); - var fileName = ""; + const fileName = ""; try { // Passing callback fn to the ctor here // will enable looging to console. @@ -63,4 +63,4 @@ async function main(args: any) { process.exit(0); } -main(process.argv).catch((err) => console.error(err)); +void main(process.argv).catch((err) => console.error(err)); diff --git a/examples/prompts/promptMixin.ts b/examples/prompts/promptMixin.ts index bd60fd3752524a66dac8d6638717ce2109d35cf2..7200d526ee72b0a8a195c6986beca1c70460f340 100644 --- a/examples/prompts/promptMixin.ts +++ b/examples/prompts/promptMixin.ts @@ -45,4 +45,4 @@ async function main() { await queryEngine.query({ query }); } -main(); +void main(); diff --git a/examples/qdrantdb/preFilters.ts b/examples/qdrantdb/preFilters.ts index 0cc105a529ca9a1903194e874b08d7e054033daf..35a04e04a1ad4ef76ca96b8fc9607f90b3213168 100644 --- a/examples/qdrantdb/preFilters.ts +++ b/examples/qdrantdb/preFilters.ts @@ -79,4 +79,4 @@ async function main() { } } -main(); +void main(); diff --git a/examples/readers/src/docx.ts b/examples/readers/src/docx.ts index fee35b0994df04d436ff9c12a80efa7a3eff5f79..2e1a1a16cbfed5d805ae6f476f3638906d2335dd 100644 --- a/examples/readers/src/docx.ts +++ b/examples/readers/src/docx.ts @@ -20,4 +20,4 @@ async function main() { console.log(`Test query > ${SAMPLE_QUERY}:\n`, response.toString()); } -main(); +void main(); diff --git a/examples/readers/src/markdown.ts b/examples/readers/src/markdown.ts index e9fb52e46c066fc4658cf825dfc98bec15bd51ad..4037f745e65fccc112e30345cbc27ae0c28bca0b 100644 --- a/examples/readers/src/markdown.ts +++ b/examples/readers/src/markdown.ts @@ -20,4 +20,4 @@ async function main() { console.log(`Test query > ${SAMPLE_QUERY}:\n`, response.toString()); } -main(); +void main(); diff --git a/examples/recipes/cost-analysis.ts b/examples/recipes/cost-analysis.ts index c27a8c6c8949a99d6fc04249a6b4c89f57fde084..1070118b059a1a00ed5f0b501ac8efac198527d5 100644 --- a/examples/recipes/cost-analysis.ts +++ b/examples/recipes/cost-analysis.ts @@ -31,7 +31,7 @@ Settings.callbackManager.on("llm-end", (event) => { const question = "Hello, how are you?"; console.log("Question:", question); -llm +void llm .chat({ stream: true, messages: [ diff --git a/examples/routerQueryEngine.ts b/examples/routerQueryEngine.ts index d28f9e30d9a7ae5d2ebc826c485020b52002d774..5bd169008905ea35f173821b314ccddbe8dfd258 100644 --- a/examples/routerQueryEngine.ts +++ b/examples/routerQueryEngine.ts @@ -65,4 +65,4 @@ async function main() { }); } -main().then(() => console.log("Done")); +void main().then(() => console.log("Done")); diff --git a/examples/split.ts b/examples/split.ts index ca077f82640656e4300740d670fd8d73bb83b72f..ce070c5f303f7580dd1d24de0e74e484b77d502a 100644 --- a/examples/split.ts +++ b/examples/split.ts @@ -13,4 +13,4 @@ async function main() { console.log(chunks); } -main(); +void main(); diff --git a/packages/core/src/indices/keyword/index.ts b/packages/core/src/indices/keyword/index.ts index 3fedcef49db5b252c6309ecaef800d83c45ffe5b..2f0441e0c326055ece125cbc5255b098d643ad0b 100644 --- a/packages/core/src/indices/keyword/index.ts +++ b/packages/core/src/indices/keyword/index.ts @@ -278,7 +278,7 @@ export class KeywordTableIndex extends BaseIndex<KeywordTable> { serviceContext = serviceContext ?? serviceContextFromDefaults({}); const docStore = storageContext.docStore; - docStore.addDocuments(documents, true); + await docStore.addDocuments(documents, true); for (const doc of documents) { docStore.setDocumentHash(doc.id_, doc.hash); } diff --git a/packages/core/src/indices/summary/index.ts b/packages/core/src/indices/summary/index.ts index 140347963f5fbc30401846f4b70d4f520947a7a9..54f381738809acd0b06e0719cc121ff2bb3316ee 100644 --- a/packages/core/src/indices/summary/index.ts +++ b/packages/core/src/indices/summary/index.ts @@ -135,7 +135,7 @@ export class SummaryIndex extends BaseIndex<IndexList> { serviceContext = serviceContext; const docStore = storageContext.docStore; - docStore.addDocuments(documents, true); + await docStore.addDocuments(documents, true); for (const doc of documents) { docStore.setDocumentHash(doc.id_, doc.hash); } diff --git a/packages/core/src/indices/vectorStore/index.ts b/packages/core/src/indices/vectorStore/index.ts index 06f5c20c973a09d7f96d956cdc5ac3810281772d..5619f7cb8fe47059f4a90eb15962f2ced0c2d9ac 100644 --- a/packages/core/src/indices/vectorStore/index.ts +++ b/packages/core/src/indices/vectorStore/index.ts @@ -364,7 +364,7 @@ export class VectorStoreIndex extends BaseIndex<IndexDict> { vectorStore: VectorStore, refDocId: string, ): Promise<void> { - vectorStore.delete(refDocId); + await vectorStore.delete(refDocId); if (!vectorStore.storesText) { const refDocInfo = await this.docStore.getRefDocInfo(refDocId); @@ -372,7 +372,7 @@ export class VectorStoreIndex extends BaseIndex<IndexDict> { if (refDocInfo) { for (const nodeId of refDocInfo.nodeIds) { this.indexStruct.delete(nodeId); - vectorStore.delete(nodeId); + await vectorStore.delete(nodeId); } } await this.indexStore.addIndexStruct(this.indexStruct); diff --git a/packages/core/src/ingestion/strategies/DuplicatesStrategy.ts b/packages/core/src/ingestion/strategies/DuplicatesStrategy.ts index 096b27c19ac18827e32bc415fe602d5d4025163d..3aee977bc7f496c6850865d5d7aaca97a34eecd9 100644 --- a/packages/core/src/ingestion/strategies/DuplicatesStrategy.ts +++ b/packages/core/src/ingestion/strategies/DuplicatesStrategy.ts @@ -25,7 +25,7 @@ export class DuplicatesStrategy implements TransformComponent { } } - this.docStore.addDocuments(nodesToRun, true); + await this.docStore.addDocuments(nodesToRun, true); return nodesToRun; } diff --git a/packages/core/src/ingestion/strategies/UpsertsStrategy.ts b/packages/core/src/ingestion/strategies/UpsertsStrategy.ts index 1a4eeca7fe274124f0496ca41f7505e54e096ac7..b562b1e426e7e6d8c1c7e639213e924298adbb11 100644 --- a/packages/core/src/ingestion/strategies/UpsertsStrategy.ts +++ b/packages/core/src/ingestion/strategies/UpsertsStrategy.ts @@ -26,7 +26,7 @@ export class UpsertsStrategy implements TransformComponent { } } // add non-duplicate docs - this.docStore.addDocuments(dedupedNodes, true); + await this.docStore.addDocuments(dedupedNodes, true); return dedupedNodes; } } diff --git a/packages/core/src/objects/base.ts b/packages/core/src/objects/base.ts index 2934de25f249e8ca45907263485ab2567c56479e..b7bd963996a3ddadd8ecacf0aeea65d2f18b85de 100644 --- a/packages/core/src/objects/base.ts +++ b/packages/core/src/objects/base.ts @@ -170,10 +170,10 @@ export class ObjectIndex { return new ObjectIndex(index, objectMapping); } - insertObject(obj: any): void { + async insertObject(obj: any): Promise<void> { this._objectNodeMapping.addObj(obj); const node = this._objectNodeMapping.toNode(obj); - this._index.insertNodes([node]); + await this._index.insertNodes([node]); } get tools(): Record<string, BaseTool> { diff --git a/packages/core/src/storage/docStore/KVDocumentStore.ts b/packages/core/src/storage/docStore/KVDocumentStore.ts index c18d233c1fad966874719a351491095093ebdc75..ac644faba00950969ab1e11dbecb33ea32b52519 100644 --- a/packages/core/src/storage/docStore/KVDocumentStore.ts +++ b/packages/core/src/storage/docStore/KVDocumentStore.ts @@ -70,7 +70,7 @@ export class KVDocumentStore extends BaseDocumentStore { metadata.refDocId = doc.sourceNode.nodeId!; } - this.kvstore.put(nodeKey, metadata, this.metadataCollection); + await this.kvstore.put(nodeKey, metadata, this.metadataCollection); } } @@ -126,9 +126,9 @@ export class KVDocumentStore extends BaseDocumentStore { !_.pull(refDocInfo.nodeIds, docId); if (refDocInfo.nodeIds.length > 0) { - this.kvstore.put(refDocId, refDocInfo, this.refDocCollection); + await this.kvstore.put(refDocId, refDocInfo, this.refDocCollection); } - this.kvstore.delete(refDocId, this.metadataCollection); + await this.kvstore.delete(refDocId, this.metadataCollection); } } diff --git a/packages/core/src/storage/vectorStore/MilvusVectorStore.ts b/packages/core/src/storage/vectorStore/MilvusVectorStore.ts index 0f06d7b7356d0f54438cefdb9fa5549df7d7e897..0a5f3f1077bad53fa0bf6fbb5e74295fa6b0cc79 100644 --- a/packages/core/src/storage/vectorStore/MilvusVectorStore.ts +++ b/packages/core/src/storage/vectorStore/MilvusVectorStore.ts @@ -167,7 +167,7 @@ export class MilvusVectorStore implements VectorStore { refDocId: string, deleteOptions?: Omit<DeleteReq, "ids">, ): Promise<void> { - this.ensureCollection(); + await this.ensureCollection(); await this.milvusClient.delete({ ids: [refDocId], diff --git a/packages/core/src/storage/vectorStore/PGVectorStore.ts b/packages/core/src/storage/vectorStore/PGVectorStore.ts index 74faa505520af696750936c9189cc52a6349c8ec..bc59542450a09b7f72f5aae43dbd85955dbbabd5 100644 --- a/packages/core/src/storage/vectorStore/PGVectorStore.ts +++ b/packages/core/src/storage/vectorStore/PGVectorStore.ts @@ -94,7 +94,7 @@ export class PGVectorStore implements VectorStore { await db.connect(); // Check vector extension - db.query("CREATE EXTENSION IF NOT EXISTS vector"); + await db.query("CREATE EXTENSION IF NOT EXISTS vector"); await registerType(db); // Check schema, table(s), index(es) diff --git a/packages/core/src/storage/vectorStore/PineconeVectorStore.ts b/packages/core/src/storage/vectorStore/PineconeVectorStore.ts index 515995469860f9032a77845300f0b1a2ad1a5ff1..e537ca2341d463fe80c9ac1e71d11b97c9deb9f5 100644 --- a/packages/core/src/storage/vectorStore/PineconeVectorStore.ts +++ b/packages/core/src/storage/vectorStore/PineconeVectorStore.ts @@ -142,11 +142,11 @@ export class PineconeVectorStore implements VectorStore { */ async query( query: VectorStoreQuery, - options?: any, + _options?: any, ): Promise<VectorStoreQueryResult> { const filter = this.toPineconeFilter(query.filters); - var options: any = { + const defaultOptions: any = { vector: query.queryEmbedding, topK: query.similarityTopK, includeValues: true, @@ -155,7 +155,7 @@ export class PineconeVectorStore implements VectorStore { }; const idx = await this.index(); - const results = await idx.query(options); + const results = await idx.query(defaultOptions); const idList = results.matches.map((row) => row.id); const records: FetchResponse<any> = await idx.fetch(idList); diff --git a/packages/core/tests/indices/VectorStoreIndex.test.ts b/packages/core/tests/indices/VectorStoreIndex.test.ts index 2d05195d4c2abc09f0872a7b9f2b4561cc5cfe50..50365b59eaba3ffafb43b09f939be627589ee121 100644 --- a/packages/core/tests/indices/VectorStoreIndex.test.ts +++ b/packages/core/tests/indices/VectorStoreIndex.test.ts @@ -63,9 +63,7 @@ describe.sequential("VectorStoreIndex", () => { expect(entries[0]).toBe(entries[1]); }); - afterAll(async () => { - // TODO: VectorStoreIndex.fromDocuments running twice is causing a cleanup issue - await new Promise((resolve) => setTimeout(resolve, 100)); + afterAll(() => { rmSync(testDir, { recursive: true }); }); }); diff --git a/packages/core/tests/objects/ObjectIndex.test.ts b/packages/core/tests/objects/ObjectIndex.test.ts index 356657919e8ba3219e80ddb89df23e659652df8d..cd74ac261654c2870341ed5b39dfce9ef67fb200 100644 --- a/packages/core/tests/objects/ObjectIndex.test.ts +++ b/packages/core/tests/objects/ObjectIndex.test.ts @@ -109,7 +109,7 @@ describe("ObjectIndex", () => { expect(Object.keys(tools).length).toBe(1); - objectRetriever.insertObject(tool2); + await objectRetriever.insertObject(tool2); tools = objectRetriever.tools; diff --git a/packages/core/tests/utility/mockOpenAI.ts b/packages/core/tests/utility/mockOpenAI.ts index 8fac02b5bf3acdeba83751784fa64445c831df9c..97fd1e4185a12284054847257ba486ca261bd9d5 100644 --- a/packages/core/tests/utility/mockOpenAI.ts +++ b/packages/core/tests/utility/mockOpenAI.ts @@ -20,7 +20,7 @@ export function mockLlmGeneration({ const chunks = text.split("-"); for (let i = 0; i < chunks.length; i++) { const chunk = chunks[i]; - callbackManager?.onLLMStream({ + await callbackManager?.onLLMStream({ index: i, token: { id: "id", @@ -39,7 +39,7 @@ export function mockLlmGeneration({ }, }); } - callbackManager?.onLLMStream({ + await callbackManager?.onLLMStream({ index: chunks.length, isDone: true, }); @@ -121,7 +121,7 @@ export function mocStructuredkLlmGeneration({ const chunks = text.split("-"); for (let i = 0; i < chunks.length; i++) { const chunk = chunks[i]; - callbackManager?.onLLMStream({ + await callbackManager?.onLLMStream({ index: i, token: { id: "id", @@ -140,7 +140,7 @@ export function mocStructuredkLlmGeneration({ }, }); } - callbackManager?.onLLMStream({ + await callbackManager?.onLLMStream({ index: chunks.length, isDone: true, }); diff --git a/packages/eslint-config-custom/index.js b/packages/eslint-config-custom/index.js index 41427af2b18bace2d8108be173be05dfa3b828bc..cb717fde3ed474e5f96aeb468f343b7405d3910d 100644 --- a/packages/eslint-config-custom/index.js +++ b/packages/eslint-config-custom/index.js @@ -1,7 +1,58 @@ module.exports = { - extends: ["next", "turbo", "prettier"], + extends: [ + "next", + "turbo", + "prettier", + "plugin:@typescript-eslint/recommended-type-checked-only", + ], rules: { "@next/next/no-html-link-for-pages": "off", + "@typescript-eslint/no-floating-promises": [ + "error", + { + ignoreIIFE: true, + }, + ], + "@typescript-eslint/await-thenable": "off", + "@typescript-eslint/ban-ts-comment": "off", + "@typescript-eslint/ban-types": "off", + "no-array-constructor": "off", + "@typescript-eslint/no-array-constructor": "off", + "@typescript-eslint/no-base-to-string": "off", + "@typescript-eslint/no-duplicate-enum-values": "off", + "@typescript-eslint/no-duplicate-type-constituents": "off", + "@typescript-eslint/no-explicit-any": "off", + "@typescript-eslint/no-extra-non-null-assertion": "off", + "@typescript-eslint/no-for-in-array": "off", + "no-implied-eval": "off", + "@typescript-eslint/no-implied-eval": "off", + "no-loss-of-precision": "off", + "@typescript-eslint/no-loss-of-precision": "off", + "@typescript-eslint/no-misused-new": "off", + "@typescript-eslint/no-misused-promises": "off", + "@typescript-eslint/no-namespace": "off", + "@typescript-eslint/no-non-null-asserted-optional-chain": "off", + "@typescript-eslint/no-redundant-type-constituents": "off", + "@typescript-eslint/no-this-alias": "off", + "@typescript-eslint/no-unnecessary-type-assertion": "off", + "@typescript-eslint/no-unnecessary-type-constraint": "off", + "@typescript-eslint/no-unsafe-argument": "off", + "@typescript-eslint/no-unsafe-assignment": "off", + "@typescript-eslint/no-unsafe-call": "off", + "@typescript-eslint/no-unsafe-declaration-merging": "off", + "@typescript-eslint/no-unsafe-enum-comparison": "off", + "@typescript-eslint/no-unsafe-member-access": "off", + "@typescript-eslint/no-unsafe-return": "off", + "no-unused-vars": "off", + "@typescript-eslint/no-unused-vars": "off", + "@typescript-eslint/no-var-requires": "off", + "@typescript-eslint/prefer-as-const": "off", + "require-await": "off", + "@typescript-eslint/require-await": "off", + "@typescript-eslint/restrict-plus-operands": "off", + "@typescript-eslint/restrict-template-expressions": "off", + "@typescript-eslint/triple-slash-reference": "off", + "@typescript-eslint/unbound-method": "off", }, // NOTE I think because we've temporarily removed all of the NextJS stuff // from the turborepo not having next in the devDeps causes an error on only @@ -13,6 +64,8 @@ module.exports = { babelOptions: { presets: [require.resolve("next/babel")], }, + project: true, + __tsconfigRootDir: __dirname, }, settings: { react: { diff --git a/packages/eslint-config-custom/package.json b/packages/eslint-config-custom/package.json index 055b7262d05bccca6360c0c27832c4ad99cdad53..ce4cbd829560ebe694d181b970691b682bfa2e9f 100644 --- a/packages/eslint-config-custom/package.json +++ b/packages/eslint-config-custom/package.json @@ -8,7 +8,8 @@ "eslint-config-next": "^13.5.6", "eslint-config-prettier": "^8.10.0", "eslint-config-turbo": "^1.11.3", - "eslint-plugin-react": "7.28.0" + "eslint-plugin-react": "7.28.0", + "@typescript-eslint/eslint-plugin": "^7.5.0" }, "publishConfig": { "access": "public" diff --git a/packages/experimental/examples/jsonQueryEngine.ts b/packages/experimental/examples/jsonQueryEngine.ts index 2757e60f60548fd3d1a7747f55e82732f9a2fe05..44dc9cf08fcdb5ae07a31f5e647a1144c5cefaba 100644 --- a/packages/experimental/examples/jsonQueryEngine.ts +++ b/packages/experimental/examples/jsonQueryEngine.ts @@ -111,4 +111,4 @@ async function main() { console.log({ rawResponse }); } -main(); +void main(); diff --git a/packages/experimental/examples/tsconfig.json b/packages/experimental/examples/tsconfig.json new file mode 100644 index 0000000000000000000000000000000000000000..722089b2e539c89c5ae4aef1b248d0aa0ab63345 --- /dev/null +++ b/packages/experimental/examples/tsconfig.json @@ -0,0 +1,22 @@ +{ + "compilerOptions": { + "target": "es2017", + "module": "esnext", + "moduleResolution": "bundler", + "esModuleInterop": true, + "forceConsistentCasingInFileNames": true, + "strict": true, + "skipLibCheck": true, + "outDir": "./lib", + "tsBuildInfoFile": "./lib/.tsbuildinfo", + "incremental": true, + "composite": true + }, + "ts-node": { + "files": true, + "compilerOptions": { + "module": "commonjs" + } + }, + "include": ["./**/*.ts"] +} diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml index 1dbf088e67de17d197d1ee27340c388ad47ef189..8d17742163b947658a9baf488eb14ea9847c62a6 100644 --- a/pnpm-lock.yaml +++ b/pnpm-lock.yaml @@ -489,6 +489,9 @@ importers: packages/eslint-config-custom: dependencies: + '@typescript-eslint/eslint-plugin': + specifier: ^7.5.0 + version: 7.5.0(@typescript-eslint/parser@7.5.0)(eslint@8.57.0)(typescript@5.4.3) eslint-config-next: specifier: ^13.5.6 version: 13.5.6(eslint@8.57.0)(typescript@5.4.3) @@ -4701,7 +4704,6 @@ packages: /@types/semver@7.5.6: resolution: {integrity: sha512-dn1l8LaMea/IjDoHNd9J52uBbInB796CDffS6VdIxvqYCPSG0V0DzHp76GpaWnlhg88uYyPbXCDIowa86ybd5A==} - dev: true /@types/send@0.17.4: resolution: {integrity: sha512-x2EM6TJOybec7c52BX0ZspPodMsQUd5L6PRwOunVyVUhXiBSKf3AezDL8Dgvgt5o0UfKNfuA0eMLr2wLT4AiBA==} @@ -4759,6 +4761,35 @@ packages: dependencies: '@types/yargs-parser': 21.0.3 + /@typescript-eslint/eslint-plugin@7.5.0(@typescript-eslint/parser@7.5.0)(eslint@8.57.0)(typescript@5.4.3): + resolution: {integrity: sha512-HpqNTH8Du34nLxbKgVMGljZMG0rJd2O9ecvr2QLYp+7512ty1j42KnsFwspPXg1Vh8an9YImf6CokUBltisZFQ==} + engines: {node: ^18.18.0 || >=20.0.0} + peerDependencies: + '@typescript-eslint/parser': ^7.0.0 + eslint: ^8.56.0 + typescript: '*' + peerDependenciesMeta: + typescript: + optional: true + dependencies: + '@eslint-community/regexpp': 4.10.0 + '@typescript-eslint/parser': 7.5.0(eslint@8.57.0)(typescript@5.4.3) + '@typescript-eslint/scope-manager': 7.5.0 + '@typescript-eslint/type-utils': 7.5.0(eslint@8.57.0)(typescript@5.4.3) + '@typescript-eslint/utils': 7.5.0(eslint@8.57.0)(typescript@5.4.3) + '@typescript-eslint/visitor-keys': 7.5.0 + debug: 4.3.4 + eslint: 8.57.0 + graphemer: 1.4.0 + ignore: 5.3.1 + natural-compare: 1.4.0 + semver: 7.6.0 + ts-api-utils: 1.0.3(typescript@5.4.3) + typescript: 5.4.3 + transitivePeerDependencies: + - supports-color + dev: false + /@typescript-eslint/parser@6.19.1(eslint@8.57.0)(typescript@5.4.3): resolution: {integrity: sha512-WEfX22ziAh6pRE9jnbkkLGp/4RhTpffr2ZK5bJ18M8mIfA8A+k97U9ZyaXCEJRlmMHh7R9MJZWXp/r73DzINVQ==} engines: {node: ^16.0.0 || >=18.0.0} @@ -4780,6 +4811,27 @@ packages: - supports-color dev: false + /@typescript-eslint/parser@7.5.0(eslint@8.57.0)(typescript@5.4.3): + resolution: {integrity: sha512-cj+XGhNujfD2/wzR1tabNsidnYRaFfEkcULdcIyVBYcXjBvBKOes+mpMBP7hMpOyk+gBcfXsrg4NBGAStQyxjQ==} + engines: {node: ^18.18.0 || >=20.0.0} + peerDependencies: + eslint: ^8.56.0 + typescript: '*' + peerDependenciesMeta: + typescript: + optional: true + dependencies: + '@typescript-eslint/scope-manager': 7.5.0 + '@typescript-eslint/types': 7.5.0 + '@typescript-eslint/typescript-estree': 7.5.0(typescript@5.4.3) + '@typescript-eslint/visitor-keys': 7.5.0 + debug: 4.3.4 + eslint: 8.57.0 + typescript: 5.4.3 + transitivePeerDependencies: + - supports-color + dev: false + /@typescript-eslint/scope-manager@6.19.1: resolution: {integrity: sha512-4CdXYjKf6/6aKNMSly/BP4iCSOpvMmqtDzRtqFyyAae3z5kkqEjKndR5vDHL8rSuMIIWP8u4Mw4VxLyxZW6D5w==} engines: {node: ^16.0.0 || >=18.0.0} @@ -4788,6 +4840,34 @@ packages: '@typescript-eslint/visitor-keys': 6.19.1 dev: false + /@typescript-eslint/scope-manager@7.5.0: + resolution: {integrity: sha512-Z1r7uJY0MDeUlql9XJ6kRVgk/sP11sr3HKXn268HZyqL7i4cEfrdFuSSY/0tUqT37l5zT0tJOsuDP16kio85iA==} + engines: {node: ^18.18.0 || >=20.0.0} + dependencies: + '@typescript-eslint/types': 7.5.0 + '@typescript-eslint/visitor-keys': 7.5.0 + dev: false + + /@typescript-eslint/type-utils@7.5.0(eslint@8.57.0)(typescript@5.4.3): + resolution: {integrity: sha512-A021Rj33+G8mx2Dqh0nMO9GyjjIBK3MqgVgZ2qlKf6CJy51wY/lkkFqq3TqqnH34XyAHUkq27IjlUkWlQRpLHw==} + engines: {node: ^18.18.0 || >=20.0.0} + peerDependencies: + eslint: ^8.56.0 + typescript: '*' + peerDependenciesMeta: + typescript: + optional: true + dependencies: + '@typescript-eslint/typescript-estree': 7.5.0(typescript@5.4.3) + '@typescript-eslint/utils': 7.5.0(eslint@8.57.0)(typescript@5.4.3) + debug: 4.3.4 + eslint: 8.57.0 + ts-api-utils: 1.0.3(typescript@5.4.3) + typescript: 5.4.3 + transitivePeerDependencies: + - supports-color + dev: false + /@typescript-eslint/types@4.33.0: resolution: {integrity: sha512-zKp7CjQzLQImXEpLt2BUw1tvOMPfNoTAfb8l51evhYbOEEzdWyQNmHWWGPR6hwKJDAi+1VXSBmnhL9kyVTTOuQ==} engines: {node: ^8.10.0 || ^10.13.0 || >=11.10.1} @@ -4803,6 +4883,11 @@ packages: engines: {node: ^16.0.0 || >=18.0.0} dev: false + /@typescript-eslint/types@7.5.0: + resolution: {integrity: sha512-tv5B4IHeAdhR7uS4+bf8Ov3k793VEVHd45viRRkehIUZxm0WF82VPiLgHzA/Xl4TGPg1ZD49vfxBKFPecD5/mg==} + engines: {node: ^18.18.0 || >=20.0.0} + dev: false + /@typescript-eslint/typescript-estree@4.33.0(typescript@3.9.10): resolution: {integrity: sha512-rkWRY1MPFzjwnEVHsxGemDzqqddw2QbTJlICPD9p9I9LfsO8fdmfQPOX3uKfUaGRDFJbfrtm/sXhVXN4E+bzCA==} engines: {node: ^10.12.0 || >=12.0.0} @@ -4867,6 +4952,47 @@ packages: - supports-color dev: false + /@typescript-eslint/typescript-estree@7.5.0(typescript@5.4.3): + resolution: {integrity: sha512-YklQQfe0Rv2PZEueLTUffiQGKQneiIEKKnfIqPIOxgM9lKSZFCjT5Ad4VqRKj/U4+kQE3fa8YQpskViL7WjdPQ==} + engines: {node: ^18.18.0 || >=20.0.0} + peerDependencies: + typescript: '*' + peerDependenciesMeta: + typescript: + optional: true + dependencies: + '@typescript-eslint/types': 7.5.0 + '@typescript-eslint/visitor-keys': 7.5.0 + debug: 4.3.4 + globby: 11.1.0 + is-glob: 4.0.3 + minimatch: 9.0.3 + semver: 7.6.0 + ts-api-utils: 1.0.3(typescript@5.4.3) + typescript: 5.4.3 + transitivePeerDependencies: + - supports-color + dev: false + + /@typescript-eslint/utils@7.5.0(eslint@8.57.0)(typescript@5.4.3): + resolution: {integrity: sha512-3vZl9u0R+/FLQcpy2EHyRGNqAS/ofJ3Ji8aebilfJe+fobK8+LbIFmrHciLVDxjDoONmufDcnVSF38KwMEOjzw==} + engines: {node: ^18.18.0 || >=20.0.0} + peerDependencies: + eslint: ^8.56.0 + dependencies: + '@eslint-community/eslint-utils': 4.4.0(eslint@8.57.0) + '@types/json-schema': 7.0.15 + '@types/semver': 7.5.6 + '@typescript-eslint/scope-manager': 7.5.0 + '@typescript-eslint/types': 7.5.0 + '@typescript-eslint/typescript-estree': 7.5.0(typescript@5.4.3) + eslint: 8.57.0 + semver: 7.6.0 + transitivePeerDependencies: + - supports-color + - typescript + dev: false + /@typescript-eslint/visitor-keys@4.33.0: resolution: {integrity: sha512-uqi/2aSz9g2ftcHWf8uLPJA70rUv6yuMW5Bohw+bwcuzaxQIHaKFZCKGoGXIrc9vkTJ3+0txM73K0Hq3d5wgIg==} engines: {node: ^8.10.0 || ^10.13.0 || >=11.10.1} @@ -4891,6 +5017,14 @@ packages: eslint-visitor-keys: 3.4.3 dev: false + /@typescript-eslint/visitor-keys@7.5.0: + resolution: {integrity: sha512-mcuHM/QircmA6O7fy6nn2w/3ditQkj+SgtOc8DW3uQ10Yfj42amm2i+6F2K4YAOPNNTmE6iM1ynM6lrSwdendA==} + engines: {node: ^18.18.0 || >=20.0.0} + dependencies: + '@typescript-eslint/types': 7.5.0 + eslint-visitor-keys: 3.4.3 + dev: false + /@ungap/structured-clone@1.2.0: resolution: {integrity: sha512-zuVdFrMJiuCDQUMCzQaD6KL28MjnqqN8XnAqiEq9PNm/hCPTSGfrXCOfwj1ow4LFb/tNymJPwsNbVePc1xFqrQ==} @@ -7464,7 +7598,7 @@ packages: eslint: 8.57.0 eslint-import-resolver-node: 0.3.9 eslint-import-resolver-typescript: 3.6.1(@typescript-eslint/parser@6.19.1)(eslint-import-resolver-node@0.3.9)(eslint-plugin-import@2.29.1)(eslint@8.57.0) - eslint-plugin-import: 2.29.1(@typescript-eslint/parser@6.19.1)(eslint-import-resolver-typescript@3.6.1)(eslint@8.57.0) + eslint-plugin-import: 2.29.1(@typescript-eslint/parser@7.5.0)(eslint@8.57.0) eslint-plugin-jsx-a11y: 6.8.0(eslint@8.57.0) eslint-plugin-react: 7.33.2(eslint@8.57.0) eslint-plugin-react-hooks: 4.6.0(eslint@8.57.0) @@ -7513,7 +7647,7 @@ packages: enhanced-resolve: 5.15.0 eslint: 8.57.0 eslint-module-utils: 2.8.0(@typescript-eslint/parser@6.19.1)(eslint-import-resolver-node@0.3.9)(eslint-import-resolver-typescript@3.6.1)(eslint@8.57.0) - eslint-plugin-import: 2.29.1(@typescript-eslint/parser@6.19.1)(eslint-import-resolver-typescript@3.6.1)(eslint@8.57.0) + eslint-plugin-import: 2.29.1(@typescript-eslint/parser@7.5.0)(eslint@8.57.0) fast-glob: 3.3.2 get-tsconfig: 4.7.2 is-core-module: 2.13.1 @@ -7555,7 +7689,36 @@ packages: - supports-color dev: false - /eslint-plugin-import@2.29.1(@typescript-eslint/parser@6.19.1)(eslint-import-resolver-typescript@3.6.1)(eslint@8.57.0): + /eslint-module-utils@2.8.0(@typescript-eslint/parser@7.5.0)(eslint-import-resolver-node@0.3.9)(eslint@8.57.0): + resolution: {integrity: sha512-aWajIYfsqCKRDgUfjEXNN/JlrzauMuSEy5sbd7WXbtW3EH6A6MpwEh42c7qD+MqQo9QMJ6fWLAeIJynx0g6OAw==} + engines: {node: '>=4'} + peerDependencies: + '@typescript-eslint/parser': '*' + eslint: '*' + eslint-import-resolver-node: '*' + eslint-import-resolver-typescript: '*' + eslint-import-resolver-webpack: '*' + peerDependenciesMeta: + '@typescript-eslint/parser': + optional: true + eslint: + optional: true + eslint-import-resolver-node: + optional: true + eslint-import-resolver-typescript: + optional: true + eslint-import-resolver-webpack: + optional: true + dependencies: + '@typescript-eslint/parser': 7.5.0(eslint@8.57.0)(typescript@5.4.3) + debug: 3.2.7 + eslint: 8.57.0 + eslint-import-resolver-node: 0.3.9 + transitivePeerDependencies: + - supports-color + dev: false + + /eslint-plugin-import@2.29.1(@typescript-eslint/parser@7.5.0)(eslint@8.57.0): resolution: {integrity: sha512-BbPC0cuExzhiMo4Ff1BTVwHpjjv28C5R+btTOGaCRC7UEz801up0JadwkeSk5Ued6TG34uaczuVuH6qyy5YUxw==} engines: {node: '>=4'} peerDependencies: @@ -7565,7 +7728,7 @@ packages: '@typescript-eslint/parser': optional: true dependencies: - '@typescript-eslint/parser': 6.19.1(eslint@8.57.0)(typescript@5.4.3) + '@typescript-eslint/parser': 7.5.0(eslint@8.57.0)(typescript@5.4.3) array-includes: 3.1.7 array.prototype.findlastindex: 1.2.3 array.prototype.flat: 1.3.2 @@ -7574,7 +7737,7 @@ packages: doctrine: 2.1.0 eslint: 8.57.0 eslint-import-resolver-node: 0.3.9 - eslint-module-utils: 2.8.0(@typescript-eslint/parser@6.19.1)(eslint-import-resolver-node@0.3.9)(eslint-import-resolver-typescript@3.6.1)(eslint@8.57.0) + eslint-module-utils: 2.8.0(@typescript-eslint/parser@7.5.0)(eslint-import-resolver-node@0.3.9)(eslint@8.57.0) hasown: 2.0.0 is-core-module: 2.13.1 is-glob: 4.0.3