Function createLocalPipe

packages/baseai/src/add/index.ts:236–327

* Asynchronously creates a local pipe configuration file. * * This function performs the following steps: * 1. Retrieves all available pipes. * 2. Slugifies the provided pipe name. * 3. Checks if a pipe with the same name already exists. * 4. If the pipe exists, prompts the user to confirm ove

(pipe: Pipe)

 * @returns {Promise<void>} - A promise that resolves when the pipe is successfully created.
 */
async function createLocalPipe(pipe: Pipe) {
	try {
		const allPipes = await getAvailablePipes();

		const pipeNameSlugified = slugify(pipe.name);

		const hasPipe = allPipes.some(p => p === pipeNameSlugified);

		if (hasPipe) {
			const pipeInfo = await p.group(
				{
					overwrite: () =>
						p.confirm({
							message: `PIPE: ${color.cyan(pipe.name)} already exists. Do you want to overwrite it?`,
							initialValue: false
						})
				},
				{
					onCancel: () => {
						p.cancel('Operation cancelled.');
						process.exit(0);
					}
				}
			);

			if (!pipeInfo.overwrite) {
				p.outro(`Skipped …`);
				return;
			}
		}

		const toolData = await getToolsPipeData(pipe.tools);

		const toolCalls = toolData.map(tool => tool.toolCall);
		const pipeNameCamelCase = camelCase('pipe-' + pipe.name);

		const messages = pipe.messages.map(message => ({
			...(message.name && { name: message.name }),
			role: message.role,
			content: message.content
		}));

		const pipeContent = `import { PipeI } from '@baseai/core';
${toolData.map(tool => tool.importPath).join('\n')}

		const ${pipeNameCamelCase} = (): PipeI => ({
			// Replace with your API key https://langbase.com/docs/api-reference/api-keys
			apiKey: process.env.LANGBASE_API_KEY!,
			name: \`${pipe.name}\`,
			description: \`${pipe.description}\`,
			status: \`${pipe.status}\`,
			model: \`${pipe.model}\`,
			stream: ${pipe.stream},
			json: ${pipe.json},
			store: ${pipe.store},
			moderate: ${pipe.moderate || true},
			top_p: ${pipe.top_p},
			max_tokens: ${pipe.max_tokens},