deno.land / x / trex@v1.13.1 / commands / run.ts
نووسراو ببینە
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250// deno-lint-ignore-file no-inner-declarations/** * Copyright (c) Crew Dev. * * This source code is licensed under the MIT license found in the * LICENSE file in the root directory of this source tree. */
import { parseToYaml } from "../tools/parse_to_yaml.ts";import { Match } from "../utils/file_resolver.ts";import type { runJson } from "../utils/types.ts";import { exists, readJson } from "tools-fs";import { isGH } from "../utils/storage.ts";import * as colors from "fmt/colors.ts";import { join } from "path/mod.ts";
const { red, yellow, green } = colors;const { env, run } = Deno;
/** * execute subprocess script * @param command */export async function Run(command: string, runArgs: string[] = []) { let prefix = (await exists("./run.json")) ? "json" : "yaml";
if ( !(await exists("./run.json")) && !(await exists("./run.yaml")) && !(await exists("./run.yml")) ) { throw new Error(red(`: ${yellow("run.json or run.yaml not found")}`)) .message; }
if ( (await exists("./run.json")) && ((await exists("./run.yaml")) || (await exists("./run.yml"))) ) { throw new Error( red(`: ${yellow("use a single format run.json or run.yaml file")}`), ).message; } else { async function Thread() { try { const runJsonFile = await Scripts();
if (!runJsonFile?.scripts) { throw new Error( red( `: ${ yellow(`the 'scripts' key not found in run.${prefix} file`) }`, ), ).message; }
const scripts = Object.keys(runJsonFile.scripts);
const toRun = scripts .map((key) => key === command ? runJsonFile.scripts[key] : undefined) .filter((el) => !!el) as string[];
if (!toRun.length) { throw new Error(red(`: ${yellow("command not found")}`)).message; } // normalize command const runnerCommand = toRun[0].split(" ").filter((arg) => !!arg);
// github action fallback deno dir path const ghFallBack = Match(Deno.build.os) .case("darwin", () => "/Users/runner/.deno/bin") .case("linux", () => "/home/runner/.deno/bin") .case("windows", () => "C:\\Users\\runneradmin\\.deno\\bin") .default() .Value() as string;
// get path to deno scripts const scriptPath = isGH ? ghFallBack : Deno.build.os === "windows" // to windows base ? join( "C:", "Users", env.get("USERNAME")!, ".deno", "bin", runnerCommand[0], ) // to unix base : join(env.get("HOME")!, ".deno", "bin", runnerCommand[0]);
// prevent deno scrips not found error if ((await exists(scriptPath)) || (await exists(`${scriptPath}.cmd`))) { if (Deno.build.os === "linux" || Deno.build.os === "darwin") { runnerCommand[0] = scriptPath; } else if (Deno.build.os === "windows") { runnerCommand[0] = `${runnerCommand[0]}.cmd`; } }
const [currentCMD, execCommand] = [ ["trex", "run", command].join(" "), [...runnerCommand] .map((cmd) => cmd?.trim()) .join(" ") .replaceAll(".cmd", ""), ];
const last = execCommand.split("/");
// remove path to compare on unix base os const toCompare = Deno.build.os === "linux" || Deno.build.os === "darwin" ? last[last.length - 1] : execCommand;
// prevent circular call if (currentCMD === toCompare) { throw new EvalError( `${yellow("Circular call found in: ")}${red(toRun[0])}`, ).message; }
const process = run({ cmd: [...runnerCommand, ...runArgs].map((command, index) => command === "deno" && (index === 0 || index === 1) ? ResolveDenoPath() : command ), stderr: "piped", stdout: "inherit", env: env.toObject(), cwd: Deno.cwd(), }); const [status] = await Promise.all([ process.status(), ]);
if (!(await process.status()).success) { Deno.close(process.rid); throw new Error(`Error: running command ${red(toRun[0])}`).message; }
Deno.close(process.rid); } catch (err) { throw new Error( err instanceof SyntaxError ? red( `the ${yellow(`'run.${prefix}'`)} file not have a valid syntax`, ) : err instanceof Deno.errors.NotFound ? red(err.message) : yellow(err.message ?? `${err}`), ).message; } }
const filesToWatch = prefix === "json" ? ((await readJson("./run.json")) as runJson) : await parseToYaml();
const watchFlags = Deno.args[2] === "--watch" || Deno.args[2] === "-w" || Deno.args[2] === "-wv";
// run using trp (trex reboot protocol) if (filesToWatch?.files && watchFlags) { const files = filesToWatch.files.length ? [...filesToWatch.files] : ["."];
let throttle = 700; let timeout: number | null = null;
function logMessages(verbose?: Deno.FsEvent) { console.clear(); console.log(green("[Reboot protocol]")); console.log(green("[*] watching files:")); console.info( red( `[#] exit using ctrl+c \n ${ filesToWatch?.files?.length ? filesToWatch.files .map((file: string) => { console.log(" |- ", yellow(join(file))); return ""; }) .join("") : (console.log( ` |- ${yellow("all files [ .* ]")}`, ) as undefined) ?? "" } `, ), ); if (Deno.args[2] === "-wv" && verbose) { console.log( green(` ╭─ Verbose output ${yellow("-wv")}:\n`), green(`│- Event Kind: ${yellow(verbose?.kind)}\n`), green(`╰─ Path: ${yellow(verbose?.paths.join(""))}\n`), ); } }
logMessages(); await Thread(); for await (const event of Deno.watchFs(files, { recursive: true })) { if (event.kind !== "access") { if (timeout) clearTimeout(timeout); console.log(yellow("reloading...")); logMessages(event); timeout = setTimeout(Thread, throttle); } } } // run a single exec thread else { await Thread(); } }}
/** * return run.json, run.yml .yaml info file */export async function Scripts() { let prefix = (await exists("./run.json")) ? "json" : "yaml"; const runJsonFile = prefix === "json" ? ((await readJson("./run.json")) as runJson) : await parseToYaml();
return runJsonFile;}
/** * resolve deno bin path. */export function ResolveDenoPath() { let fallback = "deno";
switch (Deno.build.os) { case "linux": fallback = `${Deno.env.get("HOME")}/.deno/bin/deno`; break; case "darwin": // TODO(buttercubz) resolve macos path break; case "windows": break; }
return Deno.execPath() ?? fallback;}
trex
Version Info
9 months ago
