\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",[],[186],{"_105":194,"_96":100,"_157":117,"_159":-5,"_160":142,"_161":102,"_163":22,"_107":195,"_101":196,"_165":197,"_167":198,"_169":22,"_170":97,"_171":199,"_99":200},"97a6f776-e80f-11f0-bda8-42dde27851f2",["D",1767381411486],5,"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 // Serve landing page for GET requests\n if (req.method === \"GET\") {\n const landingPageResponse = await fetch(\"https://esm.town/v/std/delay/index.html\");\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}\n",[],[100],{"_105":202,"_96":203,"_157":204,"_159":-5,"_160":142,"_161":205,"_163":119,"_107":206,"_101":32,"_165":180,"_167":207,"_169":22,"_170":-5,"_171":208,"_99":209},"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",[],[203],{"_105":211,"_96":212,"_157":213,"_159":-5,"_160":142,"_161":214,"_163":119,"_107":215,"_101":32,"_165":216,"_167":217,"_169":22,"_170":-5,"_171":218,"_99":219},"3800ecfa-e80f-11f0-89da-42dde27851f2","worker.ts","3800edd6-e80f-11f0-89da-42dde27851f2",6,["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",[],[212],"files",[154,174,184,193,201,210],"counts",{"_224":32,"_225":226,"_227":32,"_228":229},"pulls","branches",1,"forks","envVars",{"_230":32,"_231":32},"count","emptyCount","contents",[],{"_105":194,"_160":142,"_157":117,"_96":100,"_167":198,"_165":197,"_101":196,"_159":-5,"_107":235,"_161":102,"_170":97,"_99":236},["D",1767381411486],[100],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_94":95,"_96":97,"_98":44,"_101":102,"_99":100,"_103":245,"_152":250,"_220":269,"_166":270,"_232":273,"_274":-5,"_275":-5,"_276":-5,"_277":-5,"_278":279,"_228":-5},{"_105":106,"_96":97,"_107":246,"_109":-5,"_110":22,"_111":112,"_113":73,"_114":73,"_14":115,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":32,"_16":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":247,"_136":248,"_139":249,"_151":22},["D",1767380822867],{"_94":95,"_134":135},{"_94":95,"_138":135,"_14":-5},{"_101":141,"_96":44,"_105":142,"_143":106,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":-5,"_149":97,"_150":95},[251,254,257,260,263,266],{"_105":155,"_96":156,"_157":158,"_159":-5,"_160":142,"_161":162,"_163":119,"_107":164,"_101":32,"_165":166,"_167":168,"_169":22,"_170":-5,"_171":252,"_99":253},[],[156],{"_105":175,"_96":176,"_157":177,"_159":-5,"_160":142,"_161":178,"_163":119,"_107":179,"_101":32,"_165":180,"_167":181,"_169":22,"_170":-5,"_171":255,"_99":256},[],[176],{"_105":185,"_96":186,"_157":187,"_159":-5,"_160":142,"_161":188,"_163":22,"_107":189,"_101":32,"_165":166,"_167":190,"_169":22,"_170":-5,"_171":258,"_99":259},[],[186],{"_105":194,"_96":100,"_157":117,"_159":-5,"_160":142,"_161":102,"_163":22,"_107":195,"_101":196,"_165":197,"_167":198,"_169":22,"_170":97,"_171":261,"_99":262},[],[100],{"_105":202,"_96":203,"_157":204,"_159":-5,"_160":142,"_161":205,"_163":119,"_107":206,"_101":32,"_165":180,"_167":207,"_169":22,"_170":-5,"_171":264,"_99":265},[],[203],{"_105":211,"_96":212,"_157":213,"_159":-5,"_160":142,"_161":214,"_163":119,"_107":215,"_101":32,"_165":216,"_167":217,"_169":22,"_170":-5,"_171":267,"_99":268},[],[212],[251,254,257,260,263,266],{"_105":194,"_160":142,"_157":117,"_96":100,"_167":198,"_165":197,"_101":196,"_159":-5,"_107":271,"_161":102,"_170":97,"_99":272},["D",1767381411486],[100],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]