${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",[],[152,254],{"_106":262,"_99":263,"_153":264,"_155":154,"_156":142,"_157":158,"_159":122,"_108":265,"_103":33,"_161":184,"_163":266,"_164":27,"_165":-5,"_166":267,"_102":268},"f88f4d18-1a1a-11f0-9377-569c3dd06744","test-routes.ts","f88f4d86-1a1a-11f0-9377-569c3dd06744",["D",1744736358994],"import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.post(\"/asdf\", async (c) => {\n const requestData = await c.req.json();\n console.log(requestData);\n return c.json({ ok: true });\n});\n\napp.post(\"/qwer/:id\", async (c) => {\n const action = c.req.param(\"id\");\n console.log({ action });\n return c.json({ action });\n});\n\napp.post(\"/test/:id\", async (c) => {\n const requestData = await c.req.json();\n const id = c.req.param(\"id\");\n\n // Make internal requests to other routes\n await app.request(\"/asdf\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(requestData),\n });\n\n await app.request(\"/qwer/\" + id, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(requestData),\n });\n \n return c.json({ ok: true, id });\n});\n\nexport default app;",[],[152,263],[152],{"_106":271,"_99":272,"_153":273,"_155":-5,"_156":142,"_157":174,"_159":122,"_108":274,"_103":33,"_161":162,"_163":-5,"_164":27,"_165":-5,"_166":275,"_102":296},"d81a69ba-1613-11f0-91f5-569c3dd06744","utils","1a8e7db7-a152-474a-bbec-98fe46feebd6",["D",1744293493384],[276,286],{"_106":277,"_99":278,"_153":279,"_155":273,"_156":142,"_157":280,"_159":122,"_108":281,"_103":282,"_161":184,"_163":283,"_164":27,"_165":-5,"_166":284,"_102":285},"42712cda-1f8e-11f0-a119-569c3dd06744","helpers.ts","a90c4a83-fbd9-4f81-a12d-b478c179bff4",1072,["D",1745335630890],15,"export async function setBlobKey(object: any) {\n const { slug, clientPageId, containerId } = object;\n const blobKey = [ // key_legend: \"[subdomain]--[id of guest page]--[id of container to be reset]\",\n slug.split(\".\")[0], // subdomain name minus .val.run\n clientPageId.replaceAll(\"-\", \"\"), // remove hyphens from ids\n containerId,\n ].join(\"--\");\n\n // console.log(blobKey);\n return blobKey;\n}\n\nexport async function slugify(str: string) {\n // const containerTitleSlug = (await helpers.setContainerTitle(c.req.headers.get(\"x-container-title\"))).split(\" \").join(\"-\");\n return (str.replace(/[^\\w\\s]|_/g, \"\").replace(/\\s+/g, \" \").trim().toLowerCase()).split(\" \").join(\"-\");\n}\n\n// Function to scrape favicon URL from a website\nexport async function scrapeFaviconUrl(url: string) {\n try {\n // Ensure URL has protocol\n if (!url.startsWith(\"http://\") && !url.startsWith(\"https://\")) {\n url = \"https://\" + url;\n }\n\n // Parse the URL to get the origin\n const parsedUrl = new URL(url);\n const origin = parsedUrl.origin;\n\n // Fetch the HTML from the URL\n const response = await fetch(url);\n const html = await response.text();\n\n // Find favicon links in the HTML\n // Using regex patterns to find icon link tags\n let faviconUrl = null;\n\n // Look for link tags with rel=\"icon\" or similar\n const iconRegex = /]*rel=[\"'](?:icon|shortcut icon|apple-touch-icon)[^>]*href=[\"']([^\"']+)[\"'][^>]*>/gi;\n const matches = html.matchAll(iconRegex);\n\n for (const match of matches) {\n if (match && match[1]) {\n faviconUrl = match[1];\n break;\n }\n }\n\n // If we didn't find an icon in link tags, try the default location\n if (!faviconUrl) {\n faviconUrl = \"/favicon.ico\";\n }\n\n // Make sure the URL is absolute\n if (!faviconUrl.startsWith(\"http://\") && !faviconUrl.startsWith(\"https://\")) {\n if (faviconUrl.startsWith(\"/\")) {\n faviconUrl = origin + faviconUrl;\n } else {\n faviconUrl = origin + \"/\" + faviconUrl;\n }\n }\n\n // Verify the favicon exists\n const faviconResponse = await fetch(faviconUrl, { method: \"HEAD\" });\n\n if (!faviconResponse.ok) {\n return null; // Favicon not found\n }\n\n return faviconUrl;\n } catch (error) {\n console.error(\"Error scraping favicon:\", error);\n return null;\n }\n}\n\nexport async function extractCamelCaseWords(str: string) {\n if (!str) return [];\n\n // This regex looks for word boundaries:\n // - Start of string\n // - Transitions from lowercase to uppercase\n const words = str.split(/(?=[A-Z])/).map(word => word.toLowerCase());\n const watchWords = [\"favicon\", \"team\", \"invoice\", \"estimate\"];\n\n // Remove words that are not in the watchWords array\n words.forEach((word, index) => {\n if (!watchWords.includes(word)) {\n words.splice(index, 1);\n }\n });\n return words;\n}",[],[272,278],{"_106":287,"_99":288,"_153":289,"_155":273,"_156":142,"_157":290,"_159":122,"_108":291,"_103":292,"_161":184,"_163":293,"_164":27,"_165":-5,"_166":294,"_102":295},"722832be-1f90-11f0-b491-569c3dd06744","notionHelpers.ts","a84009c8-6837-4608-99c6-dd3af25a5925",1080,["D",1745336569938],130,"import { Client } from \"npm:@notionhq/client\";\nimport * as helpers from \"./helpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport async function createDatabasePagesParallel(databaseId: string, pages: []) {\n const creations = pages.map((page) =>\n notion.pages.create({\n parent: { database_id: databaseId },\n properties: {\n \"Website\": {\n \"title\": [\n {\n \"text\": {\n \"content\": page.domain,\n },\n },\n ],\n },\n \"Description\": {\n \"rich_text\": [\n {\n \"text\": {\n \"content\": page.description,\n },\n },\n ],\n },\n Status: {\n \"select\": {\n \"name\": page.status,\n },\n },\n },\n })\n );\n const results = await Promise.allSettled(creations);\n return results;\n}\n\n// delete all database rows\nexport async function deleteAllDatabasePagesParallel(databaseId: string) {\n const pageIds = await notion.databases.query({\n database_id: databaseId,\n });\n // Step 2: Delete all pages in parallel\n const deletions = pageIds.results.map((page) =>\n notion.pages.update({\n page_id: page.id,\n archived: true,\n })\n );\n // Wait for all deletions to complete (even if some fail)\n const results = await Promise.allSettled(deletions);\n return results;\n}\n\nexport async function getDatabaseId(databaseTitle: string) {\n // getDatabaseId(databaseTitle)\n const database = await notion.databases\n .query({ filter: { property: \"title\", title: { equals: databaseTitle } } });\n return database.results[0].id;\n}\n\nexport async function getDatabaseTitle(databaseId: string) {\n // getDatabaseTitle(databaseId)\n const database = await notion.databases.retrieve({ database_id: databaseId });\n // console.log(database.title[0].plain_text);\n return database.title[0].plain_text;\n}\n\nexport async function getDatabaseParentPageId(databaseId: string) {\n let currentBlockId = databaseId;\n\n while (true) {\n const block = await notion.blocks.retrieve({ block_id: currentBlockId });\n\n if (!block.parent) {\n throw new Error(`No parent found for block ${currentBlockId}`);\n }\n\n const parent = block.parent;\n\n if (parent.type === \"page_id\") {\n return parent.page_id;\n }\n\n if (parent.type === \"block_id\") {\n // Climb to the next parent block\n currentBlockId = parent.block_id;\n } else {\n throw new Error(`Unsupported parent type: ${parent.type}`);\n }\n }\n}\n\nexport async function getCalloutProperties(askingFor: string) {\n const blockProperties = (askingFor != \"val.town\")\n ? {\n \"icon\": {\n type: \"external\",\n external: {\n url: \"https://www.notion.so/icons/notion_blue.svg\",\n },\n },\n \"color\": \"default_background\",\n }\n : {\n \"icon\": {\n type: \"external\",\n external: {\n url: \"https://static.esm.town/build/_assets/vt-whiteOnBlack-VOLODW64.svg\",\n },\n },\n \"color\": \"yellow_background\",\n };\n return blockProperties;\n}\n\nexport async function findChildDatabaseBlocks(rootBlockId: string, blockIdentifier: string) {\n const matchingBlocks = [];\n\n async function searchBlock(blockId) {\n const res = await notion.blocks.children.list({ block_id: blockId });\n\n for (const block of res.results) {\n // if (\n // block.type === \"callout\" && block.callout?.rich_text?.[0]?.plain_text && (!block.archived || !block.in_trash)\n // ) {\n // const calloutText = await helpers.slugify(block.callout?.rich_text?.[0]?.plain_text.toLowerCase()) || \"\";\n // const identifier = await helpers.slugify(blockIdentifier?.toLowerCase());\n\n // if (calloutText === identifier) {\n // console.log(calloutText, identifier);\n // matchingBlocks.push(block);\n // }\n // }\n if (\n block.type === \"child_database\" && block.child_database?.title && (!block.archived || !block.in_trash)\n ) {\n const databaseTitle = await helpers.slugify(block.child_database?.title.toLowerCase()) || \"\";\n const identifier = await helpers.slugify(blockIdentifier?.toLowerCase());\n\n if (databaseTitle === identifier) {\n console.log(databaseTitle, identifier);\n matchingBlocks.push(block);\n }\n // console.log(block);\n // matchingBlocks.push(block);\n }\n\n // If the block has children, recurse\n if (block.has_children && matchingBlocks.length === 0) {\n await searchBlock(block.id);\n }\n }\n }\n\n await searchBlock(rootBlockId);\n\n return matchingBlocks;\n}\n\nexport async function findCalloutBlocks(rootBlockId: string, blockIdentifier: string) {\n const matchingBlocks = [];\n\n async function searchBlock(blockId) {\n const res = await notion.blocks.children.list({ block_id: blockId });\n\n for (const block of res.results) {\n // get callouts that are flagged with the val.town icon in this workspace\n // archived: false,\n // in_trash: false,\n if (\n block.type === \"callout\" && block.callout?.rich_text?.[0]?.plain_text && (!block.archived || !block.in_trash)\n ) {\n const calloutText = await helpers.slugify(block.callout?.rich_text?.[0]?.plain_text.toLowerCase()) || \"\";\n const identifier = await helpers.slugify(blockIdentifier?.toLowerCase());\n\n if (calloutText === identifier) {\n console.log(calloutText, identifier);\n matchingBlocks.push(block);\n }\n }\n\n // If the block has children, recurse\n // limit return to one item\n if (block.has_children && matchingBlocks.length === 0) {\n await searchBlock(block.id);\n }\n }\n }\n\n await searchBlock(rootBlockId);\n\n return matchingBlocks;\n}\n\nexport async function getBostonTime() {\n const now = new Date();\n\n const formattedDate = now.toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\",\n hour: \"numeric\",\n minute: \"numeric\",\n second: \"numeric\",\n });\n\n return `val.town says, \"It's ${formattedDate} in Boston.\"`;\n}\n\nexport async function listChildrenChildPages(blockId: string) {\n try {\n const response = await notion.blocks.children.list({\n block_id: blockId,\n });\n\n if (!response) {\n throw new Error(\"Failed to retrieve pages from Notion\");\n }\n const pages = response.results.filter((page) => page.type === \"child_page\");\n return pages;\n } catch (error) {\n console.error(`Error getting Notion pages that are children of ${blockId}:`, error);\n }\n}\n\nexport async function addFavicon(data?: any) {\n const pageId = data?.id;\n // use notion if nothing if the URL property is empty\n const url = await getWebhookPropertyValue(data, \"Website\") || \"notion.com\";\n // send the URL value to the function that will get the site's favicon location\n const faviconURL = await helpers.scrapeFaviconUrl(url);\n console.log({ \"Verified favicon URL\": faviconURL });\n // update the page icon\n await updatePageIcon(pageId, faviconURL);\n\n return pageId;\n}\n\nexport async function setPageStatus(object: any) {\n const { data, section, step } = object;\n const pageId = data?.id;\n // statuses are passed to val.town from Notion in the payload\n const statuses = await getWebhookPropertyValue(data, \"Statuses\");\n // loop through statuses to find items that have the section in their value\n const sectionStatuses = await statuses.split(\",\").filter(status => status.toLowerCase().includes(section));\n // console.log(sectionStatuses);\n const status = (() => {\n switch (step) {\n case \"first\":\n return sectionStatuses[0];\n case \"last\":\n return sectionStatuses[sectionStatuses.length - 1];\n default:\n return sectionStatuses[0];\n }\n })();\n console.log(status);\n\n try {\n const response = await notion.pages.update({\n page_id: pageId,\n properties: {\n Status: {\n select: {\n name: status,\n },\n },\n },\n });\n if (!response) {\n throw new Error(\"Failed to update page in Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error updating Notion page ${pageId}:`, error);\n }\n}\n\nexport async function updatePageIcon(pageId: string, faviconURL?: string) {\n try {\n const response = await notion.pages.update({\n page_id: pageId,\n icon: {\n type: \"external\",\n external: {\n url: faviconURL,\n },\n },\n });\n if (!response) {\n throw new Error(\"Failed to update page in Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error updating Notion page ${pageId}:`, error);\n }\n}\n\nexport async function listChildren(pageId: string) {\n // get page properties\n try {\n const response = await notion.blocks.children.list({\n block_id: pageId,\n });\n\n if (!response) {\n throw new Error(\"Failed to retrieve pages from Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error getting Notion pages that are children of ${pageId}:`, error);\n }\n}\n\n// Helper function to get property value from webhook payload\nexport async function getWebhookPropertyValue(payload: any, propertyName: any) {\n let result = null;\n // check to see if the whole payload was sent, or just the data object\n const properties = payload.data?.properties || payload.properties;\n\n if (properties) {\n const property = properties[propertyName];\n\n if (property) {\n // Different property types have different value structures\n switch (property.type) {\n case \"select\":\n result = property.select?.name;\n break;\n case \"formula\":\n result = property.formula?.string;\n break;\n case \"rich_text\":\n result = property.rich_text?.[0]?.plain_text;\n break;\n case \"title\":\n result = property.title?.[0]?.plain_text;\n break;\n case \"url\":\n result = property.url;\n break;\n case \"text\":\n result = property.text?.content;\n break;\n default:\n result = property.value;\n }\n }\n }\n\n return result;\n}\n\nexport async function getNotionPage(pageId: string) {\n // get page properties\n try {\n const response = await notion.pages.retrieve({\n page_id: pageId,\n });\n if (!response) {\n throw new Error(\"Failed to retrieve page from Notion\");\n }\n return response;\n } catch (error) {\n console.error(`Error getting Notion page ${pageId}:`, error);\n }\n}",[],[272,288],[272],{"_106":298,"_99":170,"_153":299,"_155":-5,"_156":142,"_157":300,"_159":122,"_108":301,"_103":302,"_161":175,"_163":303,"_164":27,"_165":-5,"_166":304,"_102":305},"fd611a4a-1edb-11f0-aa0d-569c3dd06744","bb208386-19eb-11f0-83c4-569c3dd06744",826,["D",1745259064604],10,"# ValTownForNotion\n\nThis val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\n\nHere's one of the examples, which uses val.town to update database pages with favicons from the web:\n\n![valtown-for-notion-example.gif](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a050f132-f6da-4af8-d0b3-ae8c60783900/public)\n\nRead up on it and try the examples:\n[https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4](https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4)\n\n## Handling Notion Webhooks\n\nThis is done in the webhookAPI file.\n\n## Resetting state\n\nEvery minute, this project has a cron that resets all the state, so that the next visitor to the Notion page has a clean experience. That cron uses the subdomain as the prefix for all the blob storage.\n\n![image.png](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a8afa60b-7ff7-4707-b07b-6011b8e2b700/public)",[],[170],{"_106":307,"_99":308,"_153":309,"_155":-5,"_156":142,"_157":310,"_159":122,"_108":311,"_103":312,"_161":313,"_163":314,"_164":27,"_165":-5,"_166":315,"_102":316},"4ec1dc34-1fd7-11f0-87f1-569c3dd06744","resets","44079c53-27a5-4518-9b07-d4566db58bb1",1112,["D",1745367004813],149,"interval","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // reset via the API\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API resets the blocks on notion pages, and also knows what to do with the blob\n // (note the x-blob-key header)\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else { // if the block is not archived (ie, archived: true), clean up the blob\n console.log(block.id, block.type, \" is gone!\", \"archived:\" + block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n console.log(await blob.getJSON(item.key));\n }\n }\n}",[],[308],{"_106":318,"_99":319,"_153":120,"_155":-5,"_156":142,"_157":172,"_159":122,"_108":320,"_103":321,"_161":322,"_163":323,"_164":27,"_165":324,"_166":325,"_102":326},"7ab52da6-2111-11f0-8da8-569c3dd06744","webhookAPI",["D",1745501940517],617,"http","import { Hono } from \"npm:hono@3\";\n// import { cors } from \"npm:hono@3/cors\";\n\n// Import route modules\nimport auth from \"./routes/auth.ts\";\nimport countExamples from \"./routes/count-examples.ts\";\nimport exampleCallout from \"./routes/example-callout.ts\";\nimport exampleChildPages from \"./routes/example-child-pages.ts\";\nimport exampleDatabasePage from \"./routes/example-database-page.ts\";\nimport exampleDatabasePages from \"./routes/example-database-pages.ts\";\nimport exampleGuestWelcome from \"./routes/example-guest-welcome.ts\";\nimport propertyInjections from \"./routes/property-injections.ts\";\nimport root from \"./routes/root.ts\";\nimport testRoutes from \"./routes/test-routes.ts\";\n\n// Create main app\nconst app = new Hono();\n\n// Mount root route\napp.route(\"/\", root);\n\n// Apply authentication middleware to all routes\napp.use(\"*\", auth);\n\n// Mount route modules\napp.route(\"/example/database/pages\", exampleDatabasePages);\napp.route(\"/example/database/page\", exampleDatabasePage);\napp.route(\"/example/child_pages\", exampleChildPages);\napp.route(\"/example/callout\", exampleCallout);\napp.route(\"/example/guest/welcome\", exampleGuestWelcome);\napp.route(\"/countExamples\", countExamples);\napp.route(\"/property/injections\", propertyInjections);\n\n// Mount test routes - these include /asdf, /qwer/:id, and /test/:id\napp.route(\"/\", testRoutes);\n\n/* this should go up just after initializing hono, if enabling cors\napp.use(\n \"/*\",\n cors({\n origin: [\"https://notion.so\", \"https://notion.com\"],\n }),\n);\napp.post(\"/test/button\", async (c) => {\n // console.log(await c);\n // console.log(await c.req.json());\n console.log(await c.res);\n console.log(await c.res.headers);\n return c.json({ ok: true });\n});\n*/\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\nexport default app.fetch;","valtownfornotion",[],[319],"files",[150,168,179,188,196,206,216,226,236,244,252,261,270,276,286,297,306,317],"counts",{"_331":33,"_332":212,"_333":126,"_334":126},"pulls","branches","forks","envVars","contents",[337,340,343,346,349],{"_106":151,"_99":152,"_153":154,"_155":-5,"_156":142,"_157":158,"_159":122,"_108":338,"_103":33,"_161":162,"_163":-5,"_164":27,"_165":-5,"_102":339},["D",1744736358994],[152],{"_106":271,"_99":272,"_153":273,"_155":-5,"_156":142,"_157":174,"_159":122,"_108":341,"_103":33,"_161":162,"_163":-5,"_164":27,"_165":-5,"_102":342},["D",1744293493384],[272],{"_106":298,"_99":170,"_153":299,"_155":-5,"_156":142,"_157":300,"_159":122,"_108":344,"_103":302,"_161":175,"_163":303,"_164":27,"_165":-5,"_102":345},["D",1745259064604],[170],{"_106":307,"_99":308,"_153":309,"_155":-5,"_156":142,"_157":310,"_159":122,"_108":347,"_103":312,"_161":313,"_163":314,"_164":27,"_165":-5,"_102":348},["D",1745367004813],[308],{"_106":318,"_99":319,"_153":120,"_155":-5,"_156":142,"_157":172,"_159":122,"_108":350,"_103":321,"_161":322,"_163":323,"_164":27,"_165":324,"_102":351},["D",1745501940517],[319],"upstream","screenshots",{"_355":356,"_357":358},"thumbnail","https://screenshots.valtown.net/screenshot.png?width=1024&height=768&version=812&url=https%3A%2F%2Fbradnoble--6b696612f13d46cca0c0612473883f2c.web.val.run","preview","https://screenshots.valtown.net/screenshot.png?width=1920&height=1080&version=812&url=https%3A%2F%2Fbradnoble--6b696612f13d46cca0c0612473883f2c.web.val.run","emptyEnvVars","routes/_app.x.$handle.$name.branch.$branch.history",{"_97":98,"_99":100,"_101":43,"_104":362,"_366":367,"_620":33,"_621":122},{"_106":107,"_99":100,"_108":363,"_110":-5,"_111":27,"_112":113,"_114":115,"_116":117,"_12":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":128,"_130":131,"_132":131,"_133":131,"_134":128,"_135":27,"_21":364,"_139":365},["D",1744293493384],{"_97":98,"_137":138},{"_103":141,"_99":43,"_106":142,"_143":107,"_144":-5,"_145":-5,"_146":-5,"_147":-5},"history",[368,373,382,391,399,407,416,425,434,443,451,460,468,476,484,498,503,512,521,530,539,548,557,566,575,584,593,602,611],{"_153":255,"_103":141,"_108":369,"_156":142,"_327":370},["D",1745504421946],[371],{"_106":253,"_156":142,"_153":255,"_99":254,"_163":258,"_161":184,"_103":257,"_155":154,"_108":369,"_157":141,"_165":-5,"_159":122,"_164":27,"_102":372},[152,254],{"_153":255,"_103":374,"_108":375,"_156":142,"_327":376},1126,["D",1745504408784],[377],{"_106":378,"_156":142,"_153":255,"_99":254,"_163":379,"_161":184,"_103":380,"_155":154,"_108":375,"_157":374,"_165":-5,"_159":27,"_164":27,"_102":381},"39e83a56-2117-11f0-abdb-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README and get started at the link.\",\n url: notionURL,\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",13,[152,254],{"_153":255,"_103":383,"_108":384,"_156":142,"_327":385},1125,["D",1745504402438],[386],{"_106":387,"_156":142,"_153":255,"_99":254,"_163":388,"_161":184,"_103":389,"_155":154,"_108":384,"_157":383,"_165":-5,"_159":27,"_164":27,"_102":390},"3621589e-2117-11f0-bf12-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README or get started at the link.\",\n url: notionURL,\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",12,[152,254],{"_153":255,"_103":392,"_108":393,"_156":142,"_327":394},1124,["D",1745504395781],[395],{"_106":396,"_156":142,"_153":255,"_99":254,"_163":258,"_161":184,"_103":397,"_155":154,"_108":393,"_157":392,"_165":-5,"_159":27,"_164":27,"_102":398},"32279dac-2117-11f0-8c63-569c3dd06744",11,[152,254],{"_153":255,"_103":400,"_108":401,"_156":142,"_327":402},1123,["D",1745504379900],[403],{"_106":404,"_156":142,"_153":255,"_99":254,"_163":405,"_161":184,"_103":302,"_155":154,"_108":401,"_157":400,"_165":-5,"_159":27,"_164":27,"_102":406},"28b054c6-2117-11f0-bb59-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README.\",\n link: notionURL,\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",[152,254],{"_153":255,"_103":408,"_108":409,"_156":142,"_327":410},1122,["D",1745504374694],[411],{"_106":412,"_156":142,"_153":255,"_99":254,"_163":413,"_161":184,"_103":414,"_155":154,"_108":409,"_157":408,"_165":-5,"_159":27,"_164":27,"_102":415},"25961db6-2117-11f0-aad0-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README.\"\n link: notionURL,\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",9,[152,254],{"_153":255,"_103":417,"_108":418,"_156":142,"_327":419},1121,["D",1745504317076],[420],{"_106":421,"_156":142,"_153":255,"_99":254,"_163":422,"_161":184,"_103":423,"_155":154,"_108":418,"_157":417,"_165":-5,"_159":27,"_164":27,"_102":424},"033e8f82-2117-11f0-aa4e-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README or here: \" + notionURL,\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",8,[152,254],{"_153":255,"_103":426,"_108":427,"_156":142,"_327":428},1120,["D",1745504053781],[429],{"_106":430,"_156":142,"_153":255,"_99":254,"_163":431,"_161":184,"_103":432,"_155":154,"_108":427,"_157":426,"_165":-5,"_159":27,"_164":27,"_102":433},"664ee85c-2116-11f0-b192-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README.\",\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.json(content);\n});\n\nexport default app;",7,[152,254],{"_153":255,"_103":435,"_108":436,"_156":142,"_327":437},1119,["D",1745503853839],[438],{"_106":439,"_156":142,"_153":255,"_99":254,"_163":440,"_161":184,"_103":441,"_155":154,"_108":436,"_157":435,"_165":-5,"_159":27,"_164":27,"_102":442},"ef21f49a-2115-11f0-b11c-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README.\",\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.html(html);\n});\n\nexport default app;",6,[152,254],{"_153":255,"_103":444,"_108":445,"_156":142,"_327":446},1118,["D",1745503833561],[447],{"_106":448,"_156":142,"_153":255,"_99":254,"_163":449,"_161":184,"_103":212,"_155":154,"_108":445,"_157":444,"_165":-5,"_159":27,"_164":27,"_102":450},"e30c2f5e-2115-11f0-a331-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"👋 Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README.\",\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.html(html);\n});\n\nexport default app;",[152,254],{"_153":255,"_103":452,"_108":453,"_156":142,"_327":454},1117,["D",1745503763005],[455],{"_106":456,"_156":142,"_153":255,"_99":254,"_163":457,"_161":184,"_103":458,"_155":154,"_108":453,"_157":452,"_165":-5,"_159":27,"_164":27,"_102":459},"b8fed978-2115-11f0-bf5b-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"Welcome to the root API endpoint of this Hono app, running on val.town\",\n message: \"Find more detail in the README.\",\n // This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n // cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.html(html);\n});\n\nexport default app;",4,[152,254],{"_153":255,"_103":461,"_108":462,"_156":142,"_327":463},1116,["D",1745503697672],[464],{"_106":465,"_156":142,"_153":255,"_99":254,"_163":466,"_161":184,"_103":126,"_155":154,"_108":462,"_157":461,"_165":-5,"_159":27,"_164":27,"_102":467},"920d0376-2115-11f0-b0d4-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"Welcome to the root API endpoint of this Hono app, running on val.town\",\n message:\n \"There's more detail in the README. This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n // html += `

${content.message}

`;\n // html += `

${content.cta}

`;\n // html += `${notionURL}`;\n\n return c.html(html);\n});\n\nexport default app;",[152,254],{"_153":255,"_103":469,"_108":470,"_156":142,"_327":471},1115,["D",1745503661424],[472],{"_106":473,"_156":142,"_153":255,"_99":254,"_163":474,"_161":184,"_103":94,"_155":154,"_108":470,"_157":469,"_165":-5,"_159":27,"_164":27,"_102":475},"7c718410-2115-11f0-8d43-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline: \"Welcome to the root API endpoint of this Hono app, running on val.town\",\n message:\n \"There's more detail in the README. This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n html += `

${content.cta}

`;\n html += `${notionURL}`;\n\n return c.html(html);\n});\n\nexport default app;",[152,254],{"_153":255,"_103":477,"_108":478,"_156":142,"_327":479},1114,["D",1745503570718],[480],{"_106":481,"_156":142,"_153":255,"_99":254,"_163":482,"_161":184,"_103":174,"_155":154,"_108":478,"_157":477,"_165":-5,"_159":27,"_164":27,"_102":483},"46615b52-2115-11f0-9d1c-569c3dd06744","import { Hono } from \"npm:hono@3\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n // create a single page react app that is deployed at this endpoint\n const valTownURL = import.meta.url;\n const notionURL = \"https://www.notion.so/bradnoble/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9\";\n\n const content = {\n headline:\n \"Hi! This is not the README, it just pops up here b/c you're viewing the root API endpoint of this Hono app.\",\n message:\n \"This val.town project catches webhooks from Notion, makes changes to the data payload, and sends those changes back to Notion as page updates.\",\n cta: \"Read up on it and try the examples: \",\n };\n\n let html = `

${content.headline}

`;\n html += `

${content.message}

`;\n html += `

${content.cta}

`;\n html += `${notionURL}`;\n\n return c.html(html);\n});\n\nexport default app;",[152,254],{"_153":120,"_103":172,"_108":485,"_156":142,"_327":486},["D",1745501940517],[487,489,492,495],{"_106":318,"_156":142,"_153":120,"_99":319,"_163":323,"_161":322,"_103":321,"_155":-5,"_108":485,"_157":172,"_165":324,"_159":122,"_164":27,"_102":488},[319],{"_106":169,"_156":142,"_153":171,"_99":170,"_163":176,"_161":175,"_103":174,"_155":154,"_108":490,"_157":172,"_165":-5,"_159":122,"_164":27,"_102":491},["D",1745501940517],[152,170],{"_106":237,"_156":142,"_153":239,"_99":238,"_163":241,"_161":184,"_103":33,"_155":154,"_108":493,"_157":172,"_165":-5,"_159":122,"_164":27,"_102":494},["D",1745501940517],[152,238],{"_106":245,"_156":142,"_153":247,"_99":246,"_163":249,"_161":184,"_103":33,"_155":154,"_108":496,"_157":172,"_165":-5,"_159":122,"_164":27,"_102":497},["D",1745501940517],[152,246],{"_153":309,"_103":310,"_108":499,"_156":142,"_327":500},["D",1745367004813],[501],{"_106":307,"_156":142,"_153":309,"_99":308,"_163":314,"_161":313,"_103":312,"_155":-5,"_108":499,"_157":310,"_165":-5,"_159":122,"_164":27,"_102":502},[308],{"_153":309,"_103":504,"_108":505,"_156":142,"_327":506},1111,["D",1745366474611],[507],{"_106":508,"_156":142,"_153":309,"_99":308,"_163":509,"_161":313,"_103":510,"_155":-5,"_108":505,"_157":504,"_165":-5,"_159":27,"_164":27,"_102":511},"12bb85ba-1fd6-11f0-a531-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // reset via the API\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API resets the blocks on notion pages, and also knows what to do with the blob\n // (note the x-blob-key header)\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else { // if the block is not archived (ie, archived: true), clean up the blob\n console.log(block.id, block.type, \" is gone!\", \"archived:\" + block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n console.log(await blob.getJSON(item.key));\n }\n }\n}",148,[308],{"_153":309,"_103":513,"_108":514,"_156":142,"_327":515},1110,["D",1745365947307],[516],{"_106":517,"_156":142,"_153":309,"_99":308,"_163":518,"_161":313,"_103":519,"_155":-5,"_108":514,"_157":513,"_165":-5,"_159":27,"_164":27,"_102":520},"d86f4b18-1fd4-11f0-8107-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // reset via the API\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API resets the blocks on notion pages, and also knows what to do with the blob\n // (note the x-blob-key header)\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else { // if the block is not archived (ie, archived: true), clean up the blob\n console.log(block.type, \" is gone!\", block.id, block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n console.log(await blob.getJSON(item.key));\n }\n }\n}",147,[308],{"_153":309,"_103":522,"_108":523,"_156":142,"_327":524},1109,["D",1745365878088],[525],{"_106":526,"_156":142,"_153":309,"_99":308,"_163":527,"_161":313,"_103":528,"_155":-5,"_108":523,"_157":522,"_165":-5,"_159":27,"_164":27,"_102":529},"af2d3440-1fd4-11f0-a1c6-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // reset via the API\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else { // if the block is not archived (ie, archived: true), clean up the blob\n console.log(block.type, \" is gone!\", block.id, block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n console.log(await blob.getJSON(item.key));\n }\n }\n}",146,[308],{"_153":309,"_103":531,"_108":532,"_156":142,"_327":533},1108,["D",1745365863577],[534],{"_106":535,"_156":142,"_153":309,"_99":308,"_163":536,"_161":313,"_103":537,"_155":-5,"_108":532,"_157":531,"_165":-5,"_159":27,"_164":27,"_102":538},"a687308e-1fd4-11f0-94f9-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else { // if the block is not archived (ie, archived: true), clean up the blob\n console.log(block.type, \" is gone!\", block.id, block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n console.log(await blob.getJSON(item.key));\n }\n }\n}",145,[308],{"_153":309,"_103":540,"_108":541,"_156":142,"_327":542},1107,["D",1745365547574],[543],{"_106":544,"_156":142,"_153":309,"_99":308,"_163":545,"_161":313,"_103":546,"_155":-5,"_108":541,"_157":540,"_165":-5,"_159":27,"_164":27,"_102":547},"ea2cd574-1fd3-11f0-93ce-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else {\n console.log(block.type, \" is gone!\", block.id, block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n console.log(await blob.getJSON(item.key));\n }\n }\n}",144,[308],{"_153":309,"_103":549,"_108":550,"_156":142,"_327":551},1106,["D",1745365526536],[552],{"_106":553,"_156":142,"_153":309,"_99":308,"_163":554,"_161":313,"_103":555,"_155":-5,"_108":550,"_157":549,"_165":-5,"_159":27,"_164":27,"_102":556},"dda32fa6-1fd3-11f0-ac63-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else {\n console.log(block.type, \" is gone!\", block.id, block.archived);\n // delete the blob\n await blob.delete(item.key);\n console.log(\"deleted: \", item.key);\n }\n }\n}",143,[308],{"_153":309,"_103":558,"_108":559,"_156":142,"_327":560},1105,["D",1745365498287],[561],{"_106":562,"_156":142,"_153":309,"_99":308,"_163":563,"_161":313,"_103":564,"_155":-5,"_108":559,"_157":558,"_165":-5,"_159":27,"_164":27,"_102":565},"cccc1544-1fd3-11f0-914d-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n } else {\n console.log(block.type, \" is gone!\", block.id, block.archived);\n // delete the blob\n await blob.delete(item.key);\n }\n }\n}",142,[308],{"_153":309,"_103":567,"_108":568,"_156":142,"_327":569},1104,["D",1745365444775],[570],{"_106":571,"_156":142,"_153":309,"_99":308,"_163":572,"_161":313,"_103":573,"_155":-5,"_108":568,"_157":567,"_165":-5,"_159":27,"_164":27,"_102":574},"ace6c814-1fd3-11f0-a598-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // if the block associated to this blob no longer exists in notion\n // the blob should be deleted; the block id is in lastRun.id\n // and can be either a callout block or a child_database\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) { // ie, archived: false in the json\n // console.log(block.type, \" exists!\", block.id, block.archived);\n // the block exists, so you can do the reset\n } else {\n console.log(block.type, \" is gone!\", block.id, block.archived);\n // delete the blob\n // await blob.delete(item.key);\n }\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n }\n}",141,[308],{"_153":309,"_103":576,"_108":577,"_156":142,"_327":578},1103,["D",1745361952571],[579],{"_106":580,"_156":142,"_153":309,"_99":308,"_163":581,"_161":313,"_103":582,"_155":-5,"_108":577,"_157":576,"_165":-5,"_159":27,"_164":27,"_102":583},"8b628be0-1fcb-11f0-8868-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // EXAMPLE BLOCK EXISTS?\n // could be gone if the user deleted it\n // especially during dev\n // if the block or the page doesn't exist, the blob should be deleted\n // get notion block, which is in the lastRun.id\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) {\n console.log(block.type, \" exists!\", block.id, block.archived);\n // delete the blob\n // await blob.delete(item.key);\n } else {\n console.log(block.type, \" is gone!\", block.id, block.archived);\n }\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n }\n}",140,[308],{"_153":309,"_103":585,"_108":586,"_156":142,"_327":587},1102,["D",1745361949315],[588],{"_106":589,"_156":142,"_153":309,"_99":308,"_163":590,"_161":313,"_103":591,"_155":-5,"_108":586,"_157":585,"_165":-5,"_159":27,"_164":27,"_102":592},"8971ff46-1fcb-11f0-80ac-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // EXAMPLE BLOCK EXISTS?\n // could be gone if the user deleted it\n // especially during dev\n // if the block or the page doesn't exist, the blob should be deleted\n // get notion block, which is in the lastRun.id\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) {\n console.log(block.type, \"exists!\", block.id, block.archived);\n // delete the blob\n // await blob.delete(item.key);\n } else {\n console.log(block.type, \"is gone!\", block.id, block.archived);\n }\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n }\n}",139,[308],{"_153":309,"_103":594,"_108":595,"_156":142,"_327":596},1101,["D",1745361866740],[597],{"_106":598,"_156":142,"_153":309,"_99":308,"_163":599,"_161":313,"_103":600,"_155":-5,"_108":595,"_157":594,"_165":-5,"_159":27,"_164":27,"_102":601},"5839e9fc-1fcb-11f0-bfbd-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // EXAMPLE BLOCK EXISTS?\n // could be gone if the user deleted it\n // especially during dev\n // if the block or the page doesn't exist, the blob should be deleted\n // get notion block, which is in the lastRun.id\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) {\n console.log(\"block exists!\", block.id, block.archived);\n // delete the blob\n // await blob.delete(item.key);\n } else {\n console.log(\"block is gone!\", block.id, block.archived);\n }\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n }\n}",138,[308],{"_153":309,"_103":603,"_108":604,"_156":142,"_327":605},1100,["D",1745361846655],[606],{"_106":607,"_156":142,"_153":309,"_99":308,"_163":608,"_161":313,"_103":609,"_155":-5,"_108":604,"_157":603,"_165":-5,"_159":27,"_164":27,"_102":610},"4c42333e-1fcb-11f0-86bf-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // BLOCK EXISTS?\n // could be gone if the user deleted it\n // especially if that was done during dev\n // if the block or the page doesn't exist, the blob should be deleted\n // get notion block, which is in the lastRun.id\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) {\n console.log(\"block exists!\", block.id, block.archived);\n // delete the blob\n // await blob.delete(item.key);\n } else {\n console.log(\"block is gone!\", block.id, block.archived);\n }\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n }\n}",137,[308],{"_153":309,"_103":612,"_108":613,"_156":142,"_327":614},1099,["D",1745361790609],[615],{"_106":616,"_156":142,"_153":309,"_99":308,"_163":617,"_161":313,"_103":618,"_155":-5,"_108":613,"_157":612,"_165":-5,"_159":27,"_164":27,"_102":619},"2ad93d78-1fcb-11f0-9767-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nexport default async function(interval: Interval) {\n const subdomain = \"valtownfornotion\";\n const items = await blob.list(subdomain);\n\n for (const item of items) {\n // get data from last run in the blob\n const lastRun = await blob.getJSON(item.key);\n const lastRunAt = new Date(lastRun?.date);\n const content = lastRun?.content;\n // const fetchURL = \"https://\" + item.key;\n const fetchURL = [\n \"https://\" + subdomain + \".val.run\",\n lastRun?.path,\n ].join(\"\");\n\n // make sure that the lastRunAt isn't recent\n // so that you don't end up switching page content underneath a user\n const now = new Date();\n const diffInMs = Math.abs(now - lastRunAt);\n const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ diffInMinutes });\n\n // TODO: check to make sure the block exists?\n // could be gone if the user deleted it\n // especially if that was done during dev\n // if the block or the page doesn't exist, the blob should be deleted\n // get notion block, which is in the lastRun.id\n const block = await notion.blocks.retrieve({ block_id: lastRun?.id });\n // console.log(block);\n if (!block.archived) {\n console.log(\"block exists!\", block.id, block.archived);\n // delete the blob\n // await blob.delete(item.key);\n } else {\n console.log(\"block is gone!\", block.id, block.archived);\n }\n\n // RESET\n // use the API, instead of hitting Notion directly like we do from the routes\n // this way we keep the notion data and the blob data (our cache) in sync\n // the API knows what to do with the blob that's at the x-blob-key\n if (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-asking-for\": \"default\",\n \"x-blob-key\": item.key,\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify({\n data: {\n id: lastRun?.user?.page_id,\n },\n }),\n });\n }\n }\n}",136,[308],"page","hasNext","routes/_app","actionData","errors"]

History