Function callOpenAI

packages/baseai/src/dev/llms/call-openai.ts:12–39

({
	pipe,
	stream,
	llmApiKey,
	messages,
	paramsTools
}: {
	pipe: Pipe;
	stream: boolean;
	llmApiKey: string;
	messages: Message[];
	paramsTools: PipeTool[] | undefined;
})

import type { PipeTool } from 'types/tools';

export async function callOpenAI({
	pipe,
	stream,
	llmApiKey,
	messages,
	paramsTools
}: {
	pipe: Pipe;
	stream: boolean;
	llmApiKey: string;
	messages: Message[];
	paramsTools: PipeTool[] | undefined;
}) {
	try {
		validateInput(pipe, messages);
		const openai = new OpenAI({ apiKey: llmApiKey });
		await moderateContent(openai, messages, pipe.moderate);

		const modelParams = buildModelParams(pipe, stream, messages);
		addToolsToParams(modelParams, pipe, paramsTools);
		applyJsonModeIfEnabled(modelParams, pipe);

		dlog('modelParams', modelParams);
		return await openai.chat.completions.create(modelParams as any);
	} catch (error: any) {
		handleLlmError({ error, provider: OPEN_AI });
	}
}

function validateInput(pipe: Pipe, messages: Message[]) {
	if (!pipe || !pipe.model || !messages || messages.length === 0) {