Function handleRun

packages/baseai/src/dev/routes/v1/pipes/run.ts:116–150

(c: any)

// Main endpoint handler
const handleRun = async (c: any) => {
	try {
		const body = await c.req.json();

		const llmKey = (body.llmApiKey as string) || '';
		const hiddenChars = new Array(45).fill('*').join('');
		const redactedKey = llmKey.length
			? llmKey.slice(0, 8) + hiddenChars
			: '';

		const logData = { ...body, llmApiKey: redactedKey };
		logger('pipe.request', logData, 'Pipe Request Body');

		const validatedBody = validateRequestBody(body);

		const { pipe, messages, llmApiKey, stream, variables } = validatedBody;
		const model = pipe.model as PipeModelT;

		const rawLlmResponse = await callLLM({
			pipe: {
				...pipe,
				model
			},
			messages,
			llmApiKey,
			stream,
			variables,
			paramsTools: validatedBody.tools
		});

		return processLlmResponse(c, validatedBody, rawLlmResponse);
	} catch (error: unknown) {
		return handleGenerateError(c, error);
	}
};

// Register the endpoint
export const registerV1PipesRun = (app: Hono) => {