Function uploadMissingDocumentsToMemory

packages/baseai/src/deploy/index.ts:809–838

({
	memory,
	prodDocs,
	documents,
	account
}: {
	memory: MemoryI;
	prodDocs: string[];
	documents: MemoryDocumentI[];
	account: Account;
})

}

async function uploadMissingDocumentsToMemory({
	memory,
	prodDocs,
	documents,
	account
}: {
	memory: MemoryI;
	prodDocs: string[];
	documents: MemoryDocumentI[];
	account: Account;
}) {
	p.log.info(
		`Prod has missing documents. Uploading new documents to ${memory.name}.`
	);
	const missingDocs = documents.filter(doc => {
		const isMissing = !prodDocs.includes(doc.name);
		if (!isMissing) {
			p.log.message(`Document "${doc.name}" already exists. Skipping.`);
		}
		return isMissing;
	});

	// wait for 500 ms to avoid rate limiting
	await new Promise(resolve => setTimeout(resolve, 500));
	await uploadDocumentsToMemory({
		documents: missingDocs,
		name: memory.name,
		account
	});
}

export async function listMemoryDocuments({
	account,