Function createPipe

packages/baseai/src/pipe/index.ts:28–189

()

const multiselectHelper = `${dimItalic(`(optional)`)} \n${dimItalic(`${lineItem} Press ${cyan(`space`)} to select, ${cyan(`enter`)} to submit or skip`)}`;

export async function createPipe() {
	const tools = await getAvailableTools();
	const memories = await getAvailableMemories();
	const hasTools = tools.length > 0;
	const hasMemories = memories.length > 0;

	p.intro(heading({ text: 'PIPE', sub: 'Create a new agent pipe' }));

	const pipeInfo = await p.group(
		{
			name: () =>
				p.text({
					message: 'Name of the pipe',
					placeholder: 'ai-agent-pipe',
					validate: value => {
						const result = pipeNameSchema.safeParse(value);
						if (!result.success) {
							return result.error.issues[0].message;
						}
						return;
					}
				}),
			description: () =>
				p.text({
					message: 'Description of the pipe',
					placeholder: 'This is a test pipe'
				}),
			status: () =>
				p.select({
					message: 'Status of the pipe',
					options: [
						{ value: 'public', label: 'Public' },
						{ value: 'private', label: 'Private' }
					]
				}) as Promise<PipeStatus>,
			systemPrompt: () =>
				p.text({
					message: 'System prompt',
					placeholder: 'You are a helpful AI assistant.',
					initialValue: 'You are a helpful AI assistant.'
				}),
			...(hasMemories && {
				memory: async () =>
					p.multiselect({
						message: `Select memory for this pipe ${multiselectHelper}`,
						options: memories.map(memoryName => ({
							value: memoryName,
							label: memoryName
						})),
						required: false
					})
			}),
			...(hasTools && {
				tools: async () =>
					p.multiselect({
						message: `Select tools for this pipe ${multiselectHelper}`,
						options: tools.map(tool => ({
							value: tool,