From a34d020bc6b252e842f042d935c7a0e6444460cf Mon Sep 17 00:00:00 2001 From: Dax Raad Date: Sat, 17 May 2025 21:31:42 -0400 Subject: sync --- js/src/util/context.ts | 25 +++++++++++++++++++++++++ js/src/util/log.ts | 27 +++++++++++++++++++++++++++ 2 files changed, 52 insertions(+) create mode 100644 js/src/util/context.ts create mode 100644 js/src/util/log.ts (limited to 'js/src/util') diff --git a/js/src/util/context.ts b/js/src/util/context.ts new file mode 100644 index 000000000..ec686293e --- /dev/null +++ b/js/src/util/context.ts @@ -0,0 +1,25 @@ +import { AsyncLocalStorage } from "node:async_hooks"; + +export namespace Context { + export class NotFound extends Error { + constructor(public readonly name: string) { + super(`No context found for ${name}`); + } + } + + export function create(name: string) { + const storage = new AsyncLocalStorage(); + return { + use() { + const result = storage.getStore(); + if (!result) { + throw new NotFound(name); + } + return result; + }, + provide(value: T, fn: () => R) { + return storage.run(value, fn); + }, + }; + } +} diff --git a/js/src/util/log.ts b/js/src/util/log.ts new file mode 100644 index 000000000..9de4eb495 --- /dev/null +++ b/js/src/util/log.ts @@ -0,0 +1,27 @@ +export namespace Log { + export function create(tags?: Record) { + tags = tags || {}; + + const result = { + info(message?: any, extra?: Record) { + const prefix = Object.entries({ + ...tags, + ...extra, + }) + .map(([key, value]) => `${key}=${value}`) + .join(" "); + console.log(prefix, message); + return result; + }, + tag(key: string, value: string) { + if (tags) tags[key] = value; + return result; + }, + clone() { + return Log.create({ ...tags }); + }, + }; + + return result; + } +} -- cgit v1.2.3