Function action

examples/remix/app/routes/api.langbase.pipes.run-stream.ts:5–21

({request})

import {ActionFunction} from '@remix-run/node';

export const action: ActionFunction = async ({request}) => {
	const runOptions = await request.json();

	// 1. Initiate the Pipe.
	const pipe = new Pipe(getPipeSummary());

	// 2. Run the Pipe.
	const {stream, threadId} = await pipe.run(runOptions);

	// 3. Return the ReadableStream directly.
	return new Response(stream, {
		status: 200,
		headers: {
			'lb-thread-id': threadId ?? '',
		},
	});
};