Stay tuned...

`);\n});\n```\n\n## Architecture Validation\n\nBefore proceeding, verify your implementation follows the architecture:\n\n- Services only make direct API calls (no environment variables, no orchestration)\n- Controllers handle business logic and coordinate services\n- Routes only handle HTTP concerns and call controllers\n- No service calls directly from routes\n- Environment variables handled in controllers, not services\n- Consistent response patterns across all layers\n\n### Expected Behavior\n\n**Important**: for the health endpoint JSON below, get the project name from the `yaml` code block in `/_townie/00-setup.md`; it is the value of the `project` key in the `yaml` code.\n\nThe health endpoint should return:\n\n```\n{\n \"status\": \"ok\",\n \"timestamp\": \"2025-07-14T18:26:28.270Z\",\n \"val\": {{project}},\n \"databases\": {\n \"configured\": true,\n \"{{db1}}\": \"connected\",\n // other databases\n }\n}\n```\n\nThis architecture is intended to create clear separation of concerns and should make the codebase maintainable and testable.\n\n---\n\n**Townie, stop here! Before proceeding to additional steps, confirm that this step is working correctly.**\n\n**If there was an error regarding environment variables**: remind the user to upload `vars.env` to the Environment Variables section of this Val, and to then let you know when that step is complete so you can retry.\n\n**If everything is working as intended**: conclude this step with these messages:\n\n1. Briefly summarize the work you just did and why it's important\n1. Provide the URL to the health endpoint so the user can see that the endpoint is live. (Tell the user that they can copy and paste that URL into a new tab to see it live.)\n\n---\n\n### Next step: web route authentication\n\nTell the user that the next step is to add authentication to the web routes of this Val, and that they should copy this line and paste it into Townie:\n\n> Add auth to this Val with what you see in `/_townie/02-auth.md`\n",[],[156,185],{"_104":192,"_95":193,"_157":194,"_159":158,"_160":139,"_161":162,"_163":164,"_106":195,"_100":32,"_166":179,"_168":196,"_169":22,"_170":-5,"_171":197,"_98":198},"d0f9956a-7951-11f0-8810-0224a6c84d84","02-auth.md","0198aa63-0ee2-725e-8c9f-80d0e5e060b2",["D",1755205275298],"# Complete Authentication Implementation Instructions\n\n## Townie instructions (Townie should follow these)\n\nRead through all of these instructions in order to understand the architecture of this Val, and implementation details important to this Val, and then once you have it all in your memory you should get to work.\n\nIf anything is unclear, you should stop and ask me for clarification before proceeding. Do not write code if you are unsure of what is expected.\n\n**Important:** there are checkpoints in these instructions where you are directed to stop and ask permission before proceeding. Follow those instructions and do not proceed without permission.\n\n## LastLogin Built-in Features\n\n**Important:** LastLogin automatically handles certain routes and authentication flows:\n\n- **`/auth/logout`** - LastLogin intercepts this route and handles logout automatically\n- **No custom logout route needed** in your Hono app\n- **Simply link to `/auth/logout`** and LastLogin will clear the session and redirect\n- **Authentication headers** - LastLogin adds `X-LastLogin-Email` header for authenticated requests\n\n**Authentication Flow:**\n\n1. **Unauthenticated requests** → LastLogin checks for session\n2. **No session** → Returns 401 or redirects to login\n3. **Valid session** → Adds `X-LastLogin-Email` header and passes to your app\n4. **`/auth/logout` requests** → LastLogin clears session automatically (never reaches your app)\n\n## Step 1. Core Architecture Setup\n\n### Main Application (main.tsx)\n\n**Add global authentication middleware to `main.tsx`:**\n\n```typescript\nimport { lastlogin } from \"https://esm.town/v/stevekrouse/lastlogin_safe\";\n\n// Import route modules\nimport authCheck from \"./backend/routes/authCheck.ts\";\n// other route modules\n\nconst app = new Hono();\n\n// Apply global authentication middleware to ALL routes\napp.use(\"*\", authCheck);\n\n// other routes\n\n// Export with LastLogin wrapper\nasync function handler(request: Request): Promise {\n return app.fetch(request);\n}\n\n// Wrap and export the main HTTP handler with lastlogin\nexport default lastlogin(handler);\n```\n\n### Dashboard Route Organization\n\n**Best Practice: Separate the root dashboard route from main.tsx**\n\nInstead of defining the root route directly in `main.tsx`, create a dedicated dashboard route file:\n\n- **Create**: `/backend/routes/views/dashboard.tsx`\n- **Purpose**: Handle the authenticated user's main dashboard/landing page\n- `import dashboardRoute from \"./backend/routes/views/dashboard.tsx\";`\n- **Mount in main.tsx**: `app.get(\"/\", dashboardRoute)`\n- **Note**: Dashboard is placed in `/routes/views/` because it's a user-facing view, not an API endpoint\n\nThis approach:\n\n- Keeps `main.tsx` focused on app setup and middleware\n- Makes the dashboard logic easier to maintain and test\n- Follows the modular architecture pattern with views separated from API routes\n- Places user-facing interfaces in `/routes/views/` for better organization\n- Allows for easier dashboard enhancements without touching core routing\n\nThe dashboard route should:\n\n- Display user information (email from `c.get(\"userEmail\")`)\n- Display the `/api/health` endpoint results as raw JSON in a
 tag; e.g., JSON.stringify(data, null, 2)\n- Include a link to the raw `/api/health` endpoint below the JSON display for easy access and testing\n- Include logout functionality via `/auth/logout`\n- Show a simple and professional welcome interface with minimal styling\n\n### URL Utility for Absolute URLs\n\n**Create `/backend/utils/url.ts`:**\n\nBefore implementing the dashboard, create a utility function for constructing absolute URLs when needed (like for sharing URLs externally):\n\n```typescript\nexport function getAbsoluteUrl(c: any, path: string): string {\n  const protocol = c.req.header(\"x-forwarded-proto\") || \"https\";\n  const host = c.req.header(\"host\");\n  return `${protocol}://${host}${path}`;\n}\n```\n\n**Usage in dashboard and other routes:**\n\n- Import: `import { getAbsoluteUrl } from \"../../utils/url.ts\";`\n- Use for external sharing: `const dashboardUrl = getAbsoluteUrl(c, '/');`\n- Continue using relative URLs for internal links: `href=\"/api/health\"`\n\n**When to use absolute vs relative URLs:**\n\n- **Absolute URLs**: External sharing, webhooks, emails, API documentation\n- **Relative URLs**: Internal navigation, forms, API calls within the app\n\n### Create `/backend/routes/authCheck.ts`\n\n**Authentication Middleware:**\n\n- Retrieve the user's email: `const email = c.req.header(\"X-LastLogin-Email\")`\n- If email exists, the user is authenticated - store in context and continue to your app\n- If no email, show login page with LoginWithGoogleButton\n- **Note:** You don't need to handle `/auth/logout` - LastLogin does this automatically\n\n**Login Page Requirements:**\n\n- `import { LoginWithGoogleButton } from \"https://esm.town/v/stevekrouse/LoginWithGoogleButton\"`\n- Use the `` React Component, optionally supplying the `text` attribute\n- Add \"via LastLogin\" underneath LoginWithGoogleButton, centered, secondary text, linking to https://lastlogin.io/\n- Pass the email from the server to the client-side code if using React hydration or similar techniques\n\n**For authenticated users:**\n\n- Store email in context: `c.set('userEmail', email)`\n- In your authenticated views, add logout functionality: `Logout`\n\n**Public Routes Whitelist:**\n\n- Add a `PUBLIC_ROUTES` array at the top for routes that should be accessible without authentication\n- **Don't include `/auth/logout`** in the whitelist (LastLogin handles it before your middleware runs)\n- Use for truly public routes like: `/demo/:id`, `/api/health`, static assets, etc.\n\nIf you encounter problems loading the React button, try this simple approach for authCheck.ts:\n\n```typescript\n// Public routes that don't require authentication\nconst PUBLIC_ROUTES = [\n  // Add public routes here as needed\n  // '/demo/:id',  // Example: public demo viewing\n  // '/api/public', // Example: public API endpoints\n];\n\n// Helper function to check if a route is public\nfunction isPublicRoute(path: string): boolean {\n  return PUBLIC_ROUTES.some((route) => {\n    // Handle exact matches\n    if (route === path) return true;\n\n    // Handle wildcard patterns (basic implementation)\n    if (route.includes(\"*\")) {\n      const pattern = route.replace(\"*\", \".*\");\n      return new RegExp(`^${pattern}$`).test(path);\n    }\n\n    // Handle route parameters (basic implementation)\n    if (route.includes(\":\")) {\n      const pattern = route.replace(/:[^/]+/g, \"[^/]+\");\n      return new RegExp(`^${pattern}$`).test(path);\n    }\n\n    return false;\n  });\n}\n\nexport default async (c, next) => {\n  // Allow public routes to bypass authentication\n  if (isPublicRoute(c.req.path)) {\n    await next();\n    return;\n  }\n\n  const email = c.req.header(\"X-LastLogin-Email\");\n\n  if (!email) {\n    // Show login page if not authenticated\n    return c.html(`\n      \n      \n      \n        Your App - Login Required\n      \n      \n        \n          Sign in
