🚀 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}",[],[224],{"_104":232,"_95":233,"_156":234,"_158":-5,"_159":141,"_160":101,"_161":162,"_106":235,"_100":236,"_164":237,"_166":238,"_167":22,"_168":-5,"_169":239,"_98":240},"df3df13e-3932-11f0-9e10-9e149126039e","scheduler.ts","37bb4522-3916-11f0-a786-9e149126039e",["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}",[],[233],{"_104":242,"_95":99,"_156":243,"_158":-5,"_159":141,"_160":244,"_161":162,"_106":245,"_100":188,"_164":218,"_166":246,"_167":22,"_168":-5,"_169":247,"_98":248},"4f5a433a-3917-11f0-99bb-9e149126039e","4da7e3c6-3917-11f0-a2ae-9e149126039e",8,["D",1748143272641],"import { NotionClient } from './lib/notion.ts';\nimport { BlueskyClient } from './lib/bluesky.ts';\n\n/**\n * Test function to verify the N2B Scheduler setup\n * This will check your environment variables and test the connections\n */\nexport default async function(req: Request) {\n const html = `\n \n \n \n N2B Scheduler Test\n \n \n \n

🧪 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}",[],[99],"files",[153,171,182,192,202,212,222,231,241],"counts",{"_253":32,"_254":188,"_255":188,"_256":257},"pulls","branches","forks","envVars",{"_258":259,"_260":32},"count",4,"emptyCount","contents",[],{"_104":242,"_95":99,"_156":243,"_158":-5,"_159":141,"_160":244,"_161":162,"_106":264,"_100":188,"_164":218,"_166":246,"_167":22,"_168":-5,"_98":265},["D",1748143272641],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":274,"_151":279,"_249":307,"_208":308,"_261":310,"_311":-5,"_312":-5,"_313":-5,"_314":-5,"_315":316},{"_104":105,"_95":96,"_106":275,"_108":-5,"_109":22,"_110":111,"_112":113,"_114":115,"_14":116,"_117":-5,"_118":22,"_119":-5,"_120":121,"_16":122,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_23":276,"_135":277,"_138":278,"_150":22},["D",1748141278512],{"_93":94,"_133":134},{"_93":94,"_137":134,"_14":116},{"_100":140,"_95":43,"_104":141,"_142":105,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":96,"_149":94},[280,292,295,298,301,304],{"_104":154,"_95":155,"_156":157,"_158":-5,"_159":141,"_160":121,"_161":162,"_106":163,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":281,"_98":291},[282,285,288],{"_104":172,"_95":173,"_156":174,"_158":157,"_159":141,"_160":175,"_161":162,"_106":176,"_100":177,"_164":178,"_166":179,"_167":22,"_168":-5,"_169":283,"_98":284},[],[155,173],{"_104":183,"_95":184,"_156":185,"_158":157,"_159":141,"_160":186,"_161":162,"_106":187,"_100":188,"_164":178,"_166":189,"_167":22,"_168":-5,"_169":286,"_98":287},[],[155,184],{"_104":193,"_95":194,"_156":195,"_158":157,"_159":141,"_160":196,"_161":162,"_106":197,"_100":177,"_164":178,"_166":198,"_167":22,"_168":-5,"_169":289,"_98":290},[],[155,194],[155],{"_104":203,"_95":204,"_156":205,"_158":-5,"_159":141,"_160":206,"_161":22,"_106":207,"_100":177,"_164":208,"_166":209,"_167":22,"_168":-5,"_169":293,"_98":294},[],[204],{"_104":213,"_95":214,"_156":215,"_158":-5,"_159":141,"_160":216,"_161":162,"_106":217,"_100":188,"_164":218,"_166":219,"_167":22,"_168":-5,"_169":296,"_98":297},[],[214],{"_104":223,"_95":224,"_156":225,"_158":-5,"_159":141,"_160":226,"_161":162,"_106":227,"_100":121,"_164":218,"_166":228,"_167":22,"_168":-5,"_169":299,"_98":300},[],[224],{"_104":232,"_95":233,"_156":234,"_158":-5,"_159":141,"_160":101,"_161":162,"_106":235,"_100":236,"_164":237,"_166":238,"_167":22,"_168":-5,"_169":302,"_98":303},[],[233],{"_104":242,"_95":99,"_156":243,"_158":-5,"_159":141,"_160":244,"_161":162,"_106":245,"_100":188,"_164":218,"_166":246,"_167":22,"_168":-5,"_169":305,"_98":306},[],[99],[280,282,285,288,292,295,298,301,304],{"_104":242,"_95":99,"_156":243,"_158":-5,"_159":141,"_160":244,"_161":162,"_106":264,"_100":188,"_164":218,"_166":246,"_167":22,"_168":-5,"_98":309},[99],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

nucky

notion-2-bluesky