📦 NEW: pipe.run node example

Author: msaaddev

examples/nodejs/examples/pipes/pipe.run.stream.ts

@@ -0,0 +1,40 @@
+import 'dotenv/config';
+import {getRunner, Pipe} from 'langbase';
+
+const pipe = new Pipe({
+	apiKey: process.env.LANGBASE_API_KEY!,
+	name: 'summary',
+});
+
+async function main() {
+	const userMsg = 'Who is an AI Engineer?';
+
+	// Get readable stream
+	const {stream, threadId, rawResponse} = await pipe.run({
+		messages: [{role: 'user', content: userMsg}],
+		stream: true,
+		rawResponse: true,
+	});
+
+	// Convert the stream to a stream runner.
+	const runner = getRunner(stream);
+
+	// Method 1: Using event listeners
+	runner.on('connect', () => {
+		console.log('Stream started.\n');
+	});
+
+	runner.on('content', content => {
+		process.stdout.write(content);
+	});
+
+	runner.on('end', () => {
+		console.log('\nStream ended.');
+	});
+
+	runner.on('error', error => {
+		console.error('Error:', error);
+	});
+}
+
+main();

examples/nodejs/examples/pipes/pipe.run.ts

@@ -0,0 +1,24 @@
+import 'dotenv/config';
+import {Pipe} from 'langbase';
+
+const pipe = new Pipe({
+	apiKey: process.env.LANGBASE_API_KEY!,
+	name: 'summary',
+});
+
+async function main() {
+	const userMsg = 'Who is an AI Engineer?';
+
+	const response = await pipe.run({
+		messages: [
+			{
+				role: 'user',
+				content: userMsg,
+			},
+		],
+		stream: false,
+	});
+	console.log('response: ', response);
+}
+
+main();

examples/nodejs/package.json

@@ -7,6 +7,8 @@
 	"main": "index.js",
 	"scripts": {
 		"generate-text": "npx tsx ./examples/pipes/generate-text.ts",
+		"pipe.run": "npx tsx ./examples/pipes/pipe.run.ts",
+		"pipe.run.stream": "npx tsx ./examples/pipes/pipe.run.stream.ts",
 		"generate-text-generate-pipe": "npx tsx ./examples/pipes/generate-text-generate-pipe.ts",
 		"generate-text-chat-pipe": "npx tsx ./examples/pipes/generate-text-chat-pipe.ts",
 		"stream-text": "npx tsx ./examples/pipes/stream-text.ts",