summaryrefslogtreecommitdiffhomepage
path: root/packages/console/core/src/util
diff options
context:
space:
mode:
Diffstat (limited to 'packages/console/core/src/util')
-rw-r--r--packages/console/core/src/util/env.cloudflare.ts0
-rw-r--r--packages/console/core/src/util/fn.ts11
-rw-r--r--packages/console/core/src/util/log.ts55
-rw-r--r--packages/console/core/src/util/memo.ts18
-rw-r--r--packages/console/core/src/util/price.ts3
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)
+}