[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_207":208,"_209":210},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_116":72,"_33":-7,"_117":-5,"_17":118,"_119":120,"_121":122,"_123":124,"_125":126,"_46":-5,"_127":-5,"_128":-5,"_129":24,"_130":131,"_132":24,"_133":-5,"_134":-5,"_135":136},"routes/_app.x.$handle.$name.branch.$branch.history",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5},"handle","nbbaier","name","blobalytics","branchName","main","project",{"_27":64,"_13":14,"_31":65,"_66":-5,"_67":24,"_68":69,"_70":69,"_71":72,"_73":-5,"_25":61,"_74":-5,"_75":24,"_76":-5,"_77":-5,"_78":79,"_34":35,"_80":81,"_82":83,"_84":85,"_86":-5,"_87":88,"_89":88,"_90":91,"_92":91,"_93":91,"_94":88,"_95":88,"_44":96,"_97":98,"_99":100,"_101":24},"page",1,"history",[26],"hasNext",false,"userId",{"_27":28,"_29":30,"_31":32,"_33":20,"_34":35,"_36":-5,"_37":-5,"_38":-5,"_39":-5,"_40":-5,"_41":-5,"_42":-5,"_43":-5,"_44":45,"_46":47,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53},"id","273dbbda-cc86-44ee-a0f2-5fc220809615","branchId","8af5eb84-17f4-4e83-baae-3102665e2777","createdAt",["D",1781304676423],"version","orgId","5f80108f-7ca4-4327-b77b-089dbe4b5a82","parentId","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_27":61,"_34":35,"_11":12,"_62":63},"file",{"_55":56,"_13":57,"_58":59,"_60":24},"pull","merge","revert","multiple","commits",[54],{"_27":28,"_29":30,"_31":32,"_33":20,"_34":35,"_36":-5,"_37":-5,"_38":-5,"_39":-5,"_40":-5,"_41":-5,"_42":-5,"_43":-5,"_44":45,"_46":47,"_48":-5,"_49":-5,"_50":-5},"fileId","38434cb4-66b1-11f1-a5ae-1607ee4eb77e","main.ts","fileType","script","deleted","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","406135f2-f7a5-45fb-8689-6654cac915e5",["D",1781304676410],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"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",{"_11":12,"_115":63},"org",{"_11":12,"_111":-5,"_62":63,"_25":61,"_112":113,"_114":24},"branch",{"_33":102,"_13":16,"_27":30,"_103":64,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":14,"_110":12},"isOwned",33,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","tier","pro","canRestrictVals","profileImageUrl","path","adoptOrgId",{"_27":64,"_13":14,"_31":202,"_66":-5,"_67":24,"_68":69,"_70":69,"_71":72,"_73":-5,"_25":61,"_74":-5,"_75":24,"_76":-5,"_77":-5,"_78":79,"_34":35,"_80":81,"_82":83,"_84":203,"_86":-5,"_87":88,"_89":88,"_90":91,"_92":91,"_93":91,"_94":88,"_95":88,"_44":204,"_97":205,"_99":206,"_101":24},"tree",[185,186,187,188],"files",[185,186,187,188],"counts",{"_175":79,"_176":20,"_177":79,"_178":179,"_180":181},"contents",[137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_27":168,"_13":169,"_55":170,"_36":-5,"_29":30,"_144":102,"_146":147,"_31":171,"_33":172,"_58":59,"_150":173,"_60":24,"_152":-5,"_116":174},{"_27":160,"_13":161,"_55":162,"_36":-5,"_29":30,"_144":163,"_146":147,"_31":164,"_33":165,"_58":59,"_150":166,"_60":24,"_152":-5,"_116":167},{"_27":154,"_13":57,"_55":56,"_36":-5,"_29":30,"_144":155,"_146":147,"_31":156,"_33":157,"_58":59,"_150":158,"_60":24,"_152":-5,"_116":159},{"_27":141,"_13":142,"_55":143,"_36":-5,"_29":30,"_144":145,"_146":147,"_31":148,"_33":149,"_58":59,"_150":151,"_60":24,"_152":-5,"_116":153},"0eda2422-1336-4295-955f-4d7b506780cc","sorted-set.ts","450cd3fc-66b1-11f1-9359-1607ee4eb77e","branchVersion",10,"latest",true,["D",1781305142611],4,"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}","label",[142],"cc1d622d-f44c-4166-86c2-2d70d429870c",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}",[57],"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));",[161],"a7b2a4f6-063f-4e02-9630-fb9a41984aa7","a.ts","d4754a90-66b3-11f1-ac89-1607ee4eb77e",["D",1781305847566],3,"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconsole.log(await blob.getJSON(\"example:pageviews:1781305740000\"));",[169],"pulls","branches","forks","envVars",{"_182":79,"_184":79},"connections",{"_182":79,"_183":79},"count","unfilledCount","emptyCount",{"_27":168,"_13":169,"_55":170,"_36":-5,"_29":30,"_144":102,"_146":147,"_31":199,"_33":172,"_58":59,"_150":173,"_60":24,"_152":-5,"_190":200,"_116":201},{"_27":160,"_13":161,"_55":162,"_36":-5,"_29":30,"_144":163,"_146":147,"_31":196,"_33":165,"_58":59,"_150":166,"_60":24,"_152":-5,"_190":197,"_116":198},{"_27":154,"_13":57,"_55":56,"_36":-5,"_29":30,"_144":155,"_146":147,"_31":193,"_33":157,"_58":59,"_150":158,"_60":24,"_152":-5,"_190":194,"_116":195},{"_27":141,"_13":142,"_55":143,"_36":-5,"_29":30,"_144":145,"_146":147,"_31":189,"_33":149,"_58":59,"_150":151,"_60":24,"_152":-5,"_190":191,"_116":192},["D",1781305142611],"children",[],[142],["D",1781305725306],[],[57],["D",1781305760720],[],[161],["D",1781305847566],[],[169],["D",1781304676410],["D",1789506649022],{"_11":12,"_115":63},{"_11":12,"_111":-5,"_62":63,"_25":61,"_112":113,"_114":24},{"_33":102,"_13":16,"_27":30,"_103":64,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":14,"_110":12},"ctx",{"_44":-5,"_134":240,"_241":242,"_243":244,"_245":24,"_246":24,"_247":24,"_248":147,"_249":-5,"_250":-7,"_251":-7,"_252":79,"_253":24,"_254":24,"_255":-5,"_256":24,"_257":24,"_258":24,"_259":-5},"ENV",{"_211":212,"_213":214,"_215":16,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239},"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"]

History