[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_262":263,"_264":265},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_191":-5,"_20":192,"_22":193,"_194":195,"_196":197,"_26":198,"_24":199,"_200":-5,"_201":-5,"_202":52,"_203":204,"_205":52,"_206":-5,"_207":-5,"_208":209},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","Thokolosh","name","gmx-cleanup","branchName","main","version","path","weekly.ts","project",{"_33":133,"_13":14,"_44":134,"_135":-5,"_136":52,"_137":138,"_139":138,"_140":141,"_142":-5,"_143":144,"_145":-5,"_146":52,"_147":-5,"_148":-5,"_149":46,"_150":151,"_152":153,"_154":155,"_156":157,"_158":-5,"_159":160,"_161":160,"_162":163,"_164":163,"_165":163,"_166":160,"_167":160,"_168":169,"_170":171,"_172":173,"_174":52},"tree",[55,56,57,58,59,60,61,62,63],"file",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":54},"contents",[],"upstream","pull","ahead","behind","envVars","id","df9adf76-e81f-4890-b2b5-47188b0c2f1b","fileId","7ac60626-afae-11f1-9c10-1607ee4eb77e","parentId","branchId","a8174eb8-3f68-480a-ae30-c80f280d9c3f","branchVersion",10,"latest",true,"createdAt",["D",1789329934404],0,"fileType","interval","content","// Weekly cleanup: scans INBOX, moves newsletters, social notifications and EXTRA_SENDERS\n// to the Trash folder (recoverable), and clears the spam folder. Never expunges the Trash.\n// Protected senders (KEEP_SENDERS) and transactional-looking mails are always left alone.\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { Imap, parseHeaders, uidSets } from \"./imap.ts\";\nimport { classify } from \"./classify.ts\";\n\nexport default async function (_interval: Interval) {\n const user = Deno.env.get(\"GMX_USER\"), pass = Deno.env.get(\"GMX_PASS\");\n if (!user || !pass) throw new Error(\"GMX_USER / GMX_PASS not set — weekly cleanup skipped.\");\n const keep = (Deno.env.get(\"KEEP_SENDERS\") ?? \"\").split(\",\").map((s) => s.trim()).filter(Boolean);\n const extra = (Deno.env.get(\"EXTRA_SENDERS\") ?? \"\").split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean);\n\n const imap = new Imap();\n await imap.connect();\n await imap.login(user, pass);\n const folders = await imap.listFolders();\n const spamFolder = folders.find((f) => f.flags.includes(\"\\\\Junk\"))?.name ?? \"Spamverdacht\";\n const trashFolder = folders.find((f) => f.flags.includes(\"\\\\Trash\"))?.name ?? \"Papierkorb\";\n\n const total = await imap.select(\"INBOX\");\n const uids = await imap.uidSearchAll();\n const toMove: number[] = [];\n const counts: Record = {};\n for (const set of uidSets(uids, 500)) {\n const got = await imap.fetchHeaders(set);\n for (const [uid, { hdr }] of got) {\n const h = parseHeaders(hdr);\n const cat = classify(h, keep);\n const from = (h[\"from\"] ?? \"\").toLowerCase();\n const hit = cat === \"newsletter\" || cat === \"social\" || (cat === \"other\" && extra.some((e) => from.includes(e)));\n if (hit) { toMove.push(uid); counts[cat] = (counts[cat] ?? 0) + 1; }\n }\n }\n for (const s of uidSets(toMove, 300)) await imap.uidMove(s, trashFolder);\n\n const spamTotal = await imap.select(spamFolder);\n const spam = await imap.uidSearchAll();\n for (const s of uidSets(spam, 400)) await imap.uidMove(s, trashFolder);\n await imap.logout();\n\n const summary = { at: new Date().toISOString(), inboxBefore: total, moved: toMove.length, counts, spamCleared: spamTotal, trashFolder };\n await blob.setJSON(\"gmx:lastWeekly\", summary);\n console.log(JSON.stringify(summary));\n}\n","deleted",false,"label",[19],{"_33":125,"_13":126,"_35":127,"_37":-5,"_38":39,"_40":128,"_42":43,"_44":129,"_17":98,"_47":73,"_49":130,"_51":52,"_53":-5,"_65":131,"_18":132},{"_33":117,"_13":118,"_35":119,"_37":-5,"_38":39,"_40":120,"_42":43,"_44":121,"_17":46,"_47":73,"_49":122,"_51":52,"_53":-5,"_65":123,"_18":124},{"_33":109,"_13":110,"_35":111,"_37":-5,"_38":39,"_40":112,"_42":43,"_44":113,"_17":98,"_47":73,"_49":114,"_51":52,"_53":-5,"_65":115,"_18":116},{"_33":102,"_13":103,"_35":104,"_37":-5,"_38":39,"_40":98,"_42":43,"_44":105,"_17":46,"_47":73,"_49":106,"_51":52,"_53":-5,"_65":107,"_18":108},{"_33":93,"_13":94,"_35":95,"_37":-5,"_38":39,"_40":96,"_42":43,"_44":97,"_17":98,"_47":73,"_49":99,"_51":52,"_53":-5,"_65":100,"_18":101},{"_33":85,"_13":86,"_35":87,"_37":-5,"_38":39,"_40":88,"_42":43,"_44":89,"_17":46,"_47":73,"_49":90,"_51":52,"_53":-5,"_65":91,"_18":92},{"_33":77,"_13":78,"_35":79,"_37":-5,"_38":39,"_40":80,"_42":43,"_44":81,"_17":46,"_47":73,"_49":82,"_51":52,"_53":-5,"_65":83,"_18":84},{"_33":68,"_13":69,"_35":70,"_37":-5,"_38":39,"_40":71,"_42":43,"_44":72,"_17":46,"_47":73,"_49":74,"_51":52,"_53":-5,"_65":75,"_18":76},{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":64,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_65":66,"_18":67},["D",1789329934404],"children",[],[19],"641f66de-f3ab-4adb-95c4-e604a6626c6c","scan.ts","a4f5951c-afac-11f1-a156-1607ee4eb77e",4,["D",1789329146163],"script","// DRY RUN: scans the GMX inbox + spam folder, classifies every message, writes a plan to blob\n// storage and prints a summary. Deletes nothing.\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { Imap, parseHeaders, uidSets } from \"./imap.ts\";\nimport { classify, senderKey, type Category } from \"./classify.ts\";\n\nconst user = Deno.env.get(\"GMX_USER\"), pass = Deno.env.get(\"GMX_PASS\");\nif (!user || !pass) throw new Error(\"Set GMX_USER and GMX_PASS as environment variables first.\");\nconst keep = (Deno.env.get(\"KEEP_SENDERS\") ?? \"\").split(\",\").map((s) => s.trim()).filter(Boolean);\n\nconst imap = new Imap();\nawait imap.connect();\nawait imap.login(user, pass);\nconst folders = await imap.listFolders();\nconsole.log(\"Folders:\", folders.map((f) => `${f.name} ${f.flags.join(\" \")}`).join(\" | \"));\nconst spamFolder = folders.find((f) => f.flags.includes(\"\\\\Junk\"))?.name ?? \"Spam\";\nconst trashFolder = folders.find((f) => f.flags.includes(\"\\\\Trash\"))?.name ?? \"Trash\";\n\nconst total = await imap.select(\"INBOX\");\nconst uids = await imap.uidSearchAll();\nconsole.log(`INBOX: ${total} messages, ${uids.length} UIDs`);\n\nconst plan: Record = { protected: [], transactional: [], social: [], newsletter: [], other: [] };\nconst senders: Record> = { protected: {}, transactional: {}, social: {}, newsletter: {}, other: {} };\nconst bytes: Record = { protected: 0, transactional: 0, social: 0, newsletter: 0, other: 0 };\nconst samples: Record = { protected: [], transactional: [], social: [], newsletter: [], other: [] };\nlet oldest = \"\", newest = \"\";\n\nfor (const set of uidSets(uids, 500)) {\n const got = await imap.fetchHeaders(set);\n for (const [uid, { hdr, size }] of got) {\n const h = parseHeaders(hdr);\n const cat = classify(h, keep);\n plan[cat].push(uid);\n bytes[cat] += size;\n const k = senderKey(h[\"from\"] ?? \"?\");\n senders[cat][k] = (senders[cat][k] ?? 0) + 1;\n if (samples[cat].length < 15) samples[cat].push(`${(h[\"date\"] ?? \"\").slice(0, 16)} | ${k} | ${(h[\"subject\"] ?? \"\").slice(0, 70)}`);\n const d = h[\"date\"] ?? \"\"; if (d) { if (!oldest) oldest = d; newest = d; }\n }\n}\n\nconst spamCount = await imap.select(spamFolder);\nawait imap.logout();\n\nconst top = (m: Record, n = 40) => Object.entries(m).sort((a, b) => b[1] - a[1]).slice(0, n);\nconst report = {\n scannedAt: new Date().toISOString(), inboxTotal: total, spamFolder, spamCount, trashFolder, keepSenders: keep,\n counts: Object.fromEntries(Object.entries(plan).map(([k, v]) => [k, v.length])),\n megabytes: Object.fromEntries(Object.entries(bytes).map(([k, v]) => [k, +(v / 1048576).toFixed(1)])),\n topSenders: Object.fromEntries(Object.entries(senders).map(([k, v]) => [k, top(v)])),\n samples, dateRange: { first: oldest, last: newest },\n};\nawait blob.setJSON(\"gmx:plan\", { scannedAt: report.scannedAt, spamFolder, trashFolder, uids: plan });\nawait blob.setJSON(\"gmx:report\", report);\nconsole.log(JSON.stringify(report, null, 1));\n",[],[69],"37575cae-0d60-4434-88d1-5638426ddf8a","probe.ts","2744aa68-afac-11f1-aaaa-1607ee4eb77e",1,["D",1789328935305],"const c = await Deno.connectTls({ hostname: \"imap.gmx.net\", port: 993 });\nconst buf = new Uint8Array(512);\nconst n = await c.read(buf);\nconsole.log(new TextDecoder().decode(buf.subarray(0, n ?? 0)));\nc.close();\n",[],[78],"1ea244a0-0538-4ed4-930d-2667d6ec252b","move-large.ts","478c88ea-afb1-11f1-ae2c-1607ee4eb77e",12,["D",1789331136957],"// Moves the messages listed in blob \"gmx:biggest\" into a folder named LARGE (created if missing).\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { Imap, uidSets } from \"./imap.ts\";\n\nconst user = Deno.env.get(\"GMX_USER\"), pass = Deno.env.get(\"GMX_PASS\");\nif (!user || !pass) throw new Error(\"GMX_USER / GMX_PASS not set.\");\nconst DEST = \"LARGE\";\n\nconst data = await blob.getJSON(\"gmx:biggest\") as { biggest: { folder: string; uid: number; mb: number }[] } | undefined;\nif (!data) throw new Error(\"Run biggest.ts first.\");\n\nconst imap = new Imap();\nawait imap.connect();\nawait imap.login(user, pass);\nconst folders = await imap.listFolders();\nif (!folders.some((f) => f.name === DEST)) { await imap.cmd(`CREATE \"${DEST}\"`); console.log(\"created\", DEST); }\n\nconst byFolder: Record = {};\nfor (const r of data.biggest) { if (r.folder !== DEST) (byFolder[r.folder] ??= []).push(r.uid); }\nlet moved = 0, mb = 0;\nfor (const [folder, uids] of Object.entries(byFolder)) {\n await imap.select(folder);\n for (const s of uidSets(uids, 100)) await imap.uidMove(s, DEST);\n moved += uids.length;\n console.log(`${folder}: moved ${uids.length}`);\n}\nfor (const r of data.biggest) mb += r.mb;\nconst count = await imap.select(DEST);\nawait imap.logout();\nconsole.log(JSON.stringify({ moved, approxMB: +mb.toFixed(1), nowInLarge: count }));\n",[],[86],"c356d0ea-d6b3-47ce-ba13-1198f0aae141","medium.ts","7179f7d2-afb1-11f1-8a90-1607ee4eb77e",15,["D",1789331284896],2,"// Finds all mails >= MIN_MB (env, default 1) outside LARGE/MEDIUM/Trash, stores them under blob\n// \"gmx:medium\" and prints size brackets. With MOVE=1 it moves them into the MEDIUM folder.\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { Imap, parseHeaders, uidSets } from \"./imap.ts\";\n\nconst user = Deno.env.get(\"GMX_USER\"), pass = Deno.env.get(\"GMX_PASS\");\nif (!user || !pass) throw new Error(\"GMX_USER / GMX_PASS not set.\");\nconst MIN = parseFloat(Deno.env.get(\"MIN_MB\") ?? \"1\");\nconst MAX = parseFloat(Deno.env.get(\"MAX_MB\") ?? \"5\");\nconst MOVE = Deno.env.get(\"MOVE\") === \"1\";\nconst DEST = \"MEDIUM\";\n\nconst imap = new Imap();\nawait imap.connect();\nawait imap.login(user, pass);\nconst folders = (await imap.listFolders()).filter((f) => !f.flags.includes(\"\\\\Noselect\") && !f.flags.includes(\"\\\\Trash\") && f.name !== \"LARGE\" && f.name !== DEST);\n\ntype Row = { folder: string; uid: number; mb: number; from: string; subject: string; date: string };\nconst rows: Row[] = [];\nfor (const f of folders) {\n let total = 0;\n try { total = await imap.select(f.name); } catch { continue; }\n if (!total) continue;\n const uids = await imap.uidSearchAll();\n for (const set of uidSets(uids, 500)) {\n const got = await imap.fetchHeaders(set);\n for (const [uid, { hdr, size }] of got) {\n if (size < MIN * 1048576 || size >= MAX * 1048576) continue;\n const h = parseHeaders(hdr);\n rows.push({ folder: f.name, uid, mb: +(size / 1048576).toFixed(2), from: (h[\"from\"] ?? \"\").slice(0, 60), subject: (h[\"subject\"] ?? \"\").slice(0, 70), date: (h[\"date\"] ?? \"\").slice(5, 16) });\n }\n }\n}\nrows.sort((a, b) => b.mb - a.mb);\nconst brackets: Record = {};\nfor (const r of rows) {\n const k = r.mb >= 10 ? \">=10 MB\" : r.mb >= 5 ? \"5-10 MB\" : r.mb >= 2 ? \"2-5 MB\" : \"1-2 MB\";\n brackets[k] ??= { n: 0, mb: 0 }; brackets[k].n++; brackets[k].mb += r.mb;\n}\nfor (const b of Object.values(brackets)) b.mb = +b.mb.toFixed(0);\n\nlet moved = 0;\nif (MOVE && rows.length) {\n const all = await imap.listFolders();\n if (!all.some((f) => f.name === DEST)) await imap.cmd(`CREATE \"${DEST}\"`);\n const byFolder: Record = {};\n for (const r of rows) (byFolder[r.folder] ??= []).push(r.uid);\n for (const [folder, uids] of Object.entries(byFolder)) {\n await imap.select(folder);\n for (const s of uidSets(uids, 200)) await imap.uidMove(s, DEST);\n moved += uids.length;\n }\n}\nawait imap.logout();\nawait blob.setJSON(\"gmx:medium\", { at: new Date().toISOString(), min: MIN, brackets, rows });\nconsole.log(JSON.stringify({ min: MIN, found: rows.length, totalMB: +rows.reduce((a, r) => a + r.mb, 0).toFixed(0), brackets, moved, top: rows.slice(0, 25) }, null, 1));\n",[],[94],"8765ad9e-2368-4424-b5fc-6fa238f13bed","imap.ts","90b95386-afac-11f1-b2d3-1607ee4eb77e",["D",1789329112241],"// Minimal IMAP client over Deno.connectTls — enough for scanning, moving and expunging.\nexport type Resp = { line: string; literals: string[] };\n\nexport class Imap {\n private conn!: Deno.TlsConn;\n private buf = new Uint8Array(0);\n private tag = 0;\n private dec = new TextDecoder(\"latin1\");\n private enc = new TextEncoder();\n\n async connect(host = \"imap.gmx.net\", port = 993) {\n this.conn = await Deno.connectTls({ hostname: host, port });\n const greet = await this.readResponse();\n if (!greet.line.startsWith(\"* OK\")) throw new Error(\"bad greeting: \" + greet.line);\n }\n\n private async fill() {\n const chunk = new Uint8Array(65536);\n const n = await this.conn.read(chunk);\n if (n === null) throw new Error(\"connection closed\");\n const nb = new Uint8Array(this.buf.length + n);\n nb.set(this.buf); nb.set(chunk.subarray(0, n), this.buf.length);\n this.buf = nb;\n }\n\n private async readLine(): Promise {\n for (;;) {\n const idx = indexOfCRLF(this.buf);\n if (idx >= 0) {\n const line = this.dec.decode(this.buf.subarray(0, idx));\n this.buf = this.buf.subarray(idx + 2);\n return line;\n }\n await this.fill();\n }\n }\n\n private async readBytes(n: number): Promise {\n while (this.buf.length < n) await this.fill();\n const s = this.dec.decode(this.buf.subarray(0, n));\n this.buf = this.buf.subarray(n);\n return s;\n }\n\n // Reads one full response (handles {N} literals), returns text with literals replaced by placeholders.\n async readResponse(): Promise {\n let line = \"\";\n const literals: string[] = [];\n for (;;) {\n const part = await this.readLine();\n line += part;\n const m = /\\{(\\d+)\\}$/.exec(part);\n if (!m) break;\n literals.push(await this.readBytes(parseInt(m[1])));\n line += ``;\n }\n return { line, literals };\n }\n\n async cmd(command: string): Promise<{ untagged: Resp[]; tagged: string }> {\n const t = \"A\" + (++this.tag).toString().padStart(4, \"0\");\n await this.conn.write(this.enc.encode(`${t} ${command}\\r\\n`));\n const untagged: Resp[] = [];\n for (;;) {\n const r = await this.readResponse();\n if (r.line.startsWith(t + \" \")) {\n if (!r.line.startsWith(t + \" OK\")) throw new Error(`${command.split(\" \")[0]} failed: ${r.line}`);\n return { untagged, tagged: r.line };\n }\n untagged.push(r);\n }\n }\n\n async login(user: string, pass: string) {\n const q = (s: string) => '\"' + s.replace(/([\"\\\\])/g, \"\\\\$1\") + '\"';\n await this.cmd(`LOGIN ${q(user)} ${q(pass)}`);\n }\n\n async listFolders(): Promise<{ name: string; flags: string[] }[]> {\n const { untagged } = await this.cmd('LIST \"\" \"*\" RETURN (SPECIAL-USE)');\n const out: { name: string; flags: string[] }[] = [];\n for (const r of untagged) {\n const m = /^\\* LIST \$([^)]*)\$ (?:\"[^\"]*\"|NIL) (?:\"((?:[^\"\\\\]|\\\\.)*)\"|(\\S+))$/.exec(r.line);\n if (m) out.push({ name: m[2] !== undefined ? m[2].replace(/\\\\(.)/g, \"$1\") : m[3], flags: m[1].split(\" \").filter(Boolean) });\n }\n return out;\n }\n\n async select(folder: string): Promise {\n const { untagged } = await this.cmd(`SELECT \"${folder}\"`);\n for (const r of untagged) { const m = /^\\* (\\d+) EXISTS/.exec(r.line); if (m) return parseInt(m[1]); }\n return 0;\n }\n\n async uidSearchAll(): Promise {\n const { untagged } = await this.cmd(\"UID SEARCH ALL\");\n const ids: number[] = [];\n for (const r of untagged) if (r.line.startsWith(\"* SEARCH\")) ids.push(...r.line.slice(8).trim().split(/\\s+/).filter(Boolean).map(Number));\n return ids;\n }\n\n // Fetch selected headers + size for a UID set string like \"1:500\" or \"1,5,9\".\n async fetchHeaders(uidSet: string): Promise> {\n const { untagged } = await this.cmd(\n `UID FETCH ${uidSet} (UID RFC822.SIZE BODY.PEEK[HEADER.FIELDS (FROM SUBJECT DATE LIST-UNSUBSCRIBE LIST-ID PRECEDENCE X-MAILER AUTO-SUBMITTED)])`,\n );\n const out = new Map();\n for (const r of untagged) {\n if (!/ FETCH \\(/.test(r.line)) continue;\n const uid = /UID (\\d+)/.exec(r.line); const size = /RFC822\\.SIZE (\\d+)/.exec(r.line);\n if (uid) out.set(parseInt(uid[1]), { hdr: r.literals[0] ?? \"\", size: size ? parseInt(size[1]) : 0 });\n }\n return out;\n }\n\n async uidMove(uidSet: string, dest: string) { await this.cmd(`UID MOVE ${uidSet} \"${dest}\"`); }\n async uidDelete(uidSet: string) { await this.cmd(`UID STORE ${uidSet} +FLAGS.SILENT (\\\\Deleted)`); }\n async expunge() { await this.cmd(\"EXPUNGE\"); }\n async logout() { try { await this.cmd(\"LOGOUT\"); } catch { /* ignore */ } this.conn.close(); }\n}\n\nfunction indexOfCRLF(b: Uint8Array): number {\n for (let i = 0; i + 1 < b.length; i++) if (b[i] === 13 && b[i + 1] === 10) return i;\n return -1;\n}\n\nexport function parseHeaders(raw: string): Record {\n const h: Record = {};\n const unfolded = raw.replace(/\\r\\n[ \\t]+/g, \" \");\n for (const line of unfolded.split(\"\\r\\n\")) {\n const i = line.indexOf(\":\"); if (i < 0) continue;\n const k = line.slice(0, i).trim().toLowerCase();\n h[k] = decodeMime(line.slice(i + 1).trim());\n }\n return h;\n}\n\n// Decode RFC 2047 encoded words (=?charset?B|Q?...?=) — good enough for sender names/subjects.\nexport function decodeMime(s: string): string {\n return s.replace(/\\?=\\s+=\\?/g, \"?==?\").replace(/=\\?([^?]+)\\?([BbQq])\\?([^?]*)\\?=/g, (_m, cs, enc, txt) => {\n try {\n let bytes: Uint8Array;\n if (enc.toUpperCase() === \"B\") bytes = Uint8Array.from(atob(txt), (c) => c.charCodeAt(0));\n else bytes = Uint8Array.from(txt.replace(/_/g, \" \").replace(/=([0-9A-Fa-f]{2})/g, (_x: string, hx: string) => String.fromCharCode(parseInt(hx, 16))), (c: string) => c.charCodeAt(0));\n return new TextDecoder(cs.toLowerCase() === \"utf8\" ? \"utf-8\" : cs).decode(bytes);\n } catch { return txt; }\n });\n}\n\n// Compress a sorted list of UIDs into IMAP set syntax, chunked to keep commands short.\nexport function uidSets(uids: number[], chunk = 400): string[] {\n const sorted = [...uids].sort((a, b) => a - b);\n const sets: string[] = [];\n for (let i = 0; i < sorted.length; i += chunk) {\n const part = sorted.slice(i, i + chunk); const ranges: string[] = [];\n let s = part[0], p = part[0];\n for (let j = 1; j <= part.length; j++) {\n const v = part[j];\n if (v === p + 1) { p = v; continue; }\n ranges.push(s === p ? `${s}` : `${s}:${p}`); s = v; p = v;\n }\n sets.push(ranges.join(\",\"));\n }\n return sets;\n}\n",[],[103],"c4ae6c12-b205-47aa-9e8f-949b5aab70b4","classify.ts","9c30462a-afac-11f1-8eee-1607ee4eb77e",7,["D",1789329634533],"// Categorises a message from its headers. Order matters: protected senders win, then\n// transactional guards, then social, then newsletter/marketing, else \"other\".\nexport type Category = \"protected\" | \"transactional\" | \"social\" | \"newsletter\" | \"other\";\n\nconst SOCIAL_DOMAINS = [\n \"linkedin.com\", \"facebookmail.com\", \"facebook.com\", \"instagram.com\", \"twitter.com\", \"x.com\",\n \"quora.com\", \"quoramail.com\", \"xing.com\", \"pinterest.com\", \"tiktok.com\", \"nextdoor.com\", \"reddit.com\", \"redditmail.com\",\n \"snapchat.com\", \"threads.net\", \"youtube.com\", \"discord.com\", \"discordapp.com\", \"meetup.com\", \"strava.com\",\n \"kiva.org\", \"tumblr.com\", \"twitch.tv\", \"medium.com\", \"goodreads.com\", \"lovoo.com\", \"tinder.com\", \"bumble.com\",\n];\n\n// Subjects that look like receipts, contracts, bookings, security notices — never auto-delete these.\nconst TRANSACTIONAL = /\\b(rechnung|invoice|receipt|quittung|beleg|bestellung|bestellbest|order\\s*(no|nr|#|confirm)|auftrag|vertrag|contract|kündigung|kuendigung|buchung|booking|reservierung|reservation|ticket|passwort|password|verification|verifizier|bestätig|confirmation|confirm your|zahlung|payment|überweisung|lastschrift|mahnung|lieferung|versand|shipped|delivery|tracking|sendung|steuer|tax|finanzamt|police|versicherung|insurance|abrechnung|gehalt|lohn|kontoauszug|statement|sicherheitshinweis|security alert|login|anmeldung|2fa|code)\\b/i;\n\nconst NEWSLETTER_FROM = /(newsletter|news@|noreply|no-reply|no_reply|nicht-antworten|donotreply|do-not-reply|marketing|promo|angebot|deals|mailer|mailing|campaign|updates?@|hello@|hallo@|team@|digest|notification)/i;\n\nexport function classify(h: Record, keepSenders: string[]): Category {\n const from = (h[\"from\"] ?? \"\");\n const fromL = from.toLowerCase();\n const subject = h[\"subject\"] ?? \"\";\n for (const k of keepSenders) if (k && fromL.includes(k.toLowerCase())) return \"protected\";\n const domain = (/@([a-z0-9.-]+)/i.exec(fromL)?.[1] ?? \"\");\n if (TRANSACTIONAL.test(subject)) return \"transactional\";\n // Replies/forwards are conversations, never bulk mail.\n if (/^\\s*(aw|re|wg|fwd?|antw)\\s*:/i.test(subject)) return \"other\";\n if (SOCIAL_DOMAINS.some((d) => domain === d || domain.endsWith(\".\" + d))) return \"social\";\n const bulk = !!h[\"list-unsubscribe\"] || !!h[\"list-id\"] || /bulk|list/i.test(h[\"precedence\"] ?? \"\") ||\n NEWSLETTER_FROM.test(fromL) || /auto-generated|auto-replied/i.test(h[\"auto-submitted\"] ?? \"\");\n if (bulk) return \"newsletter\";\n return \"other\";\n}\n\nexport function senderKey(from: string): string {\n const m = /<([^>]+)>/.exec(from);\n const addr = (m ? m[1] : from).trim().toLowerCase();\n const name = from.replace(/<[^>]+>/, \"\").replace(/^\"|\"$/g, \"\").trim();\n return name ? `${name} <${addr}>` : addr;\n}\n",[],[110],"bf7b43fe-b742-46d0-a25c-301a5a6e4342","biggest.ts","1e921414-afb1-11f1-be2a-1607ee4eb77e",11,["D",1789331068191],"// Read-only: lists the largest messages across all folders of the account.\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { Imap, parseHeaders, uidSets } from \"./imap.ts\";\n\nconst user = Deno.env.get(\"GMX_USER\"), pass = Deno.env.get(\"GMX_PASS\");\nif (!user || !pass) throw new Error(\"GMX_USER / GMX_PASS not set.\");\nconst TOP = 50;\n\nconst imap = new Imap();\nawait imap.connect();\nawait imap.login(user, pass);\nconst folders = (await imap.listFolders()).filter((f) => !f.flags.includes(\"\\\\Noselect\"));\n\ntype Row = { folder: string; uid: number; mb: number; from: string; subject: string; date: string };\nconst rows: Row[] = [];\nconst perFolder: Record = {};\nconst started = Date.now();\n\nfor (const f of folders) {\n let total = 0;\n try { total = await imap.select(f.name); } catch (e) { console.log(`skip ${f.name}: ${e}`); continue; }\n const uids = total ? await imap.uidSearchAll() : [];\n let bytes = 0;\n for (const set of uidSets(uids, 500)) {\n const got = await imap.fetchHeaders(set);\n for (const [uid, { hdr, size }] of got) {\n bytes += size;\n if (size < 2 * 1048576) continue; // only consider mails >= 2 MB for the ranking\n const h = parseHeaders(hdr);\n rows.push({ folder: f.name, uid, mb: +(size / 1048576).toFixed(1), from: (h[\"from\"] ?? \"\").slice(0, 60), subject: (h[\"subject\"] ?? \"\").slice(0, 80), date: (h[\"date\"] ?? \"\").slice(0, 16) });\n }\n }\n perFolder[f.name] = { count: total, mb: +(bytes / 1048576).toFixed(1) };\n if (Date.now() - started > 100_000) { console.log(\"time guard hit after\", f.name); break; }\n}\nawait imap.logout();\n\nrows.sort((a, b) => b.mb - a.mb);\nconst result = { at: new Date().toISOString(), perFolder, biggest: rows.slice(0, TOP) };\nawait blob.setJSON(\"gmx:biggest\", result);\nconsole.log(JSON.stringify(result, null, 1));\n",[],[118],"d91995d4-6345-41b4-baeb-a12d6f1724f0","apply.ts","ad9e4b64-afac-11f1-a35d-1607ee4eb77e",9,["D",1789329784490],"// APPLY: executes the plan written by scan.ts. Moves the chosen categories to the Trash folder\n// (reversible until Trash is emptied). Env switches:\n// APPLY_CATEGORIES comma list, default \"newsletter,social\"\n// EMPTY_SPAM=1 also move everything in the Spam folder to Trash\n// EMPTY_TRASH=1 permanently expunge the Trash folder at the end (irreversible)\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { Imap, parseHeaders, uidSets } from \"./imap.ts\";\n\nconst user = Deno.env.get(\"GMX_USER\"), pass = Deno.env.get(\"GMX_PASS\");\nif (!user || !pass) throw new Error(\"Set GMX_USER and GMX_PASS first.\");\nconst keep = (Deno.env.get(\"KEEP_SENDERS\") ?? \"\").split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean);\nconst cats = (Deno.env.get(\"APPLY_CATEGORIES\") ?? \"newsletter,social\").split(\",\").map((s) => s.trim());\n\nconst plan = await blob.getJSON(\"gmx:plan\") as { spamFolder: string; trashFolder: string; uids: Record } | undefined;\nif (!plan) throw new Error(\"No plan found — run scan.ts first.\");\n\nconst imap = new Imap();\nawait imap.connect();\nawait imap.login(user, pass);\nawait imap.select(\"INBOX\");\n\nlet moved = 0, skipped = 0;\nfor (const cat of cats) {\n const uids = plan.uids[cat] ?? [];\n console.log(`${cat}: ${uids.length} planned`);\n for (const set of uidSets(uids, 300)) {\n // Safety re-check against protected senders right before moving.\n const got = await imap.fetchHeaders(set);\n const ok: number[] = [];\n for (const [uid, { hdr }] of got) {\n const from = (parseHeaders(hdr)[\"from\"] ?? \"\").toLowerCase();\n if (keep.some((k) => from.includes(k))) { skipped++; console.log(\"SKIP protected:\", from); continue; }\n ok.push(uid);\n }\n for (const s of uidSets(ok, 300)) await imap.uidMove(s, plan.trashFolder);\n moved += ok.length;\n }\n}\n// EXTRA_SENDERS: comma list of From fragments in the \"other\" bucket that should go too.\nconst extra = (Deno.env.get(\"EXTRA_SENDERS\") ?? \"\").split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean);\nif (extra.length) {\n let n = 0;\n for (const set of uidSets(plan.uids[\"other\"] ?? [], 300)) {\n const got = await imap.fetchHeaders(set);\n const hit: number[] = [];\n for (const [uid, { hdr }] of got) {\n const from = (parseHeaders(hdr)[\"from\"] ?? \"\").toLowerCase();\n if (keep.some((k) => from.includes(k))) continue;\n if (extra.some((e) => from.includes(e))) hit.push(uid);\n }\n for (const s of uidSets(hit, 300)) await imap.uidMove(s, plan.trashFolder);\n n += hit.length;\n }\n console.log(`Extra senders: moved ${n} messages.`); moved += n;\n}\nconsole.log(`Moved ${moved} inbox messages to ${plan.trashFolder}, skipped ${skipped} protected.`);\n\nif (Deno.env.get(\"EMPTY_SPAM\") === \"1\") {\n await imap.select(plan.spamFolder);\n const spam = await imap.uidSearchAll();\n for (const s of uidSets(spam, 400)) await imap.uidMove(s, plan.trashFolder);\n console.log(`Moved ${spam.length} spam messages to ${plan.trashFolder}.`);\n}\n// Guarded so a re-run never purges the trash by accident: set EMPTY_TRASH to \"now\" for one run.\nif (Deno.env.get(\"EMPTY_TRASH\") === \"now\") {\n await imap.select(plan.trashFolder);\n const t = await imap.uidSearchAll();\n for (const s of uidSets(t, 400)) await imap.uidDelete(s);\n await imap.expunge();\n console.log(`Expunged ${t.length} messages from ${plan.trashFolder}.`);\n}\nawait imap.logout();\nawait blob.setJSON(\"gmx:lastApply\", { at: new Date().toISOString(), cats, moved, skipped });\n",[],[126],"c5a17291-e9f8-49f8-986c-e37d2a9e55d5",["D",1789328935249],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","IMAP cleanup of Kirk's GMX mailbox","imageUrl","userId","aa4a2c1b-3d04-409c-88c5-af54cb1d3470","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a08d16-8467-769a-84f6-caf4cfc8139c","tursoName","c5a17291e9f849f8986ce37d2a9e55d5","tursoHostname","c5a17291e9f849f8986ce37d2a9e55d5-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789504321592],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_190":186},"org",{"_11":12,"_183":184,"_185":186,"_143":144,"_187":188,"_189":52},"branch",{"_17":96,"_13":16,"_33":39,"_175":133,"_176":-5,"_177":-5,"_178":-5,"_179":-5,"_180":-5,"_181":14,"_182":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Kirk Lenke","avatar","https://lh3.googleusercontent.com/a/ACg8ocJoDfrcBCOirw40MHfesVj8rSjuldOifXKqr9767Swx6brFywwEAQ=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":133,"_13":14,"_44":257,"_135":-5,"_136":52,"_137":138,"_139":138,"_140":141,"_142":-5,"_143":144,"_145":-5,"_146":52,"_147":-5,"_148":-5,"_149":46,"_150":151,"_152":153,"_154":155,"_156":258,"_158":-5,"_159":160,"_161":160,"_162":163,"_164":163,"_165":163,"_166":160,"_167":160,"_168":259,"_170":260,"_172":261,"_174":52},[221,222,223,224,225,226,227,228,229],"files",[221,222,223,224,225,226,227,228,229],"counts",{"_212":46,"_213":80,"_214":46,"_32":215,"_216":217},[],{"_33":34,"_38":39,"_35":36,"_13":19,"_49":50,"_47":48,"_17":46,"_37":-5,"_44":210,"_40":41,"_53":-5,"_18":211},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1789329934404],[19],"pulls","branches","forks",{"_218":112,"_220":46},"connections",{"_218":46,"_219":46},"count","unfilledCount","emptyCount",{"_33":125,"_13":126,"_35":127,"_37":-5,"_38":39,"_40":128,"_42":43,"_44":254,"_17":98,"_47":73,"_49":130,"_51":52,"_53":-5,"_65":255,"_18":256},{"_33":117,"_13":118,"_35":119,"_37":-5,"_38":39,"_40":120,"_42":43,"_44":251,"_17":46,"_47":73,"_49":122,"_51":52,"_53":-5,"_65":252,"_18":253},{"_33":109,"_13":110,"_35":111,"_37":-5,"_38":39,"_40":112,"_42":43,"_44":248,"_17":98,"_47":73,"_49":114,"_51":52,"_53":-5,"_65":249,"_18":250},{"_33":102,"_13":103,"_35":104,"_37":-5,"_38":39,"_40":98,"_42":43,"_44":245,"_17":46,"_47":73,"_49":106,"_51":52,"_53":-5,"_65":246,"_18":247},{"_33":93,"_13":94,"_35":95,"_37":-5,"_38":39,"_40":96,"_42":43,"_44":242,"_17":98,"_47":73,"_49":99,"_51":52,"_53":-5,"_65":243,"_18":244},{"_33":85,"_13":86,"_35":87,"_37":-5,"_38":39,"_40":88,"_42":43,"_44":239,"_17":46,"_47":73,"_49":90,"_51":52,"_53":-5,"_65":240,"_18":241},{"_33":77,"_13":78,"_35":79,"_37":-5,"_38":39,"_40":80,"_42":43,"_44":236,"_17":46,"_47":73,"_49":82,"_51":52,"_53":-5,"_65":237,"_18":238},{"_33":68,"_13":69,"_35":70,"_37":-5,"_38":39,"_40":71,"_42":43,"_44":233,"_17":46,"_47":73,"_49":74,"_51":52,"_53":-5,"_65":234,"_18":235},{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":230,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_65":231,"_18":232},["D",1789329934404],[],[19],["D",1789329146163],[],[69],["D",1789328935305],[],[78],["D",1789331136957],[],[86],["D",1789331284896],[],[94],["D",1789329112241],[],[103],["D",1789329634533],[],[110],["D",1789331068191],[],[118],["D",1789329784490],[],[126],["D",1789328935249],["D",1789504321592],{"_11":12,"_190":186},{"_11":12,"_183":184,"_185":186,"_143":144,"_187":188,"_189":52},{"_17":96,"_13":16,"_33":39,"_175":133,"_176":-5,"_177":-5,"_178":-5,"_179":-5,"_180":-5,"_181":14,"_182":12},"ctx",{"_168":-5,"_207":295,"_296":297,"_298":299,"_300":52,"_301":52,"_302":52,"_303":43,"_304":-5,"_305":-7,"_306":-7,"_307":46,"_308":52,"_309":52,"_310":-5,"_311":52,"_312":52,"_313":52,"_314":-5},"ENV",{"_266":267,"_268":269,"_270":16,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286,"_287":288,"_289":290,"_291":292,"_293":294},"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"]