Function getRunThread

packages/baseai/src/dev/utils/thread/get-run-thread.ts:9–50

({
	pipe,
	messages,
	similarChunks,
	variables
}: {
	pipe: Pipe;
	messages: Message[];
	similarChunks: SimilarChunk[] | undefined;
	variables?: VariablesI;
})

import { processMessages } from './process-messages';

export function getRunThread({
	pipe,
	messages,
	similarChunks,
	variables
}: {
	pipe: Pipe;
	messages: Message[];
	similarChunks: SimilarChunk[] | undefined;
	variables?: VariablesI;
}) {
	try {
		const systemPromptMessage = getSystemPromptMessage({
			pipe,
			similarChunks
		});
		const pipeFewShotsMessages = getPipeFewShotsMessages(pipe);

		const messagesThread = [
			// Messages in the pipe
			...systemPromptMessage,
			...pipeFewShotsMessages,
			// Messages sent with the request
			...messages
		];

		const { messages: messagesThreadWithVars } = processMessages({
			pipe,
			messages: messagesThread,
			variables
		});

		return messagesThreadWithVars;
	} catch (error: any) {
		dlog('Error get-run-thread.ts:', error);

		throw new ApiError({
			code: 'INTERNAL_SERVER_ERROR',
			message: `Something unexpected happened. Error generating thread of messages.`
		});
	}
}