({
documents,
name,
account
}: {
documents: MemoryDocumentI[];
name: string;
account: Account;
})
| 635 | } |
| 636 | |
| 637 | export async function uploadDocumentsToMemory({ |
| 638 | documents, |
| 639 | name, |
| 640 | account |
| 641 | }: { |
| 642 | documents: MemoryDocumentI[]; |
| 643 | name: string; |
| 644 | account: Account; |
| 645 | }) { |
| 646 | for (const doc of documents) { |
| 647 | try { |
| 648 | p.log.message(`Uploading document: ${doc.name} ....`); |
| 649 | await new Promise(resolve => setTimeout(resolve, 800)); // To avoid rate limiting |
| 650 | const signedUrl = await getSignedUploadUrl({ |
| 651 | documentName: doc.name, |
| 652 | memoryName: name, |
| 653 | account, |
| 654 | meta: doc.meta |
| 655 | }); |
| 656 | |
| 657 | const uploadResponse = await uploadDocument(signedUrl, doc.blob); |
| 658 | dlog(`Upload response status: ${uploadResponse.status}`); |
| 659 | |
| 660 | p.log.message(`Uploaded document: ${doc.name}`); |
| 661 | } catch (error) { |
| 662 | throw error; |
| 663 | } |
| 664 | } |
| 665 | } |
| 666 | |
| 667 | export async function deleteDocumentsFromMemory({ |
| 668 | documents, |
no test coverage detected