[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_95":94,"_32":44,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":48,"_118":119,"_120":48,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":48,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":48},"version",55,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","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 const 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 console.log(JSON.stringify(data));\n // Hardcoded bleugh\n blogPostUrls.set(`https://jonathanyeong.com/writing/${data.slug}/`, null);\n console.log(\n blogPostUrls.get(`https://jonathanyeong.com/writing/${data.slug}/`),\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(bpu);\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(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",1768882429374],"branchVersion","branchId","1cd71e2e-f4ba-11f0-bb20-42dde27851f2","id","1cd495b4-f4ba-11f0-bb20-42dde27851f2","bluesky-cron",["D",1768774063322],"deletedAt","legacyEnvVars",false,"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",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":48},"branch",{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"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",{"_42":43,"_32":44,"_37":154,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":48,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":155,"_79":156,"_81":157,"_83":48},"tree",[149],"files",[149],"counts",{"_138":61,"_139":140,"_141":61,"_142":143,"_144":145},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":126,"_32":127,"_30":128,"_129":-5,"_40":41,"_39":130,"_131":48,"_37":132,"_13":133,"_33":134,"_35":135,"_24":48,"_136":-5,"_27":137},"50376ce0-f5b6-11f0-9f0f-42dde27851f2","main.ts","1cd9492e-f4ba-11f0-bb20-42dde27851f2","parentId",54,"latest",["D",1768882382706],5,"interval","import { AppBskyFeedPost, AtpAgent } from \"@atproto/api\";\n\nexport default async function (interval: Interval) {\n const { lastRunAt } = interval;\n\n // First run we'll check the last day of posts\n const cutoffDate = lastRunAt\n ? lastRunAt\n : new Date(Date.now() - 24 * 60 * 60 * 1000);\n const agent = new AtpAgent({ service: \"https://public.api.bsky.app\" });\n const feedIterator = createBlueskyFeedIterator(\n agent,\n \"jonathanyeong.com\",\n new Date(),\n );\n\n while (!feedIterator.isExhausted()) {\n await feedIterator.fetchMore();\n }\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}\n\nfunction createBlueskyFeedIterator(\n agent: AtpAgent,\n actor: string,\n cutoffDate: Date,\n) {\n let cursor: string | undefined;\n let exhausted = false;\n let bskyCommentToLink = false;\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\n const post = item.post;\n if (!AppBskyFeedPost.isRecord(post.record)) continue;\n\n const record = post.record;\n const postDate = new Date(record.createdAt as string);\n if (postDate < cutoffDate) {\n exhausted = true;\n break;\n }\n\n const links: string[] = [];\n\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\" &&\n feature.uri\n ) {\n links.push(feature.uri);\n }\n }\n }\n }\n\n if (post.embed && \"external\" in post.embed) {\n const external = post.embed.external as { uri?: string };\n if (external.uri) {\n links.push(external.uri);\n }\n }\n\n if (\n links.some((link) => link.startsWith(\"https://jonathanyeong.com\"))\n ) {\n bskyCommentToLink = true;\n break;\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 bskyCommentToLink: () => bskyCommentToLink,\n fetchMore: fetchNextPage,\n /** Check if we've exhausted all pages */\n isExhausted: () => exhausted,\n };\n}","label",[127],"pulls","branches",1,"forks","envVars",{"_146":140,"_148":61},"connections",{"_146":61,"_147":61},"count","unfilledCount","emptyCount",{"_42":126,"_32":127,"_30":128,"_129":-5,"_40":41,"_39":130,"_131":48,"_37":150,"_13":133,"_33":134,"_35":135,"_24":48,"_136":-5,"_151":152,"_27":153},["D",1768882382706],"children",[],[127],["D",1768774063322],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":48},{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_122":191,"_192":193,"_194":195,"_196":48,"_197":48,"_198":48,"_199":25,"_200":-5,"_201":-7,"_202":-7,"_203":61,"_204":48,"_205":48,"_206":-5,"_207":48,"_208":48,"_209":48,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":85,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"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 · v55