\n Showing jobs {startIdx + 1}-{Math.min(endIdx, jobs.length)} of {jobs.length}\n

\n\n

\n \n \n \n {columns.map(column => (\n \n requestSort(column.key)}\n className=\"w-full flex items-center justify-between hover:bg-gray-800 group\"\n >\n {column.label}\n \n \n \n ))}\n \n \n \n {sortedJobs.slice(startIdx, endIdx).map(job => (\n onSelectJob(job)}\n className=\"hover:bg-gray-800 cursor-pointer border-b border-gray-700 last:border-b-0\"\n >\n \n \n \n \n \n {job.error || \"-\"}\n \n \n {job.result || \"-\"}\n \n \n \n ))}\n \n

{job.id}	{job.type}	\n {job.status}\n	\n {job.args}\n	\n {Math.floor(job.runtime / 60)}m {job.runtime % 60}s\n

\n\n

\n onPageChange(currentPage - 1)}\n disabled={currentPage === 0}\n className=\"px-3 py-1 disabled:opacity-50 disabled:cursor-not-allowed hover:bg-gray-800\"\n >\n ◀\n \n \n Page {currentPage + 1} of {Math.ceil(jobs.length / itemsPerPage)}\n \n onPageChange(currentPage + 1)}\n disabled={currentPage >= Math.ceil(jobs.length / itemsPerPage) - 1}\n className=\"px-3 py-1 disabled:opacity-50 disabled:cursor-not-allowed hover:bg-gray-800\"\n >\n ▶\n \n

\n );\n};\n\nconst JobDetail = ({ job, onClose }) => {\n if (!job) return null;\n\n return (\n

\n Job Details: {job.id}\n \n

\n{`STATUS    : ${job.status}\nTYPE      : ${job.type}\nRUNTIME   : ${Math.floor(job.runtime / 60)}m ${job.runtime % 60}s\nCREATED   : ${new Date(job.created).toLocaleString()}\nARGS      : ${job.args}\n${job.error ? `ERROR     : ${job.error}` : ''}\n${job.result ? `RESULT    : ${job.result}` : ''}\n\nLOGS:\n${job.status === 'FAILED' ?\n  `[ERROR] Task execution failed: ${job.error}\\n[ERROR] Retry attempt 1/3 failed\\n[ERROR] Job terminated with exit code 1` :\n  job.status === 'COMPLETED' ?\n  `[INFO] Task initialized successfully\\n[INFO] Processing batch data\\n[INFO] ${job.result}` :\n  `[INFO] Task initialized successfully\\n[INFO] Processing batch data\\n[INFO] In progress...`\n}`}\n

\n );\n};\n\nconst QueueInterface = () => {\n const [currentPage, setCurrentPage] = useState(0);\n const [selectedJob, setSelectedJob] = useState(null);\n const itemsPerPage = 10;\n\n return (\n

Queue Management System

\n \n setSelectedJob(null)} />\n

\n );\n};\n\nexport default QueueInterface;\n\ncreateRoot(document.getElementById(\"root\")).render();",[],[160],{"_104":169,"_96":170,"_140":171,"_142":-5,"_143":131,"_144":172,"_146":147,"_106":173,"_101":174,"_150":164,"_152":175,"_154":26,"_155":176,"_99":177},"bc03359a-f075-11ef-ba89-e6cdfca9ef9f","db","a385e6be-e311-11ef-950e-e6cdfca9ef9f",142,["D",1740157392783],102,"import { InArgs, sqlite } from \"https://esm.town/v/stevekrouse/sqlite?v=13\";\nimport { parseImportMeta } from \"./parseImportMeta\";\n\nconst { projectName } = parseImportMeta(import.meta.url);\n\nconst DB_TABLE_PREFIX = `${projectName}_v1_`;\n\nconst makeTableName = (name: string): string => `${DB_TABLE_PREFIX}${name}`;\n\nexport async function addTaskToQueue({ name, args }: { name: string; args: any[] }, options?: {\n scheduledFor?: Date;\n}) {\n return (await tasksQuery(`INSERT INTO ${makeTableName(\"tasks\")} (data, scheduled_for) VALUES (?, ?) RETURNING *`, [\n JSON.stringify({ args, name }),\n (options?.scheduledFor || new Date())?.toISOString(),\n ])).at(0) as Task;\n}\n\nexport async function getPendingTasks() {\n return await tasksQuery(\n `\n SELECT * FROM ${makeTableName(\"tasks\")} \n WHERE status = 'pending' \n AND scheduled_for <= ? \n LIMIT 5`,\n [new Date().toISOString()],\n );\n}\n\nasync function claimTask(id: number) {\n return await tasksQuery(\n `UPDATE ${makeTableName(\"tasks\")} SET status = 'processing' WHERE status = 'pending' AND id = ? RETURNING *`,\n [id],\n );\n}\n\nasync function reportError(id: number, error: string) {\n return await tasksQuery(\n `UPDATE ${\n makeTableName(\"tasks\")\n } SET status = 'failed' AND error = ? WHERE status = 'processing' AND id = ? RETURNING *`,\n [error, id],\n );\n}\n\nexport async function getTasks() {\n return await tasksQuery(`SELECT * FROM ${makeTableName(\"tasks\")}`);\n}\n\nexport async function markTaskAsCompleted(id: number, result: any) {\n return await tasksQuery(`UPDATE ${makeTableName(\"tasks\")} SET status = 'completed', result = ? WHERE id = ?`, [\n JSON.stringify(result),\n id,\n ]);\n}\n\nasync function tasksQuery(query: string, args?: InArgs) {\n const rows = await sqlite.execute(query, args);\n return (rows.rows as unknown as TaskRow[]).map(taskRowMap);\n}\n\nexport type Task = {\n id: number;\n data: {\n name: string;\n args: string;\n };\n status: \"pending\" | \"processing\" | \"completed\" | \"failed\";\n created_at: Date;\n scheduled_for: Date;\n result?: any;\n};\n\nexport type TaskRow = {\n id: number;\n data: string;\n status: \"pending\" | \"processing\" | \"completed\" | \"failed\";\n created_at: string;\n result: string | null;\n scheduled_for: string;\n};\n\nfunction taskRowMap(row: TaskRow): Task {\n return {\n id: row.id,\n data: JSON.parse(row.data),\n status: row.status,\n result: row.result ? JSON.parse(row.result) : null,\n created_at: new Date(row.created_at),\n scheduled_for: new Date(row.scheduled_for),\n };\n}\n\nexport async function runMigrations() {\n await sqlite.batch([\n // `DROP TABLE IF EXISTS ${makeTableName(\"tasks\")}`,\n `CREATE TABLE IF NOT EXISTS ${makeTableName(\"tasks\")} (\n id INTEGER PRIMARY KEY, \n data TEXT, \n result TEXT,\n status TEXT NOT NULL DEFAULT 'pending' CHECK (\n status IN ('pending', 'processing', 'completed', 'failed')\n ),\n error TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')) CHECK (datetime(created_at) IS NOT NULL),\n scheduled_for TEXT NOT NULL DEFAULT (datetime('now')) CHECK (datetime(scheduled_for) IS NOT NULL)\n ) STRICT`,\n ]);\n}\n\nexport function serializeError(error: unknown): string {\n // Handle null or undefined\n if (error === null) return \"Error: null\";\n if (error === undefined) return \"Error: undefined\";\n\n // If it's already a string, return it\n if (typeof error === \"string\") return `Error: ${error}`;\n\n // Handle Error objects and their derivatives\n if (error instanceof Error) {\n const errorObj: Record = {\n name: error.name,\n message: error.message,\n stack: error.stack,\n };\n\n // Extract additional properties that might exist on custom errors\n for (const key of Object.getOwnPropertyNames(error)) {\n if (![\"name\", \"message\", \"stack\"].includes(key)) {\n const value = (error as unknown as Record)[key];\n errorObj[key] = value;\n }\n }\n\n // Handle errors with cause (available in newer JavaScript versions)\n if (\"cause\" in error && error.cause) {\n errorObj.cause = serializeError(error.cause);\n }\n\n return `Error: ${JSON.stringify(errorObj, null, 2)}`;\n }\n return `Error: ${JSON.stringify(error, null, 2)}`;\n}\n// await runMigrations();\n\n// await addTaskToQueue({ name: \"Go\", args: [] });\n\n// console.log(await getTasks());\n// console.log(await getPendingTasks());\n\nasync function getUserId() {\n const resp = await fetch(\"https://api.val.town/v1/me\", {\n headers: {\n Authorization: `Bearer ${Deno.env.get(\"valtown\")}`,\n },\n });\n const json = await resp.json();\n if (!resp.ok) {\n throw new Error(JSON.stringify(json));\n }\n return json.id;\n}\n\nexport class Queue {\n #startupPromise: ReturnType;\n #startupComplete: boolean = false;\n #userId: string | undefined;\n #tasks: Record;\n #error: Error | undefined;\n\n #httpEndpoint: string;\n\n constructor({ httpEndpoint, tasks }: { httpEndpoint: string; tasks: Record }) {\n this.#tasks = tasks;\n this.#startupPromise = (async () => {\n const [id] = await Promise.all([\n getUserId(),\n runMigrations(),\n ]);\n this.#userId = id;\n })().catch((error) => {\n this.#error = error;\n this.#startupComplete = true;\n }).then(() => {\n this.#startupComplete = true;\n });\n this.#httpEndpoint = httpEndpoint;\n }\n\n async #ensureMigration() {\n if (!this.#startupComplete) {\n await this.#startupPromise;\n }\n if (this.#error) {\n throw this.#error;\n }\n }\n\n async runScheduledTasks() {\n await this.#ensureMigration();\n const tasks = await getPendingTasks();\n for (const task of tasks) {\n fetch(`${this.#httpEndpoint}/${task.data.name}`, {\n method: \"POST\",\n body: JSON.stringify({ args: task.data.args }),\n headers: { \"Task-ID\": task.id.toString(), \"User-ID\": this.#userId || \"\" },\n }).catch((error) => console.error(error));\n }\n }\n\n async scheduleTask({ name, args }: { name: string; args: any[] }, options?: {\n scheduledFor?: Date;\n }) {\n await this.#ensureMigration();\n await addTaskToQueue({ name, args }, options);\n }\n\n async fetch(req: Request): Promise {\n await this.#ensureMigration();\n\n const url = new URL(req.url);\n const path = url.pathname.replace(/^\\//, \"\");\n const taskId = Number.parseInt(req.headers.get(\"Task-ID\") || \"\");\n if (Number.isNaN(taskId)) {\n return Response.json(\"invalid or missing task id header\", { status: 400 });\n }\n\n if (req.headers.get(\"User-ID\") !== this.#userId) {\n return Response.json(\"invalid or missing user id header\", { status: 400 });\n }\n const rows = await claimTask(taskId);\n if (rows.length === 0) {\n return Response.json(\"could not claim task\", { status: 403 });\n }\n\n const fn = this.#tasks[path];\n if (fn === undefined) {\n await reportError(taskId, `Task with name ${path} not found`);\n return Response.json(\"not found\", { status: 404 });\n }\n\n const { args } = await req.json();\n if (args === undefined || Array.isArray(args) === false) {\n await reportError(taskId, `Invalid arguments`);\n return Response.json(\"incorrect args\", { status: 400 });\n }\n\n try {\n let resp = await Promise.resolve(fn(...args));\n await markTaskAsCompleted(taskId, resp);\n } catch (error) {\n await reportError(taskId, serializeError(error));\n return Response.json(String(error), { status: 500 });\n }\n\n return Response.json(\"ok\");\n }\n}",[],[170],{"_104":179,"_96":180,"_140":181,"_142":-5,"_143":131,"_144":182,"_146":147,"_106":183,"_101":184,"_150":164,"_152":185,"_154":26,"_155":186,"_99":187},"bde33010-e312-11ef-aa7e-e6cdfca9ef9f","parseImportMeta","9b7c192e-e312-11ef-a69a-e6cdfca9ef9f",18,["D",1738685510639],3,"interface ImportMetaUrl {\n username: string;\n projectName: string;\n version: string;\n branchName: string;\n path: string;\n}\n\nexport function parseImportMeta(url: string): ImportMetaUrl {\n const pattern = /^https:\\/\\/esm\\.town\\/v\\/([^/]+)\\/([^@]+)@(\\d+)-(.+?)(\\/.*)?$/;\n const match = url.match(pattern);\n\n if (!match) {\n throw new Error(`Invalid ESM Town URL format: ${url}`);\n }\n\n const [, username, projectName, version, branchName, path = \"\"] = match;\n\n return {\n username,\n projectName,\n version,\n branchName,\n path: path.substring(1), // Remove leading slash\n };\n}\n\n// // Example usage:\n// const urls = [\n// \"https://esm.town/v/maxm/queue@11-main/runMigrations\",\n// \"https://esm.town/v/user/project@1-feature-branch-name/path/asdf/asfd/asdf/asfd\",\n// \"https://esm.town/v/dev/app@22-complex-branch-with-dashes\",\n// ];\n\n// urls.forEach(url => console.log(parseEsmTownUrl(url)));",[],[180],{"_104":189,"_96":190,"_140":191,"_142":-5,"_143":131,"_144":192,"_146":147,"_106":193,"_101":194,"_150":195,"_152":196,"_154":26,"_155":197,"_99":198},"6a24e54e-f1fa-11ef-9f65-569c3dd06744","server.ts","2c3b8fb2-f1fa-11ef-aa3c-569c3dd06744",159,["D",1740324329662],6,"http","export default async function(req: Request): Promise {\n return new Response(\n `\n \n \n `,\n { headers: { \"Content-type\": \"text/html\" } },\n );\n}",[],[190],{"_104":200,"_96":201,"_140":202,"_142":-5,"_143":131,"_144":203,"_146":147,"_106":204,"_101":163,"_150":195,"_152":205,"_154":26,"_155":206,"_99":207},"29870360-f073-11ef-9d72-e6cdfca9ef9f","test","8af8f9de-e667-11ef-9c83-e6cdfca9ef9f",133,["D",1740156288029],"import { Queue } from \"./db\";\n\nexport const queue = new Queue({\n httpEndpoint: \"https://maxm--8af8f9dee66711ef9c83e6cdfca9ef9f.web.val.run\",\n tasks: {\n \"sync\": (...args: any) => {\n return args;\n },\n \"async\": async (...args: any) => {\n await new Promise(resolve => setTimeout(resolve, 1000));\n return args;\n },\n },\n});\n\nexport default queue.fetch.bind(queue);",[],[201],{"_104":209,"_96":100,"_140":210,"_142":-5,"_143":131,"_144":211,"_146":147,"_106":212,"_101":213,"_150":164,"_152":214,"_154":26,"_155":215,"_99":216},"ce73a39a-f075-11ef-ac43-e6cdfca9ef9f","2429399a-f070-11ef-9306-e6cdfca9ef9f",145,["D",1740157423720],12,"import { getTasks } from \"./db\";\nimport { queue } from \"./test\";\n\nconsole.log(await getTasks());\nawait queue.scheduleTask({ name: \"sync\", args: [1, 2] });\nawait queue.runScheduledTasks();",[],[100],"files",[137,158,168,178,188,199,208],"counts",{"_221":32,"_222":149,"_223":32,"_224":32},"pulls","branches","forks","envVars","contents",[],{"_104":209,"_96":100,"_140":210,"_142":-5,"_143":131,"_144":211,"_146":147,"_106":228,"_101":213,"_150":164,"_152":214,"_154":26,"_99":229},["D",1740157423720],[100],"upstream","routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_94":95,"_96":97,"_98":42,"_99":100,"_102":233,"_151":237,"_240":241,"_304":305},{"_104":105,"_96":97,"_106":234,"_108":-5,"_109":110,"_111":-5,"_112":-5,"_11":113,"_114":-5,"_115":26,"_116":117,"_118":117,"_119":120,"_121":120,"_122":120,"_123":117,"_124":26,"_20":235,"_128":236},["D",1738616666562],{"_94":95,"_126":127},{"_101":130,"_96":42,"_104":131,"_132":105,"_133":-5,"_134":-5},{"_104":209,"_96":100,"_140":210,"_142":-5,"_143":131,"_144":211,"_146":147,"_106":238,"_101":213,"_150":164,"_152":214,"_154":26,"_99":239},["D",1740157423720],[100],"history",[242,244,250,256,261,266,271,275,279,285,290,295,299],{"_104":209,"_140":210,"_96":100,"_150":164,"_152":214,"_142":-5,"_143":131,"_101":213,"_144":211,"_154":26,"_106":243,"_146":147},["D",1740157423720],{"_104":245,"_140":210,"_96":100,"_150":164,"_152":246,"_142":-5,"_143":131,"_101":247,"_144":248,"_154":26,"_106":249,"_146":26},"c5bf058c-f075-11ef-8577-e6cdfca9ef9f","import { getTasks } from \"./db\";\nimport { queue } from \"./test\";\n\nconsole.log(await getTasks());\nawait queue.runScheduledTasks();\n// await queue.scheduleTask({ name: \"sync\", args: [1, 2] });",11,144,["D",1740157409112],{"_104":251,"_140":210,"_96":100,"_150":164,"_152":252,"_142":-5,"_143":131,"_101":253,"_144":254,"_154":26,"_106":255,"_146":26},"c33a90c4-f075-11ef-9177-e6cdfca9ef9f","import { getTasks } from \"./db\";\nimport { queue } from \"./test\";\n\nconsole.log(await getTasks());\nawait queue.runScheduledTasks();\nawait queue.scheduleTask({ name: \"sync\", args: [1, 2] });",10,143,["D",1740157404891],{"_104":257,"_140":210,"_96":100,"_150":164,"_152":246,"_142":-5,"_143":131,"_101":258,"_144":259,"_154":26,"_106":260,"_146":26},"4d56a5de-f073-11ef-a634-e6cdfca9ef9f",9,135,["D",1740156348108],{"_104":262,"_140":210,"_96":100,"_150":164,"_152":252,"_142":-5,"_143":131,"_101":263,"_144":264,"_154":26,"_106":265,"_146":26},"4b52da00-f073-11ef-b556-e6cdfca9ef9f",8,134,["D",1740156344730],{"_104":267,"_140":210,"_96":100,"_150":164,"_152":246,"_142":-5,"_143":131,"_101":268,"_144":269,"_154":26,"_106":270,"_146":26},"17f285f2-f073-11ef-875d-e6cdfca9ef9f",7,131,["D",1740156258539],{"_104":272,"_140":210,"_96":100,"_150":164,"_152":252,"_142":-5,"_143":131,"_101":194,"_144":273,"_154":26,"_106":274,"_146":26},"155e8566-f073-11ef-b556-e6cdfca9ef9f",130,["D",1740156254209],{"_104":276,"_140":210,"_96":100,"_150":164,"_152":246,"_142":-5,"_143":131,"_101":145,"_144":277,"_154":26,"_106":278,"_146":26},"ec5c0c2a-f071-11ef-ab03-e6cdfca9ef9f",124,["D",1740155755908],{"_104":280,"_140":210,"_96":100,"_150":164,"_152":281,"_142":-5,"_143":131,"_101":282,"_144":283,"_154":26,"_106":284,"_146":26},"5e777940-f070-11ef-a4fe-e6cdfca9ef9f","import { getTasks } from \"./db\";\nimport { queue } from \"./test\";\n\nconsole.log(await getTasks());\n// await queue.scheduleTask({ name: \"sync\", args: [1, 2] });",4,116,["D",1740155088361],{"_104":286,"_140":210,"_96":100,"_150":164,"_152":287,"_142":-5,"_143":131,"_101":184,"_144":288,"_154":26,"_106":289,"_146":26},"579cdc82-f070-11ef-b759-e6cdfca9ef9f","import { getTasks } from \"./db\";\nimport { queue } from \"./test\";\n\nawait getTasks();\nawait queue.scheduleTask({ name: \"sync\", args: [1, 2] });",115,["D",1740155076860],{"_104":291,"_140":210,"_96":100,"_150":164,"_152":292,"_142":-5,"_143":131,"_101":91,"_144":293,"_154":26,"_106":294,"_146":26},"3e263a78-f070-11ef-b9a7-e6cdfca9ef9f","import { getTasks } from \"./db\";\nimport { queue } from \"./test\";\nawait getT;",114,["D",1740155034139],{"_104":296,"_140":210,"_96":100,"_150":164,"_152":67,"_142":-5,"_143":131,"_101":149,"_144":297,"_154":26,"_106":298,"_146":26},"2f3e0194-f070-11ef-b7ca-e6cdfca9ef9f",113,["D",1740155009130],{"_104":300,"_140":210,"_96":301,"_150":164,"_152":67,"_142":-5,"_143":131,"_101":32,"_144":302,"_154":26,"_106":303,"_146":26},"242938dc-f070-11ef-9306-e6cdfca9ef9f","deftApricotWarbler",112,["D",1740154990542],"versions",[306,308,309,310,311,312,313,314,315,316,317,318,319],{"_151":242,"_307":244},"previous",{"_151":244,"_307":250},{"_151":250,"_307":256},{"_151":256,"_307":261},{"_151":261,"_307":266},{"_151":266,"_307":271},{"_151":271,"_307":275},{"_151":275,"_307":279},{"_151":279,"_307":285},{"_151":285,"_307":290},{"_151":290,"_307":295},{"_151":295,"_307":299},{"_151":299,"_307":-5},"routes/_app","actionData","errors"]

History for testScript