diff options
Diffstat (limited to 'packages/console/core/src/util')
| -rw-r--r-- | packages/console/core/src/util/env.cloudflare.ts | 0 | ||||
| -rw-r--r-- | packages/console/core/src/util/fn.ts | 11 | ||||
| -rw-r--r-- | packages/console/core/src/util/log.ts | 55 | ||||
| -rw-r--r-- | packages/console/core/src/util/memo.ts | 18 | ||||
| -rw-r--r-- | packages/console/core/src/util/price.ts | 3 |
5 files changed, 87 insertions, 0 deletions
diff --git a/packages/console/core/src/util/env.cloudflare.ts b/packages/console/core/src/util/env.cloudflare.ts new file mode 100644 index 000000000..e69de29bb --- /dev/null +++ b/packages/console/core/src/util/env.cloudflare.ts diff --git a/packages/console/core/src/util/fn.ts b/packages/console/core/src/util/fn.ts new file mode 100644 index 000000000..9efe4622f --- /dev/null +++ b/packages/console/core/src/util/fn.ts @@ -0,0 +1,11 @@ +import { z } from "zod" + +export function fn<T extends z.ZodType, Result>(schema: T, cb: (input: z.infer<T>) => Result) { + const result = (input: z.infer<T>) => { + const parsed = schema.parse(input) + return cb(parsed) + } + result.force = (input: z.infer<T>) => cb(input) + result.schema = schema + return result +} diff --git a/packages/console/core/src/util/log.ts b/packages/console/core/src/util/log.ts new file mode 100644 index 000000000..4f2d25c13 --- /dev/null +++ b/packages/console/core/src/util/log.ts @@ -0,0 +1,55 @@ +import { Context } from "../context" + +export namespace Log { + const ctx = Context.create<{ + tags: Record<string, any> + }>() + + export function create(tags?: Record<string, any>) { + tags = tags || {} + + const result = { + info(message?: any, extra?: Record<string, any>) { + const prefix = Object.entries({ + ...use().tags, + ...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 + } + + export function provide<R>(tags: Record<string, any>, cb: () => R) { + const existing = use() + return ctx.provide( + { + tags: { + ...existing.tags, + ...tags, + }, + }, + cb, + ) + } + + function use() { + try { + return ctx.use() + } catch (e) { + return { tags: {} } + } + } +} diff --git a/packages/console/core/src/util/memo.ts b/packages/console/core/src/util/memo.ts new file mode 100644 index 000000000..49043010f --- /dev/null +++ b/packages/console/core/src/util/memo.ts @@ -0,0 +1,18 @@ +export function memo<T>(fn: () => T, cleanup?: (input: T) => Promise<void>) { + let value: T | undefined + let loaded = false + + const result = (): T => { + if (loaded) return value as T + loaded = true + value = fn() + return value as T + } + result.reset = async () => { + if (cleanup && value) await cleanup(value) + loaded = false + value = undefined + } + + return result +} diff --git a/packages/console/core/src/util/price.ts b/packages/console/core/src/util/price.ts new file mode 100644 index 000000000..abdbca032 --- /dev/null +++ b/packages/console/core/src/util/price.ts @@ -0,0 +1,3 @@ +export function centsToMicroCents(amount: number) { + return Math.round(amount * 1000000) +} |
