[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_119":-5,"_20":120,"_22":121,"_122":123,"_124":125,"_25":126,"_24":-5,"_127":-5,"_128":-5,"_129":53,"_130":131,"_132":44,"_133":-5,"_134":-5,"_135":136},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","dummpreet676767","name","linkedin-job-2","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":37,"_73":44,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":81,"_82":83,"_84":85,"_86":-5,"_87":88,"_89":88,"_90":91,"_92":91,"_93":91,"_94":88,"_95":88,"_96":97,"_98":99,"_100":101,"_102":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","46b9d9cc-6ce3-4a3a-bb4d-f2949fff125c","main.ts","fileId","631aa220-892a-11f1-b53b-1607ee4eb77e","parentId","branchId","3e8a8163-ce82-4eae-b0af-5f915cab0441","branchVersion",17,"latest",true,"createdAt",["D",1785244254188],16,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst VAL3_URL =\n \"https://dummpreet676767--6bc7e7188a7c11f1bac81607ee4eb77e.web.val.run\"; // replace with your real Val3 URL\n\ninterface NormalizedJob {\n title: string;\n company: string;\n location: string;\n link: string;\n description: string;\n salaryText: string;\n fundingStage: string;\n source: string;\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\",\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\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\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;\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;\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\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\") || \"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\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\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 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 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 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 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 // finalJobs defined HERE — everything using it must come after this line\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 // CALL VAL3 TO ATTEMPT APPLICATIONS (finalJobs is in scope here)\n // =====================================================\n let applyResults: any[] = [];\n if (finalJobs.length > 0) {\n try {\n const applyRes = await fetch(VAL3_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n jobs: finalJobs.map(({ job }) => ({\n title: job.title,\n company: job.company,\n link: job.link,\n source: job.source,\n })),\n }),\n });\n if (applyRes.ok) {\n const data = await applyRes.json();\n applyResults = data.results ?? [];\n } else {\n console.error(\"Val3 responded with error status:\", applyRes.status);\n }\n } catch (err) {\n console.error(\"Val3 call failed:\", err);\n }\n }\n\n // helper to look up apply outcome for a given job when building email\n function findApplyResult(job: NormalizedJob) {\n return applyResults.find(\n (r) => r.title === job.title && r.company === job.company,\n );\n }\n\n // =====================================================\n // PERSIST TO SQLITE (dedupe bookkeeping)\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 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 // =====================================================\n // BUILD + SEND EMAIL — split into auto-applied vs needs-manual\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 const applied = finalJobs.filter(({ job }) => findApplyResult(job)?.ok);\n const manual = finalJobs.filter(({ job }) => !findApplyResult(job)?.ok);\n\n if (applied.length > 0) {\n html += `

✅ Auto-applied

`;\n applied.forEach(({ job, score }) => {\n html += `\n

${escapeHtml(job.title)}

\n Company: ${escapeHtml(job.company)}
\n Score: ${score}/10
\n View posting\n

\n `;\n });\n }\n\n if (manual.length > 0) {\n html += `

👉 Needs your click

`;\n manual.forEach(({ job, score }) => {\n const reason = findApplyResult(job)?.error ?? \"manual apply required\";\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 Why manual: ${escapeHtml(reason)}

\n Apply Now\n

\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 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}","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1785244254188],"children",[],[35],"fe127775-1e29-4912-bf59-d8cb521ee664",["D",1785095056922],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","a626a7ed-9ac5-4ff4-95a8-898f4c196c7d","pinnedFileId","pinPreview","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",{"_11":12,"_118":114},"org",{"_11":12,"_111":112,"_113":114,"_70":71,"_115":116,"_117":53},"branch",{"_17":42,"_13":16,"_33":40,"_103":61,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":14,"_110":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","dummpreet6767 67","avatar","https://lh3.googleusercontent.com/a/ACg8ocKAK8hl3OEbjg0qSVZZvQYRkzw9s1tAKMyou3E-PA7RDH2LlA=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":153,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":37,"_73":44,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":81,"_82":83,"_84":154,"_86":-5,"_87":88,"_89":88,"_90":91,"_92":91,"_93":91,"_94":88,"_95":88,"_96":155,"_98":156,"_100":157,"_102":53},[150],"files",[150],"counts",{"_139":77,"_140":141,"_142":77,"_31":143,"_144":145},[137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":138},[35],"pulls","branches",1,"forks",{"_146":148,"_149":77},"connections",{"_146":77,"_147":77},"count","unfilledCount",2,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":151,"_18":152},[],[35],["D",1785095056922],["D",1789479081816],{"_11":12,"_118":114},{"_11":12,"_111":112,"_113":114,"_70":71,"_115":116,"_117":53},{"_17":42,"_13":16,"_33":40,"_103":61,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":14,"_110":12},"ctx",{"_96":-5,"_134":191,"_192":193,"_194":195,"_196":53,"_197":53,"_198":53,"_199":44,"_200":-5,"_201":-7,"_202":-7,"_203":77,"_204":53,"_205":53,"_206":-5,"_207":53,"_208":53,"_209":53,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":16,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"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"]

Code