LogFire Query Proxy - Debug

Read Token: ${params.readToken || 'Not found'}

SQL: ${params.sql || 'Not found'}

Edit mode: ${edit}

\n \n `);\n }\n \n return c.text(`Would execute query with token: ${params.readToken?.substring(0, 10)}... and SQL: ${params.sql}`);\n});\n\n// Handle POST requests (form submissions)\napp.post('/', async (c) => {\n const formData = await c.req.formData();\n const readToken = formData.get('read_token')?.toString();\n const sql = formData.get('sql')?.toString();\n \n // Check if we have required parameters\n if (!readToken || !sql) {\n return c.html(`\n

Error

Missing required parameters: read_token and sql are required

\n Go back\n `, 400);\n }\n \n // Store read token in cookie\n setCookie(c, 'logfire-read-token', readToken, {\n httpOnly: true,\n secure: true,\n sameSite: 'Lax',\n maxAge: 60 * 60 * 24 * 30, // 30 days\n });\n \n return c.text(`Token saved and would execute: ${sql}`);\n});\n\nexport default app.fetch;",[],[172],{"_103":182,"_95":183,"_152":184,"_154":-5,"_155":137,"_156":185,"_158":159,"_105":186,"_100":176,"_161":177,"_163":187,"_165":22,"_166":-5,"_167":188,"_98":189},"313e7360-8900-11f0-b0d4-0224a6c84d84","logfire-proxy-minimal.ts","2f9ff240-8900-11f0-9cad-0224a6c84d84",12,["D",1756929436755],"import { Hono } from \"https://esm.sh/hono@4.0.10\";\nimport { getCookie, setCookie } from \"npm:hono/cookie\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err) => Promise.reject(err));\n\napp.get('/', async (c) => {\n const existingToken = getCookie(c, 'logfire-read-token');\n \n if (existingToken) {\n return c.text(`Found existing token: ${existingToken.substring(0, 10)}...`);\n } else {\n return c.html(`\n \n `);\n }\n});\n\napp.post('/', async (c) => {\n const formData = await c.req.formData();\n const token = formData.get('read_token');\n \n if (token) {\n setCookie(c, 'logfire-read-token', token.toString(), {\n httpOnly: true,\n secure: true,\n sameSite: 'Lax',\n maxAge: 60 * 60 * 24 * 30, // 30 days\n });\n return c.text(`Token saved: ${token.toString().substring(0, 10)}...`);\n }\n \n return c.text('No token provided');\n});\n\nexport default app.fetch;",[],[183],{"_103":191,"_95":192,"_152":193,"_154":-5,"_155":137,"_156":136,"_158":159,"_105":194,"_100":195,"_161":177,"_163":196,"_165":22,"_166":197,"_167":198,"_98":199},"a7d41a0a-8902-11f0-a353-0224a6c84d84","logfire-proxy.ts","cbe45786-880b-11f0-98ab-0224a6c84d84",["D",1756930494698],6,"import { Hono } from \"https://esm.sh/hono@4.0.10\";\nimport { getCookie, setCookie } from \"https://esm.sh/hono@4.0.10/cookie\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err) => Promise.reject(err));\n\ninterface LogFireParams {\n readToken?: string;\n sql?: string;\n minTimestamp?: string;\n maxTimestamp?: string;\n limit?: string;\n rowOriented?: string;\n accept?: string;\n}\n\nfunction extractParams(c: any): LogFireParams {\n const url = new URL(c.req.url);\n const params: LogFireParams = {};\n\n // Get read token from various sources (query params first, then cookie)\n params.readToken = url.searchParams.get(\"read-token\") ||\n url.searchParams.get(\"read_token\") ||\n getCookie(c, \"logfire-read-token\") || \"\";\n\n // Get other parameters from query string\n params.sql = url.searchParams.get(\"sql\") || \"\";\n params.minTimestamp = url.searchParams.get(\"min_timestamp\") || \"\";\n params.maxTimestamp = url.searchParams.get(\"max_timestamp\") || \"\";\n params.limit = url.searchParams.get(\"limit\") || \"\";\n params.rowOriented = url.searchParams.get(\"row_oriented\") || \"\";\n\n // Get Accept header\n params.accept = c.req.header(\"Accept\") || \"\";\n\n return params;\n}\n\nasync function extractFormParams(c: any): Promise {\n const params: LogFireParams = {};\n\n try {\n const formData = await c.req.formData();\n\n // Get read token from form data first, then fall back to cookie\n const formReadToken = formData.get(\"read-token\") ||\n formData.get(\"read_token\");\n params.readToken = formReadToken\n ? String(formReadToken)\n : (getCookie(c, \"logfire-read-token\") || \"\");\n\n params.sql = formData.get(\"sql\") ? String(formData.get(\"sql\")) : \"\";\n params.minTimestamp = formData.get(\"min_timestamp\")\n ? String(formData.get(\"min_timestamp\"))\n : \"\";\n params.maxTimestamp = formData.get(\"max_timestamp\")\n ? String(formData.get(\"max_timestamp\"))\n : \"\";\n params.limit = formData.get(\"limit\") ? String(formData.get(\"limit\")) : \"\";\n params.rowOriented = formData.get(\"row_oriented\")\n ? String(formData.get(\"row_oriented\"))\n : \"\";\n params.accept = formData.get(\"accept\")\n ? String(formData.get(\"accept\"))\n : (c.req.header(\"Accept\") || \"\");\n } catch (e) {\n // Not form data, ignore\n console.error(\"Error parsing form data:\", e);\n }\n\n return params;\n}\n\nfunction generateForm(\n params: LogFireParams,\n error?: string,\n success?: boolean,\n) {\n // Ensure we always try to get the cookie value if readToken is empty\n const readTokenValue = params.readToken || \"\";\n\n return `\n\n\n LogFire Query Proxy\n \n\n\n

