mirror of
https://github.com/gradio-app/gradio.git
synced 2024-12-15 02:11:15 +08:00
efdc3231a7
* changes * asd * fix tests * fix lint * fix ts * fix ts * cleanup * cleanup * fix * Apply suggestions from code review Co-authored-by: Yuichiro Tachibana (Tsuchiya) <t.yic.yt@gmail.com> * fix * add changeset * fix gitignore * fix changeset * fix lockfile * format * fix * add changeset * githunore * kit bopilerplate * add changeset * fix website * add changeset --------- Co-authored-by: Yuichiro Tachibana (Tsuchiya) <t.yic.yt@gmail.com> Co-authored-by: gradio-pr-bot <gradio-pr-bot@users.noreply.github.com>
62 lines
1.3 KiB
TypeScript
62 lines
1.3 KiB
TypeScript
import { spawn } from "node:child_process";
|
|
|
|
import type { ChildProcess } from "child_process";
|
|
|
|
export function kill_process(process: ChildProcess) {
|
|
process.kill("SIGTERM");
|
|
}
|
|
|
|
type LaunchAppBackgroundReturn = {
|
|
port: number;
|
|
_process: ChildProcess;
|
|
};
|
|
|
|
export const launch_app_background = async (
|
|
command: string,
|
|
cwd?: string
|
|
): Promise<LaunchAppBackgroundReturn> => {
|
|
const _process = spawn(command, {
|
|
shell: true,
|
|
stdio: "pipe",
|
|
cwd: cwd || process.cwd(),
|
|
env: {
|
|
...process.env,
|
|
PYTHONUNBUFFERED: "true"
|
|
}
|
|
});
|
|
|
|
_process.stdout.setEncoding("utf8");
|
|
_process.stderr.setEncoding("utf8");
|
|
|
|
_process.on("exit", () => kill_process(_process));
|
|
_process.on("close", () => kill_process(_process));
|
|
_process.on("disconnect", () => kill_process(_process));
|
|
|
|
let port;
|
|
|
|
function std_out(data: any) {
|
|
const _data: string = data.toString();
|
|
console.log(_data);
|
|
|
|
const portRegExp = /:(\d+)/;
|
|
const match = portRegExp.exec(_data);
|
|
|
|
if (match && match[1] && _data.includes("Running on local URL:")) {
|
|
port = parseInt(match[1], 10);
|
|
}
|
|
}
|
|
|
|
function std_err(data: any) {
|
|
const _data: string = data.toString();
|
|
console.log(_data);
|
|
}
|
|
|
|
_process.stdout.on("data", std_out);
|
|
_process.stderr.on("data", std_err);
|
|
|
|
while (!port) {
|
|
await new Promise((r) => setTimeout(r, 1000));
|
|
}
|
|
return { port: port, _process: _process };
|
|
};
|