🚨 New GitHub Repositories Detected

\n\n

\n Detection Time: ${new Date().toLocaleString()}
\n Total New Repositories: ${newRepos.length}\n

\n\n ${Object.entries(reposByOrg).map(([org, repos]) => `\n

${org} (${repos.length} new ${repos.length === 1 ? 'repo' : 'repos'})

\n ${repos.map(repo => `\n

\n ${repo.full_name}\n ${repo.private ? 'PRIVATE' : 'PUBLIC'}\n

\n ${repo.description || 'No description provided'}\n

\n Created: ${new Date(repo.created_at).toLocaleString()}\n

\n `).join('')}\n

\n `).join('')}\n\n \n \n \n `;\n}\n\nasync function sendNewRepoNotification(newRepos: NewRepo[]): Promise {\n const repoCount = newRepos.length;\n const orgCount = new Set(newRepos.map(r => r.org)).size;\n\n console.log(` 📝 Generating email for ${repoCount} repos across ${orgCount} orgs...`);\n const htmlContent = generateNewRepoEmail(newRepos);\n\n console.log(` 📤 Sending email...`);\n await email({\n subject: `🚨 ${repoCount} New GitHub ${repoCount === 1 ? 'Repo' : 'Repos'} Detected (${orgCount} ${orgCount === 1 ? 'org' : 'orgs'})`,\n html: htmlContent,\n });\n\n console.log(` ✅ Email notification sent for ${repoCount} new repos`);\n}\n\n// =============================================================================\n// MAIN LOGIC\n// =============================================================================\n\nasync function runCheck(): Promise {\n console.log(\"\\n\" + \"=\".repeat(80));\n console.log(\"🚀 Starting GitHub org repository check...\");\n console.log(\"=\".repeat(80) + \"\\n\");\n\n // Get and validate configuration\n const { GITHUB_TOKEN, ORGS_TO_MONITOR } = getConfig();\n\n const headers = {\n \"Authorization\": `token ${GITHUB_TOKEN}`,\n \"Accept\": \"application/vnd.github.v3+json\",\n };\n\n try {\n // Load current state\n console.log(\"📂 Loading existing state from blob storage...\");\n let state = await loadState();\n console.log(` Found state for ${Object.keys(state).length} organizations\\n`);\n\n const allNewRepos: NewRepo[] = [];\n\n // Process each organization\n console.log(`🔄 Processing ${ORGS_TO_MONITOR.length} organizations...\\n`);\n for (const orgName of ORGS_TO_MONITOR) {\n try {\n console.log(`\\n📦 Processing org: ${orgName}`);\n\n // Fetch current repos\n console.log(` 🌐 Fetching repos from GitHub API...`);\n const currentRepos = await fetchOrgReposWithRetry(orgName, headers);\n console.log(` ✅ Fetched ${currentRepos.length} repos for ${orgName}`);\n\n // Check if first run for this org\n if (isFirstRun(state, orgName)) {\n console.log(` 🆕 First run for ${orgName} - will notify about all ${currentRepos.length} existing repos`);\n // On first run, treat all current repos as \"new\" so user gets notified\n const newRepos = currentRepos.map(repo => ({ ...repo, org: orgName }));\n allNewRepos.push(...newRepos);\n console.log(` 💾 Saving initial state for ${orgName}...`);\n state = await updateState(orgName, currentRepos, state);\n continue;\n }\n\n // Detect new repos (not first run)\n console.log(` 🔍 Checking for new repos...`);\n const newRepos = detectNewRepos(orgName, currentRepos, state);\n\n if (newRepos.length > 0) {\n console.log(` 🎉 Found ${newRepos.length} new repos in ${orgName}:`);\n newRepos.forEach(repo => console.log(` - ${repo.full_name}`));\n allNewRepos.push(...newRepos);\n } else {\n console.log(` ℹ️ No new repos in ${orgName}`);\n }\n\n // Update state\n console.log(` 💾 Updating state for ${orgName}...`);\n state = await updateState(orgName, currentRepos, state);\n\n } catch (error) {\n console.error(`\\n❌ Error processing org ${orgName}:`, error);\n // Continue to next org instead of failing entire run\n }\n }\n\n // Send notification if new repos found\n console.log(\"\\n\" + \"=\".repeat(80));\n if (allNewRepos.length > 0) {\n console.log(`📧 Sending notification for ${allNewRepos.length} total new repos...`);\n await sendNewRepoNotification(allNewRepos);\n console.log(\"✅ Email notification sent successfully!\");\n } else {\n console.log(\"ℹ️ No new repos detected across all organizations\");\n console.log(\" No email will be sent.\");\n }\n\n console.log(\"\\n✅ GitHub org repository check completed successfully\");\n console.log(\"=\".repeat(80) + \"\\n\");\n\n } catch (error) {\n console.error(\"\\n\" + \"=\".repeat(80));\n console.error(\"💥 Fatal error in cron job:\", error);\n console.error(\"=\".repeat(80) + \"\\n\");\n throw error;\n }\n}\n\n// =============================================================================\n// CRON & MANUAL HANDLERS\n// =============================================================================\n\n/**\n * Cron function that runs automatically\n */\nexport default async function (interval: Interval) {\n console.log(\"⏰ Cron triggered at\", new Date().toISOString());\n await runCheck();\n}\n\n/**\n * Manual trigger function\n * Can be called directly to test\n * Set forceInit=true to clear state and test initialization\n */\nexport async function manualTrigger(forceInit = false) {\n console.log(\"\\n\" + \"=\".repeat(80));\n console.log(\"🔧 Manual trigger initiated\");\n console.log(\"=\".repeat(80));\n\n if (forceInit) {\n console.log(\"\\n🗑️ Clearing existing state...\");\n await blob.delete(BLOB_KEY);\n console.log(\"✅ State cleared - will treat all repos as new\\n\");\n }\n\n await runCheck();\n\n console.log(\"\\n\" + \"=\".repeat(80));\n console.log(\"✅ Manual check completed successfully\");\n console.log(\"=\".repeat(80) + \"\\n\");\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/amoeba/githubRepoSnoop/code/main.tsx","extension","actionData","errors"]