🧪 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}","children",[],[88],"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}",[],[98],"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}",[],[108],"63a98b0c-3917-11f0-8751-9e149126039e","debug-env.ts","6107210c-3917-11f0-ab8f-9e149126039e",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}",[],[116],"a2811450-3a6e-11f0-88e4-9e149126039e","README.md","1f668130-3916-11f0-aa03-9e149126039e",30,["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",[],[124],["D",1748142768743],[135,136,137],[19],{"_36":68,"_13":69,"_39":70,"_41":42,"_43":44,"_45":71,"_47":48,"_49":144,"_17":51,"_52":53,"_54":73,"_56":57,"_58":-5,"_94":145,"_18":146},{"_36":60,"_13":61,"_39":62,"_41":42,"_43":44,"_45":63,"_47":48,"_49":141,"_17":65,"_52":53,"_54":66,"_56":57,"_58":-5,"_94":142,"_18":143},{"_36":37,"_13":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":138,"_17":51,"_52":53,"_54":55,"_56":57,"_58":-5,"_94":139,"_18":140},["D",1748143884742],[],[19,38],["D",1748143891528],[],[19,61],["D",1748143908846],[],[19,69],"aabc2626-3912-11f0-b0aa-9e149126039e",["D",1748141278512],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","auto-schedule bsky posts from notion base","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/c3929ba2-b6eb-46e4-74a8-c5db68fde400/square512?exp=1789589475&sig=440cf916e4a8c525f308ecc35d50a22e27b968b08b12a43582a86ed2a1e68e9b","userId","56a0f9e0-375a-11f0-a39d-3380429e1c83","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","c07a30e6-b724-410c-b54c-45df602d6743","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_201":197},"org",{"_11":12,"_195":-5,"_196":197,"_158":159,"_198":199,"_200":57},"branch",{"_17":126,"_13":16,"_36":44,"_187":147,"_188":-5,"_189":-5,"_190":-5,"_191":-5,"_192":-5,"_193":14,"_194":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ4VHNLcXVkc2Yxc3RjbzRvSloxRW5OQ1FYRCJ9","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":147,"_13":14,"_49":266,"_149":-5,"_150":57,"_151":152,"_153":152,"_154":155,"_156":157,"_158":159,"_160":117,"_161":48,"_162":48,"_163":-5,"_164":76,"_165":166,"_167":-5,"_168":-5,"_169":-5,"_170":-5,"_171":172,"_173":172,"_174":175,"_176":175,"_177":175,"_178":172,"_179":172,"_180":267,"_182":268,"_184":269,"_186":57},[239,243,244,245,246,247],"files",[239,240,241,242,243,244,245,246,247],"counts",{"_229":78,"_230":65,"_231":65,"_32":232,"_233":234},[223,224,225],{"_36":75,"_43":44,"_39":42,"_13":19,"_54":-5,"_52":79,"_17":78,"_41":-5,"_49":221,"_45":76,"_58":-5,"_18":222},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1748142768743],[19],{"_36":68,"_13":69,"_39":70,"_41":42,"_43":44,"_45":71,"_47":48,"_49":72,"_17":51,"_52":53,"_54":73,"_56":57,"_58":-5,"_18":228},{"_36":60,"_13":61,"_39":62,"_41":42,"_43":44,"_45":63,"_47":48,"_49":64,"_17":65,"_52":53,"_54":66,"_56":57,"_58":-5,"_18":227},{"_36":37,"_13":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_17":51,"_52":53,"_54":55,"_56":57,"_58":-5,"_18":226},[19,38],[19,61],[19,69],"pulls","branches","forks",{"_235":237,"_238":78},"connections",{"_235":78,"_236":78},"count","unfilledCount",4,"emptyCount",{"_36":75,"_13":19,"_39":42,"_41":-5,"_43":44,"_45":76,"_47":48,"_49":132,"_17":78,"_52":79,"_54":-5,"_56":57,"_58":-5,"_94":264,"_18":265},{"_36":68,"_13":69,"_39":70,"_41":42,"_43":44,"_45":71,"_47":48,"_49":144,"_17":51,"_52":53,"_54":73,"_56":57,"_58":-5,"_94":262,"_18":263},{"_36":60,"_13":61,"_39":62,"_41":42,"_43":44,"_45":63,"_47":48,"_49":141,"_17":65,"_52":53,"_54":66,"_56":57,"_58":-5,"_94":260,"_18":261},{"_36":37,"_13":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":138,"_17":51,"_52":53,"_54":55,"_56":57,"_58":-5,"_94":258,"_18":259},{"_36":123,"_13":124,"_39":125,"_41":-5,"_43":44,"_45":126,"_47":48,"_49":127,"_17":128,"_52":24,"_54":129,"_56":57,"_58":-5,"_94":256,"_18":257},{"_36":115,"_13":116,"_39":117,"_41":-5,"_43":44,"_45":118,"_47":48,"_49":119,"_17":65,"_52":92,"_54":120,"_56":57,"_58":-5,"_94":254,"_18":255},{"_36":107,"_13":108,"_39":109,"_41":-5,"_43":44,"_45":110,"_47":48,"_49":111,"_17":76,"_52":92,"_54":112,"_56":57,"_58":-5,"_94":252,"_18":253},{"_36":97,"_13":98,"_39":99,"_41":-5,"_43":44,"_45":100,"_47":48,"_49":101,"_17":102,"_52":103,"_54":104,"_56":57,"_58":-5,"_94":250,"_18":251},{"_36":87,"_13":88,"_39":89,"_41":-5,"_43":44,"_45":90,"_47":48,"_49":91,"_17":65,"_52":92,"_54":93,"_56":57,"_58":-5,"_94":248,"_18":249},[],[88],[],[98],[],[108],[],[116],[],[124],[],[19,38],[],[19,61],[],[19,69],[240,241,242],[19],["D",1748141278512],{"_11":12,"_201":197},{"_11":12,"_195":-5,"_196":197,"_158":159,"_198":199,"_200":57},{"_17":126,"_13":16,"_36":44,"_187":147,"_188":-5,"_189":-5,"_190":-5,"_191":-5,"_192":-5,"_193":14,"_194":12},"ctx",{"_180":-5,"_218":303,"_304":305,"_306":307,"_308":57,"_309":57,"_310":57,"_311":48,"_312":-5,"_313":-7,"_314":-7,"_315":78,"_316":57,"_317":57,"_318":-5,"_319":57,"_320":57,"_321":57,"_322":-5},"ENV",{"_274":275,"_276":277,"_278":16,"_279":280,"_281":282,"_283":284,"_285":286,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302},"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"]