`, `

`, ``, etc.)\n- **Automatic styling** - Beautiful design out of the box\n- **CDN delivery** - Single `` tag, no build step\n\n### Rules\n\n❌ **NEVER use CSS class names** (no `className` attributes)\n❌ **NEVER use TailwindCSS, Bootstrap, or other class-based frameworks**\n✅ **ALWAYS use semantic HTML elements**\n✅ **Use inline styles sparingly** - Only for dynamic/conditional styling\n\n### Semantic HTML Elements\n\nUse these semantic elements - Pico styles them automatically:\n\n**Layout:**\n- `` - Main content container\n- `` - Self-contained content (cards, sections)\n- `` - Thematic grouping of content\n- ``, `` - Page/section headers and footers\n- `` - Sidebar content\n\n**Typography:**\n- `` through ` ` - Headings\n- `` - Paragraphs\n- `` - Bold/important text\n- `` - Italic/emphasized text\n- `` - Fine print\n- `` - Highlighted text\n- `` - Inline code\n- ` ` - Code blocks\n- `` - Keyboard input / tags\n\n**Lists:**\n- ``, ``, `` - Lists\n- ``, ``, ` ` - Definition lists\n\n**Forms:**\n- ``, ``, `<select>` - Form inputs\n- `<button>` - Buttons\n- `<label>` - Form labels\n- Use `aria-busy` attribute for loading states on buttons\n\n**Links & Media:**\n- `<a>` - Links\n- `<time>` - Dates and times\n- `<figure>`, `<figcaption>` - Images with captions\n\n### Example Patterns\n\n**Card layout:**\n```tsx\n<article>\n <h2>Card Title</h2>\n <p>Card content goes here.</p>\n <button>Action</button>\n</article>\n```\n\n**Form with loading state:**\n```tsx\n<div style={{ display: 'flex', gap: '1rem' }}>\n <input type=\"text\" placeholder=\"Enter value\" style={{ flex: 1 }} />\n <button disabled={loading} aria-busy={loading}>\n Submit\n </button>\n</div>\n```\n\n**Error message:**\n```tsx\n{error && <mark>{error}</mark>}\n```\n\n**Tags/badges:**\n```tsx\n<kbd>Tag 1</kbd> <kbd>Tag 2</kbd>\n```\n\n**Conditional styling:**\n```tsx\n<span style={checked ? { textDecoration: 'line-through', opacity: 0.6 } : undefined}>\n Task text\n</span>\n```\n\n### Loading Pico CSS\n\nAlready included in `frontend/index.html`:\n\n```html\n<link href=\"https://cdn.jsdelivr.net/npm/@picocss/pico@2.1.1/css/pico.classless.min.css\" rel=\"stylesheet\" />\n```\n\n## Shared Code (`shared/`)\n\n**Types** (`shared/types.ts`):\n- All TypeScript interfaces shared between frontend/backend\n- Notion data structures\n- API request/response types\n- Common data models\n\n**Utils** (`shared/utils.ts`):\n- Pure functions that work in both Deno (backend) and browser (frontend)\n- ❌ NEVER use Deno APIs (won't work in browser)\n- ✅ Only use standard JavaScript/TypeScript\n\n## Environment Variables\n\nRequired environment variables for this val:\n\n- `NOTION_API_KEY` - Notion integration token\n- `FIRECRAWLER_API_KEY` - Firecrawler service (if used)\n- Additional service API keys as needed\n\n**Access via**: `Deno.env.get('VAR_NAME')`\n\n**NEVER hardcode secrets** - always use environment variables\n\n## Data Validation\n\nValidate request data in **controllers**, not routes:\n\n```typescript\nif (!pageId || typeof pageId !== 'string') {\n return {\n success: false,\n data: null,\n error: \"Invalid pageId\",\n details: \"pageId must be a non-empty string\"\n };\n}\n```\n\n**Check:**\n- Required fields exist\n- Types are correct\n- Formats are valid\n- Values are within expected ranges\n\n**Return helpful error messages** with `details` field\n\n## Response Filtering\n\n**Filter sensitive data in controllers** before returning:\n\n- Remove button properties from Notion data\n- Don't expose internal IDs or tokens\n- Clean up API responses before sending to frontend\n- Strip unnecessary metadata\n\n**Example:**\n```typescript\n// Remove sensitive properties\nconst filtered = {\n ...notionData,\n properties: Object.entries(notionData.properties)\n .filter(([key, value]) => value.type !== 'button')\n .reduce((acc, [key, value]) => ({ ...acc, [key]: value }), {})\n};\n```\n\n## Questions to Ask User\n\nWhen the user requests a new feature, clarify:\n\n1. **Is this a webhook handler or API endpoint?**\n - Webhook → `routes/tasks/`\n - API → `routes/api/`\n\n2. **What external service needs integration?**\n - New service → create `backend/services/[name].ts`\n\n3. **What data needs to be saved back to Notion?**\n - Update Notion → use/extend `notionService.ts`\n\n4. **Does this need authentication?**\n - Protected → apply `authCheck` middleware\n\n5. **Is this frontend-facing?**\n - Yes → create React component in `frontend/components/`\n\n## Common Patterns Checklist\n\nBefore implementing, verify:\n\n- ✅ Following 3-layer architecture (Route → Controller → Service)\n- ✅ Routes only handle HTTP, no business logic\n- ✅ Controllers return standardized `{success, data, error}` structure\n- ✅ Services handle external API calls\n- ✅ Never skipping layers\n- ✅ TypeScript types defined in `shared/types.ts`\n- ✅ Environment variables used for secrets\n- ✅ Error handling at each layer\n- ✅ Validation in controllers\n- ✅ Sensitive data filtered before returning\n\n## Integration with AGENTS.md\n\n**Use AGENTS.md for:**\n- Val Town platform requirements\n- Deno-specific patterns\n- Standard library usage\n- React configuration\n- Import patterns (esm.sh)\n- Platform limitations\n\n**Use CLAUDE.md (this file) for:**\n- This val's architecture\n- MVC layer separation\n- Notion integration patterns\n- External service integration\n- File organization\n- Response formats\n\n## Entry Point\n\n`main.http.tsx` is the HTTP entry point:\n- Exports `app.fetch` for Val Town\n- Uses Hono for routing\n- Serves static frontend assets\n- Mounts API routes at `/api`\n- Includes error handler\n\n**Always mount new routes in main.http.tsx:**\n```typescript\nimport { taskRoutes } from './backend/routes/tasks/index.ts';\n\napp.route('/tasks', taskRoutes);\n```\n\n## Hono Framework Patterns\n\nThis val uses **Hono** as the web framework. Follow these patterns:\n\n### Importing Hono\n\n```typescript\nimport { Hono } from \"npm:hono@4\";\nimport { Context, Next } from \"npm:hono@4\";\n```\n\n**Note**: Use `npm:` specifier for backend-only packages (better performance, modern Deno way).\n\n### Creating Route Modules\n\nWhen creating route modules (e.g., `backend/routes/api/pages.ts`):\n\n```typescript\nimport { Hono } from \"npm:hono@4\";\nimport * as pageController from '../../controllers/pageController.ts';\n\nconst pages = new Hono();\n\n// GET /api/pages/:id\npages.get('/:id', async (c) => {\n const pageId = c.req.param('id');\n const result = await pageController.getPage(pageId);\n\n if (!result.success) {\n return c.json({ error: result.error, details: result.details }, 400);\n }\n\n return c.json(result.data);\n});\n\n// POST /api/pages/:id\npages.post('/:id', async (c) => {\n const pageId = c.req.param('id');\n const body = await c.req.json();\n\n const result = await pageController.updatePage(pageId, body.properties);\n\n if (!result.success) {\n return c.json({ error: result.error, details: result.details }, 400);\n }\n\n return c.json(result.data);\n});\n\nexport default pages;\n```\n\n### Mounting Routes\n\nCreate an index file for each route directory (e.g., `backend/routes/api/index.ts`):\n\n```typescript\nimport { Hono } from \"npm:hono@4\";\nimport pages from './pages.ts';\n\nconst api = new Hono();\n\napi.route('/pages', pages);\n// Add more routes as needed\n\nexport default api;\n```\n\nThen mount in `main.http.tsx`:\n\n```typescript\nimport api from './backend/routes/api/index.ts';\napp.route('/api', api);\n```\n\n### Accessing Request Data\n\n```typescript\n// URL params\nconst id = c.req.param('id');\n\n// Query params\nconst query = c.req.query('q');\n\n// Headers\nconst apiKey = c.req.header('x-api-key');\n\n// JSON body\nconst body = await c.req.json();\n\n// Form data\nconst formData = await c.req.formData();\n```\n\n### Returning Responses\n\n```typescript\n// JSON response\nreturn c.json({ data: 'value' });\n\n// JSON with status code\nreturn c.json({ error: 'Not found' }, 404);\n\n// HTML response\nreturn c.html('<h1>Hello</h1>');\n\n// Plain text\nreturn c.text('Hello');\n\n// Redirect (use this pattern, not Response.redirect)\nreturn new Response(null, { status: 302, headers: { Location: '/new-url' }});\n```\n\n### Middleware\n\nApply middleware to routes:\n\n```typescript\nimport { authCheck } from '../authCheck.ts';\n\n// Apply to single route\npages.post('/:id', authCheck, async (c) => {\n // Protected route logic\n});\n\n// Apply to all routes in this module\npages.use('*', authCheck);\n```\n\n### Error Handler\n\nAlready configured in `main.http.tsx`:\n\n```typescript\napp.onError((err, c) => {\n throw err; // Re-throw to see full stack trace\n});\n```\n\n### Static File Serving\n\nAlready configured in `main.http.tsx`:\n\n```typescript\nimport { serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n### Route Organization Example\n\n```\nbackend/routes/\n├── api/\n│ ├── index.ts # Mounts all API routes\n│ ├── pages.ts # /api/pages/* endpoints\n│ └── databases.ts # /api/databases/* endpoints\n├── tasks/\n│ ├── index.ts # Mounts all webhook routes\n│ └── notion.ts # /tasks/notion webhook handler\n├── views/\n│ └── dashboard.ts # /views/dashboard page\n└── authCheck.ts # Auth middleware\n```\n",[180],"1cb98422-b360-11f0-bc6f-0224a6c84d84","AGENTS.md","019a26dc-99bf-7269-a8f6-692ef14e0fe6",["D",1761588582800],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious operations)\n- Follow modern ES6+ conventions and functional programming practices if possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = 'todo_app_users_2';\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(`SELECT * FROM ${TABLE_NAME} WHERE id = ?`, [1]);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: \"Say hello in a creative way\" },\n ],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({ \n subject: \"Hi\", \n text: \"Hi\", \n html: \"<h1>Hi</h1>\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `<img src=\"https://maxm-imggenurl.web.val.run/the-description-of-your-image\" />`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `<script src=\"https://esm.town/v/std/catch\"></script>` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `<script src=\"https://cdn.twind.style\" crossorigin></script>` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n \n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n \n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = `<script>\n window.__INITIAL_DATA__ = ${JSON.stringify(initialData)};\n </script>`;\n \n html = html.replace(\"</head>\", `${dataScript}</head>`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[186],"1cb9830a-b360-11f0-bc6f-0224a6c84d84",".vtignore","019a26dc-99bf-7269-a8f6-6555ae856e94",["D",1761588582800],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor\nvars.env",[192],"1cb981de-b360-11f0-bc6f-0224a6c84d84","shared","019a26dc-99bf-7269-a8f6-63c6fd1d84b1",["D",1761588582800],"directory",[198],"1cb9746e-b360-11f0-bc6f-0224a6c84d84","frontend","019a26dc-99bf-7269-a8f6-51875d2ac446",["D",1761588582800],[204],"1cb966d6-b360-11f0-bc6f-0224a6c84d84","backend","019a26dc-99bf-7269-a8f6-32bd7c2a6dc6",["D",1761588582800],[209],"1cb9476e-b360-11f0-bc6f-0224a6c84d84",".claude","019a26dc-99bf-7269-a8f5-f075c4855e23",["D",1761588582800],[214],"pulls","branches",2,"forks","envVars",{"_226":228,"_229":63},"connections",{"_226":63,"_227":63},"count","unfilledCount",15,"emptyCount",{"_44":213,"_32":214,"_30":215,"_154":-5,"_42":43,"_41":167,"_156":59,"_39":709,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":710,"_27":711},{"_44":702,"_32":703,"_30":704,"_154":215,"_42":43,"_41":167,"_156":25,"_39":705,"_13":63,"_34":20,"_36":706,"_24":25,"_161":-5,"_294":707,"_27":708},{"_44":208,"_32":209,"_30":210,"_154":-5,"_42":43,"_41":167,"_156":59,"_39":699,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":700,"_27":701},{"_44":695,"_32":653,"_30":646,"_154":210,"_42":43,"_41":167,"_156":59,"_39":696,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":697,"_27":698},{"_44":687,"_32":688,"_30":689,"_154":646,"_42":43,"_41":690,"_156":59,"_39":691,"_13":380,"_34":317,"_36":692,"_24":25,"_161":-5,"_294":693,"_27":694},{"_44":679,"_32":680,"_30":681,"_154":646,"_42":43,"_41":682,"_156":25,"_39":683,"_13":158,"_34":317,"_36":684,"_24":25,"_161":-5,"_294":685,"_27":686},{"_44":672,"_32":673,"_30":674,"_154":646,"_42":43,"_41":315,"_156":59,"_39":675,"_13":220,"_34":317,"_36":676,"_24":25,"_161":-5,"_294":677,"_27":678},{"_44":663,"_32":664,"_30":665,"_154":646,"_42":43,"_41":666,"_156":25,"_39":667,"_13":668,"_34":317,"_36":669,"_24":25,"_161":-5,"_294":670,"_27":671},{"_44":654,"_32":655,"_30":656,"_154":646,"_42":43,"_41":657,"_156":25,"_39":658,"_13":659,"_34":317,"_36":660,"_24":25,"_161":-5,"_294":661,"_27":662},{"_44":643,"_32":644,"_30":645,"_154":646,"_42":43,"_41":647,"_156":25,"_39":648,"_13":649,"_34":317,"_36":650,"_24":25,"_161":-5,"_294":651,"_27":652},{"_44":639,"_32":629,"_30":625,"_154":210,"_42":43,"_41":495,"_156":59,"_39":640,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":641,"_27":642},{"_44":630,"_32":631,"_30":632,"_154":625,"_42":43,"_41":633,"_156":25,"_39":634,"_13":635,"_34":35,"_36":636,"_24":25,"_161":-5,"_294":637,"_27":638},{"_44":624,"_32":33,"_30":31,"_154":625,"_42":43,"_41":14,"_156":25,"_39":626,"_13":167,"_34":35,"_36":38,"_24":25,"_161":-5,"_294":627,"_27":628},{"_44":620,"_32":552,"_30":546,"_154":210,"_42":43,"_41":167,"_156":59,"_39":621,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":622,"_27":623},{"_44":616,"_32":602,"_30":597,"_154":546,"_42":43,"_41":167,"_156":59,"_39":617,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":618,"_27":619},{"_44":609,"_32":610,"_30":611,"_154":597,"_42":43,"_41":315,"_156":25,"_39":612,"_13":63,"_34":317,"_36":613,"_24":25,"_161":-5,"_294":614,"_27":615},{"_44":603,"_32":511,"_30":604,"_154":597,"_42":43,"_41":315,"_156":59,"_39":605,"_13":167,"_34":317,"_36":606,"_24":25,"_161":-5,"_294":607,"_27":608},{"_44":595,"_32":502,"_30":596,"_154":597,"_42":43,"_41":495,"_156":59,"_39":598,"_13":167,"_34":317,"_36":599,"_24":25,"_161":-5,"_294":600,"_27":601},{"_44":591,"_32":568,"_30":562,"_154":546,"_42":43,"_41":167,"_156":59,"_39":592,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":593,"_27":594},{"_44":584,"_32":585,"_30":586,"_154":562,"_42":43,"_41":228,"_156":59,"_39":587,"_13":220,"_34":317,"_36":588,"_24":25,"_161":-5,"_294":589,"_27":590},{"_44":577,"_32":578,"_30":579,"_154":562,"_42":43,"_41":428,"_156":59,"_39":580,"_13":63,"_34":317,"_36":581,"_24":25,"_161":-5,"_294":582,"_27":583},{"_44":569,"_32":570,"_30":571,"_154":562,"_42":43,"_41":572,"_156":25,"_39":573,"_13":220,"_34":317,"_36":574,"_24":25,"_161":-5,"_294":575,"_27":576},{"_44":559,"_32":560,"_30":561,"_154":562,"_42":43,"_41":563,"_156":59,"_39":564,"_13":380,"_34":317,"_36":565,"_24":25,"_161":-5,"_294":566,"_27":567},{"_44":553,"_32":554,"_30":555,"_154":546,"_42":43,"_41":167,"_156":59,"_39":556,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":557,"_27":558},{"_44":543,"_32":544,"_30":545,"_154":546,"_42":43,"_41":547,"_156":59,"_39":548,"_13":380,"_34":317,"_36":549,"_24":25,"_161":-5,"_294":550,"_27":551},{"_44":539,"_32":474,"_30":469,"_154":210,"_42":43,"_41":167,"_156":59,"_39":540,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":541,"_27":542},{"_44":535,"_32":500,"_30":494,"_154":469,"_42":43,"_41":167,"_156":59,"_39":536,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":537,"_27":538},{"_44":527,"_32":528,"_30":529,"_154":494,"_42":43,"_41":530,"_156":59,"_39":531,"_13":167,"_34":317,"_36":532,"_24":25,"_161":-5,"_294":533,"_27":534},{"_44":518,"_32":519,"_30":520,"_154":494,"_42":43,"_41":521,"_156":25,"_39":522,"_13":523,"_34":317,"_36":524,"_24":25,"_161":-5,"_294":525,"_27":526},{"_44":510,"_32":511,"_30":512,"_154":494,"_42":43,"_41":513,"_156":25,"_39":514,"_13":220,"_34":317,"_36":515,"_24":25,"_161":-5,"_294":516,"_27":517},{"_44":501,"_32":502,"_30":503,"_154":494,"_42":43,"_41":504,"_156":25,"_39":505,"_13":506,"_34":317,"_36":507,"_24":25,"_161":-5,"_294":508,"_27":509},{"_44":491,"_32":492,"_30":493,"_154":494,"_42":43,"_41":495,"_156":59,"_39":496,"_13":63,"_34":317,"_36":497,"_24":25,"_161":-5,"_294":498,"_27":499},{"_44":482,"_32":483,"_30":484,"_154":469,"_42":43,"_41":485,"_156":25,"_39":486,"_13":487,"_34":317,"_36":488,"_24":25,"_161":-5,"_294":489,"_27":490},{"_44":475,"_32":476,"_30":477,"_154":469,"_42":43,"_41":315,"_156":25,"_39":478,"_13":220,"_34":317,"_36":479,"_24":25,"_161":-5,"_294":480,"_27":481},{"_44":466,"_32":467,"_30":468,"_154":469,"_42":43,"_41":326,"_156":59,"_39":470,"_13":167,"_34":317,"_36":471,"_24":25,"_161":-5,"_294":472,"_27":473},{"_44":462,"_32":406,"_30":400,"_154":210,"_42":43,"_41":428,"_156":59,"_39":463,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":464,"_27":465},{"_44":455,"_32":456,"_30":457,"_154":400,"_42":43,"_41":428,"_156":59,"_39":458,"_13":63,"_34":317,"_36":459,"_24":25,"_161":-5,"_294":460,"_27":461},{"_44":447,"_32":448,"_30":449,"_154":400,"_42":43,"_41":450,"_156":59,"_39":451,"_13":220,"_34":317,"_36":452,"_24":25,"_161":-5,"_294":453,"_27":454},{"_44":440,"_32":441,"_30":442,"_154":400,"_42":43,"_41":315,"_156":25,"_39":443,"_13":63,"_34":317,"_36":444,"_24":25,"_161":-5,"_294":445,"_27":446},{"_44":433,"_32":434,"_30":435,"_154":400,"_42":43,"_41":401,"_156":25,"_39":436,"_13":63,"_34":317,"_36":437,"_24":25,"_161":-5,"_294":438,"_27":439},{"_44":425,"_32":426,"_30":427,"_154":400,"_42":43,"_41":428,"_156":59,"_39":429,"_13":63,"_34":317,"_36":430,"_24":25,"_161":-5,"_294":431,"_27":432},{"_44":416,"_32":417,"_30":418,"_154":400,"_42":43,"_41":419,"_156":25,"_39":420,"_13":421,"_34":317,"_36":422,"_24":25,"_161":-5,"_294":423,"_27":424},{"_44":407,"_32":408,"_30":409,"_154":400,"_42":43,"_41":410,"_156":25,"_39":411,"_13":412,"_34":317,"_36":413,"_24":25,"_161":-5,"_294":414,"_27":415},{"_44":397,"_32":398,"_30":399,"_154":400,"_42":43,"_41":401,"_156":59,"_39":402,"_13":63,"_34":317,"_36":403,"_24":25,"_161":-5,"_294":404,"_27":405},{"_44":391,"_32":172,"_30":392,"_154":210,"_42":43,"_41":167,"_156":59,"_39":393,"_13":63,"_34":20,"_36":394,"_24":25,"_161":-5,"_294":395,"_27":396},{"_44":203,"_32":204,"_30":205,"_154":-5,"_42":43,"_41":167,"_156":59,"_39":388,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":389,"_27":390},{"_44":384,"_32":367,"_30":362,"_154":205,"_42":43,"_41":167,"_156":59,"_39":385,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":386,"_27":387},{"_44":375,"_32":376,"_30":377,"_154":362,"_42":43,"_41":378,"_156":25,"_39":379,"_13":380,"_34":317,"_36":381,"_24":25,"_161":-5,"_294":382,"_27":383},{"_44":368,"_32":369,"_30":370,"_154":362,"_42":43,"_41":167,"_156":59,"_39":371,"_13":63,"_34":317,"_36":372,"_24":25,"_161":-5,"_294":373,"_27":374},{"_44":359,"_32":360,"_30":361,"_154":362,"_42":43,"_41":167,"_156":59,"_39":363,"_13":63,"_34":317,"_36":364,"_24":25,"_161":-5,"_294":365,"_27":366},{"_44":353,"_32":172,"_30":354,"_154":205,"_42":43,"_41":167,"_156":59,"_39":355,"_13":63,"_34":20,"_36":356,"_24":25,"_161":-5,"_294":357,"_27":358},{"_44":346,"_32":347,"_30":348,"_154":205,"_42":43,"_41":315,"_156":25,"_39":349,"_13":167,"_34":20,"_36":350,"_24":25,"_161":-5,"_294":351,"_27":352},{"_44":339,"_32":340,"_30":341,"_154":205,"_42":43,"_41":167,"_156":59,"_39":342,"_13":63,"_34":317,"_36":343,"_24":25,"_161":-5,"_294":344,"_27":345},{"_44":197,"_32":198,"_30":199,"_154":-5,"_42":43,"_41":167,"_156":59,"_39":336,"_13":63,"_34":201,"_36":-5,"_24":25,"_161":-5,"_294":337,"_27":338},{"_44":330,"_32":172,"_30":331,"_154":199,"_42":43,"_41":167,"_156":59,"_39":332,"_13":63,"_34":20,"_36":333,"_24":25,"_161":-5,"_294":334,"_27":335},{"_44":321,"_32":322,"_30":323,"_154":199,"_42":43,"_41":324,"_156":25,"_39":325,"_13":326,"_34":317,"_36":327,"_24":25,"_161":-5,"_294":328,"_27":329},{"_44":312,"_32":313,"_30":314,"_154":199,"_42":43,"_41":315,"_156":25,"_39":316,"_13":167,"_34":317,"_36":318,"_24":25,"_161":-5,"_294":319,"_27":320},{"_44":191,"_32":192,"_30":193,"_154":-5,"_42":43,"_41":167,"_156":59,"_39":309,"_13":63,"_34":20,"_36":195,"_24":25,"_161":-5,"_294":310,"_27":311},{"_44":185,"_32":186,"_30":187,"_154":-5,"_42":43,"_41":167,"_156":59,"_39":306,"_13":63,"_34":20,"_36":189,"_24":25,"_161":-5,"_294":307,"_27":308},{"_44":179,"_32":180,"_30":181,"_154":-5,"_42":43,"_41":167,"_156":25,"_39":303,"_13":63,"_34":20,"_36":183,"_24":25,"_161":-5,"_294":304,"_27":305},{"_44":171,"_32":172,"_30":173,"_154":-5,"_42":43,"_41":174,"_156":25,"_39":300,"_13":176,"_34":20,"_36":177,"_24":25,"_161":-5,"_294":301,"_27":302},{"_44":164,"_32":165,"_30":166,"_154":-5,"_42":43,"_41":167,"_156":59,"_39":297,"_13":63,"_34":20,"_36":169,"_24":25,"_161":-5,"_294":298,"_27":299},{"_44":152,"_32":153,"_30":57,"_154":-5,"_42":43,"_41":155,"_156":25,"_39":293,"_13":158,"_34":159,"_36":160,"_24":25,"_161":162,"_294":295,"_27":296},["D",1762253231901],"children",[],[153],["D",1761588582800],[],[165],["D",1764377312648],[],[172],["D",1761588582800],[],[180],["D",1761588582800],[],[186],["D",1761588582800],[],[192],"43d13cc8-b962-11f0-8efb-0224a6c84d84","utils.ts","019a26dc-99bf-7269-a8f6-5e2af0c9fdd2",27,["D",1762249214392],"script","/**\n * Shared utility functions\n * IMPORTANT: These must work in both browser AND Deno (no Deno APIs allowed)\n */\n\n/**\n * Check if a string is a valid Notion page ID format\n */\nexport function isValidPageId(pageId: string): boolean {\n if (!pageId || typeof pageId !== 'string') {\n return false;\n }\n\n // Notion IDs are 32 characters (with or without hyphens)\n const cleanId = pageId.replace(/-/g, '');\n return cleanId.length === 32 && /^[a-f0-9]+$/i.test(cleanId);\n}\n\n/**\n * Normalize a Notion page ID (remove hyphens)\n */\nexport function normalizePageId(pageId: string): string {\n return pageId.replace(/-/g, '');\n}\n\n/**\n * Format a Notion page ID with hyphens in standard format\n * 8-4-4-4-12\n */\nexport function formatPageId(pageId: string): string {\n const clean = normalizePageId(pageId);\n return `${clean.slice(0, 8)}-${clean.slice(8, 12)}-${clean.slice(12, 16)}-${clean.slice(16, 20)}-${clean.slice(20)}`;\n}\n\n/**\n * Extract plain text from Notion rich text array\n */\nexport function getPlainText(richText: any[]): string {\n if (!Array.isArray(richText)) {\n return '';\n }\n return richText.map(text => text.plain_text || '').join('');\n}\n\n/**\n * Safely get a property value from Notion page properties\n */\nexport function getPropertyValue(properties: any, propertyName: string): any {\n const property = properties[propertyName];\n if (!property) {\n return null;\n }\n\n // Extract value based on property type\n switch (property.type) {\n case 'title':\n return getPlainText(property.title);\n case 'rich_text':\n return getPlainText(property.rich_text);\n case 'number':\n return property.number;\n case 'select':\n return property.select?.name || null;\n case 'multi_select':\n return property.multi_select?.map((s: any) => s.name) || [];\n case 'date':\n return property.date?.start || null;\n case 'checkbox':\n return property.checkbox;\n case 'url':\n return property.url;\n case 'email':\n return property.email;\n case 'phone_number':\n return property.phone_number;\n case 'status':\n return property.status?.name || null;\n default:\n return property;\n }\n}\n\n/**\n * Format an ISO timestamp to relative time\n * Examples: \"2 hours ago\", \"Yesterday\", \"3 days ago\"\n *\n * @param isoString - ISO 8601 timestamp string\n * @returns Human-readable relative time string\n */\nexport function formatRelativeTime(isoString: string): string {\n try {\n const date = new Date(isoString);\n const now = new Date();\n const diffMs = now.getTime() - date.getTime();\n const diffMinutes = Math.floor(diffMs / (1000 * 60));\n const diffHours = Math.floor(diffMs / (1000 * 60 * 60));\n const diffDays = Math.floor(diffMs / (1000 * 60 * 60 * 24));\n\n // Less than 1 minute\n if (diffMinutes < 1) {\n return \"Just now\";\n }\n\n // Less than 1 hour\n if (diffMinutes < 60) {\n return `${diffMinutes} minute${diffMinutes === 1 ? '' : 's'} ago`;\n }\n\n // Less than 24 hours\n if (diffHours < 24) {\n return `${diffHours} hour${diffHours === 1 ? '' : 's'} ago`;\n }\n\n // Less than 2 days (show \"Yesterday\")\n if (diffDays === 1) {\n return \"Yesterday\";\n }\n\n // Less than 7 days\n if (diffDays < 7) {\n return `${diffDays} days ago`;\n }\n\n // More than 7 days - show date\n return date.toLocaleDateString('en-US', {\n month: 'short',\n day: 'numeric',\n year: date.getFullYear() !== now.getFullYear() ? 'numeric' : undefined\n });\n\n } catch (err) {\n return isoString; // Fallback to original string\n }\n}\n",[],[198,313],"f74d2ca0-d5b7-11f0-ade5-42dde27851f2","types.ts","019a26dc-99bf-7269-a8f6-5917ad49537e",161,["D",1765364655313],10,"/**\n * Shared TypeScript types and interfaces\n * These work in both frontend (browser) and backend (Deno)\n */\n\n/**\n * Standard response format for all controller functions\n */\nexport interface ControllerResponse<T = any> {\n success: boolean;\n data: T | null;\n error: string | null;\n details?: string;\n}\n\n/**\n * Notion page response (simplified)\n * For full types, use @notionhq/client types in backend\n */\nexport interface NotionPage {\n id: string;\n object: 'page';\n created_time: string;\n last_edited_time: string;\n properties: Record<string, any>;\n parent: {\n type: string;\n database_id?: string;\n page_id?: string;\n };\n url: string;\n}\n\n/**\n * Notion database response (simplified)\n */\nexport interface NotionDatabase {\n id: string;\n object: 'database';\n created_time: string;\n last_edited_time: string;\n title: Array<{\n type: string;\n plain_text: string;\n }>;\n properties: Record<string, any>;\n}\n\n/**\n * Notion webhook payload\n */\nexport interface NotionWebhookPayload {\n type: 'page' | 'database';\n page?: NotionPage;\n database?: NotionDatabase;\n}\n\n/**\n * Common page properties (extend as needed)\n */\nexport interface PageProperties {\n [key: string]: any;\n}\n\n/**\n * API request/response types\n */\nexport interface UpdatePageRequest {\n properties: PageProperties;\n}\n\nexport interface CreatePageRequest {\n databaseId: string;\n properties: PageProperties;\n}\n\nexport interface PageResponse {\n page: NotionPage;\n}\n\nexport interface PagesListResponse {\n pages: NotionPage[];\n}\n\n/**\n * Faviconizer API response\n */\nexport interface FaviconizerResponse {\n domain: string;\n faviconUrl: string;\n success: boolean;\n source: string;\n contentType: string;\n}\n\n/**\n * Favicon update result\n */\nexport interface FaviconUpdateResult {\n success: boolean;\n iconUpdated?: boolean;\n errorNoteAdded?: boolean;\n successNoteAdded?: boolean;\n error?: string;\n details?: string;\n}\n\n/**\n * Todo search result\n */\nexport interface TodoSearchResult {\n success: boolean;\n blocksFound: number;\n blocksNew?: number;\n blocksUpdated?: number;\n blocksSkipped?: number;\n blockIds: string[];\n error?: string;\n details?: string;\n}\n\n/**\n * Sync metadata for blob storage optimization\n */\nexport interface SyncMetadata {\n synced: boolean; // true = already synced, false = needs sync\n notion_page_id?: string; // Cached Notion page ID (avoids query on update)\n archived?: boolean; // true = Notion page was archived by user\n}\n\n/**\n * Reduced/transformed Notion block structure\n */\nexport interface ReducedNotionBlock {\n todo_string: string;\n block_id: string;\n block_url: string;\n page_url?: string; // Source page URL where the todo block was found\n parent_id?: string | null; // Parent block ID for traversal (null if parent is page)\n has_children?: boolean; // true = block has nested children\n last_edited_time: string;\n people_mentions: Array<{\n id: string;\n name: string;\n email: string | null;\n }>;\n date_mentions: string[];\n link_mentions: Array<{\n text: string;\n url: string;\n }>;\n sync_metadata?: SyncMetadata; // Optional sync tracking metadata\n}\n\n/**\n * Blob storage save result\n */\nexport interface BlobSaveResult {\n success: boolean;\n key: string | null;\n error: string | null;\n}\n\n/**\n * Todo save to Notion result\n */\nexport interface TodoSaveResult {\n success: boolean;\n totalBlobs: number;\n pagesCreated: number;\n pagesUpdated: number;\n pagesSkipped: number;\n pagesFailed: number;\n failures: Array<{\n blockId: string;\n error: string;\n }>;\n error?: string;\n details?: string;\n}\n",[],[198,322],"1cb975e0-b360-11f0-bc6f-0224a6c84d84","019a26dc-99bf-7269-a8f6-57913e4eabdf",["D",1761588582800],"# Shared\n\nThis directory contains code shared between frontend (browser) and backend (Deno).\n\n## Files\n\n- **types.ts** - TypeScript interfaces and types\n - Controller response format\n - Notion data structures\n - API request/response types\n\n- **utils.ts** - Utility functions\n - Must work in both browser AND Deno\n - ❌ **NEVER use Deno APIs** (won't work in browser)\n - ✅ Only use standard JavaScript/TypeScript\n\n## Guidelines\n\n### Adding Types\n- Define interfaces for data shared between layers\n- Use clear, descriptive names (PascalCase)\n- Document complex types with comments\n\n### Adding Utils\n- Test that functions work in both environments\n- Avoid platform-specific APIs (Deno, Node, browser-only)\n- Use pure functions when possible\n\n## Example\n\n```typescript\n// ✅ Good - works everywhere\nexport function formatDate(date: string): string {\n return new Date(date).toLocaleDateString();\n}\n\n// ❌ Bad - Deno-specific\nexport function readConfig() {\n return Deno.env.get('CONFIG'); // Won't work in browser!\n}\n```\n",[],[198,172],["D",1761588582800],[284,285,286],[198],"1cb97342-b360-11f0-bc6f-0224a6c84d84","index.tsx","019a26dc-99bf-7269-a8f6-4e21b80e62ce",["D",1761588582800],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport ReactDOM from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./components/App.tsx\";\n\nconst root = ReactDOM.createRoot(document.getElementById(\"root\")!);\nroot.render(\n <React.StrictMode>\n <App />\n </React.StrictMode>\n);\n",[],[204,340],"43d13ac0-b962-11f0-8efb-0224a6c84d84","index.html","019a26dc-99bf-7269-a8f6-489546010958",["D",1762249214392],"<!DOCTYPE html>\n<html lang=\"en\">\n <head>\n <meta charset=\"UTF-8\" />\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\" />\n <title>Todo Sweeper - Recent Pages</title>\n\n \n <link\n rel=\"stylesheet\"\n href=\"https://cdn.jsdelivr.net/npm/@picocss/pico@2/css/pico.min.css\"\n />\n <style>\n #root > div {\n padding-block: var(--pico-block-spacing-vertical);\n }\n </style>\n\n \n <script src=\"https://esm.town/v/std/catch\"></script>\n </head>\n <body>\n <div id=\"root\" class=\"container\"></div>\n\n \n <script type=\"module\" src=\"/frontend/index.tsx\"></script>\n </body>\n</html>\n",[],[204,347],"1cb97072-b360-11f0-bc6f-0224a6c84d84","019a26dc-99bf-7269-a8f6-463e83dc952c",["D",1761588582800],"# Frontend\n\nThis directory contains the React frontend for the Notion webhook integration application.\n\n## Structure\n\n- **index.html** - HTML shell that loads the React app\n- **index.tsx** - React app entry point\n- **components/** - React components\n - **App.tsx** - Main application component\n - **NotionBlock.tsx** - Renders Notion block content\n - **NotionProperty.tsx** - Displays Notion page properties\n\n## React Configuration\n\n**IMPORTANT**: All React files must:\n1. Include `/** @jsxImportSource https://esm.sh/react@18.2.0 */` at the top\n2. Pin React dependencies to version 18.2.0: `?deps=react@18.2.0`\n3. Use consistent React version across all imports\n\n## Styling\n\nUses Pico CSS (classless CSS framework loaded from CDN in index.html). Pico automatically styles semantic HTML elements without requiring CSS classes, keeping markup clean and maintainable.\n\n## API Communication\n\n- Fetch data from `/api/*` endpoints\n- Use shared types from `../shared/types.ts`\n- Handle loading and error states in components\n\n## Error Handling\n\nThe error catching script is included in index.html to capture client-side errors for better debugging.\n\n## Development\n\nSince this is a Val Town project, the frontend is served through Hono routes defined in `main.http.tsx`.\n",[],[204,172],"1cb96d48-b360-11f0-bc6f-0224a6c84d84","NotionProperty.tsx","019a26dc-99bf-7269-a8f6-3d6be1b615e8","019a26dc-99bf-7269-a8f6-40d88c93ec73",["D",1761588582800],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { getPropertyValue } from \"../../shared/utils.ts\";\n\ninterface NotionPropertyProps {\n name: string;\n property: any;\n}\n\n/**\n * Component for rendering Notion page properties\n * Uses semantic HTML - Pico CSS provides automatic styling\n * Handles different property types\n */\nexport function NotionProperty({ name, property }: NotionPropertyProps) {\n if (!property) {\n return null;\n }\n\n const value = getPropertyValue({ [name]: property }, name);\n\n const renderValue = () => {\n switch (property.type) {\n case 'title':\n case 'rich_text':\n return <span>{value}</span>;\n\n case 'number':\n return <code>{value}</code>;\n\n case 'select':\n return <kbd>{value}</kbd>;\n\n case 'multi_select':\n return (\n <span>\n {Array.isArray(value) && value.map((item: string, i: number) => (\n <kbd key={i} style={{ marginRight: '0.5rem' }}>\n {item}\n </kbd>\n ))}\n </span>\n );\n\n case 'date':\n return (\n <time>\n {value ? new Date(value).toLocaleDateString() : '-'}\n </time>\n );\n\n case 'checkbox':\n return (\n <input\n type=\"checkbox\"\n checked={value}\n readOnly\n />\n );\n\n case 'url':\n return (\n <a\n href={value}\n target=\"_blank\"\n rel=\"noopener noreferrer\"\n >\n {value}\n </a>\n );\n\n case 'email':\n return (\n <a href={`mailto:${value}`}>\n {value}\n </a>\n );\n\n case 'phone_number':\n return (\n <a href={`tel:${value}`}>\n {value}\n </a>\n );\n\n case 'status':\n return <mark>{value}</mark>;\n\n default:\n return (\n <small>\n <em>Unsupported: {property.type}</em>\n </small>\n );\n }\n };\n\n return (\n <p>\n <strong>{name}:</strong> {renderValue()}\n </p>\n );\n}\n",[],[204,367,360],"components","1cb96a96-b360-11f0-bc6f-0224a6c84d84","NotionBlock.tsx","019a26dc-99bf-7269-a8f6-3ab802992fe4",["D",1761588582800],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\ninterface NotionBlockProps {\n block: any;\n}\n\n/**\n * Component for rendering Notion blocks\n * Uses semantic HTML - Pico CSS provides automatic styling\n * Extend this to support different block types as needed\n */\nexport function NotionBlock({ block }: NotionBlockProps) {\n if (!block || !block.type) {\n return null;\n }\n\n const renderBlockContent = () => {\n switch (block.type) {\n case 'paragraph':\n return (\n <p>\n {block.paragraph?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </p>\n );\n\n case 'heading_1':\n return (\n <h1>\n {block.heading_1?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </h1>\n );\n\n case 'heading_2':\n return (\n <h2>\n {block.heading_2?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </h2>\n );\n\n case 'heading_3':\n return (\n <h3>\n {block.heading_3?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </h3>\n );\n\n case 'bulleted_list_item':\n return (\n <li>\n {block.bulleted_list_item?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </li>\n );\n\n case 'numbered_list_item':\n return (\n <li>\n {block.numbered_list_item?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </li>\n );\n\n case 'to_do':\n return (\n <label>\n <input\n type=\"checkbox\"\n checked={block.to_do?.checked}\n readOnly\n />\n <span style={block.to_do?.checked ? { textDecoration: 'line-through', opacity: 0.6 } : undefined}>\n {block.to_do?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </span>\n </label>\n );\n\n case 'code':\n return (\n <pre>\n <code>\n {block.code?.rich_text?.map((text: any, i: number) => (\n <span key={i}>{text.plain_text}</span>\n ))}\n </code>\n </pre>\n );\n\n default:\n return (\n <small>\n <em>Unsupported block type: {block.type}</em>\n </small>\n );\n }\n };\n\n return <div>{renderBlockContent()}</div>;\n}\n",[],[204,367,369],"02c22c48-d51d-11f0-9f74-42dde27851f2","App.tsx","019a26dc-99bf-7269-a8f6-34ccac805b70",156,["D",1765298102541],3,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport {\n useState,\n useEffect,\n} from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport { formatRelativeTime } from \"../../shared/utils.ts\";\n\ninterface NotionPage {\n id: string;\n title: string;\n url: string;\n last_edited_time: string;\n parent?: {\n type: string;\n id?: string;\n };\n}\n\ninterface RecentPagesResponse {\n pages: NotionPage[];\n count: number;\n timeRange: string;\n}\n\ninterface HealthData {\n timestamp: string;\n connections: {\n notion: {\n connected: boolean;\n };\n todos_db: {\n connected: boolean;\n title?: string;\n url?: string;\n last_edited_time?: string;\n };\n };\n environment: {\n NOTION_API_KEY: {\n configured: boolean;\n };\n WEBHOOK_SECRET: {\n configured: boolean;\n };\n TODOS_DB_ID: {\n configured: boolean;\n value?: string;\n };\n RECENT_PAGES_LOOKBACK_HOURS: {\n configured: boolean;\n value: number;\n default: number;\n };\n BLOCK_STABILITY_MINUTES: {\n configured: boolean;\n value: number;\n default: number;\n };\n MIN_BLOCK_WORDS: {\n configured: boolean;\n value: number;\n default: number;\n };\n SEARCH_KEYWORDS: {\n configured: boolean;\n value: string[];\n default: string[];\n };\n SEARCH_BLOCK_TYPE: {\n configured: boolean;\n value: string | null;\n default: string;\n };\n DEFAULT_DUE_DATE: {\n configured: boolean;\n value: string;\n default: string;\n };\n };\n pages: {\n count: number;\n lookback_hours: number;\n results: Array<{\n page_id: string;\n title: string;\n last_edited_time: string;\n url: string;\n parent?: {\n type: string;\n id?: string;\n };\n }>;\n };\n blobs: {\n category: string;\n prefix: string;\n count: number;\n };\n}\n\nexport function App() {\n const [pages, setPages] = useState<NotionPage[]>([]);\n const [loading, setLoading] = useState(true);\n const [error, setError] = useState<string | null>(null);\n const [hours, setHours] = useState(24); // Track for button state (assumes 24 default)\n const [lastSync, setLastSync] = useState<Date | null>(null);\n const [healthData, setHealthData] = useState<HealthData | null>(null);\n\n const fetchHealthData = async () => {\n setLoading(true);\n setError(null);\n\n try {\n const response = await fetch(\"/api/health\");\n const data: HealthData = await response.json();\n\n if (!response.ok) {\n throw new Error(\"Failed to fetch health data\");\n }\n\n setHealthData(data);\n\n // Convert health data pages to NotionPage format for display\n const notionPages: NotionPage[] = data.pages.results.map((p) => ({\n id: p.page_id,\n title: p.title,\n url: p.url,\n last_edited_time: p.last_edited_time,\n parent: p.parent,\n }));\n\n setPages(notionPages);\n setHours(data.pages.lookback_hours);\n setLastSync(new Date());\n } catch (err: any) {\n setError(err.message || \"An error occurred\");\n setPages([]);\n } finally {\n setLoading(false);\n }\n };\n\n const fetchRecentPages = async (timeHours?: number) => {\n setLoading(true);\n setError(null);\n\n try {\n // If timeHours is undefined, don't send param (use server default)\n const url = timeHours\n ? `/api/pages/recent?hours=${timeHours}`\n : `/api/pages/recent`;\n\n const response = await fetch(url);\n\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({}));\n throw new Error(errorData.error || \"Failed to fetch recent pages\");\n }\n\n const data: RecentPagesResponse = await response.json();\n setPages(data.pages || []);\n setLastSync(new Date());\n\n // Update hours state if explicitly provided\n if (timeHours !== undefined) {\n setHours(timeHours);\n }\n\n // Also refresh health data\n fetchHealthData();\n } catch (err: any) {\n setError(err.message || \"An error occurred\");\n setPages([]);\n } finally {\n setLoading(false);\n }\n };\n\n // Fetch health data on mount\n useEffect(() => {\n fetchHealthData();\n }, []);\n\n // Handle time range change\n const handleTimeRangeChange = (newHours: number) => {\n fetchRecentPages(newHours);\n };\n\n // Handle refresh - use current hours if set, otherwise use server default\n const handleRefresh = () => {\n // If hours is the assumed default (24), don't send param\n // This allows server env var to take effect\n // If user explicitly selected a time range, use that\n if (hours === 24) {\n fetchRecentPages(); // Use server default\n } else {\n fetchRecentPages(hours); // Use explicit selection\n }\n };\n\n return (\n <div className=\"container\">\n <header>\n <hgroup>\n <h1>\n <code>todoSweeper</code>\n </h1>\n <p>\n Sweeps todos from the pages of your Notion workspace into a central\n Todos database\n </p>\n </hgroup>\n </header>\n <main>\n {/* Connection Status */}\n <section>\n {loading && <p aria-busy=\"true\">Connecting to Notion...</p>}\n\n {!loading && !error && healthData && (\n <article>\n <h3>Connection status</h3>\n <div>\n <dl>\n <dt>Notion</dt>\n <dd>\n {healthData.connections.notion.connected ? (\n <mark>✓ connected</mark>\n ) : (\n <s>✗ not connected</s>\n )}\n </dd>\n <dt>Todos database</dt>\n <dd>\n {healthData.connections.todos_db.connected ? (\n <mark>✓ connected</mark>\n ) : (\n <s>✗ not connected</s>\n )}\n </dd>\n <dt>Todos handled</dt>\n <dd>{healthData.blobs.count}</dd>\n </dl>\n </div>\n <footer>\n <details>\n <summary>\n Details (<code>JSON</code>)\n </summary>\n <div>\n <p>\n A preview of this val's health and configuration endpoint,\n also available at{\" \"}\n <code>\n <a href=\"/api/health\" target=\"_blank\">\n /api/health\n </a>\n </code>\n :\n </p>\n {/* Health Status JSON */}\n {!loading && healthData && (\n <pre>{JSON.stringify(healthData, null, 2)}</pre>\n )}\n <p>\n The <code>environment</code> object previews the values of\n key environment variables, which are are configurable in\n the val.town UI. Learn about them in the README.\n </p>\n </div>\n </details>\n </footer>\n </article>\n )}\n\n {!loading && error && (\n <details>\n <summary>\n <strong style={{ color: \"red\" }}>✗ Connection Error</strong>\n </summary>\n <div>\n <mark>{error}</mark>\n <h3>Troubleshooting</h3>\n <ul>\n <li>\n Check that <code>NOTION_API_KEY</code> is set correctly\n </li>\n <li>Verify your integration has access to your workspace</li>\n <li>Ensure the API key hasn't expired</li>\n <li>Make sure pages are shared with your integration</li>\n </ul>\n </div>\n </details>\n )}\n </section>\n </main>\n </div>\n );\n}\n",[],[204,367,376],"1cb96f5a-b360-11f0-bc6f-0224a6c84d84",["D",1761588582800],[277,278,279],[204,367],["D",1761588582800],[276,280,281,282],[204],"1cb96514-b360-11f0-bc6f-0224a6c84d84","019a26dc-99bf-7269-a8f6-2fbd5953f9c6",["D",1761588582800],"# Backend\n\nThis directory contains the backend logic for the Notion webhook integration application.\n\n## Structure\n\n- **controllers/** - Business logic and orchestration\n - Contains functions that validate data, orchestrate service calls, and return standardized responses\n - All controllers return `{success, data, error, details?}` format\n - Controllers are HTTP-agnostic (don't create HTTP responses)\n\n- **routes/** - HTTP request/response handling\n - **api/** - RESTful API endpoints for data operations\n - **tasks/** - Notion webhook handlers\n - **views/** - User-facing HTML/React views\n - **authCheck.ts** - Authentication middleware\n\n- **services/** - External API integrations\n - Handle calls to external APIs (Notion, Firecrawler, blob storage, etc.)\n - Return structured results with `{success, data, error}` format\n - Manage API authentication and error handling\n\n## Architecture Flow\n\n```\nRequest → Route → Controller → Service → External API\n```\n\n**Never skip layers!**\n- Routes call controllers (not services directly)\n- Controllers call services (not external APIs directly)\n- Services handle external API calls\n\n## Adding New Features\n\n1. Create route in appropriate directory (`api/`, `tasks/`, or `views/`)\n2. Create controller function with business logic\n3. Create/use service functions for external API calls\n4. Mount route in `main.http.tsx`\n\nSee `CLAUDE.md` for detailed guidelines.\n",[],[209,172],"b947264a-b659-11f0-934f-0224a6c84d84","textUtils.ts","b94726c2-b659-11f0-934f-0224a6c84d84","019a2d3c-4319-71ac-88e5-a0aa162b3be7",20,["D",1761915692505],"/**\n * Text utility functions for word counting and text validation\n * Pure functions with no external dependencies\n */\n\n/**\n * Get minimum block words setting from environment variable\n *\n * Reads MIN_BLOCK_WORDS env var\n * Falls back to 5 if not set or invalid\n *\n * Default of 5 accounts for:\n * - ~1 word for person mention (e.g., \"@John\")\n * - ~2-3 words for date mention (e.g., \"October 30, 2025\")\n * - ~2-3 words for action (e.g., \"buy groceries\")\n *\n * @returns Minimum word count (integer >= 1)\n */\nexport function getMinBlockWords(): number {\n const envValue = Deno.env.get('MIN_BLOCK_WORDS');\n\n if (!envValue) {\n return 5; // Default fallback\n }\n\n const parsed = parseInt(envValue.trim(), 10);\n\n // Validate: must be a positive integer\n if (isNaN(parsed) || parsed < 1) {\n console.warn(`⚠ Invalid MIN_BLOCK_WORDS value: \"${envValue}\". Using 5 as fallback.`);\n return 5;\n }\n\n return parsed;\n}\n\n/**\n * Count words in a text string\n *\n * Splits by whitespace and counts non-empty tokens\n * - Hyphenated words count as 1 word (e.g., \"buy-now\" = 1)\n * - Emojis count as words (e.g., \"🍋 🎉\" = 2)\n * - Mentions count as words (e.g., \"@John tomorrow\" = 2)\n * - Dates count as words (e.g., \"October 30, 2025\" = 3)\n *\n * @param text - Text string to count words in\n * @returns Number of words\n */\nexport function countWords(text: string): number {\n if (!text || typeof text !== 'string') {\n return 0;\n }\n\n // Split by whitespace, filter empty strings\n const words = text.trim().split(/\\s+/).filter(w => w.length > 0);\n\n return words.length;\n}\n",[],[209,406,398],"utils","77d92e02-ccb5-11f0-bf4c-42dde27851f2","projectUtils.ts","380f0278-cc84-11f0-9eea-42dde27851f2",126,["D",1764374022023],6,"/**\n * Project utility functions for disambiguation\n */\n\nexport interface ProjectWithDates {\n id: string;\n name?: string;\n clientName: string | null;\n dateStart: string | null;\n dateEnd: string | null;\n lastEditedTime: string;\n}\n\n/**\n * Result from disambiguation - either a project ID or candidates for AI disambiguation\n */\nexport interface DisambiguationResult {\n projectId: string | null;\n needsAiDisambiguation: boolean;\n candidates?: ProjectWithDates[];\n}\n\n/**\n * Pick the best project for a client based on todo due date\n *\n * Disambiguation strategy:\n * 1. If due date falls within exactly one project's date range → use that project\n * 2. If due date falls within multiple projects → return candidates for AI disambiguation\n * 3. If no project contains the due date → pick project with closest start/end date\n * 4. If projects have no dates → use most recently edited project\n *\n * @param clientName - The client name to filter by\n * @param projects - Array of projects with dates\n * @param todoDueDate - The todo's due date (ISO string) or null\n * @returns DisambiguationResult with projectId or candidates for AI\n */\nexport function disambiguateClientProjects(\n clientName: string,\n projects: ProjectWithDates[],\n todoDueDate: string | null\n): DisambiguationResult {\n // Filter to projects for this client\n const clientProjects = projects.filter(p => p.clientName === clientName);\n\n if (clientProjects.length === 0) {\n return { projectId: null, needsAiDisambiguation: false };\n }\n if (clientProjects.length === 1) {\n return { projectId: clientProjects[0].id, needsAiDisambiguation: false };\n }\n\n // No due date - use most recently edited\n if (!todoDueDate) {\n return { projectId: getMostRecentlyEdited(clientProjects), needsAiDisambiguation: false };\n }\n\n const dueDate = new Date(todoDueDate);\n\n // Strategy 1: Find ALL projects where due date is within range\n const matchingProjects = clientProjects.filter(project => {\n if (project.dateStart && project.dateEnd) {\n const start = new Date(project.dateStart);\n const end = new Date(project.dateEnd);\n return dueDate >= start && dueDate <= end;\n }\n return false;\n });\n\n if (matchingProjects.length === 1) {\n // Exactly one match - use it\n return { projectId: matchingProjects[0].id, needsAiDisambiguation: false };\n }\n\n if (matchingProjects.length > 1) {\n // Multiple overlapping date ranges - need AI to decide\n return { projectId: null, needsAiDisambiguation: true, candidates: matchingProjects };\n }\n\n // Strategy 2: No exact matches - find closest date boundary\n let closestProject = clientProjects[0];\n let closestDistance = Infinity;\n\n for (const project of clientProjects) {\n const startDist = project.dateStart\n ? Math.abs(dueDate.getTime() - new Date(project.dateStart).getTime())\n : Infinity;\n const endDist = project.dateEnd\n ? Math.abs(dueDate.getTime() - new Date(project.dateEnd).getTime())\n : Infinity;\n const minDist = Math.min(startDist, endDist);\n\n if (minDist < closestDistance) {\n closestDistance = minDist;\n closestProject = project;\n }\n }\n\n // Strategy 3: Fallback to most recently edited (if all have Infinity distance)\n if (closestDistance === Infinity) {\n return { projectId: getMostRecentlyEdited(clientProjects), needsAiDisambiguation: false };\n }\n\n return { projectId: closestProject.id, needsAiDisambiguation: false };\n}\n\n/**\n * Get the most recently edited project from a list\n */\nfunction getMostRecentlyEdited(projects: ProjectWithDates[]): string {\n return projects.sort((a, b) =>\n new Date(b.lastEditedTime).getTime() - new Date(a.lastEditedTime).getTime()\n )[0].id;\n}\n",[],[209,406,408],"fcd94368-cdef-11f0-9531-42dde27851f2","notionUtils.ts","1582a536-b459-11f0-a09c-0224a6c84d84",137,["D",1764509107125],8,"/**\n * Notion utility functions for block transformations and processing\n */\n\n/**\n * Format an ISO date string to human-readable format\n *\n * @param dateStr - ISO date string (e.g., \"2025-10-27\" or \"2025-10-27T09:00:00.000-04:00\")\n * @returns Formatted date string (e.g., \"October 27, 2025\" or \"October 27, 2025 at 9:00 AM EDT\")\n */\nfunction formatDateString(dateStr: string): string {\n try {\n // Check if it's date-only (no time component in original string)\n const isDateOnly = !dateStr.includes('T');\n\n if (isDateOnly) {\n // Date-only format: \"October 27, 2025\"\n const date = new Date(dateStr);\n return date.toLocaleDateString('en-US', {\n year: 'numeric',\n month: 'long',\n day: 'numeric',\n timeZone: 'UTC' // Use UTC for date-only to avoid timezone shifts\n });\n } else {\n // Datetime format: \"October 27, 2025 at 9:00 AM EDT\"\n // Parse the ISO string to extract components without timezone conversion\n const isoMatch = dateStr.match(/^(\\d{4})-(\\d{2})-(\\d{2})T(\\d{2}):(\\d{2}):(\\d{2})(?:\\.\\d+)?([-+]\\d{2}:\\d{2})?$/);\n\n if (!isoMatch) {\n // Fallback to original string if format doesn't match\n return dateStr;\n }\n\n const [_, year, month, day, hour24, minute, second, tzOffset] = isoMatch;\n\n // Create date object for formatting the date part only\n const date = new Date(`${year}-${month}-${day}`);\n const datePart = date.toLocaleDateString('en-US', {\n year: 'numeric',\n month: 'long',\n day: 'numeric',\n timeZone: 'UTC'\n });\n\n // Format time part - preserve the original hour/minute\n const hourNum = parseInt(hour24, 10);\n const minuteNum = parseInt(minute, 10);\n const isPM = hourNum >= 12;\n const hour12 = hourNum === 0 ? 12 : (hourNum > 12 ? hourNum - 12 : hourNum);\n const timePart = `${hour12}:${minute} ${isPM ? 'PM' : 'AM'}`;\n\n // Extract timezone abbreviation\n let tzAbbrev = '';\n if (tzOffset) {\n // Common timezone abbreviations based on offset\n const tzMap: Record<string, string> = {\n '-04:00': 'EDT',\n '-05:00': 'EST/CDT',\n '-06:00': 'CST/MDT',\n '-07:00': 'MST/PDT',\n '-08:00': 'PST',\n '+00:00': 'UTC',\n // Add more as needed\n };\n tzAbbrev = ` ${tzMap[tzOffset] || tzOffset}`;\n }\n\n return `${datePart} at ${timePart}${tzAbbrev}`;\n }\n } catch (err) {\n // If parsing fails, return original string\n return dateStr;\n }\n}\n\n/**\n * Remove hyphens from a string (for Notion URLs)\n */\nfunction removeHyphens(str: string): string {\n return str.replace(/-/g, '');\n}\n\nexport function reduceNotionBlock(block: any) {\n const blockId = block?.id;\n const lastEdited = block?.last_edited_time;\n\n // Generate Notion block URL\n const blockUrl = blockId ? `https://www.notion.so/${removeHyphens(blockId)}` : '';\n\n const richText = block?.[block.type]?.rich_text ?? [];\n\n // Collect all date strings for display formatting\n const allDateStrings: string[] = [];\n\n // Date mentions for due dates - only include if prefaced by \"due\" or \"by\"\n // Other date mentions are treated as content, not due dates\n const date_mentions: string[] = [];\n for (let i = 0; i < richText.length; i++) {\n const part = richText[i];\n if (part.type === \"mention\" && part.mention?.type === \"date\") {\n const dateStr = part.mention.date.start ?? part.mention.date.end;\n if (dateStr) {\n // Always collect for display formatting\n allDateStrings.push(dateStr);\n\n // Get text preceding this date mention\n const precedingText = richText\n .slice(0, i)\n .map((p: any) => p.plain_text || '')\n .join('')\n .toLowerCase()\n .trimEnd();\n\n // Only use as due date if preceded by \"due\" or \"by\"\n if (precedingText.endsWith('due') || precedingText.endsWith('by')) {\n date_mentions.push(dateStr);\n }\n }\n }\n }\n\n // Build full sentence and replace ISO dates with formatted versions\n let fullSentence = richText\n .map((part: any) => part.plain_text)\n .join(\"\")\n .replace(/\\s+/g, \" \") // collapse multiple spaces\n .trim();\n\n // Replace ALL date mentions in the full sentence with formatted version\n for (const dateStr of allDateStrings) {\n const formattedDate = formatDateString(dateStr);\n // Replace the ISO date string with formatted version\n fullSentence = fullSentence.replace(dateStr, formattedDate);\n }\n\n // People mentions\n const people_mentions = richText\n .filter((part: any) => part.type === \"mention\" && part.mention?.type === \"user\")\n .map((part: any) => {\n const user = part.mention.user;\n return {\n id: user.id,\n name: user.name,\n email: user.person?.email ?? null,\n };\n });\n\n // Link mentions (Notion pages, external links - anything with href)\n const link_mentions = richText\n .filter((part: any) => {\n // Check for href property (mentions and some links)\n // OR check for text.link.url (regular hyperlinks)\n return part.href || part.text?.link?.url;\n })\n .map((part: any) => ({\n text: part.plain_text,\n url: part.href || part.text?.link?.url\n }));\n\n return {\n todo_string: fullSentence,\n block_id: blockId,\n block_url: blockUrl,\n last_edited_time: lastEdited,\n people_mentions,\n date_mentions,\n link_mentions,\n };\n}\n\n/**\n * Map ReducedNotionBlock to Notion database properties\n *\n * Property mappings:\n * - todo_string → Name (title)\n * - block_id → Block ID (rich_text)\n * - block_url → Block URL (url)\n * - last_edited_time → Todo last edited time (date)\n * - people_mentions[0] → Owner (people)\n * - people_mentions[1..] → Other people (people)\n * - date_mentions[0] → Due date (date)\n * - link_mentions → Links (rich_text with embedded links)\n * - projectIds → Projects db (relation)\n */\nexport function mapReducedBlockToProperties(reducedBlock: any, projectIds?: string[]) {\n const properties: any = {};\n\n // Name (title)\n properties[\"Name\"] = {\n title: [\n {\n type: \"text\",\n text: { content: reducedBlock.todo_string }\n }\n ]\n };\n\n // Block ID (rich_text)\n properties[\"Block ID\"] = {\n rich_text: [\n {\n type: \"text\",\n text: { content: reducedBlock.block_id }\n }\n ]\n };\n\n // Block URL (url)\n if (reducedBlock.block_url) {\n properties[\"Block URL\"] = {\n url: reducedBlock.block_url\n };\n }\n\n // Page URL (url) - source page where the todo block was found\n if (reducedBlock.page_url) {\n properties[\"Page URL\"] = {\n url: reducedBlock.page_url\n };\n }\n\n // Todo last edited time (date)\n properties[\"Todo last edited time\"] = {\n date: {\n start: reducedBlock.last_edited_time\n }\n };\n\n // Owner (people) - first person\n if (reducedBlock.people_mentions && reducedBlock.people_mentions.length > 0) {\n properties[\"Owner\"] = {\n people: [{ id: reducedBlock.people_mentions[0].id }]\n };\n }\n\n // Other people (people) - remaining people\n if (reducedBlock.people_mentions && reducedBlock.people_mentions.length > 1) {\n properties[\"Other people\"] = {\n people: reducedBlock.people_mentions.slice(1).map((p: any) => ({ id: p.id }))\n };\n }\n\n // Due date (date) - first date\n if (reducedBlock.date_mentions && reducedBlock.date_mentions.length > 0) {\n properties[\"Due date\"] = {\n date: {\n start: reducedBlock.date_mentions[0]\n }\n };\n }\n\n // Links (rich_text with embedded links as bullet list)\n if (reducedBlock.link_mentions && reducedBlock.link_mentions.length > 0) {\n properties[\"Links\"] = {\n rich_text: reducedBlock.link_mentions.flatMap((link: any, index: number) => {\n const parts = [];\n\n // Add bullet before each link\n parts.push({ type: \"text\", text: { content: \"• \" } });\n\n // Add the link\n parts.push({\n type: \"text\",\n text: {\n content: link.text,\n link: { url: link.url }\n }\n });\n\n // Add newline after each link except the last\n if (index < reducedBlock.link_mentions.length - 1) {\n parts.push({ type: \"text\", text: { content: \"\\n\" } });\n }\n\n return parts;\n })\n };\n }\n\n // Projects db (relation) - link to matching projects\n if (projectIds && projectIds.length > 0) {\n properties[\"Projects db\"] = {\n relation: projectIds.map(id => ({ id }))\n };\n }\n\n return properties;\n}\n\n/**\n * Extract Notion page ID from a URL\n *\n * Handles various Notion URL formats:\n * - https://www.notion.so/2393adc4305780f9b923d904dfacb88c (32 chars, no hyphens)\n * - https://www.notion.so/2393adc4-3057-80f9-b923-d904dfacb88c (36 chars, with hyphens)\n * - https://www.notion.so/workspace/Page-Name-2393adc4305780f9b923d904dfacb88c\n *\n * @param url - Notion page URL\n * @returns Normalized page ID (32 chars, no hyphens) or null if invalid\n */\nexport function extractPageIdFromUrl(url: string): string | null {\n if (!url || typeof url !== 'string') {\n return null;\n }\n\n try {\n // Parse URL to get pathname\n const urlObj = new URL(url);\n const pathname = urlObj.pathname;\n\n // Extract the last segment (which should contain the page ID)\n const segments = pathname.split('/').filter(s => s.length > 0);\n const lastSegment = segments[segments.length - 1];\n\n if (!lastSegment) {\n return null;\n }\n\n // Page ID can be:\n // 1. At the end: \"Page-Name-2393adc4305780f9b923d904dfacb88c\"\n // 2. The entire segment: \"2393adc4305780f9b923d904dfacb88c\"\n // 3. With hyphens: \"2393adc4-3057-80f9-b923-d904dfacb88c\"\n\n // Try to extract 32 or 36 character UUID-like pattern at the end\n const uuidPattern32 = /([a-f0-9]{32})$/i; // 32 chars without hyphens\n const uuidPattern36 = /([a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12})$/i; // 36 chars with hyphens\n\n // Try 36-char pattern first (with hyphens)\n let match = lastSegment.match(uuidPattern36);\n if (match) {\n // Remove hyphens to normalize\n return match[1].replace(/-/g, '');\n }\n\n // Try 32-char pattern (no hyphens)\n match = lastSegment.match(uuidPattern32);\n if (match) {\n return match[1];\n }\n\n return null;\n\n } catch (err) {\n // Invalid URL format\n return null;\n }\n}\n",[],[209,406,417],"1582a266-b459-11f0-a09c-0224a6c84d84","emojiUtils.ts","1582a2fc-b459-11f0-a09c-0224a6c84d84",16,["D",1761695515418],"/**\n * Emoji utility functions for extracting and detecting emojis\n */\n\n/**\n * Extract the first emoji from a text string\n *\n * @param text - Text to search for emoji\n * @returns First emoji character or null if none found\n *\n * @example\n * extractFirstEmoji(\"📝 Write documentation\") // Returns \"📝\"\n * extractFirstEmoji(\"No emoji here\") // Returns null\n */\nexport function extractFirstEmoji(text: string): string | null {\n if (!text) return null;\n\n // Comprehensive emoji regex pattern covering most common emoji ranges\n const emojiRegex = /[\\u{1F300}-\\u{1F9FF}\\u{2600}-\\u{26FF}\\u{2700}-\\u{27BF}\\u{1F000}-\\u{1F02F}\\u{1F0A0}-\\u{1F0FF}\\u{1F100}-\\u{1F64F}\\u{1F680}-\\u{1F6FF}\\u{1F900}-\\u{1F9FF}\\u{1FA00}-\\u{1FA6F}\\u{1FA70}-\\u{1FAFF}]/u;\n\n const match = text.match(emojiRegex);\n return match ? match[0] : null;\n}\n\n/**\n * Check if text contains at least one emoji\n *\n * @param text - Text to check\n * @returns True if emoji found, false otherwise\n */\nexport function hasEmoji(text: string): boolean {\n return extractFirstEmoji(text) !== null;\n}\n",[],[209,406,426],"b9471cfe-b659-11f0-934f-0224a6c84d84","dateUtils.ts","b9471dda-b659-11f0-934f-0224a6c84d84",["D",1761915692505],"/**\n * Date utility functions for calculating default due dates\n * Pure functions with no external dependencies\n */\n\n/**\n * Supported default due date settings\n */\nexport type DueDateSetting =\n | 'today'\n | 'tomorrow'\n | 'one_week'\n | 'end_of_week'\n | 'next_business_day';\n\n/**\n * Get default due date setting from environment variable\n *\n * Reads DEFAULT_DUE_DATE env var\n * Falls back to \"today\" if not set or invalid\n *\n * @returns Valid due date setting\n */\nexport function getDefaultDueDateSetting(): DueDateSetting {\n const envSetting = Deno.env.get('DEFAULT_DUE_DATE');\n\n if (!envSetting) {\n return 'today'; // Default fallback\n }\n\n const normalized = envSetting.trim().toLowerCase();\n\n // Validate setting\n const validSettings: DueDateSetting[] = [\n 'today',\n 'tomorrow',\n 'one_week',\n 'end_of_week',\n 'next_business_day'\n ];\n\n if (validSettings.includes(normalized as DueDateSetting)) {\n return normalized as DueDateSetting;\n }\n\n console.warn(`⚠ Invalid DEFAULT_DUE_DATE value: \"${envSetting}\". Using \"today\" as fallback.`);\n return 'today';\n}\n\n/**\n * Calculate due date based on setting\n *\n * Returns ISO date string (YYYY-MM-DD format)\n * All calculations are relative to today (now)\n *\n * @param setting - Due date setting\n * @returns ISO date string (e.g., \"2025-10-31\")\n */\nexport function calculateDueDate(setting: DueDateSetting): string {\n const now = new Date();\n let targetDate = new Date(now);\n\n switch (setting) {\n case 'today':\n // Already set to today\n break;\n\n case 'tomorrow':\n targetDate.setDate(targetDate.getDate() + 1);\n break;\n\n case 'one_week':\n targetDate.setDate(targetDate.getDate() + 7);\n break;\n\n case 'end_of_week':\n // Next Friday\n const currentDay = targetDate.getDay(); // 0 = Sunday, 5 = Friday\n let daysUntilFriday = (5 - currentDay + 7) % 7;\n\n // If today is Friday, go to next Friday\n if (daysUntilFriday === 0) {\n daysUntilFriday = 7;\n }\n\n targetDate.setDate(targetDate.getDate() + daysUntilFriday);\n break;\n\n case 'next_business_day':\n // Skip weekends (Saturday = 6, Sunday = 0)\n targetDate.setDate(targetDate.getDate() + 1); // Start with tomorrow\n\n while (targetDate.getDay() === 0 || targetDate.getDay() === 6) {\n targetDate.setDate(targetDate.getDate() + 1);\n }\n break;\n\n default:\n // Fallback to today for any unexpected values\n console.warn(`⚠ Unexpected due date setting: \"${setting}\". Using today.`);\n }\n\n // Format as ISO date string (YYYY-MM-DD)\n return toISODateString(targetDate);\n}\n\n/**\n * Convert Date object to ISO date string (YYYY-MM-DD)\n *\n * @param date - Date object\n * @returns ISO date string\n */\nfunction toISODateString(date: Date): string {\n const year = date.getFullYear();\n const month = String(date.getMonth() + 1).padStart(2, '0');\n const day = String(date.getDate()).padStart(2, '0');\n\n return `${year}-${month}-${day}`;\n}\n",[],[209,406,434],"43d0f5e2-b962-11f0-8efb-0224a6c84d84","configUtils.ts","43d0f650-b962-11f0-8efb-0224a6c84d84",["D",1762249214392],"/**\n * Configuration utility functions\n * Read and validate environment variables with sensible defaults\n */\n\n/**\n * Get recent pages lookback window from environment variable\n *\n * Reads RECENT_PAGES_LOOKBACK_HOURS env var to determine how far back\n * to search for recent Notion pages.\n *\n * Used by:\n * - Frontend dashboard initial load\n * - /api/pages/recent endpoint\n * - /tasks/todos batch processing\n * - Cron jobs (todoSearch.cron.ts)\n *\n * @returns Number of hours to look back (positive integer)\n * - Default: 24 if not set or invalid\n * - Must be positive integer\n */\nexport function getRecentPagesLookbackHours(): number {\n const envValue = Deno.env.get('RECENT_PAGES_LOOKBACK_HOURS');\n\n // If not set, return default of 24 hours\n if (envValue === undefined || envValue === null || envValue === '') {\n return 24;\n }\n\n // Parse as integer\n const parsed = parseInt(envValue, 10);\n\n // If invalid, return default\n if (isNaN(parsed) || parsed <= 0) {\n console.warn(`⚠ Invalid RECENT_PAGES_LOOKBACK_HOURS value \"${envValue}\", using default of 24 hours`);\n return 24;\n }\n\n return parsed;\n}\n",[],[209,406,441],"5c0f8d2e-cdf5-11f0-a2c0-42dde27851f2","blockUtils.ts","35489a72-b8ac-11f0-a94f-0224a6c84d84",142,["D",1764511414357],"/**\n * Block stability utilities\n *\n * Provides functions to check if blocks are \"stable\" (not recently edited)\n * Used to prevent saving blocks that are actively being edited to blob storage\n */\n\n/**\n * Get block stability threshold from environment variable\n *\n * Reads BLOCK_STABILITY_MINUTES env var to determine minimum age\n * before a block is considered stable enough to save to blob storage.\n *\n * @returns Number of minutes (0 or positive integer)\n * - Default: 0 if not set (no delay - immediate sync)\n * - Set env var to add a delay (e.g., \"2\" for 2 minutes)\n */\nexport function getBlockStabilityMinutes(): number {\n const envValue = Deno.env.get('BLOCK_STABILITY_MINUTES');\n\n // If not set, return default of 0 (no delay)\n if (envValue === undefined || envValue === null || envValue === '') {\n return 0;\n }\n\n // Parse as integer\n const parsed = parseInt(envValue, 10);\n\n // If invalid, return default\n if (isNaN(parsed) || parsed < 0) {\n console.warn(`⚠ Invalid BLOCK_STABILITY_MINUTES value \"${envValue}\", using default of 0 (no delay)`);\n return 0;\n }\n\n return parsed;\n}\n\n/**\n * Calculate the age of a block in minutes\n *\n * @param lastEditedTime - ISO 8601 timestamp string from Notion\n * @returns Number of minutes since the block was last edited\n */\nexport function getBlockAgeMinutes(lastEditedTime: string): number {\n const lastEditedDate = new Date(lastEditedTime);\n const now = Date.now();\n const ageMs = now - lastEditedDate.getTime();\n const ageMinutes = ageMs / (1000 * 60);\n\n return ageMinutes;\n}\n\n/**\n * Check if a block is \"stable\" (old enough to save)\n *\n * A block is considered stable if:\n * - stabilityMinutes is 0 (delay disabled), OR\n * - Block age >= stabilityMinutes\n *\n * @param lastEditedTime - ISO 8601 timestamp string from Notion\n * @param stabilityMinutes - Minimum age threshold in minutes\n * @returns true if block is stable, false if too recent\n */\nexport function isBlockStable(lastEditedTime: string, stabilityMinutes: number): boolean {\n // If stability check is disabled (0 minutes), always return true\n if (stabilityMinutes === 0) {\n return true;\n }\n\n // Calculate block age\n const ageMinutes = getBlockAgeMinutes(lastEditedTime);\n\n // Block is stable if age meets or exceeds threshold\n return ageMinutes >= stabilityMinutes;\n}\n\n/**\n * Valid Notion background colors\n */\nconst VALID_BACKGROUND_COLORS = new Set([\n 'gray_background',\n 'brown_background',\n 'orange_background',\n 'yellow_background',\n 'green_background',\n 'blue_background',\n 'purple_background',\n 'pink_background',\n 'red_background'\n]);\n\n/**\n * Get block background color from environment variable\n *\n * When set to a valid Notion background color, matched todo blocks\n * will have their background color changed in Notion as a visual indicator.\n *\n * @returns The background color if valid, null otherwise\n */\nexport function getBlockBackgroundColor(): string | null {\n const color = Deno.env.get('BLOCK_BACKGROUND_COLOR')?.toLowerCase();\n if (color && VALID_BACKGROUND_COLORS.has(color)) {\n return color;\n }\n return null;\n}\n",[],[209,406,448],"1582a054-b459-11f0-a09c-0224a6c84d84","blobUtils.ts","1582a0ea-b459-11f0-a09c-0224a6c84d84",["D",1761695515418],"/**\n * Blob storage utility functions\n */\n\n/**\n * Extract block ID from blob key\n * Key format: projectName--category--blockId\n *\n * @param key - Blob key string (e.g., \"demo--todo--abc-123-def-456\")\n * @returns Block ID (e.g., \"abc-123-def-456\")\n *\n * @example\n * extractBlockIdFromKey(\"demo--todo--abc-123\") // Returns \"abc-123\"\n */\nexport function extractBlockIdFromKey(key: string): string {\n const parts = key.split('--');\n return parts[parts.length - 1]; // Last part is the block ID\n}\n",[],[209,406,456],"1582acde-b459-11f0-a09c-0224a6c84d84",["D",1761695515418],[266,267,268,269,270,271,272,273],[209,406],"fa4ed9f6-b363-11f0-87a0-0224a6c84d84","faviconizerService.ts","b7748178-b361-11f0-b7fc-0224a6c84d84","019a26dc-99bf-7269-a8f6-2bcf04eec442",["D",1761590243094],"import type { FaviconizerResponse } from \"../../shared/types.ts\";\n\n/**\n * Get favicon URL for a domain using Faviconizer API\n */\nexport async function getFaviconForDomain(domain: string) {\n try {\n const response = await fetch(\"https://faviconizer.val.run/api/domain\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ domain }),\n });\n\n if (!response.ok) {\n return {\n success: false,\n data: null,\n error: `Faviconizer API returned status ${response.status}`,\n };\n }\n\n const data: FaviconizerResponse = await response.json();\n\n // Check if the API's success field is true\n if (!data.success) {\n return {\n success: false,\n data: null,\n error: \"Faviconizer API returned success: false\",\n };\n }\n\n return {\n success: true,\n data: data,\n error: null,\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || \"Failed to fetch favicon\",\n };\n }\n}\n",[],[209,474,467],"services","43d12cec-b962-11f0-8efb-0224a6c84d84","blobService.ts","15829b9a-b459-11f0-a09c-0224a6c84d84",["D",1762249214392],"import { blob } from \"https://esm.town/v/std/blob\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\n/**\n * Get the Val Town project name dynamically\n */\nfunction getProjectName(): string {\n try {\n const val = parseVal(import.meta.url);\n return val.name || 'unknown-val';\n } catch (err) {\n console.error('Failed to parse val name:', err);\n return 'unknown-val';\n }\n}\n\n/**\n * Save a block to Val Town blob storage\n *\n * @param category - Category of block (e.g., \"todo\", \"mention\", \"date\")\n * @param blockId - Notion block ID\n * @param data - Block data to save (typically ReducedNotionBlock)\n * @returns {success, key, error}\n */\nexport async function saveBlockToBlob(\n category: string,\n blockId: string,\n data: any\n) {\n try {\n // Construct blob key: projectName--category--blockId\n const projectName = getProjectName();\n const key = `${projectName}--${category}--${blockId}`;\n\n // Save to blob storage (overwrites if exists)\n await blob.setJSON(key, data);\n\n return {\n success: true,\n key: key,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n key: null,\n error: err.message || 'Failed to save to blob storage'\n };\n }\n}\n\n/**\n * Get a block from Val Town blob storage\n * (Future implementation)\n */\nexport async function getBlockFromBlob(\n category: string,\n blockId: string\n) {\n try {\n const projectName = getProjectName();\n const key = `${projectName}--${category}--${blockId}`;\n\n const data = await blob.getJSON(key);\n\n return {\n success: true,\n data: data,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to get from blob storage'\n };\n }\n}\n\n/**\n * Delete a block from Val Town blob storage\n * (Future implementation)\n */\nexport async function deleteBlockFromBlob(\n category: string,\n blockId: string\n) {\n try {\n const projectName = getProjectName();\n const key = `${projectName}--${category}--${blockId}`;\n\n await blob.delete(key);\n\n return {\n success: true,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n error: err.message || 'Failed to delete from blob storage'\n };\n }\n}\n\n/**\n * List all blocks in a category from Val Town blob storage\n *\n * @param category - Category of blocks to list (e.g., \"todo\")\n * @returns {success, keys, error}\n */\nexport async function listBlocksByCategory(category: string) {\n try {\n const projectName = getProjectName();\n const prefix = `${projectName}--${category}--`;\n\n // List all blobs with the prefix\n const result = await blob.list(prefix);\n\n // blob.list() returns an array of objects with 'key' property\n // Extract just the keys as strings\n const keys = Array.isArray(result)\n ? result.map((item: any) => typeof item === 'string' ? item : item.key)\n : [];\n\n return {\n success: true,\n keys: keys,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n keys: null,\n error: err.message || 'Failed to list blobs'\n };\n }\n}\n\n/**\n * Update sync metadata for a blob\n *\n * @param key - Full blob key (projectName--category--blockId)\n * @param syncMetadata - Sync metadata to update { synced: boolean, notion_page_id?: string }\n * @returns {success, error}\n */\nexport async function updateBlobSyncMetadata(\n key: string,\n syncMetadata: { synced: boolean; notion_page_id?: string }\n) {\n try {\n // Read existing blob\n const existingData = await blob.getJSON(key);\n\n if (!existingData) {\n return {\n success: false,\n error: 'Blob not found'\n };\n }\n\n // Update only sync_metadata property\n const updatedData = {\n ...existingData,\n sync_metadata: syncMetadata\n };\n\n // Save back to blob\n await blob.setJSON(key, updatedData);\n\n return {\n success: true,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n error: err.message || 'Failed to update blob sync metadata'\n };\n }\n}\n\n/**\n * Count blobs in a category\n *\n * @param category - Category of blocks to count (e.g., \"todo\")\n * @returns {success, count, prefix, error}\n */\nexport async function countBlobsByCategory(category: string) {\n try {\n const result = await listBlocksByCategory(category);\n\n if (!result.success) {\n return {\n success: false,\n count: 0,\n prefix: null,\n error: result.error\n };\n }\n\n const projectName = getProjectName();\n const prefix = `${projectName}--${category}--`;\n\n return {\n success: true,\n count: result.keys?.length || 0,\n prefix: prefix,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n count: 0,\n prefix: null,\n error: err.message || 'Failed to count blobs'\n };\n }\n}\n",[],[209,474,476],"88ff3bea-ccb5-11f0-a51f-42dde27851f2","aiService.ts","6f6e36ea-cc7e-11f0-a038-42dde27851f2",128,["D",1764374050789],11,"/**\n * AI service for fuzzy matching using OpenAI\n */\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport type { ProjectWithDates } from '../utils/projectUtils.ts';\n\n/**\n * Use AI to match a todo to a project based on semantic similarity\n *\n * Returns one of:\n * - A project ID (if confident match to specific project)\n * - \"CLIENT:ClientName\" (if matches client but not specific project)\n * - null (no match)\n *\n * @param todoText - The todo text to match\n * @param projects - Array of projects with id, name, and optional clientName\n * @returns Project ID, \"CLIENT:name\", or null\n */\nexport async function matchTodoToProject(\n todoText: string,\n projects: Array<{ id: string; name: string; clientName: string | null }>\n): Promise<string | null> {\n if (!todoText || projects.length === 0) {\n return null;\n }\n\n const openai = new OpenAI();\n\n const projectList = projects\n .map(p => `- ID: ${p.id} | Project: \"${p.name}\"${p.clientName ? ` | Client: \"${p.clientName}\"` : ''}`)\n .join('\\n');\n\n try {\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n max_tokens: 100,\n messages: [\n {\n role: \"system\",\n content: `You match todos to projects. Given a todo and a list of projects (with optional client names):\n- If the todo clearly references a specific PROJECT by name, return that project ID\n- If the todo references a CLIENT NAME but not a specific project, return \"CLIENT:ClientName\" (exact client name from the list)\n- If no match, return \"NONE\"\nBe conservative - only match if confident.`\n },\n {\n role: \"user\",\n content: `Todo: \"${todoText}\"\\n\\nProjects:\\n${projectList}\\n\\nReturn the project ID, CLIENT:name, or NONE:`\n }\n ]\n });\n\n let response = completion.choices[0]?.message?.content?.trim();\n\n if (!response || response === \"NONE\" || response.toUpperCase() === \"NONE\") {\n return null;\n }\n\n // Strip common prefixes the AI might add\n if (response.startsWith('ID: ')) {\n response = response.substring(4);\n }\n\n // Check if it's a client match\n if (response.startsWith('CLIENT:')) {\n const clientName = response.substring(7);\n // Validate that this client exists in our projects (case-insensitive)\n const matchingClient = projects.find(p =>\n p.clientName && p.clientName.toLowerCase() === clientName.toLowerCase()\n );\n if (matchingClient) {\n // Return with the exact client name from the database\n return `CLIENT:${matchingClient.clientName}`;\n }\n return null;\n }\n\n // Validate response is a known project ID\n const matchedProject = projects.find(p => p.id === response);\n return matchedProject ? response : null;\n\n } catch (err: any) {\n console.error('AI matching error:', err.message);\n return null;\n }\n}\n\n/**\n * Use AI to pick the best project from candidates with overlapping date ranges\n *\n * Called when multiple projects' date ranges contain the todo's due date.\n * AI decides based on semantic similarity between todo text and project names.\n *\n * @param todoText - The todo text to match\n * @param candidates - Array of projects with overlapping date ranges\n * @returns Best matching project ID, or first candidate as fallback\n */\nexport async function disambiguateOverlappingProjects(\n todoText: string,\n candidates: ProjectWithDates[]\n): Promise<string> {\n if (candidates.length === 0) {\n throw new Error('No candidates provided for disambiguation');\n }\n\n if (candidates.length === 1) {\n return candidates[0].id;\n }\n\n const openai = new OpenAI();\n\n const projectList = candidates\n .map(p => `- ID: ${p.id} | Project: \"${p.name || 'Untitled'}\"`)\n .join('\\n');\n\n try {\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n max_tokens: 100,\n messages: [\n {\n role: \"system\",\n content: `Given a todo and candidate projects with overlapping date ranges, pick the best semantic match based on the todo text and project names. Return ONLY the project ID, nothing else.`\n },\n {\n role: \"user\",\n content: `Todo: \"${todoText}\"\\n\\nProjects:\\n${projectList}\\n\\nReturn the best matching project ID:`\n }\n ]\n });\n\n let response = completion.choices[0]?.message?.content?.trim();\n\n // Strip common prefixes\n if (response?.startsWith('ID: ')) {\n response = response.substring(4);\n }\n\n // Validate response is a known candidate ID\n const matchedCandidate = candidates.find(p => p.id === response);\n if (matchedCandidate) {\n return matchedCandidate.id;\n }\n\n // Fallback to first candidate if AI response is invalid\n return candidates[0].id;\n\n } catch (err: any) {\n console.error('AI disambiguation error:', err.message);\n // Fallback to first candidate on error\n return candidates[0].id;\n }\n}\n",[],[209,474,483],"fd178ad2-b4f0-11f0-8e48-0224a6c84d84","search.ts","fd178b4a-b4f0-11f0-8e48-0224a6c84d84","019a26dc-99bf-7269-a8f6-24515668c88f",17,["D",1761760757953],"/**\n * Notion search operations\n */\n\nimport { notion } from \"./index.ts\";\n\n/**\n * Normalize Notion ID by removing hyphens for comparison\n */\nfunction normalizeNotionId(id: string): string {\n return id.replace(/-/g, '');\n}\n\n/**\n * Search for pages edited within the last X hours\n * Filters out:\n * - Archived items\n * - Database objects\n * - Pages inside TODOS_DB_ID database\n *\n * @param hoursAgo - Number of hours to look back (default: 24)\n * @returns {success, data, error} with array of simplified page objects\n */\nexport async function searchRecentPages(hoursAgo: number = 24) {\n try {\n // Get TODOS_DB_ID to filter out those pages\n const todosDbId = Deno.env.get('TODOS_DB_ID');\n\n // Calculate cutoff timestamp\n const cutoffTime = new Date();\n cutoffTime.setHours(cutoffTime.getHours() - hoursAgo);\n\n const results: any[] = [];\n let hasMore = true;\n let startCursor: string | undefined = undefined;\n\n // Paginate through all results\n while (hasMore) {\n const response = await notion.search({\n sort: {\n direction: 'descending',\n timestamp: 'last_edited_time'\n },\n page_size: 100,\n start_cursor: startCursor\n });\n\n // Add results to array\n results.push(...response.results);\n\n // Check if we've reached the cutoff time\n // Since results are sorted by last_edited_time descending,\n // once we hit a page older than cutoff, we can stop\n const lastResult = response.results[response.results.length - 1];\n if (lastResult) {\n const lastEditedTime = new Date(lastResult.last_edited_time);\n if (lastEditedTime < cutoffTime) {\n // We've gone past the cutoff, stop paginating\n hasMore = false;\n break;\n }\n }\n\n hasMore = response.has_more;\n startCursor = response.next_cursor ?? undefined;\n }\n\n // Filter results:\n // 1. Within time range\n // 2. Not archived\n // 3. Only pages (not databases)\n // 4. Not in TODOS_DB_ID database\n const filteredResults = results.filter((item: any) => {\n const lastEditedTime = new Date(item.last_edited_time);\n const isWithinTimeRange = lastEditedTime >= cutoffTime;\n const isNotArchived = !item.archived;\n const isPage = item.object === 'page';\n\n // Filter out pages in the todos database (normalize IDs for comparison)\n const isInTodosDb = todosDbId\n && item.parent?.type === 'database_id'\n && normalizeNotionId(item.parent?.database_id || '') === normalizeNotionId(todosDbId);\n const isNotInTodosDb = !isInTodosDb;\n\n return isWithinTimeRange && isNotArchived && isPage && isNotInTodosDb;\n });\n\n // Simplify the results - extract only needed fields\n const simplifiedResults = filteredResults.map((item: any) => {\n const simplified: any = {\n id: item.id,\n object: item.object, // 'page' or 'database'\n last_edited_time: item.last_edited_time,\n url: item.url\n };\n\n // Extract title from page properties\n const titleProp = Object.values(item.properties || {}).find(\n (prop: any) => prop.type === 'title'\n ) as any;\n\n if (titleProp?.title?.[0]?.plain_text) {\n simplified.title = titleProp.title[0].plain_text;\n } else {\n simplified.title = 'Untitled';\n }\n\n // Extract parent information\n if (item.parent) {\n simplified.parent = {\n type: item.parent.type\n };\n\n // Add the appropriate ID based on parent type\n if (item.parent.type === 'page_id' && item.parent.page_id) {\n simplified.parent.id = item.parent.page_id;\n } else if (item.parent.type === 'database_id' && item.parent.database_id) {\n simplified.parent.id = item.parent.database_id;\n } else if (item.parent.type === 'workspace' && item.parent.workspace) {\n // Workspace parent doesn't have an ID, it's a boolean\n simplified.parent.id = null;\n }\n }\n\n return simplified;\n });\n\n return {\n success: true,\n data: simplifiedResults,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message\n };\n }\n}\n",[],[209,474,500,492],"notion","14e7296a-ce3c-11f0-b18d-42dde27851f2","pages.ts","019a26dc-99bf-7269-a8f6-23db6afe7f06",146,["D",1764541789245],9,"import { notion } from \"./index.ts\";\n\n/**\n * Block types that can contain nested to_do blocks\n * Used to optimize recursive fetching in block type mode\n */\nexport const TODO_CONTAINER_TYPES = new Set([\n 'to_do', // to_do blocks can nest inside other to_do blocks\n 'toggle', // common pattern for organizing todos\n 'column_list', // layout container\n 'column', // layout container\n 'synced_block', // can contain any block type\n 'callout', // can contain nested content\n 'quote', // can contain nested blocks\n 'bulleted_list_item', // can have nested content\n 'numbered_list_item', // can have nested content\n 'template' // can contain any block type\n]);\n\n/**\n * Get a Notion page by ID\n */\nexport async function getNotionPage(pageId: string) {\n try {\n const page = await notion.pages.retrieve({ page_id: pageId });\n\n return {\n success: true,\n data: page,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to fetch Notion page'\n };\n }\n}\n\n/**\n * Update a Notion page's properties\n */\nexport async function updateNotionPage(\n pageId: string,\n properties: any,\n icon?: { type: string; emoji?: string; external?: { url: string } }\n) {\n try {\n const updateData: any = {\n page_id: pageId,\n properties: properties\n };\n\n // Add icon if provided\n if (icon) {\n updateData.icon = icon;\n }\n\n const page = await notion.pages.update(updateData);\n\n return {\n success: true,\n data: page,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to update Notion page'\n };\n }\n}\n\n/**\n * Create a new page in a database\n */\nexport async function createNotionPage(\n databaseId: string,\n properties: any,\n icon?: { type: string; emoji?: string; external?: { url: string } }\n) {\n try {\n const pageData: any = {\n parent: { database_id: databaseId },\n properties: properties\n };\n\n // Add icon if provided\n if (icon) {\n pageData.icon = icon;\n }\n\n const page = await notion.pages.create(pageData);\n\n return {\n success: true,\n data: page,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to create Notion page'\n };\n }\n}\n\n/**\n * Get page blocks (content)\n */\nexport async function getPageBlocks(pageId: string) {\n try {\n const response = await notion.blocks.children.list({ block_id: pageId });\n\n return {\n success: true,\n data: response.results,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to fetch page blocks'\n };\n }\n}\n\n/**\n * Update a Notion page's icon with an external URL\n */\nexport async function updatePageIcon(pageId: string, iconUrl: string) {\n try {\n const page = await notion.pages.update({\n page_id: pageId,\n icon: {\n type: \"external\",\n external: {\n url: iconUrl\n }\n }\n });\n\n return {\n success: true,\n data: page,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to update page icon'\n };\n }\n}\n\n/**\n * Append a paragraph block to a page (for error notes)\n */\nexport async function appendBlockToPage(pageId: string, message: string) {\n try {\n const response = await notion.blocks.children.append({\n block_id: pageId,\n children: [\n {\n object: \"block\",\n type: \"paragraph\",\n paragraph: {\n rich_text: [\n {\n type: \"text\",\n text: {\n content: message\n }\n }\n ]\n }\n }\n ]\n });\n\n return {\n success: true,\n data: response,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to append block to page'\n };\n }\n}\n\n/**\n * Append a callout block to a page indicating the source has additional details\n *\n * @param pageId - The page to append to\n * @param blockUrl - URL to the source block\n */\nexport async function appendHasChildrenCallout(pageId: string, blockUrl: string) {\n try {\n const response = await notion.blocks.children.append({\n block_id: pageId,\n children: [\n {\n object: \"block\",\n type: \"callout\",\n callout: {\n rich_text: [\n {\n type: \"text\",\n text: { content: \"This todo has additional details. \" }\n },\n {\n type: \"text\",\n text: {\n content: \"View details →\",\n link: { url: blockUrl }\n }\n }\n ],\n icon: {\n type: \"external\",\n external: { url: \"https://www.notion.so/icons/info-alternate_blue.svg\" }\n },\n color: \"blue_background\"\n }\n } as any\n ]\n });\n\n return {\n success: true,\n data: response,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to append callout to page'\n };\n }\n}\n\n/**\n * Recursively get all blocks from a page, including nested children\n *\n * @param blockId - Starting block/page ID\n * @param containerFilter - Optional set of block types to recurse into. If provided, only\n * recurses into blocks whose type is in this set. If null/undefined,\n * recurses into all blocks with children.\n */\nexport async function getPageBlocksRecursive(\n blockId: string,\n containerFilter?: Set<string>\n): Promise<any[]> {\n const allBlocks: any[] = [];\n\n try {\n const response = await notion.blocks.children.list({ block_id: blockId });\n\n for (const block of response.results) {\n // Add the current block\n allBlocks.push(block);\n\n // If block has children, check if we should recurse\n if ((block as any).has_children) {\n const blockType = (block as any).type;\n\n // Recurse if no filter, or if block type is in the filter set\n if (!containerFilter || containerFilter.has(blockType)) {\n const children = await getPageBlocksRecursive(block.id, containerFilter);\n allBlocks.push(...children);\n }\n }\n }\n\n return allBlocks;\n } catch (err: any) {\n // Silently skip validation errors for unsupported block types (transcription, audio, etc.)\n // These are expected - Notion API doesn't support all block types\n if (err.code !== 'validation_error') {\n console.error(`Notion API Error for block ${blockId}: [${err.code}] ${err.message}`);\n }\n return allBlocks; // Return what we have so far\n }\n}\n\n/**\n * Get page title from a Notion page\n *\n * Extracts the title from page properties (looks for property with type \"title\")\n * Returns plain text version of the title\n *\n * @param pageId - Notion page ID\n * @returns Object with success, title (or null), and error\n */\nexport async function getPageTitle(pageId: string) {\n try {\n const page = await notion.pages.retrieve({ page_id: pageId });\n\n // Find the title property (it's the property with type \"title\")\n const properties = (page as any).properties;\n\n if (!properties) {\n return {\n success: false,\n title: null,\n error: 'Page has no properties'\n };\n }\n\n // Find the title property\n let titleProperty = null;\n for (const [key, value] of Object.entries(properties)) {\n if ((value as any).type === 'title') {\n titleProperty = value;\n break;\n }\n }\n\n if (!titleProperty) {\n return {\n success: false,\n title: null,\n error: 'Page has no title property'\n };\n }\n\n // Extract plain text from title rich_text array\n const titleRichText = (titleProperty as any).title;\n if (!Array.isArray(titleRichText) || titleRichText.length === 0) {\n return {\n success: true,\n title: 'Untitled', // Notion pages can legitimately have empty titles\n error: null\n };\n }\n\n const title = titleRichText\n .map((rt: any) => rt.plain_text || '')\n .join('');\n\n return {\n success: true,\n title: title || 'Untitled',\n error: null\n };\n\n } catch (err: any) {\n return {\n success: false,\n title: null,\n error: err.message || 'Failed to fetch page title'\n };\n }\n}\n",[],[209,474,500,502],"061267aa-cc80-11f0-8b91-42dde27851f2","index.ts","019a26dc-99bf-7269-a8f6-1efef3029063",50,["D",1764351067812],"import { Client } from \"npm:@notionhq/client@2\";\n\n// Initialize Notion client - shared across all Notion service modules\nexport const notion = new Client({ auth: Deno.env.get(\"NOTION_API_KEY\") });\n\n// Export all page operations\nexport * from \"./pages.ts\";\n\n// Export all database operations\nexport * from \"./databases.ts\";\n\n// Export all search operations\nexport * from \"./search.ts\";\n\n// Export all block operations\nexport * from \"./blocks.ts\";\n",[],[209,474,500,511],"4ac78b58-cca5-11f0-b767-42dde27851f2","databases.ts","019a26dc-99bf-7269-a8f6-1887e096fe60",109,["D",1764367074467],12,"import { notion } from \"./index.ts\";\n\n/**\n * Query a Notion database\n */\nexport async function queryNotionDatabase(databaseId: string, filter?: any, sorts?: any) {\n try {\n const response = await notion.databases.query({\n database_id: databaseId,\n filter: filter,\n sorts: sorts\n });\n\n return {\n success: true,\n data: response.results,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to query Notion database'\n };\n }\n}\n\n/**\n * Get a database by ID\n */\nexport async function getNotionDatabase(databaseId: string) {\n try {\n const database = await notion.databases.retrieve({ database_id: databaseId });\n\n return {\n success: true,\n data: database,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to fetch Notion database'\n };\n }\n}\n\n/**\n * Get all page IDs from a database\n * Used to cache project IDs for matching against link_mentions\n *\n * @param databaseId - Notion database ID\n * @returns Object with success, pageIds array (normalized, no hyphens), and error\n */\nexport async function getProjectPageIds(databaseId: string): Promise<{\n success: boolean;\n pageIds: string[];\n error: string | null;\n}> {\n try {\n const pageIds: string[] = [];\n let hasMore = true;\n let startCursor: string | undefined = undefined;\n\n while (hasMore) {\n const response = await notion.databases.query({\n database_id: databaseId,\n page_size: 100,\n start_cursor: startCursor\n });\n\n // Extract and normalize page IDs (remove hyphens for consistent comparison)\n for (const page of response.results) {\n const normalizedId = page.id.replace(/-/g, '');\n pageIds.push(normalizedId);\n }\n\n hasMore = response.has_more;\n startCursor = response.next_cursor ?? undefined;\n }\n\n return {\n success: true,\n pageIds,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n pageIds: [],\n error: err.message || 'Failed to fetch project page IDs'\n };\n }\n}\n\n/**\n * Get projects with their names, client names, and date ranges\n * Used for AI fuzzy matching and date-based disambiguation\n *\n * @param databaseId - Projects database ID\n * @returns Object with success, projects array, and error\n */\nexport async function getProjectsWithDetails(databaseId: string): Promise<{\n success: boolean;\n projects: Array<{\n id: string;\n name: string;\n clientName: string | null;\n dateStart: string | null;\n dateEnd: string | null;\n lastEditedTime: string;\n }>;\n error: string | null;\n}> {\n try {\n const projects: Array<{\n id: string;\n name: string;\n clientName: string | null;\n dateStart: string | null;\n dateEnd: string | null;\n lastEditedTime: string;\n }> = [];\n\n // Cache client names to avoid redundant API calls\n const clientCache: Map<string, string | null> = new Map();\n\n let hasMore = true;\n let startCursor: string | undefined = undefined;\n\n while (hasMore) {\n const response = await notion.databases.query({\n database_id: databaseId,\n page_size: 100,\n start_cursor: startCursor\n });\n\n for (const page of response.results) {\n const pageAny = page as any;\n const properties = pageAny.properties || {};\n\n // Extract project name from title property\n let projectName = 'Untitled';\n for (const [key, value] of Object.entries(properties)) {\n if ((value as any).type === 'title') {\n const titleArray = (value as any).title || [];\n projectName = titleArray.map((t: any) => t.plain_text || '').join('') || 'Untitled';\n break;\n }\n }\n\n // Extract client name from Clients relation (with caching)\n let clientName: string | null = null;\n const clientsRelation = properties['Clients'];\n\n if (clientsRelation?.type === 'relation' && clientsRelation.relation?.length > 0) {\n const clientPageId = clientsRelation.relation[0].id;\n\n // Check cache first\n if (clientCache.has(clientPageId)) {\n clientName = clientCache.get(clientPageId) || null;\n } else {\n // Fetch the client page to get its title\n try {\n const clientPage = await notion.pages.retrieve({ page_id: clientPageId });\n const clientProps = (clientPage as any).properties || {};\n\n for (const [key, value] of Object.entries(clientProps)) {\n if ((value as any).type === 'title') {\n const titleArray = (value as any).title || [];\n clientName = titleArray.map((t: any) => t.plain_text || '').join('') || null;\n break;\n }\n }\n\n // Cache the result\n clientCache.set(clientPageId, clientName);\n } catch (err) {\n // Cache the failure too to avoid retrying\n clientCache.set(clientPageId, null);\n }\n }\n }\n\n // Extract date range from Dates property\n const datesProperty = properties['Dates'];\n let dateStart: string | null = null;\n let dateEnd: string | null = null;\n\n if (datesProperty?.type === 'date' && datesProperty.date) {\n dateStart = datesProperty.date.start || null;\n dateEnd = datesProperty.date.end || null;\n }\n\n projects.push({\n id: page.id.replace(/-/g, ''), // Normalize ID\n name: projectName,\n clientName,\n dateStart,\n dateEnd,\n lastEditedTime: pageAny.last_edited_time\n });\n }\n\n hasMore = response.has_more;\n startCursor = response.next_cursor ?? undefined;\n }\n\n return {\n success: true,\n projects,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n projects: [],\n error: err.message || 'Failed to fetch projects with details'\n };\n }\n}\n\n/**\n * Query database for a page with specific Block ID\n */\nexport async function queryDatabaseByBlockId(databaseId: string, blockId: string) {\n try {\n const filter = {\n property: \"Block ID\",\n rich_text: {\n equals: blockId\n }\n };\n\n const response = await notion.databases.query({\n database_id: databaseId,\n filter: filter\n });\n\n // Return first matching page or null\n const page = response.results.length > 0 ? response.results[0] : null;\n\n return {\n success: true,\n data: page,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to query database by Block ID'\n };\n }\n}\n",[],[209,474,500,519],"6072067c-cdf4-11f0-8ccd-42dde27851f2","blocks.ts","fef229ce-cc7f-11f0-a637-42dde27851f2",139,["D",1764510992220],"import { notion } from \"./index.ts\";\n\n/**\n * Get a single block by ID\n *\n * Used for parent block traversal in project matching\n */\nexport async function getBlock(blockId: string) {\n try {\n const block = await notion.blocks.retrieve({ block_id: blockId });\n\n return {\n success: true,\n data: block,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to fetch block'\n };\n }\n}\n\n/**\n * Update a block's background color\n *\n * Valid colors: gray_background, brown_background, orange_background,\n * yellow_background, green_background, blue_background, purple_background,\n * pink_background, red_background, default (no background)\n *\n * @param blockId - The block ID to update\n * @param color - The background color to set\n */\nexport async function updateBlockColor(blockId: string, color: string) {\n try {\n // First retrieve the block to get its type\n const block = await notion.blocks.retrieve({ block_id: blockId });\n const blockType = (block as any).type;\n\n // Update the block with the new color\n await notion.blocks.update({\n block_id: blockId,\n [blockType]: {\n color: color\n }\n });\n\n return { success: true, error: null };\n } catch (err: any) {\n return { success: false, error: err.message || 'Failed to update block color' };\n }\n}\n",[],[209,474,500,528],"1cb962ee-b360-11f0-bc6f-0224a6c84d84",["D",1761588582800],[257,258,259,260,261],[209,474,500],"1cb96406-b360-11f0-bc6f-0224a6c84d84",["D",1761588582800],[256,262,263,264],[209,474],"ebd4a5ce-d51c-11f0-8fa4-42dde27851f2","authCheck.ts","019a26dc-99bf-7269-a8f6-1140d0020917","019a26dc-99bf-7269-a8f6-14fb6878e1e4",151,["D",1765298064073],"import { Context, Next } from \"npm:hono@4\";\n\n/**\n * Authentication middleware for Hono routes\n *\n * This middleware checks for authentication credentials in requests.\n * Customize this based on your authentication strategy:\n * - API key in header\n * - Bearer token\n * - Notion webhook signature verification\n * - etc.\n */\nexport async function authCheck(c: Context, next: Next) {\n // Example: Check for API key in header\n const apiKey = c.req.header('x-api-key');\n const expectedKey = Deno.env.get('API_KEY');\n\n // If no API_KEY is configured, skip auth (development mode)\n if (!expectedKey) {\n console.warn('Warning: API_KEY not configured, skipping authentication');\n await next();\n return;\n }\n\n // Validate API key\n if (!apiKey || apiKey !== expectedKey) {\n return c.json({ error: 'Unauthorized', details: 'Invalid or missing API key' }, 401);\n }\n\n // Authentication successful, proceed\n await next();\n}\n\n/**\n * Webhook authentication middleware\n *\n * Protects /tasks/* and /api/* endpoints using X-API-KEY header\n * Header value must match WEBHOOK_SECRET env var\n *\n * Usage in Notion webhooks:\n * Add custom header: X-API-KEY: <your-secret>\n *\n * Usage in API requests:\n * curl -H \"X-API-KEY: <your-secret>\" https://your-val.val.town/api/pages/recent\n */\nexport async function webhookAuth(c: Context, next: Next) {\n const apiKey = c.req.header('x-api-key');\n const webhookSecret = Deno.env.get('WEBHOOK_SECRET');\n\n // If no webhook secret is configured, skip authentication (development mode)\n if (!webhookSecret) {\n console.warn('⚠ WEBHOOK_SECRET not configured, skipping authentication');\n await next();\n return;\n }\n\n // Validate API key\n if (!apiKey || apiKey !== webhookSecret) {\n return c.json({\n error: 'Unauthorized',\n details: 'Invalid or missing X-API-KEY header'\n }, 401);\n }\n\n // Authentication successful\n await next();\n}\n",[],[209,552,544],"routes","1cb956be-b360-11f0-bc6f-0224a6c84d84","views","019a26dc-99bf-7269-a8f6-0e71a3295bf6",["D",1761588582800],[],[209,552,554],"eee93626-d51c-11f0-83d7-42dde27851f2","todos.ts","fd1783e8-b4f0-11f0-8e48-0224a6c84d84","019a26dc-99bf-7269-a8f6-0b691fa0aef1",152,["D",1765298069212],"import { Hono } from \"npm:hono@4\";\nimport * as todoOrchestrationController from '../../controllers/todoOrchestrationController.ts';\n\nconst todos = new Hono();\n\n/**\n * POST /tasks/todos\n * Batch process keyword search across recent pages:\n * 1. Get recent pages (filtered by hours parameter)\n * 2. Search each page for keywords and save to blobs\n * 3. Sync all todo blobs to Notion database\n *\n * Keywords are read from SEARCH_KEYWORDS environment variable (comma-separated)\n * Defaults to \"todo\" if not set\n *\n * Note: This endpoint returns immediately (202 Accepted) and processes in background.\n * This prevents timeout errors when called from Notion webhooks or manual triggers.\n * Check console logs for detailed progress and results.\n *\n * Query parameters:\n * - hours (optional): Number of hours to look back (default: 24)\n *\n * Examples:\n * - POST /tasks/todos (defaults: 24 hours)\n * - POST /tasks/todos?hours=48\n *\n * Response (immediate):\n * {\n * accepted: true,\n * message: \"Processing started in background\",\n * parameters: { hours: 24 }\n * }\n */\ntodos.post('/', async (c) => {\n try {\n // Extract hours parameter from query string\n const hoursParam = c.req.query('hours');\n let hours: number | undefined = undefined;\n\n if (hoursParam) {\n hours = parseInt(hoursParam, 10);\n\n // Validate that it's a valid number\n if (isNaN(hours) || hours <= 0) {\n return c.json({\n success: false,\n error: \"Invalid hours parameter\",\n details: \"hours must be a positive number\"\n }, 400);\n }\n }\n\n // Get request origin for building internal URL\n const origin = new URL(c.req.url).origin;\n\n // Get webhook secret for internal authentication\n const webhookSecret = Deno.env.get('WEBHOOK_SECRET');\n\n // Trigger internal processing endpoint (don't await)\n fetch(`${origin}/tasks/todos/internal`, {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n 'X-API-KEY': webhookSecret || ''\n },\n body: JSON.stringify({ hours })\n }).catch((err) => {\n // Log fetch errors (not processing errors)\n console.error('Error triggering internal processing:', err);\n });\n\n // Return immediately with 202 Accepted\n return c.json({\n accepted: true,\n message: \"Processing started in background. Check console logs for progress and results.\",\n parameters: {\n hours: hours ?? 24\n }\n }, 202);\n\n } catch (err: any) {\n // Return error for validation failures\n console.error('Error starting batch keyword search processing:', err);\n return c.json({\n success: false,\n error: \"Failed to start processing\",\n details: err.message\n }, 500);\n }\n});\n\n/**\n * POST /tasks/todos/internal\n * Internal endpoint for actual batch processing.\n * Called by /tasks/todos to perform work in background.\n *\n * This endpoint is not intended for external use.\n *\n * Keywords are read from SEARCH_KEYWORDS environment variable (comma-separated)\n * Defaults to \"todo\" if not set\n *\n * Body:\n * {\n * hours?: number\n * }\n */\ntodos.post('/internal', async (c) => {\n try {\n // Extract parameters from body\n const body = await c.req.json();\n const hours = body.hours;\n\n console.log('Internal processing endpoint triggered');\n console.log(`Parameters: hours=${hours ?? 24}`);\n console.log('Keywords from SEARCH_KEYWORDS env var (or default \"todo\")');\n\n // Process batch keyword search (await to ensure completion)\n const result = await todoOrchestrationController.processBatchTodos(hours);\n\n console.log('Internal processing completed successfully');\n console.log(`Result summary: ${result.pagesSearched} pages searched, ${result.totalTodosFound} matches found`);\n\n // Return result (for logging purposes, no one is listening)\n return c.json(result, 200);\n\n } catch (err: any) {\n // Log errors comprehensively\n console.error('ERROR in internal processing:', err);\n console.error('Stack trace:', err.stack);\n\n // Return 200 even on errors (no one is listening anyway)\n return c.json({\n success: false,\n error: err.message,\n details: err.stack\n }, 200);\n }\n});\n\nexport default todos;\n",[],[209,552,568,560],"tasks","a889532e-d51b-11f0-af3a-42dde27851f2","todoSearch.ts","fd178870-b4f0-11f0-8e48-0224a6c84d84",149,["D",1765297521678],"import { Hono } from \"npm:hono@4\";\nimport * as todoController from '../../controllers/todoController.ts';\nimport * as todoSaveController from '../../controllers/todoSaveController.ts';\n\nconst todo = new Hono();\n\n// POST /tasks/todo - Handle Notion webhook for single-page todo search and sync\n// Keywords are read from SEARCH_KEYWORDS environment variable (comma-separated)\n// Defaults to \"todo\" if not set\n//\n// Searches only the page specified in the webhook payload, then syncs to database\n// so users see todos appear immediately when they click the button in Notion.\ntodo.post('/', async (c) => {\n try {\n // Extract payload from request body\n const payload = await c.req.json();\n\n // Extract page_id from webhook payload - try multiple possible locations\n const pageId = payload?.page_id || // Direct property\n payload?.data?.id || // Notion webhook event format\n payload?.page?.id; // Alternative format\n\n if (!pageId) {\n console.error('Failed to extract page_id from payload:', JSON.stringify(payload));\n return c.json({\n error: \"Missing page_id in webhook payload\",\n receivedPayload: payload\n }, 400);\n }\n\n // Search page for todos (applyStabilityDelay: false for webhook)\n const searchResult = await todoController.processTodoSearch(pageId, false);\n\n // Sync blobs to database so user sees results immediately\n const saveResult = await todoSaveController.processTodoSave();\n\n // Always return 200 OK to Notion webhook\n return c.json({\n success: searchResult.success,\n blocksFound: searchResult.blocksFound,\n blockIds: searchResult.blockIds,\n saveResult: {\n pagesCreated: saveResult.pagesCreated,\n pagesUpdated: saveResult.pagesUpdated,\n pagesSkipped: saveResult.pagesSkipped,\n pagesFailed: saveResult.pagesFailed\n },\n message: searchResult.success\n ? `Found ${searchResult.blocksFound} block(s), synced to database`\n : `Search failed: ${searchResult.error}`\n }, 200);\n\n } catch (err: any) {\n // Even on unexpected errors, return 200 to prevent webhook retries\n console.error('Unexpected error in todo webhook:', err);\n return c.json({\n success: false,\n error: \"Internal server error\",\n details: err.message\n }, 200);\n }\n});\n\nexport default todo;\n",[],[209,552,568,570],"15829730-b459-11f0-a09c-0224a6c84d84","todoSave.ts","158297c6-b459-11f0-a09c-0224a6c84d84",["D",1761695515418],"import { Hono } from \"npm:hono@4\";\nimport * as todoSaveController from '../../controllers/todoSaveController.ts';\n\nconst todoSave = new Hono();\n\n// POST /tasks/todo-save - Save todos from blob storage to Notion database\ntodoSave.post('/', async (c) => {\n try {\n // Process all todo blobs and save to Notion\n // Note: This processes ALL blobs, not just one page\n const result = await todoSaveController.processTodoSave();\n\n // Always return 200 OK to webhook\n return c.json({\n success: result.success,\n totalBlobs: result.totalBlobs,\n pagesCreated: result.pagesCreated,\n pagesUpdated: result.pagesUpdated,\n pagesSkipped: result.pagesSkipped,\n pagesFailed: result.pagesFailed,\n failures: result.failures,\n message: result.success\n ? `Processed ${result.totalBlobs} blobs: ${result.pagesCreated} created, ${result.pagesUpdated} updated, ${result.pagesSkipped} skipped, ${result.pagesFailed} failed`\n : `Todo save failed: ${result.error}`\n }, 200);\n\n } catch (err: any) {\n // Even on unexpected errors, return 200 to prevent webhook retries\n console.error('Unexpected error in todo-save webhook:', err);\n return c.json({\n success: false,\n error: \"Internal server error\",\n details: err.message\n }, 200);\n }\n});\n\nexport default todoSave;\n",[],[209,552,568,578],"7a2cba30-b369-11f0-a1ff-0224a6c84d84","favicon.ts","b76fa216-b361-11f0-8f90-0224a6c84d84",["D",1761592605104],"import { Hono } from \"npm:hono@4\";\nimport * as faviconController from '../../controllers/faviconController.ts';\n\nconst favicon = new Hono();\n\n// POST /tasks/favicon - Handle Notion webhook for favicon updates\nfavicon.post('/', async (c) => {\n try {\n // Extract payload from request body\n const payload = await c.req.json();\n\n // Extract page_id from webhook payload - try multiple possible locations\n const pageId = payload?.page_id || // Direct property\n payload?.data?.id || // Notion webhook event format\n payload?.page?.id; // Alternative format\n\n if (!pageId) {\n console.error('Failed to extract page_id from payload:', JSON.stringify(payload));\n return c.json({\n error: \"Missing page_id in webhook payload\",\n receivedPayload: payload\n }, 400);\n }\n\n // Process favicon update (always return 200 to webhook)\n const result = await faviconController.processFaviconUpdate(pageId);\n\n // Always return 200 OK to Notion webhook (even on errors)\n // Errors are logged as notes in the page itself\n return c.json({\n success: result.success,\n iconUpdated: result.iconUpdated,\n errorNoteAdded: result.errorNoteAdded,\n successNoteAdded: result.successNoteAdded,\n message: result.success\n ? \"Favicon updated successfully\"\n : `Favicon update failed: ${result.error}`\n }, 200);\n\n } catch (err: any) {\n // Even on unexpected errors, return 200 to prevent webhook retries\n console.error('Unexpected error in favicon webhook:', err);\n return c.json({\n success: false,\n error: \"Internal server error\",\n details: err.message\n }, 200);\n }\n});\n\nexport default favicon;\n",[],[209,552,568,585],"1cb955b0-b360-11f0-bc6f-0224a6c84d84",["D",1761588582800],[249,250,251,252],[209,552,568],"fd17b930-b4f0-11f0-8e48-0224a6c84d84","019a26dc-99bf-7269-a8f6-01b5d543f467","019a26dc-99bf-7269-a8f6-0782b134ef20",["D",1761760757953],"import { Hono } from \"npm:hono@4\";\nimport * as pageController from '../../controllers/pageController.ts';\n\nconst pages = new Hono();\n\n/**\n * GET /api/pages/recent\n * Get pages edited within the last X hours\n * Filters out:\n * - Database objects\n * - Archived pages\n * - Pages inside TODOS_DB_ID database\n *\n * Query parameters:\n * - hours (optional): Number of hours to look back (default: 24)\n *\n * Response:\n * {\n * pages: [{ id, object, title, url, last_edited_time, parent }],\n * count: number,\n * timeRange: string\n * }\n */\npages.get('/recent', async (c) => {\n // Extract hours parameter from query string\n const hoursParam = c.req.query('hours');\n let hours: number | undefined = undefined;\n\n if (hoursParam) {\n hours = parseInt(hoursParam, 10);\n\n // Validate that it's a valid number\n if (isNaN(hours)) {\n return c.json({\n error: \"Invalid hours parameter\",\n details: \"hours must be a valid number\"\n }, 400);\n }\n }\n\n // Call controller\n const result = await pageController.getRecentPages(hours);\n\n if (!result.success) {\n return c.json({\n error: result.error,\n details: result.details\n }, 500);\n }\n\n return c.json(result.data);\n});\n\n// GET /api/pages/:id - Get a Notion page\npages.get('/:id', async (c) => {\n const pageId = c.req.param('id');\n const result = await pageController.getPage(pageId);\n\n if (!result.success) {\n return c.json({ error: result.error, details: result.details }, 400);\n }\n\n return c.json(result.data);\n});\n\n// POST /api/pages/:id - Update a Notion page\npages.post('/:id', async (c) => {\n const pageId = c.req.param('id');\n const body = await c.req.json();\n\n const result = await pageController.updatePage(pageId, body.properties);\n\n if (!result.success) {\n return c.json({ error: result.error, details: result.details }, 400);\n }\n\n return c.json(result.data);\n});\n\n// GET /api/pages/:id/content - Get page blocks\npages.get('/:id/content', async (c) => {\n const pageId = c.req.param('id');\n const result = await pageController.getPageContent(pageId);\n\n if (!result.success) {\n return c.json({ error: result.error, details: result.details }, 400);\n }\n\n return c.json(result.data);\n});\n\nexport default pages;\n",[],[209,552,602,502],"api","43d12b70-b962-11f0-8efb-0224a6c84d84","019a26dc-99bf-7269-a8f5-fdd1422bebc3",["D",1762249214392],"import { Hono } from \"npm:hono@4\";\nimport pages from './pages.ts';\nimport health from './health.ts';\n\nconst api = new Hono();\n\n// Mount health check at /api/health\napi.route('/health', health);\n\n// Mount page routes at /api/pages\napi.route('/pages', pages);\n\n// Add more routes here as needed\n// Example:\n// import databases from './databases.ts';\n// api.route('/databases', databases);\n\nexport default api;\n",[],[209,552,602,511],"43d0f416-b962-11f0-8efb-0224a6c84d84","health.ts","43d0f498-b962-11f0-8efb-0224a6c84d84",["D",1762249214392],"import { Hono } from \"npm:hono@4\";\nimport * as healthController from '../../controllers/healthController.ts';\n\nconst health = new Hono();\n\n/**\n * GET /api/health\n * System health check endpoint\n *\n * Returns:\n * {\n * timestamp: ISO string,\n * lookback_hours: number,\n * notion: \"connected\" | \"error\",\n * pages: {\n * count: number,\n * results: [{ page_id, title, last_edited_time, url }]\n * },\n * todos_db: \"connected\" | \"not_configured\" | \"error\"\n * }\n *\n * Use for:\n * - Monitoring system status\n * - Debugging connection issues\n * - Validating configuration\n */\nhealth.get('/', async (c) => {\n const result = await healthController.getSystemHealth();\n\n if (!result.success) {\n return c.json({\n error: result.error || \"Health check failed\"\n }, 500);\n }\n\n return c.json(result.data);\n});\n\nexport default health;\n",[],[209,552,602,610],"1cb95484-b360-11f0-bc6f-0224a6c84d84",["D",1761588582800],[245,246,247],[209,552,602],"1cb95e2a-b360-11f0-bc6f-0224a6c84d84",["D",1761588582800],[244,248,253,254],[209,552],"1abde6f4-d5bb-11f0-a75f-42dde27851f2","019a311f-c8bf-720b-97f6-3e820327a344",["D",1765366003262],[],[209,629,33],"crons","064f4e1a-d5bb-11f0-8d74-42dde27851f2","todoSearch.cron.ts","fd177934-b4f0-11f0-8e48-0224a6c84d84",169,["D",1765365968982],5,"import * as todoOrchestrationController from '../controllers/todoOrchestrationController.ts';\n\n/**\n * Cron: Search for todos in recent pages and save to blob storage\n *\n * Lookback window: 15 minutes (cron runs frequently)\n * Schedule: Set in Val Town UI (runs every minute)\n */\nexport default async function() {\n try {\n const result = await todoOrchestrationController.processBatchSearch(0.25);\n\n if (!result.success) {\n console.error(`[Search] ERROR: ${result.error}${result.details ? ` - ${result.details}` : ''}`);\n return;\n }\n\n // Single summary line\n const summary = `[Search] ${result.totalNew || 0} new, ${result.totalUpdated || 0} updated, ${result.totalSkipped || 0} skipped (${result.pagesSearched} pages)`;\n\n // Only log page details when there's actual work\n const pagesWithChanges = result.searchResults.filter(r => r.blocksFound > 0);\n if (pagesWithChanges.length > 0) {\n console.log(summary);\n pagesWithChanges.forEach(page => {\n console.log(` ${page.pageTitle}: ${page.blocksNew || 0} new, ${page.blocksUpdated || 0} updated`);\n });\n } else {\n console.log(summary);\n }\n } catch (err: any) {\n console.error(`[Search] ERROR: ${err.message}`);\n }\n}\n",[],[209,629,631],"fd1792f2-b4f0-11f0-8e48-0224a6c84d84",["D",1761760757953],[241,242],[209,629],"342177ce-d51f-11f0-80f8-42dde27851f2","todoSaveController.ts","158284c0-b459-11f0-a09c-0224a6c84d84","019a26dc-99bf-7269-a8f5-f9aacbe46421",157,["D",1765299044362],39,"import * as notionService from '../services/notion/index.ts';\nimport * as blobService from '../services/blobService.ts';\nimport * as aiService from '../services/aiService.ts';\nimport type { TodoSaveResult, ReducedNotionBlock } from '../../shared/types.ts';\nimport { extractFirstEmoji } from '../utils/emojiUtils.ts';\nimport { mapReducedBlockToProperties, extractPageIdFromUrl, reduceNotionBlock } from '../utils/notionUtils.ts';\nimport { extractBlockIdFromKey } from '../utils/blobUtils.ts';\nimport { disambiguateClientProjects, type ProjectWithDates } from '../utils/projectUtils.ts';\n\n// Type for project with all details needed for matching\ntype ProjectWithDetails = {\n id: string;\n name: string;\n clientName: string | null;\n dateStart: string | null;\n dateEnd: string | null;\n lastEditedTime: string;\n};\n\n/**\n * Helper to match a block to projects using strategies 1, 2, and 3\n *\n * @param blockData - Block data with link_mentions, page_url, todo_string, and date_mentions\n * @param projectPageIds - Set of known project page IDs\n * @param projectsWithDetails - Array of projects with names, dates for AI matching\n * @returns Array of matched project IDs\n */\nasync function matchBlockToProjects(\n blockData: { link_mentions?: Array<{ url: string }>; page_url?: string; todo_string: string; date_mentions?: string[] },\n projectPageIds: Set<string>,\n projectsWithDetails: ProjectWithDetails[]\n): Promise<string[]> {\n const matchedProjectIds: string[] = [];\n\n // Strategy 1: Check link_mentions for project references\n if (projectPageIds.size > 0 && blockData.link_mentions?.length) {\n for (const link of blockData.link_mentions) {\n const mentionedPageId = extractPageIdFromUrl(link.url);\n if (mentionedPageId) {\n const normalizedId = mentionedPageId.replace(/-/g, '');\n if (projectPageIds.has(normalizedId)) {\n matchedProjectIds.push(normalizedId);\n }\n }\n }\n }\n\n // Strategy 2: Check if page_url is a project\n if (matchedProjectIds.length === 0 && blockData.page_url && projectPageIds.size > 0) {\n const sourcePageId = extractPageIdFromUrl(blockData.page_url);\n if (sourcePageId) {\n const normalizedId = sourcePageId.replace(/-/g, '');\n if (projectPageIds.has(normalizedId)) {\n matchedProjectIds.push(normalizedId);\n }\n }\n }\n\n // Strategy 3: AI fuzzy matching (with client disambiguation)\n if (matchedProjectIds.length === 0 && projectsWithDetails.length > 0) {\n const aiMatch = await aiService.matchTodoToProject(\n blockData.todo_string,\n projectsWithDetails\n );\n\n if (aiMatch) {\n if (aiMatch.startsWith('CLIENT:')) {\n // AI matched a client, not a specific project - disambiguate using due date\n const clientName = aiMatch.substring(7);\n const todoDueDate = blockData.date_mentions?.[0] || null;\n\n const result = disambiguateClientProjects(\n clientName,\n projectsWithDetails,\n todoDueDate\n );\n\n if (result.needsAiDisambiguation && result.candidates) {\n // Multiple overlapping date ranges - use AI to pick\n const bestProjectId = await aiService.disambiguateOverlappingProjects(\n blockData.todo_string,\n result.candidates\n );\n matchedProjectIds.push(bestProjectId);\n } else if (result.projectId) {\n matchedProjectIds.push(result.projectId);\n }\n } else {\n // AI matched a specific project - but check for better date match among siblings\n const matchedProject = projectsWithDetails.find(p => p.id === aiMatch);\n\n if (matchedProject?.clientName) {\n // Check if there are sibling projects for the same client\n const siblingProjects = projectsWithDetails.filter(\n p => p.clientName === matchedProject.clientName\n );\n\n if (siblingProjects.length > 1) {\n // Multiple projects for this client - disambiguate by date\n const todoDueDate = blockData.date_mentions?.[0] || null;\n\n const result = disambiguateClientProjects(\n matchedProject.clientName,\n projectsWithDetails,\n todoDueDate\n );\n\n if (result.needsAiDisambiguation && result.candidates) {\n // Multiple overlapping date ranges - use AI to pick\n const bestProjectId = await aiService.disambiguateOverlappingProjects(\n blockData.todo_string,\n result.candidates\n );\n matchedProjectIds.push(bestProjectId);\n } else if (result.projectId) {\n matchedProjectIds.push(result.projectId);\n } else {\n matchedProjectIds.push(aiMatch);\n }\n } else {\n // Only one project for this client - use AI's pick\n matchedProjectIds.push(aiMatch);\n }\n } else {\n // No client info - use AI's pick as-is\n matchedProjectIds.push(aiMatch);\n }\n }\n }\n }\n\n return matchedProjectIds;\n}\n\n/**\n * Process todo save: Read blobs and sync to Notion database\n * Creates new pages or updates existing pages based on timestamp comparison\n *\n * Status handling:\n * - CREATE: Sets Status to \"Not started\" for new pages\n * - UPDATE: Does NOT modify Status (preserves user changes)\n */\nexport async function processTodoSave(): Promise<TodoSaveResult> {\n // Get database ID from environment\n const databaseId = Deno.env.get('TODOS_DB_ID');\n\n if (!databaseId) {\n return {\n success: false,\n totalBlobs: 0,\n pagesCreated: 0,\n pagesUpdated: 0,\n pagesSkipped: 0,\n pagesFailed: 0,\n failures: [],\n error: \"Missing TODOS_DB_ID environment variable\",\n details: \"Set TODOS_DB_ID to the Notion database ID where todos should be saved\"\n };\n }\n\n console.log('Starting todo save...');\n\n // Cache project data for matching (held in memory for this save operation)\n // Single query fetches both IDs (for Strategy 1-2) and details (for Strategy 3)\n const projectsDbId = Deno.env.get('PROJECTS_DB_ID');\n let projectPageIds: Set<string> = new Set();\n let projectsWithDetails: ProjectWithDetails[] = [];\n\n if (projectsDbId) {\n const detailsResult = await notionService.getProjectsWithDetails(projectsDbId);\n if (detailsResult.success) {\n projectsWithDetails = detailsResult.projects;\n projectPageIds = new Set(detailsResult.projects.map(p => p.id));\n }\n }\n\n // List all todo blobs\n const blobsResult = await blobService.listBlocksByCategory('todo');\n\n if (!blobsResult.success || !blobsResult.keys) {\n return {\n success: false,\n totalBlobs: 0,\n pagesCreated: 0,\n pagesUpdated: 0,\n pagesSkipped: 0,\n pagesFailed: 0,\n failures: [],\n error: \"Failed to list blobs\",\n details: blobsResult.error || undefined\n };\n }\n\n const blobKeys = blobsResult.keys;\n\n let pagesCreated = 0;\n let pagesUpdated = 0;\n let pagesSkipped = 0;\n let pagesFailed = 0;\n const failures: Array<{ blockId: string; error: string }> = [];\n\n // Process each blob\n for (const key of blobKeys) {\n const blockId = extractBlockIdFromKey(key);\n\n try {\n // Get blob content\n const blobContentResult = await blobService.getBlockFromBlob('todo', blockId);\n\n if (!blobContentResult.success || !blobContentResult.data) {\n throw new Error(`Failed to get blob content: ${blobContentResult.error}`);\n }\n\n const reducedBlock: ReducedNotionBlock = blobContentResult.data;\n\n // OPTIMIZATION: Skip if already synced\n if (reducedBlock.sync_metadata?.synced === true) {\n pagesSkipped++;\n continue;\n }\n\n // NOTE: No validation needed here - all blobs are guaranteed valid\n // Validation happens during search phase (todoController.ts)\n // Only blocks with people_mentions AND date_mentions are saved to blob storage\n\n // Match block to projects using strategies 1-3\n let matchedProjectIds = await matchBlockToProjects(\n reducedBlock,\n projectPageIds,\n projectsWithDetails\n );\n\n // Strategy 4: Traverse up parent blocks if strategies 1-3 failed\n if (matchedProjectIds.length === 0 && reducedBlock.parent_id) {\n let currentParentId: string | null = reducedBlock.parent_id;\n const maxDepth = 5; // Prevent infinite loops\n\n for (let depth = 0; depth < maxDepth && currentParentId; depth++) {\n // Fetch parent block from Notion\n const parentResult = await notionService.getBlock(currentParentId);\n if (!parentResult.success || !parentResult.data) {\n break;\n }\n\n const parentBlock = parentResult.data;\n\n // Reduce parent block and apply matching strategies 1-3\n const parentReduced = reduceNotionBlock(parentBlock);\n\n const parentMatches = await matchBlockToProjects(\n {\n ...parentReduced,\n date_mentions: reducedBlock.date_mentions // Use todo's due date\n },\n projectPageIds,\n projectsWithDetails\n );\n\n if (parentMatches.length > 0) {\n matchedProjectIds = parentMatches;\n break;\n }\n\n // Move up to next parent (if it's a block, not a page)\n const parentParent = (parentBlock as any).parent;\n currentParentId = parentParent?.type === 'block_id' ? parentParent.block_id : null;\n }\n }\n\n // Map to Notion properties\n const properties = mapReducedBlockToProperties(reducedBlock, matchedProjectIds);\n\n // Extract emoji from todo_string for page icon\n const emoji = extractFirstEmoji(reducedBlock.todo_string);\n const icon = emoji ? { type: \"emoji\", emoji: emoji } : undefined;\n\n // OPTIMIZATION: Use cached page ID if available\n const cachedPageId = reducedBlock.sync_metadata?.notion_page_id;\n let pageId: string | null = null;\n\n if (cachedPageId) {\n // We have a cached page ID - update directly without query\n const updateResult = await notionService.updateNotionPage(cachedPageId, properties, icon);\n\n if (updateResult.success) {\n pagesUpdated++;\n pageId = cachedPageId;\n } else if (updateResult.error?.includes('archived')) {\n // Page was archived - clear cache and skip (user intentionally archived it)\n console.log(`⊘ Skipping archived page ${cachedPageId} - clearing cached reference`);\n const projectName = key.split('--')[0];\n const fullKey = `${projectName}--todo--${blockId}`;\n await blobService.updateBlobSyncMetadata(fullKey, {\n synced: true, // Mark synced to prevent retry\n notion_page_id: undefined, // Clear cached ID\n archived: true // Flag as archived\n });\n pagesSkipped++;\n continue;\n } else {\n throw new Error(`Failed to update page: ${updateResult.error}`);\n }\n } else {\n // No cached page ID - query database to check if page exists\n const existingPageResult = await notionService.queryDatabaseByBlockId(databaseId, blockId);\n\n if (!existingPageResult.success) {\n throw new Error(`Failed to query database: ${existingPageResult.error}`);\n }\n\n if (existingPageResult.data) {\n // Page exists but we don't have cached ID - just cache it, don't update\n // This handles race conditions where another sync just created the page\n pageId = existingPageResult.data.id;\n pagesSkipped++;\n } else {\n // Page doesn't exist - create new\n const createProperties = {\n ...properties,\n Status: {\n select: {\n name: \"Not started\"\n }\n }\n };\n\n const createResult = await notionService.createNotionPage(databaseId, createProperties, icon);\n\n if (createResult.success) {\n pagesCreated++;\n pageId = createResult.data?.id || null;\n\n // Add callout if source block has children\n if (pageId && reducedBlock.has_children && reducedBlock.block_url) {\n const calloutResult = await notionService.appendHasChildrenCallout(pageId, reducedBlock.block_url);\n if (!calloutResult.success) {\n console.warn(`⚠ Failed to add children callout: ${calloutResult.error}`);\n }\n }\n } else {\n throw new Error(`Failed to create page: ${createResult.error}`);\n }\n }\n }\n\n // Mark blob as synced on success\n if (pageId) {\n const projectName = key.split('--')[0];\n const fullKey = `${projectName}--todo--${blockId}`;\n\n const updateMetadataResult = await blobService.updateBlobSyncMetadata(fullKey, {\n synced: true,\n notion_page_id: pageId\n });\n\n if (!updateMetadataResult.success) {\n console.warn(`⚠ Failed to update sync metadata: ${updateMetadataResult.error}`);\n }\n }\n } catch (err: any) {\n console.error(`✗ Failed block ${blockId}: ${err.message}`);\n pagesFailed++;\n failures.push({\n blockId: blockId,\n error: err.message\n });\n }\n }\n\n // Print summary\n console.log(`Save complete: ${pagesCreated} created, ${pagesUpdated} updated, ${pagesSkipped} skipped, ${pagesFailed} failed`);\n\n return {\n success: true,\n totalBlobs: blobKeys.length,\n pagesCreated,\n pagesUpdated,\n pagesSkipped,\n pagesFailed,\n failures\n };\n}\n",[],[209,653,644],"controllers","348cf5a0-d5b8-11f0-ba29-42dde27851f2","todoOrchestrationController.ts","fd176688-b4f0-11f0-8e48-0224a6c84d84",168,["D",1765364758072],13,"import * as pageController from './pageController.ts';\nimport * as todoController from './todoController.ts';\nimport * as todoSaveController from './todoSaveController.ts';\nimport { getRecentPagesLookbackHours } from '../utils/configUtils.ts';\n\n/**\n * Batch todo search result for a single page\n */\ninterface PageSearchResult {\n pageId: string;\n pageTitle: string;\n success: boolean;\n blocksFound: number;\n blocksNew?: number;\n blocksUpdated?: number;\n blocksSkipped?: number;\n blockIds: string[];\n error?: string;\n}\n\n/**\n * Batch search result (search and save to blobs only)\n */\nexport interface BatchSearchResult {\n success: boolean;\n pagesSearched: number;\n totalTodosFound: number;\n totalNew?: number;\n totalUpdated?: number;\n totalSkipped?: number;\n searchResults: PageSearchResult[];\n error?: string;\n details?: string;\n}\n\n/**\n * Batch todos processing result (search + sync to database)\n */\nexport interface BatchTodosResult {\n success: boolean;\n pagesSearched: number;\n totalTodosFound: number;\n searchResults: PageSearchResult[];\n saveResult: any;\n error?: string;\n details?: string;\n}\n\n/**\n * Orchestrate batch keyword search:\n * 1. Get recent pages from Notion\n * 2. Search each page for keywords and save to blobs\n *\n * Does NOT sync to Notion database - that's handled separately by processTodoSave()\n *\n * Keywords are read from SEARCH_KEYWORDS environment variable (comma-separated)\n * Defaults to \"todo\" if not set\n *\n * @param hoursAgo - Number of hours to look back for recent pages (default: RECENT_PAGES_LOOKBACK_HOURS env var, fallback 24)\n * @param applyStabilityDelay - Whether to apply stability check before saving blocks (default: true for cron usage)\n */\nexport async function processBatchSearch(hoursAgo?: number, applyStabilityDelay: boolean = true): Promise<BatchSearchResult> {\n const hours = hoursAgo ?? getRecentPagesLookbackHours();\n\n // Step 1: Get recent pages\n const pagesResult = await pageController.getRecentPages(hours);\n\n if (!pagesResult.success || !pagesResult.data?.pages) {\n console.error('Failed to fetch recent pages:', pagesResult.error);\n return {\n success: false,\n pagesSearched: 0,\n totalTodosFound: 0,\n searchResults: [],\n error: \"Failed to fetch recent pages\",\n details: pagesResult.error || undefined\n };\n }\n\n const pages = pagesResult.data.pages;\n console.log(`Searching ${pages.length} recent pages...`);\n\n if (pages.length === 0) {\n return {\n success: true,\n pagesSearched: 0,\n totalTodosFound: 0,\n searchResults: []\n };\n }\n\n // Step 2: Search each page for keywords\n const searchResults: PageSearchResult[] = [];\n let totalTodosFound = 0;\n let totalNew = 0;\n let totalUpdated = 0;\n let totalSkipped = 0;\n\n for (let i = 0; i < pages.length; i++) {\n const page = pages[i];\n\n try {\n const searchResult = await todoController.processTodoSearch(page.id, applyStabilityDelay);\n\n searchResults.push({\n pageId: page.id,\n pageTitle: page.title,\n success: searchResult.success,\n blocksFound: searchResult.blocksFound,\n blocksNew: searchResult.blocksNew,\n blocksUpdated: searchResult.blocksUpdated,\n blocksSkipped: searchResult.blocksSkipped,\n blockIds: searchResult.blockIds,\n error: searchResult.error\n });\n\n if (searchResult.success) {\n totalTodosFound += searchResult.blocksFound;\n totalNew += searchResult.blocksNew || 0;\n totalUpdated += searchResult.blocksUpdated || 0;\n totalSkipped += searchResult.blocksSkipped || 0;\n } else {\n console.error(`✗ Search failed for ${page.title}: ${searchResult.error}`);\n }\n } catch (err: any) {\n console.error(`✗ Unexpected error for ${page.title}: ${err.message}`);\n searchResults.push({\n pageId: page.id,\n pageTitle: page.title,\n success: false,\n blocksFound: 0,\n blockIds: [],\n error: err.message\n });\n }\n }\n\n console.log(`Search complete: ${totalNew} new, ${totalUpdated} updated, ${totalSkipped} skipped`);\n\n // Return comprehensive summary (no database sync)\n return {\n success: true,\n pagesSearched: pages.length,\n totalTodosFound,\n totalNew,\n totalUpdated,\n totalSkipped,\n searchResults\n };\n}\n\n/**\n * Orchestrate batch keyword search processing:\n * 1. Get recent pages from Notion\n * 2. Search each page for keywords and save to blobs\n * 3. Sync all todo blobs to Notion database\n *\n * Keywords are read from SEARCH_KEYWORDS environment variable (comma-separated)\n * Defaults to \"todo\" if not set\n *\n * @param hoursAgo - Number of hours to look back for recent pages (default: RECENT_PAGES_LOOKBACK_HOURS env var, fallback 24)\n * @param applyStabilityDelay - Whether to apply stability check before saving blocks (default: false for webhook usage)\n */\nexport async function processBatchTodos(hoursAgo?: number, applyStabilityDelay: boolean = false): Promise<BatchTodosResult> {\n const hours = hoursAgo ?? getRecentPagesLookbackHours();\n\n // Step 1: Get recent pages\n const pagesResult = await pageController.getRecentPages(hours);\n\n if (!pagesResult.success || !pagesResult.data?.pages) {\n console.error('Failed to fetch recent pages:', pagesResult.error);\n return {\n success: false,\n pagesSearched: 0,\n totalTodosFound: 0,\n searchResults: [],\n saveResult: null,\n error: \"Failed to fetch recent pages\",\n details: pagesResult.error || undefined\n };\n }\n\n const pages = pagesResult.data.pages;\n console.log(`Searching ${pages.length} recent pages...`);\n\n if (pages.length === 0) {\n return {\n success: true,\n pagesSearched: 0,\n totalTodosFound: 0,\n searchResults: [],\n saveResult: { totalBlobs: 0, pagesCreated: 0, pagesUpdated: 0, pagesSkipped: 0, pagesFailed: 0 }\n };\n }\n\n // Step 2: Search each page for keywords\n const searchResults: PageSearchResult[] = [];\n let totalTodosFound = 0;\n let totalNew = 0;\n let totalUpdated = 0;\n let totalSkipped = 0;\n\n for (let i = 0; i < pages.length; i++) {\n const page = pages[i];\n\n try {\n const searchResult = await todoController.processTodoSearch(page.id, applyStabilityDelay);\n\n searchResults.push({\n pageId: page.id,\n pageTitle: page.title,\n success: searchResult.success,\n blocksFound: searchResult.blocksFound,\n blocksNew: searchResult.blocksNew,\n blocksUpdated: searchResult.blocksUpdated,\n blocksSkipped: searchResult.blocksSkipped,\n blockIds: searchResult.blockIds,\n error: searchResult.error\n });\n\n if (searchResult.success) {\n totalTodosFound += searchResult.blocksFound;\n totalNew += searchResult.blocksNew || 0;\n totalUpdated += searchResult.blocksUpdated || 0;\n totalSkipped += searchResult.blocksSkipped || 0;\n } else {\n console.error(`✗ Search failed for ${page.title}: ${searchResult.error}`);\n }\n } catch (err: any) {\n console.error(`✗ Unexpected error for ${page.title}: ${err.message}`);\n searchResults.push({\n pageId: page.id,\n pageTitle: page.title,\n success: false,\n blocksFound: 0,\n blockIds: [],\n error: err.message\n });\n }\n }\n\n console.log(`Search complete: ${totalNew} new, ${totalUpdated} updated, ${totalSkipped} skipped`);\n\n // Step 3: Save all todos to Notion database\n let saveResult;\n\n try {\n saveResult = await todoSaveController.processTodoSave();\n\n if (!saveResult.success) {\n console.error('Save failed:', saveResult.error);\n }\n\n // Log failures only\n if (saveResult.failures && saveResult.failures.length > 0) {\n saveResult.failures.forEach((failure: any) => {\n console.error(`✗ Block ${failure.blockId}: ${failure.error}`);\n });\n }\n } catch (err: any) {\n console.error('Save error:', err.message);\n saveResult = {\n success: false,\n totalBlobs: 0,\n pagesCreated: 0,\n pagesUpdated: 0,\n pagesSkipped: 0,\n pagesFailed: 0,\n failures: [],\n error: err.message\n };\n }\n\n // Return comprehensive summary\n return {\n success: true,\n pagesSearched: pages.length,\n totalTodosFound,\n searchResults,\n saveResult\n };\n}\n",[],[209,653,655],"06f58ec2-d5b8-11f0-9cfb-42dde27851f2","todoController.ts","15827462-b459-11f0-a09c-0224a6c84d84",163,["D",1765364681514],29,"import * as notionService from '../services/notion/index.ts';\nimport { TODO_CONTAINER_TYPES } from '../services/notion/pages.ts';\nimport type { TodoSearchResult } from '../../shared/types.ts';\nimport { reduceNotionBlock, extractPageIdFromUrl } from '../utils/notionUtils.ts';\nimport * as blobService from '../services/blobService.ts';\nimport { getDefaultDueDateSetting, calculateDueDate } from '../utils/dateUtils.ts';\nimport { getMinBlockWords, countWords } from '../utils/textUtils.ts';\nimport { getBlockStabilityMinutes, isBlockStable, getBlockAgeMinutes, getBlockBackgroundColor } from '../utils/blockUtils.ts';\n\n// Flag to only warn once about config conflict\nlet searchConfigWarned = false;\n\n/**\n * Get search keywords from environment variable or default\n *\n * Reads SEARCH_KEYWORDS env var (comma-separated list)\n * Falls back to [\"todo\"] if not set\n *\n * @returns Array of keywords to search for\n */\nfunction getSearchKeywords(): string[] {\n const envKeywords = Deno.env.get('SEARCH_KEYWORDS');\n\n if (envKeywords) {\n return envKeywords\n .split(',')\n .map(k => k.trim())\n .filter(k => k.length > 0);\n }\n\n return ['todo']; // Default fallback\n}\n\n/**\n * Search configuration interface\n */\ninterface SearchConfig {\n mode: 'keyword' | 'blockType';\n keywords?: string[]; // For keyword mode\n blockType?: string; // For block type mode\n}\n\n/**\n * Get search configuration from environment variables\n *\n * Determines search mode based on which env var is set:\n * - SEARCH_BLOCK_TYPE (if set) → block type mode (takes precedence)\n * - SEARCH_KEYWORDS (if set) → keyword mode\n * - Neither set → keyword mode with default \"todo\"\n *\n * @returns Search configuration\n */\nfunction getSearchConfig(): SearchConfig {\n const blockType = Deno.env.get('SEARCH_BLOCK_TYPE');\n\n if (blockType !== undefined) {\n // Block type mode takes precedence\n const type = blockType.trim() || 'to_do'; // Default to to_do if empty\n\n // Warn only once if both are set\n if (!searchConfigWarned && Deno.env.get('SEARCH_KEYWORDS')) {\n console.warn('⚠ Both SEARCH_BLOCK_TYPE and SEARCH_KEYWORDS are set. Using SEARCH_BLOCK_TYPE mode.');\n searchConfigWarned = true;\n }\n\n return {\n mode: 'blockType',\n blockType: type\n };\n }\n\n // Keyword mode (existing logic)\n const keywords = getSearchKeywords();\n return {\n mode: 'keyword',\n keywords: keywords\n };\n}\n\n/**\n * Extract creator information from Notion block\n * Returns user object in people_mentions format\n *\n * @param block - Notion block object\n * @returns Creator user object or null\n */\nfunction getBlockCreator(block: any): { id: string; name: string | null; email: string | null } | null {\n if (!block.created_by || !block.created_by.id) {\n return null;\n }\n\n return {\n id: block.created_by.id,\n name: null, // Not available without additional API call\n email: null\n };\n}\n\n/**\n * Search for blocks in a page\n * Logs entire block to console when found\n *\n * Two search modes:\n * 1. Keyword mode: Uses SEARCH_KEYWORDS env var (comma-separated)\n * 2. Block type mode: Uses SEARCH_BLOCK_TYPE env var (e.g., \"to_do\")\n *\n * Block type mode takes precedence if both are set.\n *\n * Validation:\n * - Blocks must have MIN_BLOCK_WORDS words (default: 5) to be saved\n * - Short blocks lack context needed for meaningful todos\n *\n * Auto-assignment:\n * - If no date_mentions: auto-assigns due date based on DEFAULT_DUE_DATE env var (defaults to \"today\")\n * - If no people_mentions: auto-assigns creator as owner\n *\n * Stability check:\n * - If applyStabilityDelay is true: blocks must be older than BLOCK_STABILITY_MINUTES (default: 2)\n * - If applyStabilityDelay is false: blocks are saved immediately (webhook/manual triggers)\n *\n * @param pageId - Notion page ID to search\n * @param applyStabilityDelay - Whether to check block age before saving (default: false for webhook compatibility)\n */\nexport async function processTodoSearch(pageId: string, applyStabilityDelay: boolean = false): Promise<TodoSearchResult> {\n // Validate input\n if (!pageId || typeof pageId !== 'string') {\n return {\n success: false,\n blocksFound: 0,\n blockIds: [],\n error: \"Invalid pageId\",\n details: \"pageId must be a non-empty string\"\n };\n }\n\n // Get search configuration\n const searchConfig = getSearchConfig();\n\n try {\n // Fetch page to get URL (single API call for all blocks in this page)\n const pageResult = await notionService.getNotionPage(pageId);\n const pageUrl = pageResult.success ? (pageResult.data as any)?.url : null;\n\n // Get all blocks recursively from the page\n // In block type mode, only recurse into container blocks that can hold to_do items\n const containerFilter = searchConfig.mode === 'blockType' ? TODO_CONTAINER_TYPES : undefined;\n const allBlocks = await notionService.getPageBlocksRecursive(pageId, containerFilter);\n\n if (!allBlocks || allBlocks.length === 0) {\n return {\n success: true,\n blocksFound: 0,\n blockIds: []\n };\n }\n\n const blocksMatched: string[] = [];\n let blocksNew = 0;\n let blocksUpdated = 0;\n let blocksSkipped = 0;\n\n // Search based on mode\n for (const block of allBlocks) {\n let matched = false;\n let matchInfo = '';\n\n if (searchConfig.mode === 'blockType') {\n // Block type mode: match by Notion block type\n if (block.type === searchConfig.blockType) {\n matched = true;\n matchInfo = `block type \"${searchConfig.blockType}\"`;\n }\n } else {\n // Keyword mode: match by text content\n const matchedKeyword = searchConfig.keywords?.find(kw => searchBlockForKeyword(block, kw));\n if (matchedKeyword) {\n matched = true;\n matchInfo = `keyword \"${matchedKeyword}\"`;\n }\n }\n\n if (matched) {\n const reducedBlock = reduceNotionBlock(block);\n\n // ENRICH PAGE TITLES: Replace \"Untitled\" with actual page titles\n if (reducedBlock.link_mentions && reducedBlock.link_mentions.length > 0) {\n for (const linkMention of reducedBlock.link_mentions) {\n // Only fetch title if it's currently \"Untitled\"\n if (linkMention.text === 'Untitled') {\n // Extract page ID from URL\n const pageId = extractPageIdFromUrl(linkMention.url);\n\n if (pageId) {\n // Fetch page title from Notion API\n const titleResult = await notionService.getPageTitle(pageId);\n\n if (titleResult.success && titleResult.title) {\n // Replace \"Untitled\" with actual title\n linkMention.text = titleResult.title;\n }\n }\n }\n }\n }\n\n // STABILITY CHECK: Only apply if requested (cron mode)\n if (applyStabilityDelay) {\n const stabilityMinutes = getBlockStabilityMinutes();\n\n if (stabilityMinutes > 0 && !isBlockStable(reducedBlock.last_edited_time, stabilityMinutes)) {\n continue; // Block too recent, skip\n }\n }\n\n // VALIDATION: Only save blocks that meet sync criteria\n\n // Check minimum word count\n const minWords = getMinBlockWords();\n const wordCount = countWords(reducedBlock.todo_string);\n\n if (wordCount < minWords) {\n continue; // Block too short, skip\n }\n\n // Auto-assign due date if no date mentioned\n if (!reducedBlock.date_mentions || reducedBlock.date_mentions.length === 0) {\n const setting = getDefaultDueDateSetting();\n const calculatedDate = calculateDueDate(setting);\n reducedBlock.date_mentions = [calculatedDate];\n }\n\n // Auto-assign creator as owner if no people mentioned\n if (!reducedBlock.people_mentions || reducedBlock.people_mentions.length === 0) {\n const creator = getBlockCreator(block);\n\n if (creator) {\n reducedBlock.people_mentions = [creator];\n } else {\n continue; // No owner available, skip\n }\n }\n\n // Check if blob already exists\n const existingBlobResult = await blobService.getBlockFromBlob('todo', block.id);\n\n let shouldSave = false;\n let saveReason = '';\n let existingNotionPageId: string | undefined = undefined;\n\n if (!existingBlobResult.success || !existingBlobResult.data) {\n // No existing blob, save as new\n shouldSave = true;\n saveReason = 'new';\n } else {\n // Preserve existing notion_page_id if it exists\n existingNotionPageId = existingBlobResult.data.sync_metadata?.notion_page_id;\n\n // Compare timestamps\n const existingTime = new Date(existingBlobResult.data.last_edited_time);\n const currentTime = new Date(reducedBlock.last_edited_time);\n\n if (currentTime > existingTime) {\n shouldSave = true;\n saveReason = 'updated';\n } else {\n shouldSave = false;\n }\n }\n\n // Save to blob storage if needed\n if (shouldSave) {\n // Extract parent block ID (null if parent is a page, not a block)\n const parentId = block.parent?.type === 'block_id' ? block.parent.block_id : null;\n\n // Add sync metadata - mark as needing sync, preserve page ID\n const blobData: any = {\n ...reducedBlock,\n page_url: pageUrl, // Source page URL\n parent_id: parentId, // Parent block ID for traversal\n sync_metadata: {\n synced: false, // Needs sync since block changed\n notion_page_id: existingNotionPageId // Preserve if exists\n }\n };\n\n // Flag if block has children (for callout in todo page)\n if (block.has_children) {\n blobData.has_children = true;\n }\n\n const blobResult = await blobService.saveBlockToBlob(\n 'todo',\n block.id,\n blobData\n );\n\n if (!blobResult.success) {\n console.error(`✗ Failed to save blob: ${blobResult.error}`);\n } else {\n // Set block background color ONLY for new blocks\n // (Updating color on existing blocks changes last_edited_time, causing infinite sync loop)\n if (saveReason === 'new') {\n const bgColor = getBlockBackgroundColor();\n if (bgColor) {\n const colorResult = await notionService.updateBlockColor(block.id, bgColor);\n if (!colorResult.success) {\n console.warn(`⚠ Failed to set block color: ${colorResult.error}`);\n }\n }\n }\n }\n\n // Track counters based on save reason\n if (saveReason === 'new') {\n blocksNew++;\n } else {\n blocksUpdated++;\n }\n blocksMatched.push(block.id);\n } else {\n // Block unchanged, skip\n blocksSkipped++;\n }\n }\n }\n\n return {\n success: true,\n blocksFound: blocksNew + blocksUpdated,\n blocksNew,\n blocksUpdated,\n blocksSkipped,\n blockIds: blocksMatched\n };\n\n } catch (err: any) {\n return {\n success: false,\n blocksFound: 0,\n blockIds: [],\n error: `Failed to search for keywords`,\n details: err.message\n };\n }\n}\n\n/**\n * Helper function to escape special regex characters\n */\nfunction escapeRegex(str: string): string {\n return str.replace(/[.*+?^${}()|[\\]\\\\]/g, '\\\\$&');\n}\n\n/**\n * Helper function to search a block for a keyword\n *\n * For text keywords: Uses word boundary regex for exact word match, case-insensitive\n * For non-alphanumeric keywords (like emojis): Uses exact match\n *\n * Searches within:\n * - Standard rich_text blocks (paragraphs, headings, lists, toggles, etc.)\n * - Blocks inside columns (automatically handled by recursive fetching)\n *\n * Skips:\n * - Unsupported blocks\n * - Button blocks\n * - Table blocks\n * - Table row blocks\n *\n * @param block - Notion block object\n * @param keyword - Keyword to search for (default: \"todo\")\n */\nfunction searchBlockForKeyword(block: any, keyword: string = 'todo'): boolean {\n const blockType = block.type;\n\n // Skip if block type is not defined\n if (!blockType || !block[blockType]) {\n return false;\n }\n\n // Explicitly skip unsupported, button, table, and table_row blocks\n if (blockType === 'unsupported' || blockType === 'button' || blockType === 'table' || blockType === 'table_row') {\n return false;\n }\n\n let textContent = '';\n\n // Extract text from standard rich_text array (most block types)\n if (block[blockType]?.rich_text && Array.isArray(block[blockType].rich_text)) {\n textContent = block[blockType].rich_text\n .map((rt: any) => rt.plain_text || '')\n .join(' ');\n }\n\n // If no text content extracted, return false\n if (!textContent.trim()) {\n return false;\n }\n\n // Escape special regex characters in the keyword\n const escapedKeyword = escapeRegex(keyword);\n\n // Check if keyword contains only alphanumeric characters (and common word chars)\n const isAlphanumeric = /^[\\w\\s-]+$/.test(keyword);\n\n if (isAlphanumeric) {\n // Use word boundary for text keywords (case-insensitive)\n const regex = new RegExp(`\\\\b${escapedKeyword}\\\\b`, 'i');\n return regex.test(textContent);\n } else {\n // For emojis and special characters, use exact match (case-sensitive)\n return textContent.includes(keyword);\n }\n}\n",[],[209,653,664],"43d11f54-b962-11f0-8efb-0224a6c84d84","pageController.ts","019a26dc-99bf-7269-a8f5-f4ae4994f9d7",["D",1762249214392],"import * as notionService from '../services/notion/index.ts';\nimport { getRecentPagesLookbackHours } from '../utils/configUtils.ts';\n\n/**\n * Get a Notion page by ID\n * Generic controller that works with any Notion page type\n */\nexport async function getPage(pageId: string) {\n // Validate input\n if (!pageId || typeof pageId !== 'string') {\n return {\n success: false,\n data: null,\n error: \"Invalid pageId\",\n details: \"pageId must be a non-empty string\"\n };\n }\n\n // Call service\n const result = await notionService.getNotionPage(pageId);\n\n if (!result.success) {\n return {\n success: false,\n data: null,\n error: \"Failed to fetch page\",\n details: result.error\n };\n }\n\n // Filter sensitive data if needed\n // Example: Remove button properties\n const filteredData = filterSensitiveProperties(result.data);\n\n return {\n success: true,\n data: filteredData,\n error: null\n };\n}\n\n/**\n * Update a Notion page's properties\n * Generic controller that works with any Notion page type\n */\nexport async function updatePage(pageId: string, properties: any) {\n // Validate input\n if (!pageId || typeof pageId !== 'string') {\n return {\n success: false,\n data: null,\n error: \"Invalid pageId\",\n details: \"pageId must be a non-empty string\"\n };\n }\n\n if (!properties || typeof properties !== 'object') {\n return {\n success: false,\n data: null,\n error: \"Invalid properties\",\n details: \"properties must be a non-empty object\"\n };\n }\n\n // Call service\n const result = await notionService.updateNotionPage(pageId, properties);\n\n if (!result.success) {\n return {\n success: false,\n data: null,\n error: \"Failed to update page\",\n details: result.error\n };\n }\n\n // Filter sensitive data if needed\n const filteredData = filterSensitiveProperties(result.data);\n\n return {\n success: true,\n data: filteredData,\n error: null\n };\n}\n\n/**\n * Create a new page in a database\n */\nexport async function createPage(databaseId: string, properties: any) {\n // Validate input\n if (!databaseId || typeof databaseId !== 'string') {\n return {\n success: false,\n data: null,\n error: \"Invalid databaseId\",\n details: \"databaseId must be a non-empty string\"\n };\n }\n\n if (!properties || typeof properties !== 'object') {\n return {\n success: false,\n data: null,\n error: \"Invalid properties\",\n details: \"properties must be a non-empty object\"\n };\n }\n\n // Call service\n const result = await notionService.createNotionPage(databaseId, properties);\n\n if (!result.success) {\n return {\n success: false,\n data: null,\n error: \"Failed to create page\",\n details: result.error\n };\n }\n\n // Filter sensitive data if needed\n const filteredData = filterSensitiveProperties(result.data);\n\n return {\n success: true,\n data: filteredData,\n error: null\n };\n}\n\n/**\n * Get page content (blocks)\n */\nexport async function getPageContent(pageId: string) {\n // Validate input\n if (!pageId || typeof pageId !== 'string') {\n return {\n success: false,\n data: null,\n error: \"Invalid pageId\",\n details: \"pageId must be a non-empty string\"\n };\n }\n\n // Call service\n const result = await notionService.getPageBlocks(pageId);\n\n if (!result.success) {\n return {\n success: false,\n data: null,\n error: \"Failed to fetch page content\",\n details: result.error\n };\n }\n\n return {\n success: true,\n data: result.data,\n error: null\n };\n}\n\n/**\n * Get recent pages edited within the last X hours\n * Returns simplified page objects with id, title, url, last_edited_time, parent\n * Filters out:\n * - Archived pages\n * - Database objects\n * - Pages inside TODOS_DB_ID database\n *\n * @param hoursAgo - Number of hours to look back (default: RECENT_PAGES_LOOKBACK_HOURS env var, fallback 24)\n */\nexport async function getRecentPages(hoursAgo?: number) {\n // Validate input - use env var default if not provided\n const hours = hoursAgo ?? getRecentPagesLookbackHours();\n\n if (typeof hours !== 'number' || hours <= 0) {\n return {\n success: false,\n data: null,\n error: \"Invalid hours parameter\",\n details: \"hours must be a positive number\"\n };\n }\n\n // Call service\n const result = await notionService.searchRecentPages(hours);\n\n if (!result.success) {\n return {\n success: false,\n data: null,\n error: \"Failed to fetch recent pages\",\n details: result.error\n };\n }\n\n return {\n success: true,\n data: {\n pages: result.data,\n count: result.data?.length || 0,\n timeRange: `${hours} hours`\n },\n error: null\n };\n}\n\n/**\n * Filter sensitive properties from Notion data\n * Example: Remove button properties\n */\nfunction filterSensitiveProperties(data: any) {\n if (!data || !data.properties) {\n return data;\n }\n\n const filtered = {\n ...data,\n properties: Object.entries(data.properties)\n .filter(([_key, value]: [string, any]) => value.type !== 'button')\n .reduce((acc, [key, value]) => ({ ...acc, [key]: value }), {})\n };\n\n return filtered;\n}\n",[],[209,653,673],"fd5b9ad2-d51c-11f0-8f59-42dde27851f2","healthController.ts","43d0e1d8-b962-11f0-8efb-0224a6c84d84",155,["D",1765298093482],"import * as pageController from './pageController.ts';\nimport * as notionService from '../services/notion/index.ts';\nimport * as blobService from '../services/blobService.ts';\nimport { getRecentPagesLookbackHours } from '../utils/configUtils.ts';\nimport { getBlockStabilityMinutes } from '../utils/blockUtils.ts';\nimport { getMinBlockWords } from '../utils/textUtils.ts';\nimport { getDefaultDueDateSetting } from '../utils/dateUtils.ts';\n\n/**\n * Health check response structure\n */\ninterface HealthCheckResponse {\n success: boolean;\n data: {\n timestamp: string;\n connections: {\n notion: {\n connected: boolean;\n };\n todos_db: {\n connected: boolean;\n title?: string;\n url?: string;\n last_edited_time?: string;\n };\n };\n environment: {\n NOTION_API_KEY: {\n configured: boolean;\n };\n WEBHOOK_SECRET: {\n configured: boolean;\n };\n TODOS_DB_ID: {\n configured: boolean;\n value?: string;\n };\n RECENT_PAGES_LOOKBACK_HOURS: {\n configured: boolean;\n value: number;\n default: number;\n };\n BLOCK_STABILITY_MINUTES: {\n configured: boolean;\n value: number;\n default: number;\n };\n MIN_BLOCK_WORDS: {\n configured: boolean;\n value: number;\n default: number;\n };\n SEARCH_KEYWORDS: {\n configured: boolean;\n value: string[];\n default: string[];\n };\n SEARCH_BLOCK_TYPE: {\n configured: boolean;\n value: string | null;\n default: string;\n };\n DEFAULT_DUE_DATE: {\n configured: boolean;\n value: string;\n default: string;\n };\n };\n pages: {\n count: number;\n lookback_hours: number;\n results: Array<{\n page_id: string;\n title: string;\n last_edited_time: string;\n url: string;\n parent?: {\n type: string;\n id?: string;\n };\n }>;\n };\n blobs: {\n category: string;\n prefix: string;\n count: number;\n };\n };\n error?: string | null;\n}\n\n/**\n * Get system health status\n *\n * Checks:\n * - Notion API connectivity (via recent pages check)\n * - Pages data (count + results)\n * - Todos database connectivity\n *\n * Returns structured health data for monitoring/debugging\n */\nexport async function getSystemHealth(): Promise<HealthCheckResponse> {\n const timestamp = new Date().toISOString();\n\n // 1. Check NOTION_API_KEY by fetching recent pages\n const pagesResult = await pageController.getRecentPages();\n const notionApiKey = Deno.env.get('NOTION_API_KEY');\n const notionConnected = pagesResult.success;\n\n // Extract pages data\n const pagesData = pagesResult.data?.pages || [];\n const pagesFormatted = pagesData.map((page: any) => ({\n page_id: page.id,\n title: page.title,\n last_edited_time: page.last_edited_time,\n url: page.url,\n parent: page.parent\n }));\n\n // 2. Check WEBHOOK_SECRET\n const webhookSecret = Deno.env.get('WEBHOOK_SECRET');\n\n // 3. Check TODOS_DB_ID\n const todosDbId = Deno.env.get('TODOS_DB_ID');\n let todosDbConnected = false;\n let todosDbTitle: string | undefined;\n let todosDbLastEditedTime: string | undefined;\n let todosDbUrl: string | undefined;\n\n if (todosDbId) {\n // Attempt to retrieve the database\n const dbResult = await notionService.getNotionDatabase(todosDbId);\n todosDbConnected = dbResult.success;\n\n if (dbResult.success && dbResult.data) {\n // Extract title from database object\n const titleProperty = (dbResult.data as any).title;\n if (titleProperty && Array.isArray(titleProperty)) {\n todosDbTitle = titleProperty.map((rt: any) => rt.plain_text || '').join('') || 'Untitled';\n }\n\n // Extract last_edited_time\n todosDbLastEditedTime = (dbResult.data as any).last_edited_time;\n\n // Extract url\n todosDbUrl = (dbResult.data as any).url;\n }\n }\n\n // 4. Check RECENT_PAGES_LOOKBACK_HOURS\n const recentPagesEnvValue = Deno.env.get('RECENT_PAGES_LOOKBACK_HOURS');\n const lookbackHours = getRecentPagesLookbackHours();\n\n // 5. Check BLOCK_STABILITY_MINUTES\n const blockStabilityEnvValue = Deno.env.get('BLOCK_STABILITY_MINUTES');\n const blockStabilityMinutes = getBlockStabilityMinutes();\n\n // 6. Check MIN_BLOCK_WORDS\n const minBlockWordsEnvValue = Deno.env.get('MIN_BLOCK_WORDS');\n const minBlockWords = getMinBlockWords();\n\n // 7. Check SEARCH_KEYWORDS\n const searchKeywordsEnvValue = Deno.env.get('SEARCH_KEYWORDS');\n const searchKeywords = searchKeywordsEnvValue\n ? searchKeywordsEnvValue.split(',').map(k => k.trim()).filter(k => k.length > 0)\n : ['todo'];\n\n // 8. Check SEARCH_BLOCK_TYPE\n const searchBlockTypeEnvValue = Deno.env.get('SEARCH_BLOCK_TYPE');\n const searchBlockType = searchBlockTypeEnvValue !== undefined\n ? (searchBlockTypeEnvValue.trim() || 'to_do')\n : null;\n\n // 9. Check DEFAULT_DUE_DATE\n const defaultDueDateEnvValue = Deno.env.get('DEFAULT_DUE_DATE');\n const defaultDueDateSetting = getDefaultDueDateSetting();\n\n // 10. Count blobs in storage\n const blobCount = await blobService.countBlobsByCategory('todo');\n const blobPrefix = blobCount.prefix || '';\n const blobTotal = blobCount.count || 0;\n\n // 11. Build health response\n return {\n success: true,\n data: {\n timestamp,\n connections: {\n notion: {\n connected: notionConnected\n },\n todos_db: {\n connected: todosDbConnected,\n title: todosDbTitle,\n url: todosDbUrl,\n last_edited_time: todosDbLastEditedTime\n }\n },\n environment: {\n NOTION_API_KEY: {\n configured: !!notionApiKey\n },\n WEBHOOK_SECRET: {\n configured: !!webhookSecret\n },\n TODOS_DB_ID: {\n configured: !!todosDbId,\n value: todosDbId || undefined\n },\n RECENT_PAGES_LOOKBACK_HOURS: {\n configured: !!recentPagesEnvValue,\n value: lookbackHours,\n default: 24\n },\n BLOCK_STABILITY_MINUTES: {\n configured: !!blockStabilityEnvValue,\n value: blockStabilityMinutes,\n default: 0\n },\n MIN_BLOCK_WORDS: {\n configured: !!minBlockWordsEnvValue,\n value: minBlockWords,\n default: 5\n },\n SEARCH_KEYWORDS: {\n configured: !!searchKeywordsEnvValue,\n value: searchKeywords,\n default: ['todo']\n },\n SEARCH_BLOCK_TYPE: {\n configured: searchBlockTypeEnvValue !== undefined,\n value: searchBlockType,\n default: 'to_do'\n },\n DEFAULT_DUE_DATE: {\n configured: !!defaultDueDateEnvValue,\n value: defaultDueDateSetting,\n default: 'today'\n }\n },\n pages: {\n count: pagesFormatted.length,\n lookback_hours: lookbackHours,\n results: pagesFormatted\n },\n blobs: {\n category: 'todo',\n prefix: blobPrefix,\n count: blobTotal\n }\n },\n error: null\n };\n}\n",[],[209,653,680],"71e9f9e6-b369-11f0-bc36-0224a6c84d84","faviconController.ts","b7798a9c-b361-11f0-9afd-0224a6c84d84",14,["D",1761592591230],"import * as notionService from '../services/notion/index.ts';\nimport * as faviconizerService from '../services/faviconizerService.ts';\nimport type { FaviconUpdateResult } from '../../shared/types.ts';\n\n/**\n * Process favicon update for a Notion page\n * Orchestrates: Get page → Extract Domain → Fetch favicon → Update icon\n * On error: Append error note to page\n */\nexport async function processFaviconUpdate(pageId: string): Promise<FaviconUpdateResult> {\n // Validate input\n if (!pageId || typeof pageId !== 'string') {\n return {\n success: false,\n error: \"Invalid pageId\",\n details: \"pageId must be a non-empty string\"\n };\n }\n\n // Step 1: Get the Notion page\n const pageResult = await notionService.getNotionPage(pageId);\n\n if (!pageResult.success) {\n return {\n success: false,\n error: \"Failed to fetch Notion page\",\n details: pageResult.error\n };\n }\n\n // Step 2: Extract domain from Name property (title type)\n const domain = pageResult.data?.properties?.Name?.title?.[0]?.plain_text;\n\n if (!domain || typeof domain !== 'string' || domain.trim() === '') {\n const errorMessage = \"⚠️ Favicon update failed: Name property not found or empty\";\n\n // Append error note to page\n await notionService.appendBlockToPage(pageId, errorMessage);\n\n return {\n success: false,\n iconUpdated: false,\n errorNoteAdded: true,\n error: \"Name property not found or empty\"\n };\n }\n\n // Step 3: Fetch favicon from Faviconizer\n const faviconResult = await faviconizerService.getFaviconForDomain(domain);\n\n if (!faviconResult.success || !faviconResult.data?.faviconUrl) {\n const errorMessage = `⚠️ Favicon update failed: Could not fetch favicon for domain '${domain}'. Error: ${faviconResult.error}`;\n\n // Append error note to page\n await notionService.appendBlockToPage(pageId, errorMessage);\n\n return {\n success: false,\n iconUpdated: false,\n errorNoteAdded: true,\n error: \"Failed to fetch favicon\",\n details: faviconResult.error\n };\n }\n\n // Step 4: Update page icon\n const iconUpdateResult = await notionService.updatePageIcon(pageId, faviconResult.data.faviconUrl);\n\n if (!iconUpdateResult.success) {\n const errorMessage = `⚠️ Favicon update failed for domain '${domain}': Could not update page icon. Error: ${iconUpdateResult.error}`;\n\n // Append error note to page\n await notionService.appendBlockToPage(pageId, errorMessage);\n\n return {\n success: false,\n iconUpdated: false,\n errorNoteAdded: true,\n error: \"Failed to update page icon\",\n details: iconUpdateResult.error\n };\n }\n\n // Success! Append success note to page\n const successMessage = `✅ Favicon successfully updated for domain: ${domain}`;\n const appendResult = await notionService.appendBlockToPage(pageId, successMessage);\n\n return {\n success: true,\n iconUpdated: true,\n errorNoteAdded: false,\n successNoteAdded: appendResult.success\n };\n}\n",[],[209,653,688],"1cb94fca-b360-11f0-bc6f-0224a6c84d84",["D",1761588582800],[234,235,236,237,238,239],[209,653],["D",1761588582800],[233,240,243,255,265,274],[209],"1cb93d82-b360-11f0-bc6f-0224a6c84d84","settings.local.json","019a26dc-99bf-7269-a8f5-ec22817c2d0b",["D",1761588582800],"{\n \"permissions\": {\n \"allow\": [\n \"Bash(cat:*)\"\n ],\n \"deny\": [],\n \"ask\": []\n }\n}\n",[],[214,703],["D",1761588582800],[231],[214],["D",1761588582800],["D",1789527031073],{"_104":103,"_111":107},{"_104":103,"_105":-5,"_106":107,"_18":55,"_108":109,"_110":25},{"_13":89,"_32":90,"_44":43,"_91":45,"_92":93,"_94":95,"_96":97,"_98":99,"_100":65,"_101":46,"_102":103},"ctx",{"_82":-5,"_132":750,"_751":752,"_753":754,"_755":25,"_756":25,"_757":25,"_758":59,"_759":-5,"_760":-7,"_761":-7,"_762":63,"_763":25,"_764":25,"_765":-5,"_766":25,"_767":25,"_768":25,"_769":-5},"ENV",{"_721":722,"_723":724,"_725":90,"_726":727,"_728":729,"_730":731,"_732":733,"_734":735,"_736":737,"_738":739,"_740":741,"_742":743,"_744":745,"_746":747,"_748":749},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"] </article></body></html>

Diff · v170