${content.headline}

`;\n html += `

${content.message}

`;\n html += `

${content.cta}

`;\n html += `${notionURL}`;\n\n return c.html(html);\n});\n\nexport default app;",[],[157,240],{"_103":248,"_95":249,"_158":250,"_160":159,"_161":139,"_162":251,"_164":117,"_105":252,"_100":32,"_166":189,"_168":253,"_169":22,"_170":-5,"_171":254,"_99":255},"43a513c6-1a18-11f0-a4a3-569c3dd06744","test-routes.ts","43a514a2-1a18-11f0-a4a3-569c3dd06744",17,["D",1744735196484],"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;",[],[157,249],[157],{"_103":258,"_95":259,"_158":260,"_160":-5,"_161":139,"_162":144,"_164":117,"_105":261,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":262,"_99":279},"24b41c98-1a16-11f0-835f-569c3dd06744","utils","5a5d7c80-895b-4a9c-8a3e-fd87e79ff9ad",["D",1744734285451],[263,271],{"_103":264,"_95":265,"_158":266,"_160":260,"_161":139,"_162":144,"_164":117,"_105":267,"_100":32,"_166":189,"_168":268,"_169":22,"_170":-5,"_171":269,"_99":270},"24b3f33a-1a16-11f0-835f-569c3dd06744","helpers.ts","eff0af6b-3ada-406b-83f4-154337a015f6",["D",1744734285451],"// 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}",[],[259,265],{"_103":272,"_95":273,"_158":274,"_160":260,"_161":139,"_162":144,"_164":117,"_105":275,"_100":32,"_166":189,"_168":276,"_169":22,"_170":-5,"_171":277,"_99":278},"24b41612-1a16-11f0-835f-569c3dd06744","notionHelpers.ts","ca6d991a-66a4-41e8-aa2d-e2b4a4e0caaa",["D",1744734285451],"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 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 setBlockContent(blockId: string, askingFor: string) {\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 const blockProperties = {\n \"val.town\": {\n content: `val.town says, \"It's ${formattedDate} in Boston.\"`,\n backgroundColor: \"yellow_background\",\n iconURL: \"https://static.esm.town/build/_assets/vt-whiteOnBlack-VOLODW64.svg\",\n },\n \"default\": {\n content: \"Notion says, \\\"I wish I could tell the reader what time it is in Boston.\\\"\",\n backgroundColor: \"default_background\",\n iconURL: \"https://www.notion.so/icons/notion_blue.svg\",\n },\n };\n\n const newBlock = await notion.blocks.update({\n \"block_id\": blockId, // globals.callout_block_id, // global block id\n \"callout\": {\n \"rich_text\": [\n {\n \"type\": \"text\",\n \"text\": {\n content: blockProperties[askingFor].content,\n },\n },\n ],\n color: blockProperties[askingFor].backgroundColor,\n icon: {\n type: \"external\",\n external: {\n url: blockProperties[askingFor].iconURL,\n },\n },\n },\n });\n return newBlock;\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 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}",[],[259,273],[259],{"_103":281,"_95":175,"_158":282,"_160":-5,"_161":139,"_162":283,"_164":117,"_105":284,"_100":285,"_166":179,"_168":286,"_169":22,"_170":-5,"_171":287,"_99":288},"8033a0f6-1a17-11f0-ba37-569c3dd06744","cac0e2e3-a882-441c-88c8-5ab5e18c43e1",10,["D",1744734868581],2,"# 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\nRead up on it and try the examples:\n\n[https://bradnoble.notion.site/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4](https://bradnoble.notion.site/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4)\n\n![image.png](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a8afa60b-7ff7-4707-b07b-6011b8e2b700/public)\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. The name of that cron is the same as the short subomain URL of the webhook URL so they can more easily coordianate and be kept in sync. That subdomain is also the prefix for all the blob storage.",[],[175],{"_103":290,"_95":291,"_158":292,"_160":-5,"_161":139,"_162":293,"_164":117,"_105":294,"_100":285,"_166":295,"_168":296,"_169":22,"_170":-5,"_171":297,"_99":298},"417c0c72-1a17-11f0-a192-569c3dd06744","valtownfornotion.val.run","19c333d6-1a17-11f0-9240-569c3dd06744",8,["D",1744734763359],"interval","import { blob } from \"https://esm.town/v/std/blob?v=12\";\n\nexport default async function(interval: Interval) {\n // Get the name of this file, ie \"valtownfornotion.val.run\".\n // This is the string at the beginning of each blob key\n const url = await import.meta.url;\n const subdomain = url.split(\"/\").pop();\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 console.log(item.key);\n console.log({ content });\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 (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"target_id\": lastRun.id, // custom header from Notion webhook, id of target block\n \"asking_for\": \"default\", // custom header from Notion webhook, reset content to the Notion default\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify(fetchURL),\n });\n }\n }\n}",[],[291],{"_103":300,"_95":301,"_158":302,"_160":-5,"_161":139,"_162":138,"_164":117,"_105":303,"_100":304,"_166":305,"_168":306,"_169":22,"_170":-5,"_171":307,"_99":308},"e492d610-1a18-11f0-8928-569c3dd06744","webhookAPI","841d3988-1a18-11f0-bfe9-569c3dd06744",["D",1744735466476],5,"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 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(\"/countExamples\", countExamples);\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;",[],[301],"files",[155,173,183,193,202,211,220,229,238,247,257,263,271,280,289,299],"counts",{"_313":32,"_314":285,"_315":32,"_316":317},"pulls","branches","forks","envVars",3,"contents",[320,323,326,329,332],{"_103":156,"_95":157,"_158":159,"_160":-5,"_161":139,"_162":163,"_164":117,"_105":321,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_99":322},["D",1744735147713],[157],{"_103":258,"_95":259,"_158":260,"_160":-5,"_161":139,"_162":144,"_164":117,"_105":324,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_99":325},["D",1744734285451],[259],{"_103":281,"_95":175,"_158":282,"_160":-5,"_161":139,"_162":283,"_164":117,"_105":327,"_100":285,"_166":179,"_168":286,"_169":22,"_170":-5,"_99":328},["D",1744734868581],[175],{"_103":290,"_95":291,"_158":292,"_160":-5,"_161":139,"_162":293,"_164":117,"_105":330,"_100":285,"_166":295,"_168":296,"_169":22,"_170":-5,"_99":331},["D",1744734763359],[291],{"_103":300,"_95":301,"_158":302,"_160":-5,"_161":139,"_162":138,"_164":117,"_105":333,"_100":304,"_166":305,"_168":306,"_169":22,"_170":-5,"_99":334},["D",1744735466476],[301],"upstreamProject",{"_103":147,"_95":96,"_111":337,"_112":338,"_109":110,"_23":339},"Augmenting Notion with webhooks and val.town.","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f25cb5fe-2b5b-4f08-5492-f088b3195400/square512",{"_93":340,"_131":341},"bradnoble","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ4YUNlWnM0S3Z6OWxiOUlLS25sWjNJWFhzSSJ9","upstreamBranch",{"_103":142,"_105":344,"_345":346,"_95":98,"_140":147,"_100":285,"_141":347,"_143":348,"_349":350,"_107":-5,"_152":22,"_109":110,"_151":340,"_16":149,"_150":96},["D",1744734161319],"updatedAt",["D",1744736039849],"d8176b5c-1613-11f0-91f5-569c3dd06744",817,"lockfileKey","1744736122975-esm.town_v_bradnoble_ValTownForNotion@2-SteveRefactor","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.compare.$branch",{"_93":94,"_95":96,"_97":98,"_101":357,"_362":32,"_363":32,"_364":365,"_456":117,"_457":361,"_458":459,"_462":-5},{"_103":104,"_95":96,"_105":358,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":115,"_116":117,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":359,"_133":360,"_136":361,"_152":22},["D",1744734285451],{"_93":94,"_131":132},{"_93":94,"_135":132},{"_100":138,"_95":98,"_103":139,"_140":104,"_141":142,"_143":144,"_145":110,"_146":147,"_148":149,"_150":96,"_151":94},"ahead","behind","diff",{"_366":367,"_169":419,"_420":421},"added",[368,374,379,384,389,394,399,404,409,414],{"_99":157,"_369":-7,"_370":371},"targetFile","sourceFile",{"_103":156,"_95":157,"_158":159,"_160":-5,"_161":139,"_162":163,"_164":117,"_105":165,"_100":32,"_166":167,"_168":-5,"_169":22,"_170":-5,"_171":-7,"_99":372,"_373":-5},[157],"contentHash",{"_99":375,"_369":-7,"_370":376},"routes/README.md",{"_103":174,"_95":175,"_158":176,"_160":159,"_161":139,"_162":177,"_164":117,"_105":178,"_100":32,"_166":179,"_168":180,"_169":22,"_170":-5,"_171":-7,"_99":377,"_373":378},[157,175],"5e6a6e55f7f0b7f2d2a968ee86113a02cbf3d9ef4621612f008fba8d8484e28e",{"_99":380,"_369":-7,"_370":381},"routes/auth.ts",{"_103":184,"_95":185,"_158":186,"_160":159,"_161":139,"_162":187,"_164":117,"_105":188,"_100":144,"_166":189,"_168":190,"_169":22,"_170":-5,"_171":-7,"_99":382,"_373":383},[157,185],"91b908cbfbd12ee6f43d4bcaf7fd665c8ab1c6651fbb962699906ca3219ec3a8",{"_99":385,"_369":-7,"_370":386},"routes/count-examples.ts",{"_103":194,"_95":195,"_158":196,"_160":159,"_161":139,"_162":197,"_164":117,"_105":198,"_100":32,"_166":189,"_168":199,"_169":22,"_170":-5,"_171":-7,"_99":387,"_373":388},[157,195],"f6228a8a4dcf664986588b29ded46da3a512e662377a50f37082f2ddb2c037fe",{"_99":390,"_369":-7,"_370":391},"routes/example-callout.ts",{"_103":203,"_95":204,"_158":205,"_160":159,"_161":139,"_162":206,"_164":117,"_105":207,"_100":32,"_166":189,"_168":208,"_169":22,"_170":-5,"_171":-7,"_99":392,"_373":393},[157,204],"59b2c093a3f211a8d3153df2a3a377a38fb8558efa8ffec37cf696d4eafe0f02",{"_99":395,"_369":-7,"_370":396},"routes/example-child-pages.ts",{"_103":212,"_95":213,"_158":214,"_160":159,"_161":139,"_162":215,"_164":117,"_105":216,"_100":32,"_166":189,"_168":217,"_169":22,"_170":-5,"_171":-7,"_99":397,"_373":398},[157,213],"3a2029f335bd9368eaf4d20c56b4751339e1c0b51a11f76fa16025b9e63c39d6",{"_99":400,"_369":-7,"_370":401},"routes/example-database-page.ts",{"_103":221,"_95":222,"_158":223,"_160":159,"_161":139,"_162":224,"_164":117,"_105":225,"_100":32,"_166":189,"_168":226,"_169":22,"_170":-5,"_171":-7,"_99":402,"_373":403},[157,222],"658a1c0c5f7bdcf34c0d7bf7cf464484363f35f3339a20de09b3f40130fee6f9",{"_99":405,"_369":-7,"_370":406},"routes/example-database-pages.ts",{"_103":230,"_95":231,"_158":232,"_160":159,"_161":139,"_162":233,"_164":117,"_105":234,"_100":32,"_166":189,"_168":235,"_169":22,"_170":-5,"_171":-7,"_99":407,"_373":408},[157,231],"7aa2e338c5b33cdda3137e203440c0660c82cc68562428cc89d9408b88ef07d0",{"_99":410,"_369":-7,"_370":411},"routes/root.ts",{"_103":239,"_95":240,"_158":241,"_160":159,"_161":139,"_162":242,"_164":117,"_105":243,"_100":32,"_166":189,"_168":244,"_169":22,"_170":-5,"_171":-7,"_99":412,"_373":413},[157,240],"2b803c3c714597c217985fac5e60a8e930b51c948cb95d729d56f0dc9c4b6d52",{"_99":415,"_369":-7,"_370":416},"routes/test-routes.ts",{"_103":248,"_95":249,"_158":250,"_160":159,"_161":139,"_162":251,"_164":117,"_105":252,"_100":32,"_166":189,"_168":253,"_169":22,"_170":-5,"_171":-7,"_99":417,"_373":418},[157,249],"d70c2b94c3a63625574fab3012d38eb37e9f3215ec4f6a64136e46c48d0adf64",[],"modified",[422,433,444],{"_99":175,"_369":423,"_370":430},{"_103":424,"_95":175,"_158":425,"_160":-5,"_161":142,"_162":144,"_164":22,"_105":426,"_100":32,"_166":179,"_168":427,"_169":22,"_170":-5,"_171":-7,"_99":428,"_373":429},"daa5be5e-1a15-11f0-9c86-569c3dd06744","8e2b16e4-39c0-45d6-8825-73f375a3005b",["D",1744734161332],"# 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\nRead up on it and try the examples:\n\n[https://bradnoble.notion.site/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4](https://bradnoble.notion.site/val-town-for-Notion-1cbc200736c2807bb445eccf64d0afe9?pvs=4)\n\n![image.png](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a8afa60b-7ff7-4707-b07b-6011b8e2b700/public)",[175],"f9c89ca31c3659f0e19dfe5216699d448d2317b2b6febb0f3227b1ea6cb26e6f",{"_103":281,"_95":175,"_158":282,"_160":-5,"_161":139,"_162":283,"_164":117,"_105":284,"_100":285,"_166":179,"_168":286,"_169":22,"_170":-5,"_171":-7,"_99":431,"_373":432},[175],"7317cd813af49c0c5dcc92957feed9aae2ecd3f63c08b3da31991bf60029bf5e",{"_99":291,"_369":434,"_370":441},{"_103":435,"_95":291,"_158":436,"_160":-5,"_161":142,"_162":144,"_164":22,"_105":437,"_100":32,"_166":295,"_168":438,"_169":22,"_170":-5,"_171":-7,"_99":439,"_373":440},"daa5c192-1a15-11f0-9c86-569c3dd06744","45d2d00c-1e2a-4ecc-b051-57dcc2b90b10",["D",1744734161332],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\n\nexport default async function(interval: Interval) {\n // get the \"filename\"\n // this is the string at the beginning of each blob key... (cont'd)\n const url = await import.meta.url;\n const subdomain = url.split(\"/\").pop();\n // ... which we use to grab all of the blobs set by this project\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 console.log(item.key);\n console.log({ content });\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 (content != \"default\" && diffInMinutes > .5) {\n const response = await fetch(fetchURL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"target_id\": lastRun.id, // custom header from Notion webhook, id of target block\n \"asking_for\": \"default\", // custom header from Notion webhook, reset content to the Notion default\n \"x-api-key\": Deno.env.get(\"X_API_KEY\"),\n },\n body: JSON.stringify(fetchURL),\n });\n }\n }\n}",[291],"d8a660ed49048043f2e52d7330075ed05243ad8ffe88a9880304f95be41d3ac1",{"_103":290,"_95":291,"_158":292,"_160":-5,"_161":139,"_162":293,"_164":117,"_105":294,"_100":285,"_166":295,"_168":296,"_169":22,"_170":-5,"_171":-7,"_99":442,"_373":443},[291],"ba0666b1fd59864dbf13ecc0a44727b9caa827be3ad69013f6a22d3562e1db99",{"_99":301,"_369":445,"_370":453},{"_103":446,"_95":301,"_158":447,"_160":-5,"_161":142,"_162":144,"_164":22,"_105":448,"_100":32,"_166":305,"_168":449,"_169":22,"_170":450,"_171":-7,"_99":451,"_373":452},"daa5c340-1a15-11f0-9c86-569c3dd06744","9dfa157e-0050-464e-80ec-02d5329befd2",["D",1744734161332],"import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\n// import { cors } from \"npm:hono@3/cors\";\n\n// import helpers from utils folder\nimport * as helpers from \"./utils/helpers.ts\";\nimport * as notionHelpers from \"./utils/notionHelpers.ts\";\n\n// Initialize Notion client\nconst notion = new Client({\n auth: Deno.env.get(\"NOTION_API_KEY\"),\n});\n\nconst app = new Hono();\n\napp.use(\"*\", async (c, next) => {\n const secret = c.req.header(\"x-api-key\");\n // console.log(\"secret: \", secret);\n if (secret !== Deno.env.get(\"X_API_KEY\")) {\n return c.text(\"Unauthorized\", 401);\n }\n await next();\n});\n\napp.post(\"/example/database/pages\", async (c) => {\n // blob keys map to endpoints for the cron resets\n const blobKey = await c.req.url.replace(\"https://\", \"\");\n const askingFor = c.req.headers.get(\"asking_for\") || \"default\"; // val.town or default\n\n // capture the database id to store in the blob\n const targetId = c.req.headers.get(\"target_id\");\n\n // get the pages in this database\n const databaseChildren = await notion.databases.query({ database_id: targetId });\n // delete all pages to prevent bad actors from leaving naughty rows behi\n for (const [key, child] of databaseChildren.results.entries()) {\n const page = await notion.pages.update({\n page_id: child.id,\n in_trash: true,\n });\n }\n\n // get the database\n const database = await notion.databases.retrieve({ database_id: targetId });\n // convert the statuses string in the status property into JSON\n const statuses = JSON.parse(database?.properties?.Statuses?.formula?.expression);\n // get the first item on the list of statuses, to set the status for new pages\n const status = statuses[0];\n // add back pages; fresh start for the next person to add favicons\n const defaults = [\"val.town\", \"notion.com\", \"hono.dev\"].reverse();\n // create new database pages from default object\n for (const item of defaults) {\n const page = await notion.pages.create({\n parent: {\n type: \"database_id\",\n database_id: targetId,\n },\n properties: {\n \"Website\": {\n \"title\": [\n {\n \"text\": {\n \"content\": item,\n },\n },\n ],\n },\n Status: {\n \"select\": {\n \"name\": status,\n },\n },\n },\n });\n }\n // store webhook data in blob storage for resets\n // blob key is the path variable so blobs map to endpoints\n const blobObject = {\n id: targetId,\n date: new Date(),\n content: askingFor,\n };\n await blob.setJSON(blobKey, blobObject);\n console.log(await blob.getJSON(blobKey));\n\n return c.json({ ok: true });\n});\n\napp.post(\"/example/database/page\", async (c) => {\n const payload = await c.req.json();\n const data = await payload?.data;\n // blob keys map to endpoints for the cron resets\n const blobKey = await c.req.url.replace(\"https://\", \"\") + \"s\";\n const askingFor = c.req.headers.get(\"asking_for\") || \"default\"; // val.town or default\n\n await notionHelpers.setPageStatus({ data: data, section: \"favicon\", step: \"first\" });\n const favicons = await notionHelpers.addFavicon(data);\n await notionHelpers.setPageStatus({ data: data, section: \"favicon\", step: \"last\" });\n\n // store webhook data in blob storage for resets\n // capture the database id to store in the blob\n const databaseId = data?.parent?.database_id;\n const blobObject = {\n id: databaseId,\n date: new Date(),\n content: askingFor,\n };\n await blob.setJSON(blobKey, blobObject);\n console.log(await blob.getJSON(blobKey));\n\n await notionHelpers.setPageStatus({ data: data, section: \"setup\", step: \"last\" });\n\n return c.json({ ok: true });\n});\n\napp.post(\"/example/child_pages\", async (c) => {\n // webhook data\n // blob keys map to endpoints for the cron resets\n const blobKey = await c.req.url.replace(\"https://\", \"\");\n const targetId = c.req.headers.get(\"target_id\"); // the Notion button webhook sends this as a custom header\n const askingFor = c.req.headers.get(\"asking_for\") || \"default\"; // val.town or default\n\n const children = await notionHelpers.listChildrenChildPages(targetId) || [];\n // logs.push({ children });\n const emojis = [\"👍\", \"🚀\", \"😀\", \"❤️\"];\n\n // update the page icon for each page in children\n for (const [key, child] of children.entries()) {\n // default icon is notion's page icon, which comes when icon is null\n let icon = null;\n // val.town enriches icons with emojis\n if (askingFor === \"val.town\") {\n icon = {\n type: \"emoji\",\n emoji: emojis[key], // \"👍\",\n };\n }\n // update the page icon\n const page = await notion.pages.update({\n page_id: child.id,\n icon: icon,\n });\n // logs.push(page);\n }\n // store webhook data in blob storage for resets\n // blob key is the path variable so blobs map to endpoints\n const blobObject = {\n id: targetId,\n date: new Date(),\n content: askingFor,\n };\n await blob.setJSON(blobKey, blobObject);\n console.log(await blob.getJSON(blobKey));\n\n return c.json({ ok: true });\n});\n\napp.post(\"/example/callout\", async (c) => {\n // webhook data\n const blobKey = await c.req.url.replace(\"https://\", \"\");\n const targetId = c.req.headers.get(\"target_id\"); // the Notion button webhook sends this as a custom header\n const askingFor = c.req.headers.get(\"asking_for\") || \"default\"; // val.town or default\n\n // update the callout with the content in askingFor\n await notionHelpers.setBlockContent(targetId, askingFor);\n\n // store webhook data in blob storage for resets\n // blob key is the path variable so blobs map to endpoints\n const blobObject = {\n id: targetId,\n date: new Date(),\n content: askingFor,\n };\n await blob.setJSON(blobKey, blobObject);\n console.log(await blob.getJSON(blobKey));\n\n return c.json({ ok: true });\n});\n\napp.post(\"/countExamples\", async (c) => {\n const payload = await c.req.json();\n let data = await payload?.data;\n const pageId = await data?.id;\n const logs = [];\n\n const exampleFlag = \"https://www.notion.so/icons/cursor-click_blue.svg\";\n const children = await notionHelpers.listChildren(pageId);\n const callouts = await children?.results.filter((child) => child?.callout?.icon?.external?.url === exampleFlag) || [];\n logs.push(callouts.length, { callouts });\n logs.push(callouts[0].callout.icon.external);\n\n console.log(logs);\n return c.json(logs);\n});\n\napp.post(\"/asdf\", async (c) => {\n const requestData = await c.req.json();\n console.log(requestData);\n c.json({ ok: true });\n});\n\napp.post(\"/qwer/:id\", async (c) => {\n const action = c.req.param(\"id\");\n console.log({ action });\n});\n\napp.post(\"/test/:id\", async (c) => {\n const requestData = await c.req.json();\n\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/\" + c.req.param(\"id\"), {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(requestData),\n });\n});\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: \"Hi!\",\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\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\nexport default app.fetch;","2valtownfornotion",[301],"ebebe3a48f9ce75b85d7f788bdcb68404f8d25d3322c3b10f4349c62041b4bbb",{"_103":300,"_95":301,"_158":302,"_160":-5,"_161":139,"_162":138,"_164":117,"_105":303,"_100":304,"_166":305,"_168":306,"_169":22,"_170":-5,"_171":-7,"_99":454,"_373":455},[301],"7878f83dd4232101323c7950c7bd3140725f077b725164166cce03ce869fe325","hasChanges","sourceBranch","targetBranch",{"_103":142,"_105":460,"_345":461,"_95":98,"_140":147,"_100":285,"_141":347,"_143":348,"_349":350,"_107":-5,"_152":22,"_109":110,"_151":340,"_16":149,"_150":96},["D",1744734161319],["D",1744736039849],"pull","actionData","errors"]

stevekrouse

ValTownForNotion

Mergestevekrouse/SteveRefactorintobradnoble/SteveRefactor

README.md+9-1

Cvaltownfornotion.val.run+2-3

HwebhookAPI+27-237

routes

routes/README.md+14-0

routes/auth.ts+7-0

routes/count-examples.ts+22-0

routes/example-callout.ts+29-0

routes/example-child-pages.ts+55-0

routes/example-database-page.ts+34-0

routes/example-database-pages.ts+76-0

routes/root.ts+25-0

routes/test-routes.ts+41-0