Files
product-import-ai/scripts/start-adminer.ts
T

95 lines
3.2 KiB
TypeScript

import { createWriteStream, existsSync, mkdirSync, readFileSync, writeFileSync } from "node:fs";
import { get } from "node:https";
import { dirname, resolve } from "node:path";
import { spawn, spawnSync } from "node:child_process";
const adminerFile = resolve("tools/adminer/adminer.php");
const localPhp = resolve("tools/php/php.exe");
const host = process.env.ADMINER_HOST || "127.0.0.1";
const port = process.env.ADMINER_PORT || "8080";
const adminerDownloadUrl = process.env.ADMINER_DOWNLOAD_URL || "https://www.adminer.org/latest.php";
const phpCommand = existsSync(localPhp) ? localPhp : "php";
const usesLocalPhp = existsSync(localPhp);
if (!commandExists(phpCommand)) {
console.error("Adminer needs PHP CLI. Install PHP first, then run npm run adminer again.");
process.exit(1);
}
if (usesLocalPhp) {
ensureLocalPhpMysqlExtensions();
}
if (!existsSync(adminerFile)) {
mkdirSync(dirname(adminerFile), { recursive: true });
await downloadFile(adminerDownloadUrl, adminerFile);
}
const child = spawn(phpCommand, ["-S", `${host}:${port}`, adminerFile], {
stdio: "inherit",
shell: true,
});
child.on("exit", (code, signal) => {
if (signal) {
process.kill(process.pid, signal);
return;
}
process.exit(code ?? 0);
});
function commandExists(command: string): boolean {
const result = spawnSync(command, ["-v"], { stdio: "ignore", shell: true });
return result.status === 0;
}
function ensureLocalPhpMysqlExtensions(): void {
const phpDir = dirname(localPhp);
const phpIni = resolve(phpDir, "php.ini");
const template = resolve(phpDir, "php.ini-production");
const source = existsSync(phpIni) ? phpIni : template;
if (!existsSync(source)) {
console.warn("Local PHP is missing php.ini-production; Adminer may not have MariaDB extensions enabled.");
return;
}
let contents = readFileSync(source, "utf8");
contents = ensureIniLine(contents, /^;?\s*extension_dir\s*=.*$/m, 'extension_dir = "ext"');
contents = ensureIniLine(contents, /^;?\s*extension\s*=\s*mysqli\s*$/m, "extension=mysqli");
contents = ensureIniLine(contents, /^;?\s*extension\s*=\s*pdo_mysql\s*$/m, "extension=pdo_mysql");
writeFileSync(phpIni, contents);
}
function ensureIniLine(contents: string, pattern: RegExp, line: string): string {
if (pattern.test(contents)) return contents.replace(pattern, line);
return `${contents.trimEnd()}\n${line}\n`;
}
function downloadFile(url: string, target: string): Promise<void> {
return new Promise((resolveDownload, rejectDownload) => {
const request = get(url, (response) => {
if (response.statusCode && response.statusCode >= 300 && response.statusCode < 400 && response.headers.location) {
downloadFile(response.headers.location, target).then(resolveDownload, rejectDownload);
return;
}
if (response.statusCode !== 200) {
rejectDownload(new Error(`Adminer download failed with HTTP ${response.statusCode}`));
return;
}
const file = createWriteStream(target);
response.pipe(file);
file.on("finish", () => {
file.close();
resolveDownload();
});
file.on("error", rejectDownload);
});
request.on("error", rejectDownload);
});
}