🧪 N2B Scheduler Test

🔄 Running tests...

\n \n \n \n \n `;\n\n const url = new URL(req.url);\n \n if (url.pathname === '/api/test') {\n return new Response(JSON.stringify(await runTestSuite()), {\n headers: { 'Content-Type': 'application/json' }\n });\n }\n \n return new Response(html, {\n headers: { 'Content-Type': 'text/html' }\n });\n}\n\nasync function runTestSuite() {\n const tests = [];\n \n // Test 1: Environment Variables\n try {\n const notionToken = Deno.env.get('NOTION_TOKEN');\n const notionDatabaseId = Deno.env.get('NOTION_DATABASE_ID');\n const blueskyHandle = Deno.env.get('BLUESKY_HANDLE');\n const blueskyAppPassword = Deno.env.get('BLUESKY_APP_PASSWORD');\n\n const missing = [];\n if (!notionToken) missing.push('NOTION_TOKEN');\n if (!notionDatabaseId) missing.push('NOTION_DATABASE_ID');\n if (!blueskyHandle) missing.push('BLUESKY_HANDLE');\n if (!blueskyAppPassword) missing.push('BLUESKY_APP_PASSWORD');\n\n if (missing.length > 0) {\n tests.push({\n name: 'Environment Variables',\n success: false,\n message: `Missing environment variables: ${missing.join(', ')}`,\n });\n } else {\n // Clean up the handle (remove @ if present)\n const cleanHandle = blueskyHandle.startsWith('@') ? blueskyHandle.slice(1) : blueskyHandle;\n \n tests.push({\n name: 'Environment Variables',\n success: true,\n message: 'All required environment variables are set',\n details: `Handle: ${cleanHandle}\\nDatabase ID: ${notionDatabaseId.substring(0, 8)}...`\n });\n }\n } catch (error) {\n tests.push({\n name: 'Environment Variables',\n success: false,\n message: `Error checking environment variables: ${error.message}`,\n });\n }\n\n // Test 2: Notion Connection\n try {\n const notionToken = Deno.env.get('NOTION_TOKEN');\n const notionDatabaseId = Deno.env.get('NOTION_DATABASE_ID');\n \n if (notionToken && notionDatabaseId) {\n const notion = new NotionClient(notionToken, notionDatabaseId);\n const posts = await notion.getScheduledPosts();\n \n tests.push({\n name: 'Notion Connection',\n success: true,\n message: `Successfully connected to Notion database`,\n details: `Found ${posts.length} scheduled posts ready to publish`\n });\n }\n } catch (error) {\n tests.push({\n name: 'Notion Connection',\n success: false,\n message: `Failed to connect to Notion: ${error.message}`,\n details: 'Check your NOTION_TOKEN and NOTION_DATABASE_ID. Make sure the integration has access to the database.'\n });\n }\n\n // Test 3: Bluesky Authentication\n try {\n const blueskyHandle = Deno.env.get('BLUESKY_HANDLE');\n const blueskyAppPassword = Deno.env.get('BLUESKY_APP_PASSWORD');\n \n if (blueskyHandle && blueskyAppPassword) {\n // Clean up the handle (remove @ if present)\n const cleanHandle = blueskyHandle.startsWith('@') ? blueskyHandle.slice(1) : blueskyHandle;\n \n const bluesky = new BlueskyClient(cleanHandle, blueskyAppPassword);\n await bluesky.authenticate();\n \n tests.push({\n name: 'Bluesky Authentication',\n success: true,\n message: `Successfully authenticated with Bluesky as ${cleanHandle}`,\n });\n }\n } catch (error) {\n tests.push({\n name: 'Bluesky Authentication',\n success: false,\n message: `Failed to authenticate with Bluesky: ${error.message}`,\n details: 'Check your BLUESKY_HANDLE and BLUESKY_APP_PASSWORD. Make sure the app password is correct.'\n });\n }\n\n // Test 4: Database Schema Check\n try {\n const notionToken = Deno.env.get('NOTION_TOKEN');\n const notionDatabaseId = Deno.env.get('NOTION_DATABASE_ID');\n \n if (notionToken && notionDatabaseId) {\n const response = await fetch(`https://api.notion.com/v1/databases/${notionDatabaseId}`, {\n headers: {\n 'Authorization': `Bearer ${notionToken}`,\n 'Notion-Version': '2022-06-28',\n },\n });\n \n if (response.ok) {\n const database = await response.json();\n const properties = database.properties;\n \n const requiredFields = ['Title', 'Text', 'Scheduled Date', 'Status', 'URL'];\n const missingFields = requiredFields.filter(field => !properties[field]);\n \n if (missingFields.length > 0) {\n tests.push({\n name: 'Database Schema',\n success: false,\n message: `Missing required fields: ${missingFields.join(', ')}`,\n details: `Available fields: ${Object.keys(properties).join(', ')}`\n });\n } else {\n tests.push({\n name: 'Database Schema',\n success: true,\n message: 'All required database fields are present',\n details: `Fields: ${Object.keys(properties).join(', ')}`\n });\n }\n } else {\n throw new Error(`HTTP ${response.status}`);\n }\n }\n } catch (error) {\n tests.push({\n name: 'Database Schema',\n success: false,\n message: `Failed to check database schema: ${error.message}`,\n });\n }\n\n return { tests };\n}","deleted","label",[115],"df3df13e-3932-11f0-9e10-9e149126039e","scheduler.ts","37bb4522-3916-11f0-a786-9e149126039e",28,["D",1748155110493],6,"interval","import { NotionClient } from './lib/notion.ts';\nimport { BlueskyClient } from './lib/bluesky.ts';\n\n/**\n * N2B Scheduler - Notion to Bluesky Auto Poster\n * \n * This cron job runs every 15 minutes to check for scheduled posts\n * in Notion and publishes them to Bluesky when their time comes.\n */\nexport default async function() {\n console.log('🚀 N2B Scheduler starting...', new Date().toISOString());\n\n try {\n // Get environment variables\n const notionToken = Deno.env.get('NOTION_TOKEN');\n const notionDatabaseId = Deno.env.get('NOTION_DATABASE_ID');\n const blueskyHandle = Deno.env.get('BLUESKY_HANDLE');\n const blueskyAppPassword = Deno.env.get('BLUESKY_APP_PASSWORD');\n\n if (!notionToken || !notionDatabaseId || !blueskyHandle || !blueskyAppPassword) {\n throw new Error('Missing required environment variables. Please set: NOTION_TOKEN, NOTION_DATABASE_ID, BLUESKY_HANDLE, BLUESKY_APP_PASSWORD');\n }\n\n // Initialize clients\n const notion = new NotionClient(notionToken, notionDatabaseId);\n // Clean up handle - remove @ symbol, spaces, and invisible Unicode characters\n const cleanHandle = blueskyHandle\n .replace(/[^\\w.-]/g, '') // Keep only word chars, dots, and hyphens\n .replace(/^@+/, ''); // Remove any @ symbols at the start\n const bluesky = new BlueskyClient(cleanHandle, blueskyAppPassword);\n\n // Get posts that are scheduled and due\n console.log('📋 Checking for scheduled posts...');\n const scheduledPosts = await notion.getScheduledPosts();\n \n if (scheduledPosts.length === 0) {\n console.log('✅ No posts scheduled for now');\n return;\n }\n\n console.log(`📝 Found ${scheduledPosts.length} post(s) ready to publish`);\n\n // Process each post\n for (const post of scheduledPosts) {\n try {\n console.log(`📤 Publishing: \"${post.title}\" (${post.text.substring(0, 50)}...)`);\n \n // Post to Bluesky (with media if available)\n const blueskyUrl = await bluesky.createPost(post.text, post.media);\n console.log(`✅ Posted to Bluesky: ${blueskyUrl}`);\n \n // Update Notion with success\n await notion.updatePostStatus(post.id, 'Posted', blueskyUrl);\n console.log(`📝 Updated Notion status to Posted`);\n \n } catch (error) {\n console.error(`❌ Failed to publish post \"${post.title}\":`, error);\n // Continue with other posts even if one fails\n }\n }\n\n console.log('🎉 N2B Scheduler completed successfully');\n\n } catch (error) {\n console.error('💥 N2B Scheduler failed:', error);\n throw error; // Re-throw to ensure cron job shows as failed\n }\n}",[133],"cfdef7ac-3918-11f0-9623-9e149126039e","manual-test.ts","9b54690a-3917-11f0-ac85-9e149126039e",23,["D",1748143917789],"import { NotionClient } from './lib/notion.ts';\nimport { BlueskyClient } from './lib/bluesky.ts';\n\n/**\n * Manual test to run the scheduler logic once\n * This simulates what the cron job does\n */\nexport default async function(req: Request) {\n const html = `\n \n \n \n Manual N2B Test\n \n \n \n

