${l.repos\n .map(\n (repo: string) =>\n `📦 ${repo.split(\"/\")[1]}`,\n )\n .join(\"\")}

`\n : \"\";\n\n return `\n \n \n

\n ${scoreDisplay}${l.name} ${leadTypesDisplay}${sourceTag}\n

\n ${l.reasoning}\n

\n ${reposDisplay}\n \n \n `;\n })\n .join(\"\");\n\n return `\n \n \n \n \n

🎯 ${companyName}: ${matches.length} Qualified Lead${matches.length !== 1 ? \"s\" : \"\"}

\n \n \n ${rows}\n \n

\n View dashboard\n

\n \n \n `;\n}\n\nexport default async function (interval?: { lastRunAt?: Date }) {\n console.log(\"Digest interval:\", JSON.stringify(interval));\n\n const baseUrl = await httpEndpoint(\"main.ts\", import.meta.url);\n const since = interval?.lastRunAt?.getTime() ?? Date.now() - 24 * 60 * 60 * 1000;\n console.log(\"Looking back to:\", new Date(since).toISOString());\n\n const companies = await getActiveCompanies();\n console.log(\"Active companies:\", companies.length);\n\n let totalSent = 0;\n\n for (const company of companies) {\n const recipients = JSON.parse(company.recipients) as string[];\n if (recipients.length === 0) {\n console.log(`[${company.slug}] No recipients, skipping`);\n continue;\n }\n\n const leads = await getLeadsByCompany(company.id);\n const matches = leads\n .filter((l) => l.timestamp > since)\n .filter((l) => {\n try {\n return JSON.parse(l.output_data).match === true;\n } catch {\n return false;\n }\n })\n .map((l) => ({\n id: l.id,\n source: getSource(l.input_data),\n repos: getRepos(l.input_data),\n ...JSON.parse(l.output_data),\n }))\n .sort((a, b) => (b.score ?? 0) - (a.score ?? 0));\n\n if (matches.length === 0) {\n console.log(`[${company.slug}] No matches since ${new Date(since).toISOString()}`);\n continue;\n }\n\n const dashboardUrl = `${baseUrl}/c/${company.slug}`;\n const subject = `🎯 ${company.display_name}: ${matches.length} Qualified Lead${matches.length !== 1 ? \"s\" : \"\"}`;\n\n await email({\n to: recipients,\n subject,\n html: formatHTML(matches, dashboardUrl, company.display_name),\n });\n\n console.log(`[${company.slug}] Sent ${matches.length} leads to ${recipients.join(\", \")}`);\n totalSent += matches.length;\n }\n\n return { sent: totalSent > 0, totalLeads: totalSent };\n}\n","deleted","label",[99],"permalink","https://www.val.town/x/dcm31/github-leads-multi-company/code/digest.ts","extension","actionData","errors"]