[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_193":194,"_195":196},"routes/_app.x.$handle.$name",{"_96":95,"_32":44,"_104":86,"_26":36,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":24,"_118":119,"_120":24,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":36,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":24},"version",30,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":29},"file",{"_30":31,"_32":27,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","new-file-6940.ts","latestPath","a.ts","fileId","d4754a90-66b3-11f1-ac89-1607ee4eb77e","name","fileType","script","content","","createdAt",["D",1781305797473],"branchVersion","branchId","8af5eb84-17f4-4e83-baae-3102665e2777","id","406135f2-f7a5-45fb-8689-6654cac915e5","blobalytics",["D",1781304676410],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","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",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":53,"_100":101,"_102":24},"branch",{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"isOwned",33,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","nbbaier","handle","displayName","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":188,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":36,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":189,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":190,"_80":191,"_82":192,"_84":24},"tree",[171,172,173,174],"files",[171,172,173,174],"counts",{"_160":59,"_161":162,"_163":59,"_164":165,"_166":167},"contents",[125,126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":152,"_32":153,"_30":154,"_132":-5,"_40":41,"_39":155,"_134":135,"_37":156,"_13":157,"_33":34,"_35":158,"_23":24,"_139":-5,"_26":159},{"_42":144,"_32":145,"_30":146,"_132":-5,"_40":41,"_39":147,"_134":135,"_37":148,"_13":149,"_33":34,"_35":150,"_23":24,"_139":-5,"_26":151},{"_42":141,"_32":27,"_30":31,"_132":-5,"_40":41,"_39":14,"_134":24,"_37":142,"_13":59,"_33":34,"_35":36,"_23":24,"_139":-5,"_26":143},{"_42":129,"_32":130,"_30":131,"_132":-5,"_40":41,"_39":133,"_134":135,"_37":136,"_13":137,"_33":34,"_35":138,"_23":24,"_139":-5,"_26":140},"0eda2422-1336-4295-955f-4d7b506780cc","sorted-set.ts","450cd3fc-66b1-11f1-9359-1607ee4eb77e","parentId",10,"latest",true,["D",1781305142611],4,"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",[130],"d51e6207-face-4997-a42c-2bc8c94e3001",["D",1781305797473],[27],"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}",[145],"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));",[153],"pulls","branches",1,"forks","envVars",{"_168":59,"_170":59},"connections",{"_168":59,"_169":59},"count","unfilledCount","emptyCount",{"_42":152,"_32":153,"_30":154,"_132":-5,"_40":41,"_39":155,"_134":135,"_37":185,"_13":157,"_33":34,"_35":158,"_23":24,"_139":-5,"_176":186,"_26":187},{"_42":144,"_32":145,"_30":146,"_132":-5,"_40":41,"_39":147,"_134":135,"_37":182,"_13":149,"_33":34,"_35":150,"_23":24,"_139":-5,"_176":183,"_26":184},{"_42":141,"_32":27,"_30":31,"_132":-5,"_40":41,"_39":14,"_134":24,"_37":179,"_13":59,"_33":34,"_35":36,"_23":24,"_139":-5,"_176":180,"_26":181},{"_42":129,"_32":130,"_30":131,"_132":-5,"_40":41,"_39":133,"_134":135,"_37":175,"_13":137,"_33":34,"_35":138,"_23":24,"_139":-5,"_176":177,"_26":178},["D",1781305142611],"children",[],[130],["D",1781305797473],[],[27],["D",1781305725306],[],[145],["D",1781305760720],[],[153],["D",1781304676410],["D",1789506649022],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":53,"_100":101,"_102":24},{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_122":226,"_227":228,"_229":230,"_231":24,"_232":24,"_233":24,"_234":135,"_235":-5,"_236":-7,"_237":-7,"_238":59,"_239":24,"_240":24,"_241":-5,"_242":24,"_243":24,"_244":24,"_245":-5},"ENV",{"_197":198,"_199":200,"_201":86,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225},"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"]

Diff · v30