[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_206":207,"_208":209},"routes/_app.x.$handle.$name",{"_100":99,"_32":46,"_108":90,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":61,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",722,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","utils/notionHelpers.ts","latestPath","fileId","a84009c8-6837-4608-99c6-dd3af25a5925","name","notionHelpers.ts","fileType","script","content","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 getBlock(blockId: string) {\n // this is the id of the callout that we'll be modifying\n const block = await notion.blocks.retrieve({\n block_id: blockId,\n });\n return block;\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 updateClientPageStatus(data: any, section?: string, index?: string) {\n const pageId = data?.id;\n // for the logs: track progress through the steps\n const logs = [];\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\n // logs.push(statuses);\n // logs.push({ \"first\": sectionStatuses[0] });\n // logs.push({ \"last\": sectionStatuses[sectionStatuses.length - 1] });\n const status = (index === \"start\") ? sectionStatuses[0] : sectionStatuses[sectionStatuses.length - 1];\n // update status property of notion page\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 addFavicons(data?: any) {\n const pageId = data?.id;\n // for the logs: track progress through the steps\n const logs = [];\n let status = [] as any;\n\n // get page object\n data = await checkPayloadForProperties(pageId, data);\n\n // update client page status\n status = await updateClientPageStatus(data, \"favicon\", \"start\");\n // logs.push({ status });\n // logs.push(status);\n // get URL property\n // use notion if nothing if the URL property is empty\n const url = await getWebhookPropertyValue(data, \"Website\") || \"notion.com\";\n logs.push({ url });\n\n // send the URL value to the function that will get the site's favicon location\n const faviconURL = await helpers.scrapeFaviconUrl(url);\n logs.push({ \"Verified favicon URL\": faviconURL });\n\n // get children of this page\n // const children = await listChildren(pageId) || [];\n // get all children of this page that are pages (and not other block elements like paragraphs, etc)\n const pageIds = []; // children.results.filter(block => block.type === \"child_page\").map(block => block.id);\n // add this page (the client page) to the array of child pages to update\n pageIds.push(pageId);\n logs.push({ \"Pages to update\": pageIds });\n\n // update pages with the favicon we found from the URL property\n let updatedPages = [];\n for (const page of pageIds) {\n await updatePageIcon(page, faviconURL);\n updatedPages.push(page);\n }\n\n logs.push({ \"Updated pages\": updatedPages });\n\n // update client page status\n status = await updateClientPageStatus(data, \"favicon\", \"end\");\n logs.push({ status });\n\n return logs;\n}\n\nexport async function checkPayloadForProperties(pageId: string, payload?: any) {\n // expect that any api endpoint that calls this function will send the pageId and a payload\n let data = payload?.data || payload;\n const properties = data?.properties;\n const logs = [];\n\n // logs.push(data);\n\n // write a javascript function that checks to see if the properties object is empty\n // this is helpful when using postman to hit the api and when we don't want to really be worrying about\n // structing the body of the POST request in order to get the payload right\n // and just want to send the page id\n\n // !!! note that we ACTUALLY need to check against the payload function and if anything comes back undefined, then\n // we should get the page from Notion\n // const requiredProperties = [\"Name\", \"URL\", \"Status\", \"Statuses\"];\n // loop through requiredProperties and check to see if the webhookpayload helper function returns undefined\n\n if (\n Object.keys(properties).length === 0\n || !properties?.Name\n || !properties?.URL\n || !properties?.Status\n || !properties?.Statuses\n ) {\n logs.push(\"Some properties are missing from the POST body, so call to Notion for the page object.\");\n // console.log(pageId);\n data = await getNotionPage(pageId);\n } else {\n logs.push(\"POST payload properties are NOT null and we can just use the data object inside the payload.\");\n }\n // logs.push(data);\n\n console.log(logs);\n return data;\n}\n\nexport async function updatePageStatus(pageId: string, payload?: any, path?: string) {\n let status = await getWebhookPropertyValue(payload, \"Status\");\n const statusesString = await getWebhookPropertyValue(payload, \"Statuses\");\n // turn the statuses string into an array\n const statuses = statusesString.split(\",\");\n // loop through statuses array and when the value matches the current status, capture the index\n const index = statuses.findIndex((value) => value === status);\n\n // track progress, for the logs\n let progress = [];\n progress.push({ \"initial status\": status });\n\n // if there's a path, that means that this is the first call to update the status from the API\n if (path) {\n // extract camelcase words from path\n const section = await helpers.extractCamelCaseWords(path);\n progress.push({ section });\n\n // we need to loop through the statuses array and find the first one that mentions \"favicons\"\n // because when we call this endpoint, we're starting from the beginning of the favicon section\n if (statuses.length > 0) {\n for (let i = 0; i < statuses.length; i++) {\n if (statuses[i].toLowerCase().includes(section)) {\n status = statuses[i];\n break;\n }\n }\n }\n // now that we know we're at the beginning of the favicon section, update the status on Notion\n // to the next status\n } else {\n let next = null;\n // if this is the last status in the statuses array there is no next, so...\n // make next the first status in the statuses array\n if (index === (statuses.length - 1)) {\n next = statuses[0];\n } else {\n next = statuses[index + 1];\n }\n status = next;\n }\n\n progress.push({ \"new status\": status });\n\n // update status property of notion page\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 console.log({ progress });\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\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}\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}","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\n// await notionHelpers.updateClientPageStatus(data, \"setup\", \"end\");\nexport async function updateClientPageStatus(data: any, section?: string, index?: string) {\n const pageId = data?.id;\n // for the logs: track progress through the steps\n const logs = [];\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\n // logs.push(statuses);\n // logs.push({ \"first\": sectionStatuses[0] });\n // logs.push({ \"last\": sectionStatuses[sectionStatuses.length - 1] });\n const status = (index === \"start\") ? sectionStatuses[0] : sectionStatuses[sectionStatuses.length - 1];\n // update status property of notion page\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 getBlock(blockId: string) {\n // this is the id of the callout that we'll be modifying\n const block = await notion.blocks.retrieve({\n block_id: blockId,\n });\n return block;\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 addFavicons(data?: any) {\n const pageId = data?.id;\n // for the logs: track progress through the steps\n const logs = [];\n let status = [] as any;\n\n // get page object\n data = await checkPayloadForProperties(pageId, data);\n\n // update client page status\n status = await updateClientPageStatus(data, \"favicon\", \"start\");\n // logs.push({ status });\n // logs.push(status);\n // get URL property\n // use notion if nothing if the URL property is empty\n const url = await getWebhookPropertyValue(data, \"Website\") || \"notion.com\";\n logs.push({ url });\n\n // send the URL value to the function that will get the site's favicon location\n const faviconURL = await helpers.scrapeFaviconUrl(url);\n logs.push({ \"Verified favicon URL\": faviconURL });\n\n // get children of this page\n // const children = await listChildren(pageId) || [];\n // get all children of this page that are pages (and not other block elements like paragraphs, etc)\n const pageIds = []; // children.results.filter(block => block.type === \"child_page\").map(block => block.id);\n // add this page (the client page) to the array of child pages to update\n pageIds.push(pageId);\n logs.push({ \"Pages to update\": pageIds });\n\n // update pages with the favicon we found from the URL property\n let updatedPages = [];\n for (const page of pageIds) {\n await updatePageIcon(page, faviconURL);\n updatedPages.push(page);\n }\n\n logs.push({ \"Updated pages\": updatedPages });\n\n // update client page status\n status = await updateClientPageStatus(data, \"favicon\", \"end\");\n logs.push({ status });\n\n return logs;\n}\n\nexport async function checkPayloadForProperties(pageId: string, payload?: any) {\n // expect that any api endpoint that calls this function will send the pageId and a payload\n let data = payload?.data || payload;\n const properties = data?.properties;\n const logs = [];\n\n // logs.push(data);\n\n // write a javascript function that checks to see if the properties object is empty\n // this is helpful when using postman to hit the api and when we don't want to really be worrying about\n // structing the body of the POST request in order to get the payload right\n // and just want to send the page id\n\n // !!! note that we ACTUALLY need to check against the payload function and if anything comes back undefined, then\n // we should get the page from Notion\n // const requiredProperties = [\"Name\", \"URL\", \"Status\", \"Statuses\"];\n // loop through requiredProperties and check to see if the webhookpayload helper function returns undefined\n\n if (\n Object.keys(properties).length === 0\n || !properties?.Name\n || !properties?.URL\n || !properties?.Status\n || !properties?.Statuses\n ) {\n logs.push(\"Some properties are missing from the POST body, so call to Notion for the page object.\");\n // console.log(pageId);\n data = await getNotionPage(pageId);\n } else {\n logs.push(\"POST payload properties are NOT null and we can just use the data object inside the payload.\");\n }\n // logs.push(data);\n\n console.log(logs);\n return data;\n}\n\nexport async function updatePageStatus(pageId: string, payload?: any, path?: string) {\n let status = await getWebhookPropertyValue(payload, \"Status\");\n const statusesString = await getWebhookPropertyValue(payload, \"Statuses\");\n // turn the statuses string into an array\n const statuses = statusesString.split(\",\");\n // loop through statuses array and when the value matches the current status, capture the index\n const index = statuses.findIndex((value) => value === status);\n\n // track progress, for the logs\n let progress = [];\n progress.push({ \"initial status\": status });\n\n // if there's a path, that means that this is the first call to update the status from the API\n if (path) {\n // extract camelcase words from path\n const section = await helpers.extractCamelCaseWords(path);\n progress.push({ section });\n\n // we need to loop through the statuses array and find the first one that mentions \"favicons\"\n // because when we call this endpoint, we're starting from the beginning of the favicon section\n if (statuses.length > 0) {\n for (let i = 0; i < statuses.length; i++) {\n if (statuses[i].toLowerCase().includes(section)) {\n status = statuses[i];\n break;\n }\n }\n }\n // now that we know we're at the beginning of the favicon section, update the status on Notion\n // to the next status\n } else {\n let next = null;\n // if this is the last status in the statuses array there is no next, so...\n // make next the first status in the statuses array\n if (index === (statuses.length - 1)) {\n next = statuses[0];\n } else {\n next = statuses[index + 1];\n }\n status = next;\n }\n\n progress.push({ \"new status\": status });\n\n // update status property of notion page\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 console.log({ progress });\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\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}\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}","createdAt",["D",1744563506823],"branchVersion","branchId","d8176b5c-1613-11f0-91f5-569c3dd06744","id","d814c30c-1613-11f0-91f5-569c3dd06744","ValTownForNotion",["D",1744293493384],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Augmenting Notion with webhooks and val.town.","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f25cb5fe-2b5b-4f08-5492-f088b3195400/square512?exp=1789588799&sig=7b2c074d103b1d6f93e131cf734275cfda39e55a44c11f626edab1f423393eee","5df592ef-f349-498c-a580-fdeaf4cbe6c9","pinnedFileId","6b696612-f13d-46cc-a0c0-612473883f2c","pinPreview",true,"pinMigrated","screenshotVersion",812,"likeCount",7,"orgId","553221cb-cf30-487d-a0cb-f2ba0209ad00","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":103},"org",{"_100":99,"_101":-5,"_102":103,"_18":57,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_44":43,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":46,"_98":99},"isOwned",1127,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","bradnoble","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ4YUNlWnM0S3Z6OWxiOUlLS25sWjNJWFhzSSJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":202,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":203,"_84":204,"_86":205,"_88":25},"tree",[175,178,179],"files",[175,176,177,178,179],"counts",{"_162":159,"_163":164,"_165":166,"_167":168,"_169":170},"contents",[130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":154,"_32":155,"_30":156,"_135":-5,"_42":43,"_41":157,"_137":61,"_39":158,"_13":159,"_34":160,"_36":-5,"_24":25,"_142":-5,"_27":161},{"_44":145,"_32":146,"_30":147,"_135":-5,"_42":43,"_41":148,"_137":25,"_39":149,"_13":150,"_34":151,"_36":152,"_24":25,"_142":-5,"_27":153},{"_44":133,"_32":134,"_30":59,"_135":-5,"_42":43,"_41":136,"_137":25,"_39":138,"_13":139,"_34":140,"_36":141,"_24":25,"_142":143,"_27":144},"22b81622-1888-11f0-8cc8-569c3dd06744","webhookAPI","parentId",721,"latest",["D",1744563342550],568,"http","import { blob } from \"https://esm.town/v/std/blob?v=12\";\nimport { Client } from \"npm:@notionhq/client\";\nimport { Hono } from \"npm:hono@3\";\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.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 const favicons = await notionHelpers.addFavicons(data);\n await notionHelpers.updateClientPageStatus(data, \"setup\", \"end\");\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 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\nexport default app.fetch;","label","valtownfornotion",[134],"189454fe-1887-11f0-9c70-569c3dd06744","valtownfornotion.val.run","44079c53-27a5-4518-9b07-d4566db58bb1",720,["D",1744562896041],113,"interval","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, { content });\n\n // if (content != \"default\" && diffInMinutes > .3) {\n if (content != \"default\") {\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 },\n body: JSON.stringify(fetchURL),\n });\n }\n // get values for date math\n // const now = new Date();\n // const diffInMs = Math.abs(now - lastRunAt);\n // const diffInMinutes = diffInMs / 1000 / 60;\n // console.log({ content }, { diffInMinutes });\n }\n}",[146],"d81a69ba-1613-11f0-91f5-569c3dd06744","utils","1a8e7db7-a152-474a-bbec-98fe46feebd6",1,["D",1744293493384],0,"directory",[155],"pulls","branches",5,"forks",8,"envVars",{"_171":173,"_174":159},"connections",{"_171":159,"_172":159},"count","unfilledCount",3,"emptyCount",{"_44":154,"_32":155,"_30":156,"_135":-5,"_42":43,"_41":157,"_137":61,"_39":199,"_13":159,"_34":160,"_36":-5,"_24":25,"_142":-5,"_181":200,"_27":201},{"_44":192,"_32":193,"_30":194,"_135":156,"_42":43,"_41":157,"_137":25,"_39":195,"_13":159,"_34":35,"_36":196,"_24":25,"_142":-5,"_181":197,"_27":198},{"_44":187,"_32":33,"_30":31,"_135":156,"_42":43,"_41":14,"_137":25,"_39":188,"_13":189,"_34":35,"_36":38,"_24":25,"_142":-5,"_181":190,"_27":191},{"_44":145,"_32":146,"_30":147,"_135":-5,"_42":43,"_41":148,"_137":25,"_39":184,"_13":150,"_34":151,"_36":152,"_24":25,"_142":-5,"_181":185,"_27":186},{"_44":133,"_32":134,"_30":59,"_135":-5,"_42":43,"_41":136,"_137":25,"_39":180,"_13":139,"_34":140,"_36":141,"_24":25,"_142":143,"_181":182,"_27":183},["D",1744563342550],"children",[],[134],["D",1744562896041],[],[146],"84a23c32-1888-11f0-aca1-569c3dd06744",["D",1744563506823],38,[],[155,33],"d81a5880-1613-11f0-91f5-569c3dd06744","helpers.ts","a90c4a83-fbd9-4f81-a12d-b478c179bff4",["D",1744293493384],"// 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}",[],[155,193],["D",1744293493384],[176,177],[155],["D",1744293493384],{"_100":99,"_107":103},{"_100":99,"_101":-5,"_102":103,"_18":57,"_104":105,"_106":25},{"_13":89,"_32":90,"_44":43,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":46,"_98":99},"ctx",{"_82":-5,"_127":239,"_240":241,"_242":243,"_244":25,"_245":25,"_246":25,"_247":61,"_248":-5,"_249":-7,"_250":-7,"_251":159,"_252":25,"_253":25,"_254":-5,"_255":25,"_256":25,"_257":25,"_258":-5},"ENV",{"_210":211,"_212":213,"_214":90,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v722