👌 IMPROVE: Pipe run

Author: msaaddev

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

@@ -3,7 +3,6 @@ import {getRunner, Pipe} from 'langbase';
 
 const pipe = new Pipe({
 	apiKey: process.env.LANGBASE_API_KEY!,
-	name: 'summary',
 });
 
 async function main() {
@@ -14,6 +13,7 @@ async function main() {
 		messages: [{role: 'user', content: userMsg}],
 		stream: true,
 		rawResponse: true,
+		name: 'summary',
 	});
 
 	// Convert the stream to a stream runner.

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

@@ -3,7 +3,6 @@ import {Pipe} from 'langbase';
 
 const pipe = new Pipe({
 	apiKey: process.env.LANGBASE_API_KEY!,
-	name: 'summary',
 });
 
 async function main() {
@@ -16,6 +15,8 @@ async function main() {
 				content: userMsg,
 			},
 		],
+		stream: false,
+		name: 'summary'
 	});
 	console.log('response: ', response);
 }

packages/langbase/package.json

@@ -29,7 +29,7 @@
 		"test:ui:react:watch": "vitest --config vitest.ui.react.config.js"
 	},
 	"dependencies": {
-		"@baseai/core": "0.9.30",
+		"@baseai/core": "0.9.33",
 		"dotenv": "^16.4.5",
 		"openai": "^4.53.0",
 		"zod": "^3.23.8",

packages/langbase/src/pipes/pipes.ts

@@ -2,14 +2,22 @@ import {Request} from '../common/request';
 import {Stream} from '../common/stream';
 import {
 	Pipe as PipeBaseAI,
-	RunOptions,
-	RunOptionsStream,
+	RunOptions as RunOptionsT,
+	RunOptionsStream as RunOptionsStreamT,
 	RunResponse,
 	RunResponseStream,
 } from '@baseai/core';
 
 export type Role = 'user' | 'assistant' | 'system' | 'tool';
 
+export interface RunOptions extends RunOptionsT {
+	name: string;
+}
+
+export interface RunOptionsStream extends RunOptionsStreamT {
+	name: string;
+}
+
 export interface Function {
 	name: string;
 	arguments: string;
@@ -174,11 +182,13 @@ export interface PipeListResponse {
 					description?: string;
 					parameters?: Record<string, any>;
 				};
-		}[]
+		  }[]
+		| [];
+	memory:
+		| {
+				name: string;
+		  }[]
 		| [];
-	memory: {
-		name: string;
-	}[] | [];
 }
 
 interface PipeBaseResponse {
@@ -221,11 +231,6 @@ export class Pipe {
 	public async run(
 		options: RunOptions | RunOptionsStream,
 	): Promise<RunResponse | RunResponseStream> {
-		if (!this.pipeOptions.name) {
-			throw new Error(
-				'Pipe name is required with run. Please provide pipe name when creating Pipe instance.',
-			);
-		}
 		return await this.pipe.run({...options, runTools: false});
 	}