File size: 4,605 Bytes
0ad74ed |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 |
import { spawn } from "node:child_process";
import { join, basename } from "path";
import { fileURLToPath } from "url";
import { readdirSync, writeFileSync } from "fs";
import net from "net";
import kl from "kleur";
const __dirname = fileURLToPath(new URL(".", import.meta.url));
const TEST_APP_PATH = join(__dirname, "./test.py");
const TEST_FILES_PATH = join(__dirname, "..", "js", "spa", "test");
const ROOT = join(__dirname, "..");
const test_files = readdirSync(TEST_FILES_PATH)
.filter(
(f) =>
f.endsWith("spec.ts") &&
!f.endsWith(".skip.spec.ts") &&
!f.endsWith(".component.spec.ts") &&
!f.endsWith(".reload.spec.ts")
)
.map((f) => ({
module_name: `${basename(f, ".spec.ts")}.run`,
dir_name: basename(f, ".spec.ts")
}));
export default async function global_setup() {
const verbose = process.env.GRADIO_TEST_VERBOSE;
const port = await find_free_port(7860, 8860);
process.env.GRADIO_E2E_TEST_PORT = port;
process.stdout.write(kl.yellow("\nCreating test gradio app.\n\n"));
const test_cases = [];
// check if there is a testcase file in the same directory as the test file
// if there is, append that to the file
test_files.forEach((value) => {
const test_case_dir = join(ROOT, "demo", value.dir_name);
readdirSync(test_case_dir)
.filter((f) => f.endsWith("_testcase.py"))
.forEach((f) => {
test_cases.push({
module_name: `${value.dir_name}.${basename(f, ".py")}`,
dir_name: `${value.dir_name}_${basename(f, ".py")}`
});
});
});
const all_test_files = test_files.concat(test_cases);
const test_app = make_app(all_test_files, port);
process.stdout.write(kl.yellow("App created. Starting test server.\n\n"));
process.stdout.write(kl.bgBlue(" =========================== \n"));
process.stdout.write(kl.bgBlue(" === PYTHON STARTUP LOGS === \n"));
process.stdout.write(kl.bgBlue(" =========================== \n\n"));
writeFileSync(TEST_APP_PATH, test_app);
const app = await spawn_gradio_app(TEST_APP_PATH, port, verbose);
process.stdout.write(
kl.green(`\n\nServer started. Running tests on port ${port}.\n`)
);
return () => {
process.stdout.write(kl.green(`\nTests complete, cleaning up!\n`));
kill_process(app);
};
}
const INFO_RE = /^INFO:/;
function spawn_gradio_app(app, port, verbose) {
const PORT_RE = new RegExp(`:${port}`);
return new Promise((res, rej) => {
const _process = spawn(`python`, [app], {
shell: true,
stdio: "pipe",
cwd: ROOT,
env: {
...process.env,
PYTHONUNBUFFERED: "true",
GRADIO_ANALYTICS_ENABLED: "False",
GRADIO_IS_E2E_TEST: "1"
}
});
_process.stdout.setEncoding("utf8");
function std_out(data) {
const _data = data.toString();
const is_info = INFO_RE.test(_data);
if (is_info) {
process.stdout.write(kl.yellow(_data));
}
if (!is_info) {
process.stdout.write(`${_data}\n`);
}
if (PORT_RE.test(_data)) {
process.stdout.write(kl.bgBlue("\n =========== END =========== "));
res(_process);
if (!verbose) {
_process.stdout.off("data", std_out);
_process.stderr.off("data", std_out);
}
}
}
_process.stdout.on("data", std_out);
_process.stderr.on("data", std_out);
_process.on("exit", () => kill_process(_process));
_process.on("close", () => kill_process(_process));
_process.on("disconnect", () => kill_process(_process));
});
}
function kill_process(process) {
process.kill("SIGKILL");
}
function make_app(demos, port) {
return `
import uvicorn
from fastapi import FastAPI
import gradio as gr
${demos.map((obj) => `from demo.${obj.module_name} import demo as ${obj.dir_name}`).join("\n")}
app = FastAPI()
${demos
.map(
(obj) =>
`app = gr.mount_gradio_app(app, ${obj.dir_name}, path="/${obj.dir_name}", max_file_size=${
obj.dir_name == "upload_file_limit_test" ? "'15kb'" : "None"
})`
)
.join("\n")}
config = uvicorn.Config(app, port=${port}, log_level="info")
server = uvicorn.Server(config=config)
server.run()`;
}
export async function find_free_port(start_port, end_port) {
for (let port = start_port; port < end_port; port++) {
if (await is_free_port(port)) {
return port;
}
}
throw new Error(
`Could not find free ports: there were not enough ports available.`
);
}
export function is_free_port(port) {
return new Promise((accept, reject) => {
const sock = net.createConnection(port, "127.0.0.1");
sock.once("connect", () => {
sock.end();
accept(false);
});
sock.once("error", (e) => {
sock.destroy();
if (e.code === "ECONNREFUSED") {
accept(true);
} else {
reject(e);
}
});
});
}
|