📦 NEW: Check if BaseAI dev server is running (#25)

* 👌 IMPROVE: Check if BaseAI dev server is running

* 📦 NEW: Show warning if port in use but server not running

* 📦 NEW: Lock file

* 👌 IMPROVE: Code

* 👌 IMPROVE: Remove dependency

* 👌 IMPROVE: Lock file

* 👌 IMPROVE: Code

* 👌 IMPROVE: Lingo

* 👌 IMPROVE: Code

* 🐛 FIX: Lock file

Author: msaaddev

packages/baseai/src/init/index.ts

@@ -233,7 +233,11 @@ function displayOutro({ calledAsCommand }: { calledAsCommand: boolean }): void {
 	}
 }
 
-async function updateGitignore(gitignoreEntry: string): Promise<void> {
+async function updateGitignore({
+	gitignoreEntry
+}: {
+	gitignoreEntry: string;
+}): Promise<void> {
 	const gitignorePath = path.join(process.cwd(), '.gitignore');
 
 	try {
@@ -355,8 +359,8 @@ export async function init({
 		await createBaseAIDirectories();
 		await createConfigFile();
 		await updatePackageJsonScript();
-		await updateGitignore('# baseai\n**/.baseai/\n');
-		await updateGitignore('# env file\n.env\n');
+		await updateGitignore({ gitignoreEntry: `# baseai\n**/.baseai/\n` });
+		await updateGitignore({ gitignoreEntry: `# env file\n.env\n` });
 		await createEnvBaseAIExample();
 
 		displayOutro({ calledAsCommand });

packages/core/src/common/errors.ts

@@ -108,9 +108,6 @@ export class APIConnectionError extends APIError {
 
 	constructor({message, cause}: {message?: string; cause?: Error}) {
 		super(undefined, undefined, message || 'Connection error.', undefined);
-		console.warn(
-			`\nPlease check if BaseAI dev server is running. If not, run 'npx baseai dev' in the root directory.\n`,
-		);
 		if (cause) (this as Error).cause = cause;
 	}
 }

packages/core/src/pipes/pipes.ts

@@ -4,6 +4,7 @@ import {Request} from '../common/request';
 import {getLLMApiKey} from '../utils/get-llm-api-key';
 import {getApiUrl, isProd} from '../utils/is-prod';
 import {toOldPipeFormat} from '../utils/to-old-pipe-format';
+import {isLocalServerRunning} from 'src/utils/local-server-running';
 
 // Type Definitions
 export type Role = 'user' | 'assistant' | 'system' | 'tool';
@@ -192,6 +193,10 @@ export class Pipe {
 		let response = await this.createRequest<
 			RunResponse | RunResponseStream
 		>(endpoint, body);
+		if (Object.entries(response).length === 0) {
+			return {} as RunResponse | RunResponseStream;
+		}
+
 		console.log('pipe.run.response');
 		console.dir(response, {depth: null, colors: true});
 
@@ -272,7 +277,14 @@ export class Pipe {
 				llmApiKey: getLLMApiKey(this.pipe.model.provider),
 			},
 		};
-		return this.request.post<T>(isProd() ? prodOptions : localOptions);
+
+		const isProdEnv = isProd();
+		if (!isProdEnv) {
+			const isServerRunning = await isLocalServerRunning();
+			if (!isServerRunning) return {} as T;
+		}
+
+		return this.request.post<T>(isProdEnv ? prodOptions : localOptions);
 	}
 }
 

packages/core/src/utils/local-server-running.ts

@@ -0,0 +1,36 @@
+import {getApiUrl} from './is-prod';
+
+export async function isLocalServerRunning(): Promise<Boolean> {
+	try {
+		const endpoint = getApiUrl();
+
+		const response = await fetch(endpoint, {
+			mode: 'no-cors',
+			cache: 'no-cache', // Prevents caching of the request
+		});
+
+		const portUseError = `\nPort 9000 is already in use. \nTerminate the process running on it. \nRun npx baseai@latest dev in an new terminal to start the dev server.\n`;
+
+		if (!response.ok) {
+			console.error(portUseError);
+			return false;
+		}
+
+		const res = (await response.json()) as unknown as {
+			success: boolean;
+		};
+
+		if (!res.success) {
+			console.error(portUseError);
+			return false;
+		}
+
+		return true;
+	} catch (error) {
+		// Port is not in use and BaseAI dev server is not running
+		console.error(
+			`\nBaseAI dev server is not running. \nPlease run npx baseai@latest dev in a new teriminal to start dev server.\n`,
+		);
+		return false;
+	}
+}