Function upsertPipe

packages/baseai/src/deploy/index.ts:244–273

({ pipe, account }: { pipe: Pipe; account: Account })

}

async function upsertPipe({ pipe, account }: { pipe: Pipe; account: Account }) {
	const { createUrl } = getApiUrls(pipe.name);

	try {
		const createResponse = await fetch(createUrl, {
			method: 'POST',
			headers: {
				'Content-Type': 'application/json',
				Authorization: `Bearer ${account.apiKey}`
			},
			body: JSON.stringify({
				...pipe,
				upsert: true
			})
		});

		if (createResponse.ok) {
			return (await createResponse.json()) as any;
		}

		const errorData = (await createResponse.json()) as ErrorResponse;

		throw new Error(
			`HTTP error! status: ${createResponse.status}, message: ${errorData.error?.message}`
		);
	} catch (error) {
		console.error('Error in createNewPipe:', error);
		throw error;
	}
}

async function updateExistingPipe({
	updateUrl,