[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_189":190,"_191":192},"routes/_app.x.$handle.$name",{"_95":94,"_31":43,"_103":85,"_26":51,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":24,"_117":118,"_119":57,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":51,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":24},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","client.ts","latestPath","fileId","4724726a-e80f-11f0-89da-42dde27851f2","name","fileType","script","content","/**\n * Val Town Delay Service Client\n * \n * Schedule HTTP requests to be executed in the future.\n * \n * @example\n * ```ts\n * import { delay } from \"https://esm.town/v/std/delay/client.ts\";\n * \n * // Delay by seconds\n * await delay.schedule({\n * url: \"https://myapp.com/webhook\",\n * delaySeconds: 300,\n * });\n * \n * // Schedule for a specific time\n * await delay.schedule({\n * url: \"https://myapp.com/webhook\",\n * executeAt: \"2024-12-25T10:00:00Z\",\n * });\n * ```\n */\n\nconst DELAY_SERVICE_URL = \"https://delay.val.run\";\n\nexport interface ScheduleOptions {\n /** The URL to send the request to */\n url: string;\n /** HTTP method (default: \"POST\") */\n method?: \"GET\" | \"POST\" | \"PUT\" | \"PATCH\" | \"DELETE\" | string;\n /** Headers to include in the request */\n headers?: Record;\n /** Request body (will be JSON stringified if object) */\n body?: unknown;\n /** Number of seconds to delay the request */\n delaySeconds?: number;\n /** ISO 8601 timestamp to execute the request at */\n executeAt?: string | Date;\n}\n\nexport interface ScheduleResult {\n /** Unique identifier for the scheduled request */\n id: string;\n /** ISO 8601 timestamp when the request will be executed */\n scheduledFor: string;\n /** Status of the scheduled request */\n status: \"scheduled\";\n}\n\nexport interface DelayError extends Error {\n statusCode: number;\n response: unknown;\n}\n\n/**\n * Schedule an HTTP request to be executed in the future.\n * \n * @param options - The scheduling options\n * @returns Promise resolving to the schedule result\n * @throws {DelayError} If the request fails\n * \n * @example\n * ```ts\n * // Simple delay\n * const result = await schedule({\n * url: \"https://api.example.com/callback\",\n * delaySeconds: 60,\n * });\n * console.log(`Scheduled for: ${result.scheduledFor}`);\n * ```\n */\nexport async function schedule(options: ScheduleOptions): Promise {\n // Convert Date to ISO string if needed\n const executeAt = options.executeAt instanceof Date \n ? options.executeAt.toISOString() \n : options.executeAt;\n\n const response = await fetch(DELAY_SERVICE_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n url: options.url,\n method: options.method,\n headers: options.headers,\n body: options.body,\n delaySeconds: options.delaySeconds,\n executeAt,\n }),\n });\n\n const data = await response.json();\n\n if (!response.ok) {\n const error = new Error(data.error || \"Failed to schedule request\") as DelayError;\n error.statusCode = response.status;\n error.response = data;\n throw error;\n }\n\n return data as ScheduleResult;\n}\n\n/**\n * Schedule a request to be executed after a delay in seconds.\n * Convenience wrapper around `schedule()`.\n * \n * @param url - The URL to send the request to\n * @param delaySeconds - Number of seconds to delay\n * @param options - Additional request options\n * @returns Promise resolving to the schedule result\n * \n * @example\n * ```ts\n * await delayBy(\"https://api.example.com/callback\", 300);\n * ```\n */\nexport async function delayBy(\n url: string, \n delaySeconds: number, \n options?: Omit\n): Promise {\n return schedule({ ...options, url, delaySeconds });\n}\n\n/**\n * Schedule a request to be executed at a specific time.\n * Convenience wrapper around `schedule()`.\n * \n * @param url - The URL to send the request to\n * @param executeAt - When to execute (Date or ISO string)\n * @param options - Additional request options\n * @returns Promise resolving to the schedule result\n * \n * @example\n * ```ts\n * await delayUntil(\"https://api.example.com/callback\", new Date(\"2024-12-25T10:00:00Z\"));\n * ```\n */\nexport async function delayUntil(\n url: string, \n executeAt: Date | string, \n options?: Omit\n): Promise {\n return schedule({ ...options, url, executeAt });\n}\n\n// Default export for convenience\nexport const delay = {\n schedule,\n delayBy,\n delayUntil,\n};\n\nexport default delay;\n","createdAt",["D",1767381276416],"branchVersion","branchId","38ce400c-e80e-11f0-a3c2-42dde27851f2","id","38ce013c-e80e-11f0-a3c2-42dde27851f2","delay",["D",1767380822867],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","38d01a08-e80e-11f0-a3c2-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","c606f87f-4d7e-48c8-9c39-ef5ab94aec49","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":-5,"_99":100,"_101":24},"branch",{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"isOwned",15,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","std","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJVaVhpQ1BId3dscVpBbkdZVWlMNjJtcjkxWS5wbmcifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":185,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":51,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":186,"_79":187,"_81":188,"_83":24},"tree",[168,169,170,171],"files",[168,169,170,171],"counts",{"_157":61,"_158":159,"_160":61,"_161":162,"_163":164},"contents",[124,125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":154,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_133":57,"_36":155,"_13":61,"_32":33,"_34":35,"_23":24,"_137":-5,"_26":156},{"_41":146,"_31":147,"_29":55,"_131":-5,"_39":40,"_38":148,"_133":24,"_36":149,"_13":150,"_32":151,"_34":152,"_23":24,"_137":43,"_26":153},{"_41":139,"_31":140,"_29":141,"_131":-5,"_39":40,"_38":142,"_133":57,"_36":143,"_13":61,"_32":33,"_34":144,"_23":24,"_137":-5,"_26":145},{"_41":128,"_31":129,"_29":130,"_131":-5,"_39":40,"_38":132,"_133":24,"_36":134,"_13":61,"_32":135,"_34":136,"_23":24,"_137":-5,"_26":138},"3800ecfa-e80f-11f0-89da-42dde27851f2","worker.ts","3800edd6-e80f-11f0-89da-42dde27851f2","parentId",6,"latest",["D",1767381251016],"interval","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { initSchema, rowToRequest, type DelayedRequest } from \"./schema.ts\";\n\n// Ensure schema exists on cold start\nlet schemaInitialized = false;\n\nexport default async function() {\n // Initialize schema once per cold start\n if (!schemaInitialized) {\n await initSchema();\n schemaInitialized = true;\n }\n\n const now = new Date().toISOString();\n console.log(`[${now}] Worker running - checking for due requests`);\n\n // Fetch all pending requests that are due\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM delayed_requests \n WHERE status = 'pending' AND scheduled_for <= ?\n ORDER BY scheduled_for ASC\n LIMIT 100\n `,\n args: [now],\n });\n\n if (result.rows.length === 0) {\n console.log(\"No pending requests due\");\n return;\n }\n\n console.log(`Found ${result.rows.length} requests to process`);\n\n // Process each request\n for (const row of result.rows) {\n const request = rowToRequest(result.columns, row);\n await processRequest(request);\n }\n\n console.log(\"Worker completed\");\n}\n\nasync function processRequest(request: DelayedRequest): Promise {\n const executedAt = new Date().toISOString();\n console.log(`Processing request ${request.id} to ${request.url}`);\n\n try {\n // Build fetch options\n const options: RequestInit = {\n method: request.method,\n };\n\n // Add headers if present\n if (request.headers) {\n try {\n options.headers = JSON.parse(request.headers);\n } catch {\n console.error(`Invalid headers JSON for request ${request.id}`);\n }\n }\n\n // Add body if present (and method allows it)\n if (request.body && ![\"GET\", \"HEAD\"].includes(request.method.toUpperCase())) {\n options.body = request.body;\n \n // Set Content-Type if not already set and body looks like JSON\n const headers = (options.headers as Record) || {};\n if (!headers[\"Content-Type\"] && !headers[\"content-type\"]) {\n try {\n JSON.parse(request.body);\n options.headers = { ...headers, \"Content-Type\": \"application/json\" };\n } catch {\n // Not JSON, leave Content-Type unset\n }\n }\n }\n\n // Make the request\n const response = await fetch(request.url, options);\n \n console.log(`Request ${request.id} completed with status ${response.status}`);\n\n // Mark as completed\n await sqlite.execute({\n sql: `\n UPDATE delayed_requests \n SET status = 'completed', executed_at = ?\n WHERE id = ?\n `,\n args: [executedAt, request.id],\n });\n\n } catch (error) {\n const errorMessage = error instanceof Error ? error.message : String(error);\n console.error(`Request ${request.id} failed:`, errorMessage);\n\n // Mark as failed\n await sqlite.execute({\n sql: `\n UPDATE delayed_requests \n SET status = 'failed', executed_at = ?, error = ?\n WHERE id = ?\n `,\n args: [executedAt, errorMessage, request.id],\n });\n }\n}\n","label",[129],"24635660-e80f-11f0-89da-42dde27851f2","schema.ts","24635778-e80f-11f0-89da-42dde27851f2",4,["D",1767381218094],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// Initialize the database schema\nexport async function initSchema() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS delayed_requests (\n id TEXT PRIMARY KEY,\n status TEXT NOT NULL DEFAULT 'pending',\n created_at TEXT NOT NULL,\n scheduled_for TEXT NOT NULL,\n url TEXT NOT NULL,\n method TEXT NOT NULL DEFAULT 'POST',\n headers TEXT,\n body TEXT,\n executed_at TEXT,\n error TEXT\n )\n `);\n\n // Index for efficient worker queries\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_delayed_requests_pending \n ON delayed_requests(status, scheduled_for) \n WHERE status = 'pending'\n `);\n}\n\n// Types\nexport interface DelayedRequest {\n id: string;\n status: \"pending\" | \"completed\" | \"failed\";\n created_at: string;\n scheduled_for: string;\n url: string;\n method: string;\n headers: string | null;\n body: string | null;\n executed_at: string | null;\n error: string | null;\n}\n\nexport interface ScheduleInput {\n url: string;\n method?: string;\n headers?: Record;\n body?: unknown;\n delaySeconds?: number;\n executeAt?: string;\n}\n\nexport interface ScheduleResponse {\n id: string;\n scheduledFor: string;\n status: \"scheduled\";\n}\n\n// Helper to convert row array to object\nexport function rowToRequest(columns: string[], row: unknown[]): DelayedRequest {\n return Object.fromEntries(columns.map((col, i) => [col, row[i]])) as DelayedRequest;\n}\n",[140],"2e86aa98-e80f-11f0-89da-42dde27851f2","main.ts",5,["D",1767381235113],3,"http","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { initSchema, type ScheduleInput, type ScheduleResponse } from \"./schema.ts\";\n\n// Ensure schema exists on cold start\nlet schemaInitialized = false;\n\nexport default async function(req: Request): Promise {\n // Initialize schema once per cold start\n if (!schemaInitialized) {\n await initSchema();\n schemaInitialized = true;\n }\n\n // Only accept POST requests\n if (req.method !== \"POST\") {\n return Response.json(\n { error: \"Method not allowed. Use POST.\" },\n { status: 405 }\n );\n }\n\n // Parse and validate input\n let input: ScheduleInput;\n try {\n input = await req.json();\n } catch {\n return Response.json(\n { error: \"Invalid JSON body\" },\n { status: 400 }\n );\n }\n\n // Validate required fields\n if (!input.url) {\n return Response.json(\n { error: \"Missing required field: url\" },\n { status: 400 }\n );\n }\n\n // Validate URL format\n try {\n new URL(input.url);\n } catch {\n return Response.json(\n { error: \"Invalid URL format\" },\n { status: 400 }\n );\n }\n\n // Validate timing - must have exactly one of delaySeconds or executeAt\n if (!input.delaySeconds && !input.executeAt) {\n return Response.json(\n { error: \"Must provide either delaySeconds or executeAt\" },\n { status: 400 }\n );\n }\n\n if (input.delaySeconds && input.executeAt) {\n return Response.json(\n { error: \"Provide only one of delaySeconds or executeAt, not both\" },\n { status: 400 }\n );\n }\n\n // Validate delaySeconds if provided\n if (input.delaySeconds !== undefined) {\n if (typeof input.delaySeconds !== \"number\" || input.delaySeconds <= 0) {\n return Response.json(\n { error: \"delaySeconds must be a positive number\" },\n { status: 400 }\n );\n }\n }\n\n // Calculate scheduled time\n let scheduledFor: Date;\n if (input.delaySeconds) {\n scheduledFor = new Date(Date.now() + input.delaySeconds * 1000);\n } else {\n scheduledFor = new Date(input.executeAt!);\n if (isNaN(scheduledFor.getTime())) {\n return Response.json(\n { error: \"Invalid executeAt date format. Use ISO 8601 format.\" },\n { status: 400 }\n );\n }\n if (scheduledFor.getTime() <= Date.now()) {\n return Response.json(\n { error: \"executeAt must be in the future\" },\n { status: 400 }\n );\n }\n }\n\n // Generate job ID\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const scheduledForISO = scheduledFor.toISOString();\n\n // Prepare body for storage\n let bodyToStore: string | null = null;\n if (input.body !== undefined) {\n bodyToStore = typeof input.body === \"string\" \n ? input.body \n : JSON.stringify(input.body);\n }\n\n // Insert into database\n try {\n await sqlite.execute({\n sql: `\n INSERT INTO delayed_requests (id, status, created_at, scheduled_for, url, method, headers, body)\n VALUES (?, 'pending', ?, ?, ?, ?, ?, ?)\n `,\n args: [\n id,\n now,\n scheduledForISO,\n input.url,\n input.method || \"POST\",\n input.headers ? JSON.stringify(input.headers) : null,\n bodyToStore,\n ],\n });\n } catch (error) {\n console.error(\"Database error:\", error);\n return Response.json(\n { error: \"Failed to schedule request\" },\n { status: 500 }\n );\n }\n\n const response: ScheduleResponse = {\n id,\n scheduledFor: scheduledForISO,\n status: \"scheduled\",\n };\n\n return Response.json(response, { status: 201 });\n}\n",[147],"472471ac-e80f-11f0-89da-42dde27851f2",["D",1767381276416],[27],"pulls","branches",1,"forks","envVars",{"_165":61,"_167":61},"connections",{"_165":61,"_166":61},"count","unfilledCount","emptyCount",{"_41":154,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_133":57,"_36":182,"_13":61,"_32":33,"_34":35,"_23":24,"_137":-5,"_173":183,"_26":184},{"_41":146,"_31":147,"_29":55,"_131":-5,"_39":40,"_38":148,"_133":24,"_36":179,"_13":150,"_32":151,"_34":152,"_23":24,"_137":43,"_173":180,"_26":181},{"_41":139,"_31":140,"_29":141,"_131":-5,"_39":40,"_38":142,"_133":57,"_36":176,"_13":61,"_32":33,"_34":144,"_23":24,"_137":-5,"_173":177,"_26":178},{"_41":128,"_31":129,"_29":130,"_131":-5,"_39":40,"_38":132,"_133":24,"_36":172,"_13":61,"_32":135,"_34":136,"_23":24,"_137":-5,"_173":174,"_26":175},["D",1767381251016],"children",[],[129],["D",1767381218094],[],[140],["D",1767381235113],[],[147],["D",1767381276416],[],[27],["D",1767380822867],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":-5,"_99":100,"_101":24},{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"ctx",{"_77":-5,"_121":222,"_223":224,"_225":226,"_227":24,"_228":24,"_229":24,"_230":57,"_231":-5,"_232":-7,"_233":-7,"_234":61,"_235":24,"_236":24,"_237":-5,"_238":24,"_239":24,"_240":24,"_241":-5},"ENV",{"_193":194,"_195":196,"_197":85,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221},"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 · v7