Function toOldPipeFormat

packages/baseai/src/utils/to-old-pipe-format.ts:31–88

(newFormat: Pipe)

 * @returns The converted old pipe format.
 */
export function toOldPipeFormat(newFormat: Pipe): PipeOld {
	const [providerString, modelName] = newFormat.model.split(':');

	const systemMessage = newFormat.messages.find(
		m => m.role === 'system' && !m.name
	);
	const safetyMessage = newFormat.messages.find(
		m => m.role === 'system' && m.name === 'safety'
	);
	const ragMessage = newFormat.messages.find(
		m => m.role === 'system' && m.name === 'rag'
	);
	const jsonMessage = newFormat.messages.find(
		m => m.role === 'system' && m.name === 'json'
	);

	return {
		name: newFormat.name,
		description: newFormat.description,
		status: newFormat.status,
		config: {
			meta: {
				stream: newFormat.stream,
				json: newFormat.json,
				store: newFormat.store,
				moderate: newFormat.moderate
			},
			model: {
				name: modelName,
				provider: getProvider(providerString),
				params: {
					top_p: newFormat.top_p,
					max_tokens: newFormat.max_tokens,
					temperature: newFormat.temperature,
					presence_penalty: newFormat.presence_penalty,
					frequency_penalty: newFormat.frequency_penalty,
					stop: newFormat.stop
				},
				tool_choice: newFormat.tool_choice,
				parallel_tool_calls: newFormat.parallel_tool_calls
			},
			prompt: {
				system:
					systemMessage?.content || 'You are a helpful AI assistant.',
				opening: 'Welcome to Langbase. Prompt away!',
				safety: safetyMessage?.content || '',
				messages: newFormat.messages
					.filter(m => m.role !== 'system')
					.map(m => ({ role: m.role, content: m.content ?? '' })),
				variables: newFormat.variables,
				json: jsonMessage?.content || '',
				rag: ragMessage?.content || ''
			},
			tools: newFormat.tools,
			memorysets: newFormat.memory.map(memory => memory.name)
		}
	};
}