📦 NEW: /run endpoint support

Author: msaaddev

packages/langbase/.eslintrc.js

@@ -1,8 +1,15 @@
 module.exports = {
 	root: true,
-	extends: ['@langbase/eslint-config/library.js'],
+	extends: [
+		'@langbase/eslint-config/library.js',
+		'plugin:prettier/recommended', // prettier
+	],
 	parser: '@typescript-eslint/parser',
 	parserOptions: {
 		project: true,
 	},
+	plugins: ['prettier'], // prettier
+	rules: {
+		'prettier/prettier': 'error', // prettier
+	},
 };

packages/langbase/package.json

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

packages/langbase/src/index.ts

@@ -1,2 +1,9 @@
 export {fromReadableStream} from './lib/browser/stream';
 export * from './pipes/pipes';
+export * from '@baseai/core/helpers';
+export type {
+	RunOptions,
+	RunOptionsStream,
+	RunResponse,
+	RunResponseStream,
+} from '@baseai/core';

packages/langbase/src/pipes/pipes.ts

@@ -1,5 +1,12 @@
 import {Request} from '../common/request';
 import {Stream} from '../common/stream';
+import {
+	Pipe as PipeBaseAI,
+	RunOptions,
+	RunOptionsStream,
+	RunResponse,
+	RunResponseStream,
+} from '@baseai/core';
 
 export type Role = 'user' | 'assistant' | 'system' | 'tool';
 
@@ -97,14 +104,36 @@ export interface StreamChunk {
 export interface PipeOptions {
 	apiKey: string;
 	baseUrl?: string;
+	name?: string;
 }
 
 export class Pipe {
 	private request: Request;
+	private pipe: PipeBaseAI;
+	private pipeOptions;
 
 	constructor(options: PipeOptions) {
 		const baseUrl = 'https://api.langbase.com';
 		this.request = new Request({apiKey: options.apiKey, baseUrl});
+		this.pipeOptions = options;
+		this.pipe = new PipeBaseAI({
+			apiKey: options.apiKey, // Langbase API key
+			name: options.name?.trim() || '', // Pipe name
+			prod: true,
+		} as any);
+	}
+
+	public async run(options: RunOptionsStream): Promise<RunResponseStream>;
+	public async run(options: RunOptions): Promise<RunResponse>;
+	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});
 	}
 
 	async generateText(options: GenerateOptions): Promise<GenerateResponse> {