diff --git a/src/main.ts b/src/main.ts index 2669446..9884791 100644 --- a/src/main.ts +++ b/src/main.ts @@ -17,6 +17,7 @@ const mapToCone = (path: string) => (embed: EmbedResponse): PineconeRecord 0 ? Promise.all( created.map( path => read(path) @@ -24,13 +25,16 @@ export default async function main(created: string[] = [], updated: string[] = [ .then(mapToCone(path)) ) ).then(create) : resolved - const updating = await Promise.all( + + const updating = Promise.all( updated.map( path => read(path) .then(embed) .then(mapToCone(path)) ) - ).then(res => res.map(update)) + ).then(res => Promise.all(res.map(update))) + const removing = removed.length > 0 ? destroy(removed) : resolved - await Promise.all([creating, ...updating, removing]).catch(logger.error) + + await Promise.all([creating, updating, removing]).catch(console.error) } diff --git a/src/pinecone/index.ts b/src/pinecone/index.ts index f687537..e3f41db 100644 --- a/src/pinecone/index.ts +++ b/src/pinecone/index.ts @@ -7,12 +7,12 @@ export const index = pinecone.index(config.index) export const namespace = index.namespace(config.namespace) -export const create = (data: PineconeRecord[]) => namespace.upsert(data).then(logger.sillier) +export const create = (data: PineconeRecord[]) => namespace.upsert(data) -export const update = (data: PineconeRecord) => namespace.update(data).then(logger.sillier) +export const update = (data: PineconeRecord) => namespace.update(data) export const destroy = (ids: string[]) => ( ids.length === 1 ? namespace.deleteOne(ids[0] as string) : namespace.deleteMany(ids) -).then(logger.sillier) +) export default pinecone \ No newline at end of file