[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_210":211,"_212":213},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_157":-5,"_20":158,"_22":159,"_160":161,"_162":163,"_25":164,"_24":-5,"_165":-5,"_166":-5,"_167":56,"_168":169,"_170":56,"_171":-5,"_172":-5,"_173":174},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","nbbaier","name","blobalytics","branchName","main","version","path","","project",{"_36":100,"_13":14,"_48":101,"_102":-5,"_103":56,"_104":105,"_106":105,"_107":19,"_108":-5,"_109":110,"_111":-5,"_112":56,"_113":-5,"_114":-5,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_135":136,"_137":138,"_139":140,"_141":56},"tree",[83,84,85,86],"file","contents",[32,33,34,35],"upstream","pull","ahead","behind","envVars",{"_36":75,"_13":76,"_39":77,"_41":-5,"_42":43,"_44":78,"_46":47,"_48":79,"_17":80,"_51":52,"_53":81,"_55":56,"_57":-5,"_18":82},{"_36":67,"_13":68,"_39":69,"_41":-5,"_42":43,"_44":70,"_46":47,"_48":71,"_17":72,"_51":52,"_53":73,"_55":56,"_57":-5,"_18":74},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":62,"_46":47,"_48":63,"_17":64,"_51":52,"_53":65,"_55":56,"_57":-5,"_18":66},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":49,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_18":58},"id","0eda2422-1336-4295-955f-4d7b506780cc","sorted-set.ts","fileId","450cd3fc-66b1-11f1-9359-1607ee4eb77e","parentId","branchId","8af5eb84-17f4-4e83-baae-3102665e2777","branchVersion",10,"latest",true,"createdAt",["D",1781305142611],4,"fileType","script","content","type Entry = { score: number; member: string };\n\nfunction compareEntries(a: Entry, b: Entry): number {\n if (a.score !== b.score) {\n return a.score - b.score;\n }\n return a.member < b.member ? -1 : a.member > b.member ? 1 : 0;\n}\n\nexport class SortedSet {\n private entries: Entry[] = [];\n private index = new Map();\n\n zadd(...items: [score: number, member: string][]): number {\n let added = 0;\n\n for (const [score, member] of items) {\n const existingIndex = this.index.get(member);\n\n if (existingIndex !== undefined) {\n const entry = this.entries[existingIndex];\n if (!entry || entry.score === score) {\n continue;\n }\n\n this.entries.splice(existingIndex, 1);\n this.rebuildIndexFrom(existingIndex);\n this.insert({ score, member });\n continue;\n }\n\n this.insert({ score, member });\n added++;\n }\n\n return added;\n }\n\n zrem(...members: string[]): number {\n let removed = 0;\n\n for (const member of members) {\n const index = this.index.get(member);\n if (index === undefined) {\n continue;\n }\n\n this.entries.splice(index, 1);\n this.rebuildIndexFrom(index);\n removed++;\n }\n\n return removed;\n }\n\n zscore(member: string): number | null {\n const index = this.index.get(member);\n if (index === undefined) {\n return null;\n }\n return this.entries[index]?.score ?? null;\n }\n\n zrank(member: string): number | null {\n const index = this.index.get(member);\n return index === undefined ? null : index;\n }\n\n zrevrank(member: string): number | null {\n const index = this.index.get(member);\n return index === undefined ? null : this.entries.length - 1 - index;\n }\n\n zcard(): number {\n return this.entries.length;\n }\n\n zcount(min: number, max: number): number {\n return this.zrangebyscore(min, max).length;\n }\n\n zincrby(increment: number, member: string): number {\n const score = this.zscore(member);\n const nextScore = (score ?? 0) + increment;\n this.zadd([nextScore, member]);\n return nextScore;\n }\n\n zrange(start: number, stop: number, withScores?: false): string[];\n zrange(\n start: number,\n stop: number,\n withScores: true,\n ): [member: string, score: number][];\n zrange(\n start: number,\n stop: number,\n withScores = false,\n ): string[] | [member: string, score: number][] {\n const slice = this.sliceByRank(start, stop);\n if (!withScores) {\n return slice.map((entry) => entry.member);\n }\n return slice.map((entry): [string, number] => [entry.member, entry.score]);\n }\n\n zrevrange(start: number, stop: number, withScores?: false): string[];\n zrevrange(\n start: number,\n stop: number,\n withScores: true,\n ): [member: string, score: number][];\n zrevrange(\n start: number,\n stop: number,\n withScores = false,\n ): string[] | [member: string, score: number][] {\n const length = this.entries.length;\n if (length === 0) {\n return [];\n }\n\n const normalizedStart = this.normalizeRank(start, length);\n const normalizedStop = this.normalizeRank(stop, length);\n const slice = this.entries\n .slice()\n .reverse()\n .slice(normalizedStart, normalizedStop + 1);\n\n if (!withScores) {\n return slice.map((entry) => entry.member);\n }\n return slice.map((entry): [string, number] => [entry.member, entry.score]);\n }\n\n zrangebyscore(min: number, max: number, withScores?: false): string[];\n zrangebyscore(\n min: number,\n max: number,\n withScores: true,\n ): [member: string, score: number][];\n zrangebyscore(\n min: number,\n max: number,\n withScores = false,\n ): string[] | [member: string, score: number][] {\n const matches = this.entries.filter(\n (entry) => entry.score >= min && entry.score <= max,\n );\n\n if (!withScores) {\n return matches.map((entry) => entry.member);\n }\n return matches.map((entry): [string, number] => [\n entry.member,\n entry.score,\n ]);\n }\n\n toJSON(): [score: number, member: string][] {\n return this.entries.map((entry) => [entry.score, entry.member]);\n }\n\n static fromJSON(data: [score: number, member: string][]): SortedSet {\n const set = new SortedSet();\n set.zadd(...data);\n return set;\n }\n\n static zunion(...sets: SortedSet[]): SortedSet {\n const merged = new SortedSet();\n\n for (const set of sets) {\n for (const [score, member] of set.toJSON()) {\n merged.zincrby(score, member);\n }\n }\n\n return merged;\n }\n\n private insert(entry: Entry): void {\n const insertAt = this.findInsertIndex(entry);\n this.entries.splice(insertAt, 0, entry);\n this.rebuildIndexFrom(insertAt);\n }\n\n private findInsertIndex(entry: Entry): number {\n let low = 0;\n let high = this.entries.length;\n\n while (low < high) {\n const mid = (low + high) >>> 1;\n const current = this.entries[mid];\n if (!current || compareEntries(current, entry) < 0) {\n low = mid + 1;\n } else {\n high = mid;\n }\n }\n\n return low;\n }\n\n private sliceByRank(start: number, stop: number): Entry[] {\n const length = this.entries.length;\n if (length === 0) {\n return [];\n }\n\n const normalizedStart = this.normalizeRank(start, length);\n const normalizedStop = this.normalizeRank(stop, length);\n\n if (normalizedStart > normalizedStop) {\n return [];\n }\n\n return this.entries.slice(normalizedStart, normalizedStop + 1);\n }\n\n private normalizeRank(rank: number, length: number): number {\n if (rank < 0) {\n return Math.max(length + rank, 0);\n }\n return Math.min(rank, length - 1);\n }\n\n private rebuildIndexFrom(start: number): void {\n for (let i = start; i < this.entries.length; i++) {\n const entry = this.entries[i];\n if (entry) {\n this.index.set(entry.member, i);\n }\n }\n }\n}","deleted",false,"label",[38],"cc1d622d-f44c-4166-86c2-2d70d429870c","main.ts","38434cb4-66b1-11f1-a5ae-1607ee4eb77e",27,["D",1781305725306],17,"import { SortedSet } from \"./sorted-set.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nexport type Event = {\n time?: number;\n [key: string]: string | number | boolean | undefined;\n};\n\nexport type Window = `${number}${\"s\" | \"m\" | \"h\" | \"d\"}`;\n\nexport type AnalyticsConfig = {\n window: Window | number;\n prefix?: string;\n};\n\ninterface AggregateTime {\n time: number;\n}\n\ninterface AggregateGeneric {\n [someFieldName: string]: {\n [someFieldValue: string]: number;\n };\n}\n\nexport type Aggregate = AggregateTime & AggregateGeneric;\n\nexport type RawSuccessResponse = 1 | null;\nexport type SuccessResponse = RawSuccessResponse | string;\n\nexport class Analytics {\n private readonly prefix: string;\n private readonly bucketSize: number;\n\n constructor(config: AnalyticsConfig) {\n this.prefix = config.prefix ?? \"logs\";\n this.bucketSize = this.parseWindow(config.window);\n }\n\n private parseWindow(window: Window | number): number {\n if (typeof window === \"number\") {\n if (window <= 0) {\n throw new Error(`Invalid window: ${window}`);\n }\n return window;\n }\n const regex = /^(\\d+)([smhd])$/;\n if (!regex.test(window)) {\n throw new Error(`Invalid window: ${window}`);\n }\n const [, valueStr, unit] = window.match(regex) ?? [];\n const value = Number.parseInt(valueStr ?? \"0\", 10);\n switch (unit) {\n case \"s\":\n return value * 1000;\n case \"m\":\n return value * 1000 * 60;\n case \"h\":\n return value * 1000 * 60 * 60;\n case \"d\":\n return value * 1000 * 60 * 60 * 24;\n default:\n throw new Error(`Invalid window unit: ${unit}`);\n }\n }\n\n private validateTableName(table: string) {\n const regex = /^[a-zA-Z0-9_-]+$/;\n if (!regex.test(table)) {\n throw new Error(\n `Invalid table name: ${table}. Table names can only contain letters, numbers, dashes and underscores.`,\n );\n }\n }\n\n public getBucket(time?: number): number {\n const bucketTime = time ?? Date.now();\n return Math.floor(bucketTime / this.bucketSize) * this.bucketSize;\n }\n\n private bucketKey(table: string, bucket: number): string {\n return [this.prefix, table, bucket].join(\":\");\n }\n\n private eventMember(event: Event): string {\n return JSON.stringify({\n ...event,\n time: undefined,\n });\n }\n\n private async loadBucket(key: string): Promise {\n const data = await blob.getJSON<[number, string][]>(key);\n if (data === undefined) {\n return new SortedSet();\n }\n return SortedSet.fromJSON(data);\n }\n\n private async saveBucket(key: string, set: SortedSet): Promise {\n await blob.setJSON(key, set.toJSON());\n }\n\n private async loadMergedBuckets(\n table: string,\n timestamp: number | undefined,\n timestampCount: number,\n ): Promise {\n let bucket = this.getBucket(timestamp);\n const sets: SortedSet[] = [];\n\n for (let i = 0; i < timestampCount; i++) {\n sets.push(await this.loadBucket(this.bucketKey(table, bucket)));\n bucket -= this.bucketSize;\n }\n\n return SortedSet.zunion(...sets);\n }\n\n public async ingest(table: string, ...events: Event[]): Promise {\n this.validateTableName(table);\n\n const byBucket = new Map();\n for (const event of events) {\n const bucket = this.getBucket(event.time);\n const bucketEvents = byBucket.get(bucket);\n if (bucketEvents) {\n bucketEvents.push(event);\n continue;\n }\n byBucket.set(bucket, [event]);\n }\n\n await Promise.all(\n [...byBucket.entries()].map(async ([bucket, bucketEvents]) => {\n const key = this.bucketKey(table, bucket);\n const set = await this.loadBucket(key);\n\n for (const event of bucketEvents) {\n set.zincrby(1, this.eventMember(event));\n }\n\n await this.saveBucket(key, set);\n }),\n );\n }\n\n public async query(\n table: string,\n bucket?: number,\n start = 0,\n stop = -1,\n ): Promise {\n this.validateTableName(table);\n const resolvedBucket = bucket ?? this.getBucket();\n const set = await this.loadBucket(this.bucketKey(table, resolvedBucket));\n return set.zrange(start, stop).map((member) => JSON.parse(member) as Event);\n }\n}",[60],"5ff5d718-4b24-4cb2-bf8d-2a429398d326","example.ts","89d20942-66b3-11f1-b409-1607ee4eb77e",29,["D",1781305760720],5,"import { Analytics } from \"./main.ts\";\n\nconst analytics = new Analytics({\n window: \"30s\",\n prefix: \"example\",\n});\n\nconst now = Date.now();\nconst bucket = analytics.getBucket(now);\n\nconsole.log(\"Bucket for now:\", bucket);\n\nawait analytics.ingest(\n \"pageviews\",\n { userId: \"alice\", page: \"/\", country: \"US\" },\n { userId: \"bob\", page: \"/pricing\", country: \"DE\" },\n { userId: \"alice\", page: \"/\", country: \"US\" },\n { userId: \"carol\", page: \"/docs\", country: \"US\", time: now - 1000 },\n);\n\n// await analytics.ingest(\n// \"ratelimit\",\n// { identifier: \"alice@example.com\", success: true },\n// { identifier: \"alice@example.com\", success: true },\n// { identifier: \"alice@example.com\", success: false },\n// { identifier: \"bob@example.com\", success: true },\n// { identifier: \"eve@example.com\", success: \"denied\" },\n// { identifier: \"eve@example.com\", success: \"denied\" },\n// { identifier: \"eve@example.com\", success: \"denied\" },\n// );\n\n// console.log(\"\\n--- query (current bucket) ---\");\n// console.log(await analytics.query(\"pageviews\"));\n\n// console.log(\"\\n--- query (explicit bucket) ---\");\n// console.log(await analytics.query(\"pageviews\", bucket));\n\n// console.log(\"\\n--- aggregateBucket (pageviews by country) ---\");\n// console.log(await analytics.aggregateBucket(\"pageviews\", \"country\", now));\n\n// console.log(\"\\n--- aggregateBuckets (last 3 hours by page) ---\");\n// console.log(await analytics.aggregateBuckets(\"pageviews\", \"page\", 3, now));\n\n// console.log(\"\\n--- aggregateBucketsWithPipeline ---\");\n// console.log(\n// await analytics.aggregateBucketsWithPipeline(\n// \"pageviews\",\n// \"country\",\n// 3,\n// now,\n// 2,\n// ),\n// );\n\n// console.log(\"\\n--- getAllowedBlocked ---\");\n// console.log(await analytics.getAllowedBlocked(\"ratelimit\", 1, now));\n\n// console.log(\"\\n--- getMostAllowedBlocked ---\");\n// console.log(await analytics.getMostAllowedBlocked(\"ratelimit\", 1, 3, now));",[68],"a7b2a4f6-063f-4e02-9630-fb9a41984aa7","a.ts","d4754a90-66b3-11f1-ac89-1607ee4eb77e",33,["D",1781305847566],3,"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconsole.log(await blob.getJSON(\"example:pageviews:1781305740000\"));",[76],{"_36":75,"_13":76,"_39":77,"_41":-5,"_42":43,"_44":78,"_46":47,"_48":97,"_17":80,"_51":52,"_53":81,"_55":56,"_57":-5,"_88":98,"_18":99},{"_36":67,"_13":68,"_39":69,"_41":-5,"_42":43,"_44":70,"_46":47,"_48":94,"_17":72,"_51":52,"_53":73,"_55":56,"_57":-5,"_88":95,"_18":96},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":62,"_46":47,"_48":91,"_17":64,"_51":52,"_53":65,"_55":56,"_57":-5,"_88":92,"_18":93},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":87,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_88":89,"_18":90},["D",1781305142611],"children",[],[38],["D",1781305725306],[],[60],["D",1781305760720],[],[68],["D",1781305847566],[],[76],"406135f2-f7a5-45fb-8689-6654cac915e5",["D",1781304676410],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","5f80108f-7ca4-4327-b77b-089dbe4b5a82","tursoName","406135f2f7a545fb86896654cac915e5","tursoHostname","406135f2f7a545fb86896654cac915e5-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789506649022],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_156":152},"org",{"_11":12,"_150":-5,"_151":152,"_109":110,"_153":154,"_155":56},"branch",{"_17":78,"_13":16,"_36":43,"_142":100,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":14,"_149":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","tier","pro","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":100,"_13":14,"_48":205,"_102":-5,"_103":56,"_104":105,"_106":105,"_107":19,"_108":-5,"_109":110,"_111":-5,"_112":56,"_113":-5,"_114":-5,"_115":116,"_117":118,"_119":120,"_121":122,"_123":206,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_135":207,"_137":208,"_139":209,"_141":56},[193,194,195,196],"files",[193,194,195,196],"counts",{"_183":116,"_184":185,"_186":116,"_31":187,"_188":189},[175,176,177,178],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_36":75,"_13":76,"_39":77,"_41":-5,"_42":43,"_44":78,"_46":47,"_48":79,"_17":80,"_51":52,"_53":81,"_55":56,"_57":-5,"_18":182},{"_36":67,"_13":68,"_39":69,"_41":-5,"_42":43,"_44":70,"_46":47,"_48":71,"_17":72,"_51":52,"_53":73,"_55":56,"_57":-5,"_18":181},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":62,"_46":47,"_48":63,"_17":64,"_51":52,"_53":65,"_55":56,"_57":-5,"_18":180},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":49,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_18":179},[38],[60],[68],[76],"pulls","branches",1,"forks",{"_190":116,"_192":116},"connections",{"_190":116,"_191":116},"count","unfilledCount","emptyCount",{"_36":75,"_13":76,"_39":77,"_41":-5,"_42":43,"_44":78,"_46":47,"_48":97,"_17":80,"_51":52,"_53":81,"_55":56,"_57":-5,"_88":203,"_18":204},{"_36":67,"_13":68,"_39":69,"_41":-5,"_42":43,"_44":70,"_46":47,"_48":94,"_17":72,"_51":52,"_53":73,"_55":56,"_57":-5,"_88":201,"_18":202},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":62,"_46":47,"_48":91,"_17":64,"_51":52,"_53":65,"_55":56,"_57":-5,"_88":199,"_18":200},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":87,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_88":197,"_18":198},[],[38],[],[60],[],[68],[],[76],["D",1781304676410],["D",1789506649022],{"_11":12,"_156":152},{"_11":12,"_150":-5,"_151":152,"_109":110,"_153":154,"_155":56},{"_17":78,"_13":16,"_36":43,"_142":100,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":14,"_149":12},"ctx",{"_135":-5,"_172":243,"_244":245,"_246":247,"_248":56,"_249":56,"_250":56,"_251":47,"_252":-5,"_253":-7,"_254":-7,"_255":116,"_256":56,"_257":56,"_258":-5,"_259":56,"_260":56,"_261":56,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":16,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Code