LogFire Query Proxy

\n \n ${\n error\n ? `

${error}

`\n : \"\"\n }\n ${\n success\n ? `

Query executed successfully! Token has been saved.

`\n : \"\"\n }\n \n

\n \n Read Token *\n ${\n readTokenValue\n ? '(Saved in cookie)'\n : \"\"\n }\n \n \n

\n \n

\n \n SQL Query *\n \n \n

\n \n

\n \n Min Timestamp (ISO format)\n \n \n

\n \n

\n \n Max Timestamp (ISO format)\n \n \n

\n \n

\n \n Limit (max 10,000)\n \n \n

\n \n

\n \n Response Format\n \n \n

\n \n

\n \n JSON Row Oriented\n \n \n

\n \n

\n \n \n \n \n \n Reset Form\n \n

\n \n

Usage Notes:

Read Token is required and will be stored in cookies for future requests
SQL query is required - this is what will be executed against LogFire
Default limit is 500, maximum is 10,000
Timestamps should be in ISO format (e.g., 2024-01-01T00:00:00Z)
You can also make direct API requests with query parameters or form data
Use \"Download Result\" to save the query results to a file

\n\n`;\n}\n\nasync function makeLogFireRequest(params: LogFireParams): Promise {\n if (!params.readToken || !params.sql) {\n throw new Error(\n \"Missing required parameters: read_token and sql are required\",\n );\n }\n\n const url = new URL(\"https://logfire-us.pydantic.dev/v1/query\");\n\n // Add query parameters\n url.searchParams.set(\"sql\", params.sql);\n\n if (params.minTimestamp) {\n url.searchParams.set(\"min_timestamp\", params.minTimestamp);\n }\n\n if (params.maxTimestamp) {\n url.searchParams.set(\"max_timestamp\", params.maxTimestamp);\n }\n\n if (params.limit) {\n url.searchParams.set(\"limit\", params.limit);\n }\n\n if (params.rowOriented === \"true\") {\n url.searchParams.set(\"row_oriented\", \"true\");\n }\n\n const headers: Record = {\n \"Authorization\": `Bearer ${params.readToken}`,\n };\n\n // Set Accept header\n if (params.accept) {\n headers[\"Accept\"] = params.accept;\n } else {\n headers[\"Accept\"] = \"application/json\";\n }\n\n const response = await fetch(url.toString(), {\n method: \"GET\",\n headers,\n });\n\n return response;\n}\n\n// Handle GET requests\napp.get(\"/\", async (c) => {\n const url = new URL(c.req.url);\n const edit = url.searchParams.get(\"edit\") === \"true\";\n const success = url.searchParams.get(\"success\") === \"true\";\n\n const params = extractParams(c);\n\n // If edit=true or missing required params for direct query, show form\n if (edit || !params.readToken || !params.sql) {\n // Get cookie value to pre-populate form\n const cookieToken = getCookie(c, \"logfire-read-token\");\n if (cookieToken && !params.readToken) {\n params.readToken = cookieToken;\n }\n return c.html(generateForm(params, undefined, success));\n }\n\n try {\n const response = await makeLogFireRequest(params);\n\n // Store read token in cookie if provided\n if (params.readToken) {\n setCookie(c, \"logfire-read-token\", params.readToken, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 60 * 60 * 24 * 30, // 30 days\n path: \"/\",\n });\n }\n\n // Forward the response\n const responseBody = await response.text();\n\n return new Response(responseBody, {\n status: response.status,\n headers: {\n \"Content-Type\": response.headers.get(\"Content-Type\") ||\n \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, Accept\",\n },\n });\n } catch (error) {\n // Get cookie value for form\n const cookieToken = getCookie(c, \"logfire-read-token\");\n if (cookieToken && !params.readToken) {\n params.readToken = cookieToken;\n }\n return c.html(generateForm(params, `Error: ${error.message}`), 400);\n }\n});\n\n// Handle POST requests (form submissions)\napp.post(\"/\", async (c) => {\n const formParams = await extractFormParams(c);\n const queryParams = extractParams(c);\n\n // Check for action type\n let action = \"query\";\n try {\n const formData = await c.req.formData();\n action = formData.get(\"action\") || \"query\";\n } catch (e) {\n // Ignore\n }\n\n // Merge form and query parameters (form takes precedence)\n const params: LogFireParams = {\n readToken: formParams.readToken || queryParams.readToken,\n sql: formParams.sql || queryParams.sql,\n minTimestamp: formParams.minTimestamp || queryParams.minTimestamp,\n maxTimestamp: formParams.maxTimestamp || queryParams.maxTimestamp,\n limit: formParams.limit || queryParams.limit || \"500\",\n rowOriented: formParams.rowOriented || queryParams.rowOriented,\n accept: formParams.accept || queryParams.accept || \"application/json\",\n };\n\n // Check if we have required parameters\n if (!params.readToken || !params.sql) {\n // Get cookie value for form\n const cookieToken = getCookie(c, \"logfire-read-token\");\n if (cookieToken && !params.readToken) {\n params.readToken = cookieToken;\n }\n return c.html(\n generateForm(\n params,\n \"Missing required parameters: read_token and sql are required\",\n ),\n 400,\n );\n }\n\n try {\n const response = await makeLogFireRequest(params);\n\n // Store read token in cookie\n if (params.readToken) {\n setCookie(c, \"logfire-read-token\", params.readToken, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 60 * 60 * 24 * 30, // 30 days\n path: \"/\",\n });\n }\n\n // Get the response body\n const responseBody = await response.text();\n\n // If action is download, return with download headers\n if (action === \"download\") {\n const extension = params.accept === \"text/csv\"\n ? \"csv\"\n : params.accept === \"application/vnd.apache.arrow.stream\"\n ? \"arrow\"\n : \"json\";\n const filename = `logfire-query-${Date.now()}.${extension}`;\n\n return new Response(responseBody, {\n status: response.status,\n headers: {\n \"Content-Type\": response.headers.get(\"Content-Type\") ||\n \"application/json\",\n \"Content-Disposition\": `attachment; filename=\"${filename}\"`,\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n\n // For regular query, show the result in a nice format\n if (response.ok) {\n // For HTML form submission, show success and allow viewing results\n const contentType = response.headers.get(\"Content-Type\") || \"\";\n\n // If it's a form submission from browser, show formatted response\n if (c.req.header(\"Content-Type\")?.includes(\"multipart/form-data\")) {\n let formattedResult = \"\";\n\n if (contentType.includes(\"json\")) {\n try {\n const jsonData = JSON.parse(responseBody);\n formattedResult =\n `

${\n                JSON.stringify(jsonData, null, 2)\n              }

`;\n } catch {\n formattedResult =\n `

${responseBody}

`;\n }\n } else {\n formattedResult =\n `

${responseBody}

`;\n }\n\n const resultHtml = `\n\n\n LogFire Query Results\n \n\n\n

Query Results

\n \n

\n Query executed successfully! Your read token has been saved.\n

\n \n

Query:

${params.sql}

\n \n

Results:

\n ${formattedResult}\n

\n \n

\n \n New Query\n \n \n

\n\n`;\n\n return c.html(resultHtml);\n }\n }\n\n // For API requests, return raw response\n return new Response(responseBody, {\n status: response.status,\n headers: {\n \"Content-Type\": response.headers.get(\"Content-Type\") ||\n \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, Accept\",\n },\n });\n } catch (error) {\n // Get cookie value for form\n const cookieToken = getCookie(c, \"logfire-read-token\");\n if (cookieToken && !params.readToken) {\n params.readToken = cookieToken;\n }\n return c.html(generateForm(params, `Error: ${error.message}`), 400);\n }\n});\n\n// Handle OPTIONS for CORS\napp.options(\"*\", (c) => {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, Accept\",\n },\n });\n});\n\nexport default app.fetch;","logfire-viewer",[],[192],{"_103":201,"_95":202,"_152":203,"_154":-5,"_155":137,"_156":204,"_158":159,"_105":205,"_100":176,"_161":177,"_163":206,"_165":22,"_166":-5,"_167":207,"_98":208},"2829395e-8900-11f0-ac09-0224a6c84d84","test-cookies.ts","2609f3b6-8900-11f0-8418-0224a6c84d84",10,["D",1756929421517],"import { Hono } from \"https://esm.sh/hono@4.0.10\";\nimport { getCookie, setCookie } from \"npm:hono/cookie\";\n\nconst app = new Hono();\n\napp.get('/', (c) => {\n const existingToken = getCookie(c, 'test-token');\n \n if (existingToken) {\n return c.text(`Found existing token: ${existingToken}`);\n } else {\n setCookie(c, 'test-token', 'test-value-123', {\n httpOnly: true,\n secure: true,\n sameSite: 'Lax',\n maxAge: 60 * 60 * 24 * 30, // 30 days\n });\n return c.text('Set new token: test-value-123');\n }\n});\n\nexport default app.fetch;",[],[202],{"_103":210,"_95":99,"_152":211,"_154":-5,"_155":137,"_156":212,"_158":159,"_105":213,"_100":176,"_161":177,"_163":214,"_165":22,"_166":-5,"_167":215,"_98":216},"1f9f6aec-8900-11f0-b369-0224a6c84d84","1e29aea2-8900-11f0-995a-0224a6c84d84",8,["D",1756929407190],"import { Hono } from \"https://esm.sh/hono@4.0.10\";\n\nconst app = new Hono();\n\napp.get('/', (c) => {\n return c.text('Hello Hono!');\n});\n\nexport default app.fetch;",[],[99],{"_103":218,"_95":219,"_152":220,"_154":-5,"_155":137,"_156":195,"_158":159,"_105":221,"_100":176,"_161":177,"_163":222,"_165":22,"_166":-5,"_167":223,"_98":224},"19750fc8-8900-11f0-9911-0224a6c84d84","test-simple.ts","16cc5a4c-8900-11f0-96da-0224a6c84d84",["D",1756929396849],"export default async function (req: Request) {\n return new Response(\"Hello World - Basic Test\");\n}",[],[219],"files",[149,170,181,190,200,209,217],"counts",{"_229":32,"_230":176,"_231":32,"_232":32},"pulls","branches","forks","envVars","contents",[],{"_103":210,"_95":99,"_152":211,"_154":-5,"_155":137,"_156":212,"_158":159,"_105":236,"_100":176,"_161":177,"_163":214,"_165":22,"_166":-5,"_98":237},["D",1756929407190],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.code.$",{"_93":94,"_95":96,"_97":43,"_100":-7,"_98":99,"_101":246,"_147":251,"_225":273,"_162":274,"_233":276,"_277":-5,"_278":22,"_279":-5,"_280":-5,"_281":-5,"_282":283},{"_103":104,"_95":96,"_105":247,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":248,"_131":249,"_134":250,"_146":22},["D",1756608197655],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_100":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},[252,255,258,261,264,267,270],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":157,"_158":159,"_105":160,"_100":32,"_161":162,"_163":164,"_165":22,"_166":-5,"_167":253,"_98":254},[],[151],{"_103":171,"_95":172,"_152":173,"_154":-5,"_155":137,"_156":174,"_158":159,"_105":175,"_100":176,"_161":177,"_163":178,"_165":22,"_166":-5,"_167":256,"_98":257},[],[172],{"_103":182,"_95":183,"_152":184,"_154":-5,"_155":137,"_156":185,"_158":159,"_105":186,"_100":176,"_161":177,"_163":187,"_165":22,"_166":-5,"_167":259,"_98":260},[],[183],{"_103":191,"_95":192,"_152":193,"_154":-5,"_155":137,"_156":136,"_158":159,"_105":194,"_100":195,"_161":177,"_163":196,"_165":22,"_166":197,"_167":262,"_98":263},[],[192],{"_103":201,"_95":202,"_152":203,"_154":-5,"_155":137,"_156":204,"_158":159,"_105":205,"_100":176,"_161":177,"_163":206,"_165":22,"_166":-5,"_167":265,"_98":266},[],[202],{"_103":210,"_95":99,"_152":211,"_154":-5,"_155":137,"_156":212,"_158":159,"_105":213,"_100":176,"_161":177,"_163":214,"_165":22,"_166":-5,"_167":268,"_98":269},[],[99],{"_103":218,"_95":219,"_152":220,"_154":-5,"_155":137,"_156":195,"_158":159,"_105":221,"_100":176,"_161":177,"_163":222,"_165":22,"_166":-5,"_167":271,"_98":272},[],[219],[252,255,258,261,264,267,270],{"_103":210,"_95":99,"_152":211,"_154":-5,"_155":137,"_156":212,"_158":159,"_105":236,"_100":176,"_161":177,"_163":214,"_165":22,"_166":-5,"_98":275},[99],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]