\n \n \n\n \n

delay.val.run

Schedule HTTP requests to be executed in the future

POST https://delay.val.run

\n\n \n

How It Works

Send a POST request

Include the target URL, timing (delay or specific time), and optional request config

We store and schedule it

Your request is saved and queued for execution at the specified time

Request fires automatically

When the time comes, we send the HTTP request to your target URL

\n\n \n

Quick Start

\n \n

Using the TypeScript Client

import { delay } from \"https://esm.town/v/std/delay/client.ts\";\n\n// Delay by 5 minutes\nawait delay.schedule({\n  url: \"https://myapp.com/webhook\",\n  delaySeconds: 300,\n});\n\n// Or schedule for a specific time\nawait delay.schedule({\n  url: \"https://myapp.com/webhook\",\n  method: \"POST\",\n  headers: { \"Authorization\": \"Bearer token\" },\n  body: { orderId: 123 },\n  executeAt: \"2024-12-25T10:00:00Z\",\n});

\n\n

Using fetch directly

await fetch(\"https://delay.val.run\", {\n  method: \"POST\",\n  headers: { \"Content-Type\": \"application/json\" },\n  body: JSON.stringify({\n    url: \"https://myapp.com/webhook\",\n    delaySeconds: 300,\n  }),\n});

\n\n

Using cURL

curl -X POST https://delay.val.run \\\n  -H \"Content-Type: application/json\" \\\n  -d '{\"url\": \"https://myapp.com/webhook\", \"delaySeconds\": 300}'

\n\n \n

API Reference

Send a POST request to https://delay.val.run with a JSON body:

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

Field	Type	Required	Description
`url`	string	Yes	Target URL to send the request to
`method`	string	No	HTTP method (default: \"POST\")
`headers`	object	No	Headers to include in the request
`body`	any	No	Request body (JSON or string)
`delaySeconds`	number	*	Seconds to delay before executing
`executeAt`	string	*	ISO 8601 timestamp to execute at

* Either delaySeconds or executeAt is required (not both)

\n\n

Response

{\n  \"id\": \"550e8400-e29b-41d4-a716-446655440000\",\n  \"scheduledFor\": \"2024-01-15T10:05:00.000Z\",\n  \"status\": \"scheduled\"\n}

\n\n \n

Use Cases

⏰ Delayed Webhooks

Send a notification after a cooldown period

📧 Reminder Systems

Trigger follow-up emails at specific times

🔄 Retry Logic

Schedule a retry attempt after a delay

📅 Scheduled Tasks

Execute API calls at future dates

\n\n \n

Limitations

\n ⚡\n ~1 minute precision: Requests are processed every minute, so execution may be up to 60 seconds after the scheduled time\n

\n 🔁\n No retries: If a request fails, it will not be automatically retried\n

\n ❌\n No cancellation: Once scheduled, requests cannot be cancelled\n

\n 🔓\n No authentication: This is an open service with no API keys\n

\n 🧪\n Experimental: This service may change or become unavailable without notice\n

\n\n \n \n

\n\n\n",2,["D",1767381736409],"branchVersion","label",[18],"pulls","branches",1,"forks","envVars",{"_178":26,"_180":26},"connections",{"_178":26,"_179":26},"count","unfilledCount","emptyCount",{"_34":225,"_13":226,"_63":227,"_44":-5,"_36":37,"_167":228,"_190":102,"_38":229,"_40":26,"_65":21,"_163":230,"_66":24,"_168":-5,"_194":231,"_17":232},{"_34":217,"_13":218,"_63":219,"_44":-5,"_36":37,"_167":220,"_190":102,"_38":221,"_40":26,"_65":202,"_163":222,"_66":24,"_168":-5,"_194":223,"_17":224},{"_34":162,"_13":18,"_63":64,"_44":-5,"_36":37,"_167":81,"_190":102,"_38":214,"_40":165,"_65":21,"_163":164,"_66":24,"_168":-5,"_194":215,"_17":216},{"_34":206,"_13":207,"_63":100,"_44":-5,"_36":37,"_167":87,"_190":102,"_38":208,"_40":209,"_65":210,"_163":211,"_66":24,"_168":14,"_194":212,"_17":213},{"_34":197,"_13":198,"_63":199,"_44":-5,"_36":37,"_167":200,"_190":102,"_38":201,"_40":26,"_65":202,"_163":203,"_66":24,"_168":-5,"_194":204,"_17":205},{"_34":187,"_13":188,"_63":189,"_44":-5,"_36":37,"_167":126,"_190":102,"_38":191,"_40":172,"_65":192,"_163":193,"_66":24,"_168":-5,"_194":195,"_17":196},"93484d30-f4ab-11f0-84f3-42dde27851f2","worker.ts","3800edd6-e80f-11f0-89da-42dde27851f2","latest",["D",1768767819598],"interval","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { type DelayedRequest, rowToRequest } from \"./schema.ts\";\n\nexport default async function () {\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 (\n request.body && ![\"GET\", \"HEAD\"].includes(request.method.toUpperCase())\n ) {\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(\n `Request ${request.id} completed with status ${response.status}`,\n );\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 } 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}","children",[],[188],"24635660-e80f-11f0-89da-42dde27851f2","schema.ts","24635778-e80f-11f0-89da-42dde27851f2",4,["D",1767381218094],"script","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",[],[198],"19316a7e-e810-11f0-b79d-42dde27851f2","main.ts",["D",1767381628815],6,"http","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport {\n initSchema,\n type ScheduleInput,\n type ScheduleResponse,\n} 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 // Serve landing page for GET requests\n if (req.method === \"GET\") {\n const landingPageResponse = await fetch(\n \"https://esm.town/v/std/delay/index.html\",\n );\n const landingPage = await landingPageResponse.text();\n return new Response(landingPage, {\n headers: { \"Content-Type\": \"text/html\" },\n });\n }\n\n // Only accept POST requests for API\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}",[],[207],["D",1767381736409],[],[18],"472471ac-e80f-11f0-89da-42dde27851f2","client.ts","4724726a-e80f-11f0-89da-42dde27851f2",7,["D",1767381276416],"/**\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",[],[218],"7bc87502-e80f-11f0-bda8-42dde27851f2","README.md","7bc875b6-e80f-11f0-bda8-42dde27851f2",9,["D",1767381364732],"# delay.val.run\n\nSchedule HTTP requests to be executed in the future.\n\n> ⚠️ **Experimental Service**: This is a free, experimental service provided as-is with no guarantees. Use with caution.\n\n## Quick Start\n\n### Using the TypeScript Client\n\n```typescript\nimport { delay } from \"https://esm.town/v/std/delay/client.ts\";\n\n// Delay by 5 minutes\nawait delay.schedule({\n url: \"https://myapp.com/webhook\",\n delaySeconds: 300,\n});\n\n// Or schedule for a specific time\nawait delay.schedule({\n url: \"https://myapp.com/webhook\",\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer token\" },\n body: { orderId: 123 },\n executeAt: \"2024-12-25T10:00:00Z\",\n});\n```\n\n### Using fetch\n\n```typescript\nawait fetch(\"https://delay.val.run\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n url: \"https://myapp.com/webhook\",\n delaySeconds: 300,\n }),\n});\n```\n\n### Using cURL\n\n```bash\ncurl -X POST https://delay.val.run \\\n -H \"Content-Type: application/json\" \\\n -d '{\"url\": \"https://myapp.com/webhook\", \"delaySeconds\": 300}'\n```\n\n## API Reference\n\n### POST https://delay.val.run\n\nSchedule a delayed HTTP request.\n\n#### Request Body\n\n| Field | Type | Required | Description |\n|-------|------|----------|-------------|\n| `url` | string | Yes | Target URL to send the request to |\n| `method` | string | No | HTTP method (default: \"POST\") |\n| `headers` | object | No | Headers to include in the request |\n| `body` | any | No | Request body (JSON or string) |\n| `delaySeconds` | number | * | Seconds to delay before executing |\n| `executeAt` | string | * | ISO 8601 timestamp to execute at |\n\n\\* Either `delaySeconds` or `executeAt` is required (not both)\n\n#### Response\n\n```json\n{\n \"id\": \"550e8400-e29b-41d4-a716-446655440000\",\n \"scheduledFor\": \"2024-01-15T10:05:00.000Z\",\n \"status\": \"scheduled\"\n}\n```\n\n## Client Library\n\nThe TypeScript client provides a convenient wrapper around the API.\n\n### Installation\n\n```typescript\nimport { delay } from \"https://esm.town/v/std/delay/client.ts\";\n```\n\n### Methods\n\n#### `delay.schedule(options)`\n\nSchedule a request with full configuration options.\n\n```typescript\nconst result = await delay.schedule({\n url: \"https://api.example.com/webhook\",\n method: \"POST\",\n headers: { \"X-Custom-Header\": \"value\" },\n body: { data: \"payload\" },\n delaySeconds: 60,\n});\n```\n\n#### `delay.delayBy(url, seconds, options?)`\n\nConvenience method to schedule by delay duration.\n\n```typescript\nawait delay.delayBy(\"https://api.example.com/webhook\", 300);\n\n// With additional options\nawait delay.delayBy(\"https://api.example.com/webhook\", 300, {\n method: \"PUT\",\n body: { updated: true },\n});\n```\n\n#### `delay.delayUntil(url, time, options?)`\n\nConvenience method to schedule for a specific time.\n\n```typescript\nawait delay.delayUntil(\"https://api.example.com/webhook\", new Date(\"2024-12-25T10:00:00Z\"));\n\n// Or with an ISO string\nawait delay.delayUntil(\"https://api.example.com/webhook\", \"2024-12-25T10:00:00Z\");\n```\n\n## Limitations\n\n- **~1 minute precision**: Requests are processed every minute\n- **No retries**: Failed requests are not automatically retried\n- **No cancellation**: Scheduled requests cannot be cancelled\n- **No authentication**: This is an open service\n- **Experimental**: Service may change without notice\n\n## Use Cases\n\n- **Delayed webhooks**: Send notifications after a cooldown period\n- **Reminder systems**: Trigger follow-up actions at specific times\n- **Retry logic**: Schedule retry attempts after failures\n- **Scheduled tasks**: Execute API calls at future dates\n\n## License\n\nMIT\n",[],[226],["D",1767380822867],{"_11":12,"_140":136},{"_11":12,"_135":-5,"_69":136,"_30":-5,"_137":138,"_139":24},{"_40":126,"_13":16,"_34":37,"_127":89,"_128":-5,"_129":-5,"_130":-5,"_131":-5,"_132":-5,"_133":14,"_134":12},"ctx",{"_53":-5,"_159":270,"_271":272,"_273":274,"_275":24,"_276":24,"_277":24,"_278":102,"_279":-5,"_280":-7,"_281":-7,"_282":26,"_283":24,"_284":24,"_285":-5,"_286":24,"_287":24,"_288":24,"_289":-5},"ENV",{"_241":242,"_243":244,"_245":16,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269},"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 · index.html