[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_168":169,"_170":171},"routes/_app.x.$handle.$name",{"_96":95,"_33":46,"_104":86,"_28":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":27,"_119":120,"_121":27,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":27,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":27},"version",49,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":27},"previous",{"_31":32,"_33":29,"_34":35,"_36":37},"deleted",true,"deletedHere",false,"path","bskytest.ts","latestPath","fileId","301dd94e-f4bc-11f0-9d15-42dde27851f2","name","fileType","script","content","import { AppBskyFeedPost, AtpAgent } from \"npm:@atproto/api\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { withoutTrailingSlash } from \"https://unpkg.com/ufo/dist/index.mjs\";\n\ninterface ParsedPost {\n uri: string;\n createdAt: string;\n link: string; // URLs found in facets and embeds\n}\n\nexport default async function fetchBlueskyPosts() {\n const ghostPostIds = await blob.list(\"ghost_\");\n if (ghostPostIds.length === 0) {\n console.log(\"No ghost posts to process\");\n return;\n }\n let earliestDate: string;\n let blogPostUrls = new Map();\n for (const { key } of ghostPostIds) {\n const data = await blob.getJSON(key) as {\n slug: string;\n publishedAt: string;\n };\n\n // Hardcoded bleugh\n blogPostUrls.set(`https://jonathanyeong.com/writing/${data.slug}/`, null);\n\n if (!earliestDate || data.publishedAt < earliestDate) {\n earliestDate = data.publishedAt;\n }\n }\n\n const agent = new AtpAgent({ service: \"https://public.api.bsky.app\" });\n const feedIterator = createFeedIterator(\n agent,\n \"jonathanyeong.com\",\n new Date(earliestDate),\n );\n\n while (!feedIterator.isExhausted()) {\n await feedIterator.fetchMore();\n }\n\n // arary of blog data and an array of feed iterator posts\n // Feed iterator posts could have duplicate urls.\n for (const post of feedIterator.posts) {\n const postDate = new Date(post.createdAt);\n console.log(JSON.stringify(post));\n\n const bpu = blogPostUrls.get(post.link);\n conole.log(JSON.stringify(blogPostUrls))\n // If object in map and the createdAt is earlier then the post created At.\n // Then we need to set the key-val\n if (!bpu || bpu.createdAt > postDate) {\n const bskyPostId = post.uri.split(\"/\").pop();\n blogPostUrls.set(post.link, { bskyPostId, createdAt: postDate });\n }\n }\n\n console.log(JSON.stringify(blogPostUrls));\n}\n\nfunction createFeedIterator(\n agent: AtpAgent,\n actor: string,\n earliestDate: Date,\n) {\n const posts: ParsedPost[] = [];\n let cursor: string | undefined;\n let exhausted = false;\n let oldestPostDate: Date | null = null;\n\n async function fetchNextPage(): Promise {\n if (exhausted) return false;\n\n try {\n const { data } = await agent.getAuthorFeed({\n actor,\n limit: 100,\n cursor,\n });\n\n for (const item of data.feed) {\n // skip reposts\n if (item.reason) continue;\n // skip replies\n if (item.reply) continue;\n\n const post = item.post;\n\n if (!AppBskyFeedPost.isRecord(post.record)) continue;\n\n const record = post.record;\n const postDate = new Date(record.createdAt as string);\n\n if (!oldestPostDate || postDate < oldestPostDate) {\n oldestPostDate = postDate;\n }\n\n if (postDate < earliestDate) {\n exhausted = true;\n break;\n }\n\n let link = \"\";\n // Extract links from facets\n const facets = record.facets as\n | Array<{ features: Array<{ uri?: string; $type?: string }> }>\n | undefined;\n if (facets) {\n for (const facet of facets) {\n for (const feature of facet.features) {\n if (\n feature.$type === \"app.bsky.richtext.facet#link\" && feature.uri\n ) {\n link = feature.uri;\n }\n }\n }\n }\n\n // Let's assume I'll always have a link\n // if (post.embed && \"external\" in post.embed) {\n // const external = post.embed.external as { uri?: string };\n // if (external.uri && link !== external.uri) {\n // link = external.uri\n // }\n // }\n\n if (!link.startsWith(\"https://jonathanyeong.com/writing/\")) {\n // If this record doesn't have a link from my blog then skip\n continue;\n }\n\n posts.push({\n uri: post.uri,\n createdAt: record.createdAt as string,\n link,\n });\n }\n\n cursor = data.cursor;\n\n if (!cursor) {\n exhausted = true;\n }\n\n return true;\n } catch {\n exhausted = true;\n return false;\n }\n }\n\n return {\n posts,\n fetchMore: fetchNextPage,\n getOldestPostDate: () => oldestPostDate,\n /** Check if we've exhausted all pages */\n isExhausted: () => exhausted,\n };\n}\n\nawait blob.setJSON(\"ghost_12345\", {\n slug: \"using-val-town-as-a-webhook-middleware\",\n publishedAt: \"2026-01-06T20:36:56.000Z\",\n});\n\nawait fetchBlueskyPosts();","import { AppBskyFeedPost, AtpAgent } from \"npm:@atproto/api\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { withoutTrailingSlash } from \"https://unpkg.com/ufo/dist/index.mjs\";\n\ninterface ParsedPost {\n uri: string;\n createdAt: string;\n link: string; // URLs found in facets and embeds\n}\n\nexport default async function fetchBlueskyPosts() {\n const ghostPostIds = await blob.list(\"ghost_\");\n if (ghostPostIds.length === 0) {\n console.log(\"No ghost posts to process\");\n return;\n }\n let earliestDate: string;\n let blogPostUrls = new Map();\n for (const { key } of ghostPostIds) {\n const data = await blob.getJSON(key) as {\n slug: string;\n publishedAt: string;\n };\n\n // Hardcoded bleugh\n blogPostUrls.set(`https://jonathanyeong.com/writing/${data.slug}/`, null);\n\n if (!earliestDate || data.publishedAt < earliestDate) {\n earliestDate = data.publishedAt;\n }\n }\n\n const agent = new AtpAgent({ service: \"https://public.api.bsky.app\" });\n const feedIterator = createFeedIterator(\n agent,\n \"jonathanyeong.com\",\n new Date(earliestDate),\n );\n\n while (!feedIterator.isExhausted()) {\n await feedIterator.fetchMore();\n }\n\n // arary of blog data and an array of feed iterator posts\n // Feed iterator posts could have duplicate urls.\n for (const post of feedIterator.posts) {\n const postDate = new Date(post.createdAt);\n console.log(JSON.stringify(post));\n\n const bpu = blogPostUrls.get(post.link);\n console.log(JSON.stringify(blogPostUrls))\n // If object in map and the createdAt is earlier then the post created At.\n // Then we need to set the key-val\n if (!bpu || bpu.createdAt > postDate) {\n const bskyPostId = post.uri.split(\"/\").pop();\n blogPostUrls.set(post.link, { bskyPostId, createdAt: postDate });\n }\n }\n\n console.log(JSON.stringify(blogPostUrls));\n}\n\nfunction createFeedIterator(\n agent: AtpAgent,\n actor: string,\n earliestDate: Date,\n) {\n const posts: ParsedPost[] = [];\n let cursor: string | undefined;\n let exhausted = false;\n let oldestPostDate: Date | null = null;\n\n async function fetchNextPage(): Promise {\n if (exhausted) return false;\n\n try {\n const { data } = await agent.getAuthorFeed({\n actor,\n limit: 100,\n cursor,\n });\n\n for (const item of data.feed) {\n // skip reposts\n if (item.reason) continue;\n // skip replies\n if (item.reply) continue;\n\n const post = item.post;\n\n if (!AppBskyFeedPost.isRecord(post.record)) continue;\n\n const record = post.record;\n const postDate = new Date(record.createdAt as string);\n\n if (!oldestPostDate || postDate < oldestPostDate) {\n oldestPostDate = postDate;\n }\n\n if (postDate < earliestDate) {\n exhausted = true;\n break;\n }\n\n let link = \"\";\n // Extract links from facets\n const facets = record.facets as\n | Array<{ features: Array<{ uri?: string; $type?: string }> }>\n | undefined;\n if (facets) {\n for (const facet of facets) {\n for (const feature of facet.features) {\n if (\n feature.$type === \"app.bsky.richtext.facet#link\" && feature.uri\n ) {\n link = feature.uri;\n }\n }\n }\n }\n\n // Let's assume I'll always have a link\n // if (post.embed && \"external\" in post.embed) {\n // const external = post.embed.external as { uri?: string };\n // if (external.uri && link !== external.uri) {\n // link = external.uri\n // }\n // }\n\n if (!link.startsWith(\"https://jonathanyeong.com/writing/\")) {\n // If this record doesn't have a link from my blog then skip\n continue;\n }\n\n posts.push({\n uri: post.uri,\n createdAt: record.createdAt as string,\n link,\n });\n }\n\n cursor = data.cursor;\n\n if (!cursor) {\n exhausted = true;\n }\n\n return true;\n } catch {\n exhausted = true;\n return false;\n }\n }\n\n return {\n posts,\n fetchMore: fetchNextPage,\n getOldestPostDate: () => oldestPostDate,\n /** Check if we've exhausted all pages */\n isExhausted: () => exhausted,\n };\n}\n\nawait blob.setJSON(\"ghost_12345\", {\n slug: \"using-val-town-as-a-webhook-middleware\",\n publishedAt: \"2026-01-06T20:36:56.000Z\",\n});\n\nawait fetchBlueskyPosts();","createdAt",["D",1768780615145],"branchVersion","branchId","1cd71e2e-f4ba-11f0-bb20-42dde27851f2","id","1cd495b4-f4ba-11f0-bb20-42dde27851f2","bluesky-cron",["D",1768774063322],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Discovers posts tied to my blog and triggers a new Netlify build","imageUrl","019b1359-dddb-7208-bfc6-65e13186f32a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019b1359-dddb-7208-bfc6-6a33b3440626","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":56,"_100":101,"_102":27},"branch",{"_13":85,"_33":86,"_44":43,"_87":45,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":46,"_94":95},"isOwned",61,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","jonoyeong","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zNmtndFZjT0d2VUFzN3FMVEtwSTV1ajk0S1YifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_33":46,"_39":164,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":27,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":165,"_80":166,"_82":167,"_84":27},"tree",[155,156],"files",[155,156],"counts",{"_144":62,"_145":146,"_147":62,"_148":149,"_150":151},"contents",[126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":140,"_33":29,"_31":32,"_131":-5,"_42":43,"_41":14,"_133":27,"_39":141,"_13":142,"_34":35,"_36":38,"_24":27,"_138":-5,"_28":143},{"_44":128,"_33":129,"_31":130,"_131":-5,"_42":43,"_41":132,"_133":27,"_39":134,"_13":135,"_34":136,"_36":137,"_24":27,"_138":-5,"_28":139},"2ad5fade-f4bc-11f0-ae99-42dde27851f2","main.ts","1cd9492e-f4ba-11f0-bb20-42dde27851f2","parentId",4,"latest",["D",1768774945809],3,"interval","import { AppBskyFeedPost, AtpAgent } from \"@atproto/api\";\n\nexport default async function (interval: Interval) {\n // Get user DID from environment\n const userDID = Deno.env.get(\"BLUESKY_DID\");\n if (!userDID) {\n throw new Error(\"BLUESKY_DID environment variable not set\");\n }\n\n // Initialize ATP agent\n const agent = new AtpAgent({ service: \"https://public.api.bsky.app\" });\n\n // Fetch posts from Bluesky using AtpAgent\n const bskyData = await agent.com.atproto.repo.listRecords({\n repo: userDID,\n collection: \"app.bsky.feed.post\",\n limit: 100,\n });\n\n // Get earliest entry from val blob storage\n const blobResponse = await fetch(\"https://api.val.town/v1/blob/yourBlobKey\", {\n headers: {\n Authorization: `Bearer ${Deno.env.get(\"valtown\")}`,\n },\n });\n const blobData = await blobResponse.json();\n const earliestDate = new Date(blobData.earliestEntry);\n\n // Slug regex pattern (matches Ghost-style slugs)\n const slugRegex = /\\/([a-z0-9-]+)$/;\n\n // Track matching posts\n const matchingPosts: Array<{ uri: string; createdAt: string }> = [];\n\n for (const record of bskyData.data.records) {\n const postDate = new Date(record.value.createdAt);\n\n // Only process posts up until the earliest date\n if (postDate > earliestDate) continue;\n\n const text = record.value.text || \"\";\n if (slugRegex.test(text)) {\n matchingPosts.push({\n uri: record.uri,\n createdAt: record.value.createdAt,\n });\n }\n }\n\n // Sort by least to most recent (oldest first)\n matchingPosts.sort((a, b) =>\n new Date(a.createdAt).getTime() - new Date(b.createdAt).getTime()\n );\n\n if (matchingPosts.length === 0) {\n console.log(\"No matching posts found\");\n return;\n }\n\n // Get the first (oldest) post URI and extract ID\n const firstPostURI = matchingPosts[0].uri;\n const postID = firstPostURI.split(\"/\").pop(); // Extracts ID like '3mckbwpes4s2u'\n\n // Call Ghost Admin API to update post\n const ghostApiKey = Deno.env.get(\"GHOST_ADMIN_API_KEY\");\n const ghostApiUrl = Deno.env.get(\"GHOST_API_URL\");\n\n const ghostResponse = await fetch(\n `${ghostApiUrl}/ghost/api/admin/posts/${postID}`,\n {\n method: \"PUT\",\n headers: {\n Authorization: `Ghost ${ghostApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n posts: [{\n id: postID,\n updated_at: new Date().toISOString(),\n // Add other fields from blobData as needed\n }],\n }),\n },\n );\n\n console.log(\"Updated post:\", postID, await ghostResponse.json());\n}","label",[129],"5e05e3d0-f4c9-11f0-8e6c-42dde27851f2",["D",1768780615145],44,[29],"pulls","branches",1,"forks","envVars",{"_152":146,"_154":62},"connections",{"_152":62,"_153":62},"count","unfilledCount","emptyCount",{"_44":140,"_33":29,"_31":32,"_131":-5,"_42":43,"_41":14,"_133":27,"_39":161,"_13":142,"_34":35,"_36":38,"_24":27,"_138":-5,"_158":162,"_28":163},{"_44":128,"_33":129,"_31":130,"_131":-5,"_42":43,"_41":132,"_133":27,"_39":157,"_13":135,"_34":136,"_36":137,"_24":27,"_138":-5,"_158":159,"_28":160},["D",1768774945809],"children",[],[129],["D",1768780615145],[],[29],["D",1768774063322],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":56,"_100":101,"_102":27},{"_13":85,"_33":86,"_44":43,"_87":45,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":46,"_94":95},"ctx",{"_78":-5,"_123":201,"_202":203,"_204":205,"_206":27,"_207":27,"_208":27,"_209":25,"_210":-5,"_211":-7,"_212":-7,"_213":62,"_214":27,"_215":27,"_216":-5,"_217":27,"_218":27,"_219":27,"_220":-5},"ENV",{"_172":173,"_174":175,"_176":86,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v49