[{"_1":2,"_303":-5,"_304":-5},"loaderData",{"_3":4,"_96":97,"_215":216,"_302":-5},"root",{"_5":6,"_33":34,"_65":66},"ctx",{"_7":8,"_19":20,"_21":-5,"_22":23,"_24":25,"_26":27,"_28":27,"_29":27,"_30":31,"_32":27},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","environmentVariableKeys",[],"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers",false,"preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","cd91d0696cef9eeb93d71d606c9edd488d76e7fe","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","WORKER_FINGERPRINT","fd7e47ba602df66e0f857b45e802b861","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":44,"_72":73,"_74":73,"_75":27,"_76":73,"_77":73,"_78":73,"_79":73,"_80":73,"_81":73,"_82":73,"_83":73,"_84":85,"_94":27,"_95":27},"__clerk_ssr_state",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__signInForceRedirectUrl","__signUpForceRedirectUrl","__signInFallbackRedirectUrl","__signUpFallbackRedirectUrl","__clerk_debug",{"_86":27,"_87":73,"_88":89,"_90":73,"_91":44,"_92":27,"_93":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_98":99,"_100":101,"_102":42,"_103":73,"_104":-7,"_105":106,"_150":151,"_181":182,"_183":184,"_189":190,"_163":-5,"_197":198,"_204":205,"_213":27,"_214":27},"handle","ianv","name","blueskyAlert","branchName","path","version","project",{"_107":108,"_100":101,"_109":110,"_111":-5,"_112":113,"_114":115,"_116":-5,"_117":-5,"_12":118,"_119":-5,"_120":113,"_121":-5,"_122":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_133":27,"_21":134,"_137":138},"id","3241a7b8-2781-11f0-b46e-569c3dd06744","createdAt",["D",1746209629588],"deletedAt","legacyEnvVars",true,"privacy","public","description","imageUrl","8d236517-5555-4f37-829e-c2c222653030","pinnedFileId","pinPreview","screenshotVersion","likeCount",1,"userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","isOwned",{"_98":99,"_135":136},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXgxd2RPTzg3QUh4NzgxajlwV1o0c1B5aiIsImluaXRpYWxzIjoiSVYifQ","branch",{"_104":139,"_100":42,"_107":140,"_141":108,"_142":143,"_144":31,"_145":115,"_146":147,"_148":101,"_149":99},10,"3241f5d8-2781-11f0-b46e-569c3dd06744","projectId","forkedBranchId","25ea44fc-1962-11f0-a443-569c3dd06744","forkedBranchVersion","forkedProjectPrivacy","forkedProjectUserId","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","projectName","userHandle","tree",[152,171],{"_107":153,"_100":154,"_155":156,"_157":-5,"_158":140,"_159":123,"_160":113,"_109":161,"_104":31,"_162":163,"_164":165,"_166":27,"_167":-5,"_168":169,"_103":170},"324a07dc-2781-11f0-b46e-569c3dd06744","README.md","fileId","324a0854-2781-11f0-b46e-569c3dd06744","parentId","branchId","branchVersion","latest",["D",1734736598763],"fileType","file","content","# Bluesky keyword alerts\n\nCustom notifications for when you, your company, or anything you care about is mentioned on Bluesky.\n\n## 1. Query\n\nSpecify your queries in the `queries` variable.\n\n[Bluesky doesn't support boolean OR yet](https://github.com/bluesky-social/social-app/issues/1522) so we do a separate search for each keyword.\n\nSearch demo: https://www.val.town/v/stevekrouse/blueskySearchPostsDemo\n\n## 2. Notification\n\nBelow I'm sending these mentions to a private channel in our company Discord, but you can customize that to whatever you want, @std/email, Slack, Telegram, whatever.","deleted","label","children",[],[154],{"_107":172,"_100":173,"_155":174,"_157":-5,"_158":140,"_159":139,"_160":113,"_109":175,"_104":176,"_162":177,"_164":178,"_166":27,"_167":-5,"_168":179,"_103":180},"32937994-2781-11f0-b46e-569c3dd06744","main.tsx","324a02f0-2781-11f0-b46e-569c3dd06744",["D",1735355529848],9,"interval","import { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"posthog\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n const res = await agent.app.bsky.feed.searchPosts({\n q,\n sort: \"latest\",\n since: lastRunAt?.toISOString(),\n });\n const posts = res.data?.posts;\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(blocks: object[]): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ blocks }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // Format posts into Slack blocks\n const blocks = posts.map(post => {\n return [\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: ``,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: post.record.text,\n },\n },\n {\n type: \"context\",\n elements: [\n {\n type: \"mrkdwn\",\n text: `Posted on *${new Date(post.record.createdAt).toLocaleDateString()}* by *${post.author.displayName}*`,\n },\n ],\n },\n { type: \"divider\" },\n ];\n }).flat();\n\n // Send the Slack message\n await sendSlackMessage(blocks);\n};",[],[173],"files",[152,171],"counts",{"_185":31,"_186":123,"_187":123,"_188":31},"pulls","branches","forks","envVars","contents",[191,194],{"_107":153,"_100":154,"_155":156,"_157":-5,"_158":140,"_159":123,"_160":113,"_109":192,"_104":31,"_162":163,"_164":165,"_166":27,"_167":-5,"_103":193},["D",1734736598763],[154],{"_107":172,"_100":173,"_155":174,"_157":-5,"_158":140,"_159":139,"_160":113,"_109":195,"_104":176,"_162":177,"_164":178,"_166":27,"_167":-5,"_103":196},["D",1735355529848],[173],"upstreamProject",{"_107":199,"_100":101,"_116":200,"_117":-5,"_114":115,"_21":201},"25e9eb10-1962-11f0-a443-569c3dd06744","Get notified when Val Town is mentioned on Bluesky",{"_98":202,"_135":203},"stevekrouse","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","upstreamBranch",{"_107":143,"_109":206,"_207":208,"_100":42,"_141":199,"_104":209,"_142":210,"_144":31,"_211":212,"_111":-5,"_133":27,"_114":115,"_149":202,"_148":101},["D",1744656978203],"updatedAt",["D",1744656979856],46,"b9093948-2793-11f0-9d52-569c3dd06744","lockfileKey","1744657771289-esm.town_v_stevekrouse_blueskyAlert@46-main","emptyEnvVars","isNew","routes/_app.x.$handle.$name.branch.$branch.history",{"_98":99,"_100":101,"_102":42,"_105":217,"_221":222,"_300":31,"_301":27},{"_107":108,"_100":101,"_109":218,"_111":-5,"_112":113,"_114":115,"_116":-5,"_117":-5,"_12":118,"_119":-5,"_120":113,"_121":-5,"_122":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_133":27,"_21":219,"_137":220},["D",1746209629588],{"_98":99,"_135":136},{"_104":139,"_100":42,"_107":140,"_141":108,"_142":143,"_144":31,"_145":115,"_146":147,"_148":101,"_149":99},"history",[223,228,236,244,252,260,267,275,283,290],{"_155":174,"_104":139,"_109":224,"_158":140,"_181":225},["D",1735355529848],[226],{"_107":172,"_158":140,"_155":174,"_100":173,"_164":178,"_162":177,"_104":176,"_157":-5,"_109":224,"_159":139,"_167":-5,"_160":113,"_166":27,"_103":227},[173],{"_155":174,"_104":176,"_109":229,"_158":140,"_181":230},["D",1735355381472],[231],{"_107":232,"_158":140,"_155":174,"_100":173,"_164":233,"_162":177,"_104":234,"_157":-5,"_109":229,"_159":176,"_167":-5,"_160":27,"_166":27,"_103":235},"328ca862-2781-11f0-b46e-569c3dd06744","import { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"posthog\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n // const res = await agent.app.bsky.feed.searchPosts({\n // q,\n // sort: \"latest\",\n // since: lastRunAt?.toISOString(),\n // });\n // const posts = res.data?.posts;\n\n const posts = [\n {\n uri: \"at://did:plc:5htjlplvb63k7nhsrltadcfh/app.bsky.feed.post/3lecxiusexc2r\",\n cid: \"bafyreihxcjvxwuc72pkhjp4jp3xfvp54dt7pokbsii6m6klh3conja4jdm\",\n author: {\n did: \"did:plc:5htjlplvb63k7nhsrltadcfh\",\n handle: \"builditn0w.bsky.social\",\n displayName: \"Lars 🚀\",\n avatar:\n \"https://cdn.bsky.app/img/avatar/plain/did:plc:5htjlplvb63k7nhsrltadcfh/bafkreidc5u2ffv4n4cojsgy5zcrr3d2g2rcsntihf3xxrxle4bcqdig6he@jpeg\",\n labels: [],\n createdAt: \"2024-11-05T19:42:58.079Z\",\n },\n record: {\n \"$type\": \"app.bsky.feed.post\",\n createdAt: \"2024-12-27T21:44:22.874Z\",\n langs: [\"en\"],\n reply: {\n parent: {\n cid: \"bafyreigku6fx6a4tzs2i3izfqdcfvx6kgssjo4yyr5zeebuv7lhcsgc5ve\",\n uri: \"at://did:plc:xtjxu5thjmrqvgw6jfu43asn/app.bsky.feed.post/3le3aelxbn22l\",\n },\n root: {\n cid: \"bafyreib2tbld3lcm2weng2yyh4loqwic64zmjquznzjp6seexgbwluvtdu\",\n uri: \"at://did:plc:5htjlplvb63k7nhsrltadcfh/app.bsky.feed.post/3lcucpx7gqu2t\",\n },\n },\n text: \"No worries mate!\\n\"\n + \"\\n\"\n + \"I think with posthog you can definitely do all you need! Or did you found something that is not possible so far?\",\n },\n replyCount: 0,\n repostCount: 0,\n likeCount: 0,\n quoteCount: 0,\n indexedAt: \"2024-12-27T21:44:23.859Z\",\n labels: [],\n },\n ];\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(blocks: object[]): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ blocks }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // Format posts into Slack blocks\n const blocks = posts.map(post => {\n return [\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: ``,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: post.record.text,\n },\n },\n {\n type: \"context\",\n elements: [\n {\n type: \"mrkdwn\",\n text: `Posted on *${new Date(post.record.createdAt).toLocaleDateString()}* by *${post.author.displayName}*`,\n },\n ],\n },\n { type: \"divider\" },\n ];\n }).flat();\n\n // Send the Slack message\n await sendSlackMessage(blocks);\n};",8,[173],{"_155":174,"_104":234,"_109":237,"_158":140,"_181":238},["D",1735355337033],[239],{"_107":240,"_158":140,"_155":174,"_100":173,"_164":241,"_162":177,"_104":242,"_157":-5,"_109":237,"_159":234,"_167":-5,"_160":27,"_166":27,"_103":243},"328613d0-2781-11f0-b46e-569c3dd06744","import { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"posthog\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n // const res = await agent.app.bsky.feed.searchPosts({\n // q,\n // sort: \"latest\",\n // since: lastRunAt?.toISOString(),\n // });\n // const posts = res.data?.posts;\n\n const posts = [\n {\n uri: \"at://did:plc:5htjlplvb63k7nhsrltadcfh/app.bsky.feed.post/3lecxiusexc2r\",\n cid: \"bafyreihxcjvxwuc72pkhjp4jp3xfvp54dt7pokbsii6m6klh3conja4jdm\",\n author: {\n did: \"did:plc:5htjlplvb63k7nhsrltadcfh\",\n handle: \"builditn0w.bsky.social\",\n displayName: \"Lars 🚀\",\n avatar:\n \"https://cdn.bsky.app/img/avatar/plain/did:plc:5htjlplvb63k7nhsrltadcfh/bafkreidc5u2ffv4n4cojsgy5zcrr3d2g2rcsntihf3xxrxle4bcqdig6he@jpeg\",\n labels: [],\n createdAt: \"2024-11-05T19:42:58.079Z\",\n },\n record: {\n \"$type\": \"app.bsky.feed.post\",\n createdAt: \"2024-12-27T21:44:22.874Z\",\n langs: [\"en\"],\n reply: {\n parent: {\n cid: \"bafyreigku6fx6a4tzs2i3izfqdcfvx6kgssjo4yyr5zeebuv7lhcsgc5ve\",\n uri: \"at://did:plc:xtjxu5thjmrqvgw6jfu43asn/app.bsky.feed.post/3le3aelxbn22l\",\n },\n root: {\n cid: \"bafyreib2tbld3lcm2weng2yyh4loqwic64zmjquznzjp6seexgbwluvtdu\",\n uri: \"at://did:plc:5htjlplvb63k7nhsrltadcfh/app.bsky.feed.post/3lcucpx7gqu2t\",\n },\n },\n text: \"No worries mate!\\n\"\n + \"\\n\"\n + \"I think with posthog you can definitely do all you need! Or did you found something that is not possible so far?\",\n },\n replyCount: 0,\n repostCount: 0,\n likeCount: 0,\n quoteCount: 0,\n indexedAt: \"2024-12-27T21:44:23.859Z\",\n labels: [],\n },\n ];\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(blocks: object[]): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ blocks }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // Format posts into Slack blocks\n const blocks = posts.map(post => {\n return [\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: ``,\n },\n accessory: {\n type: \"image\",\n image_url: post.author.avatar,\n alt_text: `Avatar of ${post.author.displayName}`,\n },\n },\n {\n type: \"context\",\n elements: [\n {\n type: \"mrkdwn\",\n text:\n `*Reply to:* <${post.record.reply.parent?.uri}|Parent Post> · <${post.record.reply.root?.uri}|Root Post>`,\n },\n ],\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: post.record.text,\n },\n },\n {\n type: \"context\",\n elements: [\n {\n type: \"mrkdwn\",\n text: `Posted on *${new Date(post.record.createdAt).toLocaleDateString()}* by *${post.author.displayName}*`,\n },\n ],\n },\n { type: \"divider\" },\n ];\n }).flat();\n\n // Send the Slack message\n await sendSlackMessage(blocks);\n};",7,[173],{"_155":174,"_104":242,"_109":245,"_158":140,"_181":246},["D",1735354924158],[247],{"_107":248,"_158":140,"_155":174,"_100":173,"_164":249,"_162":177,"_104":250,"_157":-5,"_109":245,"_159":242,"_167":-5,"_160":27,"_166":27,"_103":251},"3280478e-2781-11f0-b46e-569c3dd06744","import { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"posthog\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n // const res = await agent.app.bsky.feed.searchPosts({\n // q,\n // sort: \"latest\",\n // since: lastRunAt?.toISOString(),\n // });\n // const posts = res.data?.posts;\n\n const posts = [\n {\n uri: \"at://did:plc:5htjlplvb63k7nhsrltadcfh/app.bsky.feed.post/3lecxiusexc2r\",\n cid: \"bafyreihxcjvxwuc72pkhjp4jp3xfvp54dt7pokbsii6m6klh3conja4jdm\",\n author: {\n did: \"did:plc:5htjlplvb63k7nhsrltadcfh\",\n handle: \"builditn0w.bsky.social\",\n displayName: \"Lars 🚀\",\n avatar: \"https://cdn.bsky.app/img/avatar/plain/did:plc:5htjlplvb63k7nhsrltadcfh/bafkreidc5u2ffv4n4cojsgy5zcrr3d2g2rcsntihf3xxrxle4bcqdig6he@jpeg\",\n labels: [],\n createdAt: \"2024-11-05T19:42:58.079Z\"\n },\n record: {\n \"$type\": \"app.bsky.feed.post\",\n createdAt: \"2024-12-27T21:44:22.874Z\",\n langs: [ \"en\" ],\n reply: {\n parent: {\n cid: \"bafyreigku6fx6a4tzs2i3izfqdcfvx6kgssjo4yyr5zeebuv7lhcsgc5ve\",\n uri: \"at://did:plc:xtjxu5thjmrqvgw6jfu43asn/app.bsky.feed.post/3le3aelxbn22l\"\n },\n root: {\n cid: \"bafyreib2tbld3lcm2weng2yyh4loqwic64zmjquznzjp6seexgbwluvtdu\",\n uri: \"at://did:plc:5htjlplvb63k7nhsrltadcfh/app.bsky.feed.post/3lcucpx7gqu2t\"\n }\n },\n text: \"No worries mate!\\n\" +\n \"\\n\" +\n \"I think with posthog you can definitely do all you need! Or did you found something that is not possible so far?\"\n },\n replyCount: 0,\n repostCount: 0,\n likeCount: 0,\n quoteCount: 0,\n indexedAt: \"2024-12-27T21:44:23.859Z\",\n labels: []\n }\n]\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(message: string): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n blocks: [\n {\n type: \"section\",\n text: { type: \"mrkdwn\", text: message },\n },\n ],\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // format\n const content = posts.map(\n post =>\n `New Bluesky mention:\\n• By ${post.author.handle}: `,\n ).join(\n \"\\n\",\n );\n\n // notify\n await sendSlackMessage(content);\n};",6,[173],{"_155":174,"_104":250,"_109":253,"_158":140,"_181":254},["D",1734800670737],[255],{"_107":256,"_158":140,"_155":174,"_100":173,"_164":257,"_162":177,"_104":258,"_157":-5,"_109":253,"_159":250,"_167":-5,"_160":27,"_166":27,"_103":259},"327a7a5c-2781-11f0-b46e-569c3dd06744","import { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"posthog\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n const res = await agent.app.bsky.feed.searchPosts({\n q,\n sort: \"latest\",\n since: lastRunAt?.toISOString(),\n });\n const posts = res.data?.posts;\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(message: string): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n blocks: [\n {\n type: \"section\",\n text: { type: \"mrkdwn\", text: message },\n },\n ],\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // format\n const content = posts.map(\n post =>\n `New Bluesky mention:\\n• By ${post.author.handle}: `,\n ).join(\n \"\\n\",\n );\n\n // notify\n await sendSlackMessage(content);\n};",5,[173],{"_155":174,"_104":258,"_109":261,"_158":140,"_181":262},["D",1734800666373],[263],{"_107":264,"_158":140,"_155":174,"_100":173,"_164":257,"_162":177,"_104":265,"_157":-5,"_109":261,"_159":258,"_167":-5,"_160":27,"_166":27,"_103":266},"326db740-2781-11f0-b46e-569c3dd06744",4,[173],{"_155":174,"_104":265,"_109":268,"_158":140,"_181":269},["D",1734800646151],[270],{"_107":271,"_158":140,"_155":174,"_100":173,"_164":272,"_162":177,"_104":273,"_157":-5,"_109":268,"_159":265,"_167":-5,"_160":27,"_166":27,"_103":274},"3267e2de-2781-11f0-b46e-569c3dd06744","import { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"posthog\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n const res = await agent.app.bsky.feed.searchPosts({\n q,\n sort: \"latest\",\n since: lastRunAt?.toISOString(),\n });\n const posts = res.data?.posts;\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(message: string): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n blocks: [\n {\n type: \"section\",\n text: { type: \"mrkdwn\", text: message },\n },\n ],\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // format\n const content = posts.map(\n post => `New Bluesky post mentioning Val Town:\\n• By ${post.author.handle}: `\n ).join(\n \"\\n\",\n );\n\n // notify\n await sendSlackMessage(content);\n};",3,[173],{"_155":174,"_104":273,"_109":276,"_158":140,"_181":277},["D",1734736895227],[278],{"_107":279,"_158":140,"_155":174,"_100":173,"_164":280,"_162":177,"_104":281,"_157":-5,"_109":276,"_159":273,"_167":-5,"_160":27,"_166":27,"_103":282},"3261a676-2781-11f0-b46e-569c3dd06744","import { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"val town\", \"val.town\", \"web.val.run\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n const res = await agent.app.bsky.feed.searchPosts({\n q,\n sort: \"latest\",\n since: lastRunAt?.toISOString(),\n });\n const posts = res.data?.posts;\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(message: string): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n blocks: [\n {\n type: \"section\",\n text: { type: \"mrkdwn\", text: message },\n },\n ],\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // format\n const content = posts.map(\n post => `New Bluesky post mentioning Val Town:\\n• By ${post.author.handle}: `\n ).join(\n \"\\n\",\n );\n\n // notify\n await sendSlackMessage(content);\n};",2,[173],{"_155":174,"_104":281,"_109":284,"_158":140,"_181":285},["D",1734736852380],[286],{"_107":287,"_158":140,"_155":174,"_100":173,"_164":288,"_162":177,"_104":123,"_157":-5,"_109":284,"_159":281,"_167":-5,"_160":27,"_166":27,"_103":289},"3250d8f0-2781-11f0-b46e-569c3dd06744","import { discordWebhook } from \"https://esm.town/v/stevekrouse/discordWebhook\";\nimport { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"val town\", \"val.town\", \"web.val.run\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n const res = await agent.app.bsky.feed.searchPosts({\n q,\n sort: \"latest\",\n since: lastRunAt?.toISOString(),\n });\n const posts = res.data?.posts;\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nasync function sendSlackMessage(message: string): Promise {\n const slackWebhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!slackWebhookUrl) {\n throw new Error(\"SLACK_WEBHOOK_URL environment variable is not set\");\n }\n\n const response = await fetch(slackWebhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n blocks: [\n {\n type: \"section\",\n text: { type: \"mrkdwn\", text: message },\n },\n ],\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Slack API error: ${response.status} ${response.statusText}`);\n }\n\n return response;\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // format\n const content = posts.map(\n post => `https://bsky.app/profile/${post.author.handle}/post/${post.uri.split(\"/\").at(-1)}`,\n ).join(\n \"\\n\",\n );\n\n // notify\n await discordWebhook({\n url: Deno.env.get(\"mentionsDiscord\"),\n content,\n });\n};",[173],{"_155":156,"_104":123,"_109":291,"_158":140,"_181":292},["D",1734736598763],[293,295],{"_107":153,"_158":140,"_155":156,"_100":154,"_164":165,"_162":163,"_104":31,"_157":-5,"_109":291,"_159":123,"_167":-5,"_160":113,"_166":27,"_103":294},[154],{"_107":296,"_158":140,"_155":174,"_100":173,"_164":297,"_162":177,"_104":31,"_157":-5,"_109":298,"_159":123,"_167":-5,"_160":27,"_166":27,"_103":299},"324a0246-2781-11f0-b46e-569c3dd06744","import { discordWebhook } from \"https://esm.town/v/stevekrouse/discordWebhook\";\nimport { AtpAgent } from \"npm:@atproto/api@0.13.15\";\nimport pMap from \"npm:p-map\";\n\nconst queries = [\"val town\", \"val.town\", \"web.val.run\"];\n\nconst agent = new AtpAgent({\n service: \"https://public.api.bsky.app/\",\n // fetch, ideally we'd use our @std/fetch proxy here but that doesn't work and I don't know why\n});\n\nasync function search(q: string, lastRunAt: Date | undefined) {\n const res = await agent.app.bsky.feed.searchPosts({\n q,\n sort: \"latest\",\n since: lastRunAt?.toISOString(),\n });\n const posts = res.data?.posts;\n\n // ensure it contains the query exactly\n // ie filter out stray references to \"val\" that aren't about \"val town\"\n return posts.filter(\n p => p.record.text.includes(q),\n );\n}\n\nexport const blueskyAlert = async ({ lastRunAt }: Interval) => {\n let posts = (\n await pMap(\n queries,\n q => search(q, lastRunAt),\n { concurrency: 1 }, // otherwise we get rate-limited\n )\n ).flat();\n\n console.log(posts);\n\n if (posts.length === 0) return;\n\n // format\n const content = posts.map(\n post => `https://bsky.app/profile/${post.author.handle}/post/${post.uri.split(\"/\").at(-1)}`,\n ).join(\n \"\\n\",\n );\n\n // notify\n await discordWebhook({\n url: Deno.env.get(\"mentionsDiscord\"),\n content,\n });\n};",["D",1734736598763],[173],"page","hasNext","routes/_app","actionData","errors"]

History