🚀 Manual N2B Scheduler Test

📋 Instructions:

Make sure you have a post in Notion with Status = \"Scheduled\"
Set the Scheduled Date to a time in the past or very soon
Click the button below to run the scheduler manually

\n \n \n \n

Click the button above to test the scheduler

\n \n \n \n \n `;\n\n const url = new URL(req.url);\n \n if (url.pathname === '/api/run') {\n return new Response(JSON.stringify(await runSchedulerTest()), {\n headers: { 'Content-Type': 'application/json' }\n });\n }\n \n return new Response(html, {\n headers: { 'Content-Type': 'text/html' }\n });\n}\n\nasync function runSchedulerTest() {\n try {\n console.log('🚀 Manual N2B Scheduler test starting...', new Date().toISOString());\n\n // Get environment variables\n const notionToken = Deno.env.get('NOTION_TOKEN');\n const notionDatabaseId = Deno.env.get('NOTION_DATABASE_ID');\n const blueskyHandle = Deno.env.get('BLUESKY_HANDLE');\n const blueskyAppPassword = Deno.env.get('BLUESKY_APP_PASSWORD');\n\n if (!notionToken || !notionDatabaseId || !blueskyHandle || !blueskyAppPassword) {\n throw new Error('Missing required environment variables');\n }\n\n // Initialize clients\n const notion = new NotionClient(notionToken, notionDatabaseId);\n const cleanHandle = blueskyHandle\n .replace(/[^\\w.-]/g, '')\n .replace(/^@+/, '');\n const bluesky = new BlueskyClient(cleanHandle, blueskyAppPassword);\n\n // Get posts that are scheduled and due\n console.log('📋 Checking for scheduled posts...');\n const scheduledPosts = await notion.getScheduledPosts();\n \n if (scheduledPosts.length === 0) {\n return {\n success: true,\n message: 'No posts scheduled for now',\n details: 'Make sure you have a post with Status=\"Scheduled\" and Scheduled Date in the past or very soon'\n };\n }\n\n console.log(`📝 Found ${scheduledPosts.length} post(s) ready to publish`);\n \n const results = [];\n\n // Process each post\n for (const post of scheduledPosts) {\n try {\n console.log(`📤 Publishing: \"${post.title}\" (${post.text.substring(0, 50)}...)`);\n \n // Post to Bluesky (with media if available)\n const blueskyUrl = await bluesky.createPost(post.text, post.media);\n console.log(`✅ Posted to Bluesky: ${blueskyUrl}`);\n \n // Update Notion with success\n await notion.updatePostStatus(post.id, 'Posted', blueskyUrl);\n console.log(`📝 Updated Notion status to Posted`);\n \n results.push({\n title: post.title,\n success: true,\n blueskyUrl: blueskyUrl\n });\n \n } catch (error) {\n console.error(`❌ Failed to publish post \"${post.title}\":`, error);\n results.push({\n title: post.title,\n success: false,\n error: error.message\n });\n }\n }\n\n const successCount = results.filter(r => r.success).length;\n const failCount = results.filter(r => !r.success).length;\n\n return {\n success: failCount === 0,\n message: `Processed ${results.length} post(s): ${successCount} successful, ${failCount} failed`,\n details: JSON.stringify(results, null, 2)\n };\n\n } catch (error) {\n console.error('💥 Manual scheduler test failed:', error);\n return {\n success: false,\n message: error.message,\n details: error.stack\n };\n }\n}",[142],"63a98b0c-3917-11f0-8751-9e149126039e","debug-env.ts",12,["D",1748143306749],"/**\n * Debug environment variables to see exactly what's stored\n */\nexport default async function(req: Request) {\n const blueskyHandle = Deno.env.get('BLUESKY_HANDLE');\n const notionDatabaseId = Deno.env.get('NOTION_DATABASE_ID');\n \n return new Response(JSON.stringify({\n blueskyHandle: {\n value: blueskyHandle,\n length: blueskyHandle?.length,\n charCodes: blueskyHandle ? Array.from(blueskyHandle).map(c => c.charCodeAt(0)) : null,\n cleaned: blueskyHandle ? blueskyHandle.replace(/[^\\w.-]/g, '') : null\n },\n notionDatabaseId: {\n value: notionDatabaseId,\n length: notionDatabaseId?.length,\n }\n }, null, 2), {\n headers: { 'Content-Type': 'application/json' }\n });\n}",[149],"a2811450-3a6e-11f0-88e4-9e149126039e","README.md","1f668130-3916-11f0-aa03-9e149126039e",["D",1748290729561],5,"# N2B Scheduler - Notion to Bluesky Auto Poster\n\nAn automated scheduler that reads posts from a Notion database and publishes them to Bluesky at scheduled times.\n\nSee it in action, https://bsky.app/profile/nucky.bsky.social\n\n## Features\n\n- 📅 Schedule Bluesky posts from Notion database\n- 🤖 Automatic posting via cron job (every 15 minutes)\n- 📊 Status tracking (Draft → Scheduled → Posted)\n- 🔗 Stores posted URLs back to Notion\n- 📸 **Media support** - Upload images with your posts (up to 4 images per post)\n\n## Setup\n\n### 1. Notion Database Setup\n\nYour database needs these fields:\n- **Title** (Title field) - Post title/identifier\n- **Text** (Rich Text field) - The post content\n- **Scheduled Date** (Date field with time) - When to post\n- **Status** (Select field) - Options: Draft, Scheduled, Posted\n- **URL** (URL field) - Stores the Bluesky post URL after posting\n- **Media** (Files & media field) - Upload images (JPG, PNG, GIF, WebP)\n\n### 2. Environment Variables\n\nSet these in your Val Town environment:\n- `NOTION_TOKEN` - Your Notion integration token\n- `NOTION_DATABASE_ID` - Your database ID\n- `BLUESKY_HANDLE` - Your Bluesky handle (e.g., user.bsky.social)\n- `BLUESKY_APP_PASSWORD` - Your Bluesky app password\n\n### 3. Notion Integration Permissions\n\nMake sure your Notion integration has access to:\n- Read content\n- Update content\n- Read database structure\n\n## Files\n\n- `/scheduler.ts` - Main cron job that checks and posts\n- `/lib/notion.ts` - Notion API integration\n- `/lib/bluesky.ts` - Bluesky posting functionality\n- `/lib/types.ts` - TypeScript interfaces\n\n## How It Works\n\n1. Cron job runs every 15 minutes\n2. Queries Notion for posts with status \"Scheduled\" and due date/time\n3. Posts to Bluesky\n4. Updates Notion record with \"Posted\" status and Bluesky URL\n\n## Usage\n\n1. Create a new row in your Notion database\n2. Set the Text field with your post content\n3. **Optional**: Upload images to the Media field (supports JPG, PNG, GIF, WebP)\n4. Set the Scheduled Date field with when you want it posted\n5. Set Status to \"Scheduled\"\n6. The cron job will automatically post it at the scheduled time",[155],"22fc34fc-3916-11f0-9782-9e149126039e","lib","0715c3de-48cf-4405-940f-41f359e72c2f",["D",1748142768743],0,"directory",[162],"pulls","branches","forks","envVars",{"_175":177,"_178":165},"connections",{"_175":165,"_176":165},"count","unfilledCount",4,"emptyCount",{"_18":161,"_20":162,"_116":163,"_118":-5,"_119":69,"_120":43,"_122":39,"_22":230,"_66":165,"_125":166,"_127":-5,"_129":26,"_130":-5,"_189":231,"_86":232},{"_18":222,"_20":223,"_116":224,"_118":163,"_119":69,"_120":225,"_122":39,"_22":226,"_66":209,"_125":210,"_127":227,"_129":26,"_130":-5,"_189":228,"_86":229},{"_18":214,"_20":215,"_116":216,"_118":163,"_119":69,"_120":217,"_122":39,"_22":218,"_66":124,"_125":210,"_127":219,"_129":26,"_130":-5,"_189":220,"_86":221},{"_18":204,"_20":205,"_116":206,"_118":163,"_119":69,"_120":207,"_122":39,"_22":208,"_66":209,"_125":210,"_127":211,"_129":26,"_130":-5,"_189":212,"_86":213},{"_18":154,"_20":155,"_116":156,"_118":-5,"_119":69,"_120":67,"_122":39,"_22":201,"_66":158,"_125":97,"_127":159,"_129":26,"_130":-5,"_189":202,"_86":203},{"_18":148,"_20":149,"_116":37,"_118":-5,"_119":69,"_120":150,"_122":39,"_22":198,"_66":124,"_125":126,"_127":152,"_129":26,"_130":-5,"_189":199,"_86":200},{"_18":141,"_20":142,"_116":143,"_118":-5,"_119":69,"_120":144,"_122":39,"_22":195,"_66":43,"_125":126,"_127":146,"_129":26,"_130":-5,"_189":196,"_86":197},{"_18":132,"_20":133,"_116":134,"_118":-5,"_119":69,"_120":135,"_122":39,"_22":192,"_66":137,"_125":138,"_127":139,"_129":26,"_130":-5,"_189":193,"_86":194},{"_18":114,"_20":115,"_116":117,"_118":-5,"_119":69,"_120":121,"_122":39,"_22":188,"_66":124,"_125":126,"_127":128,"_129":26,"_130":-5,"_189":190,"_86":191},["D",1748143272641],"children",[],[115],["D",1748155110493],[],[133],["D",1748143917789],[],[142],["D",1748143306749],[],[149],["D",1748290729561],[],[155],"bc2cd5b2-3918-11f0-821d-9e149126039e","types.ts","22fc14fe-3916-11f0-9782-9e149126039e",19,["D",1748143884742],3,"script","// Shared types for the N2B Scheduler\n\nexport interface NotionPost {\n id: string;\n title: string;\n text: string;\n scheduledDate: string;\n status: 'Draft' | 'Scheduled' | 'Posted';\n url?: string;\n media?: string[]; // Array of image URLs\n}\n\nexport interface BlueskyPost {\n text: string;\n createdAt: string;\n embed?: {\n $type: 'app.bsky.embed.images';\n images: Array<{\n alt: string;\n image: {\n $type: 'blob';\n ref: {\n $link: string;\n };\n mimeType: string;\n size: number;\n };\n }>;\n };\n}\n\nexport interface BlueskyResponse {\n uri: string;\n cid: string;\n}\n\nexport interface NotionDatabaseResponse {\n results: Array<{\n id: string;\n properties: {\n Title: {\n title: Array<{\n plain_text: string;\n }>;\n };\n Text: {\n rich_text: Array<{\n plain_text: string;\n }>;\n };\n 'Scheduled Date': {\n date: {\n start: string;\n } | null;\n };\n Status: {\n select: {\n name: string;\n } | null;\n };\n URL: {\n url: string | null;\n };\n Media: {\n files: Array<{\n name: string;\n file: {\n url: string;\n };\n }>;\n };\n };\n }>;\n}",[],[162,205],"c0376f32-3918-11f0-92eb-9e149126039e","notion.ts","29cc0078-3916-11f0-89aa-9e149126039e",20,["D",1748143891528],"import type { NotionPost, NotionDatabaseResponse } from './types.ts';\n\nconst NOTION_API_BASE = 'https://api.notion.com/v1';\n\nexport class NotionClient {\n private token: string;\n private databaseId: string;\n\n constructor(token: string, databaseId: string) {\n this.token = token;\n this.databaseId = databaseId;\n }\n\n private async makeRequest(endpoint: string, options: RequestInit = {}) {\n const response = await fetch(`${NOTION_API_BASE}${endpoint}`, {\n ...options,\n headers: {\n 'Authorization': `Bearer ${this.token}`,\n 'Notion-Version': '2022-06-28',\n 'Content-Type': 'application/json',\n ...options.headers,\n },\n });\n\n if (!response.ok) {\n const error = await response.text();\n throw new Error(`Notion API error: ${response.status} ${error}`);\n }\n\n return response.json();\n }\n\n async getScheduledPosts(): Promise {\n const now = new Date().toISOString();\n \n const query = {\n filter: {\n and: [\n {\n property: 'Status',\n select: {\n equals: 'Scheduled'\n }\n },\n {\n property: 'Scheduled Date',\n date: {\n on_or_before: now\n }\n }\n ]\n }\n };\n\n const response: NotionDatabaseResponse = await this.makeRequest(\n `/databases/${this.databaseId}/query`,\n {\n method: 'POST',\n body: JSON.stringify(query),\n }\n );\n\n return response.results.map(this.parseNotionPage);\n }\n\n async updatePostStatus(pageId: string, status: 'Posted', url?: string): Promise {\n const updateData: any = {\n properties: {\n Status: {\n select: {\n name: status\n }\n }\n }\n };\n\n if (url) {\n updateData.properties.URL = {\n url: url\n };\n }\n\n await this.makeRequest(`/pages/${pageId}`, {\n method: 'PATCH',\n body: JSON.stringify(updateData),\n });\n }\n\n private parseNotionPage(page: NotionDatabaseResponse['results'][0]): NotionPost {\n const props = page.properties;\n \n // Extract media URLs\n const mediaUrls = props.Media?.files?.map(file => file.file.url) || [];\n \n return {\n id: page.id,\n title: props.Title?.title?.[0]?.plain_text || '',\n text: props.Text?.rich_text?.map(rt => rt.plain_text).join('') || '',\n scheduledDate: props['Scheduled Date']?.date?.start || '',\n status: (props.Status?.select?.name as any) || 'Draft',\n url: props.URL?.url || undefined,\n media: mediaUrls.length > 0 ? mediaUrls : undefined,\n };\n }\n}",[],[162,215],"ca89dc18-3918-11f0-87cf-9e149126039e","bluesky.ts","303cd022-3916-11f0-b36e-9e149126039e",21,["D",1748143908846],"import type { BlueskyPost, BlueskyResponse } from './types.ts';\n\nexport class BlueskyClient {\n private handle: string;\n private appPassword: string;\n private accessJwt?: string;\n\n constructor(handle: string, appPassword: string) {\n // Clean up handle - remove @ symbol, spaces, and invisible Unicode characters\n this.handle = handle\n .replace(/[^\\w.-]/g, '') // Keep only word chars, dots, and hyphens\n .replace(/^@+/, ''); // Remove any @ symbols at the start\n this.appPassword = appPassword;\n }\n\n async authenticate(): Promise {\n const response = await fetch('https://bsky.social/xrpc/com.atproto.server.createSession', {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify({\n identifier: this.handle,\n password: this.appPassword,\n }),\n });\n\n if (!response.ok) {\n const error = await response.text();\n throw new Error(`Bluesky auth failed: ${response.status} ${error}`);\n }\n\n const data = await response.json();\n this.accessJwt = data.accessJwt;\n }\n\n async createPost(text: string, mediaUrls?: string[]): Promise {\n if (!this.accessJwt) {\n await this.authenticate();\n }\n\n const post: BlueskyPost = {\n text: text,\n createdAt: new Date().toISOString(),\n };\n\n // Handle media uploads if provided\n if (mediaUrls && mediaUrls.length > 0) {\n const images = [];\n \n for (const mediaUrl of mediaUrls.slice(0, 4)) { // Bluesky supports max 4 images\n try {\n const blob = await this.uploadImage(mediaUrl);\n images.push({\n alt: '', // You could extract alt text from Notion if needed\n image: blob,\n });\n } catch (error) {\n console.warn(`Failed to upload image ${mediaUrl}:`, error);\n // Continue with other images\n }\n }\n\n if (images.length > 0) {\n post.embed = {\n $type: 'app.bsky.embed.images',\n images: images,\n };\n }\n }\n\n const record = {\n repo: this.handle,\n collection: 'app.bsky.feed.post',\n record: {\n $type: 'app.bsky.feed.post',\n ...post,\n },\n };\n\n const response = await fetch('https://bsky.social/xrpc/com.atproto.repo.createRecord', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${this.accessJwt}`,\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(record),\n });\n\n if (!response.ok) {\n const error = await response.text();\n throw new Error(`Bluesky post failed: ${response.status} ${error}`);\n }\n\n const result: BlueskyResponse = await response.json();\n \n // Convert AT Protocol URI to web URL\n const postId = result.uri.split('/').pop();\n const userHandle = this.handle;\n return `https://bsky.app/profile/${userHandle}/post/${postId}`;\n }\n\n private async uploadImage(imageUrl: string): Promise {\n // Download the image from Notion\n const imageResponse = await fetch(imageUrl);\n if (!imageResponse.ok) {\n throw new Error(`Failed to download image: ${imageResponse.status}`);\n }\n\n const imageBuffer = await imageResponse.arrayBuffer();\n const contentType = imageResponse.headers.get('content-type') || 'image/jpeg';\n\n // Upload to Bluesky\n const uploadResponse = await fetch('https://bsky.social/xrpc/com.atproto.repo.uploadBlob', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${this.accessJwt}`,\n 'Content-Type': contentType,\n },\n body: imageBuffer,\n });\n\n if (!uploadResponse.ok) {\n const error = await uploadResponse.text();\n throw new Error(`Image upload failed: ${uploadResponse.status} ${error}`);\n }\n\n const uploadResult = await uploadResponse.json();\n \n return {\n $type: 'blob',\n ref: {\n $link: uploadResult.blob.ref.$link,\n },\n mimeType: contentType,\n size: uploadResult.blob.size,\n };\n }\n}",[],[162,223],["D",1748142768743],[180,181,182],[162],["D",1748141278512],{"_16":17,"_84":80},{"_16":17,"_78":-5,"_79":80,"_34":35,"_81":82,"_83":26},{"_66":67,"_20":68,"_18":69,"_70":19,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":21,"_77":17},"ctx",{"_59":-5,"_105":270,"_271":272,"_273":274,"_275":26,"_276":26,"_277":26,"_278":39,"_279":-5,"_280":-7,"_281":-7,"_282":165,"_283":26,"_284":26,"_285":-5,"_286":26,"_287":26,"_288":26,"_289":-5},"ENV",{"_241":242,"_243":244,"_245":68,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

Search