Function runBaseServer

packages/baseai/src/dev/index.ts:18–86

()

import { registerV1PipesRun } from './routes/v1/pipes/run';

export async function runBaseServer() {
	const app = new Hono();

	app.use(trimTrailingSlash());
	app.use('*', customCors);
	app.use(prettyJSON());
	app.use(poweredBy());
	app.use(preFlight());
	app.onError((err, c) => {
		return handleError(err, c as unknown as Context<HonoEnv, any, {}>);
	});

	// Routes.
	registerRoot(app);
	registerV1PipesRun(app);

	const port = 9000;

	try {
		p.intro(heading({ text: 'DEV', sub: 'BaseAI dev server' }));

		const server = serve({
			fetch: app.fetch,
			port
		});

		server.on('error', (e: NodeJS.ErrnoException) => {
			if (e.code === 'EADDRINUSE') {
				p.log.error(
					color.red(`Error: Port ${port} is already in use.`)
				);
				p.log.info(
					`Please close the other application using 9000 port. And try again.`
				);

				process.exit(1);
			} else {
				console.error('Unexpected server error:', e);
				process.exit(1);
			}
		});

		server.on('listening', () => {
			outro(
				`BaseAI server running on: ${color.green(`http://localhost:${port}`)}`
			);
			console.log(
				`When needed you can press ${color.cyan('Ctrl + C')} to shut down.`
			);
		});

		// Add immediate shutdown handler using Clack
		process.on('SIGINT', () => {
			const spinner = p.spinner();
			spinner.start('Shutting down server');

			server.close(() => {
				spinner.stop('Shutting down the server …');