👌 IMPROVE: Example updates

Author: ahmadawais

examples/everything/.env.example

@@ -0,0 +1,4 @@
+# These env vars should always be used on the server side and can be called anything.
+PIPE_LESS_WORDY=""
+LANGBASE_SDK_GENERATE_PIPE=""
+LANGBASE_SDK_CHAT_PIPE=""

examples/everything/index.ts

@@ -0,0 +1,36 @@
+/**
+ * Generates a text completion using `generateText()`
+ *
+ * @docs: https://langbase.com/docs/langbase-sdk/generate-text
+ */
+
+import 'dotenv/config';
+import {Pipe} from 'langbase';
+
+(async () => {
+	console.log('\n============= CHAT PIPE =============');
+
+	//  Initiate the Pipe.
+	const myPipe = new Pipe({
+		apiKey: process.env.LANGBASE_SDK_CHAT_PIPE!,
+	});
+
+	// Message 1: Tell the AI about something.
+	const userMsg1 = 'My company is ⌘ Langbase.';
+	let {completion, threadId} = await myPipe.generateText({
+		messages: [{role: 'user', content: userMsg1}],
+		chat: true,
+	});
+	console.log(`User: `, userMsg1);
+	console.log(`AI: `, completion);
+
+	// Message 2: Ask the AI about what you told in previous message.
+	const userMsg2 = 'What is the name of my company?';
+	const {completion: completion2} = await myPipe.generateText({
+		messages: [{role: 'user', content: userMsg2}],
+		threadId,
+		chat: true,
+	});
+	console.log(`User: `, userMsg2);
+	console.log(`AI: `, completion2);
+})();

examples/everything/package.json

@@ -0,0 +1,23 @@
+/**
+ * Generates a text completion using `generateText()`
+ *
+ * @docs: https://langbase.com/docs/langbase-sdk/generate-text
+ */
+
+import 'dotenv/config';
+import {Pipe} from 'langbase';
+
+(async () => {
+	console.log('\n============= GENERATE PIPE =============');
+
+	//  Initiate the Pipe.
+	const myPipe = new Pipe({
+		apiKey: process.env.LANGBASE_SDK_GENERATE_PIPE!,
+	});
+
+	// Generate the text by asking a question.
+	let {completion} = await myPipe.generateText({
+		messages: [{role: 'user', content: 'Who is an AI Engineer?'}],
+	});
+	console.log(completion);
+})();

examples/node/.env.example

@@ -8,14 +8,14 @@ import 'dotenv/config';
 import {Pipe} from 'langbase';
 
 // 1. Initiate the Pipe.
-const pipe = new Pipe({
-	apiKey: process.env.PIPE_LESS_WORDY!,
+const myPipe = new Pipe({
+	apiKey: process.env.LANGBASE_SDK_GENERATE_PIPE!,
 });
 
 // 3. Generate the text by asking a question.
-const result = await pipe.generateText({
+const {completion} = await myPipe.generateText({
 	messages: [{role: 'user', content: 'Who is an AI Engineer?'}],
 });
 
 // 4. Done: You got the generated completion.
-console.log(result.completion);
+console.log(completion);

examples/everything/.gitignore examples/node/.gitignoreexamples/everything/.gitignore renamed to examples/node/.gitignore

@@ -0,0 +1,61 @@
+/**
+ * Generates a text completion using `streamText()`
+ *
+ * @docs: https://langbase.com/docs/langbase-sdk/stream-text
+ */
+import 'dotenv/config';
+import type {StreamText} from 'langbase';
+import {Pipe, printStreamToStdout} from 'langbase';
+
+// Helper function to print the stream.
+// You can write your own — or use printStreamToStdout() from the SDK.
+const helperPrintStream = async (stream: StreamText) => {
+	for await (const chunk of stream) {
+		// Streaming text part — a single word or several.
+		const textPart = chunk.choices[0]?.delta?.content || '';
+
+		// Demo: Print the stream — you can use it however.
+		process.stdout.write(textPart);
+	}
+};
+
+// Helper function to print the chat.
+const printChat = async ({
+	userMessage,
+	stream,
+}: {
+	userMessage: string;
+	stream: StreamText;
+}) => {
+	console.log(`\n`);
+	console.log(`User: `, userMessage);
+	console.log(`AI: `);
+	await printStreamToStdout(stream);
+};
+
+(async () => {
+	console.log('\n\n============= CHAT PIPE =============');
+
+	//  Initiate the Pipe.
+	const myPipe = new Pipe({
+		apiKey: process.env.LANGBASE_SDK_CHAT_PIPE!,
+	});
+
+	// Message 1: Tell the AI about something.
+	const userMsg1 = 'My company is ⌘ Langbase.';
+	let {stream, threadId} = await myPipe.streamText({
+		messages: [{role: 'user', content: userMsg1}],
+		chat: true,
+	});
+
+	await printChat({userMessage: userMsg1, stream});
+
+	// Message 2: Ask the AI about what you told in previous message.
+	const userMsg2 = 'What is the name of my company?';
+	const {stream: stream2} = await myPipe.streamText({
+		messages: [{role: 'user', content: userMsg2}],
+		threadId,
+		chat: true,
+	});
+	await printChat({userMessage: userMsg2, stream: stream2});
+})();