From 310d0a7324477079022b178f1a83161e9e61fb1d Mon Sep 17 00:00:00 2001 From: amankumarsingh77 Date: Sat, 2 May 2026 15:31:01 +0530 Subject: feat(util): add result, time, and paths primitives for v0.3 rewrite --- src/util/paths.ts | 9 +++++++++ src/util/result.ts | 15 +++++++++++++++ src/util/time.ts | 29 +++++++++++++++++++++++++++++ 3 files changed, 53 insertions(+) create mode 100644 src/util/paths.ts create mode 100644 src/util/result.ts create mode 100644 src/util/time.ts (limited to 'src/util') diff --git a/src/util/paths.ts b/src/util/paths.ts new file mode 100644 index 0000000..8cd9961 --- /dev/null +++ b/src/util/paths.ts @@ -0,0 +1,9 @@ +import { randomUUID } from "node:crypto"; +import { tmpdir } from "node:os"; +import { join } from "node:path"; + +export const screenshotPath = (namespace: string, ext: "png" | "jpeg" = "png"): string => + join(tmpdir(), `pi-browser-screenshot-${namespace}-${randomUUID()}.${ext}`); + +export const pdfPath = (namespace: string): string => + join(tmpdir(), `pi-browser-pdf-${namespace}-${randomUUID()}.pdf`); diff --git a/src/util/result.ts b/src/util/result.ts new file mode 100644 index 0000000..ca57c2a --- /dev/null +++ b/src/util/result.ts @@ -0,0 +1,15 @@ +export type Result = + | { readonly success: true; readonly data: T } + | { readonly success: false; readonly error: E }; + +export const ok = (data: T): Result => ({ success: true, data }); +export const err = (error: E): Result => ({ success: false, error }); + +export const map = (r: Result, f: (t: T) => U): Result => + r.success ? ok(f(r.data)) : r; + +export const andThen = (r: Result, f: (t: T) => Result): Result => + r.success ? f(r.data) : r; + +export const mapErr = (r: Result, f: (e: E) => F): Result => + r.success ? r : err(f(r.error)); diff --git a/src/util/time.ts b/src/util/time.ts new file mode 100644 index 0000000..73990ad --- /dev/null +++ b/src/util/time.ts @@ -0,0 +1,29 @@ +export const sleep = (ms: number, signal?: AbortSignal): Promise => + new Promise((resolve, reject) => { + if (signal?.aborted) { + reject(new Error("aborted")); + return; + } + const timer = setTimeout(() => { + signal?.removeEventListener("abort", onAbort); + resolve(); + }, ms); + const onAbort = (): void => { + clearTimeout(timer); + reject(new Error("aborted")); + }; + signal?.addEventListener("abort", onAbort, { once: true }); + }); + +export type Deadline = { + readonly remainingMs: () => number; + readonly expired: () => boolean; +}; + +export const deadline = (totalMs: number): Deadline => { + const end = Date.now() + totalMs; + return { + remainingMs: () => Math.max(0, end - Date.now()), + expired: () => Date.now() >= end, + }; +}; -- cgit v1.2.3