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;","deleted","label","logfire-viewer",[98],"permalink","https://www.val.town/x/curtcox/LogfireViewer/code/logfire-proxy.ts","extension","actionData","errors"]