4 files changed, 70 insertions, 0 deletions
diff --git a/u/process/env.ts b/u/process/env.ts
new file mode 100644
index 0000000..e80ec4a
--- /dev/null
+++ b/u/process/env.ts
@@ -0,0 +1,10 @@
+import { Either, type IEither } from "@emprespresso/utils";
+
+export const getRequiredEnv = (name: string): IEither<Error, string> =>
+  Either.fromFailable(() => {
+    const value = Deno.env.get(name); // could throw when no permission.
+    if (!value) {
+      throw new Error(`environment variable "${name}" is required D:`);
+    }
+    return value;
+  });
diff --git a/u/process/mod.ts b/u/process/mod.ts
new file mode 100644
index 0000000..3f02d46
--- /dev/null
+++ b/u/process/mod.ts
@@ -0,0 +1,3 @@
+export * from "./env.ts";
+export * from "./run.ts";
+export * from "./validate_identifier.ts";
diff --git a/u/process/run.ts b/u/process/run.ts
new file mode 100644
index 0000000..6dc37d0
--- /dev/null
+++ b/u/process/run.ts
@@ -0,0 +1,40 @@
+import { Either, type Traceable } from "@emprespresso/utils";
+
+export class ProcessError extends Error {}
+export const getStdout = async (
+  { item: cmd, logger: _logger }: Traceable<string[] | string>,
+  options: Deno.CommandOptions = {},
+): Promise<Either<ProcessError, string>> => {
+  const logger = _logger.addTracer(() => "[getStdout]");
+
+  logger.log(`:> im gonna run this command!`, cmd);
+  const [exec, ...args] = (typeof cmd === "string") ? cmd.split(" ") : cmd;
+  const command = new Deno.Command(exec, {
+    args,
+    stdout: "piped",
+    stderr: "piped",
+    ...options,
+  });
+
+  try {
+    const { code, stdout, stderr } = await command.output();
+    const stdoutText = new TextDecoder().decode(stdout);
+    const stderrText = new TextDecoder().decode(stderr);
+
+    if (code !== 0) {
+      logger.error(`i weceived an exit code of ${code} i wanna zeroooo :<`);
+      return Either.left<ProcessError, string>(
+        new ProcessError(`command failed\n${stderrText}`),
+      );
+    }
+
+    logger.log("yay! i got code 0 :3", cmd);
+    return Either.right<ProcessError, string>(stdoutText);
+  } catch (e) {
+    logger.error(`o.o wat`, e);
+    if (e instanceof Error) {
+      return Either.left<ProcessError, string>(e);
+    }
+    throw new Error("unknown error " + e);
+  }
+};
diff --git a/u/process/validate_identifier.ts b/u/process/validate_identifier.ts
new file mode 100644
index 0000000..ec8b77b
--- /dev/null
+++ b/u/process/validate_identifier.ts
@@ -0,0 +1,17 @@
+import { Either } from "./mod.ts";
+
+export const validateIdentifier = (token: string) => {
+  return (/^[a-zA-Z0-9_\-:. \/]+$/).test(token) && !token.includes("..");
+};
+
+// ensure {@param obj} is a Record<string, string> with stuff that won't
+// have the potential for shell injection, just to be super safe.
+export const validateExecutionEntries = (
+  obj: Record<string, unknown>,
+): Either<Array<[string, unknown]>, Record<string, string>> => {
+  const invalidEntries = Object.entries(obj).filter((e) =>
+    !e.every((x) => typeof x === "string" && validateIdentifier(x))
+  );
+  if (invalidEntries.length > 0) return Either.left(invalidEntries);
+  return Either.right(<Record<string, string>> obj);
+};