[{"_1":2,"_168":-5,"_169":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","d481f3d28ac6dd3f9b89bb10f2a0c9798df3020a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_147":148,"_165":166,"_167":-5},"handle","rozek","name","floatingQuotaTracker","path","main.tsx","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":107,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":-5,"_114":107,"_115":-5,"_116":32,"_14":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":127,"_130":131,"_133":134,"_146":20},"id","92c046be-26d5-11f0-a5b3-569c3dd06744","createdAt",["D",1746135918041],"deletedAt","legacyEnvVars",true,"privacy","public","description","imageUrl","1678d123-c574-4afe-8768-fb0515c072b3","pinnedFileId","pinPreview","screenshotVersion","likeCount","868ff51d-0dea-4fa9-9266-d3e632613c42","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ybjB5SWh3N1NZbElndXIzcnRoT2tlVGFQMFoifQ","org",{"_93":94,"_132":129},"avatar","branch",{"_135":136,"_95":43,"_101":137,"_138":102,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},"version",3,"92c0a046-26d5-11f0-a5b3-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":149,"_95":98,"_150":151,"_152":-5,"_153":137,"_154":136,"_155":107,"_103":156,"_135":157,"_158":159,"_160":161,"_162":20,"_163":-5,"_97":164},"92d34728-26d5-11f0-a5b3-569c3dd06744","fileId","92c2f3d2-26d5-11f0-a5b3-569c3dd06744","parentId","branchId","branchVersion","latest",["D",1738165336857],2,"fileType","script","content","import { sqlite } from 'https://esm.town/v/stevekrouse/sqlite'\nimport {\n expectStringMatching, expectCardinal, expectedCardinal, throwError\n} from 'https://rozek.github.io/javascript-interface-library/dist/javascript-interface-library.esm.js'\n\nexport class floatingQuotaTracker {\n private _Name:string\n\n/**** private constructor ****/\n\n private constructor (Name:string) {\n this._Name = Name\n }\n\n/**** async factory method floatingQuotaTracker.new ****/\n\n static async new (\n Name:string,\n Limit:number = 10, Period:number = 60*1000, Granularity:number = 5*1000\n ): Promise {\n expectStringMatching ('name',Name, /^[a-z_][0-9a-z_]+$/i)\n expectCardinal('usage limit',Limit)\n expectCardinal ('period',Period)\n expectCardinal('granularity',Granularity)\n\n const Tracker = new floatingQuotaTracker(Name)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${Name}_Info (\n UsageLimit INTEGER NOT NULL,\n Period INTEGER NOT NULL,\n Granularity INTEGER NOT NULL\n )\n `)\n\n await sqlite.execute(`\n INSERT INTO ${Name}_Info (UsageLimit, Period, Granularity)\n SELECT ${Limit}, ${Period}, ${Granularity}\n WHERE NOT EXISTS (SELECT 1 FROM ${Name}_Info)\n `)\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${Name}_Log (\n Time INTEGER NOT NULL PRIMARY KEY,\n Usage INTEGER NOT NULL DEFAULT 0\n )\n `)\n return Tracker\n }\n\n/**** async Limit ****/\n\n async Limit ():Promise {\n const QueryResult = await sqlite.execute(\n `SELECT UsageLimit FROM ${this._Name}_Info LIMIT 1`\n )\n return QueryResult.rows[0].UsageLimit\n }\n\n/**** async setLimit ****/\n\n async setLimit (newLimit:number):Promise {\n const Limit = expectedCardinal('Limit',newLimit)\n await sqlite.execute(\n `UPDATE ${this._Name}_Info SET UsageLimit = ?`, [Limit]\n )\n }\n\n/**** async Period ****/\n\n async Period ():Promise {\n const QueryResult = await sqlite.execute(\n `SELECT Period FROM ${this._Name}_Info LIMIT 1`\n )\n return QueryResult.rows[0].Period\n }\n\n/**** async setPeriod ****/\n\n async setPeriod (newPeriod:number):Promise {\n const Period = expectedCardinal('Period',newPeriod)\n await sqlite.execute(\n `UPDATE ${this._Name}_Info SET Period = ?`, [Period]\n )\n }\n\n/**** async Granularity ****/\n\n async Granularity ():Promise {\n const QueryResult = await sqlite.execute(\n `SELECT Granularity FROM ${this._Name}_Info LIMIT 1`\n )\n return QueryResult.rows[0].Granularity\n }\n\n/**** async setGranularity ****/\n\n async setGranularity (newGranularity:number):Promise {\n const Granularity = expectedCardinal('Granularity',newGranularity)\n await sqlite.execute(\n `UPDATE ${this._Name}_Info SET Granularity = ?`, [Granularity]\n )\n }\n\n/**** async reset ****/\n\n async reset ():Promise {\n await sqlite.execute(`DELETE FROM ${this._Name}_Log`)\n }\n\n/**** async Usage ****/\n\n async Usage ():Promise {\n const Period = await this.Period()\n const currentTime = Date.now()\n const QueryResult = await sqlite.execute(`\n SELECT SUM(Usage) as TotalUsage\n FROM ${this._Name}_Log\n WHERE Time > ?\n `, [currentTime - Period])\n return QueryResult.rows[0].TotalUsage || 0\n }\n\n/**** async LimitExceeded ****/\n\n async LimitExceeded ():Promise {\n const Usage = await this.Usage()\n const Limit = await this.Limit()\n return (Usage > Limit)\n }\n\n/**** async increment ****/\n\n async increment ():Promise {\n const currentTime = Date.now()\n const Granularity = await this.Granularity()\n const Period = await this.Period();\n const roundedTime = Math.floor(currentTime / Granularity) * Granularity\n\n await sqlite.execute(`\n INSERT INTO ${this._Name}_Log (Time, Usage)\n VALUES (?, 1)\n ON CONFLICT (Time) DO UPDATE SET Usage = Usage + 1\n `, [roundedTime])\n\n await sqlite.execute(`\n DELETE FROM ${this._Name}_Log\n WHERE Time <= ?\n `, [currentTime - Period])\n }\n\n/**** async incrementIfAllowed ****/\n\n async incrementIfAllowed ():Promise {\n const Usage = await this.Usage()\n const Limit = await this.Limit()\n\n if (Usage >= Limit) {\n throwError('LimitExceeded')\n }\n\n await this.increment()\n }\n\n/**** async TimeToWait ****/\n\n async TimeToWait ():Promise {\n const Usage = await this.Usage()\n const Limit = await this.Limit()\n\n if (Usage < Limit) {\n return 0\n }\n\n const Period = await this.Period()\n const currentTime = Date.now()\n\n const QueryResult = await sqlite.execute(`\n SELECT Time, Usage\n FROM ${this._Name}_Log\n WHERE Time > ?\n ORDER BY Time ASC\n `, [currentTime - Period])\n\n let totalUsage = 0\n let oldestTime = currentTime\n\n for (const row of QueryResult.rows) {\n totalUsage += row.Usage\n if (totalUsage > Limit) {\n oldestTime = row.Time\n break\n }\n }\n\n return Math.max(0, oldestTime + Period - currentTime)\n }\n}\n","deleted","label",[98],"permalink","https://www.val.town/x/rozek/floatingQuotaTracker/code/main.tsx","extension","actionData","errors"]