[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_181":182,"_183":184},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_105":87,"_27":37,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":25,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":37,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",24,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_34":35,"_36":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","example.ts","latestPath","fileId","89d20942-66b3-11f1-b409-1607ee4eb77e","name","new-file-4176.ts","fileType","script","content","","createdAt",["D",1781305675217],"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",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"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",{"_43":44,"_32":45,"_38":176,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":37,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":177,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":178,"_81":179,"_83":180,"_85":25},"tree",[163,164,165],"files",[163,164,165],"counts",{"_153":60,"_154":151,"_155":60,"_156":157,"_158":159},"contents",[126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":149,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":150,"_13":151,"_34":35,"_36":37,"_24":25,"_139":-5,"_27":152},{"_43":141,"_32":142,"_30":143,"_132":-5,"_41":42,"_40":144,"_134":25,"_38":145,"_13":146,"_34":35,"_36":147,"_24":25,"_139":-5,"_27":148},{"_43":129,"_32":130,"_30":131,"_132":-5,"_41":42,"_40":133,"_134":135,"_38":136,"_13":137,"_34":35,"_36":138,"_24":25,"_139":-5,"_27":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],"2f4834f5-5684-4b08-a01b-6efd11eae231","main.ts","38434cb4-66b1-11f1-a5ae-1607ee4eb77e",22,["D",1781305648286],16,"import { SortedSet } from \"./sorted-set\";\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}",[142],"fdd1e8b2-6bd7-4f87-b50c-1a728372cbd5",["D",1781305675217],1,[28],"pulls","branches","forks","envVars",{"_160":60,"_162":60},"connections",{"_160":60,"_161":60},"count","unfilledCount","emptyCount",{"_43":149,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":173,"_13":151,"_34":35,"_36":37,"_24":25,"_139":-5,"_167":174,"_27":175},{"_43":141,"_32":142,"_30":143,"_132":-5,"_41":42,"_40":144,"_134":25,"_38":170,"_13":146,"_34":35,"_36":147,"_24":25,"_139":-5,"_167":171,"_27":172},{"_43":129,"_32":130,"_30":131,"_132":-5,"_41":42,"_40":133,"_134":135,"_38":166,"_13":137,"_34":35,"_36":138,"_24":25,"_139":-5,"_167":168,"_27":169},["D",1781305142611],"children",[],[130],["D",1781305648286],[],[142],["D",1781305675217],[],[28],["D",1781304676410],["D",1789506649022],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_123":214,"_215":216,"_217":218,"_219":25,"_220":25,"_221":25,"_222":135,"_223":-5,"_224":-7,"_225":-7,"_226":60,"_227":25,"_228":25,"_229":-5,"_230":25,"_231":25,"_232":25,"_233":-5},"ENV",{"_185":186,"_187":188,"_189":87,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213},"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 · v24