[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_159":160,"_161":162},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":53,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":58,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",14,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","631aa220-892a-11f1-b53b-1607ee4eb77e","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\ninterface Job {\n title?: string;\n company?: string;\n companyName?: string;\n description?: string;\n descriptionText?: string;\n descriptionHtml?: string;\n location?: string;\n link?: string;\n url?: string;\n jobUrl?: string;\n relevanceScore?: number;\n}\n\nconst titleKeywords = {\n excellent: [\n \"java engineer\",\n \"java developer\",\n \"spring boot\",\n \"full stack engineer\",\n \"full-stack engineer\",\n \"backend engineer\",\n \"microservices engineer\",\n \"software engineer\",\n \"application engineer\",\n \"api engineer\",\n ],\n good: [\n \"developer\",\n \"engineer\",\n \"sde\",\n \"angular developer\",\n \"frontend engineer\",\n ],\n};\n\nconst skillKeywords = {\n excellent: [\n \"java\",\n \"spring boot\",\n \"microservices\",\n \"kafka\",\n \"angular\",\n \"typescript\",\n \"rest api\",\n \"oauth\",\n \"oidc\",\n \"jwt\",\n ],\n good: [\n \"docker\",\n \"kubernetes\",\n \"openshift\",\n \"jenkins\",\n \"ci/cd\",\n \"websocket\",\n \"mysql\",\n \"postgresql\",\n \"aws\",\n \"rxjs\",\n ],\n};\n\nconst bfsKeywords = [\n \"bfsi\",\n \"banking\",\n \"finance\",\n \"fintech\",\n \"insurance\",\n \"payments\",\n \"trading\",\n];\n\nconst badStackKeywords = [\n \".net\",\n \"c#\",\n \"php\",\n \"ruby\",\n \"swift\",\n \"ios\",\n \"android\",\n \"salesforce\",\n \"sap abap\",\n];\n\nconst seniorKeywords = [\n \"senior\",\n \"lead\",\n \"principal\",\n \"staff\",\n \"architect\",\n \"manager\",\n \"director\",\n];\n\nfunction experiencePenalty(text: string) {\n let penalty = 0;\n const matches = text.match(/(\\d+)\\+?\\s*years?/gi);\n if (matches) {\n matches.forEach((match) => {\n const years = parseInt(match);\n if (years >= 7) penalty -= 20;\n else if (years >= 5) penalty -= 12;\n else if (years >= 4) penalty -= 5;\n });\n }\n return penalty;\n}\n\nfunction getDescription(job: Job): string {\n const raw = job.description ?? job.descriptionText ?? job.descriptionHtml ??\n \"\";\n return raw.replace(/<[^>]*>/g, \" \");\n}\n\nfunction getCompany(job: Job): string {\n return job.company ?? job.companyName ?? \"Unknown\";\n}\n\nfunction getLink(job: Job): string {\n return job.link ?? job.url ?? job.jobUrl ?? \"#\";\n}\n\nfunction scoreJob(job: Job): number {\n const title = (job.title ?? \"\").toLowerCase();\n const description = getDescription(job).toLowerCase();\n const text = `${title} ${description}`;\n\n let score = 0;\n\n titleKeywords.excellent.forEach((k) => {\n if (title.includes(k)) score += 15;\n });\n titleKeywords.good.forEach((k) => {\n if (title.includes(k)) score += 7;\n });\n skillKeywords.excellent.forEach((k) => {\n if (text.includes(k)) score += 8;\n });\n skillKeywords.good.forEach((k) => {\n if (text.includes(k)) score += 3;\n });\n bfsKeywords.forEach((k) => {\n if (text.includes(k)) score += 5;\n });\n badStackKeywords.forEach((k) => {\n if (text.includes(k)) score -= 15;\n });\n seniorKeywords.forEach((k) => {\n if (title.includes(k)) score -= 12;\n });\n\n score += experiencePenalty(text);\n\n let finalScore = Math.round(score / 10);\n if (finalScore < 0) finalScore = 0;\n if (finalScore > 10) finalScore = 10;\n return finalScore;\n}\n\nfunction escapeHtml(value: string) {\n return value\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\")\n .replaceAll('\"', \""\");\n}\n\nfunction dedupeKey(title: string, company: string) {\n return `${title}-${company}`.toLowerCase().trim();\n}\n\nexport default async function (req: Request): Promise {\n const APIFY_TOKEN = Deno.env.get(\"APIFY_TOKEN\");\n const RESEND_KEY = Deno.env.get(\"RESEND_KEY\");\n const YOUR_EMAIL = \"eakas000@gmail.com\";\n\n if (!APIFY_TOKEN || !RESEND_KEY) {\n console.error(\"Missing APIFY_TOKEN or RESEND_KEY\");\n return new Response(\"Missing config\", { status: 500 });\n }\n\n await sqlite.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS job_runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id TEXT NOT NULL UNIQUE,\n status TEXT DEFAULT 'pending',\n started_at TEXT\n )\n `,\n args: [],\n });\n\n await sqlite.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS jobs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id TEXT,\n title TEXT,\n company TEXT,\n location TEXT,\n link TEXT,\n score INTEGER,\n dedupe_key TEXT,\n created_at TEXT\n )\n `,\n args: [],\n });\n\n // =====================================================\n // PARSE APIFY WEBHOOK PAYLOAD\n // =====================================================\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n const runId: string | undefined = payload?.resource?.id ??\n payload?.eventData?.actorRunId;\n const status: string | undefined = payload?.resource?.status;\n const datasetId: string | undefined = payload?.resource?.defaultDatasetId;\n\n console.log(\"Webhook received. runId:\", runId, \"status:\", status);\n\n if (!runId || !datasetId) {\n return new Response(\"Missing runId or datasetId in webhook payload\", {\n status: 400,\n });\n }\n\n if (status !== \"SUCCEEDED\") {\n console.log(\"Run did not succeed, skipping:\", status);\n return new Response(\"Run not succeeded, ignored\", { status: 200 });\n }\n\n try {\n // =====================================================\n // FETCH JOB DATA\n // =====================================================\n\n const itemsRes = await fetch(\n `https://api.apify.com/v2/datasets/${datasetId}/items?token=${APIFY_TOKEN}`,\n );\n\n if (!itemsRes.ok) {\n console.error(\n \"Dataset fetch failed:\",\n itemsRes.status,\n await itemsRes.text(),\n );\n return new Response(\"Dataset fetch failed\", { status: 500 });\n }\n\n const linkedinJobs = (await itemsRes.json()) as Job[];\n console.log(`Raw jobs fetched from Apify: ${linkedinJobs.length}`);\n\n if (linkedinJobs.length > 0) {\n console.log(\"Sample job keys:\", Object.keys(linkedinJobs[0]));\n }\n\n // =====================================================\n // SCORE + DEDUPE WITHIN THIS BATCH\n // =====================================================\n\n const MIN_SCORE = 4;\n\n const scoredJobs = linkedinJobs\n .map((job) => ({ ...job, relevanceScore: scoreJob(job) }))\n .filter((job) => (job.relevanceScore ?? 0) >= MIN_SCORE)\n .sort((a, b) => (b.relevanceScore ?? 0) - (a.relevanceScore ?? 0));\n\n const seenInBatch = new Set();\n const batchJobs = scoredJobs.filter((job) => {\n const key = dedupeKey(job.title ?? \"\", getCompany(job));\n if (seenInBatch.has(key)) return false;\n seenInBatch.add(key);\n return true;\n });\n\n // =====================================================\n // DEDUPE AGAINST JOBS SENT IN THE LAST 24H (SQLITE)\n // =====================================================\n\n const cutoff = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const recentResult = await sqlite.execute({\n sql: `SELECT dedupe_key FROM jobs WHERE created_at >= ?`,\n args: [cutoff],\n });\n const alreadySent = new Set(recentResult.rows.map((r: any) => r[0]));\n\n const jobs = batchJobs.filter((job) => {\n const key = dedupeKey(job.title ?? \"\", getCompany(job));\n return !alreadySent.has(key);\n });\n\n console.log(\n `Matching jobs after scoring: ${batchJobs.length}, new (not sent in last 24h): ${jobs.length}`,\n );\n\n // =====================================================\n // BUILD + SEND EMAIL (only if there's something new)\n // =====================================================\n\n let html = `\n

Java / Spring Boot / Angular Jobs (${new Date().toDateString()})

Matching score: 0 = irrelevant | 10 = perfect match

\n `;\n\n if (jobs.length === 0) {\n html += `

No new matching jobs this run.

`;\n } else {\n jobs.forEach((job) => {\n html += `\n

${escapeHtml(job.title ?? \"Unknown role\")}

\n Company: ${escapeHtml(getCompany(job))}

\n Location: ${escapeHtml(job.location ?? \"\")}

\n Match Score: ${job.relevanceScore}/10

\n Apply Now\n

\n `;\n });\n }\n\n // Only send an email when there's at least one new job, to avoid\n // an inbox full of \"no new jobs\" emails every hour.\n if (jobs.length > 0) {\n const emailRes = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${RESEND_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: \"onboarding@resend.dev\",\n to: YOUR_EMAIL,\n subject: `Java Jobs ${\n new Date().toDateString()\n } (${jobs.length} new)`,\n html,\n }),\n });\n\n if (!emailRes.ok) {\n console.error(\"Email failed:\", emailRes.status, await emailRes.text());\n } else {\n console.log(`Email sent successfully. ${jobs.length} new jobs.`);\n }\n } else {\n console.log(\"No new jobs, skipping email.\");\n }\n\n // =====================================================\n // PERSIST RESULTS TO SQLITE (backup + future dedupe)\n // =====================================================\n\n const now = new Date().toISOString();\n for (const job of jobs) {\n await sqlite.execute({\n sql:\n `INSERT INTO jobs (run_id, title, company, location, link, score, dedupe_key, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n runId,\n job.title ?? \"\",\n getCompany(job),\n job.location ?? \"\",\n getLink(job),\n job.relevanceScore ?? 0,\n dedupeKey(job.title ?? \"\", getCompany(job)),\n now,\n ],\n });\n }\n\n await sqlite.execute({\n sql: `UPDATE job_runs SET status = 'done' WHERE run_id = ?`,\n args: [runId],\n });\n\n // =====================================================\n // CLEANUP: DELETE ANYTHING OLDER THAN 24H\n // =====================================================\n\n await sqlite.execute({\n sql: `DELETE FROM jobs WHERE created_at < ?`,\n args: [cutoff],\n });\n await sqlite.execute({\n sql: `DELETE FROM job_runs WHERE started_at < ?`,\n args: [cutoff],\n });\n\n return new Response(\"OK\", { status: 200 });\n } catch (error) {\n console.error(\"Pipeline failed:\", error);\n return new Response(\"Pipeline failed\", { status: 500 });\n }\n}","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// =====================================================================\n// Generic normalized job shape. Each source's raw fields get mapped\n// into this before scoring, so scoring logic doesn't care where the\n// job came from.\n// =====================================================================\ninterface NormalizedJob {\n title: string;\n company: string;\n location: string;\n link: string;\n description: string;\n salaryText: string;\n fundingStage: string; // \"\" if unknown\n source: string;\n}\n\n// =====================================================================\n// SCORING CONFIG\n// =====================================================================\n\nconst titleKeywords = {\n excellent: [\n \"java engineer\",\n \"java developer\",\n \"spring boot\",\n \"full stack engineer\",\n \"full-stack engineer\",\n \"full stack developer\",\n \"full-stack developer\",\n \"backend engineer\",\n \"backend developer\",\n \"microservices engineer\",\n \"software engineer\",\n \"software developer\",\n \"application engineer\",\n \"application developer\",\n \"api engineer\",\n \"product engineer\",\n ],\n good: [\n \"developer\",\n \"engineer\",\n \"sde\",\n \"angular developer\",\n \"frontend engineer\",\n \"fullstack ai developer\",\n \"ai engineer\", // modern-culture roles you asked to broaden into\n \"platform engineer\",\n \"cloud engineer\",\n ],\n};\n\nconst skillKeywords = {\n excellent: [\n \"java\",\n \"spring boot\",\n \"microservices\",\n \"kafka\",\n \"angular\",\n \"typescript\",\n \"rest api\",\n \"oauth\",\n \"oidc\",\n \"jwt\",\n ],\n good: [\n \"docker\",\n \"kubernetes\",\n \"openshift\",\n \"jenkins\",\n \"ci/cd\",\n \"websocket\",\n \"mysql\",\n \"postgresql\",\n \"aws\",\n \"rxjs\",\n \"genai\",\n \"llm\",\n \"langchain\",\n \"machine learning\",\n ],\n};\n\nconst bfsKeywords = [\n \"bfsi\",\n \"banking\",\n \"finance\",\n \"fintech\",\n \"insurance\",\n \"payments\",\n \"trading\",\n];\n\nconst badStackKeywords = [\n \".net\",\n \"c#\",\n \"php\",\n \"ruby\",\n \"swift\",\n \"ios\",\n \"android\",\n \"salesforce\",\n \"sap abap\",\n];\n\nconst seniorKeywords = [\n \"senior\",\n \"lead\",\n \"principal\",\n \"staff\",\n \"architect\",\n \"manager\",\n \"director\",\n];\n\n// Bonus signal for roles that read as right-fit for a 2.5 YOE candidate\nconst juniorFitKeywords = [\n \"0-2 years\",\n \"1-3 years\",\n \"2-4 years\",\n \"2-3 years\",\n \"1-4 years\",\n \"junior\",\n \"associate software\",\n \"early career\",\n \"sde 1\",\n \"sde-1\",\n \"sde i\",\n \"software engineer i\",\n];\n\nconst fundingKeywords = [\n \"series a\",\n \"series b\",\n \"series c\",\n \"seed funded\",\n \"recently funded\",\n \"funded startup\",\n \"backed by\",\n];\n\nfunction experiencePenalty(text: string) {\n let penalty = 0;\n const matches = text.match(/(\\d+)\\+?\\s*years?/gi);\n if (matches) {\n matches.forEach((match) => {\n const years = parseInt(match);\n if (years >= 7) penalty -= 20;\n else if (years >= 5) penalty -= 12;\n else if (years >= 4) penalty -= 5;\n });\n }\n return penalty;\n}\n\n// Best-effort salary parsing. Looks for \"X LPA\" or \"X-Y LPA\" style\n// figures (Naukri/Indeed India) and boosts/penalizes relative to the\n// 8 LPA+ target. If nothing parseable is found, this is a no-op —\n// most listings hide salary, so we never punish missing data.\nfunction salaryBonus(text: string): number {\n const lpaMatch = text.match(\n /(\\d+(?:\\.\\d+)?)\\s*(?:-|to)?\\s*(\\d+(?:\\.\\d+)?)?\\s*lpa/i,\n );\n if (lpaMatch) {\n const max = lpaMatch[2] ? parseFloat(lpaMatch[2]) : parseFloat(lpaMatch[1]);\n if (max >= 8) return 8;\n if (max >= 6) return 2;\n if (max < 4) return -10; // clearly below target, deprioritize\n }\n return 0;\n}\n\nfunction fundingBonus(job: NormalizedJob): number {\n let bonus = 0;\n const text = `${job.description} ${job.fundingStage}`.toLowerCase();\n if (job.source === \"wellfound\") bonus += 5; // startup-native source\n if (job.fundingStage && job.fundingStage.trim().length > 0) bonus += 5;\n fundingKeywords.forEach((k) => {\n if (text.includes(k)) bonus += 4;\n });\n return bonus;\n}\n\nfunction scoreJob(job: NormalizedJob): number {\n const title = job.title.toLowerCase();\n const description = job.description.toLowerCase();\n const text = `${title} ${description}`;\n\n let score = 0;\n\n titleKeywords.excellent.forEach((k) => {\n if (title.includes(k)) score += 15;\n });\n titleKeywords.good.forEach((k) => {\n if (title.includes(k)) score += 7;\n });\n skillKeywords.excellent.forEach((k) => {\n if (text.includes(k)) score += 8;\n });\n skillKeywords.good.forEach((k) => {\n if (text.includes(k)) score += 3;\n });\n bfsKeywords.forEach((k) => {\n if (text.includes(k)) score += 5;\n });\n badStackKeywords.forEach((k) => {\n if (text.includes(k)) score -= 15;\n });\n seniorKeywords.forEach((k) => {\n if (title.includes(k)) score -= 12;\n });\n juniorFitKeywords.forEach((k) => {\n if (text.includes(k)) score += 6;\n });\n\n score += experiencePenalty(text);\n score += salaryBonus(`${job.salaryText} ${description}`);\n score += fundingBonus(job);\n\n let finalScore = Math.round(score / 10);\n if (finalScore < 0) finalScore = 0;\n if (finalScore > 10) finalScore = 10;\n return finalScore;\n}\n\nfunction escapeHtml(value: string) {\n return value\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\")\n .replaceAll('\"', \""\");\n}\n\nfunction dedupeKey(title: string, company: string) {\n return `${title}-${company}`.toLowerCase().trim();\n}\n\n// =====================================================================\n// PER-SOURCE NORMALIZATION\n// =====================================================================\n// Raw actor output shapes differ. Add/adjust field names here if an\n// actor's schema doesn't match — check a sample item's Object.keys()\n// in the logs (already logged below) and tweak.\n// =====================================================================\n\nfunction stripHtml(raw: string): string {\n return raw.replace(/<[^>]*>/g, \" \");\n}\n\nfunction normalizeJob(raw: any, source: string): NormalizedJob {\n const get = (...keys: string[]) => {\n for (const k of keys) {\n if (raw[k] !== undefined && raw[k] !== null && raw[k] !== \"\") {\n return raw[k];\n }\n }\n return \"\";\n };\n\n const descRaw = get(\n \"description\",\n \"descriptionText\",\n \"descriptionHtml\",\n \"jobDescription\",\n );\n\n return {\n title: String(get(\"title\", \"jobTitle\", \"role\") || \"Unknown role\"),\n company: String(\n get(\"company\", \"companyName\", \"employerName\", \"startupName\") ||\n \"Unknown\",\n ),\n location: String(get(\"location\", \"jobLocation\", \"city\") || \"\"),\n link: String(get(\"link\", \"url\", \"jobUrl\", \"applyUrl\") || \"#\"),\n description: stripHtml(String(descRaw || \"\")),\n salaryText: String(\n get(\"salary\", \"salaryRange\", \"compensation\", \"pay\") || \"\",\n ),\n fundingStage: String(\n get(\"fundingStage\", \"funding\", \"companyFundingStage\") || \"\",\n ),\n source,\n };\n}\n\nexport default async function (req: Request): Promise {\n const APIFY_TOKEN = Deno.env.get(\"APIFY_TOKEN\");\n const RESEND_KEY = Deno.env.get(\"RESEND_KEY\");\n const YOUR_EMAIL = \"eakas000@gmail.com\";\n\n if (!APIFY_TOKEN || !RESEND_KEY) {\n console.error(\"Missing APIFY_TOKEN or RESEND_KEY\");\n return new Response(\"Missing config\", { status: 500 });\n }\n\n await sqlite.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS job_runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id TEXT NOT NULL UNIQUE,\n source TEXT,\n status TEXT DEFAULT 'pending',\n started_at TEXT\n )\n `,\n args: [],\n });\n try {\n await sqlite.execute({\n sql: `ALTER TABLE job_runs ADD COLUMN source TEXT`,\n args: [],\n });\n } catch {\n // fine\n }\n\n await sqlite.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS jobs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id TEXT,\n title TEXT,\n company TEXT,\n location TEXT,\n link TEXT,\n score INTEGER,\n source TEXT,\n dedupe_key TEXT,\n created_at TEXT\n )\n `,\n args: [],\n });\n try {\n await sqlite.execute({\n sql: `ALTER TABLE jobs ADD COLUMN source TEXT`,\n args: [],\n });\n } catch {\n // fine\n }\n\n // =====================================================\n // PARSE APIFY WEBHOOK PAYLOAD\n // =====================================================\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n const runId: string | undefined = payload?.resource?.id ??\n payload?.eventData?.actorRunId;\n const status: string | undefined = payload?.resource?.status;\n const datasetId: string | undefined = payload?.resource?.defaultDatasetId;\n\n console.log(\"Webhook received. runId:\", runId, \"status:\", status);\n\n if (!runId || !datasetId) {\n return new Response(\"Missing runId or datasetId in webhook payload\", {\n status: 400,\n });\n }\n\n if (status !== \"SUCCEEDED\") {\n console.log(\"Run did not succeed, skipping:\", status);\n return new Response(\"Run not succeeded, ignored\", { status: 200 });\n }\n\n try {\n // Look up which source this run belongs to (linkedin/naukri/wellfound/indeed)\n const runRow = await sqlite.execute({\n sql: `SELECT source FROM job_runs WHERE run_id = ?`,\n args: [runId],\n });\n const source = (runRow.rows[0]?.[0] as string) || \"unknown\";\n\n // =====================================================\n // FETCH JOB DATA\n // =====================================================\n\n const itemsRes = await fetch(\n `https://api.apify.com/v2/datasets/${datasetId}/items?token=${APIFY_TOKEN}`,\n );\n\n if (!itemsRes.ok) {\n console.error(\n \"Dataset fetch failed:\",\n itemsRes.status,\n await itemsRes.text(),\n );\n return new Response(\"Dataset fetch failed\", { status: 500 });\n }\n\n const rawItems = (await itemsRes.json()) as any[];\n console.log(`[${source}] Raw jobs fetched from Apify: ${rawItems.length}`);\n\n if (rawItems.length > 0) {\n console.log(`[${source}] Sample job keys:`, Object.keys(rawItems[0]));\n }\n\n const normalizedJobs = rawItems.map((raw) => normalizeJob(raw, source));\n\n // =====================================================\n // SCORE + DEDUPE WITHIN THIS BATCH\n // =====================================================\n\n // Lowered from 4 -> 3: with 4x the sources and broader keywords,\n // this comfortably clears 20+ matches/day without letting through\n // clearly-irrelevant roles. Tune up/down if volume/quality drifts.\n const MIN_SCORE = 3;\n\n const scored = normalizedJobs\n .map((job) => ({ job, score: scoreJob(job) }))\n .filter((x) => x.score >= MIN_SCORE)\n .sort((a, b) => b.score - a.score);\n\n const seenInBatch = new Set();\n const batchJobs = scored.filter(({ job }) => {\n const key = dedupeKey(job.title, job.company);\n if (seenInBatch.has(key)) return false;\n seenInBatch.add(key);\n return true;\n });\n\n // =====================================================\n // DEDUPE AGAINST JOBS SENT IN THE LAST 24H (SQLITE)\n // =====================================================\n\n const cutoff = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();\n const recentResult = await sqlite.execute({\n sql: `SELECT dedupe_key FROM jobs WHERE created_at >= ?`,\n args: [cutoff],\n });\n const alreadySent = new Set(recentResult.rows.map((r: any) => r[0]));\n\n const finalJobs = batchJobs.filter(({ job }) => {\n const key = dedupeKey(job.title, job.company);\n return !alreadySent.has(key);\n });\n\n console.log(\n `[${source}] Matching after scoring: ${batchJobs.length}, new (not sent in last 24h): ${finalJobs.length}`,\n );\n\n // =====================================================\n // BUILD + SEND EMAIL (only if there's something new)\n // =====================================================\n\n let html = `\n

Java / Spring Boot / Angular / Full-Stack Jobs (${\n new Date().toDateString()\n })

Source: ${\n escapeHtml(source)\n } | Matching score: 0 = irrelevant | 10 = perfect match

\n `;\n\n if (finalJobs.length === 0) {\n html += `

No new matching jobs this run.

`;\n } else {\n finalJobs.forEach(({ job, score }) => {\n const fundingBadge = job.fundingStage || job.source === \"wellfound\"\n ? `🚀 ${\n escapeHtml(job.fundingStage || \"Startup\")\n }

`\n : \"\";\n html += `\n

${escapeHtml(job.title)}

\n Company: ${escapeHtml(job.company)}

\n Location: ${escapeHtml(job.location)}

\n Source: ${escapeHtml(job.source)}

\n ${fundingBadge}\n Match Score: ${score}/10

\n Apply Now\n

\n `;\n });\n }\n\n if (finalJobs.length > 0) {\n const emailRes = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${RESEND_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: \"onboarding@resend.dev\",\n to: YOUR_EMAIL,\n subject: `Java Jobs ${\n new Date().toDateString()\n } - ${source} (${finalJobs.length} new)`,\n html,\n }),\n });\n\n if (!emailRes.ok) {\n console.error(\"Email failed:\", emailRes.status, await emailRes.text());\n } else {\n console.log(`Email sent successfully. ${finalJobs.length} new jobs.`);\n }\n } else {\n console.log(\"No new jobs, skipping email.\");\n }\n\n // =====================================================\n // PERSIST RESULTS TO SQLITE (backup + future dedupe)\n // =====================================================\n\n const now = new Date().toISOString();\n for (const { job, score } of finalJobs) {\n await sqlite.execute({\n sql:\n `INSERT INTO jobs (run_id, title, company, location, link, score, source, dedupe_key, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n runId,\n job.title,\n job.company,\n job.location,\n job.link,\n score,\n job.source,\n dedupeKey(job.title, job.company),\n now,\n ],\n });\n }\n\n await sqlite.execute({\n sql: `UPDATE job_runs SET status = 'done' WHERE run_id = ?`,\n args: [runId],\n });\n\n // =====================================================\n // CLEANUP: DELETE ANYTHING OLDER THAN 24H\n // =====================================================\n\n await sqlite.execute({\n sql: `DELETE FROM jobs WHERE created_at < ?`,\n args: [cutoff],\n });\n await sqlite.execute({\n sql: `DELETE FROM job_runs WHERE started_at < ?`,\n args: [cutoff],\n });\n\n return new Response(\"OK\", { status: 200 });\n } catch (error) {\n console.error(\"Pipeline failed:\", error);\n return new Response(\"Pipeline failed\", { status: 500 });\n }\n}","createdAt",["D",1785143095521],"branchVersion","branchId","3e8a8163-ce82-4eae-b0af-5f915cab0441","id","fe127775-1e29-4912-bf59-d8cb521ee664","linkedin-job-2",["D",1785095056922],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","a626a7ed-9ac5-4ff4-95a8-898f4c196c7d","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f9fcc-d892-722b-a890-ab5f8a8aba6d","tursoName","fe1277751e294912bf59d8cb521ee664","tursoHostname","fe1277751e294912bf59d8cb521ee664-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789479081816],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",17,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","dummpreet676767","handle","displayName","dummpreet6767 67","avatar","https://lh3.googleusercontent.com/a/ACg8ocKAK8hl3OEbjg0qSVZZvQYRkzw9s1tAKMyou3E-PA7RDH2LlA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":154,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":155,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":156,"_83":157,"_85":158,"_87":25},"tree",[149],"files",[149],"counts",{"_137":62,"_138":139,"_140":62,"_141":142,"_143":144},"contents",[129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":133,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":136},"028784b3-750e-4de3-9d72-224f8e190a6e","parentId","latest",["D",1785143095521],13,"label",[28],"pulls","branches",1,"forks","envVars",{"_145":147,"_148":62},"connections",{"_145":62,"_146":62},"count","unfilledCount",2,"emptyCount",{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":150,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_151":152,"_27":153},["D",1785143095521],"children",[],[28],["D",1785095056922],["D",1789479081816],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_126":192,"_193":194,"_195":196,"_197":25,"_198":25,"_199":25,"_200":58,"_201":-5,"_202":-7,"_203":-7,"_204":62,"_205":25,"_206":25,"_207":-5,"_208":25,"_209":25,"_210":25,"_211":-5},"ENV",{"_163":164,"_165":166,"_167":89,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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"]

Diff · v14