Function getPipe

packages/baseai/src/add/index.ts:56–103

* Fetches a pipe from Langbase using the provided login and name. * * @param {Object} params - The parameters for fetching the pipe. * @param {string} params.login - The login identifier. * @param {string} params.name - The name of the pipe. * @param {Spinner} params.spinner - The spinner insta

({
	login,
	name,
	spinner
}: {
	login: string;
	name: string;
	spinner: Spinner;
})

 * @returns {Promise<Pipe | null>} - A promise that resolves to the fetched pipe or null if an error occurs.
 */
async function getPipe({
	login,
	name,
	spinner
}: {
	login: string;
	name: string;
	spinner: Spinner;
}) {
	try {
		const account = await retrieveAuthentication({ spinner });
		if (!account) {
			p.log.error(
				'Authentication failed. Please run "npx baseai auth" to authenticate.'
			);
			return;
		}

		spinner.start('Fetching pipe from Langbase');

		const API_URL = `https://api.langbase.com/v1/pipes/${login}/${name}`;

		const createResponse = await fetch(API_URL, {
			method: 'GET',
			headers: {
				'Content-Type': 'application/json',
				...(account && { Authorization: `Bearer ${account.apiKey}` })
			}
		});

		if (createResponse.ok) {
			spinner.stop('Fetched pipe from Langbase');
			return (await createResponse.json()) as Pipe;
		}

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

		if (errorData) {
			spinner.stop(
				`Failed to fetch pipe from Langbase: ${errorData.error?.message}`
			);
			process.exit(1);
		}
	} catch (error: any) {
		spinner.stop(error);
		return null;
	}
}

/**
 * Asynchronously creates local tools based on the provided `Pipe` object.