\n          Sign in to access your app.
\n          \n            Loading login button...
\n          
\n          \n            via LastLogin\n          
\n        
\n\n        \n      \n      \n    `);\n  }\n\n  // If authenticated, store email in context for use by routes\n  c.set(\"userEmail\", email);\n\n  // Continue to the next middleware/route\n  await next();\n};\n```\n\n## Common Gotchas\n\n**Logout Route:**\n\n- ❌ Don't create a custom `/auth/logout` route in your Hono app\n- ✅ Just link to `/auth/logout` - LastLogin handles it automatically\n- The logout link will work for authenticated users without any custom code\n- LastLogin intercepts `/auth/logout` at the wrapper level before it reaches your middleware\n\n**Public Routes:**\n\n- Use the whitelist in authCheck.ts for routes that should be accessible without authentication\n- `/auth/logout` doesn't need to be whitelisted (LastLogin handles it before your middleware runs)\n- Examples of routes that should be whitelisted: public demos, health checks, static assets\n\n**Authentication Headers:**\n\n- Authenticated requests will have `X-LastLogin-Email` header\n- Unauthenticated requests will not have this header\n- LastLogin wrapper handles session validation before your code runs\n\n**Error Handling:**\n\n- If LastLogin can't validate a session, it returns 401 before reaching your app\n- Your authCheck middleware only runs for requests that pass LastLogin's validation\n- No need to handle session expiration - LastLogin manages this\n\n---\n\n**Townie, stop here! Before proceeding to additional steps, confirm that this step is working correctly.**\n\n**If everything is working as intended**: conclude this step with these messages:\n\n1. Briefly summarize the work that was just completed and why it's important\n1. Use the getAbsoluteUrl utility to construct the dashboard URL and provide it to the user so they can see that the dashboard is live. Tell the user that they can copy and paste that URL into a new tab to see it live.\n1. Tell the user that they can log into the dashboard using their Google email address.\n\n---\n\n### Next step: webhook authentication\n\nTell the user that the next step is to add webhook authentication to this Val. Explain what webhooks are why it's important to authenticate them.\n\nLastly, tell the user to copy this line and paste it into Townie:\n\n> Add webhook auth to this Val with what you see in `/_townie/03-webhooks.md`\n",[],[156,193],{"_104":200,"_95":201,"_157":202,"_159":158,"_160":139,"_161":162,"_163":164,"_106":203,"_100":32,"_166":179,"_168":204,"_169":22,"_170":-5,"_171":205,"_98":206},"d0f9a28a-7951-11f0-8810-0224a6c84d84","03-webhooks.md","0198aa63-0ee2-725e-8c9f-85a7e7bb5cea",["D",1755205275298],"# Webhook Authentication Architecture Instructions\n\n## Townie instructions (Townie should follow these)\n\n## Middleware Order\n\nPlace authentication middleware in the following order:\n\n1. **Notion webhook auth middleware** (X-API-KEY for `/tasks/*`)\n2. **Global user auth middleware** (for other protected routes)\n3. **Route handlers**\n\n## Webhook Authentication\n\n### Scope\n\n- Apply only to routes under /tasks/\\*\n- All /tasks endpoints expect POSTs from Notion webhooks\n\n### Implementation\n\n- Create `/backend/routes/webhookAuthCheck.ts`\n- Extract X-API-KEY header from incoming requests\n- Compare against NOTION_WEBHOOK_SECRET environment variable\n- Use constant-time comparison to prevent timing attacks\n- Return 401/403 for authentication failures with generic error messages\n- Log failed authentication attempts for monitoring\n\n### Route Implementation Requirements\n\n**CRITICAL:** All webhook routes MUST use POST method:\n\n```\n// ✅ CORRECT - Webhooks are POST requests\napp.post(\"/webhook-endpoint\", async (c) => {\n  // Handle webhook\n});\n\n// ❌ WRONG - This won't work with webhooks\napp.get(\"/webhook-endpoint\", async (c) => {\n  // Webhooks can't reach this\n});\n```\n\nWhy: Notion (and most webhook providers) send POST requests, never GET.\n\n### Middleware Application (EXACT CODE)\n\nApply middleware in this EXACT order in main.tsx:\n\n```\n// 1. Webhook auth - ONLY for /tasks/* routes\napp.use(\"/tasks/*\", webhookAuth);\n\n// 2. User auth - for ALL routes EXCEPT /tasks/*\napp.use(\"/api/*\", authCheck);\napp.use(\"/views/*\", authCheck);\napp.use(\"/\", authCheck);\n\n// Add root route - now serves the authenticated dashboard\napp.get(\"/\", dashboardRoute);\n\n// 3. Mount routes AFTER middleware\napp.route(\"/tasks\", taskRoutes);\n```\n\n**Important:** We've changed the global authentication from app.use(\"\\*\") to\nmore specific auth route handling.\n\n**Before:**\n\n```\napp.use(\"*\", authCheck);  // Applied to ALL routes including /tasks/*\n```\n\n**After:**\n\n```\napp.use(\"/api/*\", authCheck);   // Applied to API routes\napp.use(\"/views/*\", authCheck); // Applied to view routes\napp.use(\"/\", authCheck);        // Applied to root route\n```\n\n**This ensures:**\n\n✅ `/` (root) still requires user authentication ✅ `/api/*` routes still\nrequire user authentication ✅ `/views/*` routes still require user\nauthentication ✅ `/tasks/*` routes only use webhook authentication (no user\nauth)\n\n**Common mistake:** Using app.use(\"\\*\", webhookAuth) - this applies to all\nroutes incorrectly.\n\n### Flow Logic\n\n- Request to /tasks/\\* → Check X-API-KEY → If valid, proceed to route handler\n  (skip global auth)\n- Request to /tasks/\\* → Check X-API-KEY → If invalid, return 401 (never reaches\n  global auth)\n- Request to other routes → Skip webhook auth → Go to global auth → Then route\n  handler\n\n### Testing Webhook Authentication\n\nTest in this exact order:\n\n1. **Test without header** (should fail):\n\nPOST /tasks/test Expected: 401 \"Authentication required\"\n\n1. **Test with wrong key** (should fail):\n\nPOST /tasks/test Headers: {\"X-API-KEY\": \"wrong-key\"} Expected: 403\n\"Authentication failed\"\n\n1. Test with correct key (should succeed):\n\nPOST /tasks/test\\\nHeaders: {\"X-API-KEY\": \"your-configured-secret-value\"} Expected: 200 (reaches\nyour route handler)\n\n**If step 3 returns 404:** Your route is probably defined as GET instead of\nPOST.\n\n### Debugging Webhook Auth Issues\n\nAdd this temporary debug endpoint:\n\n```\napp.get(\"/debug-webhook\", (c) => {\n  const secret = Deno.env.get(\"NOTION_WEBHOOK_SECRET\");\n  return c.json({\n    hasSecret: !!secret,\n    secretLength: secret?.length || 0,\n  });\n});\n```\n\n**Expected response:** {\"hasSecret\":true,\"secretLength\":>0}\n\nAdd this catch all endpoint:\n\n```\n// Catch-all handler for undefined webhook endpoints\n// This must be the LAST route defined to catch unmatched paths\napp.post(\"*\", (c) => {\n  const path = c.req.path;\n  const method = c.req.method;\n  const returnObj = {\n    error: \"Endpoint not found\",\n    path: path,\n    method: method,\n    availableEndpoints: [\n      \"GET /tasks/debug-webhook\",\n      \"POST /tasks/test\",\n      \"POST /tasks/notion-webhook\",\n    ],\n  };\n  console.log(returnObj);\n\n  return c.json(returnObj, 404);\n});\n```\n\n### Complete Working Example\n\nHere's a complete working webhook endpoint:\n\n```\n// backend/routes/tasks/_tasks.routes.ts\nimport { Hono } from \"npm:hono@3.12.12\";\n\nconst app = new Hono();\n\napp.post(\"/notion-webhook\", async (c) => {\n  // At this point, webhook auth has already passed\n  const body = await c.req.json();\n  console.log(\"Notion webhook received:\", body);\n\n  // Process the webhook...\n\n  return c.json({ success: true });\n});\n\nexport default app;\n```\n\nTest with:\n\nPOST /tasks/notion-webhook Headers: {\"X-API-KEY\":\n\"your-configured-secret-value\"} Body: {\"test\": \"data\"} Expected: 200 {\"success\":\ntrue}\n\n### 4\\. Add Simplified Webhook Testing to Dashboard\n\nUpdate `/backend/routes/views/dashboard.tsx`:\n\n**Import the URL utility in the dashboard:**\n\nAdd this import at the top of `/backend/routes/views/dashboard.tsx`:\n\n```typescript\nimport { getAbsoluteUrl } from \"../../utils/url.ts\";\n```\n\n**Add webhook configuration variables after health data:**\n\n    // Check webhook configuration\n    const webhookSecret = Deno.env.get(\"NOTION_WEBHOOK_SECRET\");\n    const webhookConfigured = !!webhookSecret;\n    const webhookEndpoint = getAbsoluteUrl(c, '/tasks/notion-webhook');\n\n**Note:** We use `getAbsoluteUrl()` here because the webhook endpoint needs to be shared with external services (Notion), unlike internal links which should remain relative.\n\n**Add CSS styles for webhook section (after existing styles):**\n\n    .webhook-section {\n      background: #f8f9fa;\n      border: 1px solid #e9ecef;\n      border-radius: 6px;\n      padding: 20px;\n      margin-top: 20px;\n    }\n    .webhook-section h3 {\n      color: #333;\n      margin-top: 0;\n      margin-bottom: 15px;\n    }\n    .webhook-url {\n      margin-bottom: 20px;\n    }\n    .webhook-endpoint {\n      font-family: 'Monaco', 'Menlo', 'Ubuntu Mono', monospace;\n      font-size: 14px;\n      background: white;\n      padding: 12px;\n      border: 1px solid #dee2e6;\n      border-radius: 4px;\n      word-break: break-all;\n      user-select: all;\n    }\n    .test-section {\n      border-top: 1px solid #dee2e6;\n      padding-top: 20px;\n      margin-top: 20px;\n    }\n    .test-section p {\n      margin-bottom: 15px;\n      color: #495057;\n    }\n    .test-section code {\n      background: #f8f9fa;\n      padding: 2px 4px;\n      border-radius: 3px;\n      font-family: 'Monaco', 'Menlo', 'Ubuntu Mono', monospace;\n      font-size: 13px;\n    }\n    .test-controls {\n      display: flex;\n      gap: 10px;\n      align-items: center;\n      margin-bottom: 15px;\n    }\n    .test-btn {\n      background: #28a745;\n      color: white;\n      border: none;\n      padding: 8px 16px;\n      border-radius: 4px;\n      cursor: pointer;\n      font-size: 14px;\n      transition: background-color 0.2s;\n    }\n    .test-btn:hover {\n      background: #218838;\n    }\n    .test-btn:disabled {\n      background: #6c757d;\n      cursor: not-allowed;\n    }\n    .api-key-input {\n      padding: 6px 10px;\n      border: 1px solid #ced4da;\n      border-radius: 4px;\n      font-size: 14px;\n      width: 200px;\n    }\n    .test-result {\n      background: white;\n      border: 1px solid #dee2e6;\n      border-radius: 4px;\n      padding: 15px;\n      font-family: 'Monaco', 'Menlo', 'Ubuntu Mono', monospace;\n      font-size: 13px;\n      min-height: 60px;\n      white-space: pre-wrap;\n    }\n    .result-success {\n      border-color: #28a745;\n      background: #d4edda;\n    }\n    .result-error {\n      border-color: #dc3545;\n      background: #f8d7da;\n    }\n\n**Add simplified webhook section HTML (after health section):**\n\n    \n      Webhook Endpoint
\n\n      \n        ${webhookEndpoint}
\n      
\n\n      \n        To test: Get the NOTION_WEBHOOK_SECRET value from your vars.env file (provided by your administrator)
\n        \n          \n          \n        
\n        Ready to test webhook authentication...
\n      
\n    
\n\n**Add JavaScript for form submission (before closing body tag):**\n\n    \n\n## Testing Verification\n\n1. Test `/tasks/debug-webhook` (GET) - should show webhook configuration\n2. Test `/tasks/test` (POST) without header - should return 401\n3. Test `/tasks/test` (POST) with wrong key - should return 403\n4. Test `/tasks/test` (POST) with correct key - should return 200\n5. Verify user authentication still works for other routes\n6. Check dashboard shows simplified webhook testing interface\n7. Verify form submission works with both button click and Enter key\n\n## Expected Results\n\nMake sure these are true:\n\n- Webhook endpoints only accessible with correct X-API-KEY\n- User authentication preserved for non-webhook routes\n- Dashboard provides clean, simplified webhook testing interface\n- Form submission works via button click or Enter key\n- All authentication flows working independently\n- Webhook endpoint ready for Notion integration\n\n## Security Considerations\n\n- Webhook middleware should return early (success or failure) without calling\n  next()\n- Never pass webhook requests to the global auth middleware\n- Maintain complete separation between webhook auth and user auth mechanisms\n- Consider rate limiting on /tasks endpoints\n- Use generic error messages that don't reveal authentication mechanism details\n\n## Route Structure\n\n- /tasks/\\* → Webhook auth required (Notion POSTs)\n- /api/\\* → User auth required (if applicable)\n- /\\* → Public routes (static files, etc.)\n\n### 5\\. Update Documentation\n\nUpdate README.md to include webhook authentication section and environment\nvariables.\n\n## Final Deliverables\n\nMake sure these are true:\n\n- Webhook authentication middleware implemented\n- Middleware order correctly configured\n- Test endpoints available\n- Simplified dashboard with webhook testing form\n- Form supports both click and keyboard submission\n- Documentation updated\n- Ready for Notion webhook configuration\n\n---\n\n**Townie, stop here! Before proceeding to additional steps, confirm that this\nstep is working correctly.**\n\n**If everything is working as intended**: conclude this step with these\nmessages:\n\n1. Briefly summarize the work that was just completed and why it's important\n1. Provide the URL to the dashboard endpoint, from which the user can test the\n   new webhook endpoint with the webhook form\n1. Explain that the user will need the `NOTION_WEBHOOK_SECRET` from the\n   `vars.env` to test the webhook endpoint successfully\n1. Explain that we will implement webhooks from Notion in a step that comes\n   later\n",[],[156,201],{"_104":208,"_95":209,"_157":210,"_159":158,"_160":139,"_161":211,"_163":164,"_106":212,"_100":32,"_166":179,"_168":213,"_169":22,"_170":-5,"_171":214,"_98":215},"82c4257c-7a05-11f0-9236-0224a6c84d84","2-stage-questions-openai.md","82c4264e-7a05-11f0-9236-0224a6c84d84",8,["D",1755282453562],"# Instructions: Implementing Incremental Findings Analysis\n\n## Context\n\nYou have a cron job that processes research questions against multiple\ntranscripts using OpenAI, then updates a Notion report page. The original\nimplementation had two problems:\n\n1. Used non-existent OpenAI API endpoints\n2. Processed all questions in memory then updated Notion once at the end (bad\n   for 30+ questions)\n\nRough notes: does the openai service first ask a question of all transcripts,\ngenerate an answer per question, and then look for consensus across all 10\nanswers from all 10 transcripts? do not write code, just answer the question.\n\nYes, exactly! The OpenAI service uses a two-stage approach:\n\nStage 1 (Individual Analysis):\n\nTakes each transcript individually Asks the same research question to each\ntranscript separately Generates an individual analysis for each transcript that\nincludes: A stance (supports/mixed/contradicts/not enough evidence) Key findings\nSupporting quotes Rationale Confidence score Stage 2 (Consensus Synthesis):\n\nTakes all the individual analyses from Stage 1 Feeds them to a second OpenAI\ncall that acts as a \"senior research synthesizer\" This second call looks across\nall the individual answers to determine: Overall consensus level\n(high/medium/low) A direct answer that synthesizes all individual responses Key\npoints most transcripts agree on Notable disagreements or outliers Overall\nconfidence score So if you have 10 transcripts, it makes 10 individual OpenAI\ncalls in Stage 1, then 1 synthesis call in Stage 2 (total of 11 API calls per\nquestion). The final answer is based on finding patterns and consensus across\nall 10 individual transcript analyses.\n\n## Goal\n\nImplement a 2-stage OpenAI analysis with incremental Notion updates for\nreal-time progress visibility and fault tolerance.\n\n## Architecture & Separation of Concerns\n\n**This implementation follows Val Town's layered architecture:**\n\n- **Cron** (`findings-analysis.ts`): Simple trigger, calls controller\n- **Controller** (`findings.controller.ts`): Business logic orchestration,\n  environment variables, error handling\n- **Services** (`openai.service.ts`, `notion.service.ts`): Pure API calls with\n  consistent response format\n- **Types** (`findings.types.ts`): Shared interfaces\n\n**Key principle**: Services only make API calls and return\n`{ success, data?, error? }`. Controllers handle business logic and coordinate\nmultiple service calls.\n\n## Step 1: Rewrite OpenAI Service (`/backend/services/openai.service.ts`)\n\n**Replace entire file with 2-stage implementation:**\n\n### Core Types\n\n    export interface ConsensusAnalysisRequest {\n      question: string;\n      transcripts: string[];\n      apiKey: string;\n    }\n\n    export interface ConsensusAnswer {\n      question: string;\n      consensusLevel: \"high\" | \"medium\" | \"low\";\n      directAnswer: string;\n      keyPoints: string[];\n      disagreements: string[];\n      confidence: number; // 0..1\n      methodologyNote: string;\n      perTranscriptFindings: PerTranscriptFinding[];\n    }\n\n    export interface ConsensusAnalysisResponse {\n      success: boolean;\n      data?: ConsensusAnswer;\n      error?: string;\n      timestamp: string;\n    }\n\n### Stage 1: Individual Transcript Analysis\n\n**Function**:\n`analyzeIndividualTranscript(openai, model, question, transcript, transcriptKey, maxChars)`\n\n**Implementation details:**\n\n- Use `openai.chat.completions.create()` with actual OpenAI client\n- Model: `gpt-4o-mini` (cost efficient)\n- System prompt: \"You are a meticulous research analyst. Analyze the provided\n  interview transcript to answer a specific research question.\"\n- Response format: `{ type: \"json_object\" }`\n- Expected JSON structure:\n\n      {\n        \"stance\": \"supports|mixed|contradicts|not enough evidence\",\n        \"keyFindings\": [\"finding 1\", \"finding 2\"],\n        \"supportingQuotes\": [\"quote 1\", \"quote 2\"],\n        \"rationale\": \"Brief explanation\",\n        \"confidence\": 0.85\n      }\n\n- Error handling: Return fallback analysis with stance \"not enough evidence\" and\n  confidence 0.0\n- Truncate transcripts to maxChars (default 15,000) to avoid token limits\n\n### Stage 2: Consensus Synthesis\n\n**Function**: `synthesizeConsensus(openai, model, question, individualAnalyses)`\n\n**Implementation details:**\n\n- Use `openai.chat.completions.create()` with actual OpenAI client\n- Model: `gpt-4o` (high quality reasoning)\n- System prompt: \"You are a senior research synthesizer. You will receive\n  multiple individual analyses of different transcripts for the same research\n  question.\"\n- Input: Formatted string of all individual analyses\n- Response format: `{ type: \"json_object\" }`\n- Expected JSON structure:\n\n      {\n        \"consensusLevel\": \"high|medium|low\",\n        \"directAnswer\": \"Clear, direct answer\",\n        \"keyPoints\": [\"point 1\", \"point 2\"],\n        \"disagreements\": [\"disagreement 1\"],\n        \"confidence\": 0.85,\n        \"methodologyNote\": \"Brief explanation\"\n      }\n\n- Consensus level logic:\n  - HIGH: 80%+ of transcripts support same conclusion\n  - MEDIUM: 60-79% agreement\n  - LOW: <60% agreement or significant contradictions\n- Error handling: Create fallback consensus using stance distribution from Stage\n  1 results\n\n### Concurrency Control\n\n**Function**: `mapWithLimit(items, limit, fn)`\n\n- Process transcripts with configurable concurrency (default: 3)\n- Prevents API rate limiting and timeouts\n- Sequential processing within each transcript, parallel across transcripts\n\n### Main Export Function\n\n**Function**: `analyzeTranscriptsWithConsensus(request, options?)`\n\n**Flow:**\n\n1. Validate inputs (apiKey, question, transcripts)\n2. Create OpenAI client with timeout\n3. Stage 1: Process all transcripts in parallel (with limit) → individual\n   analyses\n4. Stage 2: Synthesize consensus from individual analyses → final answer\n5. Return `ConsensusAnalysisResponse` format\n\n**Error handling:**\n\n- Validation errors: Return immediately with descriptive error\n- Stage 1 errors: Continue with other transcripts, mark failed ones\n- Stage 2 errors: Use fallback consensus calculation\n- All errors include timestamp and preserve partial results\n\n## Step 2: Add New Notion Service Functions (`/backend/services/notion.service.ts`)\n\n**Add these functions following service pattern:**\n\n    export async function deletePageContent(pageId: string) {\n      try {\n        const existingBlocks = await notion.blocks.children.list({ block_id: pageId });\n        for (const block of existingBlocks.results) {\n          await notion.blocks.delete({ block_id: block.id });\n        }\n        return { success: true, data: { deletedBlocks: existingBlocks.results.length }, timestamp: new Date().toISOString() };\n      } catch (error) {\n        return { success: false, error: error.message, timestamp: new Date().toISOString() };\n      }\n    }\n\n    export async function appendPageContent(pageId: string, blocks: any[]) {\n      try {\n        const response = await notion.blocks.children.append({ block_id: pageId, children: blocks });\n        return { success: true, data: response, timestamp: new Date().toISOString() };\n      } catch (error) {\n        return { success: false, error: error.message, timestamp: new Date().toISOString() };\n      }\n    }\n\n**Service responsibilities:**\n\n- Pure API calls to Notion\n- Consistent `{ success, data?, error?, timestamp }` response format\n- No business logic or environment variable handling\n- Error handling only for API failures\n\n## Step 3: Restructure Controller (`/backend/controllers/findings.controller.ts`)\n\n**Controller responsibilities:**\n\n- Handle environment variables (`OPENAI_API_KEY`, database IDs)\n- Orchestrate multiple service calls\n- Implement business rules (incremental updates, error recovery)\n- Transform data between services\n- Comprehensive logging and error handling\n\n### Key Changes\n\n**1\\. Import new Notion functions:**\n\n    import { deletePageContent, appendPageContent } from \"../services/notion.service.ts\";\n\n**2\\. Early initialization (after finding report page):**\n\n    // Set status to \"Working...\" \n    const statusUpdateResult = await updatePageStatus(reportPageId, \"Working...\");\n\n    // Clear existing content (clean slate)\n    const clearContentResult = await deletePageContent(reportPageId);\n\n**3\\. Replace batch processing with incremental loop:**\n\n    // OLD: Collect all results, then update once\n    const analyses: EnhancedQuestionAnalysis[] = [];\n    for (const question of questions) {\n      // analyze and push to analyses array\n    }\n    const contentBlocks = formatEnhancedReportContent(analyses);\n    await updatePageContent(reportPageId, contentBlocks);\n\n    // NEW: Process and immediately append each question\n    for (const question of questions) {\n      const analysisResult = await analyzeTranscriptsWithConsensus({...});\n      if (analysisResult.success) {\n        const questionAnalysis = { question: question.name, consensusAnswer: analysisResult.data };\n        const contentBlocks = formatEnhancedReportContent([questionAnalysis]);\n        await appendPageContent(reportPageId, contentBlocks);\n      } else {\n        const errorBlocks = createErrorBlock(question.name, analysisResult.error);\n        await appendPageContent(reportPageId, errorBlocks);\n      }\n    }\n\n**4\\. Add error block creation:**\n\n    function createErrorBlock(questionName: string, errorMessage: string): any[] {\n      return [\n        { object: \"block\", type: \"heading_2\", heading_2: { rich_text: [{ type: \"text\", text: { content: questionName } }] } },\n        { object: \"block\", type: \"callout\", callout: { \n          icon: { emoji: \"❌\" }, \n          rich_text: [{ type: \"text\", text: { content: `Error: ${errorMessage}` }, annotations: { bold: true, color: \"red\" } }] \n        }},\n        { object: \"block\", type: \"divider\", divider: {} }\n      ];\n    }\n\n**5\\. Track success metrics:**\n\n    let questionsProcessed = 0;\n    let questionsSucceeded = 0;\n    // Increment in loop, return both in response\n\n**Business logic handled by controller:**\n\n- Environment variable validation\n- Status management (\"Not started\" → \"Working...\" → \"Done\")\n- Error recovery (continue processing other questions if one fails)\n- Progress tracking and logging\n- Data transformation between OpenAI and Notion formats\n\n## Step 4: Update Types (`/backend/types/findings.types.ts`)\n\n**Add to ProcessFindingsResponse:**\n\n    questionsSucceeded?: number;\n\n**Type responsibilities:**\n\n- Shared interfaces between layers\n- No business logic\n- Clear data contracts\n\n## Step 5: Update Cron Logging (`/backend/crons/findings-analysis.ts`)\n\n**Add logging for success metrics:**\n\n    if (result.success) {\n      console.log(`✅ Questions succeeded: ${result.questionsSucceeded}`);\n      if (result.questionsSucceeded !== result.questionsProcessed) {\n        console.log(`⚠️ Some questions failed: ${result.questionsProcessed - result.questionsSucceeded} errors`);\n      }\n    }\n\n**Cron responsibilities:**\n\n- Simple trigger mechanism\n- Basic logging of results\n- No business logic or error handling\n\n## Step 6: Test Implementation\n\n**Create temporary test endpoint:**\n\n    // /run-findings-cron.ts (HTTP)\n    import findingsAnalysisCron from \"./backend/crons/findings-analysis.ts\";\n    export default async function(req: Request) {\n      const result = await findingsAnalysisCron();\n      return new Response(JSON.stringify({ message: \"Cron execution completed\", result }, null, 2));\n    }\n\n**Test scenarios:**\n\n1. No syntax errors\n2. Handles \"No report pages found\" gracefully\n3. OpenAI service works with sample data\n4. Service response formats are consistent\n\n## Step 7: Clean Up\n\n**Remove test endpoint after verification**\n\n## Expected Outcome\n\n**Separation of concerns achieved:**\n\n- **Cron**: Minimal trigger\n- **Controller**: Business orchestration, environment handling, error recovery\n- **Services**: Pure API calls with consistent responses\n- **Types**: Clear data contracts\n\n**For 30 questions, users will see:**\n\n1. Report status changes to \"Working...\" immediately\n2. Questions appear in Notion one by one as they complete\n3. Failed questions show error blocks instead of breaking the entire process\n4. Final status shows \"Done\" with success metrics\n5. No timeouts or memory issues\n6. Fault tolerance - partial results preserved if process fails mid-way\n\n**Performance:**\n\n- ~70% cost reduction using gpt-4o-mini for Stage 1\n- Real-time progress visibility\n- Handles failures gracefully\n- Scales to 30+ questions without issues\n\n## Updated Instructions: Add Timing Capture\n\n### Step 3 Enhancement: Add Timing to Controller (`/backend/controllers/findings.controller.ts`)\n\n**Add timing capture at the start of processing:**\n\n    // After clearing page content, capture start time\n    const processingStartTime = new Date();\n    console.log(`⏱️ Starting question processing at ${processingStartTime.toISOString()}`);\n\n**Add timing capture after all questions are processed:**\n\n    // After the incremental processing loop, before final status update\n    const processingEndTime = new Date();\n    const totalTimeMs = processingEndTime.getTime() - processingStartTime.getTime();\n    const totalMinutes = Math.floor(totalTimeMs / 60000);\n    const totalSeconds = Math.floor((totalTimeMs % 60000) / 1000);\n\n    console.log(`⏱️ Completed question processing at ${processingEndTime.toISOString()}`);\n    console.log(`⏱️ Total processing time: ${totalMinutes}m ${totalSeconds}s`);\n\n    // Create timing summary block\n    const timingSummaryBlocks = createTimingSummaryBlock(totalMinutes, totalSeconds, questionsProcessed, questionsSucceeded);\n\n    // Append timing summary as final block\n    const timingAppendResult = await appendPageContent(reportPageId, timingSummaryBlocks);\n    if (!timingAppendResult.success) {\n      console.error(`⚠️ Failed to append timing summary: ${timingAppendResult.error}`);\n    }\n\n**Add timing summary block creation function:**\n\n    /**\n     * Create timing summary block for the end of the report\n     */\n    function createTimingSummaryBlock(minutes: number, seconds: number, totalQuestions: number, successfulQuestions: number): any[] {\n      const timeDisplay = minutes > 0 ? `${minutes}m ${seconds}s` : `${seconds}s`;\n      const successRate = Math.round((successfulQuestions / totalQuestions) * 100);\n      \n      return [\n        {\n          object: \"block\",\n          type: \"divider\",\n          divider: {}\n        },\n        {\n          object: \"block\",\n          type: \"heading_3\",\n          heading_3: {\n            rich_text: [\n              {\n                type: \"text\",\n                text: {\n                  content: \"📊 Report Generation Summary\"\n                }\n              }\n            ]\n          }\n        },\n        {\n          object: \"block\",\n          type: \"callout\",\n          callout: {\n            icon: { emoji: \"⏱️\" },\n            rich_text: [\n              {\n                type: \"text\",\n                text: {\n                  content: `Total time to generate report: ${timeDisplay}`\n                },\n                annotations: { bold: true }\n              }\n            ]\n          }\n        },\n        {\n          object: \"block\",\n          type: \"paragraph\",\n          paragraph: {\n            rich_text: [\n              {\n                type: \"text\",\n                text: {\n                  content: `Questions processed: ${successfulQuestions}/${totalQuestions} (${successRate}% success rate)`\n                }\n              }\n            ]\n          }\n        },\n        {\n          object: \"block\",\n          type: \"paragraph\",\n          paragraph: {\n            rich_text: [\n              {\n                type: \"text\",\n                text: {\n                  content: `Generated on: ${new Date().toLocaleString()}`\n                },\n                annotations: { italic: true, color: \"gray\" }\n              }\n            ]\n          }\n        }\n      ];\n    }\n\n### Updated Processing Flow\n\n**The complete timing flow:**\n\n1. Find report page → Set status to \"Working...\" → Clear content\n2. **Capture start time** ⏱️\n3. Process each question incrementally (append immediately)\n4. **Capture end time** ⏱️\n5. **Calculate and append timing summary** 📊\n6. Set status to \"Done\"\n\n### Expected Output\n\n**At the bottom of every report, users will see:**\n\n    📊 Report Generation Summary\n\n    ⏱️ Total time to generate report: 3m 45s\n\n    Questions processed: 28/30 (93% success rate)\n\n    Generated on: 8/15/2025, 3:45:23 PM\n\n**Benefits:**\n\n- ✅ Users can see how long the analysis took\n- ✅ Performance tracking for optimization\n- ✅ Success rate visibility\n- ✅ Clear completion timestamp\n- ✅ Professional report footer\n\n**Implementation notes:**\n\n- Time calculation excludes initial setup (finding pages, fetching data)\n- Focuses on actual question processing time\n- Handles both successful and failed questions in timing\n- Timing block is always appended, even if some questions fail",[],[156,209],{"_104":217,"_95":218,"_157":219,"_159":158,"_160":139,"_161":220,"_163":164,"_106":221,"_100":32,"_166":179,"_168":222,"_169":22,"_170":-5,"_171":223,"_98":224},"c8fa0d2a-79c6-11f0-95e0-0224a6c84d84","pdf-to-blob.md","c8fa0dd4-79c6-11f0-95e0-0224a6c84d84",6,["D",1755255513063],"# Complete Instructions for Creating the `/tasks/blob` Endpoint\n\n## Overview\n\nCreate a webhook endpoint that processes PDF text extraction and blob storage\nfor Notion pages, following the established separation of concerns architecture.\n\n## Prerequisites\n\nBefore starting, verify these files exist and understand their current state:\n\n- `/backend/routes/tasks/_tasks.routes.ts` (route definitions)\n- `/backend/controllers/tasks.controller.ts` (business logic)\n- `/backend/services/notion.service.ts` (Notion API calls)\n- `/backend/utils/pdfExtractor.ts` (PDF processing utilities)\n- `/backend/types/` (type definitions directory)\n\n## Step 1: Create Type Definitions\n\nCreate or update `/backend/types/tasks.types.ts` with the following content:\n\n    /**\n     * Task processing type definitions\n     */\n\n    export interface ProcessBlobRequest {\n      pageId: string;\n    }\n\n    export interface ProcessBlobResponse {\n      success: boolean;\n      pageId: string;\n      blobKey?: string;\n      textLength?: number;\n      statusUpdated?: boolean;\n      timestamp: string;\n      error?: string;\n      details?: string;\n    }\n\n    export interface WebhookPayload {\n      data: {\n        id: string;\n        [key: string]: any;\n      };\n      [key: string]: any;\n    }\n\n    export interface NotionPageProperties {\n      id: string;\n      properties: {\n        PDF?: {\n          type: 'files';\n          files: Array<{\n            type: 'external' | 'file';\n            external?: { url: string };\n            file?: { url: string };\n          }>;\n        };\n        [key: string]: any;\n      };\n    }\n\n## Step 2: Add Required Imports to Route File\n\nIn `/backend/routes/tasks/_tasks.routes.ts`, ensure these imports are present at\nthe top:\n\n    import { Hono } from \"npm:hono@3.12.12\";\n    import { processBlobExtraction, extractPageIdFromWebhook } from \"../../controllers/tasks.controller.ts\";\n\n## Step 3: Add Route Handler\n\nIn `/backend/routes/tasks/_tasks.routes.ts`, add this endpoint **before** the\ncatch-all handler (the `app.post(\"*\", ...)` route):\n\n    // PDF text extraction and blob storage endpoint\n    app.post(\"/blob\", async (c) => {\n      try {\n        // At this point, webhook auth has already passed\n        const body = await c.req.json();\n        console.log(\"📥 Blob processing webhook received:\", body);\n\n        // Extract page ID from webhook payload\n        const pageId = extractPageIdFromWebhook(body);\n        if (!pageId) {\n          return c.json({ error: \"Page ID is required\" }, 400);\n        }\n\n        // Process the blob extraction using controller\n        const result = await processBlobExtraction({ pageId });\n\n        // Return appropriate HTTP status based on result\n        if (result.success) {\n          return c.json(result);\n        } else {\n          const statusCode = result.error?.includes(\"No PDF\") || result.error?.includes(\"No text\") ? 400 : 500;\n          return c.json(result, statusCode);\n        }\n\n      } catch (error) {\n        console.error(\"❌ Error in blob endpoint:\", error);\n        return c.json({ \n          error: \"Internal server error\", \n          details: error.message,\n          timestamp: new Date().toISOString()\n        }, 500);\n      }\n    });\n\n## Step 4: Update Available Endpoints List\n\nIn the same file, find the catch-all handler and update the `availableEndpoints`\narray to include the new endpoint:\n\n    app.post(\"*\", (c) => {\n      const path = c.req.path;\n      const method = c.req.method;\n      const returnObj = {\n        error: \"Endpoint not found\",\n        path: path,\n        method: method,\n        availableEndpoints: [\n          \"GET /tasks/debug-webhook\",\n          \"POST /tasks/test\",\n          \"POST /tasks/notion-webhook\",\n          \"POST /tasks/blob\",  // <- Add this line\n        ],\n      };\n      console.log(returnObj);\n\n      return c.json(returnObj, 404);\n    });\n\n## Step 5: Add Required Imports to Controller\n\nIn `/backend/controllers/tasks.controller.ts`, ensure these imports are present\nat the top:\n\n    import { blob } from \"https://esm.town/v/std/blob\";\n    import { getPageProperties, updatePageStatus } from \"../services/notion.service.ts\";\n    import { extractTextFromPDFUrl } from \"../utils/pdfExtractor.ts\";\n    import type { \n      ProcessBlobRequest, \n      ProcessBlobResponse, \n      WebhookPayload, \n      NotionPageProperties \n    } from \"../types/tasks.types.ts\";\n\n## Step 6: Add Main Controller Function\n\nIn `/backend/controllers/tasks.controller.ts`, add this function:\n\n    /**\n     * Process PDF extraction and blob storage for a Notion page\n     */\n    export async function processBlobExtraction(request: ProcessBlobRequest): Promise {\n      const { pageId } = request;\n      const timestamp = new Date().toISOString();\n\n      try {\n        console.log(`🔍 Processing page: ${pageId}`);\n\n        // Get page properties from Notion\n        const pageResult = await getPageProperties(pageId);\n        if (!pageResult.success) {\n          console.error(`❌ Failed to get page properties: ${pageResult.error}`);\n          return {\n            success: false,\n            pageId,\n            timestamp,\n            error: `Failed to get page properties: ${pageResult.error}`\n          };\n        }\n\n        const page = pageResult.data;\n        console.log(`📄 Retrieved page properties for: ${page.id}`);\n\n        // Extract PDF URL from page properties\n        const pdfUrl = extractPdfUrl(page);\n        if (!pdfUrl) {\n          console.error(\"❌ No valid PDF found on page\");\n          return {\n            success: false,\n            pageId,\n            timestamp,\n            error: \"No PDF files found in PDF property\"\n          };\n        }\n\n        console.log(`📎 Found PDF URL: ${pdfUrl}`);\n\n        // Extract text from PDF\n        console.log(\"🔄 Starting PDF text extraction...\");\n        const extractedText = await extractTextFromPDFUrl(pdfUrl);\n        \n        if (!extractedText || extractedText.trim().length === 0) {\n          console.error(\"❌ No text extracted from PDF\");\n          return {\n            success: false,\n            pageId,\n            timestamp,\n            error: \"No text could be extracted from PDF\"\n          };\n        }\n\n        // Save extracted text to blob storage\n        const blobKey = `findings--transcripts--${pageId}`;\n        console.log(`💾 Saving extracted text to blob with key: ${blobKey}`);\n        \n        await blob.setJSON(blobKey, {\n          pageId: pageId,\n          extractedText: extractedText,\n          extractedAt: timestamp,\n          textLength: extractedText.length,\n          pdfUrl: pdfUrl\n        });\n\n        console.log(`✅ Text saved to blob storage successfully`);\n\n        // Update page status to \"Done\" and save blob key\n        console.log(\"🔄 Updating page status to 'Done' and saving blob key...\");\n        const statusResult = await updatePageStatus(pageId, \"Done\", blobKey);\n        if (!statusResult.success) {\n          console.error(`⚠️ Failed to update page status: ${statusResult.error}`);\n          // Don't fail the entire operation if status update fails\n        } else {\n          console.log(\"✅ Page status updated to 'Done' and blob key saved\");\n        }\n\n        return {\n          success: true,\n          pageId,\n          blobKey,\n          textLength: extractedText.length,\n          statusUpdated: statusResult.success,\n          timestamp\n        };\n\n      } catch (error) {\n        console.error(\"❌ Error processing blob extraction:\", error);\n        return {\n          success: false,\n          pageId,\n          timestamp,\n          error: \"Internal server error\",\n          details: error.message\n        };\n      }\n    }\n\n## Step 7: Add Helper Functions to Controller\n\nIn `/backend/controllers/tasks.controller.ts`, add these helper functions:\n\n    /**\n     * Extract PDF URL from Notion page properties\n     */\n    function extractPdfUrl(page: NotionPageProperties): string | null {\n      // Extract PDF property\n      const pdfProperty = page.properties?.PDF;\n      if (!pdfProperty || pdfProperty.type !== 'files') {\n        console.error(\"❌ No PDF property found or property is not of type 'files'\");\n        return null;\n      }\n\n      const files = pdfProperty.files;\n      if (!files || files.length === 0) {\n        console.error(\"❌ No files found in PDF property\");\n        return null;\n      }\n\n      // Get the first (and should be only) PDF file\n      const pdfFile = files[0];\n      if (!pdfFile) {\n        console.error(\"❌ PDF file is null or undefined\");\n        return null;\n      }\n\n      // Get the file URL (handle both external and Notion-hosted files)\n      if (pdfFile.type === 'external') {\n        return pdfFile.external?.url || null;\n      } else if (pdfFile.type === 'file') {\n        return pdfFile.file?.url || null;\n      } else {\n        console.error(\"❌ Unknown PDF file type:\", pdfFile.type);\n        return null;\n      }\n    }\n\n    /**\n     * Extract page ID from Notion webhook payload\n     */\n    export function extractPageIdFromWebhook(webhookBody: WebhookPayload): string | null {\n      const pageId = webhookBody.data?.id;\n      if (!pageId) {\n        console.error(\"❌ No page ID found in webhook payload\", JSON.stringify(webhookBody, null, 2));\n        return null;\n      }\n      return pageId;\n    }\n\n## Step 8: Verify Required Service Functions\n\nCheck that `/backend/services/notion.service.ts` contains these functions. If\nthey don't exist, add them:\n\n    import { Client } from \"npm:@notionhq/client\";\n\n    const notion = new Client({ auth: Deno.env.get(\"NOTION_API_KEY\") });\n\n    export async function getPageProperties(pageId: string) {\n      try {\n        const response = await notion.pages.retrieve({\n          page_id: pageId,\n        });\n        return {\n          success: true,\n          data: response,\n          timestamp: new Date().toISOString(),\n        };\n      } catch (error) {\n        return {\n          success: false,\n          error: error.message,\n          timestamp: new Date().toISOString(),\n        };\n      }\n    }\n\n    export async function updatePageStatus(pageId: string, status: string, blobKey?: string) {\n      try {\n        const properties: any = {\n          Status: {\n            select: {\n              name: status\n            }\n          }\n        };\n\n        // Add blob key if provided\n        if (blobKey) {\n          properties[\"Blob Key\"] = {\n            rich_text: [\n              {\n                text: {\n                  content: blobKey\n                }\n              }\n            ]\n          };\n        }\n\n        const response = await notion.pages.update({\n          page_id: pageId,\n          properties: properties\n        });\n\n        return {\n          success: true,\n          data: response,\n          timestamp: new Date().toISOString(),\n        };\n      } catch (error) {\n        return {\n          success: false,\n          error: error.message,\n          timestamp: new Date().toISOString(),\n        };\n      }\n    }\n\n## Step 9: Verify Required Utility Function\n\nCheck that `/backend/utils/pdfExtractor.ts` contains the `extractTextFromPDFUrl`\nfunction. If it doesn't exist, add it:\n\n    /**\n     * Extract text from a PDF file accessible via URL\n     */\n    export async function extractTextFromPDFUrl(pdfUrl: string): Promise {\n      try {\n        console.log(`📄 Downloading PDF from URL: ${pdfUrl}`);\n        \n        // Download the PDF file\n        const response = await fetch(pdfUrl);\n        if (!response.ok) {\n          throw new Error(`Failed to download PDF: ${response.status} ${response.statusText}`);\n        }\n        \n        const arrayBuffer = await response.arrayBuffer();\n        console.log(`📄 Downloaded PDF, size: ${arrayBuffer.byteLength} bytes`);\n        \n        // Use pdfjs-dist to extract text\n        const pdfjsLib = await import(\"https://esm.sh/pdfjs-dist@4.0.379/legacy/build/pdf.mjs\");\n        \n        // Load the PDF document\n        const loadingTask = pdfjsLib.getDocument({ data: arrayBuffer });\n        const pdfDocument = await loadingTask.promise;\n        \n        console.log(`📄 PDF loaded with ${pdfDocument.numPages} pages`);\n        \n        // Extract text from all pages\n        let fullText = '';\n        for (let pageNum = 1; pageNum <= pdfDocument.numPages; pageNum++) {\n          const page = await pdfDocument.getPage(pageNum);\n          const textContent = await page.getTextContent();\n          \n          // Combine text items into a single string\n          const pageText = textContent.items\n            .map((item: any) => item.str)\n            .join(' ');\n          \n          fullText += pageText + '\\n';\n          console.log(`📄 Extracted text from page ${pageNum}: ${pageText.length} characters`);\n        }\n        \n        console.log(`✅ Total extracted text: ${fullText.length} characters`);\n        return fullText.trim();\n        \n      } catch (error) {\n        console.error(\"❌ Error extracting text from PDF URL:\", error);\n        throw new Error(`PDF text extraction failed: ${error.message}`);\n      }\n    }\n\n## Step 10: Test the Implementation\n\n### Test 1: Basic Functionality Test\n\n    # Use the fetch tool to test the endpoint\n    fetch(\"/tasks/blob\", {\n      method: \"POST\",\n      body: JSON.stringify({\n        data: {\n          id: \"test-page-id-123\"\n        }\n      }),\n      headers: {\n        \"Content-Type\": \"application/json\"\n      }\n    })\n\n### Test 2: Error Handling Test\n\n    # Test with invalid payload\n    fetch(\"/tasks/blob\", {\n      method: \"POST\", \n      body: JSON.stringify({\n        data: {} // Missing id\n      }),\n      headers: {\n        \"Content-Type\": \"application/json\"\n      }\n    })\n\n### Test 3: Check Logs\n\n    # Use the requests tool to examine execution logs\n    requests(\"main.tsx\")\n\n## Step 11: Verification Checklist\n\nAfter implementation, verify:\n\n- \\[ \\] **Types file created**: `/backend/types/tasks.types.ts` exists with all\n  required interfaces\n- \\[ \\] **Route handler added**: Endpoint is in\n  `/backend/routes/tasks/_tasks.routes.ts` before catch-all handler\n- \\[ \\] **Imports correct**: All files have proper import statements with\n  correct paths\n- \\[ \\] **Controller function**: `processBlobExtraction` exists in tasks\n  controller with proper typing\n- \\[ \\] **Helper functions**: `extractPageIdFromWebhook` and `extractPdfUrl`\n  exist with proper typing\n- \\[ \\] **Service functions**: `getPageProperties` and `updatePageStatus` exist\n  in notion service\n- \\[ \\] **Utility function**: `extractTextFromPDFUrl` exists in PDF extractor\n  utility\n- \\[ \\] **Available endpoints updated**: New endpoint listed in catch-all\n  handler\n- \\[ \\] **Blob storage format**: Uses key format\n  `findings--transcripts--{pageId}`\n- \\[ \\] **Error handling**: Proper HTTP status codes (400 for client errors, 500\n  for server errors)\n- \\[ \\] **Logging consistency**: All console.log statements use emoji prefixes\n- \\[ \\] **Type safety**: No `any` types used except where necessary for external\n  APIs\n\n## Expected Behavior\n\n**Successful Request:**\n\n- Status: 200\n- Response:\n\n  { \"success\": true, \"pageId\": \"abc123\", \"blobKey\":\n  \"findings--transcripts--abc123\", \"textLength\": 1234, \"statusUpdated\": true,\n  \"timestamp\": \"2024-01-01T12:00:00.000Z\" }\n\n**Missing Page ID:**\n\n- Status: 400\n- Response:\n\n  { \"error\": \"Page ID is required\" }\n\n**No PDF Found:**\n\n- Status: 400\n- Response:\n\n  { \"success\": false, \"pageId\": \"abc123\", \"error\": \"No PDF files found in PDF\n  property\", \"timestamp\": \"2024-01-01T12:00:00.000Z\" }\n\n**Internal Error:**\n\n- Status: 500\n- Response:\n\n  { \"error\": \"Internal server error\", \"details\": \"Specific error message\",\n  \"timestamp\": \"2024-01-01T12:00:00.000Z\" }\n\n## Architecture Compliance\n\nThis implementation follows the established patterns:\n\n- **Routes**: Handle HTTP request/response only, delegate to controllers\n- **Controllers**: Orchestrate business logic, call services and utilities\n- **Services**: Make pure API calls to external systems (Notion)\n- **Utils**: Provide reusable utility functions (PDF processing)\n- **Types**: Centralized type definitions shared across modules\n- **Error Handling**: Consistent success/error response patterns\n- **Logging**: Emoji-prefixed console logs for easy debugging\n\nThe endpoint integrates seamlessly with existing webhook authentication\nmiddleware and follows the same patterns as other endpoints in the project.",[],[156,218],[156],{"_104":227,"_95":228,"_157":229,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":230,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":231,"_98":531},"d0f9e7f4-7951-11f0-8810-0224a6c84d84","backend","0198aa63-0ee2-725e-8c9f-fc915e8caa81",["D",1755205275298],[232,285,310,425,456,478,524],{"_104":233,"_95":234,"_157":235,"_159":229,"_160":139,"_161":162,"_163":164,"_106":236,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":237,"_98":284},"d0f9b68a-7951-11f0-8810-0224a6c84d84","controllers","0198aa63-0ee2-725e-8c9f-952287ab9a39",["D",1755205275298],[238,248,258,267,275],{"_104":239,"_95":240,"_157":241,"_159":235,"_160":139,"_161":242,"_163":22,"_106":243,"_100":244,"_166":179,"_168":245,"_169":22,"_170":-5,"_171":246,"_98":247},"9118cbc2-7a3d-11f0-b176-0224a6c84d84","README.md","0198aa63-0ee2-725e-8c9f-8c3d44adcdc9",26,["D",1755306529418],3,"# Controllers\n\nBusiness logic coordination between routes and services. Controllers should:\n\n- Handle environment variables and configuration\n- Coordinate multiple service calls\n- Implement business rules and validation\n- Handle service business logic layer (result.success)\n\n## Available Controllers\n\n- `tasks.controller.ts` - Handles PDF extraction, blob storage, and page duplication workflows for Notion webhooks\n  - **Page Duplication**: Includes content filtering and H3-to-paragraph transformation for \"Key findings\" and \"Notable disagreements\"\n- `health.controller.ts` - System health checks\n- `findings.controller.ts` - Handles findings analysis workflow using ChatGPT and Notion integration",[],[228,234,240],{"_104":249,"_95":250,"_157":251,"_159":235,"_160":139,"_161":101,"_163":22,"_106":252,"_100":253,"_166":254,"_168":255,"_169":22,"_170":-5,"_171":256,"_98":257},"00e25294-82df-11f0-b5a9-0224a6c84d84","findings.controller.ts","82c445de-7a05-11f0-9236-0224a6c84d84",["D",1756255475247],5,"script","/**\n * Findings Controller\n * Business logic for findings analysis workflow\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport {\n  queryDatabasePages,\n  getDatabasePages,\n  updatePageContent,\n  updatePageStatus,\n  deletePageContent,\n  appendPageContent,\n  updatePageProperties,\n  createInlineDatabase,\n  createPageInDatabaseWithContent,\n  getPageProperties,\n} from \"../services/notion.service.ts\";\nimport {\n  analyzeTranscriptsForQuestion,\n  analyzeTranscriptsWithConsensus,\n} from \"../services/openai.service.ts\";\nimport { createTimestampProperties, createAnalysisResultsDatabaseSchema, createResultsDatabaseProperty } from \"../utils/notion-properties.utils.ts\";\nimport {\n  calculateDuration,\n  createTimingSummaryBlocks,\n} from \"../utils/process-timing.utils.ts\";\nimport type {\n  ProcessFindingsRequest,\n  ProcessFindingsResponse,\n  FindingsQuestion,\n  TranscriptPage,\n  TranscriptBlob,\n  QuestionAnalysis,\n  EnhancedQuestionAnalysis,\n  ConsensusAnswer,\n} from \"../types/findings.types.ts\";\n\n/**\n * Main function to process findings analysis with batched processing\n */\nexport async function processFindings(\n  request: ProcessFindingsRequest\n): Promise {\n  const timestamp = new Date().toISOString();\n  let reportPageId: string | undefined;\n  let resultsDatabaseId: string | undefined;\n  const BATCH_SIZE = 5; // Process 5 questions per batch\n\n  try {\n    console.log(\"🔍 Starting findings analysis process...\");\n\n    // Get environment variables\n    const reportsDbId = Deno.env.get(\"FINDINGS_REPORTS_RAW_DB_ID\");\n    const questionsDbId = Deno.env.get(\"FINDINGS_QUESTIONS_DB_ID\");\n    const transcriptsDbId = Deno.env.get(\"FINDINGS_TRANSCRIPTS_DB_ID\");\n    const openaiApiKey = Deno.env.get(\"OPENAI_API_KEY\");\n\n    if (!reportsDbId || !questionsDbId || !transcriptsDbId || !openaiApiKey) {\n      return {\n        success: false,\n        error: \"Missing required environment variables\",\n        timestamp,\n      };\n    }\n\n    // Step 1: Get report page (Status = \"Ready\" OR \"Working...\")\n    console.log(\"📊 Querying reports database for 'Ready' status...\");\n    const notStartedReportsResult = await queryDatabasePages(reportsDbId, {\n      property: \"Status\",\n      select: {\n        equals: \"Ready\",\n      },\n    });\n\n    console.log(\"📊 Querying reports database for 'Working...' status...\");\n    const workingReportsResult = await queryDatabasePages(reportsDbId, {\n      property: \"Status\",\n      select: {\n        equals: \"Working...\",\n      },\n    });\n\n    if (!notStartedReportsResult.success || !workingReportsResult.success) {\n      return {\n        success: false,\n        error: `Failed to query reports database: ${\n          notStartedReportsResult.error || workingReportsResult.error\n        }`,\n        timestamp,\n      };\n    }\n\n    const notStartedReports = notStartedReportsResult.data.results;\n    const workingReports = workingReportsResult.data.results;\n\n    if (notStartedReports.length === 0 && workingReports.length === 0) {\n      return {\n        success: false,\n        error:\n          \"No report pages found with Status 'Ready' or 'Working...'\",\n        timestamp,\n      };\n    }\n\n    // Prioritize \"Ready\" reports over \"Working...\" reports\n    if (notStartedReports.length > 0) {\n      // New report found - initialize it\n      reportPageId = notStartedReports[0].id;\n      console.log(`📄 Found new report page: ${reportPageId}`);\n\n      // Initialize: Reset all questions to \"Not started\" and create results database\n      resultsDatabaseId = await initializeNewReport(reportPageId, questionsDbId);\n      if (!resultsDatabaseId) {\n        return {\n          success: false,\n          error: \"Failed to initialize new report and create results database\",\n          timestamp,\n        };\n      }\n    } else {\n      // Continue with existing \"Working...\" report\n      reportPageId = workingReports[0].id;\n      console.log(`📄 Continuing with working report page: ${reportPageId}`);\n      \n      // For existing reports, we need to find the existing results database\n      // This is a simplified approach - in production you might want to store the database ID\n      console.log(\"🔍 Looking for existing Analysis Results database...\");\n      // For now, we'll create a new database if we can't find one\n      // In a more robust implementation, you'd store the database ID in the report page properties\n      resultsDatabaseId = await findOrCreateResultsDatabase(reportPageId);\n      if (!resultsDatabaseId) {\n        return {\n          success: false,\n          error: \"Failed to find or create results database for existing report\",\n          timestamp,\n        };\n      }\n    }\n\n    // Step 2: Get next batch of questions to process\n    console.log(\n      `❓ Fetching next batch of ${BATCH_SIZE} questions with 'Not started' status...`\n    );\n    const questionsResult = await queryDatabasePages(questionsDbId, {\n      property: \"Status\",\n      select: {\n        equals: \"Not started\",\n      },\n    });\n\n    if (!questionsResult.success) {\n      return {\n        success: false,\n        error: `Failed to get questions: ${questionsResult.error}`,\n        timestamp,\n      };\n    }\n\n    const allNotStartedQuestions = extractQuestions(\n      questionsResult.data.results\n    );\n\n    if (allNotStartedQuestions.length === 0) {\n      // No more questions to process - check if we're done\n      return await checkAndFinalizeReport(\n        reportPageId,\n        questionsDbId,\n        timestamp\n      );\n    }\n\n    // Take only the batch size we can handle\n    const questionsToProcess = allNotStartedQuestions.slice(0, BATCH_SIZE);\n    console.log(\n      `📝 Processing batch of ${questionsToProcess.length} questions (${allNotStartedQuestions.length} total remaining)`\n    );\n\n    // Step 3: Mark selected questions as \"Working...\"\n    console.log(\"🔄 Marking selected questions as 'Working...'\");\n    for (const question of questionsToProcess) {\n      const updateResult = await updatePageProperties(question.id, {\n        Status: {\n          select: {\n            name: \"Working...\",\n          },\n        },\n      });\n\n      if (!updateResult.success) {\n        console.error(\n          `⚠️ Failed to update question ${question.id} status: ${updateResult.error}`\n        );\n      }\n    }\n\n    // Step 4: Get transcript data (only once per batch)\n    console.log(\"📋 Fetching transcript pages...\");\n    const transcriptsResult = await getDatabasePages(transcriptsDbId);\n    if (!transcriptsResult.success) {\n      return {\n        success: false,\n        error: `Failed to get transcripts: ${transcriptsResult.error}`,\n        timestamp,\n      };\n    }\n\n    const transcriptPages = extractTranscriptPages(\n      transcriptsResult.data.results\n    );\n    console.log(`🗂️ Found ${transcriptPages.length} transcript pages`);\n\n    // Step 5: Fetch transcript blobs\n    console.log(\"💾 Fetching transcript blobs...\");\n    const transcriptTexts = await fetchTranscriptBlobs(\n      transcriptPages.map((t) => t.blobKey)\n    );\n    console.log(\n      `📄 Successfully fetched ${transcriptTexts.length} transcripts`\n    );\n\n    // Step 6: Process each question in the batch\n    console.log(\"🤖 Processing questions batch...\");\n    const batchStartTime = new Date();\n\n    let questionsProcessed = 0;\n    let questionsSucceeded = 0;\n\n    for (const question of questionsToProcess) {\n      console.log(\n        `🔍 Analyzing question ${questionsProcessed + 1}/${\n          questionsToProcess.length\n        }: ${question.name}`\n      );\n\n      try {\n        const analysisResult = await analyzeTranscriptsWithConsensus({\n          question: question.name,\n          transcripts: transcriptTexts,\n          apiKey: openaiApiKey,\n        });\n\n        if (analysisResult.success && analysisResult.data) {\n          // Create child page in results database\n          const consensus = analysisResult.data;\n          \n          // Prepare page properties\n          const pageProperties = {\n            \"Name\": {\n              title: [\n                {\n                  text: {\n                    content: question.name\n                  }\n                }\n              ]\n            },\n            \"Consensus Level\": {\n              select: {\n                name: consensus.consensusLevel === \"high\" ? \"High\" : \n                       consensus.consensusLevel === \"medium\" ? \"Medium\" : \"Low\"\n              }\n            },\n            \"Confidence Score\": {\n              number: consensus.confidence\n            },\n            \"Status\": {\n              select: {\n                name: \"Done\"\n              }\n            }\n          };\n\n          // Prepare page content blocks\n          const contentBlocks = formatEnhancedReportContent([{\n            question: question.name,\n            consensusAnswer: consensus\n          }]);\n\n          // Create the child page with content\n          const createPageResult = await createPageInDatabaseWithContent(\n            resultsDatabaseId!,\n            pageProperties,\n            contentBlocks\n          );\n\n          if (createPageResult.success) {\n            questionsSucceeded++;\n            console.log(\n              `✅ Question ${\n                questionsProcessed + 1\n              } completed and added as child page (Consensus: ${\n                consensus.consensusLevel\n              }, Confidence: ${Math.round(\n                consensus.confidence * 100\n              )}%)`\n            );\n\n            // Mark question as \"Done\"\n            await updatePageProperties(question.id, {\n              Status: {\n                select: {\n                  name: \"Done\",\n                },\n              },\n            });\n          } else {\n            console.error(\n              `❌ Failed to create child page for question ${\n                questionsProcessed + 1\n              }: ${createPageResult.error}`\n            );\n            \n            // Create error page\n            await createErrorPage(\n              resultsDatabaseId!,\n              question.name,\n              `Failed to create result page: ${createPageResult.error}`\n            );\n\n            // Mark question as \"Error\"\n            await updatePageProperties(question.id, {\n              Status: {\n                select: {\n                  name: \"Error\",\n                },\n              },\n            });\n          }\n        } else {\n          console.error(\n            `❌ Failed to analyze question ${questionsProcessed + 1}: ${\n              analysisResult.error\n            }`\n          );\n          \n          // Create error page for failed analysis\n          await createErrorPage(\n            resultsDatabaseId!,\n            question.name,\n            `Analysis failed: ${analysisResult.error}`\n          );\n\n          // Mark question as \"Error\"\n          await updatePageProperties(question.id, {\n            Status: {\n              select: {\n                name: \"Error\",\n              },\n            },\n          });\n        }\n      } catch (error) {\n        console.error(\n          `❌ Unexpected error processing question ${questionsProcessed + 1}:`,\n          error\n        );\n        \n        // Create error page for unexpected errors\n        await createErrorPage(\n          resultsDatabaseId!,\n          question.name,\n          `Unexpected error: ${error.message}`\n        );\n\n        // Mark question as \"Error\"\n        await updatePageProperties(question.id, {\n          Status: {\n            select: {\n              name: \"Error\",\n            },\n          },\n        });\n      }\n\n      questionsProcessed++;\n    }\n\n    // Calculate batch processing time\n    const batchEndTime = new Date();\n    const batchDuration = calculateDuration(batchStartTime, batchEndTime);\n    console.log(\n      `⏱️ Batch processing time: ${batchDuration.minutes}m ${batchDuration.seconds}s`\n    );\n\n    // Check if all questions are now complete\n    console.log(\"🔍 Checking for remaining incomplete questions...\");\n    const incompleteQuestionsResult = await queryDatabasePages(questionsDbId, {\n      property: \"Status\",\n      select: {\n        does_not_equal: \"Done\",\n      },\n    });\n\n    const remainingQuestions = incompleteQuestionsResult.success\n      ? incompleteQuestionsResult.data.results.length\n      : 0;\n    console.log(`📊 Found ${remainingQuestions} questions that are not 'Done'`);\n\n    if (remainingQuestions === 0) {\n      // All questions processed - finalize the report\n      console.log(\"🎉 All questions processed! Finalizing report...\");\n      return await finalizeReport(reportPageId, questionsDbId, timestamp);\n    } else {\n      console.log(\n        `📊 Batch complete. ${remainingQuestions} questions remaining for next cron run.`\n      );\n\n      return {\n        success: true,\n        reportPageId,\n        questionsProcessed: questionsToProcess.length,\n        questionsSucceeded,\n        transcriptsAnalyzed: transcriptTexts.length,\n        timestamp,\n        remainingQuestions,\n      };\n    }\n  } catch (error) {\n    console.error(\"❌ Error in findings analysis:\", error);\n\n    // Try to record error status if we have a report page\n    if (reportPageId) {\n      const errorEndTime = new Date();\n      console.log(`⏱️ Recording error end time: ${errorEndTime.toISOString()}`);\n\n      const errorStatusResult = await updatePageProperties(\n        reportPageId,\n        createTimestampProperties(undefined, errorEndTime, \"Error\")\n      );\n\n      if (!errorStatusResult.success) {\n        console.error(\n          `⚠️ Failed to update error status and end time: ${errorStatusResult.error}`\n        );\n      } else {\n        console.log(\"✅ Error status and end time recorded in database\");\n      }\n    }\n\n    return {\n      success: false,\n      error: \"Internal server error\",\n      details: error.message,\n      timestamp,\n    };\n  }\n}\n\n/**\n * Initialize a new report by resetting all questions and creating the results database\n */\nasync function initializeNewReport(\n  reportPageId: string,\n  questionsDbId: string\n): Promise {\n  console.log(\"🔄 Initializing new report...\");\n\n  // Capture and record start time immediately\n  const processStartTime = new Date();\n  console.log(`⏱️ Recording start time: ${processStartTime.toISOString()}`);\n\n  const startTimeResult = await updatePageProperties(\n    reportPageId,\n    createTimestampProperties(processStartTime, undefined, \"Working...\")\n  );\n\n  if (!startTimeResult.success) {\n    console.error(`⚠️ Failed to update start time: ${startTimeResult.error}`);\n  } else {\n    console.log(\"✅ Start time recorded in database\");\n  }\n\n  // Clear page content\n  console.log(\"🗑️ Clearing existing page content...\");\n  const clearContentResult = await deletePageContent(reportPageId);\n  if (!clearContentResult.success) {\n    console.error(\n      `⚠️ Failed to clear page content: ${clearContentResult.error}`\n    );\n  } else {\n    console.log(\n      `🗑️ Cleared ${clearContentResult.data.deletedBlocks} existing blocks`\n    );\n  }\n\n  // Create inline database for analysis results\n  console.log(\"📊 Creating Analysis Results database...\");\n  const databaseProperties = createAnalysisResultsDatabaseSchema();\n\n  const createDbResult = await createInlineDatabase(\n    reportPageId,\n    \"Analysis Results\",\n    databaseProperties\n  );\n\n  if (!createDbResult.success) {\n    console.error(`❌ Failed to create inline database: ${createDbResult.error}`);\n    return null;\n  }\n\n  const resultsDatabaseId = createDbResult.data.databaseId;\n  console.log(`✅ Created Analysis Results database: ${resultsDatabaseId}`);\n\n  // Store the database ID in the report page properties\n  console.log(\"💾 Storing database ID in report page properties...\");\n  const storeDatabaseIdResult = await updatePageProperties(\n    reportPageId,\n    createResultsDatabaseProperty(resultsDatabaseId)\n  );\n\n  if (!storeDatabaseIdResult.success) {\n    console.error(`⚠️ Failed to store database ID: ${storeDatabaseIdResult.error}`);\n  } else {\n    console.log(\"✅ Database ID stored in report page properties\");\n  }\n\n  // Reset all questions to \"Not started\"\n  console.log(\"🔄 Resetting all questions to 'Not started' status...\");\n  const allQuestionsResult = await getDatabasePages(questionsDbId);\n\n  if (allQuestionsResult.success) {\n    const allQuestions = extractQuestions(allQuestionsResult.data.results);\n    console.log(\n      `📝 Resetting ${allQuestions.length} questions to 'Not started'`\n    );\n\n    for (const question of allQuestions) {\n      const updateResult = await updatePageProperties(question.id, {\n        Status: {\n          select: {\n            name: \"Not started\",\n          },\n        },\n      });\n\n      if (!updateResult.success) {\n        console.error(\n          `⚠️ Failed to reset question ${question.id} status: ${updateResult.error}`\n        );\n      }\n    }\n\n    console.log(\"✅ All questions reset to 'Not started'\");\n  } else {\n    console.error(\n      `⚠️ Failed to get questions for reset: ${allQuestionsResult.error}`\n    );\n  }\n\n  return resultsDatabaseId;\n}\n\n/**\n * Find existing results database or create a new one for continuing reports\n */\nasync function findOrCreateResultsDatabase(reportPageId: string): Promise {\n  try {\n    // First, try to get the database ID from report page properties\n    console.log(\"🔍 Looking for existing Results Database ID in page properties...\");\n    const pagePropertiesResult = await getPageProperties(reportPageId);\n    \n    if (pagePropertiesResult.success) {\n      const resultsDatabaseId = extractResultsDatabaseId(pagePropertiesResult.data);\n      if (resultsDatabaseId) {\n        console.log(`✅ Found existing Results Database ID: ${resultsDatabaseId}`);\n        return resultsDatabaseId;\n      }\n    }\n    \n    console.log(\"📊 No existing database ID found, creating new Analysis Results database...\");\n    const databaseProperties = createAnalysisResultsDatabaseSchema();\n\n    const createDbResult = await createInlineDatabase(\n      reportPageId,\n      \"Analysis Results\",\n      databaseProperties\n    );\n\n    if (!createDbResult.success) {\n      console.error(`❌ Failed to create results database: ${createDbResult.error}`);\n      return null;\n    }\n\n    const resultsDatabaseId = createDbResult.data.databaseId;\n    console.log(`✅ Created Analysis Results database: ${resultsDatabaseId}`);\n    \n    // Store the database ID in the report page properties\n    console.log(\"💾 Storing database ID in report page properties...\");\n    const storeDatabaseIdResult = await updatePageProperties(\n      reportPageId,\n      createResultsDatabaseProperty(resultsDatabaseId)\n    );\n\n    if (!storeDatabaseIdResult.success) {\n      console.error(`⚠️ Failed to store database ID: ${storeDatabaseIdResult.error}`);\n    } else {\n      console.log(\"✅ Database ID stored in report page properties\");\n    }\n    \n    return resultsDatabaseId;\n  } catch (error) {\n    console.error(`❌ Error finding/creating results database:`, error);\n    return null;\n  }\n}\n\n/**\n * Create an error page in the results database\n */\nasync function createErrorPage(\n  databaseId: string,\n  questionName: string,\n  errorMessage: string\n): Promise {\n  try {\n    const pageProperties = {\n      \"Name\": {\n        title: [\n          {\n            text: {\n              content: questionName\n            }\n          }\n        ]\n      },\n      \"Consensus Level\": {\n        select: {\n          name: \"Low\"\n        }\n      },\n      \"Confidence Score\": {\n        number: 0\n      },\n      \"Status\": {\n        select: {\n          name: \"Error\"\n        }\n      }\n    };\n\n    const errorContent = [\n      {\n        object: \"block\",\n        type: \"callout\",\n        callout: {\n          icon: { emoji: \"❌\" },\n          rich_text: [\n            {\n              type: \"text\",\n              text: {\n                content: `Error: ${errorMessage}`,\n              },\n              annotations: { bold: true, color: \"red\" },\n            },\n          ],\n        },\n      },\n    ];\n\n    const createResult = await createPageInDatabaseWithContent(\n      databaseId,\n      pageProperties,\n      errorContent\n    );\n\n    if (!createResult.success) {\n      console.error(`❌ Failed to create error page: ${createResult.error}`);\n    }\n  } catch (error) {\n    console.error(`❌ Error creating error page:`, error);\n  }\n}\nasync function checkAndFinalizeReport(\n  reportPageId: string,\n  questionsDbId: string,\n  timestamp: string\n): Promise {\n  console.log(\"🔍 Checking if all questions are complete...\");\n\n  // Check for any remaining incomplete questions (any status other than \"Done\")\n  const incompleteQuestionsResult = await queryDatabasePages(questionsDbId, {\n    property: \"Status\",\n    select: {\n      does_not_equal: \"Done\",\n    },\n  });\n\n  if (\n    incompleteQuestionsResult.success &&\n    incompleteQuestionsResult.data.results.length > 0\n  ) {\n    const incompleteCount = incompleteQuestionsResult.data.results.length;\n    console.log(\n      `⚠️ Found ${incompleteCount} questions that are not 'Done'. Report is not ready for finalization.`\n    );\n\n    // Log the statuses for debugging\n    const statusCounts: Record = {};\n    for (const question of incompleteQuestionsResult.data.results) {\n      const status = question.properties?.Status?.select?.name || \"Unknown\";\n      statusCounts[status] = (statusCounts[status] || 0) + 1;\n    }\n    console.log(`📊 Incomplete question statuses:`, statusCounts);\n\n    return {\n      success: false,\n      error: `Report not ready: ${incompleteCount} questions are not complete`,\n      timestamp,\n      remainingQuestions: incompleteCount,\n    };\n  }\n\n  return await finalizeReport(reportPageId, questionsDbId, timestamp);\n}\n\n/**\n * Finalize the report by updating status and properties (no content summary)\n */\nasync function finalizeReport(\n  reportPageId: string,\n  questionsDbId: string,\n  timestamp: string\n): Promise {\n  console.log(\"🎉 Finalizing report...\");\n\n  // Get final counts\n  const doneQuestionsResult = await queryDatabasePages(questionsDbId, {\n    property: \"Status\",\n    select: {\n      equals: \"Done\",\n    },\n  });\n\n  const errorQuestionsResult = await queryDatabasePages(questionsDbId, {\n    property: \"Status\",\n    select: {\n      equals: \"Error\",\n    },\n  });\n\n  const allQuestionsResult = await getDatabasePages(questionsDbId);\n\n  const questionsSucceeded = doneQuestionsResult.success\n    ? doneQuestionsResult.data.results.length\n    : 0;\n  const questionsErrored = errorQuestionsResult.success\n    ? errorQuestionsResult.data.results.length\n    : 0;\n  const totalQuestions = allQuestionsResult.success\n    ? allQuestionsResult.data.results.length\n    : 0;\n\n  console.log(\n    `📊 Final counts: ${questionsSucceeded} succeeded, ${questionsErrored} errors, ${totalQuestions} total`\n  );\n\n  // Update report page status to \"Done\" and record end time\n  const processEndTime = new Date();\n  console.log(\n    \"🔄 Updating report page status to 'Done' and recording end time...\"\n  );\n  const finalStatusResult = await updatePageProperties(\n    reportPageId,\n    createTimestampProperties(undefined, processEndTime, \"Done\")\n  );\n\n  if (!finalStatusResult.success) {\n    console.error(\n      `⚠️ Failed to update end time and status: ${finalStatusResult.error}`\n    );\n  } else {\n    console.log(\n      \"✅ End time recorded and report page status updated to 'Done'\"\n    );\n  }\n\n  const successMessage =\n    questionsErrored === 0\n      ? \"✅ All questions processed successfully\"\n      : `⚠️ Completed with ${questionsErrored} errors: ${questionsSucceeded}/${totalQuestions} questions processed successfully`;\n\n  console.log(successMessage);\n\n  return {\n    success: true,\n    reportPageId,\n    questionsProcessed: totalQuestions,\n    questionsSucceeded,\n    transcriptsAnalyzed: 0, // Not tracked in batched mode\n    timestamp,\n  };\n}\n\n/**\n * Extract questions from Notion database pages\n */\nfunction extractQuestions(pages: any[]): FindingsQuestion[] {\n  return pages\n    .map((page) => ({\n      id: page.id,\n      name: extractNameProperty(page),\n    }))\n    .filter((q) => q.name); // Filter out pages without names\n}\n\n/**\n * Extract transcript pages with blob keys\n */\nfunction extractTranscriptPages(pages: any[]): TranscriptPage[] {\n  return pages\n    .map((page) => ({\n      id: page.id,\n      blobKey: extractBlobKeyProperty(page),\n    }))\n    .filter((t) => t.blobKey); // Filter out pages without blob keys\n}\n\n/**\n * Fetch transcript blobs and extract text\n */\nasync function fetchTranscriptBlobs(blobKeys: string[]): Promise {\n  const transcriptTexts: string[] = [];\n\n  for (const blobKey of blobKeys) {\n    try {\n      const blobData = (await blob.getJSON(blobKey)) as TranscriptBlob;\n      if (blobData && blobData.extractedText) {\n        transcriptTexts.push(blobData.extractedText);\n      }\n    } catch (error) {\n      console.error(`⚠️ Failed to fetch blob ${blobKey}:`, error);\n      // Continue with other blobs\n    }\n  }\n\n  return transcriptTexts;\n}\n\n/**\n * Format questions and answers into Notion content blocks (legacy)\n */\nfunction formatReportContent(analyses: QuestionAnalysis[]): any[] {\n  const blocks: any[] = [];\n\n  for (const analysis of analyses) {\n    // Add question as heading\n    blocks.push({\n      object: \"block\",\n      type: \"heading_2\",\n      heading_2: {\n        rich_text: [\n          {\n            type: \"text\",\n            text: {\n              content: analysis.question,\n            },\n          },\n        ],\n      },\n    });\n\n    // Add answer as paragraph\n    blocks.push({\n      object: \"block\",\n      type: \"paragraph\",\n      paragraph: {\n        rich_text: [\n          {\n            type: \"text\",\n            text: {\n              content: analysis.answer,\n            },\n          },\n        ],\n      },\n    });\n\n    // Add spacing\n    blocks.push({\n      object: \"block\",\n      type: \"paragraph\",\n      paragraph: {\n        rich_text: [],\n      },\n    });\n  }\n\n  return blocks;\n}\n\n/**\n * Format enhanced consensus analysis into rich Notion content blocks\n */\nfunction formatEnhancedReportContent(\n  analyses: EnhancedQuestionAnalysis[]\n): any[] {\n  const blocks: any[] = [];\n\n  for (const analysis of analyses) {\n    const consensus = analysis.consensusAnswer;\n\n    // Add direct answer (no question heading since it's in the Name property)\n    blocks.push({\n      object: \"block\",\n      type: \"paragraph\",\n      paragraph: {\n        rich_text: [\n          {\n            type: \"text\",\n            text: {\n              content: consensus.directAnswer,\n            },\n          },\n        ],\n      },\n    });\n\n    // Add key points if any (h3 heading like Notable Disagreements)\n    if (consensus.keyPoints.length > 0) {\n      blocks.push({\n        object: \"block\",\n        type: \"heading_3\",\n        heading_3: {\n          rich_text: [\n            {\n              type: \"text\",\n              text: {\n                content: \"Key Findings\",\n              },\n            },\n          ],\n        },\n      });\n\n      for (const point of consensus.keyPoints) {\n        blocks.push({\n          object: \"block\",\n          type: \"bulleted_list_item\",\n          bulleted_list_item: {\n            rich_text: [\n              {\n                type: \"text\",\n                text: {\n                  content: point,\n                },\n              },\n            ],\n          },\n        });\n      }\n    }\n\n    // Add disagreements if any\n    if (consensus.disagreements.length > 0) {\n      blocks.push({\n        object: \"block\",\n        type: \"heading_3\",\n        heading_3: {\n          rich_text: [\n            {\n              type: \"text\",\n              text: {\n                content: \"Notable Disagreements\",\n              },\n            },\n          ],\n        },\n      });\n\n      for (const disagreement of consensus.disagreements) {\n        blocks.push({\n          object: \"block\",\n          type: \"bulleted_list_item\",\n          bulleted_list_item: {\n            rich_text: [\n              {\n                type: \"text\",\n                text: {\n                  content: disagreement,\n                },\n              },\n            ],\n          },\n        });\n      }\n    }\n\n    // Add per-transcript findings table\n    if (consensus.perTranscriptFindings.length > 0) {\n      blocks.push({\n        object: \"block\",\n        type: \"heading_3\",\n        heading_3: {\n          rich_text: [\n            {\n              type: \"text\",\n              text: {\n                content: \"Evidence Summary\",\n              },\n            },\n          ],\n        },\n      });\n\n      // Create a simple text-based table since Notion API table blocks are complex\n      let tableText = \"Transcript | Stance | Rationale\\n\";\n      tableText += \"--- | --- | ---\\n\";\n\n      for (const finding of consensus.perTranscriptFindings) {\n        const stanceEmoji =\n          finding.stance === \"supports\"\n            ? \"✅\"\n            : finding.stance === \"mixed\"\n            ? \"🟡\"\n            : finding.stance === \"contradicts\"\n            ? \"❌\"\n            : \"❓\";\n        tableText += `${finding.key} | ${stanceEmoji} ${finding.stance} | ${finding.shortRationale}\\n`;\n      }\n\n      blocks.push({\n        object: \"block\",\n        type: \"code\",\n        code: {\n          language: \"plain text\",\n          rich_text: [\n            {\n              type: \"text\",\n              text: {\n                content: tableText,\n              },\n            },\n          ],\n        },\n      });\n    }\n\n    // Add methodology note\n    if (consensus.methodologyNote) {\n      blocks.push({\n        object: \"block\",\n        type: \"toggle\",\n        toggle: {\n          rich_text: [\n            {\n              type: \"text\",\n              text: {\n                content: \"Methodology\",\n              },\n              annotations: { italic: true },\n            },\n          ],\n          children: [\n            {\n              object: \"block\",\n              type: \"paragraph\",\n              paragraph: {\n                rich_text: [\n                  {\n                    type: \"text\",\n                    text: {\n                      content: consensus.methodologyNote,\n                    },\n                  },\n                ],\n              },\n            },\n          ],\n        },\n      });\n    }\n\n    // Add spacing between questions (only needed if processing multiple questions in one page)\n    blocks.push({\n      object: \"block\",\n      type: \"divider\",\n      divider: {},\n    });\n\n    blocks.push({\n      object: \"block\",\n      type: \"paragraph\",\n      paragraph: {\n        rich_text: [],\n      },\n    });\n  }\n\n  return blocks;\n}\n\n/**\n * Extract Results Database ID from Notion page properties\n */\nfunction extractResultsDatabaseId(page: any): string | null {\n  const resultsDatabaseProperty = page.properties?.[\"Results Database ID\"];\n  if (!resultsDatabaseProperty || resultsDatabaseProperty.type !== \"rich_text\") {\n    return null;\n  }\n\n  if (resultsDatabaseProperty.rich_text?.length > 0) {\n    return resultsDatabaseProperty.rich_text[0].text.content;\n  }\n\n  return null;\n}\n\n/**\n * Extract Name property from Notion page\n */\nfunction extractNameProperty(page: any): string {\n  const nameProperty = page.properties?.Name;\n  if (!nameProperty) return \"\";\n\n  if (nameProperty.type === \"title\" && nameProperty.title?.length > 0) {\n    return nameProperty.title[0].text.content;\n  }\n\n  if (nameProperty.type === \"rich_text\" && nameProperty.rich_text?.length > 0) {\n    return nameProperty.rich_text[0].text.content;\n  }\n\n  return \"\";\n}\n\n/**\n * Extract Blob key property from Notion page\n */\nfunction extractBlobKeyProperty(page: any): string {\n  const blobKeyProperty = page.properties?.[\"Blob key\"];\n  if (!blobKeyProperty || blobKeyProperty.type !== \"rich_text\") return \"\";\n\n  if (blobKeyProperty.rich_text?.length > 0) {\n    return blobKeyProperty.rich_text[0].text.content;\n  }\n\n  return \"\";\n}\n",[],[228,234,250],{"_104":259,"_95":260,"_157":261,"_159":235,"_160":139,"_161":262,"_163":164,"_106":263,"_100":162,"_166":254,"_168":264,"_169":22,"_170":-5,"_171":265,"_98":266},"ee67af02-7dec-11f0-b478-0224a6c84d84","health.controller.ts","0198aa63-0ee2-725e-8c9f-92a15aa2aac7",32,["D",1755711701178],"import { getDatabaseById } from \"../services/notion.service.ts\";\n\nexport async function getConfiguredDatabases() {\n  const transcriptsDbId = Deno.env.get(\"FINDINGS_TRANSCRIPTS_DB_ID\");\n  const questionsDbId = Deno.env.get(\"FINDINGS_QUESTIONS_DB_ID\");\n  const reportsDbId = Deno.env.get(\"FINDINGS_REPORTS_RAW_DB_ID\");\n\n  const databases = {\n    transcripts: null,\n    questions: null,\n    reports: null,\n  };\n  const errors: string[] = [];\n\n  // Check transcripts database\n  if (transcriptsDbId) {\n    const result = await getDatabaseById(transcriptsDbId);\n    if (result.success) {\n      databases.transcripts = result.data;\n    } else {\n      errors.push(`Transcripts DB: ${result.error}`);\n    }\n  } else {\n    errors.push(\"FINDINGS_TRANSCRIPTS_DB_ID not configured\");\n  }\n\n  // Check questions database\n  if (questionsDbId) {\n    const result = await getDatabaseById(questionsDbId);\n    if (result.success) {\n      databases.questions = result.data;\n    } else {\n      errors.push(`Questions DB: ${result.error}`);\n    }\n  } else {\n    errors.push(\"FINDINGS_QUESTIONS_DB_ID not configured\");\n  }\n\n  // Check reports database\n  if (reportsDbId) {\n    const result = await getDatabaseById(reportsDbId);\n    if (result.success) {\n      databases.reports = result.data;\n    } else {\n      errors.push(`Reports DB: ${result.error}`);\n    }\n  } else {\n    errors.push(\"FINDINGS_REPORTS_RAW_DB_ID not configured\");\n  }\n\n  return {\n    success: errors.length === 0,\n    data: databases,\n    errors: errors.length > 0 ? errors : undefined,\n    timestamp: new Date().toISOString(),\n  };\n}\n\nexport async function getHealthStatus() {\n  const configuredDatabases = await getConfiguredDatabases();\n\n  const healthStatus = {\n    status: configuredDatabases.success ? \"ok\" : \"error\",\n    timestamp: new Date().toISOString(),\n    val: \"findings\",\n    databases: {\n      configured: configuredDatabases.success,\n      transcripts: configuredDatabases.data?.transcripts\n        ? \"connected\"\n        : \"error\",\n      questions: configuredDatabases.data?.questions ? \"connected\" : \"error\",\n      reports: configuredDatabases.data?.reports ? \"connected\" : \"error\",\n    },\n  };\n\n  if (configuredDatabases.errors) {\n    healthStatus.errors = configuredDatabases.errors;\n  }\n\n  return healthStatus;\n}\n",[],[228,234,260],{"_104":268,"_95":269,"_157":270,"_159":235,"_160":139,"_161":242,"_163":22,"_106":271,"_100":162,"_166":254,"_168":272,"_169":22,"_170":-5,"_171":273,"_98":274},"9118cd48-7a3d-11f0-b176-0224a6c84d84","tasks.controller.test.ts","c8fa3e62-79c6-11f0-95e0-0224a6c84d84",["D",1755306529418],"/**\n * Basic tests for tasks controller\n * These are simple validation tests - not comprehensive unit tests\n */\n\nimport { extractPageIdFromWebhook } from \"./tasks.controller.ts\";\n\n// Test webhook payload parsing\nconsole.log(\"Testing extractPageIdFromWebhook...\");\n\n// Valid payload\nconst validPayload = { data: { id: \"test-page-123\" } };\nconst pageId = extractPageIdFromWebhook(validPayload);\nconsole.log(\"✅ Valid payload test:\", pageId === \"test-page-123\" ? \"PASS\" : \"FAIL\");\n\n// Invalid payload\nconst invalidPayload = { data: {} };\nconst noPageId = extractPageIdFromWebhook(invalidPayload);\nconsole.log(\"✅ Invalid payload test:\", noPageId === null ? \"PASS\" : \"FAIL\");\n\n// Empty payload\nconst emptyPayload = {};\nconst emptyResult = extractPageIdFromWebhook(emptyPayload);\nconsole.log(\"✅ Empty payload test:\", emptyResult === null ? \"PASS\" : \"FAIL\");\n\n// Test block transformation logic\nconsole.log(\"\\nTesting block transformation...\");\n\n// Mock H3 blocks for testing\nconst mockBlocks = [\n  {\n    type: \"heading_3\",\n    heading_3: {\n      rich_text: [\n        {\n          type: \"text\",\n          text: { content: \"Key findings\" },\n          plain_text: \"Key findings\"\n        }\n      ]\n    }\n  },\n  {\n    type: \"heading_3\", \n    heading_3: {\n      rich_text: [\n        {\n          type: \"text\",\n          text: { content: \"Notable disagreements\" },\n          plain_text: \"Notable disagreements\"\n        }\n      ]\n    }\n  },\n  {\n    type: \"heading_3\",\n    heading_3: {\n      rich_text: [\n        {\n          type: \"text\", \n          text: { content: \"Other heading\" },\n          plain_text: \"Other heading\"\n        }\n      ]\n    }\n  },\n  {\n    type: \"paragraph\",\n    paragraph: {\n      rich_text: [\n        {\n          type: \"text\",\n          text: { content: \"Regular paragraph\" },\n          plain_text: \"Regular paragraph\"\n        }\n      ]\n    }\n  }\n];\n\n// Import the transform function (we need to make it accessible for testing)\n// For now, let's test the logic conceptually\nconsole.log(\"📋 Mock blocks created for transformation test\");\nconsole.log(\"- H3: Key findings (should transform)\");\nconsole.log(\"- H3: Notable disagreements (should transform)\"); \nconsole.log(\"- H3: Other heading (should NOT transform)\");\nconsole.log(\"- Paragraph: Regular paragraph (should NOT transform)\");\n\nconsole.log(\"✅ Block transformation test setup: PASS\");\nconsole.log(\"Note: Full transformation testing requires the function to be exported\");\n\nconsole.log(\"\\nController tests completed!\");",[],[228,234,269],{"_104":276,"_95":277,"_157":278,"_159":235,"_160":139,"_161":279,"_163":22,"_106":280,"_100":244,"_166":254,"_168":281,"_169":22,"_170":-5,"_171":282,"_98":283},"ee4caf9a-7dec-11f0-9662-0224a6c84d84","tasks.controller.ts","c8fa40ba-79c6-11f0-95e0-0224a6c84d84",30,["D",1755711701210],"/**\n * Tasks Controller\n * Business logic for webhook-triggered task processing\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport {\n  getPageProperties,\n  updatePageStatus,\n  getPageBlocks,\n  createPageInDatabase,\n  copyBlocksToPage,\n  deleteAllDatabasePages,\n} from \"../services/notion.service.ts\";\nimport { extractTextFromPDFUrl } from \"../utils/pdfExtractor.ts\";\nimport type {\n  DuplicatePageRequest,\n  DuplicatePageResponse,\n  ConvertPageRequest,\n  ConvertPageResponse,\n} from \"../types/findings.types.ts\";\n\nexport interface ProcessBlobRequest {\n  pageId: string;\n}\n\nexport interface ProcessBlobResponse {\n  success: boolean;\n  pageId: string;\n  blobKey?: string;\n  textLength?: number;\n  statusUpdated?: boolean;\n  timestamp: string;\n  error?: string;\n  details?: string;\n}\n\n/**\n * Process PDF extraction and blob storage for a Notion page\n */\nexport async function processBlobExtraction(\n  request: ProcessBlobRequest\n): Promise {\n  const { pageId } = request;\n  const timestamp = new Date().toISOString();\n\n  try {\n    console.log(`🔍 Processing page: ${pageId}`);\n\n    // Get page properties from Notion\n    const pageResult = await getPageProperties(pageId);\n    if (!pageResult.success) {\n      console.error(`❌ Failed to get page properties: ${pageResult.error}`);\n      return {\n        success: false,\n        pageId,\n        timestamp,\n        error: `Failed to get page properties: ${pageResult.error}`,\n      };\n    }\n\n    const page = pageResult.data;\n    console.log(`📄 Retrieved page properties for: ${page.id}`);\n\n    // Extract PDF URL from page properties\n    const pdfUrl = extractPdfUrl(page);\n    if (!pdfUrl) {\n      console.error(\"❌ No valid PDF found on page\");\n      return {\n        success: false,\n        pageId,\n        timestamp,\n        error: \"No PDF files found in PDF property\",\n      };\n    }\n\n    console.log(`📎 Found PDF URL: ${pdfUrl}`);\n\n    // Extract text from PDF\n    console.log(\"🔄 Starting PDF text extraction...\");\n    const extractedText = await extractTextFromPDFUrl(pdfUrl);\n\n    if (!extractedText || extractedText.trim().length === 0) {\n      console.error(\"❌ No text extracted from PDF\");\n      return {\n        success: false,\n        pageId,\n        timestamp,\n        error: \"No text could be extracted from PDF\",\n      };\n    }\n\n    // Save extracted text to blob storage\n    const blobKey = `findings--transcripts--${pageId}`;\n    console.log(`💾 Saving extracted text to blob with key: ${blobKey}`);\n\n    await blob.setJSON(blobKey, {\n      pageId: pageId,\n      extractedText: extractedText,\n      extractedAt: timestamp,\n      textLength: extractedText.length,\n      pdfUrl: pdfUrl,\n    });\n\n    console.log(`✅ Text saved to blob storage successfully`);\n\n    // Update page status to \"Done\" and save blob key\n    console.log(\"🔄 Updating page status to 'Done' and saving blob key...\");\n    const statusResult = await updatePageStatus(pageId, \"Done\", blobKey);\n    if (!statusResult.success) {\n      console.error(`⚠️ Failed to update page status: ${statusResult.error}`);\n      // Don't fail the entire operation if status update fails\n    } else {\n      console.log(\"✅ Page status updated to 'Done' and blob key saved\");\n    }\n\n    return {\n      success: true,\n      pageId,\n      blobKey,\n      textLength: extractedText.length,\n      statusUpdated: statusResult.success,\n      timestamp,\n    };\n  } catch (error) {\n    console.error(\"❌ Error processing blob extraction:\", error);\n    return {\n      success: false,\n      pageId,\n      timestamp,\n      error: \"Internal server error\",\n      details: error.message,\n    };\n  }\n}\n\n/**\n * Extract PDF URL from Notion page properties\n */\nfunction extractPdfUrl(page: any): string | null {\n  // Extract PDF property\n  const pdfProperty = page.properties?.PDF;\n  if (!pdfProperty || pdfProperty.type !== \"files\") {\n    console.error(\n      \"❌ No PDF property found or property is not of type 'files'\"\n    );\n    return null;\n  }\n\n  const files = pdfProperty.files;\n  if (!files || files.length === 0) {\n    console.error(\"❌ No files found in PDF property\");\n    return null;\n  }\n\n  // Get the first (and should be only) PDF file\n  const pdfFile = files[0];\n  if (!pdfFile) {\n    console.error(\"❌ PDF file is null or undefined\");\n    return null;\n  }\n\n  // Get the file URL (handle both external and Notion-hosted files)\n  if (pdfFile.type === \"external\") {\n    return pdfFile.external.url;\n  } else if (pdfFile.type === \"file\") {\n    return pdfFile.file.url;\n  } else {\n    console.error(\"❌ Unknown PDF file type:\", pdfFile.type);\n    return null;\n  }\n}\n\n/**\n * Extract page ID from Notion webhook payload\n */\nexport function extractPageIdFromWebhook(webhookBody: any): string | null {\n  const pageId = webhookBody.data?.id;\n  if (!pageId) {\n    console.error(\n      \"❌ No page ID found in webhook payload\",\n      JSON.stringify(webhookBody, null, 2)\n    );\n    return null;\n  }\n  return pageId;\n}\n\n/**\n * Duplicate a Notion page to the final reports database with content filtering\n */\nexport async function duplicatePageToFinalReports(\n  request: DuplicatePageRequest\n): Promise {\n  const { pageId } = request;\n  const timestamp = new Date().toISOString();\n\n  try {\n    console.log(`🔄 Starting page duplication for: ${pageId}`);\n\n    // Get environment variable for target database\n    const finalReportsDbId = Deno.env.get(\"FINDINGS_REPORTS_DRAFT_DB_ID\");\n    if (!finalReportsDbId) {\n      return {\n        success: false,\n        sourcePageId: pageId,\n        timestamp,\n        error:\n          \"FINDINGS_REPORTS_DRAFT_DB_ID environment variable not configured\",\n      };\n    }\n\n    // Step 1: Get source page properties\n    console.log(`📄 Getting source page properties...`);\n    const pageResult = await getPageProperties(pageId);\n    if (!pageResult.success) {\n      console.error(`❌ Failed to get page properties: ${pageResult.error}`);\n      return {\n        success: false,\n        sourcePageId: pageId,\n        timestamp,\n        error: `Failed to get source page properties: ${pageResult.error}`,\n      };\n    }\n\n    const sourcePage = pageResult.data;\n    console.log(`✅ Retrieved source page properties`);\n\n    // Step 2: Extract Name property for target page\n    const nameProperty = sourcePage.properties?.Name;\n    if (!nameProperty) {\n      console.error(`❌ No Name property found on source page`);\n      return {\n        success: false,\n        sourcePageId: pageId,\n        timestamp,\n        error: \"Source page has no Name property\",\n      };\n    }\n\n    // Step 3: Get source page content blocks\n    console.log(`📝 Getting source page content blocks...`);\n    const blocksResult = await getPageBlocks(pageId);\n    if (!blocksResult.success) {\n      console.error(`❌ Failed to get page blocks: ${blocksResult.error}`);\n      return {\n        success: false,\n        sourcePageId: pageId,\n        timestamp,\n        error: `Failed to get source page blocks: ${blocksResult.error}`,\n      };\n    }\n\n    const sourceBlocks = blocksResult.data.results;\n    console.log(`✅ Retrieved ${sourceBlocks.length} source blocks`);\n\n    // Step 4: Filter content blocks\n    console.log(`🔍 Filtering content blocks...`);\n    console.log(\n      `📋 Original blocks:`,\n      sourceBlocks.map((block) => ({ type: block.type, id: block.id }))\n    );\n\n    // Count H2 blocks before filtering\n    const h2CountBefore = sourceBlocks.filter(\n      (block) => block.type === \"heading_2\"\n    ).length;\n    console.log(`📊 Found ${h2CountBefore} H2 blocks in source`);\n\n    const filteredBlocks = filterPageBlocks(sourceBlocks);\n    const blocksFiltered = sourceBlocks.length - filteredBlocks.length;\n\n    // Count H2 blocks after filtering\n    const h2CountAfter = filteredBlocks.filter(\n      (block) => block.type === \"heading_2\"\n    ).length;\n    console.log(`📊 ${h2CountAfter} H2 blocks remaining after filtering`);\n\n    console.log(\n      `✅ Filtered ${blocksFiltered} blocks, ${filteredBlocks.length} blocks remaining`\n    );\n    console.log(\n      `📋 Remaining blocks:`,\n      filteredBlocks.map((block) => ({ type: block.type, id: block.id }))\n    );\n\n    // Step 5: Transform specific H3 blocks to bold paragraphs\n    console.log(`🔄 Transforming specific H3 blocks to bold paragraphs...`);\n    const transformedBlocks = transformPageBlocks(filteredBlocks);\n    const blocksTransformed =\n      filteredBlocks.length -\n      transformedBlocks.filter((block) => block.type === \"heading_3\").length +\n      transformedBlocks.filter(\n        (block) => block.type === \"paragraph\" && block._transformed\n      ).length;\n\n    console.log(\n      `✅ Transformed blocks, ${transformedBlocks.length} blocks total`\n    );\n    console.log(\n      `📋 Final blocks:`,\n      transformedBlocks.map((block) => ({\n        type: block.type,\n        id: block.id,\n        transformed: block._transformed || false,\n      }))\n    );\n\n    // Step 6: Create target page in final reports database\n    console.log(`📋 Creating target page in final reports database...`);\n\n    // Modify the Name property: replace \"(raw)\" with \"(draft)\"\n    let targetProperties;\n    if (\n      nameProperty.type === \"title\" &&\n      nameProperty.title &&\n      nameProperty.title.length > 0\n    ) {\n      // Get the current title text\n      const currentTitle = nameProperty.title[0].text.content;\n      const updatedTitle = currentTitle.replace(/\\(raw\\)/gi, \"(draft)\");\n\n      console.log(\n        `📝 Updating title from \"${currentTitle}\" to \"${updatedTitle}\"`\n      );\n\n      targetProperties = {\n        Name: {\n          title: [\n            {\n              type: \"text\",\n              text: {\n                content: updatedTitle,\n              },\n            },\n          ],\n        },\n      };\n    } else {\n      // Fallback: use original property if structure is unexpected\n      console.log(`⚠️ Unexpected Name property structure, using original`);\n      targetProperties = {\n        Name: nameProperty,\n      };\n    }\n\n    const createResult = await createPageInDatabase(\n      finalReportsDbId,\n      targetProperties\n    );\n    if (!createResult.success) {\n      console.error(`❌ Failed to create target page: ${createResult.error}`);\n      return {\n        success: false,\n        sourcePageId: pageId,\n        timestamp,\n        error: `Failed to create target page: ${createResult.error}`,\n      };\n    }\n\n    const targetPage = createResult.data;\n    const targetPageId = targetPage.id;\n    console.log(`✅ Created target page: ${targetPageId}`);\n\n    // Step 7: Copy filtered blocks to target page\n    if (transformedBlocks.length > 0) {\n      console.log(\n        `📋 Copying ${transformedBlocks.length} blocks to target page...`\n      );\n\n      // Clean blocks for copying (remove Notion-specific metadata and our transformation markers)\n      const cleanedBlocks = transformedBlocks.map((block) => {\n        const {\n          id,\n          created_time,\n          created_by,\n          last_edited_time,\n          last_edited_by,\n          archived,\n          has_children,\n          _transformed,\n          ...cleanBlock\n        } = block;\n        return cleanBlock;\n      });\n\n      console.log(\n        `📋 Cleaned blocks for copying:`,\n        cleanedBlocks.map((block) => ({ type: block.type }))\n      );\n\n      const copyResult = await copyBlocksToPage(targetPageId, cleanedBlocks);\n      if (!copyResult.success) {\n        console.error(`⚠️ Failed to copy blocks: ${copyResult.error}`);\n\n        // Check if it was a partial failure\n        if (copyResult.data?.successRate && copyResult.data.successRate >= 80) {\n          console.log(\n            `ℹ️ Partial success: ${copyResult.data.successRate}% of content was copied`\n          );\n          return {\n            success: true, // Mark as success since most content was copied\n            sourcePageId: pageId,\n            targetPageId: targetPageId,\n            blocksCopied: copyResult.data.totalBlocks || 0,\n            blocksFiltered: blocksFiltered,\n            timestamp,\n            warning:\n              copyResult.warning ||\n              `Partial copy: ${copyResult.data.successRate}% success rate`,\n          };\n        }\n\n        // Complete failure - create error content in target page\n        const errorBlocks = [\n          {\n            object: \"block\",\n            type: \"paragraph\",\n            paragraph: {\n              rich_text: [\n                {\n                  type: \"text\",\n                  text: {\n                    content: `Error copying content from source page: ${copyResult.error}`,\n                  },\n                },\n              ],\n            },\n          },\n        ];\n\n        await copyBlocksToPage(targetPageId, errorBlocks);\n\n        return {\n          success: false,\n          sourcePageId: pageId,\n          targetPageId: targetPageId,\n          blocksCopied: copyResult.data?.totalBlocks || 0,\n          blocksFiltered: blocksFiltered,\n          timestamp,\n          error: `Failed to copy blocks to target page: ${copyResult.error}`,\n        };\n      }\n      console.log(`✅ Successfully copied blocks to target page`);\n    } else {\n      console.log(`ℹ️ No blocks to copy after filtering and transformation`);\n    }\n\n    return {\n      success: true,\n      sourcePageId: pageId,\n      targetPageId: targetPageId,\n      blocksCopied: transformedBlocks.length,\n      blocksFiltered: blocksFiltered,\n      timestamp,\n    };\n  } catch (error) {\n    console.error(\"❌ Error duplicating page:\", error);\n    return {\n      success: false,\n      sourcePageId: pageId,\n      timestamp,\n      error: \"Internal server error\",\n      details: error.message,\n    };\n  }\n}\n\n/**\n * Filter page blocks to remove unwanted content\n */\nfunction filterPageBlocks(blocks: any[]): any[] {\n  return blocks.filter((block) => {\n    // Remove callout blocks\n    if (block.type === \"callout\") {\n      console.log(`🚫 Filtering out callout block`);\n      return false;\n    }\n\n    // Remove code blocks\n    if (block.type === \"code\") {\n      console.log(`🚫 Filtering out code block`);\n      return false;\n    }\n\n    // Remove divider blocks\n    if (block.type === \"divider\") {\n      console.log(`🚫 Filtering out divider block`);\n      return false;\n    }\n\n    // Remove blocks containing target phrases\n    const blockText = extractTextFromBlock(block);\n    if (blockText.toLowerCase().includes(\"evidence summary\")) {\n      console.log(`🚫 Filtering out block containing \"Evidence summary\"`);\n      return false;\n    }\n    if (blockText.toLowerCase().includes(\"methodology\")) {\n      console.log(`🚫 Filtering out block containing \"Methodology\"`);\n      return false;\n    }\n    if (blockText.toLowerCase().includes(\"executive summary\")) {\n      console.log(`🚫 Filtering out block containing \"Executive summary\"`);\n      return false;\n    }\n\n    return true;\n  });\n}\n\n/**\n * Transform specific H3 blocks to bold paragraphs\n */\nfunction transformPageBlocks(blocks: any[]): any[] {\n  return blocks.map((block) => {\n    // Only process heading_3 blocks\n    if (block.type !== \"heading_3\") {\n      return block;\n    }\n\n    // Extract text from the H3 block\n    const blockText = extractTextFromBlock(block);\n    const lowerText = blockText.toLowerCase().trim();\n\n    // Check if this H3 should be transformed\n    if (lowerText === \"key findings\" || lowerText === \"notable disagreements\") {\n      console.log(`🔄 Transforming H3 \"${blockText}\" to bold paragraph`);\n\n      // Create a new paragraph block with bold text\n      const transformedBlock = {\n        ...block,\n        type: \"paragraph\",\n        paragraph: {\n          rich_text: [\n            {\n              type: \"text\",\n              text: {\n                content: blockText,\n              },\n              annotations: {\n                bold: true,\n                italic: false,\n                strikethrough: false,\n                underline: false,\n                code: false,\n                color: \"default\",\n              },\n            },\n          ],\n        },\n        _transformed: true, // Mark for logging purposes\n      };\n\n      // Remove the original heading_3 property\n      delete transformedBlock.heading_3;\n\n      return transformedBlock;\n    }\n\n    // Return unchanged if not a target heading\n    return block;\n  });\n}\n\n/**\n * Extract text content from various Notion block types\n */\nfunction extractTextFromBlock(block: any): string {\n  if (!block || !block.type) return \"\";\n\n  const blockType = block[block.type];\n  if (!blockType) return \"\";\n\n  // Handle blocks with rich_text property\n  if (blockType.rich_text && Array.isArray(blockType.rich_text)) {\n    return blockType.rich_text\n      .map((text: any) => text.plain_text || text.text?.content || \"\")\n      .join(\"\");\n  }\n\n  // Handle blocks with text property (some block types use this)\n  if (blockType.text && Array.isArray(blockType.text)) {\n    return blockType.text\n      .map((text: any) => text.plain_text || text.text?.content || \"\")\n      .join(\"\");\n  }\n\n  // Handle title property (for some block types)\n  if (blockType.title && Array.isArray(blockType.title)) {\n    return blockType.title\n      .map((text: any) => text.plain_text || text.text?.content || \"\")\n      .join(\"\");\n  }\n\n  return \"\";\n}\n\n/**\n * Convert a Notion page to database pages based on H2 sections\n */\nexport async function convertPageToDatabase(\n  request: ConvertPageRequest\n): Promise {\n  const { pageId } = request;\n  const timestamp = new Date().toISOString();\n  const warnings: string[] = [];\n\n  try {\n    console.log(`🔄 Starting page conversion for: ${pageId}`);\n\n    // Get environment variable for target database\n    const targetDatabaseId = Deno.env.get(\"FINDINGS_REPORT_FINAL_DB_ID\");\n    if (!targetDatabaseId) {\n      return {\n        success: false,\n        sourcePageId: pageId,\n        targetDatabaseId: \"\",\n        h2SectionsFound: 0,\n        pagesCreated: 0,\n        pagesWithContent: 0,\n        timestamp,\n        error:\n          \"FINDINGS_REPORT_FINAL_DB_ID environment variable not configured\",\n      };\n    }\n\n    // Step 1: Get source page content blocks\n    console.log(`📝 Getting source page content blocks...`);\n    const blocksResult = await getPageBlocks(pageId);\n    if (!blocksResult.success) {\n      console.error(`❌ Failed to get page blocks: ${blocksResult.error}`);\n      return {\n        success: false,\n        sourcePageId: pageId,\n        targetDatabaseId,\n        h2SectionsFound: 0,\n        pagesCreated: 0,\n        pagesWithContent: 0,\n        timestamp,\n        error: `Failed to get source page blocks: ${blocksResult.error}`,\n      };\n    }\n\n    const sourceBlocks = blocksResult.data.results;\n    console.log(`✅ Retrieved ${sourceBlocks.length} source blocks`);\n\n    // Debug: Log all block types to see what we're working with\n    console.log(\n      `🔍 Block types found:`,\n      sourceBlocks.map((block) => ({ type: block.type, id: block.id }))\n    );\n\n    // Step 2: Parse blocks to identify H2 sections\n    console.log(`🔍 Parsing H2 sections...`);\n    const h2Sections = parseH2Sections(sourceBlocks);\n    console.log(`✅ Found ${h2Sections.length} H2 sections`);\n\n    if (h2Sections.length === 0) {\n      return {\n        success: false,\n        sourcePageId: pageId,\n        targetDatabaseId,\n        h2SectionsFound: 0,\n        pagesCreated: 0,\n        pagesWithContent: 0,\n        timestamp,\n        error: \"No H2 sections found in source page\",\n      };\n    }\n\n    // Step 3: Delete all existing pages from target database\n    console.log(`🗑️ Deleting all pages from target database...`);\n    const deleteResult = await deleteAllDatabasePages(targetDatabaseId);\n    if (!deleteResult.success) {\n      console.error(\n        `❌ Failed to delete database pages: ${deleteResult.error}`\n      );\n      return {\n        success: false,\n        sourcePageId: pageId,\n        targetDatabaseId,\n        h2SectionsFound: h2Sections.length,\n        pagesCreated: 0,\n        pagesWithContent: 0,\n        timestamp,\n        error: `Failed to delete existing database pages: ${deleteResult.error}`,\n      };\n    }\n\n    if (deleteResult.warning) {\n      warnings.push(deleteResult.warning);\n    }\n\n    console.log(\n      `✅ Deleted ${deleteResult.data.deletedPages} pages from database`\n    );\n\n    // Step 4: Create new pages for each H2 section\n    let pagesCreated = 0;\n    let pagesWithContent = 0;\n\n    for (let i = 0; i < h2Sections.length; i++) {\n      const section = h2Sections[i];\n      console.log(\n        `📋 Processing H2 section ${i + 1}/${h2Sections.length}: \"${\n          section.title\n        }\"`\n      );\n\n      try {\n        // Create page with H2 title as Name property\n        const pageProperties = {\n          Name: {\n            title: [\n              {\n                type: \"text\",\n                text: {\n                  content: section.title,\n                },\n              },\n            ],\n          },\n        };\n\n        const createResult = await createPageInDatabase(\n          targetDatabaseId,\n          pageProperties\n        );\n        if (!createResult.success) {\n          console.error(\n            `❌ Failed to create page for \"${section.title}\": ${createResult.error}`\n          );\n          warnings.push(\n            `Failed to create page for \"${section.title}\": ${createResult.error}`\n          );\n          continue;\n        }\n\n        const newPageId = createResult.data.id;\n        pagesCreated++;\n        console.log(\n          `✅ Created page: ${newPageId} with title \"${section.title}\"`\n        );\n\n        // Copy content blocks to the new page (if any)\n        if (section.contentBlocks.length > 0) {\n          console.log(\n            `📋 Copying ${section.contentBlocks.length} content blocks...`\n          );\n\n          // Clean blocks for copying (remove Notion-specific metadata)\n          const cleanedBlocks = section.contentBlocks.map((block) => {\n            const {\n              id,\n              created_time,\n              created_by,\n              last_edited_time,\n              last_edited_by,\n              archived,\n              has_children,\n              ...cleanBlock\n            } = block;\n            return cleanBlock;\n          });\n\n          const copyResult = await copyBlocksToPage(newPageId, cleanedBlocks);\n          if (!copyResult.success) {\n            console.error(\n              `⚠️ Failed to copy content to \"${section.title}\": ${copyResult.error}`\n            );\n            warnings.push(\n              `Failed to copy content to \"${section.title}\": ${copyResult.error}`\n            );\n          } else {\n            pagesWithContent++;\n            console.log(`✅ Successfully copied content to \"${section.title}\"`);\n          }\n        } else {\n          console.log(`ℹ️ No content blocks to copy for \"${section.title}\"`);\n        }\n\n        // Small delay to avoid rate limiting\n        await new Promise((resolve) => setTimeout(resolve, 200));\n      } catch (sectionError) {\n        console.error(\n          `❌ Error processing section \"${section.title}\":`,\n          sectionError\n        );\n        warnings.push(\n          `Error processing section \"${section.title}\": ${sectionError.message}`\n        );\n      }\n    }\n\n    // Determine overall success\n    const successRate = pagesCreated / h2Sections.length;\n    const isSuccess = successRate >= 0.8; // Consider success if 80%+ of sections were processed\n\n    console.log(\n      `📊 Conversion complete: ${pagesCreated}/${h2Sections.length} pages created, ${pagesWithContent} with content`\n    );\n\n    return {\n      success: isSuccess,\n      sourcePageId: pageId,\n      targetDatabaseId,\n      h2SectionsFound: h2Sections.length,\n      pagesCreated,\n      pagesWithContent,\n      timestamp,\n      warnings: warnings.length > 0 ? warnings : undefined,\n    };\n  } catch (error) {\n    console.error(\"❌ Error converting page to database:\", error);\n    return {\n      success: false,\n      sourcePageId: pageId,\n      targetDatabaseId: \"\",\n      h2SectionsFound: 0,\n      pagesCreated: 0,\n      pagesWithContent: 0,\n      timestamp,\n      error: \"Internal server error\",\n      details: error.message,\n    };\n  }\n}\n\n/**\n * Parse blocks to identify H2 sections and their content\n */\nfunction parseH2Sections(\n  blocks: any[]\n): Array<{ title: string; contentBlocks: any[] }> {\n  const sections: Array<{ title: string; contentBlocks: any[] }> = [];\n  let currentSection: { title: string; contentBlocks: any[] } | null = null;\n\n  console.log(\n    `🔍 Starting to parse ${blocks.length} blocks for H2 sections...`\n  );\n\n  for (let i = 0; i < blocks.length; i++) {\n    const block = blocks[i];\n    console.log(\n      `📋 Processing block ${i + 1}: type=\"${block.type}\", id=\"${block.id}\"`\n    );\n\n    if (block.type === \"heading_2\") {\n      // Save previous section if it exists\n      if (currentSection) {\n        console.log(\n          `💾 Saving previous section \"${currentSection.title}\" with ${currentSection.contentBlocks.length} content blocks`\n        );\n        sections.push(currentSection);\n      }\n\n      // Start new section with H2 title (exclude the H2 block itself from content)\n      const title = extractTextFromBlock(block);\n      currentSection = {\n        title: title || \"Untitled Section\",\n        contentBlocks: [],\n      };\n\n      console.log(`📝 Found H2 section: \"${currentSection.title}\"`);\n    } else if (currentSection) {\n      // Add content block to current section (excluding the H2 itself)\n      console.log(\n        `📄 Adding content block to section \"${currentSection.title}\": type=\"${block.type}\"`\n      );\n      currentSection.contentBlocks.push(block);\n    } else {\n      console.log(`⏭️ Skipping block before first H2: type=\"${block.type}\"`);\n    }\n    // Ignore blocks before the first H2 (as per requirements)\n  }\n\n  // Don't forget the last section\n  if (currentSection) {\n    console.log(\n      `💾 Saving final section \"${currentSection.title}\" with ${currentSection.contentBlocks.length} content blocks`\n    );\n    sections.push(currentSection);\n  }\n\n  console.log(`✅ Parsing complete: found ${sections.length} H2 sections`);\n  return sections;\n}\n",[],[228,234,277],[228,234],{"_104":286,"_95":287,"_157":288,"_159":229,"_160":139,"_161":162,"_163":164,"_106":289,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":290,"_98":309},"d0f9bc20-7951-11f0-8810-0224a6c84d84","crons","0198aa63-0ee2-725e-8c9f-9f1fa6f65456",["D",1755205275298],[291,300],{"_104":292,"_95":240,"_157":293,"_159":288,"_160":139,"_161":294,"_163":164,"_106":295,"_100":296,"_166":179,"_168":297,"_169":22,"_170":-5,"_171":298,"_98":299},"24e30a3c-7a18-11f0-8841-0224a6c84d84","0198aa63-0ee2-725e-8c9f-9afb0718c9af",24,["D",1755290456490],2,"# Crons\n\nScheduled task handlers.\n\n## Available Crons\n\n- `findings-analysis.ts` - **Batched Processing**: Analyzes transcripts using enhanced two-stage consensus analysis and generates rich findings reports with:\n  - **Batch Size**: Processes 5 questions per cron run to avoid timeouts\n  - **State Management**: Uses question status tracking (\"Not started\" → \"Working...\" → \"Done\"/\"Error\")\n  - **Resume Logic**: Automatically continues from where previous runs left off\n  - **Per-transcript individual analysis**\n  - **Cross-transcript consensus synthesis**  \n  - **Confidence scores and consensus levels**\n  - **Disagreement tracking and evidence summaries**\n  - **Rich Notion formatting with callouts, tables, and structured sections**\n\n### Batched Processing Workflow\n\n1. **Initialization**: When a new report is found, all questions are reset to \"Not started\"\n2. **Batch Selection**: Each cron run picks up to 5 questions with \"Not started\" status\n3. **Processing**: Selected questions are marked \"Working...\" then processed individually\n4. **Completion**: Successfully processed questions are marked \"Done\", failed ones marked \"Error\"\n5. **Resume**: Subsequent cron runs continue with remaining \"Not started\" questions\n6. **Finalization**: When all questions are complete, the report is marked \"Done\"\n\n### Timing\n- **Per Question**: ~30 seconds average processing time\n- **Per Batch**: ~3-4 minutes total (5 questions + overhead)\n- **Safety Margin**: Well under timeout limits with room for variability",[],[228,287,240],{"_104":301,"_95":302,"_157":303,"_159":288,"_160":139,"_161":294,"_163":164,"_106":304,"_100":162,"_166":305,"_168":306,"_169":22,"_170":-5,"_171":307,"_98":308},"24e30d8e-7a18-11f0-8841-0224a6c84d84","findings-analysis.ts","82c45a60-7a05-11f0-9236-0224a6c84d84",["D",1755290456490],"interval","/**\n * Findings Analysis Cron Job\n * Scheduled task to analyze transcripts and generate findings reports in batches\n */\n\nimport { processFindings } from \"../controllers/findings.controller.ts\";\n\nexport default async function() {\n  console.log(\"🚀 Starting findings analysis cron job (batched processing)...\");\n  \n  const result = await processFindings({});\n  \n  if (result.success) {\n    if (result.remainingQuestions !== undefined && result.remainingQuestions > 0) {\n      // Batch completed, more work remaining\n      console.log(\"✅ Batch processing completed successfully\");\n      console.log(`📊 Report page: ${result.reportPageId}`);\n      console.log(`❓ Questions in this batch: ${result.questionsProcessed}`);\n      console.log(`✅ Questions succeeded: ${result.questionsSucceeded}`);\n      console.log(`⏳ Questions remaining: ${result.remainingQuestions}`);\n      console.log(\"🔄 Next cron run will process the remaining questions\");\n      \n      if (result.questionsSucceeded !== result.questionsProcessed) {\n        console.log(`⚠️ Some questions in this batch failed: ${result.questionsProcessed - result.questionsSucceeded} errors`);\n      }\n    } else {\n      // All processing complete\n      console.log(\"🎉 All findings analysis completed successfully!\");\n      console.log(`📊 Report page: ${result.reportPageId}`);\n      console.log(`❓ Total questions processed: ${result.questionsProcessed}`);\n      console.log(`✅ Questions succeeded: ${result.questionsSucceeded}`);\n      \n      if (result.questionsSucceeded !== result.questionsProcessed) {\n        console.log(`⚠️ Some questions failed: ${result.questionsProcessed - result.questionsSucceeded} errors`);\n      }\n    }\n  } else {\n    console.error(\"❌ Findings analysis failed:\", result.error);\n    if (result.details) {\n      console.error(\"Details:\", result.details);\n    }\n  }\n  \n  return result;\n}",[],[228,287,302],[228,287],{"_104":311,"_95":312,"_157":313,"_159":229,"_160":139,"_161":162,"_163":164,"_106":314,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":315,"_98":424},"d0f9da34-7951-11f0-8810-0224a6c84d84","routes","0198aa63-0ee2-725e-8c9f-d562adf43e32",["D",1755205275298],[316,338,362,392,399,407,416],{"_104":317,"_95":318,"_157":319,"_159":313,"_160":139,"_161":162,"_163":164,"_106":320,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":321,"_98":337},"d0f9c0b2-7951-11f0-8810-0224a6c84d84","api","0198aa63-0ee2-725e-8c9f-abba08232a49",["D",1755205275298],[322,329],{"_104":323,"_95":240,"_157":324,"_159":319,"_160":139,"_161":162,"_163":164,"_106":325,"_100":32,"_166":179,"_168":326,"_169":22,"_170":-5,"_171":327,"_98":328},"d0f9bd24-7951-11f0-8810-0224a6c84d84","0198aa63-0ee2-725e-8c9f-a1731ad70c90",["D",1755205275298],"# API Routes\n\nJSON API endpoints for frontend/backend communication.",[],[228,312,318,240],{"_104":330,"_95":331,"_157":332,"_159":319,"_160":139,"_161":162,"_163":164,"_106":333,"_100":32,"_166":254,"_168":334,"_169":22,"_170":-5,"_171":335,"_98":336},"d0f9bf9a-7951-11f0-8810-0224a6c84d84","_api.routes.ts","0198aa63-0ee2-725e-8c9f-a4a44f77a838",["D",1755205275298],"import { Hono } from \"npm:hono@3.12.12\";\nimport { getHealthStatus } from \"../../controllers/health.controller.ts\";\n\nconst app = new Hono();\n\napp.get(\"/health\", async (c) => {\n  const healthStatus = await getHealthStatus();\n  return c.json(healthStatus);\n});\n\nexport default app;",[],[228,312,318,331],[228,312,318],{"_104":339,"_95":340,"_157":341,"_159":313,"_160":139,"_161":162,"_163":164,"_106":342,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":343,"_98":361},"d0f9c562-7951-11f0-8810-0224a6c84d84","tasks","0198aa63-0ee2-725e-8c9f-b6bbe70d9965",["D",1755205275298],[344,352],{"_104":345,"_95":240,"_157":346,"_159":341,"_160":139,"_161":347,"_163":22,"_106":348,"_100":244,"_166":179,"_168":349,"_169":22,"_170":-5,"_171":350,"_98":351},"ee5334f0-7dec-11f0-8201-0224a6c84d84","0198aa63-0ee2-725e-8c9f-ae02d77fc854",31,["D",1755711701214],"# Task Routes\n\nWebhook handlers for Notion integrations.\n\n## Endpoints\n\n- `POST /tasks/blob` - Process PDF extraction and blob storage for Notion pages\n- `POST /tasks/dupe` - Duplicate Notion page to final reports database with content filtering\n- `POST /tasks/notion-webhook` - General Notion webhook handler\n- `POST /tasks/test` - Test endpoint for webhook authentication\n- `GET /tasks/debug-webhook` - Debug endpoint to check webhook configuration\n\n## Architecture\n\nRoutes handle HTTP request/response only. Business logic is delegated to:\n\n- `tasks.controller.ts` - Orchestrates PDF extraction, blob storage, page duplication, and Notion updates\n- `notion.service.ts` - Handles Notion API calls\n- `pdfExtractor.ts` - Handles PDF text extraction\n\n## Page Duplication (`/tasks/dupe`)\n\nThe `/tasks/dupe` endpoint duplicates a Notion page from any database to the final reports database (`FINDINGS_REPORTS_DRAFT_DB_ID`) with content filtering:\n\n### Content Filtering\n\n- **Removes**: Callout blocks, code blocks, divider blocks, blocks containing \"Evidence summary\", blocks containing \"Methodology\", blocks containing \"Executive summary\"\n- **Preserves**: All other content blocks in original order\n- **Source**: Original page remains unchanged\n\n### Webhook Payload\n\nExpects Notion webhook with page ID in `data.id`:\n\n```json\n{\n  \"data\": {\n    \"id\": \"page-id-here\"\n  }\n}\n```\n\n### Response Format\n\n```json\n{\n  \"success\": true,\n  \"sourcePageId\": \"source-page-id\",\n  \"targetPageId\": \"new-page-id\",\n  \"blocksCopied\": 15,\n  \"blocksFiltered\": 3,\n  \"timestamp\": \"2025-08-15T22:25:47.000Z\"\n}\n```\n",[],[228,312,340,240],{"_104":353,"_95":354,"_157":355,"_159":341,"_160":139,"_161":356,"_163":22,"_106":357,"_100":244,"_166":254,"_168":358,"_169":22,"_170":-5,"_171":359,"_98":360},"82af98c8-7afa-11f0-8f1f-0224a6c84d84","_tasks.routes.ts","0198aa63-0ee2-725e-8c9f-b3edc7440c83",27,["D",1755387680127],"import { Hono } from \"npm:hono@3.12.12\";\nimport { processBlobExtraction, extractPageIdFromWebhook, duplicatePageToFinalReports, convertPageToDatabase } from \"../../controllers/tasks.controller.ts\";\n\nconst app = new Hono();\n\n// Debug endpoint to check webhook configuration\napp.get(\"/debug-webhook\", (c) => {\n  const secret = Deno.env.get(\"NOTION_WEBHOOK_SECRET\");\n  return c.json({\n    hasSecret: !!secret,\n    secretLength: secret?.length || 0,\n  });\n});\n\n// Test endpoint for webhook authentication\napp.post(\"/test\", async (c) => {\n  // At this point, webhook auth has already passed\n  return c.json({ \n    success: true, \n    message: \"Webhook authentication successful\",\n    timestamp: new Date().toISOString()\n  });\n});\n\n// Main Notion webhook endpoint\napp.post(\"/notion-webhook\", async (c) => {\n  // At this point, webhook auth has already passed\n  const body = await c.req.json();\n  console.log(\"Notion webhook received:\", body);\n\n  // Process the webhook...\n  // TODO: Add webhook processing logic here\n\n  return c.json({ success: true });\n});\n\n// PDF text extraction and blob storage endpoint\napp.post(\"/blob\", async (c) => {\n  try {\n    // At this point, webhook auth has already passed\n    const body = await c.req.json();\n    console.log(\"📥 Blob processing webhook received:\", body);\n\n    // Extract page ID from webhook payload\n    const pageId = extractPageIdFromWebhook(body);\n    if (!pageId) {\n      return c.json({ error: \"Page ID is required\" }, 400);\n    }\n\n    // Process the blob extraction using controller\n    const result = await processBlobExtraction({ pageId });\n\n    // Return appropriate HTTP status based on result\n    if (result.success) {\n      return c.json(result);\n    } else {\n      const statusCode = result.error?.includes(\"No PDF\") || result.error?.includes(\"No text\") ? 400 : 500;\n      return c.json(result, statusCode);\n    }\n\n  } catch (error) {\n    console.error(\"❌ Error in blob endpoint:\", error);\n    return c.json({ \n      error: \"Internal server error\", \n      details: error.message,\n      timestamp: new Date().toISOString()\n    }, 500);\n  }\n});\n\n// Page duplication endpoint\napp.post(\"/dupe\", async (c) => {\n  try {\n    // At this point, webhook auth has already passed\n    const body = await c.req.json();\n    console.log(\"📥 Page duplication webhook received:\", body);\n\n    // Extract page ID from webhook payload\n    const pageId = extractPageIdFromWebhook(body);\n    if (!pageId) {\n      return c.json({ error: \"Page ID is required\" }, 400);\n    }\n\n    // Process the page duplication using controller\n    const result = await duplicatePageToFinalReports({ pageId });\n\n    // Return appropriate HTTP status based on result\n    if (result.success) {\n      return c.json(result);\n    } else {\n      return c.json(result, 500);\n    }\n\n  } catch (error) {\n    console.error(\"❌ Error in dupe endpoint:\", error);\n    return c.json({ \n      error: \"Internal server error\", \n      details: error.message,\n      timestamp: new Date().toISOString()\n    }, 500);\n  }\n});\n\n// Page conversion endpoint\napp.post(\"/convert\", async (c) => {\n  try {\n    // At this point, webhook auth has already passed\n    const body = await c.req.json();\n    console.log(\"📥 Page conversion webhook received:\", body);\n\n    // Extract page ID from webhook payload\n    const pageId = extractPageIdFromWebhook(body);\n    if (!pageId) {\n      return c.json({ error: \"Page ID is required\" }, 400);\n    }\n\n    // Process the page conversion using controller\n    const result = await convertPageToDatabase({ pageId });\n\n    // Return appropriate HTTP status based on result\n    if (result.success) {\n      return c.json(result);\n    } else {\n      return c.json(result, 500);\n    }\n\n  } catch (error) {\n    console.error(\"❌ Error in convert endpoint:\", error);\n    return c.json({ \n      error: \"Internal server error\", \n      details: error.message,\n      timestamp: new Date().toISOString()\n    }, 500);\n  }\n});\n\n// Catch-all handler for undefined webhook endpoints\n// This must be the LAST route defined to catch unmatched paths\napp.post(\"*\", (c) => {\n  const path = c.req.path;\n  const method = c.req.method;\n  const returnObj = {\n    error: \"Endpoint not found\",\n    path: path,\n    method: method,\n    availableEndpoints: [\n      \"GET /tasks/debug-webhook\",\n      \"POST /tasks/test\",\n      \"POST /tasks/notion-webhook\",\n      \"POST /tasks/blob\",\n      \"POST /tasks/dupe\",\n      \"POST /tasks/convert\",\n    ],\n  };\n  console.log(returnObj);\n\n  return c.json(returnObj, 404);\n});\n\nexport default app;",[],[228,312,340,354],[228,312,340],{"_104":363,"_95":364,"_157":365,"_159":313,"_160":139,"_161":162,"_163":164,"_106":366,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":367,"_98":391},"d0f9d336-7951-11f0-8810-0224a6c84d84","views","0198aa63-0ee2-725e-8c9f-c76212a512de",["D",1755205275298],[368,375,383],{"_104":369,"_95":240,"_157":370,"_159":365,"_160":139,"_161":162,"_163":164,"_106":371,"_100":32,"_166":179,"_168":372,"_169":22,"_170":-5,"_171":373,"_98":374},"d0f9c97c-7951-11f0-8810-0224a6c84d84","0198aa63-0ee2-725e-8c9f-b8ca6925a52f",["D",1755205275298],"# View Routes\n\nServer-side rendered views for frontend.",[],[228,312,364,240],{"_104":376,"_95":377,"_157":378,"_159":365,"_160":139,"_161":162,"_163":164,"_106":379,"_100":32,"_166":254,"_168":380,"_169":22,"_170":-5,"_171":381,"_98":382},"d0f9cb02-7951-11f0-8810-0224a6c84d84","_views.routes.ts","0198aa63-0ee2-725e-8c9f-bce257a069f1",["D",1755205275298],"import { Hono } from \"npm:hono@3.12.12\";\n\nconst app = new Hono();\n\n// TODO: Add routes here\n\nexport default app;",[],[228,312,364,377],{"_104":384,"_95":385,"_157":386,"_159":365,"_160":139,"_161":162,"_163":164,"_106":387,"_100":32,"_166":254,"_168":388,"_169":22,"_170":-5,"_171":389,"_98":390},"d0f9cc06-7951-11f0-8810-0224a6c84d84","dashboard.tsx","0198aa63-0ee2-725e-8c9f-c128742e671b",["D",1755205275298],"import { getAbsoluteUrl } from \"../../utils/url.ts\";\nimport { getHealthStatus } from \"../../controllers/health.controller.ts\";\n\nexport default async (c) => {\n  const userEmail = c.get(\"userEmail\");\n  const healthData = await getHealthStatus();\n  const healthUrl = getAbsoluteUrl(c, \"/api/health\");\n  \n  // Check webhook configuration\n  const webhookSecret = Deno.env.get(\"NOTION_WEBHOOK_SECRET\");\n  const webhookConfigured = !!webhookSecret;\n  const webhookEndpoint = getAbsoluteUrl(c, '/tasks/notion-webhook');\n\n  return c.html(`\n    \n    \n    \n      Findings Dashboard\n      \n    \n    \n      \n        \n          Findings Dashboard
\n          \n            Welcome, ${userEmail}\n            Logout\n          
\n        
\n        \n        \n          \n            Welcome to your Findings Dashboard
\n            This is your central hub for managing research findings, transcripts, questions, and reports.
\n          
\n\n          \n            \n              System Health Status\n              \n                ${healthData.status}\n              \n            
\n            Current system status and database connectivity:
\n            \n            ${JSON.stringify(healthData, null, 2)}
\n            \n            \n              View Raw Health Endpoint →\n            \n\n            \n              Webhook Endpoint
\n\n              \n                ${webhookEndpoint}
\n              
\n\n              \n                To test: Get the NOTION_WEBHOOK_SECRET value from your vars.env file (provided by your administrator)
\n                \n                  \n                  \n                
\n                Ready to test webhook authentication...
\n              
\n            
\n          
\n        
\n      
\n\n      \n    \n    \n  `);\n};",[],[228,312,364,385],[228,312,364],{"_104":393,"_95":240,"_157":394,"_159":313,"_160":139,"_161":162,"_163":164,"_106":395,"_100":32,"_166":179,"_168":396,"_169":22,"_170":-5,"_171":397,"_98":398},"d0f9d458-7951-11f0-8810-0224a6c84d84","0198aa63-0ee2-725e-8c9f-cbd69df307e2",["D",1755205275298],"# Routes\n\nHTTP route handlers organized by functionality. Each subdirectory has a `_[directory_name].routes.ts` file that mounts routes for that section.",[],[228,312,240],{"_104":400,"_95":401,"_157":402,"_159":313,"_160":139,"_161":162,"_163":164,"_106":403,"_100":32,"_166":254,"_168":404,"_169":22,"_170":-5,"_171":405,"_98":406},"d0f9d566-7951-11f0-8810-0224a6c84d84","authCheck.ts","0198aa63-0ee2-725e-8c9f-cdfa4503b01e",["D",1755205275298],"// Public routes that don't require authentication\nconst PUBLIC_ROUTES = [\n  \"/api/health\", // Health check endpoint should be public\n  // Add other public routes here as needed\n  // '/demo/:id',  // Example: public demo viewing\n  // '/api/public', // Example: public API endpoints\n];\n\n// Helper function to check if a route is public\nfunction isPublicRoute(path: string): boolean {\n  return PUBLIC_ROUTES.some((route) => {\n    // Handle exact matches\n    if (route === path) return true;\n\n    // Handle wildcard patterns (basic implementation)\n    if (route.includes(\"*\")) {\n      const pattern = route.replace(\"*\", \".*\");\n      return new RegExp(`^${pattern}$`).test(path);\n    }\n\n    // Handle route parameters (basic implementation)\n    if (route.includes(\":\")) {\n      const pattern = route.replace(/:[^/]+/g, \"[^/]+\");\n      return new RegExp(`^${pattern}$`).test(path);\n    }\n\n    return false;\n  });\n}\n\nexport default async (c, next) => {\n  // Allow public routes to bypass authentication\n  if (isPublicRoute(c.req.path)) {\n    await next();\n    return;\n  }\n\n  const email = c.req.header(\"X-LastLogin-Email\");\n\n  if (!email) {\n    // Show login page if not authenticated\n    return c.html(`\n      \n      \n      \n        Findings - Login Required\n        \n      \n      \n        \n          Sign in to Findings
\n          Sign in to access your dashboard and manage your research findings.
\n          \n            Loading login button...
\n          
\n          \n            via LastLogin\n          
\n        
\n\n        \n      \n      \n    `);\n  }\n\n  // If authenticated, store email in context for use by routes\n  c.set(\"userEmail\", email);\n\n  // Continue to the next middleware/route\n  await next();\n};",[],[228,312,401],{"_104":408,"_95":409,"_157":410,"_159":313,"_160":139,"_161":211,"_163":22,"_106":411,"_100":32,"_166":412,"_168":413,"_169":22,"_170":-5,"_171":414,"_98":415},"82c45bdc-7a05-11f0-9236-0224a6c84d84","test-openai.ts","82c45c5e-7a05-11f0-9236-0224a6c84d84",["D",1755282453562],"http","/**\n * Test endpoint for OpenAI consensus analysis\n * Tests the simplified two-stage approach with timeout protection\n */\n\nimport { analyzeTranscriptsWithConsensus } from \"../services/openai.service.ts\";\n\n// Sample test data - small, controlled transcripts\nconst SAMPLE_TRANSCRIPTS = [\n  // Transcript 1: Clear feedback about challenges\n  `Meeting with Customer A - Product Feedback Session\n  \n  Interviewer: What are the main challenges you're facing with our product?\n  \n  Customer A: The biggest issue is definitely the loading times. Pages take 15-20 seconds to load, which is frustrating for our team. We also struggle with the user interface - it's not intuitive, and new employees need extensive training. The reporting feature is another pain point - it's hard to export data in the formats we need.\n  \n  Interviewer: How has this impacted your workflow?\n  \n  Customer A: We've had to implement workarounds, which adds extra steps to our daily processes. Some team members have started using competitor tools for certain tasks because they're faster.`,\n\n  // Transcript 2: Mixed feedback\n  `Meeting with Customer B - Quarterly Review\n  \n  Interviewer: How would you rate your experience with our platform?\n  \n  Customer B: It's been a mixed bag honestly. The core functionality works well - we love the analytics dashboard and the automated reports save us hours each week. But we've had some technical issues. The mobile app crashes frequently, and the integration with our CRM system has been problematic.\n  \n  Interviewer: What would you prioritize for improvements?\n  \n  Customer B: Fix the mobile stability first - that's critical for our field team. The CRM integration is important too, but we've found workarounds for now.`,\n\n  // Transcript 3: Doesn't directly address challenges\n  `Meeting with Customer C - Feature Request Discussion\n  \n  Interviewer: Tell us about your team's usage patterns.\n  \n  Customer C: We primarily use the platform for monthly reporting and data analysis. Our team of 12 accesses it regularly, mostly during business hours. We've been customers for about 18 months now and have seen good ROI from the insights we get.\n  \n  Interviewer: Any new features you'd like to see?\n  \n  Customer C: We'd love to see more customization options for the dashboards and maybe some AI-powered insights. Integration with more third-party tools would be valuable too.`\n];\n\nconst SAMPLE_QUESTION = \"What are the main challenges mentioned in customer feedback?\";\n\n/**\n * Timeout wrapper for promises\n */\nfunction withTimeout(promise: Promise, timeoutMs: number, operation: string): Promise {\n  return Promise.race([\n    promise,\n    new Promise((_, reject) =>\n      setTimeout(() => reject(new Error(`${operation} timed out after ${timeoutMs}ms`)), timeoutMs)\n    )\n  ]);\n}\n\n/**\n * Calculate estimated token count (rough approximation)\n */\nfunction estimateTokens(text: string): number {\n  // Rough estimate: ~4 characters per token\n  return Math.ceil(text.length / 4);\n}\n\n/**\n * Calculate estimated cost for GPT-5\n */\nfunction estimateCost(inputTokens: number, outputTokens: number): number {\n  // GPT-5 pricing (approximate - check current OpenAI pricing)\n  const INPUT_COST_PER_1K = 0.01; // $0.01 per 1K input tokens\n  const OUTPUT_COST_PER_1K = 0.03; // $0.03 per 1K output tokens\n  \n  return (inputTokens / 1000 * INPUT_COST_PER_1K) + (outputTokens / 1000 * OUTPUT_COST_PER_1K);\n}\n\nexport default async function(req: Request): Promise {\n  const startTime = Date.now();\n  console.log(\"🧪 Starting OpenAI service test...\");\n\n  try {\n    // Get API key from environment\n    const apiKey = Deno.env.get(\"OPENAI_API_KEY\");\n    if (!apiKey) {\n      return new Response(JSON.stringify({\n        success: false,\n        error: \"Missing OPENAI_API_KEY environment variable\",\n        timestamp: new Date().toISOString()\n      }), {\n        status: 400,\n        headers: { \"content-type\": \"application/json\" }\n      });\n    }\n\n    // Log test parameters\n    console.log(`📊 Test Parameters:`);\n    console.log(`  - Question: \"${SAMPLE_QUESTION}\"`);\n    console.log(`  - Transcripts: ${SAMPLE_TRANSCRIPTS.length}`);\n    console.log(`  - Total input chars: ${SAMPLE_TRANSCRIPTS.join(' ').length}`);\n    \n    // Estimate input tokens\n    const totalInputText = SAMPLE_QUESTION + SAMPLE_TRANSCRIPTS.join(' ');\n    const estimatedInputTokens = estimateTokens(totalInputText);\n    console.log(`  - Estimated input tokens: ${estimatedInputTokens}`);\n    console.log(`  - Estimated max cost: $${estimateCost(estimatedInputTokens, 2000).toFixed(4)}`);\n\n    // Run the analysis with timeout protection\n    console.log(\"🚀 Starting consensus analysis...\");\n    const analysisPromise = analyzeTranscriptsWithConsensus({\n      question: SAMPLE_QUESTION,\n      transcripts: SAMPLE_TRANSCRIPTS,\n      apiKey: apiKey\n    });\n\n    // Apply 5-minute total timeout\n    const result = await withTimeout(\n      analysisPromise, \n      5 * 60 * 1000, // 5 minutes\n      \"Consensus analysis\"\n    );\n\n    const endTime = Date.now();\n    const duration = endTime - startTime;\n\n    console.log(`✅ Analysis completed in ${duration}ms`);\n\n    // Log results summary\n    if (result.success && result.data) {\n      console.log(`📋 Results Summary:`);\n      console.log(`  - Consensus Level: ${result.data.consensusLevel}`);\n      console.log(`  - Confidence: ${(result.data.confidence * 100).toFixed(1)}%`);\n      console.log(`  - Key Points: ${result.data.keyPoints.length}`);\n      console.log(`  - Disagreements: ${result.data.disagreements.length}`);\n      console.log(`  - Per-transcript findings: ${result.data.perTranscriptFindings.length}`);\n    }\n\n    // Return detailed test results\n    return new Response(JSON.stringify({\n      testInfo: {\n        question: SAMPLE_QUESTION,\n        transcriptCount: SAMPLE_TRANSCRIPTS.length,\n        totalInputChars: totalInputText.length,\n        estimatedInputTokens,\n        durationMs: duration,\n        timestamp: new Date().toISOString()\n      },\n      result: result\n    }, null, 2), {\n      headers: { \"content-type\": \"application/json\" }\n    });\n\n  } catch (error) {\n    const endTime = Date.now();\n    const duration = endTime - startTime;\n    \n    console.error(`❌ Test failed after ${duration}ms:`, error);\n    \n    return new Response(JSON.stringify({\n      success: false,\n      error: error.message,\n      duration: duration,\n      timestamp: new Date().toISOString()\n    }, null, 2), {\n      status: 500,\n      headers: { \"content-type\": \"application/json\" }\n    });\n  }\n}",[],[228,312,409],{"_104":417,"_95":418,"_157":419,"_159":313,"_160":139,"_161":162,"_163":164,"_106":420,"_100":32,"_166":254,"_168":421,"_169":22,"_170":-5,"_171":422,"_98":423},"d0f9d8ae-7951-11f0-8810-0224a6c84d84","webhookAuthCheck.ts","0198aa63-0ee2-725e-8c9f-d0c7bb4f3135",["D",1755205275298],"export default async (c, next) => {\n  // Allow GET requests for debug endpoints to bypass webhook auth\n  if (c.req.method === \"GET\") {\n    await next();\n    return;\n  }\n\n  const apiKey = c.req.header(\"X-API-KEY\");\n  const expectedSecret = Deno.env.get(\"NOTION_WEBHOOK_SECRET\");\n\n  // Check if webhook secret is configured\n  if (!expectedSecret) {\n    console.log(\"Webhook authentication failed: NOTION_WEBHOOK_SECRET not configured\");\n    return c.json({ error: \"Authentication required\" }, 401);\n  }\n\n  // Check if API key is provided\n  if (!apiKey) {\n    console.log(\"Webhook authentication failed: No X-API-KEY header provided\");\n    return c.json({ error: \"Authentication required\" }, 401);\n  }\n\n  // Use constant-time comparison to prevent timing attacks\n  const expectedBuffer = new TextEncoder().encode(expectedSecret);\n  const providedBuffer = new TextEncoder().encode(apiKey);\n\n  // Ensure buffers are the same length for constant-time comparison\n  if (expectedBuffer.length !== providedBuffer.length) {\n    console.log(\"Webhook authentication failed: Invalid API key length\");\n    return c.json({ error: \"Authentication failed\" }, 403);\n  }\n\n  // Constant-time comparison\n  let isValid = true;\n  for (let i = 0; i < expectedBuffer.length; i++) {\n    if (expectedBuffer[i] !== providedBuffer[i]) {\n      isValid = false;\n    }\n  }\n\n  if (!isValid) {\n    console.log(\"Webhook authentication failed: Invalid API key\");\n    return c.json({ error: \"Authentication failed\" }, 403);\n  }\n\n  // Authentication successful, proceed to route handler\n  await next();\n};",[],[228,312,418],[228,312],{"_104":426,"_95":427,"_157":428,"_159":229,"_160":139,"_161":162,"_163":164,"_106":429,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":430,"_98":455},"d0f9dd9a-7951-11f0-8810-0224a6c84d84","services","0198aa63-0ee2-725e-8c9f-e39dc7a1bd77",["D",1755205275298],[431,438,446],{"_104":432,"_95":240,"_157":433,"_159":428,"_160":139,"_161":211,"_163":22,"_106":434,"_100":162,"_166":179,"_168":435,"_169":22,"_170":-5,"_171":436,"_98":437},"82c47be4-7a05-11f0-9236-0224a6c84d84","0198aa63-0ee2-725e-8c9f-da1f9466971b",["D",1755282453562],"# Services\n\nExternal API integrations - pure API calls only. Services should:\n\n- Make direct API calls to external systems\n- Return consistent `{ success: boolean, data?: any, error?: string }` format\n- NOT handle environment variables or business logic\n- NOT orchestrate multiple calls\n\n## Available Services\n\n- `notion.service.ts` - Notion API integration for database queries and page updates\n  - **Generic functions**: `updatePageProperties()` for any property updates\n  - **Content management**: Page content creation, updates, and deletion\n  - **Database operations**: Query databases and retrieve pages\n- `openai.service.ts` - OpenAI API integration with two-stage consensus analysis:\n  - **Stage 1**: Individual transcript analysis using `gpt-4o-mini` for cost efficiency\n  - **Stage 2**: Consensus synthesis using `gpt-4o` for high-quality reasoning\n  - **Features**: Structured JSON output, confidence scoring, disagreement tracking, evidence tables\n  - **Concurrency**: Configurable parallel processing with rate limiting\n  - **Fallback**: Graceful error handling with fallback consensus calculation",[],[228,427,240],{"_104":439,"_95":440,"_157":441,"_159":428,"_160":139,"_161":101,"_163":22,"_106":442,"_100":253,"_166":254,"_168":443,"_169":22,"_170":-5,"_171":444,"_98":445},"00e27f8a-82df-11f0-b5a9-0224a6c84d84","notion.service.ts","0198aa63-0ee2-725e-8c9f-deb04ed4654f",["D",1756255475247],"import { Client } from \"npm:@notionhq/client\";\n\nconst notion = new Client({ auth: Deno.env.get(\"NOTION_API_KEY\") });\n\nexport async function getDatabases() {\n  try {\n    const response = await notion.search({\n      filter: {\n        property: \"object\",\n        value: \"database\",\n      },\n    });\n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\nexport async function getDatabaseById(databaseId: string) {\n  try {\n    const response = await notion.databases.retrieve({\n      database_id: databaseId,\n    });\n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\nexport async function getPageProperties(pageId: string) {\n  try {\n    const response = await notion.pages.retrieve({\n      page_id: pageId,\n    });\n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\nexport async function updatePageStatus(pageId: string, status: string, blobKey?: string) {\n  try {\n    const properties: any = {\n      \"Status\": {\n        select: {\n          name: status\n        }\n      }\n    };\n\n    // Add blob key if provided\n    if (blobKey) {\n      properties[\"Blob key\"] = {\n        rich_text: [\n          {\n            text: {\n              content: blobKey\n            }\n          }\n        ]\n      };\n    }\n\n    const response = await notion.pages.update({\n      page_id: pageId,\n      properties: properties\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\nexport async function queryDatabasePages(databaseId: string, filter?: any) {\n  try {\n    const response = await notion.databases.query({\n      database_id: databaseId,\n      filter: filter\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\nexport async function getDatabasePages(databaseId: string) {\n  try {\n    const response = await notion.databases.query({\n      database_id: databaseId\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\nexport async function updatePageContent(pageId: string, blocks: any[]) {\n  try {\n    // First, get existing blocks to clear them\n    const existingBlocks = await notion.blocks.children.list({\n      block_id: pageId\n    });\n\n    // Delete existing blocks\n    for (const block of existingBlocks.results) {\n      await notion.blocks.delete({\n        block_id: block.id\n      });\n    }\n\n    // Add new blocks\n    const response = await notion.blocks.children.append({\n      block_id: pageId,\n      children: blocks\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Delete all block children from a page (clean slate)\n */\nexport async function deletePageContent(pageId: string) {\n  try {\n    const existingBlocks = await notion.blocks.children.list({\n      block_id: pageId\n    });\n\n    // Delete all existing blocks\n    for (const block of existingBlocks.results) {\n      await notion.blocks.delete({\n        block_id: block.id\n      });\n    }\n    \n    return {\n      success: true,\n      data: { deletedBlocks: existingBlocks.results.length },\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Append new blocks to existing page content (incremental updates)\n */\nexport async function appendPageContent(pageId: string, blocks: any[]) {\n  try {\n    const response = await notion.blocks.children.append({\n      block_id: pageId,\n      children: blocks\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Update page properties (generic function for any property updates)\n */\nexport async function updatePageProperties(pageId: string, properties: any) {\n  try {\n    const response = await notion.pages.update({\n      page_id: pageId,\n      properties: properties\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Get all content blocks from a page (with pagination)\n */\nexport async function getPageBlocks(pageId: string) {\n  try {\n    let allBlocks: any[] = [];\n    let hasMore = true;\n    let nextCursor: string | undefined = undefined;\n    \n    while (hasMore) {\n      const response = await notion.blocks.children.list({\n        block_id: pageId,\n        page_size: 100,\n        start_cursor: nextCursor\n      });\n      \n      allBlocks = allBlocks.concat(response.results);\n      hasMore = response.has_more;\n      nextCursor = response.next_cursor || undefined;\n      \n      console.log(`📄 Retrieved ${response.results.length} blocks (total: ${allBlocks.length}, hasMore: ${hasMore})`);\n    }\n    \n    return {\n      success: true,\n      data: { results: allBlocks },\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Create a new page in a database\n */\nexport async function createPageInDatabase(databaseId: string, properties: any) {\n  try {\n    const response = await notion.pages.create({\n      parent: {\n        database_id: databaseId\n      },\n      properties: properties\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Create a new page in a database with content\n */\nexport async function createPageInDatabaseWithContent(databaseId: string, properties: any, children: any[]) {\n  try {\n    const response = await notion.pages.create({\n      parent: {\n        database_id: databaseId\n      },\n      properties: properties,\n      children: children\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Create an inline database within a page\n */\nexport async function createInlineDatabase(pageId: string, title: string, properties: any) {\n  try {\n    const response = await notion.databases.create({\n      parent: {\n        type: \"page_id\",\n        page_id: pageId,\n      },\n      is_inline: true,\n      title: [\n        {\n          type: \"text\",\n          text: {\n            content: title,\n          },\n        },\n      ],\n      properties: properties,\n    });\n    \n    return {\n      success: true,\n      data: {\n        databaseId: response.id,\n        database: response\n      },\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Copy blocks to a target page (with batching and retry logic)\n */\nexport async function copyBlocksToPage(targetPageId: string, blocks: any[]) {\n  try {\n    // Log the blocks we're trying to copy for debugging\n    console.log(`🔧 Attempting to copy ${blocks.length} blocks to page ${targetPageId}`);\n    console.log(`🔧 Block types:`, blocks.map(b => b.type));\n    \n    // Notion API limit is 100 blocks per request, so we need to batch\n    const BATCH_SIZE = 50; // Reduced from 100 to be more conservative\n    const batches = [];\n    \n    for (let i = 0; i < blocks.length; i += BATCH_SIZE) {\n      batches.push(blocks.slice(i, i + BATCH_SIZE));\n    }\n    \n    console.log(`🔧 Splitting into ${batches.length} batches of up to ${BATCH_SIZE} blocks each`);\n    \n    let totalCopied = 0;\n    let failedBatches = 0;\n    \n    for (let i = 0; i < batches.length; i++) {\n      const batch = batches[i];\n      console.log(`🔧 Copying batch ${i + 1}/${batches.length} (${batch.length} blocks)`);\n      \n      // Retry logic for each batch\n      let batchSuccess = false;\n      let retryCount = 0;\n      const maxRetries = 2;\n      \n      while (!batchSuccess && retryCount <= maxRetries) {\n        try {\n          const response = await notion.blocks.children.append({\n            block_id: targetPageId,\n            children: batch\n          });\n          \n          batchSuccess = true;\n          totalCopied += batch.length;\n          console.log(`✅ Batch ${i + 1} copied successfully (${totalCopied}/${blocks.length} total)`);\n          \n        } catch (batchError) {\n          retryCount++;\n          console.log(`⚠️ Batch ${i + 1} failed (attempt ${retryCount}/${maxRetries + 1}): ${batchError.message}`);\n          \n          if (retryCount <= maxRetries) {\n            // Exponential backoff: wait longer between retries\n            const delay = Math.pow(2, retryCount) * 500; // 1s, 2s delays\n            console.log(`⏳ Retrying batch ${i + 1} in ${delay}ms...`);\n            await new Promise(resolve => setTimeout(resolve, delay));\n          } else {\n            console.error(`❌ Batch ${i + 1} failed permanently after ${maxRetries + 1} attempts`);\n            failedBatches++;\n          }\n        }\n      }\n      \n      // Longer delay between batches to avoid rate limiting\n      if (i < batches.length - 1) {\n        await new Promise(resolve => setTimeout(resolve, 300)); // Increased to 300ms\n      }\n    }\n    \n    // Determine success based on how many batches failed\n    const successRate = (batches.length - failedBatches) / batches.length;\n    const isSuccess = successRate >= 0.8; // Consider success if 80%+ of batches succeeded\n    \n    console.log(`📊 Copy operation completed: ${totalCopied}/${blocks.length} blocks copied, ${failedBatches}/${batches.length} batches failed`);\n    \n    return {\n      success: isSuccess,\n      data: { \n        totalBlocks: totalCopied, \n        batches: batches.length,\n        failedBatches: failedBatches,\n        successRate: Math.round(successRate * 100)\n      },\n      timestamp: new Date().toISOString(),\n      warning: failedBatches > 0 ? `${failedBatches} batches failed, but ${Math.round(successRate * 100)}% of content was copied` : undefined\n    };\n  } catch (error) {\n    console.error(`❌ Error copying blocks:`, error);\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Archive a single page (Notion's way of deleting)\n */\nexport async function archivePage(pageId: string) {\n  try {\n    const response = await notion.pages.update({\n      page_id: pageId,\n      archived: true\n    });\n    \n    return {\n      success: true,\n      data: response,\n      timestamp: new Date().toISOString(),\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}\n\n/**\n * Delete all pages from a database by archiving them\n */\nexport async function deleteAllDatabasePages(databaseId: string) {\n  try {\n    console.log(`🗑️ Getting all pages from database: ${databaseId}`);\n    \n    // Get all pages in the database\n    const pagesResult = await getDatabasePages(databaseId);\n    if (!pagesResult.success) {\n      return {\n        success: false,\n        error: `Failed to get database pages: ${pagesResult.error}`,\n        timestamp: new Date().toISOString(),\n      };\n    }\n    \n    const pages = pagesResult.data.results;\n    console.log(`🗑️ Found ${pages.length} pages to delete`);\n    \n    if (pages.length === 0) {\n      return {\n        success: true,\n        data: { deletedPages: 0 },\n        timestamp: new Date().toISOString(),\n      };\n    }\n    \n    // Archive each page\n    let deletedCount = 0;\n    let failedCount = 0;\n    \n    for (const page of pages) {\n      const archiveResult = await archivePage(page.id);\n      if (archiveResult.success) {\n        deletedCount++;\n        console.log(`✅ Archived page: ${page.id}`);\n      } else {\n        failedCount++;\n        console.error(`❌ Failed to archive page ${page.id}: ${archiveResult.error}`);\n      }\n      \n      // Small delay to avoid rate limiting\n      await new Promise(resolve => setTimeout(resolve, 100));\n    }\n    \n    console.log(`🗑️ Deletion complete: ${deletedCount} deleted, ${failedCount} failed`);\n    \n    return {\n      success: failedCount === 0,\n      data: { \n        deletedPages: deletedCount,\n        failedPages: failedCount,\n        totalPages: pages.length\n      },\n      timestamp: new Date().toISOString(),\n      warning: failedCount > 0 ? `${failedCount} pages failed to delete` : undefined\n    };\n  } catch (error) {\n    return {\n      success: false,\n      error: error.message,\n      timestamp: new Date().toISOString(),\n    };\n  }\n}",[],[228,427,440],{"_104":447,"_95":448,"_157":449,"_159":428,"_160":139,"_161":450,"_163":164,"_106":451,"_100":162,"_166":254,"_168":452,"_169":22,"_170":-5,"_171":453,"_98":454},"48eaad56-7a0c-11f0-b82f-0224a6c84d84","openai.service.ts","82c4626c-7a05-11f0-9236-0224a6c84d84",23,["D",1755285362994],"/**\n * Two-Stage Consensus Analysis for Meeting Transcripts\n * \n * Stage 1: Analyze each transcript individually against the question\n * Stage 2: Synthesize consensus across all individual analyses\n * \n * Uses actual OpenAI Chat Completions API with proper error handling\n */\n\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\n\n/*** Types ***/\nexport interface ConsensusAnalysisRequest {\n  question: string;\n  transcripts: string[];\n  apiKey: string;\n}\n\nexport type Stance = \"supports\" | \"mixed\" | \"contradicts\" | \"not enough evidence\";\n\nexport interface PerTranscriptFinding {\n  key: string;\n  stance: Stance;\n  shortRationale: string; // <= 120 chars\n}\n\nexport interface ConsensusAnswer {\n  question: string;\n  consensusLevel: \"high\" | \"medium\" | \"low\";\n  directAnswer: string;\n  keyPoints: string[];\n  disagreements: string[];\n  confidence: number; // 0..1\n  methodologyNote: string;\n  perTranscriptFindings: PerTranscriptFinding[];\n}\n\nexport interface ConsensusAnalysisResponse {\n  success: boolean;\n  data?: ConsensusAnswer;\n  error?: string;\n  timestamp: string;\n}\n\nexport interface ConsensusOptions {\n  extractModel?: string; // default: \"gpt-4o-mini\"\n  consensusModel?: string; // default: \"gpt-4o\"\n  maxConcurrency?: number; // default: 3\n  maxTranscriptChars?: number; // default: 15000\n}\n\ninterface IndividualAnalysis {\n  transcriptKey: string;\n  stance: Stance;\n  keyFindings: string[];\n  supportingQuotes: string[];\n  rationale: string;\n  confidence: number;\n}\n\n/*** Configuration ***/\nconst DEFAULTS: Required = {\n  extractModel: \"gpt-4o-mini\",\n  consensusModel: \"gpt-4o\",\n  maxConcurrency: 3,\n  maxTranscriptChars: 100000,\n};\n\n/*** Stage 1: Individual Transcript Analysis ***/\nconst INDIVIDUAL_ANALYSIS_PROMPT = `You are a meticulous research analyst. Analyze the provided interview transcript to answer a specific research question.\n\nYour task:\n1. Determine your stance on how this transcript answers the question\n2. Extract key findings that support your stance\n3. Find relevant quotes (if any) that support your findings\n4. Provide a clear rationale for your stance\n5. Rate your confidence in this analysis\n\nResponse format (JSON):\n{\n  \"stance\": \"supports|mixed|contradicts|not enough evidence\",\n  \"keyFindings\": [\"finding 1\", \"finding 2\", \"finding 3\"],\n  \"supportingQuotes\": [\"quote 1\", \"quote 2\"],\n  \"rationale\": \"Brief explanation of why you chose this stance\",\n  \"confidence\": 0.85\n}\n\nGuidelines:\n- Be objective and evidence-based\n- If the transcript doesn't address the question, use \"not enough evidence\"\n- Keep findings concise but specific\n- Quotes should be under 140 characters\n- Confidence should reflect how clearly the transcript addresses the question (0.0 to 1.0)`;\n\nasync function analyzeIndividualTranscript(\n  openai: OpenAI,\n  model: string,\n  question: string,\n  transcript: string,\n  transcriptKey: string,\n  maxChars: number\n): Promise {\n  // Truncate transcript if too long\n  const truncatedTranscript = transcript.length > maxChars \n    ? transcript.substring(0, maxChars) + \"... [truncated]\"\n    : transcript;\n\n  const userPrompt = `RESEARCH QUESTION:\n${question}\n\nTRANSCRIPT (${transcriptKey}):\n${truncatedTranscript}`;\n\n  try {\n    const completion = await openai.chat.completions.create({\n      model,\n      messages: [\n        { role: \"system\", content: INDIVIDUAL_ANALYSIS_PROMPT },\n        { role: \"user\", content: userPrompt }\n      ],\n      response_format: { type: \"json_object\" },\n      temperature: 0.1,\n      max_tokens: 1000\n    });\n\n    const content = completion.choices[0]?.message?.content;\n    if (!content) {\n      throw new Error(\"No response content from OpenAI\");\n    }\n\n    const parsed = JSON.parse(content);\n    \n    return {\n      transcriptKey,\n      stance: parsed.stance || \"not enough evidence\",\n      keyFindings: Array.isArray(parsed.keyFindings) ? parsed.keyFindings : [],\n      supportingQuotes: Array.isArray(parsed.supportingQuotes) ? parsed.supportingQuotes : [],\n      rationale: parsed.rationale || \"No rationale provided\",\n      confidence: typeof parsed.confidence === 'number' ? parsed.confidence : 0.5\n    };\n\n  } catch (error) {\n    console.error(`Error analyzing ${transcriptKey}:`, error);\n    return {\n      transcriptKey,\n      stance: \"not enough evidence\",\n      keyFindings: [],\n      supportingQuotes: [],\n      rationale: `Analysis failed: ${error.message}`,\n      confidence: 0.0\n    };\n  }\n}\n\n/*** Stage 2: Consensus Synthesis ***/\nconst CONSENSUS_SYNTHESIS_PROMPT = `You are a senior research synthesizer. You will receive multiple individual analyses of different transcripts for the same research question. Your job is to synthesize these into a comprehensive consensus answer.\n\nAnalyze the individual findings and create a consensus that:\n1. Provides a direct, actionable answer to the research question\n2. Identifies the level of consensus across transcripts\n3. Highlights key points that most transcripts agree on\n4. Notes any significant disagreements or outliers\n5. Provides an overall confidence score\n6. Explains your methodology\n\nResponse format (JSON):\n{\n  \"consensusLevel\": \"high|medium|low\",\n  \"directAnswer\": \"Clear, direct answer to the research question\",\n  \"keyPoints\": [\"point 1\", \"point 2\", \"point 3\"],\n  \"disagreements\": [\"disagreement 1\", \"disagreement 2\"],\n  \"confidence\": 0.85,\n  \"methodologyNote\": \"Brief explanation of how you reached consensus\"\n}\n\nConsensus Level Guidelines:\n- HIGH: 80%+ of transcripts support the same conclusion\n- MEDIUM: 60-79% agreement, or mixed but trending\n- LOW: <60% agreement, or significant contradictions\n\nConfidence Guidelines:\n- Consider both the consensus level and the quality of evidence\n- Factor in how directly transcripts addressed the question\n- Account for the strength of supporting evidence`;\n\nasync function synthesizeConsensus(\n  openai: OpenAI,\n  model: string,\n  question: string,\n  individualAnalyses: IndividualAnalysis[]\n): Promise {\n  const analysisText = individualAnalyses.map((analysis, index) => \n    `### ${analysis.transcriptKey}\nStance: ${analysis.stance}\nConfidence: ${analysis.confidence}\nKey Findings: ${analysis.keyFindings.join('; ')}\nSupporting Quotes: ${analysis.supportingQuotes.join('; ')}\nRationale: ${analysis.rationale}`\n  ).join('\\n\\n');\n\n  const userPrompt = `RESEARCH QUESTION:\n${question}\n\nINDIVIDUAL TRANSCRIPT ANALYSES:\n${analysisText}\n\nPlease synthesize these analyses into a comprehensive consensus answer.`;\n\n  try {\n    const completion = await openai.chat.completions.create({\n      model,\n      messages: [\n        { role: \"system\", content: CONSENSUS_SYNTHESIS_PROMPT },\n        { role: \"user\", content: userPrompt }\n      ],\n      response_format: { type: \"json_object\" },\n      temperature: 0.1,\n      max_tokens: 1500\n    });\n\n    const content = completion.choices[0]?.message?.content;\n    if (!content) {\n      throw new Error(\"No response content from OpenAI\");\n    }\n\n    const parsed = JSON.parse(content);\n    \n    // Create per-transcript findings for the final output\n    const perTranscriptFindings: PerTranscriptFinding[] = individualAnalyses.map(analysis => ({\n      key: analysis.transcriptKey,\n      stance: analysis.stance,\n      shortRationale: analysis.rationale.length > 120 \n        ? analysis.rationale.substring(0, 117) + \"...\"\n        : analysis.rationale\n    }));\n\n    return {\n      question,\n      consensusLevel: parsed.consensusLevel || \"low\",\n      directAnswer: parsed.directAnswer || \"Unable to determine consensus answer\",\n      keyPoints: Array.isArray(parsed.keyPoints) ? parsed.keyPoints : [],\n      disagreements: Array.isArray(parsed.disagreements) ? parsed.disagreements : [],\n      confidence: typeof parsed.confidence === 'number' ? parsed.confidence : 0.5,\n      methodologyNote: parsed.methodologyNote || \"Consensus analysis completed\",\n      perTranscriptFindings\n    };\n\n  } catch (error) {\n    console.error(\"Error in consensus synthesis:\", error);\n    \n    // Fallback consensus based on individual analyses\n    const stanceCounts = individualAnalyses.reduce((acc, analysis) => {\n      acc[analysis.stance] = (acc[analysis.stance] || 0) + 1;\n      return acc;\n    }, {} as Record);\n\n    const totalAnalyses = individualAnalyses.length;\n    const maxStance = Object.entries(stanceCounts).reduce((a, b) => \n      stanceCounts[a[0] as Stance] > stanceCounts[b[0] as Stance] ? a : b\n    )[0] as Stance;\n    \n    const maxCount = stanceCounts[maxStance];\n    const consensusPercentage = maxCount / totalAnalyses;\n    \n    const consensusLevel = consensusPercentage >= 0.8 ? \"high\" : \n                          consensusPercentage >= 0.6 ? \"medium\" : \"low\";\n\n    const perTranscriptFindings: PerTranscriptFinding[] = individualAnalyses.map(analysis => ({\n      key: analysis.transcriptKey,\n      stance: analysis.stance,\n      shortRationale: analysis.rationale.length > 120 \n        ? analysis.rationale.substring(0, 117) + \"...\"\n        : analysis.rationale\n    }));\n\n    return {\n      question,\n      consensusLevel,\n      directAnswer: `Synthesis failed, but ${maxCount}/${totalAnalyses} transcripts ${maxStance} the question. Error: ${error.message}`,\n      keyPoints: [],\n      disagreements: [`Synthesis error: ${error.message}`],\n      confidence: 0.3,\n      methodologyNote: `Fallback analysis due to synthesis error. Based on stance distribution: ${JSON.stringify(stanceCounts)}`,\n      perTranscriptFindings\n    };\n  }\n}\n\n/*** Concurrency Control ***/\nasync function mapWithLimit(\n  items: T[],\n  limit: number,\n  fn: (item: T, index: number) => Promise\n): Promise {\n  const results: R[] = new Array(items.length);\n  let index = 0;\n\n  const workers = Array.from({ length: Math.min(limit, items.length) }, async () => {\n    while (index < items.length) {\n      const currentIndex = index++;\n      results[currentIndex] = await fn(items[currentIndex], currentIndex);\n    }\n  });\n\n  await Promise.all(workers);\n  return results;\n}\n\n/*** Public API ***/\nexport async function analyzeTranscriptsWithConsensus(\n  request: ConsensusAnalysisRequest,\n  options: ConsensusOptions = {}\n): Promise {\n  const timestamp = new Date().toISOString();\n\n  // Validation\n  if (!request?.apiKey) {\n    return { success: false, error: \"Missing OpenAI API key\", timestamp };\n  }\n  if (!request?.question?.trim()) {\n    return { success: false, error: \"Missing or empty question\", timestamp };\n  }\n  if (!request?.transcripts?.length) {\n    return { success: false, error: \"No transcripts provided\", timestamp };\n  }\n\n  const config = { ...DEFAULTS, ...options };\n  const openai = new OpenAI({ apiKey: request.apiKey });\n\n  try {\n    console.log(`🔍 Starting 2-stage analysis for question: \"${request.question}\"`);\n    console.log(`📄 Processing ${request.transcripts.length} transcripts with max ${config.maxConcurrency} concurrent requests`);\n\n    // Stage 1: Analyze each transcript individually\n    console.log(\"📊 Stage 1: Individual transcript analysis...\");\n    const individualAnalyses = await mapWithLimit(\n      request.transcripts,\n      config.maxConcurrency,\n      async (transcript, index) => {\n        const transcriptKey = `Transcript ${index + 1}`;\n        console.log(`  🔍 Analyzing ${transcriptKey}...`);\n        \n        const analysis = await analyzeIndividualTranscript(\n          openai,\n          config.extractModel,\n          request.question,\n          transcript,\n          transcriptKey,\n          config.maxTranscriptChars\n        );\n        \n        console.log(`  ✅ ${transcriptKey}: ${analysis.stance} (confidence: ${Math.round(analysis.confidence * 100)}%)`);\n        return analysis;\n      }\n    );\n\n    // Stage 2: Synthesize consensus\n    console.log(\"🤝 Stage 2: Consensus synthesis...\");\n    const consensus = await synthesizeConsensus(\n      openai,\n      config.consensusModel,\n      request.question,\n      individualAnalyses\n    );\n\n    console.log(`✅ Consensus reached: ${consensus.consensusLevel} (confidence: ${Math.round(consensus.confidence * 100)}%)`);\n\n    return {\n      success: true,\n      data: consensus,\n      timestamp\n    };\n\n  } catch (error) {\n    console.error(\"❌ Error in consensus analysis:\", error);\n    return {\n      success: false,\n      error: error instanceof Error ? error.message : String(error),\n      timestamp\n    };\n  }\n}\n\n// Legacy function for backward compatibility (not used in new approach)\nexport async function analyzeTranscriptsForQuestion(\n  question: string,\n  transcripts: string[],\n  apiKey: string\n): Promise<{ success: boolean; data?: any; error?: string }> {\n  const result = await analyzeTranscriptsWithConsensus({\n    question,\n    transcripts,\n    apiKey\n  });\n  \n  return {\n    success: result.success,\n    data: result.data ? { answer: result.data.directAnswer } : undefined,\n    error: result.error\n  };\n}",[],[228,427,448],[228,427],{"_104":457,"_95":458,"_157":459,"_159":229,"_160":139,"_161":162,"_163":164,"_106":460,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":461,"_98":477},"d0f9df7a-7951-11f0-8810-0224a6c84d84","types","0198aa63-0ee2-725e-8c9f-e81d8e4fe527",["D",1755205275298],[462,469],{"_104":463,"_95":240,"_157":464,"_159":459,"_160":139,"_161":211,"_163":22,"_106":465,"_100":162,"_166":179,"_168":466,"_169":22,"_170":-5,"_171":467,"_98":468},"82c485bc-7a05-11f0-9236-0224a6c84d84","0198aa63-0ee2-725e-8c9f-e4354f333684",["D",1755282453562],"# Types\n\nShared TypeScript type definitions.\n\n## Available Types\n\n- `findings.types.ts` - Types for findings analysis workflow",[],[228,458,240],{"_104":470,"_95":471,"_157":472,"_159":459,"_160":139,"_161":356,"_163":22,"_106":473,"_100":244,"_166":254,"_168":474,"_169":22,"_170":-5,"_171":475,"_98":476},"82afb36c-7afa-11f0-8f1f-0224a6c84d84","findings.types.ts","82c46dca-7a05-11f0-9236-0224a6c84d84",["D",1755387680127],"/**\n * Types for findings analysis workflow\n */\n\nexport interface FindingsQuestion {\n  id: string;\n  name: string; // The question text from Name property\n}\n\nexport interface TranscriptPage {\n  id: string;\n  blobKey: string; // From Blob key property\n}\n\nexport interface TranscriptBlob {\n  pageId: string;\n  extractedText: string;\n  extractedAt: string;\n  textLength: number;\n  pdfUrl: string;\n}\n\nexport interface QuestionAnalysis {\n  question: string;\n  answer: string;\n}\n\n// Enhanced consensus analysis types\nexport interface ConsensusAnswer {\n  question: string;\n  consensusLevel: \"high\" | \"medium\" | \"low\";\n  directAnswer: string;\n  keyPoints: string[];              // most agreed-on points\n  disagreements: string[];          // notable divergences/outliers\n  confidence: number;               // 0-1\n  methodologyNote: string;          // how consensus was computed\n  perTranscriptFindings: Array<{\n    key: string;                    // transcript identifier\n    stance: \"supports\" | \"mixed\" | \"contradicts\" | \"not enough evidence\";\n    shortRationale: string;         // one-liner why\n  }>;\n}\n\nexport interface EnhancedQuestionAnalysis {\n  question: string;\n  consensusAnswer: ConsensusAnswer;\n}\n\nexport interface ProcessFindingsRequest {\n  // No parameters needed - uses environment variables\n}\n\nexport interface ProcessFindingsResponse {\n  success: boolean;\n  reportPageId?: string;\n  questionsProcessed?: number;\n  questionsSucceeded?: number;\n  transcriptsAnalyzed?: number;\n  remainingQuestions?: number; // Number of questions still to be processed\n  timestamp: string;\n  error?: string;\n  details?: string;\n}\n\nexport interface DuplicatePageRequest {\n  pageId: string;\n}\n\nexport interface DuplicatePageResponse {\n  success: boolean;\n  sourcePageId: string;\n  targetPageId?: string;\n  blocksCopied?: number;\n  blocksFiltered?: number;\n  timestamp: string;\n  error?: string;\n  details?: string;\n  warning?: string;\n}\n\nexport interface ConvertPageRequest {\n  pageId: string;\n}\n\nexport interface ConvertPageResponse {\n  success: boolean;\n  sourcePageId: string;\n  targetDatabaseId: string;\n  h2SectionsFound: number;\n  pagesCreated: number;\n  pagesWithContent: number;\n  timestamp: string;\n  error?: string;\n  details?: string;\n  warnings?: string[];\n}\n\nexport interface H2Section {\n  title: string;\n  contentBlocks: any[]; // excludes the H2 block itself\n}",[],[228,458,471],[228,458],{"_104":479,"_95":480,"_157":481,"_159":229,"_160":139,"_161":162,"_163":164,"_106":482,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":483,"_98":523},"d0f9e376-7951-11f0-8810-0224a6c84d84","utils","0198aa63-0ee2-725e-8c9f-f5ea225718eb",["D",1755205275298],[484,491,499,507,515],{"_104":485,"_95":240,"_157":486,"_159":481,"_160":139,"_161":211,"_163":22,"_106":487,"_100":162,"_166":179,"_168":488,"_169":22,"_170":-5,"_171":489,"_98":490},"82c48710-7a05-11f0-9236-0224a6c84d84","0198aa63-0ee2-725e-8c9f-ee81b2256350",["D",1755282453562],"# Utils\n\nCommon utility functions.\n\n## Available Utils\n\n- `pdfExtractor.ts` - PDF text extraction utilities\n- `process-timing.utils.ts` - Process timing calculations and formatting utilities\n- `notion-properties.utils.ts` - Notion property creation and formatting utilities",[],[228,480,240],{"_104":492,"_95":493,"_157":494,"_159":481,"_160":139,"_161":101,"_163":22,"_106":495,"_100":162,"_166":254,"_168":496,"_169":22,"_170":-5,"_171":497,"_98":498},"00e28ade-82df-11f0-b5a9-0224a6c84d84","notion-properties.utils.ts","82c47040-7a05-11f0-9236-0224a6c84d84",["D",1756255475247],"/**\n * Notion Properties Utilities\n * Helper functions for creating Notion property objects\n */\n\nexport interface NotionDateProperty {\n  date: {\n    start: string;\n  };\n}\n\nexport interface NotionSelectProperty {\n  select: {\n    name: string;\n  };\n}\n\nexport interface NotionRichTextProperty {\n  rich_text: Array<{\n    text: {\n      content: string;\n    };\n  }>;\n}\n\nexport interface NotionProperties {\n  [key: string]: NotionDateProperty | NotionSelectProperty | NotionRichTextProperty;\n}\n\n/**\n * Create a Notion date property\n */\nexport function createDateProperty(date: Date): NotionDateProperty {\n  return {\n    date: {\n      start: date.toISOString()\n    }\n  };\n}\n\n/**\n * Create a Notion select property\n */\nexport function createStatusProperty(status: string): NotionSelectProperty {\n  return {\n    select: {\n      name: status\n    }\n  };\n}\n\n/**\n * Create timestamp properties for process tracking\n */\nexport function createTimestampProperties(\n  start?: Date,\n  end?: Date,\n  status?: string\n): NotionProperties {\n  const properties: NotionProperties = {};\n\n  if (start) {\n    properties[\"Start\"] = createDateProperty(start);\n  }\n\n  if (end) {\n    properties[\"End\"] = createDateProperty(end);\n  }\n\n  if (status) {\n    properties[\"Status\"] = createStatusProperty(status);\n  }\n\n  return properties;\n}\n\n/**\n * Create Analysis Results database schema\n * Defines the structure and options for the findings analysis database\n */\nexport function createAnalysisResultsDatabaseSchema(): any {\n  return {\n    \"Name\": {\n      title: {}\n    },\n    \"Consensus Level\": {\n      select: {\n        options: [\n          { name: \"High\", color: \"green\" },\n          { name: \"Medium\", color: \"yellow\" },\n          { name: \"Low\", color: \"red\" }\n        ]\n      }\n    },\n    \"Confidence Score\": {\n      number: {\n        format: \"percent\"\n      }\n    },\n    \"Status\": {\n      select: {\n        options: [\n          { name: \"Done\", color: \"green\" },\n          { name: \"Error\", color: \"red\" }\n        ]\n      }\n    },\n    \"Category\": {\n      select: {\n        options: [\n          { name: \"Strategy\", color: \"blue\" },\n          { name: \"GTM\", color: \"purple\" },\n          { name: \"AI\", color: \"orange\" },\n          { name: \"Product feedback\", color: \"pink\" },\n          { name: \"Competition\", color: \"brown\" }\n        ]\n      }\n    },\n    \"Priority\": {\n      select: {\n        options: [\n          { name: \"1\", color: \"red\" },\n          { name: \"2\", color: \"yellow\" },\n          { name: \"3\", color: \"green\" },\n          { name: \"Exclude\", color: \"gray\" }\n        ]\n      }\n    }\n  };\n}\n\n/**\n * Create Results Database ID property for storing database reference\n */\nexport function createResultsDatabaseProperty(databaseId: string): NotionProperties {\n  return {\n    \"Results Database ID\": {\n      rich_text: [\n        {\n          text: {\n            content: databaseId\n          }\n        }\n      ]\n    } as NotionRichTextProperty\n  };\n}",[],[228,480,493],{"_104":500,"_95":501,"_157":502,"_159":481,"_160":139,"_161":220,"_163":164,"_106":503,"_100":32,"_166":254,"_168":504,"_169":22,"_170":-5,"_171":505,"_98":506},"c8fa4844-79c6-11f0-95e0-0224a6c84d84","pdfExtractor.ts","c8fa48c6-79c6-11f0-95e0-0224a6c84d84",["D",1755255513063],"/**\n * PDF Text Extraction Utility\n * Extracts text from PDF files using pdfjs-dist\n */\n\nexport async function extractTextFromPDF(file: File): Promise {\n  try {\n    console.log(`📄 Starting PDF text extraction for file: ${file.name}`);\n    \n    // Convert File to ArrayBuffer\n    const arrayBuffer = await file.arrayBuffer();\n    \n    // Try using pdfjs-dist which is more Deno-compatible\n    const pdfjsLib = await import(\"https://esm.sh/pdfjs-dist@4.0.379/legacy/build/pdf.mjs\");\n    \n    // Load the PDF document\n    const loadingTask = pdfjsLib.getDocument({ data: arrayBuffer });\n    const pdfDocument = await loadingTask.promise;\n    \n    console.log(`📄 PDF loaded with ${pdfDocument.numPages} pages`);\n    \n    // Extract text from all pages\n    let fullText = '';\n    for (let pageNum = 1; pageNum <= pdfDocument.numPages; pageNum++) {\n      const page = await pdfDocument.getPage(pageNum);\n      const textContent = await page.getTextContent();\n      \n      // Combine text items into a single string\n      const pageText = textContent.items\n        .map((item: any) => item.str)\n        .join(' ');\n      \n      fullText += pageText + '\\n';\n    }\n    \n    console.log(`✅ Text extracted successfully. Length: ${fullText.length} characters`);\n    console.log(`📝 Text preview (first 200 chars): ${fullText.substring(0, 200)}...`);\n    \n    return fullText.trim();\n    \n  } catch (error) {\n    console.error(`❌ PDF text extraction failed:`, error);\n    throw new Error(`Failed to extract text from PDF: ${error.message}`);\n  }\n}\n\nexport async function extractTextFromPDFUrl(pdfUrl: string): Promise {\n  try {\n    console.log(`📄 Downloading PDF from URL: ${pdfUrl}`);\n    \n    // Download the PDF file\n    const response = await fetch(pdfUrl);\n    if (!response.ok) {\n      throw new Error(`Failed to download PDF: ${response.status} ${response.statusText}`);\n    }\n    \n    // Convert response to File object\n    const arrayBuffer = await response.arrayBuffer();\n    const file = new File([arrayBuffer], 'document.pdf', { type: 'application/pdf' });\n    \n    // Extract text using the existing function\n    return await extractTextFromPDF(file);\n    \n  } catch (error) {\n    console.error(`❌ PDF download and extraction failed:`, error);\n    throw new Error(`Failed to download and extract text from PDF: ${error.message}`);\n  }\n}",[],[228,480,501],{"_104":508,"_95":509,"_157":510,"_159":481,"_160":139,"_161":211,"_163":164,"_106":511,"_100":32,"_166":254,"_168":512,"_169":22,"_170":-5,"_171":513,"_98":514},"82c47144-7a05-11f0-9236-0224a6c84d84","process-timing.utils.ts","82c471a8-7a05-11f0-9236-0224a6c84d84",["D",1755282453562],"/**\n * Process Timing Utilities\n * Common functions for timing calculations and formatting\n */\n\nexport interface Duration {\n  minutes: number;\n  seconds: number;\n}\n\n/**\n * Format date in NYC timezone\n */\nexport function formatNYCTime(date: Date, format: '12h' | '24h' = '12h'): string {\n  return date.toLocaleString(\"en-US\", {\n    timeZone: \"America/New_York\",\n    year: \"numeric\",\n    month: \"2-digit\",\n    day: \"2-digit\",\n    hour: \"2-digit\",\n    minute: \"2-digit\",\n    second: \"2-digit\",\n    hour12: format === '12h'\n  });\n}\n\n/**\n * Calculate duration between two dates\n */\nexport function calculateDuration(startTime: Date, endTime: Date): Duration {\n  const totalTimeMs = endTime.getTime() - startTime.getTime();\n  const minutes = Math.floor(totalTimeMs / 60000);\n  const seconds = Math.floor((totalTimeMs % 60000) / 1000);\n  \n  return { minutes, seconds };\n}\n\n/**\n * Format duration for display\n */\nexport function formatDuration(duration: Duration): string {\n  return duration.minutes > 0 ? `${duration.minutes}m ${duration.seconds}s` : `${duration.seconds}s`;\n}\n\n/**\n * Create timing summary blocks for Notion report\n */\nexport function createTimingSummaryBlocks(\n  duration: Duration, \n  totalQuestions: number, \n  successfulQuestions: number\n): any[] {\n  const timeDisplay = formatDuration(duration);\n  const successRate = Math.round((successfulQuestions / totalQuestions) * 100);\n  const nycTime = formatNYCTime(new Date(), '12h');\n  \n  return [\n    {\n      object: \"block\",\n      type: \"divider\",\n      divider: {}\n    },\n    {\n      object: \"block\",\n      type: \"heading_3\",\n      heading_3: {\n        rich_text: [\n          {\n            type: \"text\",\n            text: {\n              content: \"📊 Report Generation Summary\"\n            }\n          }\n        ]\n      }\n    },\n    {\n      object: \"block\",\n      type: \"callout\",\n      callout: {\n        icon: { emoji: \"⏱️\" },\n        rich_text: [\n          {\n            type: \"text\",\n            text: {\n              content: `Total time to generate report: ${timeDisplay}`\n            },\n            annotations: { bold: true }\n          }\n        ]\n      }\n    },\n    {\n      object: \"block\",\n      type: \"paragraph\",\n      paragraph: {\n        rich_text: [\n          {\n            type: \"text\",\n            text: {\n              content: `Questions processed: ${successfulQuestions}/${totalQuestions} (${successRate}% success rate)`\n            }\n          }\n        ]\n      }\n    },\n    {\n      object: \"block\",\n      type: \"paragraph\",\n      paragraph: {\n        rich_text: [\n          {\n            type: \"text\",\n            text: {\n              content: `Generated on: ${nycTime} (NYC)`\n            },\n            annotations: { italic: true, color: \"gray\" }\n          }\n        ]\n      }\n    }\n  ];\n}",[],[228,480,509],{"_104":516,"_95":517,"_157":518,"_159":481,"_160":139,"_161":162,"_163":164,"_106":519,"_100":32,"_166":254,"_168":520,"_169":22,"_170":-5,"_171":521,"_98":522},"d0f9e240-7951-11f0-8810-0224a6c84d84","url.ts","0198aa63-0ee2-725e-8c9f-f19b9262c162",["D",1755205275298],"export function getAbsoluteUrl(c: any, path: string): string {\n  const protocol = c.req.header(\"x-forwarded-proto\") || \"https\";\n  const host = c.req.header(\"host\");\n  return `${protocol}://${host}${path}`;\n}",[],[228,480,517],[228,480],{"_104":525,"_95":240,"_157":526,"_159":229,"_160":139,"_161":242,"_163":22,"_106":527,"_100":162,"_166":179,"_168":528,"_169":22,"_170":-5,"_171":529,"_98":530},"9118c60e-7a3d-11f0-b176-0224a6c84d84","0198aa63-0ee2-725e-8c9f-f8f1bff870bc",["D",1755306529418],"# Backend\n\nThis directory contains all server-side code organized by functionality:\n\n- `/routes` - HTTP route handlers organized by functionality\n- `/api` - JSON API endpoints for frontend/backend communication  \n- `/tasks` - Webhook handlers for Notion integrations (PDF extraction, page duplication)\n- `/views` - Server-side rendered views for frontend\n- `/services` - External API integrations (pure API calls only)\n- `/controllers` - Business logic coordination between routes and services\n- `/crons` - Scheduled task handlers\n- `/types` - Shared TypeScript type definitions\n- `/utils` - Common utility functions\n\n## Architecture\n\n- **Services**: Pure API calls to external systems\n- **Controllers**: Business logic and orchestration\n- **Routes**: HTTP request/response handling only",[],[228,240],[228],{"_104":533,"_95":534,"_157":535,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":536,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":537,"_98":545},"d0f9ea2e-7951-11f0-8810-0224a6c84d84","frontend","0198aa63-0ee2-725e-8ca0-054e1ef4f005",["D",1755205275298],[538],{"_104":539,"_95":240,"_157":540,"_159":535,"_160":139,"_161":162,"_163":164,"_106":541,"_100":32,"_166":179,"_168":542,"_169":22,"_170":-5,"_171":543,"_98":544},"d0f9e934-7951-11f0-8810-0224a6c84d84","0198aa63-0ee2-725e-8ca0-01af51fe4bc0",["D",1755205275298],"# Frontend\n\nClient-side files that render in the browser.",[],[534,240],[534],{"_104":547,"_95":548,"_157":549,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":550,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":551,"_98":559},"d0f9ec40-7951-11f0-8810-0224a6c84d84","shared","0198aa63-0ee2-725e-8ca0-0c5d990abef8",["D",1755205275298],[552],{"_104":553,"_95":240,"_157":554,"_159":549,"_160":139,"_161":162,"_163":164,"_106":555,"_100":32,"_166":179,"_168":556,"_169":22,"_170":-5,"_171":557,"_98":558},"d0f9eb46-7951-11f0-8810-0224a6c84d84","0198aa63-0ee2-725e-8ca0-0b7410f5f5a9",["D",1755205275298],"# Shared\n\nFiles used by both backend and frontend. Code in this directory must work in both environments.",[],[548,240],[548],{"_104":561,"_95":562,"_157":563,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":564,"_100":32,"_166":179,"_168":565,"_169":22,"_170":-5,"_171":566,"_98":567},"d0f9ed30-7951-11f0-8810-0224a6c84d84",".vtignore","0198aa63-0ee2-725e-8ca0-105d2f2cb6c3",["D",1755205275298],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor\nvars.env",[],[562],{"_104":569,"_95":570,"_157":571,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":572,"_100":32,"_166":179,"_168":573,"_169":22,"_170":-5,"_171":574,"_98":575},"d0f9ee20-7951-11f0-8810-0224a6c84d84","deno.json","0198aa63-0ee2-725e-8ca0-17f855c1ff92",["D",1755205275298],"{\n  \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n  \"lock\": false,\n  \"compilerOptions\": {\n    \"noImplicitAny\": false,\n    \"strict\": false,\n    \"types\": [\n      \"https://www.val.town/types/valtown.d.ts\"\n    ],\n    \"lib\": [\n      \"dom\",\n      \"dom.iterable\",\n      \"dom.asynciterable\",\n      \"deno.ns\",\n      \"deno.unstable\"\n    ]\n  },\n  \"lint\": {\n    \"files\": {\n      \"include\": [\n        \"deno:/https/esm.town/**/*\"\n      ]\n    },\n    \"rules\": {\n      \"exclude\": [\n        \"no-explicit-any\"\n      ]\n    }\n  },\n  \"node_modules_dir\": false,\n  \"experimental\": {\n    \"unstable-node-globals\": true,\n    \"unstable-temporal\": true,\n    \"unstable-worker-options\": true,\n    \"unstable-sloppy-imports\": true\n  }\n}",[],[570],{"_104":577,"_95":578,"_157":579,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":580,"_100":32,"_166":412,"_168":581,"_169":22,"_170":96,"_171":582,"_98":583},"d0f9ef1a-7951-11f0-8810-0224a6c84d84","main.tsx","0198aa63-0ee2-725e-8ca0-1891f44fbfbe",["D",1755205275298],"import { Hono } from \"npm:hono@3.12.12\";\nimport { lastlogin } from \"https://esm.town/v/stevekrouse/lastlogin_safe\";\n\n// Import route modules\nimport authCheck from \"./backend/routes/authCheck.ts\";\nimport webhookAuth from \"./backend/routes/webhookAuthCheck.ts\";\nimport dashboardRoute from \"./backend/routes/views/dashboard.tsx\";\nimport apiRoutes from \"./backend/routes/api/_api.routes.ts\";\nimport taskRoutes from \"./backend/routes/tasks/_tasks.routes.ts\";\nimport viewRoutes from \"./backend/routes/views/_views.routes.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n  throw err;\n});\n\n// 1. Webhook auth - ONLY for /tasks/* routes\napp.use(\"/tasks/*\", webhookAuth);\n\n// 2. User auth - for ALL routes EXCEPT /tasks/*\napp.use(\"/api/*\", authCheck);\napp.use(\"/views/*\", authCheck);\napp.use(\"/\", authCheck);\n\n// Dashboard route (authenticated)\napp.get(\"/\", dashboardRoute);\n\n// 3. Mount routes AFTER middleware\napp.route(\"/api\", apiRoutes);\napp.route(\"/tasks\", taskRoutes);\napp.route(\"/views\", viewRoutes);\n\n// Main HTTP handler\nasync function handler(request: Request): Promise {\n  return app.fetch(request);\n}\n\n// Wrap and export the main HTTP handler with lastlogin\nexport default lastlogin(handler);",[],[578],{"_104":585,"_95":586,"_157":587,"_159":-5,"_160":139,"_161":588,"_163":22,"_106":589,"_100":244,"_166":254,"_168":590,"_169":22,"_170":-5,"_171":591,"_98":592},"16256a40-7a08-11f0-a1da-0224a6c84d84","test-findings-controller.ts","82c4768a-7a05-11f0-9236-0224a6c84d84",14,["D",1755283559825],"/**\n * Direct test endpoint for findings controller logic\n * \n * This endpoint bypasses the cron wrapper and directly calls the core findings\n * processing controller. Useful for:\n * - Testing the core business logic without cron-specific overhead\n * - Faster iteration during controller development and debugging\n * - Isolating controller issues from cron wrapper complications\n * - Getting raw controller responses without additional formatting\n * \n * Unlike test-run-findings-cron.ts which executes the full cron flow,\n * this provides direct access to the processFindings controller function.\n */\n\nimport { processFindings } from \"./backend/controllers/findings.controller.ts\";\n\nexport default async function(req: Request): Promise {\n  console.log(\"🧪 Testing findings analysis cron job...\");\n  \n  const result = await processFindings({});\n  \n  return new Response(JSON.stringify(result, null, 2), {\n    headers: { \"content-type\": \"application/json\" }\n  });\n}",[],[586],{"_104":594,"_95":99,"_157":595,"_159":-5,"_160":139,"_161":596,"_163":22,"_106":597,"_100":244,"_166":254,"_168":598,"_169":22,"_170":-5,"_171":599,"_98":600},"edd556f4-7a07-11f0-8d9d-0224a6c84d84","82c47496-7a05-11f0-9236-0224a6c84d84",13,["D",1755283492197],"/**\n * Manual HTTP trigger for findings analysis cron job\n * \n * This endpoint allows you to manually execute the findings analysis cron job\n * without waiting for the scheduled execution. Useful for:\n * - Testing cron job logic during development\n * - Debugging issues with the full cron execution flow\n * - Running analysis on-demand when new transcripts are available\n * - Verifying cron job behavior with complete logging and error handling\n * \n * Unlike test-cron.ts which directly calls the controller, this executes\n * the full cron wrapper including all logging, error handling, and result formatting.\n */\n\nimport findingsAnalysisCron from \"./backend/crons/findings-analysis.ts\";\n\nexport default async function(req: Request) {\n  try {\n    console.log(\"🚀 Manually triggering findings analysis cron...\");\n    \n    const result = await findingsAnalysisCron();\n    \n    return new Response(JSON.stringify({\n      message: \"Cron execution completed\",\n      result: result\n    }, null, 2), {\n      headers: { \"Content-Type\": \"application/json\" }\n    });\n\n  } catch (error) {\n    console.error(\"❌ Error running cron:\", error);\n    return new Response(JSON.stringify({ \n      error: \"Cron execution failed\", \n      details: error.message,\n      stack: error.stack\n    }), {\n      status: 500,\n      headers: { \"Content-Type\": \"application/json\" }\n    });\n  }\n}",[],[99],"files",[154,173,183,191,199,207,216,226,232,238,248,258,267,275,285,291,300,310,316,322,329,338,344,352,362,368,375,383,392,399,407,416,425,431,438,446,456,462,469,478,484,491,499,507,515,524,532,538,546,552,560,568,576,584,593],"counts",{"_605":32,"_606":296,"_607":32,"_608":211},"pulls","branches","forks","envVars","contents",[],{"_104":594,"_95":99,"_157":595,"_159":-5,"_160":139,"_161":596,"_163":22,"_106":612,"_100":244,"_166":254,"_168":598,"_169":22,"_170":-5,"_98":613},["D",1755283492197],[99],"upstreamProject",{"_104":147,"_95":616,"_112":617,"_113":618,"_110":111,"_23":619},"findings-base","Connect Notion and val.town, including user and webhook auth","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/2c2c44af-ae1d-44bb-37da-2478b01ac700/square512",{"_93":94,"_131":132},"upstreamBranch",{"_104":142,"_106":622,"_623":624,"_95":43,"_140":147,"_100":144,"_141":-5,"_143":-5,"_625":626,"_108":-5,"_151":22,"_110":111,"_150":94,"_16":120,"_149":616},["D",1755176650069],"updatedAt",["D",1755192248891],"lockfileKey","1755705837344-esm.town_v_lightweight_findings-base@173-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":633,"_152":638,"_601":804,"_179":805,"_609":807,"_808":809,"_812":164,"_813":-5,"_814":815,"_816":32,"_817":818},{"_104":105,"_95":96,"_106":634,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":114,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":635,"_133":636,"_136":637,"_151":22},["D",1755205275298],{"_93":94,"_131":132},{"_93":94,"_135":132},{"_100":138,"_95":43,"_104":139,"_140":105,"_141":142,"_143":144,"_145":111,"_146":147,"_148":120,"_149":96,"_150":94},[639,660,777,783,789,792,795,798,801],{"_104":155,"_95":156,"_157":158,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":165,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":640,"_98":659},[641,644,647,650,653,656],{"_104":174,"_95":175,"_157":176,"_159":158,"_160":139,"_161":177,"_163":164,"_106":178,"_100":162,"_166":179,"_168":180,"_169":22,"_170":-5,"_171":642,"_98":643},[],[156,175],{"_104":184,"_95":185,"_157":186,"_159":158,"_160":139,"_161":162,"_163":164,"_106":187,"_100":32,"_166":179,"_168":188,"_169":22,"_170":-5,"_171":645,"_98":646},[],[156,185],{"_104":192,"_95":193,"_157":194,"_159":158,"_160":139,"_161":162,"_163":164,"_106":195,"_100":32,"_166":179,"_168":196,"_169":22,"_170":-5,"_171":648,"_98":649},[],[156,193],{"_104":200,"_95":201,"_157":202,"_159":158,"_160":139,"_161":162,"_163":164,"_106":203,"_100":32,"_166":179,"_168":204,"_169":22,"_170":-5,"_171":651,"_98":652},[],[156,201],{"_104":208,"_95":209,"_157":210,"_159":158,"_160":139,"_161":211,"_163":164,"_106":212,"_100":32,"_166":179,"_168":213,"_169":22,"_170":-5,"_171":654,"_98":655},[],[156,209],{"_104":217,"_95":218,"_157":219,"_159":158,"_160":139,"_161":220,"_163":164,"_106":221,"_100":32,"_166":179,"_168":222,"_169":22,"_170":-5,"_171":657,"_98":658},[],[156,218],[156],{"_104":227,"_95":228,"_157":229,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":230,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":661,"_98":776},[662,680,689,734,746,755,773],{"_104":233,"_95":234,"_157":235,"_159":229,"_160":139,"_161":162,"_163":164,"_106":236,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":663,"_98":679},[664,667,670,673,676],{"_104":239,"_95":240,"_157":241,"_159":235,"_160":139,"_161":242,"_163":22,"_106":243,"_100":244,"_166":179,"_168":245,"_169":22,"_170":-5,"_171":665,"_98":666},[],[228,234,240],{"_104":249,"_95":250,"_157":251,"_159":235,"_160":139,"_161":101,"_163":22,"_106":252,"_100":253,"_166":254,"_168":255,"_169":22,"_170":-5,"_171":668,"_98":669},[],[228,234,250],{"_104":259,"_95":260,"_157":261,"_159":235,"_160":139,"_161":262,"_163":164,"_106":263,"_100":162,"_166":254,"_168":264,"_169":22,"_170":-5,"_171":671,"_98":672},[],[228,234,260],{"_104":268,"_95":269,"_157":270,"_159":235,"_160":139,"_161":242,"_163":22,"_106":271,"_100":162,"_166":254,"_168":272,"_169":22,"_170":-5,"_171":674,"_98":675},[],[228,234,269],{"_104":276,"_95":277,"_157":278,"_159":235,"_160":139,"_161":279,"_163":22,"_106":280,"_100":244,"_166":254,"_168":281,"_169":22,"_170":-5,"_171":677,"_98":678},[],[228,234,277],[228,234],{"_104":286,"_95":287,"_157":288,"_159":229,"_160":139,"_161":162,"_163":164,"_106":289,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":681,"_98":688},[682,685],{"_104":292,"_95":240,"_157":293,"_159":288,"_160":139,"_161":294,"_163":164,"_106":295,"_100":296,"_166":179,"_168":297,"_169":22,"_170":-5,"_171":683,"_98":684},[],[228,287,240],{"_104":301,"_95":302,"_157":303,"_159":288,"_160":139,"_161":294,"_163":164,"_106":304,"_100":162,"_166":305,"_168":306,"_169":22,"_170":-5,"_171":686,"_98":687},[],[228,287,302],[228,287],{"_104":311,"_95":312,"_157":313,"_159":229,"_160":139,"_161":162,"_163":164,"_106":314,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":690,"_98":733},[691,700,709,721,724,727,730],{"_104":317,"_95":318,"_157":319,"_159":313,"_160":139,"_161":162,"_163":164,"_106":320,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":692,"_98":699},[693,696],{"_104":323,"_95":240,"_157":324,"_159":319,"_160":139,"_161":162,"_163":164,"_106":325,"_100":32,"_166":179,"_168":326,"_169":22,"_170":-5,"_171":694,"_98":695},[],[228,312,318,240],{"_104":330,"_95":331,"_157":332,"_159":319,"_160":139,"_161":162,"_163":164,"_106":333,"_100":32,"_166":254,"_168":334,"_169":22,"_170":-5,"_171":697,"_98":698},[],[228,312,318,331],[228,312,318],{"_104":339,"_95":340,"_157":341,"_159":313,"_160":139,"_161":162,"_163":164,"_106":342,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":701,"_98":708},[702,705],{"_104":345,"_95":240,"_157":346,"_159":341,"_160":139,"_161":347,"_163":22,"_106":348,"_100":244,"_166":179,"_168":349,"_169":22,"_170":-5,"_171":703,"_98":704},[],[228,312,340,240],{"_104":353,"_95":354,"_157":355,"_159":341,"_160":139,"_161":356,"_163":22,"_106":357,"_100":244,"_166":254,"_168":358,"_169":22,"_170":-5,"_171":706,"_98":707},[],[228,312,340,354],[228,312,340],{"_104":363,"_95":364,"_157":365,"_159":313,"_160":139,"_161":162,"_163":164,"_106":366,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":710,"_98":720},[711,714,717],{"_104":369,"_95":240,"_157":370,"_159":365,"_160":139,"_161":162,"_163":164,"_106":371,"_100":32,"_166":179,"_168":372,"_169":22,"_170":-5,"_171":712,"_98":713},[],[228,312,364,240],{"_104":376,"_95":377,"_157":378,"_159":365,"_160":139,"_161":162,"_163":164,"_106":379,"_100":32,"_166":254,"_168":380,"_169":22,"_170":-5,"_171":715,"_98":716},[],[228,312,364,377],{"_104":384,"_95":385,"_157":386,"_159":365,"_160":139,"_161":162,"_163":164,"_106":387,"_100":32,"_166":254,"_168":388,"_169":22,"_170":-5,"_171":718,"_98":719},[],[228,312,364,385],[228,312,364],{"_104":393,"_95":240,"_157":394,"_159":313,"_160":139,"_161":162,"_163":164,"_106":395,"_100":32,"_166":179,"_168":396,"_169":22,"_170":-5,"_171":722,"_98":723},[],[228,312,240],{"_104":400,"_95":401,"_157":402,"_159":313,"_160":139,"_161":162,"_163":164,"_106":403,"_100":32,"_166":254,"_168":404,"_169":22,"_170":-5,"_171":725,"_98":726},[],[228,312,401],{"_104":408,"_95":409,"_157":410,"_159":313,"_160":139,"_161":211,"_163":22,"_106":411,"_100":32,"_166":412,"_168":413,"_169":22,"_170":-5,"_171":728,"_98":729},[],[228,312,409],{"_104":417,"_95":418,"_157":419,"_159":313,"_160":139,"_161":162,"_163":164,"_106":420,"_100":32,"_166":254,"_168":421,"_169":22,"_170":-5,"_171":731,"_98":732},[],[228,312,418],[228,312],{"_104":426,"_95":427,"_157":428,"_159":229,"_160":139,"_161":162,"_163":164,"_106":429,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":735,"_98":745},[736,739,742],{"_104":432,"_95":240,"_157":433,"_159":428,"_160":139,"_161":211,"_163":22,"_106":434,"_100":162,"_166":179,"_168":435,"_169":22,"_170":-5,"_171":737,"_98":738},[],[228,427,240],{"_104":439,"_95":440,"_157":441,"_159":428,"_160":139,"_161":101,"_163":22,"_106":442,"_100":253,"_166":254,"_168":443,"_169":22,"_170":-5,"_171":740,"_98":741},[],[228,427,440],{"_104":447,"_95":448,"_157":449,"_159":428,"_160":139,"_161":450,"_163":164,"_106":451,"_100":162,"_166":254,"_168":452,"_169":22,"_170":-5,"_171":743,"_98":744},[],[228,427,448],[228,427],{"_104":457,"_95":458,"_157":459,"_159":229,"_160":139,"_161":162,"_163":164,"_106":460,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":747,"_98":754},[748,751],{"_104":463,"_95":240,"_157":464,"_159":459,"_160":139,"_161":211,"_163":22,"_106":465,"_100":162,"_166":179,"_168":466,"_169":22,"_170":-5,"_171":749,"_98":750},[],[228,458,240],{"_104":470,"_95":471,"_157":472,"_159":459,"_160":139,"_161":356,"_163":22,"_106":473,"_100":244,"_166":254,"_168":474,"_169":22,"_170":-5,"_171":752,"_98":753},[],[228,458,471],[228,458],{"_104":479,"_95":480,"_157":481,"_159":229,"_160":139,"_161":162,"_163":164,"_106":482,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":756,"_98":772},[757,760,763,766,769],{"_104":485,"_95":240,"_157":486,"_159":481,"_160":139,"_161":211,"_163":22,"_106":487,"_100":162,"_166":179,"_168":488,"_169":22,"_170":-5,"_171":758,"_98":759},[],[228,480,240],{"_104":492,"_95":493,"_157":494,"_159":481,"_160":139,"_161":101,"_163":22,"_106":495,"_100":162,"_166":254,"_168":496,"_169":22,"_170":-5,"_171":761,"_98":762},[],[228,480,493],{"_104":500,"_95":501,"_157":502,"_159":481,"_160":139,"_161":220,"_163":164,"_106":503,"_100":32,"_166":254,"_168":504,"_169":22,"_170":-5,"_171":764,"_98":765},[],[228,480,501],{"_104":508,"_95":509,"_157":510,"_159":481,"_160":139,"_161":211,"_163":164,"_106":511,"_100":32,"_166":254,"_168":512,"_169":22,"_170":-5,"_171":767,"_98":768},[],[228,480,509],{"_104":516,"_95":517,"_157":518,"_159":481,"_160":139,"_161":162,"_163":164,"_106":519,"_100":32,"_166":254,"_168":520,"_169":22,"_170":-5,"_171":770,"_98":771},[],[228,480,517],[228,480],{"_104":525,"_95":240,"_157":526,"_159":229,"_160":139,"_161":242,"_163":22,"_106":527,"_100":162,"_166":179,"_168":528,"_169":22,"_170":-5,"_171":774,"_98":775},[],[228,240],[228],{"_104":533,"_95":534,"_157":535,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":536,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":778,"_98":782},[779],{"_104":539,"_95":240,"_157":540,"_159":535,"_160":139,"_161":162,"_163":164,"_106":541,"_100":32,"_166":179,"_168":542,"_169":22,"_170":-5,"_171":780,"_98":781},[],[534,240],[534],{"_104":547,"_95":548,"_157":549,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":550,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":784,"_98":788},[785],{"_104":553,"_95":240,"_157":554,"_159":549,"_160":139,"_161":162,"_163":164,"_106":555,"_100":32,"_166":179,"_168":556,"_169":22,"_170":-5,"_171":786,"_98":787},[],[548,240],[548],{"_104":561,"_95":562,"_157":563,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":564,"_100":32,"_166":179,"_168":565,"_169":22,"_170":-5,"_171":790,"_98":791},[],[562],{"_104":569,"_95":570,"_157":571,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":572,"_100":32,"_166":179,"_168":573,"_169":22,"_170":-5,"_171":793,"_98":794},[],[570],{"_104":577,"_95":578,"_157":579,"_159":-5,"_160":139,"_161":162,"_163":164,"_106":580,"_100":32,"_166":412,"_168":581,"_169":22,"_170":96,"_171":796,"_98":797},[],[578],{"_104":585,"_95":586,"_157":587,"_159":-5,"_160":139,"_161":588,"_163":22,"_106":589,"_100":244,"_166":254,"_168":590,"_169":22,"_170":-5,"_171":799,"_98":800},[],[586],{"_104":594,"_95":99,"_157":595,"_159":-5,"_160":139,"_161":596,"_163":22,"_106":597,"_100":244,"_166":254,"_168":598,"_169":22,"_170":-5,"_171":802,"_98":803},[],[99],[639,641,644,647,650,653,656,660,662,664,667,670,673,676,680,682,685,689,691,693,696,700,702,705,709,711,714,717,721,724,727,730,734,736,739,742,746,748,751,755,757,760,763,766,769,773,777,779,783,785,789,792,795,798,801],{"_104":594,"_95":99,"_157":595,"_159":-5,"_160":139,"_161":596,"_163":22,"_106":612,"_100":244,"_166":254,"_168":598,"_169":22,"_170":-5,"_98":806},[99],[],"upstream",{"_104":142,"_106":810,"_623":811,"_95":43,"_140":147,"_100":144,"_141":-5,"_143":-5,"_625":626,"_108":-5,"_151":22,"_110":111,"_150":94,"_16":120,"_149":616},["D",1755176650069],["D",1755192248891],"showCompareCallout","pull","ahead",45,"behind","templates",[],"actionData","errors"]