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

\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(\"interval received:\", JSON.stringify(interval));\n\n if (RECIPIENTS.length === 0) {\n console.log(\"No RECIPIENTS configured in digest.ts, skipping email\");\n return { sent: false, reason: \"no_recipients\" };\n }\n\n const dashboardUrl = await httpEndpoint(\"main.ts\", import.meta.url);\n const since = interval?.lastRunAt?.getTime() ??\n Date.now() - 24 * 60 * 60 * 1000;\n\n console.log(\"looking back to:\", new Date(since).toISOString());\n\n const leads = await getAllLeads();\n console.log(\"total leads in db:\", leads.length);\n\n const matches = leads\n .filter((l) => l.timestamp > since)\n .filter((l) => JSON.parse(l.output_data).match)\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 console.log(\"matches found:\", matches.length);\n\n if (matches.length === 0) {\n console.log(\"No matches since\", new Date(since).toISOString());\n return { sent: false };\n }\n\n const subject = `🎯 ${matches.length} Qualified Lead${\n matches.length !== 1 ? \"s\" : \"\"\n }`;\n await email({\n to: RECIPIENTS,\n subject,\n html: formatHTML(matches, dashboardUrl),\n });\n\n console.log(\n `Sent digest: ${matches.length} leads to ${RECIPIENTS.join(\", \")}`,\n );\n return { sent: true, count: matches.length };\n}","deleted","label",[100],"permalink","https://www.val.town/x/acumenix/github-leads/code/digest.ts","extension","actionData","errors"]