Function upsertMemory

packages/baseai/src/deploy/index.ts:526–635

({
	memory,
	documents,
	account,
	overwrite,
	isGitSync = false,
	docsToDelete = []
}: {
	memory: MemoryI;
	documents: MemoryDocumentI[];
	account: Account;
	overwrite: boolean;
	isGitSync?: boolean;
	docsToDelete?: string[];
})

}

export async function upsertMemory({
	memory,
	documents,
	account,
	overwrite,
	isGitSync = false,
	docsToDelete = []
}: {
	memory: MemoryI;
	documents: MemoryDocumentI[];
	account: Account;
	overwrite: boolean;
	isGitSync?: boolean;
	docsToDelete?: string[];
}): Promise<void> {
	const { createMemory } = getMemoryApiUrls({
		memoryName: memory.name
	});

	try {
		await new Promise(resolve => setTimeout(resolve, 800)); // To avoid rate limiting
		const createResponse = await fetch(createMemory, {
			method: 'POST',
			headers: {
				'Content-Type': 'application/json',
				Authorization: `Bearer ${account.apiKey}`
			},
			body: JSON.stringify(memory)
		});

		if (!createResponse.ok) {
			const errorData = (await createResponse.json()) as ErrorResponse;

			// If memory already exists, handle it.
			if (errorData.error?.message.includes('already exists')) {
				if (!isGitSync) {
					// Show that Memory already exists
					p.log.info(
						`Memory "${memory.name}" already exists in production.`
					);
					await handleExistingMemoryDeploy({
						memory,
						account,
						documents,
						overwrite
					});
					return;
				}

				// If Git-sync memory, update the existing memory
				if (isGitSync) {
					p.log.info(
						`Memory "${memory.name}" already exists. Updating changed documents.`
					);
					await handleGitSyncMemoryDeploy({
						memory,
						account,
						documents,