[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_168":169,"_170":171},"routes/_app.x.$handle.$name",{"_94":93,"_32":44,"_103":84,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",51,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":20,"_34":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":20,"_34":35},"deleted",false,"deletedHere","path","valtown-backend.ts","latestPath","fileId","a3fb1e98-589a-11f1-813b-ee650bb23af1","name","fileType","content","\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.30.0\";\nimport { ROLE_CONTEXTS, DEFAULT_SYSTEM_PROMPTS } from \"https://check.liftaro.de/vorabcheck/prompts.js?v=3\";\nimport { VORABCHECK_TARGET_FIELDS, handleUploadVorabcheckPdf } from \"https://check.liftaro.de/vorabcheck/backend-extras.js?v=6\";\n\nconst MODEL = \"claude-sonnet-4-6\"; // Upgrade von 4.5 → 4.6 für besseres Vision-Verständnis bei Tabellen\nconst COST_PER_M_INPUT_TOKENS = 3.0; // $ pro 1M Input-Tokens (Sonnet 4.6 — Preise ähnlich 4.5)\nconst COST_PER_M_OUTPUT_TOKENS = 15.0; // $ pro 1M Output-Tokens\nconst USD_TO_EUR = 0.92;\n\nlet _promptCache: Record | null = null;\nlet _promptCacheTs = 0;\nconst PROMPT_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function atPatchRetry(url: string, k: string, fields: any, max = 15): Promise<{ ok: boolean, error?: string }> {\n const headers = { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' };\n let a = 0;\n while (a++ < max) {\n const r = await fetch(url, { method: 'PATCH', headers, body: JSON.stringify({ fields }) });\n if (r.ok) return { ok: true };\n const txt = await r.text();\n let bad = '';\n try {\n const j = JSON.parse(txt);\n const m = String(j?.error?.message || j?.error || '').match(/Unknown field name:\\s*\"([^\"]+)\"/i);\n if (m) bad = m[1];\n } catch (_) {}\n if (bad && Object.prototype.hasOwnProperty.call(fields, bad)) { delete fields[bad]; continue; }\n return { ok: false, error: txt.slice(0, 200) };\n }\n return { ok: false, error: 'too many retries' };\n}\n\nasync function loadCustomPrompts(): Promise> {\n if (_promptCache && Date.now() - _promptCacheTs < PROMPT_CACHE_TTL_MS) return _promptCache;\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { _promptCache = {}; _promptCacheTs = Date.now(); return _promptCache; }\n try {\n const res = await fetch(`https://api.airtable.com/v0/${base}/Vorabcheck-Prompts`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(\"HTTP \" + res.status);\n const data = await res.json();\n const map: Record = {};\n (data.records || []).forEach((r: any) => {\n const t = r.fields?.check_type;\n const p = r.fields?.system_prompt;\n if (t && p && p.trim().length > 50) map[t] = p;\n });\n _promptCache = map;\n _promptCacheTs = Date.now();\n return map;\n } catch (e) {\n console.warn(\"loadCustomPrompts:\", e);\n return _promptCache || {};\n }\n}\n\nconst PIPEDRIVE_MASTER_BASE = 'appzhNrhkLSTEaNFW';\nconst PIPEDRIVE_PROJECT_ID = 'p_1777239396379';\nlet _pdCache: { domain: string, token: string } | null = null;\nlet _pdCacheTs = 0;\nconst PD_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function loadPipedriveConfig(): Promise<{ domain: string, token: string } | null> {\n if (_pdCache && Date.now() - _pdCacheTs < PD_CACHE_TTL_MS) return _pdCache;\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n if (!atKey) { _pdCacheTs = Date.now(); return null; }\n try {\n const url = 'https://api.airtable.com/v0/' + PIPEDRIVE_MASTER_BASE + '/Keys?filterByFormula=' +\n encodeURIComponent(\"AND({project_id}='\" + PIPEDRIVE_PROJECT_ID + \"',OR({key_name}='pipedriveDomain',{key_name}='pipedriveApiToken'))\");\n const res = await fetch(url, { headers: { Authorization: 'Bearer ' + atKey } });\n if (!res.ok) throw new Error('HTTP ' + res.status);\n const data = await res.json();\n let domain = '', token = '';\n (data.records || []).forEach((r: any) => {\n if (r.fields?.key_name === 'pipedriveDomain') domain = String(r.fields.key_value || '').trim();\n if (r.fields?.key_name === 'pipedriveApiToken') token = String(r.fields.key_value || '').trim();\n });\n _pdCacheTs = Date.now();\n if (!domain || !token) { _pdCache = null; return null; }\n _pdCache = { domain: domain.replace(/^https?:\\/\\//, '').replace(/\\/$/, ''), token };\n return _pdCache;\n } catch (e) {\n console.warn('[Pipedrive] loadPipedriveConfig:', e);\n return null;\n }\n}\n\nasync function createPipedriveLead(input: {\n name: string;\n email?: string;\n phone?: string;\n org?: string;\n title: string;\n note: string;\n}): Promise<{ ok: boolean; lead_id?: string; person_id?: number; reused?: boolean; error?: string }> {\n return upsertPipedriveLead(input);\n}\n\nasync function upsertPipedriveLead(input: {\n name: string;\n email?: string;\n phone?: string;\n org?: string;\n title: string;\n note: string;\n}): Promise<{ ok: boolean; lead_id?: string; person_id?: number; reused?: boolean; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n let personId: number | null = null;\n let personExisted = false;\n\n if (input.email) {\n try {\n const searchUrl = base + '/persons/search?fields=email&exact_match=true&limit=5&term=' +\n encodeURIComponent(input.email) + '&api_token=' + encodeURIComponent(cfg.token);\n const sr = await fetch(searchUrl);\n const sd = await sr.json();\n if (sd?.success && sd.data?.items?.length) {\n personId = sd.data.items[0].item?.id || null;\n if (personId) personExisted = true;\n }\n } catch (e) { }\n }\n\n if (!personId) {\n const personBody: any = { name: input.name || 'Anonym' };\n if (input.email) personBody.email = [{ value: input.email, primary: true, label: 'work' }];\n if (input.phone) personBody.phone = [{ value: input.phone, primary: true, label: 'work' }];\n const personRes = await fetch(base + '/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(personBody),\n });\n const personData = await personRes.json();\n if (!personData.success) {\n return { ok: false, error: 'Person: ' + JSON.stringify(personData.error || personData).slice(0, 200) };\n }\n personId = personData.data.id;\n }\n\n let orgId: number | null = null;\n if (input.org && input.org.trim() && !personExisted) {\n try {\n const orgRes = await fetch(base + '/organizations' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ name: input.org.trim() }),\n });\n const orgData = await orgRes.json();\n if (orgData.success) orgId = orgData.data.id;\n } catch (e) { }\n }\n\n let leadId: string | null = null;\n let leadReused = false;\n try {\n const leadsUrl = base + '/leads?person_id=' + personId + '&archived_status=not_archived&limit=20&api_token=' + encodeURIComponent(cfg.token);\n const lr = await fetch(leadsUrl);\n const ld = await lr.json();\n if (ld?.success && Array.isArray(ld.data) && ld.data.length > 0) {\n const sorted = ld.data.slice().sort((a: any, b: any) =>\n String(b.add_time || '').localeCompare(String(a.add_time || ''))\n );\n leadId = sorted[0].id;\n leadReused = true;\n }\n } catch (e) { }\n\n if (!leadId) {\n const leadBody: any = { title: input.title, person_id: personId };\n if (orgId) leadBody.organization_id = orgId;\n const leadRes = await fetch(base + '/leads' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(leadBody),\n });\n const leadData = await leadRes.json();\n if (!leadData.success) {\n return { ok: false, error: 'Lead: ' + JSON.stringify(leadData.error || leadData).slice(0, 200), person_id: personId };\n }\n leadId = leadData.data.id;\n }\n\n if (input.note) {\n try {\n const stamp = new Date().toISOString().replace('T', ' ').slice(0, 16) + ' UTC';\n const noteWithStamp = '🕒 ' + stamp + '\\n\\n' + input.note;\n await fetch(base + '/notes' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteWithStamp, lead_id: leadId }),\n });\n } catch (e) { }\n }\n\n console.log('[Pipedrive] ' + (leadReused ? 'Lead reused' : 'Lead created') + ':', leadId,\n 'person=' + personId + (personExisted ? ' (existed)' : ' (new)'));\n return { ok: true, lead_id: leadId, person_id: personId, reused: leadReused };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nconst HV_GENERIC_EMAIL_PREFIXES = [\n 'info', 'kontakt', 'service', 'mail', 'office',\n 'verwaltung', 'hausverwaltung', 'team', 'kundenservice',\n 'support', 'anfrage', 'post', 'zentrale', 'verwalter',\n 'buero', 'hello', 'welcome', 'empfang', 'sekretariat',\n 'wohnen', 'immobilien',\n];\n\nfunction isGenericHvEmail(email: string): boolean {\n if (!email || typeof email !== 'string') return false;\n const e = email.trim().toLowerCase();\n if (!/^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/.test(e)) return false;\n const local = e.split('@')[0];\n return HV_GENERIC_EMAIL_PREFIXES.includes(local);\n}\n\nfunction pickGenericEmailFromPersons(persons: any[]): string | null {\n if (!Array.isArray(persons) || !persons.length) return null;\n for (const p of persons) {\n const emails = Array.isArray(p?.email) ? p.email : [];\n for (const e of emails) {\n const val = String(e?.value || '').trim();\n if (isGenericHvEmail(val)) return val;\n }\n }\n return null;\n}\n\nasync function findPipedriveOrgsByName(name: string, limit = 3): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return [];\n const term = String(name || '').trim();\n if (term.length < 3) return [];\n const termLow = term.toLowerCase();\n const base = 'https://' + cfg.domain + '/api/v1';\n try {\n const url = base + '/organizations/search?term=' + encodeURIComponent(term) +\n '&fields=name&exact_match=false&limit=10&api_token=' + encodeURIComponent(cfg.token);\n const r = await fetch(url);\n const d = await r.json();\n if (!d?.success || !d.data?.items?.length) return [];\n const filtered = d.data.items\n .map((it: any) => ({\n item: it.item,\n score: Number(it.result_score || 0),\n }))\n .filter((x: any) => {\n if (!x.item || !x.item.name) return false;\n const nameLow = String(x.item.name).toLowerCase();\n if (!nameLow.includes(termLow)) return false;\n return x.score >= 0.3 || term.length >= 5; // bei längerem Term Score-Toleranz lockern\n })\n .sort((a: any, b: any) => b.score - a.score)\n .slice(0, limit)\n .map((x: any) => x.item);\n return filtered;\n } catch (e) { console.warn('[Pipedrive] findOrgsByName:', e); return []; }\n}\n\nasync function findPipedriveOrgByName(name: string): Promise {\n const hits = await findPipedriveOrgsByName(name, 1);\n return hits.length ? hits[0] : null;\n}\n\nasync function getOrgGenericEmail(orgId: number): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg || !orgId) return null;\n const base = 'https://' + cfg.domain + '/api/v1';\n try {\n const url = base + '/organizations/' + orgId + '/persons?api_token=' + encodeURIComponent(cfg.token);\n const r = await fetch(url);\n const d = await r.json();\n if (!d?.success || !Array.isArray(d.data)) return null;\n return pickGenericEmailFromPersons(d.data);\n } catch (e) { console.warn('[Pipedrive] getOrgGenericEmail:', e); return null; }\n}\n\nasync function createPipedriveOrgWithEmail(input: {\n name: string;\n email?: string;\n website?: string;\n city?: string;\n source?: string; // 'manuell' | 'ki_serper' | 'user_verifiziert'\n}): Promise<{ ok: boolean; org_id?: number; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const orgBody: any = { name: input.name };\n if (input.city) orgBody.address = input.city;\n const orgRes = await fetch(base + '/organizations' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(orgBody),\n });\n const orgData = await orgRes.json();\n if (!orgData.success) return { ok: false, error: 'Org-Create: ' + JSON.stringify(orgData.error || {}).slice(0, 200) };\n const orgId = orgData.data.id;\n if (input.email && isGenericHvEmail(input.email)) {\n const personBody: any = {\n name: input.name + ' (Allgemein)',\n email: [{ value: input.email, primary: true, label: 'work' }],\n org_id: orgId,\n };\n await fetch(base + '/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(personBody),\n }).catch(() => { });\n }\n return { ok: true, org_id: orgId };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nasync function linkPersonToOrg(personId: number, orgId: number): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg || !personId || !orgId) return false;\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const r = await fetch(base + '/persons/' + personId + auth, {\n method: 'PUT',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ org_id: orgId }),\n });\n const d = await r.json();\n return !!d?.success;\n } catch (e) { console.warn('[Pipedrive] linkPersonToOrg:', e); return false; }\n}\n\nasync function createHvLead(input: {\n orgId: number;\n userFullName: string;\n userEmail?: string;\n savingsTotal?: number;\n checkNr: string;\n role: string;\n hvName: string;\n}): Promise<{ ok: boolean; lead_id?: string; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n let leadId: string | null = null;\n let reused = false;\n try {\n const lr = await fetch(base + '/leads?organization_id=' + input.orgId +\n '&archived_status=not_archived&limit=20&api_token=' + encodeURIComponent(cfg.token));\n const ld = await lr.json();\n if (ld?.success && Array.isArray(ld.data) && ld.data.length > 0) {\n const sorted = ld.data.slice().sort((a: any, b: any) =>\n String(b.add_time || '').localeCompare(String(a.add_time || '')));\n leadId = sorted[0].id;\n reused = true;\n }\n } catch (e) { }\n\n if (!leadId) {\n const title = '[HV-Lead] ' + input.hvName + ' — via Vorabcheck ' + input.checkNr;\n const leadBody: any = { title, organization_id: input.orgId };\n const lr = await fetch(base + '/leads' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(leadBody),\n });\n const ld = await lr.json();\n if (!ld.success) return { ok: false, error: 'HV-Lead: ' + JSON.stringify(ld.error || {}).slice(0, 200) };\n leadId = ld.data.id;\n }\n\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const stamp = new Date().toISOString().replace('T', ' ').slice(0, 16) + ' UTC';\n const roleLabel = input.role === 'eigentuemer' ? 'Eigentümer'\n : input.role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const noteLines = [\n '🕒 ' + stamp, '', 'HV-Lead aus Liftaro-Vorabcheck',\n 'Check-Nr: ' + input.checkNr, 'Auftraggeber: ' + input.userFullName + ' (' + roleLabel + ')',\n input.userEmail ? 'E-Mail: ' + input.userEmail : '',\n input.savingsTotal ? 'Sparpotenzial: ' + fmt(input.savingsTotal) + ' €/Jahr' : '',\n '', 'Follow-up: Einsparungsberechnung + Light-Paket',\n ].filter(Boolean);\n try {\n await fetch(base + '/notes' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteLines.join('\\n'), lead_id: leadId }),\n });\n } catch (e) { }\n\n console.log('[Pipedrive] HV-Lead ' + (reused ? 'reused' : 'created') + ':', leadId, 'org=' + input.orgId);\n return { ok: true, lead_id: leadId };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nlet _preisrefCache: any[] | null = null;\nlet _preisrefCacheTs = 0;\nconst PREISREF_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function loadPreisreferenzen(): Promise {\n if (_preisrefCache && Date.now() - _preisrefCacheTs < PREISREF_CACHE_TTL_MS) return _preisrefCache;\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { _preisrefCache = []; _preisrefCacheTs = Date.now(); return []; }\n try {\n const res = await fetch(`https://api.airtable.com/v0/${base}/Preisreferenzen`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(\"HTTP \" + res.status);\n const data = await res.json();\n const list = (data.records || []).map((r: any) => ({\n position: r.fields?.position || '',\n einheit: r.fields?.einheit || '',\n median_eur: Number(r.fields?.median_eur || 0),\n region: r.fields?.region || '',\n notes: r.fields?.notes || '',\n })).filter((p: any) => p.position && p.median_eur > 0);\n _preisrefCache = list;\n _preisrefCacheTs = Date.now();\n return list;\n } catch (e) {\n console.warn(\"loadPreisreferenzen:\", e);\n return _preisrefCache || [];\n }\n}\n\nfunction deterministicSavingsFactor(seed: string): number {\n let h = 0;\n for (let i = 0; i < seed.length; i++) h = ((h << 5) - h + seed.charCodeAt(i)) | 0;\n return 0.30 + ((h >>> 0) % 1000) / 1000 * 0.30; // 0,30 – 0,60\n}\n\n\nfunction buildSystemPrompt(checkType: string, role: string, customMap: Record): string | null {\n if (customMap[checkType + '.' + role]) return customMap[checkType + '.' + role];\n if (customMap[checkType]) return customMap[checkType];\n\n const base = DEFAULT_SYSTEM_PROMPTS[checkType];\n if (!base) return null;\n const roleCtx = ROLE_CONTEXTS[role] || ROLE_CONTEXTS.mieter;\n return roleCtx + '\\n\\n────────────────────────────────────────\\n\\n' + base;\n}\n\n\nexport default async function (req: Request): Promise {\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n };\n if (req.method === \"OPTIONS\") return new Response(null, { headers: corsHeaders });\n if (req.method !== \"POST\") return jsonResp({ error: \"POST only\" }, 405, corsHeaders);\n\n try {\n const body = await req.json();\n\n if (body.action === 'contact') {\n const c = body.contact || {};\n const name = String(c.name || '').trim();\n const email = String(c.email || '').trim();\n if (!name || !email) return jsonResp({ ok: false, error: 'name und email sind Pflichtfelder' }, 400, corsHeaders);\n const firma = String(c.firma || '').trim();\n const telefon = String(c.telefon || '').trim();\n const paket = String(c.paket || 'andere').toLowerCase();\n const anzahl = parseInt(String(c.anzahl || '0'), 10) || 0;\n const nachricht = String(c.nachricht || '').trim();\n const paketLabel = paket === 'free' ? 'Free (50% Erfolgsbeteiligung)'\n : paket === 'light' ? 'Light (45 €/Monat je Aufzug)'\n : 'Andere / unklar';\n\n try {\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n const atBase = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (atKey && atBase) {\n await fetch('https://api.airtable.com/v0/' + atBase + '/Kontakt-Anfragen', {\n method: 'POST',\n headers: { Authorization: 'Bearer ' + atKey, 'Content-Type': 'application/json' },\n body: JSON.stringify({\n fields: {\n name, email,\n firma: firma || '',\n telefon: telefon || '',\n paket: paketLabel,\n anzahl_aufzuege: anzahl,\n nachricht: nachricht || '',\n savedAt: new Date().toISOString(),\n },\n }),\n });\n }\n } catch (e: any) { console.warn('[Kontakt] Airtable failed:', e.message); }\n\n const noteLines = [\n 'Quelle: Startseite Kontakt-Formular',\n 'Paket-Interesse: ' + paketLabel,\n anzahl ? 'Anzahl Aufzüge: ' + anzahl : 'Anzahl Aufzüge: –',\n 'Firma / Hausverwaltung: ' + (firma || '–'),\n 'Telefon: ' + (telefon || '–'),\n '',\n '— Nachricht —',\n nachricht || '(keine)',\n ];\n const pd = await createPipedriveLead({\n name,\n email,\n phone: telefon || undefined,\n org: firma || undefined,\n title: '[Inbound] ' + name + ' — ' + paketLabel + (anzahl ? ' (' + anzahl + ' Aufzug' + (anzahl === 1 ? '' : 'e') + ')' : ''),\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: pd }, 200, corsHeaders);\n }\n\n if (body.action === 'soft_capture') {\n const lead = body.lead || {};\n const ct = String(body.check_type || '').trim() || 'unbekannt';\n const fileMeta = body.file_meta || {};\n const name = ((String(lead.vorname || '').trim() + ' ' + String(lead.nachname || '').trim()).trim()) || 'Anonym';\n const email = String(lead.email || '').trim();\n const telefon = String(lead.telefon || '').trim();\n const adresse = String(lead.adresse || '').trim();\n const rolle = String(lead.rolle || '').trim();\n const firma = String(lead.firma || '').trim();\n if (!email) return jsonResp({ ok: false, error: 'email Pflicht' }, 400, corsHeaders);\n\n const noteLines = [\n '🟡 SOFT-LEAD — User hat Step 2 abgeschickt, Analyse läuft / könnte abbrechen',\n '',\n 'Quelle: Vorabcheck Public-Landing',\n 'Check-Typ: ' + ct,\n rolle ? 'Rolle: ' + rolle : '',\n adresse ? 'Adresse Objekt: ' + adresse : '',\n firma ? 'Firma: ' + firma : '',\n 'Telefon: ' + (telefon || '–'),\n fileMeta.name ? 'Hochgeladenes Dokument: ' + fileMeta.name : '',\n fileMeta.size ? 'Dateigröße: ' + Math.round(fileMeta.size / 1024) + ' KB' : '',\n ].filter(Boolean);\n\n const pd = await upsertPipedriveLead({\n name,\n email,\n phone: telefon || undefined,\n org: firma || undefined,\n title: '[Vorabcheck Start] ' + name + ' — ' + ct,\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: pd }, 200, corsHeaders);\n }\n\n if (body.action === 'request_liftaro_callback') {\n const c = body.cta || {};\n const userEmail = String(c.user_email || '').trim();\n const userName = String(c.user_name || '').trim() || userEmail || 'Anonym';\n const checkNr = String(c.check_nr || '').trim() || '—';\n const role = String(c.role || 'eigentuemer').trim();\n const savings = Number(c.savings_total_eur || 0);\n const hvName = String(c.hv_name || '').trim();\n if (!userEmail) return jsonResp({ ok: false, error: 'user_email Pflichtfeld' }, 400, corsHeaders);\n\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const roleLabel = role === 'eigentuemer' ? 'Eigentümer'\n : role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const noteLines = [\n '🔥 HOT-LEAD — User hat „Direktkontakt durch Liftaro\" angeklickt',\n '',\n 'User-Wunsch: Liftaro soll proaktiv binnen 24h kontaktieren.',\n '',\n 'Vorabcheck-Kontext:',\n ' Check-Nr: ' + checkNr,\n ' Rolle: ' + roleLabel,\n savings ? ' Sparpotenzial: ' + fmt(savings) + ' € / Jahr' : '',\n hvName ? ' Hausverwaltung (genannt): ' + hvName : ' Hausverwaltung: nicht angegeben',\n '',\n 'Empfehlung Vertrieb:',\n ' → Anruf oder persönliche Mail innerhalb 24h.',\n ' → Konkrete Einsparungsberechnung anbieten.',\n ' → Light-Paket-Pitch anschließen wenn passend.',\n ].filter(Boolean);\n\n const result = await upsertPipedriveLead({\n name: userName,\n email: userEmail,\n title: '🔥 [HOT] ' + userName + ' — wünscht Direktkontakt (' + checkNr + ')',\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: result }, 200, corsHeaders);\n }\n\n if (body.action === 'list_property_managers') {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return jsonResp({ ok: false, error: 'pipedrive not configured' }, 500, corsHeaders);\n const lim = Math.min(parseInt(String(body.limit || '500'), 10) || 500, 500);\n try {\n const r = await fetch('https://' + cfg.domain + '/api/v1/organizations?start=0&limit=' + lim +\n '&api_token=' + encodeURIComponent(cfg.token));\n const d = await r.json();\n const orgs = (Array.isArray(d.data) ? d.data : []).map((o: any) => ({\n org_id: o.id, name: o.name || '', address: o.address || '',\n person_count: Number(o.people_count || 0),\n }));\n return jsonResp({ ok: true, results: orgs }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'get_property_manager_details') {\n const oid = parseInt(String(body.org_id || '0'), 10);\n if (!oid) return jsonResp({ ok: false, error: 'org_id required' }, 400, corsHeaders);\n const cfg = await loadPipedriveConfig();\n if (!cfg) return jsonResp({ ok: false, error: 'pipedrive not configured' }, 500, corsHeaders);\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const oRes = await fetch('https://' + cfg.domain + '/api/v1/organizations/' + oid + auth);\n const oData = await oRes.json();\n if (!oData?.success) return jsonResp({ ok: false, error: 'org not found' }, 404, corsHeaders);\n const org = oData.data;\n const pRes = await fetch('https://' + cfg.domain + '/api/v1/organizations/' + oid + '/persons' + auth);\n const pData = await pRes.json();\n const persons = Array.isArray(pData?.data) ? pData.data : [];\n const genEmail = pickGenericEmailFromPersons(persons);\n let gfName = '', gfTel = '', gfEmail = '';\n const personalP = persons.find((p: any) => {\n const emails = Array.isArray(p?.email) ? p.email : [];\n return emails.some((e: any) => e?.value && !isGenericHvEmail(String(e.value)));\n });\n const firstP = personalP || persons[0];\n if (firstP) {\n gfName = String(firstP.name || '').replace(/\\s*\$Allgemein\$\\s*$/i, '').trim();\n gfEmail = String((Array.isArray(firstP.email) ? firstP.email : []).find((e: any) => e?.value)?.value || '');\n gfTel = String((Array.isArray(firstP.phone) ? firstP.phone : []).find((p: any) => p?.value)?.value || '');\n }\n let strasse = '', plz = '', ort = '';\n const addr = String(org.address || '').trim();\n if (addr) {\n const parts = addr.split(',').map((s: string) => s.trim()).filter(Boolean);\n if (parts.length >= 2) {\n strasse = parts[0];\n const m = parts[1].match(/^(\\d{4,5})\\s+(.+)$/);\n if (m) { plz = m[1]; ort = m[2]; } else ort = parts[1];\n } else { strasse = addr; }\n }\n return jsonResp({ ok: true, details: {\n org_id: org.id, firma: String(org.name || ''), gf: gfName,\n strasse, plz, ort, email: genEmail || gfEmail || '', tel: gfTel,\n } }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'get_verwalter_context') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const enc = encodeURIComponent(\"{check_nr}='\" + cn + \"'\");\n const [vr, lr] = await Promise.all([\n fetch('https://api.airtable.com/v0/' + b + '/Vorab-Checks?filterByFormula=' + enc + '&maxRecords=1',\n { headers: { Authorization: 'Bearer ' + k } }),\n fetch('https://api.airtable.com/v0/' + b + '/Vorabcheck-Leads?filterByFormula=' + enc + '&maxRecords=1',\n { headers: { Authorization: 'Bearer ' + k } }),\n ]);\n const vd = await vr.json(); const ld = await lr.json();\n const vc = vd?.records?.[0]?.fields;\n if (!vc) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const lead = ld?.records?.[0]?.fields || {};\n return jsonResp({ ok: true, ctx: {\n check_nr: cn,\n check_type: vc.check_type || '',\n ampel: vc.ampel || '',\n summary: vc.summary || '',\n savings_total_eur: Number(vc.savings_total_eur || vc.savings_estimate_eur || 0),\n savings_individual_eur: Number(vc.savings_individual_eur || 0),\n aufzug_count: Number(vc.aufzug_count || 0),\n parteien_count: Number(vc.parteien_count || 0),\n role: vc.role || '',\n eigentuemer_name: [lead.vorname, lead.nachname].filter(Boolean).join(' '),\n objekt_adresse: String(vc.objekt_adresse || lead.adresse || ''),\n hv_name: vc.hv_name || '',\n hv_email: vc.hv_email || '',\n hv_telefon: vc.hv_telefon || '',\n hv_adresse: vc.hv_adresse || '',\n hv_website: vc.hv_website || '',\n verwalter_status: vc.verwalter_status || 'offen',\n verwalter_name: vc.verwalter_name || '',\n verwalter_response_at: vc.verwalter_response_at || '',\n } }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'submit_verwalter_response') {\n const cn = String(body.check_nr || '').trim();\n const v = body.verwalter || {};\n const mode = String(body.mode || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n if (!v.name || !v.email) return jsonResp({ ok: false, error: 'name+email pflicht' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n verwalter_name: String(v.name || '').trim(),\n verwalter_email: String(v.email || '').trim(),\n verwalter_telefon: String(v.telefon || '').trim(),\n verwalter_response_mode: mode,\n verwalter_response_at: new Date().toISOString(),\n verwalter_status: 'antwort_erhalten',\n };\n const vFirma = String(v.firma || '').trim();\n if (vFirma) fields.verwalter_firma_name = vFirma;\n const vObj = String(v.objekt_adresse || '').trim();\n if (vObj) { fields.verwalter_objekt_adresse = vObj; fields.objekt_adresse = vObj; }\n if (body.responses) fields.verwalter_response_json = JSON.stringify(body.responses);\n if (mode === 'fragen' && body.responses && typeof body.responses === 'object') {\n const r: any = body.responses;\n if (r.anzahl_aufzuege) {\n const n = parseInt(String(r.anzahl_aufzuege), 10);\n if (n > 0 && n <= 50) fields.vertrag_anzahl_aufzuege = n;\n }\n if (r.wartungen) fields.vertrag_wartungen_pro_jahr = String(r.wartungen);\n if (r.vertragsart === 'voll') fields.vertrag_wartungstyp = 'Vollwartung';\n if (r.vertragsart === 'system') fields.vertrag_wartungstyp = 'Systemwartung';\n if (r.tuev_begl) fields.vertrag_tuev_begleitung = (r.tuev_begl === 'inkl');\n if (r.tuev_pruef) fields.vertrag_tuev_pruefung = (r.tuev_pruef === 'inkl');\n if (r.notruf) fields.vertrag_notruf = (r.notruf === 'inkl');\n fields.vertrag_extracted_at = new Date().toISOString();\n fields.vertrag_extracted_source = 'konfig';\n }\n if (body.pdf_base64 && body.pdf_base64.length > 100) {\n const fname = String(body.pdf_name || 'vertrag.pdf');\n try {\n const up = await fetch('https://content.airtable.com/v0/' + b + '/' + recId + '/verwalter_response_pdf/uploadAttachment', {\n method: 'POST', headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify({ contentType: String(body.pdf_mime || 'application/pdf'), filename: fname, file: body.pdf_base64 }),\n });\n if (!up.ok) fields.verwalter_response_pdf_name = fname + ' (Upload fehlgeschlagen)';\n } catch (e) { fields.verwalter_response_pdf_name = fname; }\n }\n await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 25);\n return jsonResp({ ok: true, applied_fields: Object.keys(fields) }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'set_bearbeiter_status') {\n const cn = String(body.check_nr || '').trim();\n const st = String(body.status || '').trim();\n const allowed = new Set(['offen', 'in_bearbeitung', 'erledigt']);\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n if (!allowed.has(st)) return jsonResp({ ok: false, error: 'status invalid' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n bearbeiter_status: st,\n bearbeiter_status_at: new Date().toISOString(),\n };\n if (body.bearbeiter_name) fields.bearbeiter_name = String(body.bearbeiter_name).trim();\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 10);\n return res.ok ? jsonResp({ ok: true, status: st }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'link_followup_check') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n linked_check_id: String(body.linked_check_id || '').trim(),\n linked_check_requestid: String(body.linked_check_requestid || '').trim(),\n linked_check_type: String(body.linked_check_type || '').trim(),\n linked_check_ersparnis: String(body.linked_check_ersparnis || '').trim(),\n linked_check_at: new Date().toISOString(),\n bearbeiter_status: 'in_bearbeitung',\n bearbeiter_status_at: new Date().toISOString(),\n };\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 15);\n return res.ok ? jsonResp({ ok: true, linked: fields.linked_check_requestid }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'sync_hv_pipedrive') {\n const hvName = String(body.hv_name || '').trim();\n if (!hvName) return jsonResp({ ok: false, error: 'hv_name pflicht' }, 400, corsHeaders);\n try {\n const ex = await findPipedriveOrgByName(hvName);\n if (ex?.id) return jsonResp({ ok: true, action: 'found', org_id: ex.id, org_name: ex.name || hvName }, 200, corsHeaders);\n const c = await createPipedriveOrgWithEmail({\n name: hvName,\n email: String(body.hv_email || '').trim() || undefined,\n city: String(body.hv_adresse || '').trim() || undefined,\n source: body.hv_adresse ? 'ki_web' : 'user_verifiziert',\n });\n if (!c.ok || !c.org_id) return jsonResp({ ok: false, error: 'create failed' }, 500, corsHeaders);\n try {\n const cfg = await loadPipedriveConfig();\n if (cfg && (body.check_nr || body.hv_telefon || body.hv_adresse)) {\n const note = 'Aus Liftaro-Vertragscheck' +\n (body.check_nr ? '\\nCheck-Nr: ' + body.check_nr : '') +\n (body.hv_telefon ? '\\nTel: ' + body.hv_telefon : '') +\n (body.hv_adresse ? '\\nAdresse: ' + body.hv_adresse : '');\n await fetch('https://' + cfg.domain + '/api/v1/notes?api_token=' + encodeURIComponent(cfg.token), {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: note, org_id: c.org_id }),\n }).catch(() => {});\n }\n } catch (_) {}\n return jsonResp({ ok: true, action: 'created', org_id: c.org_id }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'patch_objekt_adresse') {\n const cn = String(body.check_nr || '').trim();\n const addr = String(body.objekt_adresse || '').trim();\n if (!cn || !addr) return jsonResp({ ok: false, error: 'check_nr + objekt_adresse erforderlich' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, { objekt_adresse: addr });\n return res.ok ? jsonResp({ ok: true }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'enrich_property_manager') {\n const name = String(body.name || '').trim();\n const city = String(body.city || '').trim();\n if (!name) return jsonResp({ ok: false, error: 'name required' }, 400, corsHeaders);\n let serperKey = String(Deno.env.get(\"SERPER_API_KEY\") || '').trim();\n if (!serperKey) {\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n try {\n const url = 'https://api.airtable.com/v0/' + PIPEDRIVE_MASTER_BASE + '/Keys?filterByFormula=' +\n encodeURIComponent(\"AND({project_id}='\" + PIPEDRIVE_PROJECT_ID + \"',{key_name}='serperApiKey')\");\n const r = await fetch(url, { headers: { Authorization: 'Bearer ' + atKey } });\n const d = await r.json();\n serperKey = String(d?.records?.[0]?.fields?.key_value || '').trim();\n } catch (e) { /* */ }\n }\n if (!serperKey) return jsonResp({ ok: false, error: 'SERPER_API_KEY nicht konfiguriert (Env-Var oder Master-Base)' }, 500, corsHeaders);\n const q = '\"' + name + '\"' + (city ? ' ' + city : '') + ' Hausverwaltung Impressum';\n let snippets = '';\n try {\n const sr = await fetch('https://google.serper.dev/search', {\n method: 'POST',\n headers: { 'X-API-KEY': serperKey, 'Content-Type': 'application/json' },\n body: JSON.stringify({ q, gl: 'de', hl: 'de', num: 5 }),\n });\n const sd = await sr.json();\n const hits = Array.isArray(sd.organic) ? sd.organic.slice(0, 3) : [];\n snippets = hits.map((h: any) => 'URL: ' + (h.link || '') + '\\nTitel: ' + (h.title || '') + '\\nSnippet: ' + (h.snippet || '')).join('\\n\\n');\n } catch (e: any) { return jsonResp({ ok: false, error: 'Serper: ' + e.message }, 500, corsHeaders); }\n if (!snippets) return jsonResp({ ok: false, error: 'Keine Suchergebnisse' }, 404, corsHeaders);\n const anthropic = new Anthropic({ apiKey: Deno.env.get(\"ANTHROPIC_KEY\") });\n const sys = 'Du extrahierst Stammdaten von Hausverwaltungen aus Google-Suchergebnis-Snippets. WICHTIG: Gib NUR Werte zurueck, die WORTWOERTLICH in den Snippets vorkommen. Wenn ein Feld nicht eindeutig im Text steht, setze es auf null. Erfinde NICHTS. Antworte ausschliesslich als JSON ohne Fliesstext und ohne Markdown-Code-Block.';\n const userPrompt = 'Hausverwaltung: \"' + name + '\"' + (city ? ' in ' + city : '') + '\\n\\nExtrahiere die offiziellen Stammdaten.\\n\\nFormat:\\n{\\n \"strasse\": \"...\",\\n \"plz\": \"...\",\\n \"ort\": \"...\",\\n \"telefon\": \"...\",\\n \"email\": \"...\",\\n \"ustidnr\": \"DEXXXXXXXXX\",\\n \"steuernr\": \"...\",\\n \"website\": \"...\"\\n}\\n\\nSuchergebnisse:\\n' + snippets;\n try {\n const msg = await anthropic.messages.create({\n model: 'claude-haiku-4-5',\n max_tokens: 600,\n system: sys,\n messages: [{ role: 'user', content: userPrompt }],\n });\n const txt = (msg.content[0] as any)?.type === 'text' ? (msg.content[0] as any).text : '';\n const jm = txt.match(/\\{[\\s\\S]*\\}/);\n if (!jm) return jsonResp({ ok: false, error: 'KI hat keine Daten geliefert' }, 200, corsHeaders);\n const raw = JSON.parse(jm[0]);\n const snipLow = snippets.toLowerCase();\n const snipNoSpace = snipLow.replace(/\\s+/g, '');\n const data: any = {};\n for (const k of ['strasse','plz','ort','telefon','email','ustidnr','steuernr','website']) {\n const v = raw[k];\n if (v && typeof v === 'string' && v !== 'null' && v.trim().length > 1) {\n const vLow = String(v).toLowerCase();\n const vNoSpace = vLow.replace(/\\s+/g, '');\n if (snipLow.includes(vLow) || snipNoSpace.includes(vNoSpace)) {\n data[k] = String(v).trim();\n }\n }\n }\n return jsonResp({ ok: true, data, snippet_count: snippets.split('\\n\\n').length }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: 'Claude: ' + e.message }, 500, corsHeaders); }\n }\n if (body.action === 'create_pm') {\n const n=String(body.name||'').trim(); if(!n) return jsonResp({ok:false,error:'name required'},400,corsHeaders);\n const e=String(body.email||'').trim(), s=String(body.strasse||'').trim(), c=String(body.city||'').trim(), t=String(body.tel||'').trim(), w=String(body.website||'').trim();\n const cr=await createPipedriveOrgWithEmail({name:n,email:e,city:s||c,website:w,source:'inbox_ki'});\n if(!cr.ok) return jsonResp(cr,200,corsHeaders);\n if(t||w||s){const cfg=await loadPipedriveConfig(); if(cfg){const note='🤖 Inbox-KI:\\n'+(s?'Adresse: '+s+(c?', '+c:'')+'\\n':'')+(t?'Telefon: '+t+'\\n':'')+(w?'Website: '+w+'\\n':''); await fetch('https://'+cfg.domain+'/api/v1/notes?api_token='+encodeURIComponent(cfg.token),{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({content:note,org_id:cr.org_id})}).catch(()=>{});}}\n return jsonResp({ok:true,org_id:cr.org_id,name:n},200,corsHeaders);\n }\n if (body.action === 'find_property_manager') {\n const q = String(body.query || '').trim();\n if (q.length < 3) return jsonResp({ ok: true, results: [] }, 200, corsHeaders);\n const orgs = await findPipedriveOrgsByName(q, 3);\n if (!orgs.length) return jsonResp({ ok: true, results: [], source: 'db' }, 200, corsHeaders);\n const enriched = await Promise.all(orgs.map(async (org: any) => {\n const email = await getOrgGenericEmail(org.id);\n return {\n org_id: org.id,\n name: org.name,\n email: email, // null wenn nur personalisierte Mails vorhanden\n city: org.address || '', // best-effort, Pipedrive-Adresse als Volltext\n confidence: email ? 100 : 60, // mit Email = sichere DB-Quelle\n };\n }));\n return jsonResp({ ok: true, source: 'db', results: enriched }, 200, corsHeaders);\n }\n\n if (body.action === 'submit_eigentuemer_cta') {\n const c = body.cta || {};\n const hvName = String(c.hv_name || '').trim();\n const hvEmail = String(c.hv_email || '').trim();\n const hvAddress = String(c.hv_address || '').trim();\n const hvTelefon = String(c.hv_telefon || '').trim();\n const hvWebsite = String(c.hv_website || '').trim();\n const userEmail = String(c.user_email || '').trim();\n const userName = String(c.user_name || '').trim() || userEmail || 'Anonym';\n const checkNr = String(c.check_nr || '').trim() || '—';\n const role = String(c.role || 'eigentuemer').trim();\n const savings = Number(c.savings_total_eur || 0);\n\n if (!hvName) return jsonResp({ ok: false, error: 'hv_name Pflichtfeld' }, 400, corsHeaders);\n\n try {\n let org = await findPipedriveOrgByName(hvName);\n let orgId: number | null = org?.id || null;\n let orgCreated = false;\n if (!orgId) {\n const created = await createPipedriveOrgWithEmail({\n name: hvName,\n email: isGenericHvEmail(hvEmail) ? hvEmail : undefined,\n city: hvAddress || undefined,\n source: hvAddress ? 'ki_web' : 'user_verifiziert',\n });\n if (created.ok && created.org_id) {\n orgId = created.org_id;\n orgCreated = true;\n if (hvTelefon || hvWebsite) {\n const cfgN = await loadPipedriveConfig();\n if (cfgN) {\n const noteContent = '🔍 Aus Web-Suche extrahiert:\\n' +\n (hvAddress ? 'Adresse: ' + hvAddress + '\\n' : '') +\n (hvTelefon ? 'Telefon: ' + hvTelefon + '\\n' : '') +\n (hvWebsite ? 'Website: ' + hvWebsite + '\\n' : '');\n await fetch('https://' + cfgN.domain + '/api/v1/notes?api_token=' + encodeURIComponent(cfgN.token), {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteContent, org_id: orgId }),\n }).catch(() => { /* non-critical */ });\n }\n }\n }\n }\n\n if (orgId && !orgCreated && hvEmail && isGenericHvEmail(hvEmail)) {\n const existingMail = await getOrgGenericEmail(orgId);\n if (!existingMail) {\n const cfg = await loadPipedriveConfig();\n if (cfg) {\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n await fetch('https://' + cfg.domain + '/api/v1/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({\n name: hvName + ' (Allgemein)',\n email: [{ value: hvEmail, primary: true, label: 'work' }],\n org_id: orgId,\n }),\n }).catch(() => { });\n }\n }\n }\n\n let userPersonId: number | null = null;\n if (orgId && userEmail) {\n const cfg = await loadPipedriveConfig();\n if (cfg) {\n try {\n const searchUrl = 'https://' + cfg.domain + '/api/v1/persons/search?fields=email&exact_match=true&limit=5&term=' +\n encodeURIComponent(userEmail) + '&api_token=' + encodeURIComponent(cfg.token);\n const sr = await fetch(searchUrl);\n const sd = await sr.json();\n if (sd?.success && sd.data?.items?.length) {\n userPersonId = sd.data.items[0].item?.id || null;\n }\n } catch (e) { }\n }\n if (userPersonId) await linkPersonToOrg(userPersonId, orgId);\n }\n\n let hvLead: any = { ok: false };\n if (orgId) {\n hvLead = await createHvLead({\n orgId,\n userFullName: userName,\n userEmail,\n savingsTotal: savings,\n checkNr,\n role,\n hvName,\n });\n }\n\n try {\n const ak = Deno.env.get(\"AIRTABLE_KEY\"); const ab = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (ak && ab && checkNr && checkNr !== '—') {\n const fr = await fetch('https://api.airtable.com/v0/' + ab + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + checkNr + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + ak } });\n const rId = (await fr.json())?.records?.[0]?.id;\n if (rId) {\n const hvFields: any = {};\n if (hvName) hvFields.hv_name = hvName;\n if (hvEmail) hvFields.hv_email = hvEmail;\n if (hvTelefon) hvFields.hv_telefon = hvTelefon;\n if (hvAddress) hvFields.hv_adresse = hvAddress;\n if (hvWebsite) hvFields.hv_website = hvWebsite;\n if (orgId) hvFields.hv_pipedrive_org_id = String(orgId);\n if (Object.keys(hvFields).length) {\n await atPatchRetry('https://api.airtable.com/v0/' + ab + '/Vorab-Checks/' + rId, ak, hvFields, 12);\n }\n }\n }\n } catch (e) { /* HV-Patch non-critical */ }\n return jsonResp({\n ok: true,\n org_id: orgId,\n org_created: orgCreated,\n user_person_id: userPersonId,\n hv_lead: hvLead,\n }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: 'Exception: ' + (e.message || String(e)) }, 500, corsHeaders);\n }\n }\n\n if (body.action === 'get_defaults') {\n return jsonResp({\n prompts: DEFAULT_SYSTEM_PROMPTS,\n role_contexts: ROLE_CONTEXTS,\n model: MODEL,\n backend_version: 'V9.90',\n backend_features: ['set_bearbeiter_status', 'link_followup_check', 'vertrag_mapping_konfig', 'patch_retry_on_unknown_field', 'ensure_vorabcheck_schema', 'verwalter_pdf_attachment'],\n }, 200, corsHeaders);\n }\n if (body.action === 'ensure_vorabcheck_schema') {\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n const TARGET_FIELDS: any[] = VORABCHECK_TARGET_FIELDS;\n try {\n const schemaRes = await fetch('https://api.airtable.com/v0/meta/bases/' + b + '/tables', {\n headers: { Authorization: 'Bearer ' + k },\n });\n if (!schemaRes.ok) {\n const txt = await schemaRes.text();\n let hint = '';\n if (schemaRes.status === 403 || schemaRes.status === 401) {\n hint = ' — Dein Airtable-PAT braucht den Scope schema.bases:read und schema.bases:write. Erweitere ihn unter airtable.com/create/tokens.';\n }\n return jsonResp({ ok: false, error: 'Schema lesen fehlgeschlagen (HTTP ' + schemaRes.status + ')' + hint, raw: txt.slice(0, 300) }, schemaRes.status, corsHeaders);\n }\n const schema = await schemaRes.json();\n const tbl = schema.tables?.find((t: any) => t.name === 'Vorab-Checks');\n if (!tbl) return jsonResp({ ok: false, error: 'Tabelle „Vorab-Checks\" nicht gefunden' }, 404, corsHeaders);\n const existingNames = new Set(tbl.fields.map((f: any) => f.name));\n const created: string[] = [];\n const skipped: string[] = [];\n const failed: any[] = [];\n if (body.dry_run) {\n for (const field of TARGET_FIELDS) {\n if (existingNames.has(field.name)) skipped.push(field.name);\n else created.push(field.name);\n }\n return jsonResp({ ok: true, dry_run: true, would_create: created, already_exists: skipped, total_target: TARGET_FIELDS.length, table_id: tbl.id }, 200, corsHeaders);\n }\n for (const field of TARGET_FIELDS) {\n if (existingNames.has(field.name)) { skipped.push(field.name); continue; }\n const createRes = await fetch('https://api.airtable.com/v0/meta/bases/' + b + '/tables/' + tbl.id + '/fields', {\n method: 'POST',\n headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify(field),\n });\n if (createRes.ok) {\n created.push(field.name);\n } else {\n const txt = await createRes.text();\n failed.push({ name: field.name, status: createRes.status, error: txt.slice(0, 200) });\n }\n }\n return jsonResp({ ok: true, created, skipped, failed, total_target: TARGET_FIELDS.length, table_id: tbl.id }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: e.message }, 500, corsHeaders);\n }\n }\n if (body.action === 'ping') {\n return jsonResp({\n ok: true,\n backend_version: 'V9.91',\n backend_features: ['set_bearbeiter_status', 'link_followup_check', 'vertrag_mapping_konfig', 'patch_retry_on_unknown_field', 'ensure_vorabcheck_schema', 'verwalter_pdf_attachment', 'upload_vorabcheck_pdf'],\n model: MODEL,\n }, 200, corsHeaders);\n }\n\n // V12.42: Vorabcheck-PDF auf ergebnis_pdf hochladen (Logik in backend-extras.js)\n if (body.action === 'upload_vorabcheck_pdf') {\n const res = await handleUploadVorabcheckPdf(body, {\n AIRTABLE_KEY: Deno.env.get(\"AIRTABLE_KEY\"),\n AIRTABLE_BASE_ID: Deno.env.get(\"AIRTABLE_BASE_ID\"),\n });\n return jsonResp(res, res.status || (res.ok ? 200 : 500), corsHeaders);\n }\n\n if (body.action === 'correct') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ error: 'check_nr fehlt' }, 400, corsHeaders);\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) return jsonResp({ ok: false, warning: 'Airtable nicht konfiguriert' }, 200, corsHeaders);\n const fields = body.fields || {};\n const records: any[] = [];\n Object.keys(fields).forEach(k => {\n const v = fields[k];\n if (v && v.changed) {\n records.push({\n fields: {\n check_nr: cn,\n field_name: k,\n original_value: String(v.original ?? ''),\n corrected_value: String(v.corrected ?? ''),\n savedAt: new Date().toISOString(),\n }\n });\n }\n });\n if (!records.length) return jsonResp({ ok: true, count: 0 }, 200, corsHeaders);\n try {\n const url = `https://api.airtable.com/v0/${base}/Vorabcheck-Korrekturen`;\n for (let i = 0; i < records.length; i += 10) {\n const batch = records.slice(i, i + 10);\n await fetch(url, {\n method: 'POST',\n headers: { Authorization: `Bearer ${key}`, 'Content-Type': 'application/json' },\n body: JSON.stringify({ records: batch }),\n });\n }\n return jsonResp({ ok: true, count: records.length }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: e.message }, 500, corsHeaders);\n }\n }\n\n const { check_type, file, lead, turnstile_token, consent_given } = body;\n const role = ['mieter','eigentuemer','verwalter'].includes(body.role) ? body.role : 'mieter';\n const aufzugCountUser = Math.max(1, Math.min(50, parseInt(String(body.aufzug_count_user || '1'), 10) || 1));\n const wartungBruttoUser = Math.max(0, parseFloat(String(body.wartung_brutto_user || '0').replace(',', '.')) || 0);\n\n const turnstileSecret = Deno.env.get(\"TURNSTILE_SECRET_KEY\");\n const isDevBypass = String(turnstile_token || '') === 'dev-bypass-token';\n if (turnstileSecret && turnstile_token && !isDevBypass) {\n const ok = await verifyTurnstile(turnstile_token, turnstileSecret);\n if (!ok) return jsonResp({ error: \"Captcha ungültig\" }, 403, corsHeaders);\n }\n\n if (!consent_given) return jsonResp({ error: \"Einwilligung fehlt\" }, 400, corsHeaders);\n\n const custom = await loadCustomPrompts();\n let systemPrompt = buildSystemPrompt(check_type, role, custom);\n if (!systemPrompt) return jsonResp({ error: \"Unbekannter Check-Typ\" }, 400, corsHeaders);\n\n let preisrefList: any[] = [];\n if (check_type === 'angebot') {\n preisrefList = await loadPreisreferenzen();\n if (preisrefList.length) {\n const preisrefBlock =\n '\\n\\n═══════════════════════════════════════════\\n' +\n 'MARKTPREIS-REFERENZEN (verbindlich, NICHT VERHANDELBAR)\\n' +\n '═══════════════════════════════════════════\\n' +\n 'Diese Liste enthält den aktuellen Marktmedian je Position für Aufzug-Reparatur/Wartung. ' +\n 'Vergleiche JEDE Angebots-Position mit dieser Liste:\\n\\n' +\n preisrefList.map((p, i) =>\n (i + 1) + '. ' + p.position + ' — ' + p.median_eur.toFixed(2) + ' € pro ' + p.einheit +\n (p.region ? ' (' + p.region + ')' : '') +\n (p.notes ? ' — ' + p.notes : '')\n ).join('\\n') + '\\n\\n' +\n 'Wenn eine Angebots-Position in dieser Liste auftaucht: nutze den Median als Vergleichsbasis. ' +\n 'Die konkreten Median-€-Werte dürfen in deiner Antwort genannt werden, denn sie sind Liftaro-Marktdaten. ' +\n 'Wenn eine Angebots-Position NICHT in der Liste steht, gib in deiner JSON-Antwort ein Feld ' +\n '\"positions_nicht_in_liste\": [{titel, betrag_eur}] mit den entsprechenden Positionen zurück — ' +\n 'das Backend schätzt dafür einen Fallback-Wert.';\n systemPrompt = systemPrompt + preisrefBlock;\n }\n }\n\n const anthropic = new Anthropic({ apiKey: Deno.env.get(\"ANTHROPIC_KEY\") });\n const t0 = Date.now();\n\n const isPdf = file.mime === \"application/pdf\";\n const userContent: any[] = [\n {\n type: isPdf ? \"document\" : \"image\",\n source: { type: \"base64\", media_type: file.mime, data: file.base64 },\n },\n { type: \"text\", text: \"Prüfe das beigefügte Dokument gemäß den Vorgaben und antworte ausschließlich mit dem geforderten JSON. Falls im Dokument eine Objekt-, Liegenschafts- oder Gebäudeadresse erkennbar ist (z.B. 'Beispielstr. 12, 55116 Mainz'), gib sie zusätzlich als Top-Level-Feld 'objekt_adresse' (String, Format: 'Straße Hausnr., PLZ Ort') zurück. Wenn nicht eindeutig erkennbar, setze 'objekt_adresse' auf einen leeren String.\" },\n ];\n\n const response = await anthropic.messages.create({\n model: MODEL,\n max_tokens: 4096, // Erhöht von 2048 — komplexe Tabellen brauchen mehr Output-Spielraum\n system: systemPrompt,\n messages: [{ role: \"user\", content: userContent }],\n });\n\n const duration_ms = Date.now() - t0;\n const tokens_in = response.usage.input_tokens;\n const tokens_out = response.usage.output_tokens;\n const cost_eur = ((tokens_in * COST_PER_M_INPUT_TOKENS + tokens_out * COST_PER_M_OUTPUT_TOKENS) / 1_000_000) * USD_TO_EUR;\n\n const textBlock = response.content.find((c: any) => c.type === \"text\");\n const rawText = textBlock?.text || \"{}\";\n const cleaned = rawText.replace(/^```json\\s*|\\s*```$/g, \"\").trim();\n let result: any;\n try { result = JSON.parse(cleaned); }\n catch { return jsonResp({ error: \"KI-Antwort konnte nicht geparst werden\", raw: rawText }, 500, corsHeaders); }\n\n const checkNr = await generateCheckNr();\n result.check_nr = checkNr;\n\n await saveToAirtable({\n check_nr: checkNr,\n check_type,\n role,\n lead,\n result,\n file_name: file.name,\n cost_eur,\n tokens_in,\n tokens_out,\n model: MODEL,\n duration_ms,\n });\n\n let savingsTotal = Number(result.savings_total_eur || result.savings_estimate_eur || 0);\n const meaPool = Number(result.mea_pool_total || 0);\n const meaEigentuemer = Number(result.mea_eigentuemer || 0);\n\n if (check_type === 'nebenkosten') {\n const aufzugCount = aufzugCountUser;\n result.aufzug_count = aufzugCount; // Im Response konsistent halten\n let aufzugBrutto = 0;\n let bruttoSource = 'unknown'; // 'user' | 'ki' | 'regex' — für Transparenz\n\n if (wartungBruttoUser > 0) {\n aufzugBrutto = wartungBruttoUser;\n bruttoSource = 'user';\n if (!result.anonymized_data) result.anonymized_data = {};\n result.anonymized_data.betrag_aufzug_brutto = aufzugBrutto;\n console.log('[liftaro-vorabcheck] brutto vom User:', aufzugBrutto);\n } else {\n aufzugBrutto = Number(result.anonymized_data?.betrag_aufzug_brutto || 0);\n if (aufzugBrutto >= 500) bruttoSource = 'ki';\n\n if (!aufzugBrutto || aufzugBrutto < 500) {\n const haystack = String(result.summary || '') + ' ' +\n (result.findings || []).map(f => (f.title||'') + ' ' + (f.description||'')).join(' ');\n const matches = [...haystack.matchAll(/aufzug[a-zäöü\\s\\-/]*wartung[^0-9]{0,40}(\\d{1,3}(?:\\.\\d{3})*(?:,\\d{2})?|\\d{4,6}(?:,\\d{2})?)\\s*(?:€|eur)/gi)];\n if (matches.length) {\n const candidates = matches.map(m => parseFloat(m[1].replace(/\\./g, '').replace(',', '.'))).filter(n => n > 500);\n if (candidates.length) {\n aufzugBrutto = Math.max(...candidates);\n bruttoSource = 'regex';\n console.log('[liftaro-vorabcheck] brutto via Regex aus Klartext:', aufzugBrutto);\n }\n }\n }\n }\n\n const proAnlage = aufzugCount > 0 ? aufzugBrutto / aufzugCount : 0;\n\n if (proAnlage > 1200) {\n const correctTotal = Math.round((proAnlage - 980) * aufzugCount);\n const proAnlageStr = Math.round(proAnlage).toLocaleString('de-DE');\n const diffStr = Math.round(proAnlage - 980).toLocaleString('de-DE');\n const pctSavings = aufzugBrutto > 0 ? Math.round((correctTotal / aufzugBrutto) * 100) : 0;\n\n savingsTotal = correctTotal;\n result.savings_text = 'rund ' + pctSavings + ' % der bisherigen Wartungskosten durch marktgerechte Neuausschreibung';\n\n const summaryHasMarketClaim = /markt|median/i.test(String(result.summary || ''));\n const summaryIsConsistent = summaryHasMarketClaim && /über|ueber|deutlich|teuer/i.test(String(result.summary || ''));\n if (!summaryIsConsistent) {\n result.summary = 'Ihre Wartung kostet ' + proAnlageStr + ' € pro Jahr je Aufzug — das ist rund ' + diffStr + ' € mehr als der übliche Marktpreis für Wartung und Notruf. Optimierungspotenzial vorhanden.';\n }\n if (result.summary) {\n result.summary = String(result.summary).replace(/\\bvon\\s+9\\s?80\\s*(€|EUR)\\b/gi, '').replace(/\$?\\b9\\s?80\\s*(€|EUR)\\b\$?/gi, '').replace(/\\s{2,}/g, ' ').trim();\n }\n if (result.savings_text) {\n result.savings_text = String(result.savings_text).replace(/\\bvon\\s+9\\s?80\\s*(€|EUR)\\b/gi, '').replace(/\$?\\b9\\s?80\\s*(€|EUR)\\b\$?/gi, '').replace(/\\s{2,}/g, ' ').trim();\n }\n\n let findings = result.findings || [];\n findings = findings.filter(f => !/markt|wartung.*(zu\\s+(teuer|hoch)|ueber|über)|optimierung.*?wartung/i.test((f.title||'') + ' ' + (f.description||'')));\n findings.unshift({\n severity: proAnlage > 1800 ? 'warn' : (proAnlage > 1500 ? 'amber' : 'blue'),\n title: 'Wartung teurer als üblich',\n description: 'Die Wartung kostet ' + proAnlageStr + ' € pro Jahr je Aufzug — rund ' + diffStr + ' € mehr als der übliche Marktpreis. Bei einer Neuausschreibung zu marktüblichen Konditionen sparen Sie ' + correctTotal.toLocaleString('de-DE') + ' € pro Jahr.',\n tag: 'Liftaro-Marktreferenz · aktuell ' + proAnlageStr + ' EUR/Jahr',\n });\n\n result.findings = findings;\n\n if ((result.ampel === 'gruen' || result.ampel === 'grün') && proAnlage > 1500) {\n result.ampel = 'gelb';\n }\n\n console.log('[liftaro-vorabcheck] Markt-Override: brutto=' + aufzugBrutto + ', anlagen=' + aufzugCount + ', proAnlage=' + proAnlage + ', diff=' + diffStr + ', ersparnis=' + correctTotal);\n }\n\n if (role === 'eigentuemer' || role === 'verwalter') {\n const findings = result.findings || [];\n const hasRepairHint = findings.some(f => /reparatur.*(8\\.?000|einsparen|liftaro.*pr[üu]f|zus[äa]tzlich)/i.test((f.title||'') + ' ' + (f.description||'')));\n if (!hasRepairHint) {\n findings.push({\n severity: 'blue',\n title: 'Zusätzliches Sparpotenzial bei Reparaturen',\n description: 'Diese Schätzung berücksichtigt nur Wartung und Notruf. Unterjährige Reparaturen sind nicht eingerechnet — gerade dort steckt oft das größte Potenzial. Durch regelmäßige Überprüfung der Reparatur-Rechnungen durch Liftaro lassen sich im Einzelfall bis zu 8.000 € zusätzlich einsparen.',\n tag: 'Reparatur-Prüfung · Liftaro-Service',\n });\n result.findings = findings;\n }\n }\n }\n\n if (check_type === 'angebot') {\n const angebotsumme = Number(result.anonymized_data?.angebotssumme_brutto || result.anonymized_data?.angebotssumme_netto || 0);\n const positionsLeer = !Array.isArray(result.positions_nicht_in_liste) ? 0 : result.positions_nicht_in_liste.length;\n if (!savingsTotal && angebotsumme > 100) {\n const factor = deterministicSavingsFactor(checkNr);\n savingsTotal = Math.round(angebotsumme * factor);\n result.savings_total_eur = savingsTotal;\n result.savings_text = 'rund ' + Math.round(factor * 100) + ' % der Angebotssumme — Schätzwert ohne konkrete Preisliste';\n const findings = result.findings || [];\n findings.push({\n severity: 'amber',\n title: 'Schätzwert ohne Preislisten-Treffer',\n description: 'Keine Angebots-Position fand einen direkten Treffer in der Liftaro-Preisliste. Der ausgewiesene Ersparnis-Wert ist ein Schätzwert (zwischen 30–60 % der Angebotssumme, deterministisch aus der Check-Nr).',\n tag: 'Schätzwert · Preisliste-Lücke',\n });\n result.findings = findings;\n } else if (positionsLeer && savingsTotal) {\n const findings = result.findings || [];\n findings.push({\n severity: 'blue',\n title: 'Positionen ohne Preislisten-Referenz',\n description: positionsLeer + ' Angebots-Position(en) konnten nicht direkt gegen die Liftaro-Preisliste verglichen werden — diese Werte sind grobe Marktschätzungen.',\n tag: 'Preisliste-Lücke',\n });\n result.findings = findings;\n }\n\n if (role === 'eigentuemer' || role === 'verwalter') {\n const findings = result.findings || [];\n const hasRepairHint = findings.some(f => /reparatur.*(8\\.?000|einsparen|liftaro.*pr[üu]f|zus[äa]tzlich)/i.test((f.title||'') + ' ' + (f.description||'')));\n if (!hasRepairHint) {\n findings.push({\n severity: 'blue',\n title: 'Zusätzliches Sparpotenzial bei Reparaturen',\n description: 'Diese Schätzung berücksichtigt nur Wartung und Notruf. Unterjährige Reparaturen sind nicht eingerechnet — gerade dort steckt oft das größte Potenzial. Durch regelmäßige Überprüfung der Reparatur-Rechnungen durch Liftaro lassen sich im Einzelfall bis zu 8.000 € zusätzlich einsparen.',\n tag: 'Reparatur-Prüfung · Liftaro-Service',\n });\n result.findings = findings;\n }\n }\n }\n\n let savingsIndividual = Number(result.savings_individual_eur || 0);\n if (!savingsIndividual && savingsTotal > 0 && meaPool > 0 && meaEigentuemer > 0) {\n savingsIndividual = Math.round(savingsTotal * meaEigentuemer / meaPool);\n }\n\n if (lead?.email) {\n const fullName = ((lead.vorname || '') + ' ' + (lead.nachname || '')).trim() || lead.email;\n const roleLabel = role === 'eigentuemer' ? 'Eigentümer'\n : role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const checkTypeLabel = check_type === 'nebenkosten' ? 'Nebenkostenabrechnung'\n : check_type === 'angebot' ? 'Angebot'\n : 'Wartungsvertrag';\n const ampelLabel = result.ampel === 'rot' ? '🔴 Rot' : result.ampel === 'gelb' ? '🟡 Gelb' : result.ampel === 'gruen' ? '🟢 Grün' : '–';\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const noteLines = [\n '✅ ANALYSE ' + checkNr,\n '', 'Rolle: ' + roleLabel, 'Check-Typ: ' + checkTypeLabel, 'Ampel: ' + ampelLabel,\n savingsTotal ? 'Ersparnis Haus: ' + fmt(savingsTotal) + ' €/Jahr' : '',\n savingsIndividual ? 'Anteil indiv.: ' + fmt(savingsIndividual) + ' €/Jahr' : '',\n 'Adresse: ' + (lead.adresse || '–'), '',\n '— Zusammenfassung —', result.summary || '(keine)',\n ].filter(Boolean);\n const title = '[Vorabcheck] ' + fullName + ' — ' + roleLabel + ' (' + checkNr + ')';\n upsertPipedriveLead({ name: fullName, email: lead.email, phone: lead.telefon || undefined, title, note: noteLines.join('\\n') })\n .then(async (pd: any) => {\n if (!pd.ok || !pd.lead_id) return;\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return;\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + checkNr + \"'\"),\n { headers: { Authorization: 'Bearer ' + k } });\n const rec = (await fr.json())?.records?.[0]?.id;\n if (!rec) return;\n await fetch('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + rec, {\n method: 'PATCH', headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify({ fields: { pipedrive_lead_id: pd.lead_id, pipedrive_person_id: String(pd.person_id || '') } }),\n });\n } catch (e) { /* */ }\n }).catch(e => console.warn('[Pipedrive] Vorabcheck failed:', e?.message || e));\n }\n\n const aufzugPositionen = Array.isArray(result.aufzug_positionen)\n ? result.aufzug_positionen\n .filter((p: any) => p && (p.text || p.betrag_eur))\n .map((p: any) => ({ text: String(p.text || '').trim(), betrag_eur: Number(p.betrag_eur || 0) }))\n : [];\n let aufzugGesamtkosten = Number(result.aufzug_gesamtkosten_eur || 0);\n if (!aufzugGesamtkosten && aufzugPositionen.length) {\n aufzugGesamtkosten = aufzugPositionen.reduce((s, p) => s + (Number(p.betrag_eur) || 0), 0);\n }\n\n return jsonResp({\n ampel: result.ampel,\n summary: result.summary,\n findings: result.findings || [],\n aufzug_count: aufzugCountUser,\n aufzug_positionen: aufzugPositionen,\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n wartung_brutto_used: Number(result.anonymized_data?.betrag_aufzug_brutto || wartungBruttoUser || 0),\n wartung_brutto_source: wartungBruttoUser > 0 ? 'user' : 'ki', // Transparenz: woher kam der Wartungs-Wert?\n verteilerschluessel: String(result.verteilerschluessel || 'unbekannt'),\n parteien_count: Number(result.parteien_count || 0),\n mea_pool_total: meaPool,\n mea_eigentuemer: meaEigentuemer,\n savings_total_eur: savingsTotal,\n savings_individual_eur: savingsIndividual,\n savings_estimate_eur: savingsTotal, // Legacy für altes Frontend\n savings_text: result.savings_text || \"\",\n check_nr: checkNr,\n role: role,\n objekt_adresse: String(result.objekt_adresse || result.anonymized_data?.objekt_adresse || result.anonymized_data?.gebaeude_adresse || result.anonymized_data?.liegenschaft_adresse || '').trim(),\n }, 200, corsHeaders);\n\n } catch (e: any) {\n console.error(\"[liftaro-vorabcheck]\", e);\n return jsonResp({ error: e.message || \"Server-Fehler\" }, 500, corsHeaders);\n }\n}\n\nfunction jsonResp(body: any, status: number, headers: Record) {\n return new Response(JSON.stringify(body), {\n status,\n headers: { ...headers, \"Content-Type\": \"application/json\" },\n });\n}\n\nasync function verifyTurnstile(token: string, secret: string): Promise {\n const res = await fetch(\"https://challenges.cloudflare.com/turnstile/v0/siteverify\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: `secret=${encodeURIComponent(secret)}&response=${encodeURIComponent(token)}`,\n });\n const json = await res.json();\n return !!json.success;\n}\n\nasync function generateCheckNr(): Promise {\n const year = new Date().getFullYear();\n const random = Math.floor(Math.random() * 9000) + 1000;\n return `VC-${year}-${random}`;\n}\n\nasync function saveToAirtable(data: {\n check_nr: string;\n check_type: string;\n role: string;\n lead: any;\n result: any;\n file_name: string;\n cost_eur: number;\n tokens_in: number;\n tokens_out: number;\n model: string;\n duration_ms: number;\n}) {\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { console.warn(\"Airtable-Keys fehlen — überspringe Persistenz\"); return; }\n const at = `https://api.airtable.com/v0/${base}`;\n const headers = { \"Authorization\": `Bearer ${key}`, \"Content-Type\": \"application/json\" };\n\n async function atPostSafe(tableUrl: string, fieldsIn: Record) {\n const fields = { ...fieldsIn };\n for (let i = 0; i < 20; i++) {\n try {\n const r = await fetch(tableUrl, { method: 'POST', headers, body: JSON.stringify({ fields }) });\n if (r.ok) return;\n const txt = await r.text();\n let badField = '';\n try {\n const j = JSON.parse(txt);\n const msg = j?.error?.message || j?.error || '';\n const m = String(msg).match(/Unknown field name:\\s*\"([^\"]+)\"/i);\n if (m) badField = m[1];\n } catch (_) { /* nicht JSON */ }\n if (badField && Object.prototype.hasOwnProperty.call(fields, badField)) {\n delete fields[badField];\n console.warn('[Airtable] retry ohne unbekanntes Feld:', badField);\n continue;\n }\n console.warn('[Airtable]', tableUrl.slice(-30), 'POST fehlgeschlagen:', txt.slice(0, 200));\n return;\n } catch (e: any) { console.warn('[Airtable]', tableUrl, e.message); return; }\n }\n }\n\n const totalEur = Number(data.result.savings_total_eur || data.result.savings_estimate_eur || 0);\n const indivEur = Number(data.result.savings_individual_eur || 0);\n\n await atPostSafe(`${at}/Vorabcheck-Leads`, {\n check_nr: data.check_nr,\n check_type: data.check_type,\n role: data.role,\n vorname: data.lead.vorname,\n nachname: data.lead.nachname,\n email: data.lead.email,\n telefon: data.lead.telefon || \"\",\n adresse: data.lead.adresse,\n file_name: data.file_name,\n savedAt: new Date().toISOString(),\n });\n\n const aufzugPositionen = Array.isArray(data.result.aufzug_positionen) ? data.result.aufzug_positionen : [];\n const aufzugPositionenText = aufzugPositionen\n .map((p: any) => (p.text || '') + ': ' + (Number(p.betrag_eur || 0).toLocaleString('de-DE', { minimumFractionDigits: 2, maximumFractionDigits: 2 })) + ' €')\n .join('\\n');\n let aufzugGesamtkosten = Number(data.result.aufzug_gesamtkosten_eur || 0);\n if (!aufzugGesamtkosten && aufzugPositionen.length) {\n aufzugGesamtkosten = aufzugPositionen.reduce((s: number, p: any) => s + (Number(p.betrag_eur) || 0), 0);\n }\n const aufzugCount = Number(data.result.aufzug_count || 0);\n const kostenProAufzugEur = aufzugCount > 0\n ? Math.round((aufzugGesamtkosten / aufzugCount) * 100) / 100\n : 0;\n const objektAdresse = String(\n data.result.objekt_adresse ||\n data.result.anonymized_data?.objekt_adresse ||\n data.result.anonymized_data?.gebaeude_adresse ||\n data.result.anonymized_data?.liegenschaft_adresse ||\n data.lead?.adresse || ''\n ).trim();\n\n await atPostSafe(`${at}/Vorab-Checks`, {\n check_nr: data.check_nr,\n check_type: data.check_type,\n role: data.role,\n ampel: data.result.ampel,\n summary: data.result.summary,\n savings_estimate_eur: totalEur,\n savings_total_eur: totalEur,\n savings_individual_eur: indivEur,\n aufzug_count: aufzugCount,\n parteien_count: Number(data.result.parteien_count || 0),\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n kosten_pro_aufzug_eur: kostenProAufzugEur,\n aufzug_positionen_text: aufzugPositionenText,\n aufzug_positionen_json: JSON.stringify(aufzugPositionen),\n objekt_adresse: objektAdresse,\n findings_json: JSON.stringify(data.result.findings || []),\n anonymized_data_json: JSON.stringify(data.result.anonymized_data || {}),\n savedAt: new Date().toISOString(),\n });\n\n await atPostSafe(`${at}/API-Cost-Log`, {\n check_nr: data.check_nr,\n endpoint: \"vorabcheck\",\n model: data.model,\n tokens_in: data.tokens_in,\n tokens_out: data.tokens_out,\n cost_eur: Math.round(data.cost_eur * 10000) / 10000,\n duration_ms: data.duration_ms,\n savedAt: new Date().toISOString(),\n });\n}\n","\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.30.0\";\nimport { ROLE_CONTEXTS, DEFAULT_SYSTEM_PROMPTS } from \"https://check.liftaro.de/vorabcheck/prompts.js?v=3\";\nimport { VORABCHECK_TARGET_FIELDS, handleUploadVorabcheckPdf, handleSubmitOwnerSelfServe } from \"https://check.liftaro.de/vorabcheck/backend-extras.js?v=7\";\n\nconst MODEL = \"claude-sonnet-4-6\"; // Upgrade von 4.5 → 4.6 für besseres Vision-Verständnis bei Tabellen\nconst COST_PER_M_INPUT_TOKENS = 3.0; // $ pro 1M Input-Tokens (Sonnet 4.6 — Preise ähnlich 4.5)\nconst COST_PER_M_OUTPUT_TOKENS = 15.0; // $ pro 1M Output-Tokens\nconst USD_TO_EUR = 0.92;\n\nlet _promptCache: Record | null = null;\nlet _promptCacheTs = 0;\nconst PROMPT_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function atPatchRetry(url: string, k: string, fields: any, max = 15): Promise<{ ok: boolean, error?: string }> {\n const headers = { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' };\n let a = 0;\n while (a++ < max) {\n const r = await fetch(url, { method: 'PATCH', headers, body: JSON.stringify({ fields }) });\n if (r.ok) return { ok: true };\n const txt = await r.text();\n let bad = '';\n try {\n const j = JSON.parse(txt);\n const m = String(j?.error?.message || j?.error || '').match(/Unknown field name:\\s*\"([^\"]+)\"/i);\n if (m) bad = m[1];\n } catch (_) {}\n if (bad && Object.prototype.hasOwnProperty.call(fields, bad)) { delete fields[bad]; continue; }\n return { ok: false, error: txt.slice(0, 200) };\n }\n return { ok: false, error: 'too many retries' };\n}\n\nasync function loadCustomPrompts(): Promise> {\n if (_promptCache && Date.now() - _promptCacheTs < PROMPT_CACHE_TTL_MS) return _promptCache;\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { _promptCache = {}; _promptCacheTs = Date.now(); return _promptCache; }\n try {\n const res = await fetch(`https://api.airtable.com/v0/${base}/Vorabcheck-Prompts`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(\"HTTP \" + res.status);\n const data = await res.json();\n const map: Record = {};\n (data.records || []).forEach((r: any) => {\n const t = r.fields?.check_type;\n const p = r.fields?.system_prompt;\n if (t && p && p.trim().length > 50) map[t] = p;\n });\n _promptCache = map;\n _promptCacheTs = Date.now();\n return map;\n } catch (e) {\n console.warn(\"loadCustomPrompts:\", e);\n return _promptCache || {};\n }\n}\n\nconst PIPEDRIVE_MASTER_BASE = 'appzhNrhkLSTEaNFW';\nconst PIPEDRIVE_PROJECT_ID = 'p_1777239396379';\nlet _pdCache: { domain: string, token: string } | null = null;\nlet _pdCacheTs = 0;\nconst PD_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function loadPipedriveConfig(): Promise<{ domain: string, token: string } | null> {\n if (_pdCache && Date.now() - _pdCacheTs < PD_CACHE_TTL_MS) return _pdCache;\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n if (!atKey) { _pdCacheTs = Date.now(); return null; }\n try {\n const url = 'https://api.airtable.com/v0/' + PIPEDRIVE_MASTER_BASE + '/Keys?filterByFormula=' +\n encodeURIComponent(\"AND({project_id}='\" + PIPEDRIVE_PROJECT_ID + \"',OR({key_name}='pipedriveDomain',{key_name}='pipedriveApiToken'))\");\n const res = await fetch(url, { headers: { Authorization: 'Bearer ' + atKey } });\n if (!res.ok) throw new Error('HTTP ' + res.status);\n const data = await res.json();\n let domain = '', token = '';\n (data.records || []).forEach((r: any) => {\n if (r.fields?.key_name === 'pipedriveDomain') domain = String(r.fields.key_value || '').trim();\n if (r.fields?.key_name === 'pipedriveApiToken') token = String(r.fields.key_value || '').trim();\n });\n _pdCacheTs = Date.now();\n if (!domain || !token) { _pdCache = null; return null; }\n _pdCache = { domain: domain.replace(/^https?:\\/\\//, '').replace(/\\/$/, ''), token };\n return _pdCache;\n } catch (e) {\n console.warn('[Pipedrive] loadPipedriveConfig:', e);\n return null;\n }\n}\n\nasync function createPipedriveLead(input: {\n name: string;\n email?: string;\n phone?: string;\n org?: string;\n title: string;\n note: string;\n}): Promise<{ ok: boolean; lead_id?: string; person_id?: number; reused?: boolean; error?: string }> {\n return upsertPipedriveLead(input);\n}\n\nasync function upsertPipedriveLead(input: {\n name: string;\n email?: string;\n phone?: string;\n org?: string;\n title: string;\n note: string;\n}): Promise<{ ok: boolean; lead_id?: string; person_id?: number; reused?: boolean; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n let personId: number | null = null;\n let personExisted = false;\n\n if (input.email) {\n try {\n const searchUrl = base + '/persons/search?fields=email&exact_match=true&limit=5&term=' +\n encodeURIComponent(input.email) + '&api_token=' + encodeURIComponent(cfg.token);\n const sr = await fetch(searchUrl);\n const sd = await sr.json();\n if (sd?.success && sd.data?.items?.length) {\n personId = sd.data.items[0].item?.id || null;\n if (personId) personExisted = true;\n }\n } catch (e) { }\n }\n\n if (!personId) {\n const personBody: any = { name: input.name || 'Anonym' };\n if (input.email) personBody.email = [{ value: input.email, primary: true, label: 'work' }];\n if (input.phone) personBody.phone = [{ value: input.phone, primary: true, label: 'work' }];\n const personRes = await fetch(base + '/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(personBody),\n });\n const personData = await personRes.json();\n if (!personData.success) {\n return { ok: false, error: 'Person: ' + JSON.stringify(personData.error || personData).slice(0, 200) };\n }\n personId = personData.data.id;\n }\n\n let orgId: number | null = null;\n if (input.org && input.org.trim() && !personExisted) {\n try {\n const orgRes = await fetch(base + '/organizations' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ name: input.org.trim() }),\n });\n const orgData = await orgRes.json();\n if (orgData.success) orgId = orgData.data.id;\n } catch (e) { }\n }\n\n let leadId: string | null = null;\n let leadReused = false;\n try {\n const leadsUrl = base + '/leads?person_id=' + personId + '&archived_status=not_archived&limit=20&api_token=' + encodeURIComponent(cfg.token);\n const lr = await fetch(leadsUrl);\n const ld = await lr.json();\n if (ld?.success && Array.isArray(ld.data) && ld.data.length > 0) {\n const sorted = ld.data.slice().sort((a: any, b: any) =>\n String(b.add_time || '').localeCompare(String(a.add_time || ''))\n );\n leadId = sorted[0].id;\n leadReused = true;\n }\n } catch (e) { }\n\n if (!leadId) {\n const leadBody: any = { title: input.title, person_id: personId };\n if (orgId) leadBody.organization_id = orgId;\n const leadRes = await fetch(base + '/leads' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(leadBody),\n });\n const leadData = await leadRes.json();\n if (!leadData.success) {\n return { ok: false, error: 'Lead: ' + JSON.stringify(leadData.error || leadData).slice(0, 200), person_id: personId };\n }\n leadId = leadData.data.id;\n }\n\n if (input.note) {\n try {\n const stamp = new Date().toISOString().replace('T', ' ').slice(0, 16) + ' UTC';\n const noteWithStamp = '🕒 ' + stamp + '\\n\\n' + input.note;\n await fetch(base + '/notes' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteWithStamp, lead_id: leadId }),\n });\n } catch (e) { }\n }\n\n console.log('[Pipedrive] ' + (leadReused ? 'Lead reused' : 'Lead created') + ':', leadId,\n 'person=' + personId + (personExisted ? ' (existed)' : ' (new)'));\n return { ok: true, lead_id: leadId, person_id: personId, reused: leadReused };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nconst HV_GENERIC_EMAIL_PREFIXES = [\n 'info', 'kontakt', 'service', 'mail', 'office',\n 'verwaltung', 'hausverwaltung', 'team', 'kundenservice',\n 'support', 'anfrage', 'post', 'zentrale', 'verwalter',\n 'buero', 'hello', 'welcome', 'empfang', 'sekretariat',\n 'wohnen', 'immobilien',\n];\n\nfunction isGenericHvEmail(email: string): boolean {\n if (!email || typeof email !== 'string') return false;\n const e = email.trim().toLowerCase();\n if (!/^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/.test(e)) return false;\n const local = e.split('@')[0];\n return HV_GENERIC_EMAIL_PREFIXES.includes(local);\n}\n\nfunction pickGenericEmailFromPersons(persons: any[]): string | null {\n if (!Array.isArray(persons) || !persons.length) return null;\n for (const p of persons) {\n const emails = Array.isArray(p?.email) ? p.email : [];\n for (const e of emails) {\n const val = String(e?.value || '').trim();\n if (isGenericHvEmail(val)) return val;\n }\n }\n return null;\n}\n\nasync function findPipedriveOrgsByName(name: string, limit = 3): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return [];\n const term = String(name || '').trim();\n if (term.length < 3) return [];\n const termLow = term.toLowerCase();\n const base = 'https://' + cfg.domain + '/api/v1';\n try {\n const url = base + '/organizations/search?term=' + encodeURIComponent(term) +\n '&fields=name&exact_match=false&limit=10&api_token=' + encodeURIComponent(cfg.token);\n const r = await fetch(url);\n const d = await r.json();\n if (!d?.success || !d.data?.items?.length) return [];\n const filtered = d.data.items\n .map((it: any) => ({\n item: it.item,\n score: Number(it.result_score || 0),\n }))\n .filter((x: any) => {\n if (!x.item || !x.item.name) return false;\n const nameLow = String(x.item.name).toLowerCase();\n if (!nameLow.includes(termLow)) return false;\n return x.score >= 0.3 || term.length >= 5; // bei längerem Term Score-Toleranz lockern\n })\n .sort((a: any, b: any) => b.score - a.score)\n .slice(0, limit)\n .map((x: any) => x.item);\n return filtered;\n } catch (e) { console.warn('[Pipedrive] findOrgsByName:', e); return []; }\n}\n\nasync function findPipedriveOrgByName(name: string): Promise {\n const hits = await findPipedriveOrgsByName(name, 1);\n return hits.length ? hits[0] : null;\n}\n\nasync function getOrgGenericEmail(orgId: number): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg || !orgId) return null;\n const base = 'https://' + cfg.domain + '/api/v1';\n try {\n const url = base + '/organizations/' + orgId + '/persons?api_token=' + encodeURIComponent(cfg.token);\n const r = await fetch(url);\n const d = await r.json();\n if (!d?.success || !Array.isArray(d.data)) return null;\n return pickGenericEmailFromPersons(d.data);\n } catch (e) { console.warn('[Pipedrive] getOrgGenericEmail:', e); return null; }\n}\n\nasync function createPipedriveOrgWithEmail(input: {\n name: string;\n email?: string;\n website?: string;\n city?: string;\n source?: string; // 'manuell' | 'ki_serper' | 'user_verifiziert'\n}): Promise<{ ok: boolean; org_id?: number; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const orgBody: any = { name: input.name };\n if (input.city) orgBody.address = input.city;\n const orgRes = await fetch(base + '/organizations' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(orgBody),\n });\n const orgData = await orgRes.json();\n if (!orgData.success) return { ok: false, error: 'Org-Create: ' + JSON.stringify(orgData.error || {}).slice(0, 200) };\n const orgId = orgData.data.id;\n if (input.email && isGenericHvEmail(input.email)) {\n const personBody: any = {\n name: input.name + ' (Allgemein)',\n email: [{ value: input.email, primary: true, label: 'work' }],\n org_id: orgId,\n };\n await fetch(base + '/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(personBody),\n }).catch(() => { });\n }\n return { ok: true, org_id: orgId };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nasync function linkPersonToOrg(personId: number, orgId: number): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg || !personId || !orgId) return false;\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const r = await fetch(base + '/persons/' + personId + auth, {\n method: 'PUT',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ org_id: orgId }),\n });\n const d = await r.json();\n return !!d?.success;\n } catch (e) { console.warn('[Pipedrive] linkPersonToOrg:', e); return false; }\n}\n\nasync function createHvLead(input: {\n orgId: number;\n userFullName: string;\n userEmail?: string;\n savingsTotal?: number;\n checkNr: string;\n role: string;\n hvName: string;\n}): Promise<{ ok: boolean; lead_id?: string; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n let leadId: string | null = null;\n let reused = false;\n try {\n const lr = await fetch(base + '/leads?organization_id=' + input.orgId +\n '&archived_status=not_archived&limit=20&api_token=' + encodeURIComponent(cfg.token));\n const ld = await lr.json();\n if (ld?.success && Array.isArray(ld.data) && ld.data.length > 0) {\n const sorted = ld.data.slice().sort((a: any, b: any) =>\n String(b.add_time || '').localeCompare(String(a.add_time || '')));\n leadId = sorted[0].id;\n reused = true;\n }\n } catch (e) { }\n\n if (!leadId) {\n const title = '[HV-Lead] ' + input.hvName + ' — via Vorabcheck ' + input.checkNr;\n const leadBody: any = { title, organization_id: input.orgId };\n const lr = await fetch(base + '/leads' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(leadBody),\n });\n const ld = await lr.json();\n if (!ld.success) return { ok: false, error: 'HV-Lead: ' + JSON.stringify(ld.error || {}).slice(0, 200) };\n leadId = ld.data.id;\n }\n\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const stamp = new Date().toISOString().replace('T', ' ').slice(0, 16) + ' UTC';\n const roleLabel = input.role === 'eigentuemer' ? 'Eigentümer'\n : input.role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const noteLines = [\n '🕒 ' + stamp, '', 'HV-Lead aus Liftaro-Vorabcheck',\n 'Check-Nr: ' + input.checkNr, 'Auftraggeber: ' + input.userFullName + ' (' + roleLabel + ')',\n input.userEmail ? 'E-Mail: ' + input.userEmail : '',\n input.savingsTotal ? 'Sparpotenzial: ' + fmt(input.savingsTotal) + ' €/Jahr' : '',\n '', 'Follow-up: Einsparungsberechnung + Light-Paket',\n ].filter(Boolean);\n try {\n await fetch(base + '/notes' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteLines.join('\\n'), lead_id: leadId }),\n });\n } catch (e) { }\n\n console.log('[Pipedrive] HV-Lead ' + (reused ? 'reused' : 'created') + ':', leadId, 'org=' + input.orgId);\n return { ok: true, lead_id: leadId };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nlet _preisrefCache: any[] | null = null;\nlet _preisrefCacheTs = 0;\nconst PREISREF_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function loadPreisreferenzen(): Promise {\n if (_preisrefCache && Date.now() - _preisrefCacheTs < PREISREF_CACHE_TTL_MS) return _preisrefCache;\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { _preisrefCache = []; _preisrefCacheTs = Date.now(); return []; }\n try {\n const res = await fetch(`https://api.airtable.com/v0/${base}/Preisreferenzen`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(\"HTTP \" + res.status);\n const data = await res.json();\n const list = (data.records || []).map((r: any) => ({\n position: r.fields?.position || '',\n einheit: r.fields?.einheit || '',\n median_eur: Number(r.fields?.median_eur || 0),\n region: r.fields?.region || '',\n notes: r.fields?.notes || '',\n })).filter((p: any) => p.position && p.median_eur > 0);\n _preisrefCache = list;\n _preisrefCacheTs = Date.now();\n return list;\n } catch (e) {\n console.warn(\"loadPreisreferenzen:\", e);\n return _preisrefCache || [];\n }\n}\n\nfunction deterministicSavingsFactor(seed: string): number {\n let h = 0;\n for (let i = 0; i < seed.length; i++) h = ((h << 5) - h + seed.charCodeAt(i)) | 0;\n return 0.30 + ((h >>> 0) % 1000) / 1000 * 0.30; // 0,30 – 0,60\n}\n\n\nfunction buildSystemPrompt(checkType: string, role: string, customMap: Record): string | null {\n if (customMap[checkType + '.' + role]) return customMap[checkType + '.' + role];\n if (customMap[checkType]) return customMap[checkType];\n\n const base = DEFAULT_SYSTEM_PROMPTS[checkType];\n if (!base) return null;\n const roleCtx = ROLE_CONTEXTS[role] || ROLE_CONTEXTS.mieter;\n return roleCtx + '\\n\\n────────────────────────────────────────\\n\\n' + base;\n}\n\n\nexport default async function (req: Request): Promise {\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n };\n if (req.method === \"OPTIONS\") return new Response(null, { headers: corsHeaders });\n if (req.method !== \"POST\") return jsonResp({ error: \"POST only\" }, 405, corsHeaders);\n\n try {\n const body = await req.json();\n\n if (body.action === 'contact') {\n const c = body.contact || {};\n const name = String(c.name || '').trim();\n const email = String(c.email || '').trim();\n if (!name || !email) return jsonResp({ ok: false, error: 'name und email sind Pflichtfelder' }, 400, corsHeaders);\n const firma = String(c.firma || '').trim();\n const telefon = String(c.telefon || '').trim();\n const paket = String(c.paket || 'andere').toLowerCase();\n const anzahl = parseInt(String(c.anzahl || '0'), 10) || 0;\n const nachricht = String(c.nachricht || '').trim();\n const paketLabel = paket === 'free' ? 'Free (50% Erfolgsbeteiligung)'\n : paket === 'light' ? 'Light (45 €/Monat je Aufzug)'\n : 'Andere / unklar';\n\n try {\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n const atBase = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (atKey && atBase) {\n await fetch('https://api.airtable.com/v0/' + atBase + '/Kontakt-Anfragen', {\n method: 'POST',\n headers: { Authorization: 'Bearer ' + atKey, 'Content-Type': 'application/json' },\n body: JSON.stringify({\n fields: {\n name, email,\n firma: firma || '',\n telefon: telefon || '',\n paket: paketLabel,\n anzahl_aufzuege: anzahl,\n nachricht: nachricht || '',\n savedAt: new Date().toISOString(),\n },\n }),\n });\n }\n } catch (e: any) { console.warn('[Kontakt] Airtable failed:', e.message); }\n\n const noteLines = [\n 'Quelle: Startseite Kontakt-Formular',\n 'Paket-Interesse: ' + paketLabel,\n anzahl ? 'Anzahl Aufzüge: ' + anzahl : 'Anzahl Aufzüge: –',\n 'Firma / Hausverwaltung: ' + (firma || '–'),\n 'Telefon: ' + (telefon || '–'),\n '',\n '— Nachricht —',\n nachricht || '(keine)',\n ];\n const pd = await createPipedriveLead({\n name,\n email,\n phone: telefon || undefined,\n org: firma || undefined,\n title: '[Inbound] ' + name + ' — ' + paketLabel + (anzahl ? ' (' + anzahl + ' Aufzug' + (anzahl === 1 ? '' : 'e') + ')' : ''),\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: pd }, 200, corsHeaders);\n }\n\n if (body.action === 'soft_capture') {\n const lead = body.lead || {};\n const ct = String(body.check_type || '').trim() || 'unbekannt';\n const fileMeta = body.file_meta || {};\n const name = ((String(lead.vorname || '').trim() + ' ' + String(lead.nachname || '').trim()).trim()) || 'Anonym';\n const email = String(lead.email || '').trim();\n const telefon = String(lead.telefon || '').trim();\n const adresse = String(lead.adresse || '').trim();\n const rolle = String(lead.rolle || '').trim();\n const firma = String(lead.firma || '').trim();\n if (!email) return jsonResp({ ok: false, error: 'email Pflicht' }, 400, corsHeaders);\n\n const noteLines = [\n '🟡 SOFT-LEAD — User hat Step 2 abgeschickt, Analyse läuft / könnte abbrechen',\n '',\n 'Quelle: Vorabcheck Public-Landing',\n 'Check-Typ: ' + ct,\n rolle ? 'Rolle: ' + rolle : '',\n adresse ? 'Adresse Objekt: ' + adresse : '',\n firma ? 'Firma: ' + firma : '',\n 'Telefon: ' + (telefon || '–'),\n fileMeta.name ? 'Hochgeladenes Dokument: ' + fileMeta.name : '',\n fileMeta.size ? 'Dateigröße: ' + Math.round(fileMeta.size / 1024) + ' KB' : '',\n ].filter(Boolean);\n\n const pd = await upsertPipedriveLead({\n name,\n email,\n phone: telefon || undefined,\n org: firma || undefined,\n title: '[Vorabcheck Start] ' + name + ' — ' + ct,\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: pd }, 200, corsHeaders);\n }\n\n if (body.action === 'request_liftaro_callback') {\n const c = body.cta || {};\n const userEmail = String(c.user_email || '').trim();\n const userName = String(c.user_name || '').trim() || userEmail || 'Anonym';\n const checkNr = String(c.check_nr || '').trim() || '—';\n const role = String(c.role || 'eigentuemer').trim();\n const savings = Number(c.savings_total_eur || 0);\n const hvName = String(c.hv_name || '').trim();\n if (!userEmail) return jsonResp({ ok: false, error: 'user_email Pflichtfeld' }, 400, corsHeaders);\n\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const roleLabel = role === 'eigentuemer' ? 'Eigentümer'\n : role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const noteLines = [\n '🔥 HOT-LEAD — User hat „Direktkontakt durch Liftaro\" angeklickt',\n '',\n 'User-Wunsch: Liftaro soll proaktiv binnen 24h kontaktieren.',\n '',\n 'Vorabcheck-Kontext:',\n ' Check-Nr: ' + checkNr,\n ' Rolle: ' + roleLabel,\n savings ? ' Sparpotenzial: ' + fmt(savings) + ' € / Jahr' : '',\n hvName ? ' Hausverwaltung (genannt): ' + hvName : ' Hausverwaltung: nicht angegeben',\n '',\n 'Empfehlung Vertrieb:',\n ' → Anruf oder persönliche Mail innerhalb 24h.',\n ' → Konkrete Einsparungsberechnung anbieten.',\n ' → Light-Paket-Pitch anschließen wenn passend.',\n ].filter(Boolean);\n\n const result = await upsertPipedriveLead({\n name: userName,\n email: userEmail,\n title: '🔥 [HOT] ' + userName + ' — wünscht Direktkontakt (' + checkNr + ')',\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: result }, 200, corsHeaders);\n }\n\n if (body.action === 'list_property_managers') {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return jsonResp({ ok: false, error: 'pipedrive not configured' }, 500, corsHeaders);\n const lim = Math.min(parseInt(String(body.limit || '500'), 10) || 500, 500);\n try {\n const r = await fetch('https://' + cfg.domain + '/api/v1/organizations?start=0&limit=' + lim +\n '&api_token=' + encodeURIComponent(cfg.token));\n const d = await r.json();\n const orgs = (Array.isArray(d.data) ? d.data : []).map((o: any) => ({\n org_id: o.id, name: o.name || '', address: o.address || '',\n person_count: Number(o.people_count || 0),\n }));\n return jsonResp({ ok: true, results: orgs }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'get_property_manager_details') {\n const oid = parseInt(String(body.org_id || '0'), 10);\n if (!oid) return jsonResp({ ok: false, error: 'org_id required' }, 400, corsHeaders);\n const cfg = await loadPipedriveConfig();\n if (!cfg) return jsonResp({ ok: false, error: 'pipedrive not configured' }, 500, corsHeaders);\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const oRes = await fetch('https://' + cfg.domain + '/api/v1/organizations/' + oid + auth);\n const oData = await oRes.json();\n if (!oData?.success) return jsonResp({ ok: false, error: 'org not found' }, 404, corsHeaders);\n const org = oData.data;\n const pRes = await fetch('https://' + cfg.domain + '/api/v1/organizations/' + oid + '/persons' + auth);\n const pData = await pRes.json();\n const persons = Array.isArray(pData?.data) ? pData.data : [];\n const genEmail = pickGenericEmailFromPersons(persons);\n let gfName = '', gfTel = '', gfEmail = '';\n const personalP = persons.find((p: any) => {\n const emails = Array.isArray(p?.email) ? p.email : [];\n return emails.some((e: any) => e?.value && !isGenericHvEmail(String(e.value)));\n });\n const firstP = personalP || persons[0];\n if (firstP) {\n gfName = String(firstP.name || '').replace(/\\s*\$Allgemein\$\\s*$/i, '').trim();\n gfEmail = String((Array.isArray(firstP.email) ? firstP.email : []).find((e: any) => e?.value)?.value || '');\n gfTel = String((Array.isArray(firstP.phone) ? firstP.phone : []).find((p: any) => p?.value)?.value || '');\n }\n let strasse = '', plz = '', ort = '';\n const addr = String(org.address || '').trim();\n if (addr) {\n const parts = addr.split(',').map((s: string) => s.trim()).filter(Boolean);\n if (parts.length >= 2) {\n strasse = parts[0];\n const m = parts[1].match(/^(\\d{4,5})\\s+(.+)$/);\n if (m) { plz = m[1]; ort = m[2]; } else ort = parts[1];\n } else { strasse = addr; }\n }\n return jsonResp({ ok: true, details: {\n org_id: org.id, firma: String(org.name || ''), gf: gfName,\n strasse, plz, ort, email: genEmail || gfEmail || '', tel: gfTel,\n } }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'get_verwalter_context') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const enc = encodeURIComponent(\"{check_nr}='\" + cn + \"'\");\n const [vr, lr] = await Promise.all([\n fetch('https://api.airtable.com/v0/' + b + '/Vorab-Checks?filterByFormula=' + enc + '&maxRecords=1',\n { headers: { Authorization: 'Bearer ' + k } }),\n fetch('https://api.airtable.com/v0/' + b + '/Vorabcheck-Leads?filterByFormula=' + enc + '&maxRecords=1',\n { headers: { Authorization: 'Bearer ' + k } }),\n ]);\n const vd = await vr.json(); const ld = await lr.json();\n const vc = vd?.records?.[0]?.fields;\n if (!vc) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const lead = ld?.records?.[0]?.fields || {};\n return jsonResp({ ok: true, ctx: {\n check_nr: cn,\n check_type: vc.check_type || '',\n ampel: vc.ampel || '',\n summary: vc.summary || '',\n savings_total_eur: Number(vc.savings_total_eur || vc.savings_estimate_eur || 0),\n savings_individual_eur: Number(vc.savings_individual_eur || 0),\n aufzug_count: Number(vc.aufzug_count || 0),\n parteien_count: Number(vc.parteien_count || 0),\n role: vc.role || '',\n eigentuemer_name: [lead.vorname, lead.nachname].filter(Boolean).join(' '),\n objekt_adresse: String(vc.objekt_adresse || lead.adresse || ''),\n hv_name: vc.hv_name || '',\n hv_email: vc.hv_email || '',\n hv_telefon: vc.hv_telefon || '',\n hv_adresse: vc.hv_adresse || '',\n hv_website: vc.hv_website || '',\n verwalter_status: vc.verwalter_status || 'offen',\n verwalter_name: vc.verwalter_name || '',\n verwalter_response_at: vc.verwalter_response_at || '',\n } }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'submit_verwalter_response') {\n const cn = String(body.check_nr || '').trim();\n const v = body.verwalter || {};\n const mode = String(body.mode || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n if (!v.name || !v.email) return jsonResp({ ok: false, error: 'name+email pflicht' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n verwalter_name: String(v.name || '').trim(),\n verwalter_email: String(v.email || '').trim(),\n verwalter_telefon: String(v.telefon || '').trim(),\n verwalter_response_mode: mode,\n verwalter_response_at: new Date().toISOString(),\n verwalter_status: 'antwort_erhalten',\n };\n const vFirma = String(v.firma || '').trim();\n if (vFirma) fields.verwalter_firma_name = vFirma;\n const vObj = String(v.objekt_adresse || '').trim();\n if (vObj) { fields.verwalter_objekt_adresse = vObj; fields.objekt_adresse = vObj; }\n if (body.responses) fields.verwalter_response_json = JSON.stringify(body.responses);\n if (mode === 'fragen' && body.responses && typeof body.responses === 'object') {\n const r: any = body.responses;\n if (r.anzahl_aufzuege) {\n const n = parseInt(String(r.anzahl_aufzuege), 10);\n if (n > 0 && n <= 50) fields.vertrag_anzahl_aufzuege = n;\n }\n if (r.wartungen) fields.vertrag_wartungen_pro_jahr = String(r.wartungen);\n if (r.vertragsart === 'voll') fields.vertrag_wartungstyp = 'Vollwartung';\n if (r.vertragsart === 'system') fields.vertrag_wartungstyp = 'Systemwartung';\n if (r.tuev_begl) fields.vertrag_tuev_begleitung = (r.tuev_begl === 'inkl');\n if (r.tuev_pruef) fields.vertrag_tuev_pruefung = (r.tuev_pruef === 'inkl');\n if (r.notruf) fields.vertrag_notruf = (r.notruf === 'inkl');\n fields.vertrag_extracted_at = new Date().toISOString();\n fields.vertrag_extracted_source = 'konfig';\n }\n if (body.pdf_base64 && body.pdf_base64.length > 100) {\n const fname = String(body.pdf_name || 'vertrag.pdf');\n try {\n const up = await fetch('https://content.airtable.com/v0/' + b + '/' + recId + '/verwalter_response_pdf/uploadAttachment', {\n method: 'POST', headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify({ contentType: String(body.pdf_mime || 'application/pdf'), filename: fname, file: body.pdf_base64 }),\n });\n if (!up.ok) fields.verwalter_response_pdf_name = fname + ' (Upload fehlgeschlagen)';\n } catch (e) { fields.verwalter_response_pdf_name = fname; }\n }\n await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 25);\n return jsonResp({ ok: true, applied_fields: Object.keys(fields) }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'set_bearbeiter_status') {\n const cn = String(body.check_nr || '').trim();\n const st = String(body.status || '').trim();\n const allowed = new Set(['offen', 'in_bearbeitung', 'erledigt']);\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n if (!allowed.has(st)) return jsonResp({ ok: false, error: 'status invalid' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n bearbeiter_status: st,\n bearbeiter_status_at: new Date().toISOString(),\n };\n if (body.bearbeiter_name) fields.bearbeiter_name = String(body.bearbeiter_name).trim();\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 10);\n return res.ok ? jsonResp({ ok: true, status: st }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'link_followup_check') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n linked_check_id: String(body.linked_check_id || '').trim(),\n linked_check_requestid: String(body.linked_check_requestid || '').trim(),\n linked_check_type: String(body.linked_check_type || '').trim(),\n linked_check_ersparnis: String(body.linked_check_ersparnis || '').trim(),\n linked_check_at: new Date().toISOString(),\n bearbeiter_status: 'in_bearbeitung',\n bearbeiter_status_at: new Date().toISOString(),\n };\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 15);\n return res.ok ? jsonResp({ ok: true, linked: fields.linked_check_requestid }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'sync_hv_pipedrive') {\n const hvName = String(body.hv_name || '').trim();\n if (!hvName) return jsonResp({ ok: false, error: 'hv_name pflicht' }, 400, corsHeaders);\n try {\n const ex = await findPipedriveOrgByName(hvName);\n if (ex?.id) return jsonResp({ ok: true, action: 'found', org_id: ex.id, org_name: ex.name || hvName }, 200, corsHeaders);\n const c = await createPipedriveOrgWithEmail({\n name: hvName,\n email: String(body.hv_email || '').trim() || undefined,\n city: String(body.hv_adresse || '').trim() || undefined,\n source: body.hv_adresse ? 'ki_web' : 'user_verifiziert',\n });\n if (!c.ok || !c.org_id) return jsonResp({ ok: false, error: 'create failed' }, 500, corsHeaders);\n try {\n const cfg = await loadPipedriveConfig();\n if (cfg && (body.check_nr || body.hv_telefon || body.hv_adresse)) {\n const note = 'Aus Liftaro-Vertragscheck' +\n (body.check_nr ? '\\nCheck-Nr: ' + body.check_nr : '') +\n (body.hv_telefon ? '\\nTel: ' + body.hv_telefon : '') +\n (body.hv_adresse ? '\\nAdresse: ' + body.hv_adresse : '');\n await fetch('https://' + cfg.domain + '/api/v1/notes?api_token=' + encodeURIComponent(cfg.token), {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: note, org_id: c.org_id }),\n }).catch(() => {});\n }\n } catch (_) {}\n return jsonResp({ ok: true, action: 'created', org_id: c.org_id }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'patch_objekt_adresse') {\n const cn = String(body.check_nr || '').trim();\n const addr = String(body.objekt_adresse || '').trim();\n if (!cn || !addr) return jsonResp({ ok: false, error: 'check_nr + objekt_adresse erforderlich' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, { objekt_adresse: addr });\n return res.ok ? jsonResp({ ok: true }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'enrich_property_manager') {\n const name = String(body.name || '').trim();\n const city = String(body.city || '').trim();\n if (!name) return jsonResp({ ok: false, error: 'name required' }, 400, corsHeaders);\n let serperKey = String(Deno.env.get(\"SERPER_API_KEY\") || '').trim();\n if (!serperKey) {\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n try {\n const url = 'https://api.airtable.com/v0/' + PIPEDRIVE_MASTER_BASE + '/Keys?filterByFormula=' +\n encodeURIComponent(\"AND({project_id}='\" + PIPEDRIVE_PROJECT_ID + \"',{key_name}='serperApiKey')\");\n const r = await fetch(url, { headers: { Authorization: 'Bearer ' + atKey } });\n const d = await r.json();\n serperKey = String(d?.records?.[0]?.fields?.key_value || '').trim();\n } catch (e) { /* */ }\n }\n if (!serperKey) return jsonResp({ ok: false, error: 'SERPER_API_KEY nicht konfiguriert (Env-Var oder Master-Base)' }, 500, corsHeaders);\n const q = '\"' + name + '\"' + (city ? ' ' + city : '') + ' Hausverwaltung Impressum';\n let snippets = '';\n try {\n const sr = await fetch('https://google.serper.dev/search', {\n method: 'POST',\n headers: { 'X-API-KEY': serperKey, 'Content-Type': 'application/json' },\n body: JSON.stringify({ q, gl: 'de', hl: 'de', num: 5 }),\n });\n const sd = await sr.json();\n const hits = Array.isArray(sd.organic) ? sd.organic.slice(0, 3) : [];\n snippets = hits.map((h: any) => 'URL: ' + (h.link || '') + '\\nTitel: ' + (h.title || '') + '\\nSnippet: ' + (h.snippet || '')).join('\\n\\n');\n } catch (e: any) { return jsonResp({ ok: false, error: 'Serper: ' + e.message }, 500, corsHeaders); }\n if (!snippets) return jsonResp({ ok: false, error: 'Keine Suchergebnisse' }, 404, corsHeaders);\n const anthropic = new Anthropic({ apiKey: Deno.env.get(\"ANTHROPIC_KEY\") });\n const sys = 'Du extrahierst Stammdaten von Hausverwaltungen aus Google-Suchergebnis-Snippets. WICHTIG: Gib NUR Werte zurueck, die WORTWOERTLICH in den Snippets vorkommen. Wenn ein Feld nicht eindeutig im Text steht, setze es auf null. Erfinde NICHTS. Antworte ausschliesslich als JSON ohne Fliesstext und ohne Markdown-Code-Block.';\n const userPrompt = 'Hausverwaltung: \"' + name + '\"' + (city ? ' in ' + city : '') + '\\n\\nExtrahiere die offiziellen Stammdaten.\\n\\nFormat:\\n{\\n \"strasse\": \"...\",\\n \"plz\": \"...\",\\n \"ort\": \"...\",\\n \"telefon\": \"...\",\\n \"email\": \"...\",\\n \"ustidnr\": \"DEXXXXXXXXX\",\\n \"steuernr\": \"...\",\\n \"website\": \"...\"\\n}\\n\\nSuchergebnisse:\\n' + snippets;\n try {\n const msg = await anthropic.messages.create({\n model: 'claude-haiku-4-5',\n max_tokens: 600,\n system: sys,\n messages: [{ role: 'user', content: userPrompt }],\n });\n const txt = (msg.content[0] as any)?.type === 'text' ? (msg.content[0] as any).text : '';\n const jm = txt.match(/\\{[\\s\\S]*\\}/);\n if (!jm) return jsonResp({ ok: false, error: 'KI hat keine Daten geliefert' }, 200, corsHeaders);\n const raw = JSON.parse(jm[0]);\n const snipLow = snippets.toLowerCase();\n const snipNoSpace = snipLow.replace(/\\s+/g, '');\n const data: any = {};\n for (const k of ['strasse','plz','ort','telefon','email','ustidnr','steuernr','website']) {\n const v = raw[k];\n if (v && typeof v === 'string' && v !== 'null' && v.trim().length > 1) {\n const vLow = String(v).toLowerCase();\n const vNoSpace = vLow.replace(/\\s+/g, '');\n if (snipLow.includes(vLow) || snipNoSpace.includes(vNoSpace)) {\n data[k] = String(v).trim();\n }\n }\n }\n return jsonResp({ ok: true, data, snippet_count: snippets.split('\\n\\n').length }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: 'Claude: ' + e.message }, 500, corsHeaders); }\n }\n if (body.action === 'create_pm') {\n const n=String(body.name||'').trim(); if(!n) return jsonResp({ok:false,error:'name required'},400,corsHeaders);\n const e=String(body.email||'').trim(), s=String(body.strasse||'').trim(), c=String(body.city||'').trim(), t=String(body.tel||'').trim(), w=String(body.website||'').trim();\n const cr=await createPipedriveOrgWithEmail({name:n,email:e,city:s||c,website:w,source:'inbox_ki'});\n if(!cr.ok) return jsonResp(cr,200,corsHeaders);\n if(t||w||s){const cfg=await loadPipedriveConfig(); if(cfg){const note='🤖 Inbox-KI:\\n'+(s?'Adresse: '+s+(c?', '+c:'')+'\\n':'')+(t?'Telefon: '+t+'\\n':'')+(w?'Website: '+w+'\\n':''); await fetch('https://'+cfg.domain+'/api/v1/notes?api_token='+encodeURIComponent(cfg.token),{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({content:note,org_id:cr.org_id})}).catch(()=>{});}}\n return jsonResp({ok:true,org_id:cr.org_id,name:n},200,corsHeaders);\n }\n if (body.action === 'find_property_manager') {\n const q = String(body.query || '').trim();\n if (q.length < 3) return jsonResp({ ok: true, results: [] }, 200, corsHeaders);\n const orgs = await findPipedriveOrgsByName(q, 3);\n if (!orgs.length) return jsonResp({ ok: true, results: [], source: 'db' }, 200, corsHeaders);\n const enriched = await Promise.all(orgs.map(async (org: any) => {\n const email = await getOrgGenericEmail(org.id);\n return {\n org_id: org.id,\n name: org.name,\n email: email, // null wenn nur personalisierte Mails vorhanden\n city: org.address || '', // best-effort, Pipedrive-Adresse als Volltext\n confidence: email ? 100 : 60, // mit Email = sichere DB-Quelle\n };\n }));\n return jsonResp({ ok: true, source: 'db', results: enriched }, 200, corsHeaders);\n }\n\n if (body.action === 'submit_eigentuemer_cta') {\n const c = body.cta || {};\n const hvName = String(c.hv_name || '').trim();\n const hvEmail = String(c.hv_email || '').trim();\n const hvAddress = String(c.hv_address || '').trim();\n const hvTelefon = String(c.hv_telefon || '').trim();\n const hvWebsite = String(c.hv_website || '').trim();\n const userEmail = String(c.user_email || '').trim();\n const userName = String(c.user_name || '').trim() || userEmail || 'Anonym';\n const checkNr = String(c.check_nr || '').trim() || '—';\n const role = String(c.role || 'eigentuemer').trim();\n const savings = Number(c.savings_total_eur || 0);\n\n if (!hvName) return jsonResp({ ok: false, error: 'hv_name Pflichtfeld' }, 400, corsHeaders);\n\n try {\n let org = await findPipedriveOrgByName(hvName);\n let orgId: number | null = org?.id || null;\n let orgCreated = false;\n if (!orgId) {\n const created = await createPipedriveOrgWithEmail({\n name: hvName,\n email: isGenericHvEmail(hvEmail) ? hvEmail : undefined,\n city: hvAddress || undefined,\n source: hvAddress ? 'ki_web' : 'user_verifiziert',\n });\n if (created.ok && created.org_id) {\n orgId = created.org_id;\n orgCreated = true;\n if (hvTelefon || hvWebsite) {\n const cfgN = await loadPipedriveConfig();\n if (cfgN) {\n const noteContent = '🔍 Aus Web-Suche extrahiert:\\n' +\n (hvAddress ? 'Adresse: ' + hvAddress + '\\n' : '') +\n (hvTelefon ? 'Telefon: ' + hvTelefon + '\\n' : '') +\n (hvWebsite ? 'Website: ' + hvWebsite + '\\n' : '');\n await fetch('https://' + cfgN.domain + '/api/v1/notes?api_token=' + encodeURIComponent(cfgN.token), {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteContent, org_id: orgId }),\n }).catch(() => { /* non-critical */ });\n }\n }\n }\n }\n\n if (orgId && !orgCreated && hvEmail && isGenericHvEmail(hvEmail)) {\n const existingMail = await getOrgGenericEmail(orgId);\n if (!existingMail) {\n const cfg = await loadPipedriveConfig();\n if (cfg) {\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n await fetch('https://' + cfg.domain + '/api/v1/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({\n name: hvName + ' (Allgemein)',\n email: [{ value: hvEmail, primary: true, label: 'work' }],\n org_id: orgId,\n }),\n }).catch(() => { });\n }\n }\n }\n\n let userPersonId: number | null = null;\n if (orgId && userEmail) {\n const cfg = await loadPipedriveConfig();\n if (cfg) {\n try {\n const searchUrl = 'https://' + cfg.domain + '/api/v1/persons/search?fields=email&exact_match=true&limit=5&term=' +\n encodeURIComponent(userEmail) + '&api_token=' + encodeURIComponent(cfg.token);\n const sr = await fetch(searchUrl);\n const sd = await sr.json();\n if (sd?.success && sd.data?.items?.length) {\n userPersonId = sd.data.items[0].item?.id || null;\n }\n } catch (e) { }\n }\n if (userPersonId) await linkPersonToOrg(userPersonId, orgId);\n }\n\n let hvLead: any = { ok: false };\n if (orgId) {\n hvLead = await createHvLead({\n orgId,\n userFullName: userName,\n userEmail,\n savingsTotal: savings,\n checkNr,\n role,\n hvName,\n });\n }\n\n try {\n const ak = Deno.env.get(\"AIRTABLE_KEY\"); const ab = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (ak && ab && checkNr && checkNr !== '—') {\n const fr = await fetch('https://api.airtable.com/v0/' + ab + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + checkNr + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + ak } });\n const rId = (await fr.json())?.records?.[0]?.id;\n if (rId) {\n const hvFields: any = {};\n if (hvName) hvFields.hv_name = hvName;\n if (hvEmail) hvFields.hv_email = hvEmail;\n if (hvTelefon) hvFields.hv_telefon = hvTelefon;\n if (hvAddress) hvFields.hv_adresse = hvAddress;\n if (hvWebsite) hvFields.hv_website = hvWebsite;\n if (orgId) hvFields.hv_pipedrive_org_id = String(orgId);\n if (Object.keys(hvFields).length) {\n await atPatchRetry('https://api.airtable.com/v0/' + ab + '/Vorab-Checks/' + rId, ak, hvFields, 12);\n }\n }\n }\n } catch (e) { /* HV-Patch non-critical */ }\n return jsonResp({\n ok: true,\n org_id: orgId,\n org_created: orgCreated,\n user_person_id: userPersonId,\n hv_lead: hvLead,\n }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: 'Exception: ' + (e.message || String(e)) }, 500, corsHeaders);\n }\n }\n\n if (body.action === 'get_defaults') {\n return jsonResp({\n prompts: DEFAULT_SYSTEM_PROMPTS,\n role_contexts: ROLE_CONTEXTS,\n model: MODEL,\n backend_version: 'V9.90',\n backend_features: ['set_bearbeiter_status', 'link_followup_check', 'vertrag_mapping_konfig', 'patch_retry_on_unknown_field', 'ensure_vorabcheck_schema', 'verwalter_pdf_attachment'],\n }, 200, corsHeaders);\n }\n if (body.action === 'ensure_vorabcheck_schema') {\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n const TARGET_FIELDS: any[] = VORABCHECK_TARGET_FIELDS;\n try {\n const schemaRes = await fetch('https://api.airtable.com/v0/meta/bases/' + b + '/tables', {\n headers: { Authorization: 'Bearer ' + k },\n });\n if (!schemaRes.ok) {\n const txt = await schemaRes.text();\n let hint = '';\n if (schemaRes.status === 403 || schemaRes.status === 401) {\n hint = ' — Dein Airtable-PAT braucht den Scope schema.bases:read und schema.bases:write. Erweitere ihn unter airtable.com/create/tokens.';\n }\n return jsonResp({ ok: false, error: 'Schema lesen fehlgeschlagen (HTTP ' + schemaRes.status + ')' + hint, raw: txt.slice(0, 300) }, schemaRes.status, corsHeaders);\n }\n const schema = await schemaRes.json();\n const tbl = schema.tables?.find((t: any) => t.name === 'Vorab-Checks');\n if (!tbl) return jsonResp({ ok: false, error: 'Tabelle „Vorab-Checks\" nicht gefunden' }, 404, corsHeaders);\n const existingNames = new Set(tbl.fields.map((f: any) => f.name));\n const created: string[] = [];\n const skipped: string[] = [];\n const failed: any[] = [];\n if (body.dry_run) {\n for (const field of TARGET_FIELDS) {\n if (existingNames.has(field.name)) skipped.push(field.name);\n else created.push(field.name);\n }\n return jsonResp({ ok: true, dry_run: true, would_create: created, already_exists: skipped, total_target: TARGET_FIELDS.length, table_id: tbl.id }, 200, corsHeaders);\n }\n for (const field of TARGET_FIELDS) {\n if (existingNames.has(field.name)) { skipped.push(field.name); continue; }\n const createRes = await fetch('https://api.airtable.com/v0/meta/bases/' + b + '/tables/' + tbl.id + '/fields', {\n method: 'POST',\n headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify(field),\n });\n if (createRes.ok) {\n created.push(field.name);\n } else {\n const txt = await createRes.text();\n failed.push({ name: field.name, status: createRes.status, error: txt.slice(0, 200) });\n }\n }\n return jsonResp({ ok: true, created, skipped, failed, total_target: TARGET_FIELDS.length, table_id: tbl.id }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: e.message }, 500, corsHeaders);\n }\n }\n if (body.action === 'ping') {\n return jsonResp({\n ok: true,\n backend_version: 'V9.91',\n backend_features: ['set_bearbeiter_status', 'link_followup_check', 'vertrag_mapping_konfig', 'patch_retry_on_unknown_field', 'ensure_vorabcheck_schema', 'verwalter_pdf_attachment', 'upload_vorabcheck_pdf'],\n model: MODEL,\n }, 200, corsHeaders);\n }\n\n // V12.42/V12.45: Thin Wrappers für PDF-Upload + Owner-Self-Serve\n if (body.action === 'upload_vorabcheck_pdf' || body.action === 'submit_owner_self_serve') {\n const env = { AIRTABLE_KEY: Deno.env.get(\"AIRTABLE_KEY\"), AIRTABLE_BASE_ID: Deno.env.get(\"AIRTABLE_BASE_ID\") };\n const fn = body.action === 'upload_vorabcheck_pdf' ? handleUploadVorabcheckPdf : handleSubmitOwnerSelfServe;\n const res = await fn(body, env);\n return jsonResp(res, res.status || (res.ok ? 200 : 500), corsHeaders);\n }\n\n if (body.action === 'correct') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ error: 'check_nr fehlt' }, 400, corsHeaders);\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) return jsonResp({ ok: false, warning: 'Airtable nicht konfiguriert' }, 200, corsHeaders);\n const fields = body.fields || {};\n const records: any[] = [];\n Object.keys(fields).forEach(k => {\n const v = fields[k];\n if (v && v.changed) {\n records.push({\n fields: {\n check_nr: cn,\n field_name: k,\n original_value: String(v.original ?? ''),\n corrected_value: String(v.corrected ?? ''),\n savedAt: new Date().toISOString(),\n }\n });\n }\n });\n if (!records.length) return jsonResp({ ok: true, count: 0 }, 200, corsHeaders);\n try {\n const url = `https://api.airtable.com/v0/${base}/Vorabcheck-Korrekturen`;\n for (let i = 0; i < records.length; i += 10) {\n const batch = records.slice(i, i + 10);\n await fetch(url, {\n method: 'POST',\n headers: { Authorization: `Bearer ${key}`, 'Content-Type': 'application/json' },\n body: JSON.stringify({ records: batch }),\n });\n }\n return jsonResp({ ok: true, count: records.length }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: e.message }, 500, corsHeaders);\n }\n }\n\n const { check_type, file, lead, turnstile_token, consent_given } = body;\n const role = ['mieter','eigentuemer','verwalter'].includes(body.role) ? body.role : 'mieter';\n const aufzugCountUser = Math.max(1, Math.min(50, parseInt(String(body.aufzug_count_user || '1'), 10) || 1));\n const wartungBruttoUser = Math.max(0, parseFloat(String(body.wartung_brutto_user || '0').replace(',', '.')) || 0);\n\n const turnstileSecret = Deno.env.get(\"TURNSTILE_SECRET_KEY\");\n const isDevBypass = String(turnstile_token || '') === 'dev-bypass-token';\n if (turnstileSecret && turnstile_token && !isDevBypass) {\n const ok = await verifyTurnstile(turnstile_token, turnstileSecret);\n if (!ok) return jsonResp({ error: \"Captcha ungültig\" }, 403, corsHeaders);\n }\n\n if (!consent_given) return jsonResp({ error: \"Einwilligung fehlt\" }, 400, corsHeaders);\n\n const custom = await loadCustomPrompts();\n let systemPrompt = buildSystemPrompt(check_type, role, custom);\n if (!systemPrompt) return jsonResp({ error: \"Unbekannter Check-Typ\" }, 400, corsHeaders);\n\n let preisrefList: any[] = [];\n if (check_type === 'angebot') {\n preisrefList = await loadPreisreferenzen();\n if (preisrefList.length) {\n const preisrefBlock =\n '\\n\\n═══════════════════════════════════════════\\n' +\n 'MARKTPREIS-REFERENZEN (verbindlich, NICHT VERHANDELBAR)\\n' +\n '═══════════════════════════════════════════\\n' +\n 'Diese Liste enthält den aktuellen Marktmedian je Position für Aufzug-Reparatur/Wartung. ' +\n 'Vergleiche JEDE Angebots-Position mit dieser Liste:\\n\\n' +\n preisrefList.map((p, i) =>\n (i + 1) + '. ' + p.position + ' — ' + p.median_eur.toFixed(2) + ' € pro ' + p.einheit +\n (p.region ? ' (' + p.region + ')' : '') +\n (p.notes ? ' — ' + p.notes : '')\n ).join('\\n') + '\\n\\n' +\n 'Wenn eine Angebots-Position in dieser Liste auftaucht: nutze den Median als Vergleichsbasis. ' +\n 'Die konkreten Median-€-Werte dürfen in deiner Antwort genannt werden, denn sie sind Liftaro-Marktdaten. ' +\n 'Wenn eine Angebots-Position NICHT in der Liste steht, gib in deiner JSON-Antwort ein Feld ' +\n '\"positions_nicht_in_liste\": [{titel, betrag_eur}] mit den entsprechenden Positionen zurück — ' +\n 'das Backend schätzt dafür einen Fallback-Wert.';\n systemPrompt = systemPrompt + preisrefBlock;\n }\n }\n\n const anthropic = new Anthropic({ apiKey: Deno.env.get(\"ANTHROPIC_KEY\") });\n const t0 = Date.now();\n\n const isPdf = file.mime === \"application/pdf\";\n const userContent: any[] = [\n {\n type: isPdf ? \"document\" : \"image\",\n source: { type: \"base64\", media_type: file.mime, data: file.base64 },\n },\n { type: \"text\", text: \"Prüfe das beigefügte Dokument gemäß den Vorgaben und antworte ausschließlich mit dem geforderten JSON. Falls im Dokument eine Objekt-, Liegenschafts- oder Gebäudeadresse erkennbar ist (z.B. 'Beispielstr. 12, 55116 Mainz'), gib sie zusätzlich als Top-Level-Feld 'objekt_adresse' (String, Format: 'Straße Hausnr., PLZ Ort') zurück. Wenn nicht eindeutig erkennbar, setze 'objekt_adresse' auf einen leeren String.\" },\n ];\n\n const response = await anthropic.messages.create({\n model: MODEL,\n max_tokens: 4096, // Erhöht von 2048 — komplexe Tabellen brauchen mehr Output-Spielraum\n system: systemPrompt,\n messages: [{ role: \"user\", content: userContent }],\n });\n\n const duration_ms = Date.now() - t0;\n const tokens_in = response.usage.input_tokens;\n const tokens_out = response.usage.output_tokens;\n const cost_eur = ((tokens_in * COST_PER_M_INPUT_TOKENS + tokens_out * COST_PER_M_OUTPUT_TOKENS) / 1_000_000) * USD_TO_EUR;\n\n const textBlock = response.content.find((c: any) => c.type === \"text\");\n const rawText = textBlock?.text || \"{}\";\n const cleaned = rawText.replace(/^```json\\s*|\\s*```$/g, \"\").trim();\n let result: any;\n try { result = JSON.parse(cleaned); }\n catch { return jsonResp({ error: \"KI-Antwort konnte nicht geparst werden\", raw: rawText }, 500, corsHeaders); }\n\n const checkNr = await generateCheckNr();\n result.check_nr = checkNr;\n\n await saveToAirtable({\n check_nr: checkNr,\n check_type,\n role,\n lead,\n result,\n file_name: file.name,\n cost_eur,\n tokens_in,\n tokens_out,\n model: MODEL,\n duration_ms,\n });\n\n let savingsTotal = Number(result.savings_total_eur || result.savings_estimate_eur || 0);\n const meaPool = Number(result.mea_pool_total || 0);\n const meaEigentuemer = Number(result.mea_eigentuemer || 0);\n\n if (check_type === 'nebenkosten') {\n const aufzugCount = aufzugCountUser;\n result.aufzug_count = aufzugCount; // Im Response konsistent halten\n let aufzugBrutto = 0;\n let bruttoSource = 'unknown'; // 'user' | 'ki' | 'regex' — für Transparenz\n\n if (wartungBruttoUser > 0) {\n aufzugBrutto = wartungBruttoUser;\n bruttoSource = 'user';\n if (!result.anonymized_data) result.anonymized_data = {};\n result.anonymized_data.betrag_aufzug_brutto = aufzugBrutto;\n console.log('[liftaro-vorabcheck] brutto vom User:', aufzugBrutto);\n } else {\n aufzugBrutto = Number(result.anonymized_data?.betrag_aufzug_brutto || 0);\n if (aufzugBrutto >= 500) bruttoSource = 'ki';\n\n if (!aufzugBrutto || aufzugBrutto < 500) {\n const haystack = String(result.summary || '') + ' ' +\n (result.findings || []).map(f => (f.title||'') + ' ' + (f.description||'')).join(' ');\n const matches = [...haystack.matchAll(/aufzug[a-zäöü\\s\\-/]*wartung[^0-9]{0,40}(\\d{1,3}(?:\\.\\d{3})*(?:,\\d{2})?|\\d{4,6}(?:,\\d{2})?)\\s*(?:€|eur)/gi)];\n if (matches.length) {\n const candidates = matches.map(m => parseFloat(m[1].replace(/\\./g, '').replace(',', '.'))).filter(n => n > 500);\n if (candidates.length) {\n aufzugBrutto = Math.max(...candidates);\n bruttoSource = 'regex';\n console.log('[liftaro-vorabcheck] brutto via Regex aus Klartext:', aufzugBrutto);\n }\n }\n }\n }\n\n const proAnlage = aufzugCount > 0 ? aufzugBrutto / aufzugCount : 0;\n\n if (proAnlage > 1200) {\n const correctTotal = Math.round((proAnlage - 980) * aufzugCount);\n const proAnlageStr = Math.round(proAnlage).toLocaleString('de-DE');\n const diffStr = Math.round(proAnlage - 980).toLocaleString('de-DE');\n const pctSavings = aufzugBrutto > 0 ? Math.round((correctTotal / aufzugBrutto) * 100) : 0;\n\n savingsTotal = correctTotal;\n result.savings_text = 'rund ' + pctSavings + ' % der bisherigen Wartungskosten durch marktgerechte Neuausschreibung';\n\n const summaryHasMarketClaim = /markt|median/i.test(String(result.summary || ''));\n const summaryIsConsistent = summaryHasMarketClaim && /über|ueber|deutlich|teuer/i.test(String(result.summary || ''));\n if (!summaryIsConsistent) {\n result.summary = 'Ihre Wartung kostet ' + proAnlageStr + ' € pro Jahr je Aufzug — das ist rund ' + diffStr + ' € mehr als der übliche Marktpreis für Wartung und Notruf. Optimierungspotenzial vorhanden.';\n }\n if (result.summary) {\n result.summary = String(result.summary).replace(/\\bvon\\s+9\\s?80\\s*(€|EUR)\\b/gi, '').replace(/\$?\\b9\\s?80\\s*(€|EUR)\\b\$?/gi, '').replace(/\\s{2,}/g, ' ').trim();\n }\n if (result.savings_text) {\n result.savings_text = String(result.savings_text).replace(/\\bvon\\s+9\\s?80\\s*(€|EUR)\\b/gi, '').replace(/\$?\\b9\\s?80\\s*(€|EUR)\\b\$?/gi, '').replace(/\\s{2,}/g, ' ').trim();\n }\n\n let findings = result.findings || [];\n findings = findings.filter(f => !/markt|wartung.*(zu\\s+(teuer|hoch)|ueber|über)|optimierung.*?wartung/i.test((f.title||'') + ' ' + (f.description||'')));\n findings.unshift({\n severity: proAnlage > 1800 ? 'warn' : (proAnlage > 1500 ? 'amber' : 'blue'),\n title: 'Wartung teurer als üblich',\n description: 'Die Wartung kostet ' + proAnlageStr + ' € pro Jahr je Aufzug — rund ' + diffStr + ' € mehr als der übliche Marktpreis. Bei einer Neuausschreibung zu marktüblichen Konditionen sparen Sie ' + correctTotal.toLocaleString('de-DE') + ' € pro Jahr.',\n tag: 'Liftaro-Marktreferenz · aktuell ' + proAnlageStr + ' EUR/Jahr',\n });\n\n result.findings = findings;\n\n if ((result.ampel === 'gruen' || result.ampel === 'grün') && proAnlage > 1500) {\n result.ampel = 'gelb';\n }\n\n console.log('[liftaro-vorabcheck] Markt-Override: brutto=' + aufzugBrutto + ', anlagen=' + aufzugCount + ', proAnlage=' + proAnlage + ', diff=' + diffStr + ', ersparnis=' + correctTotal);\n }\n\n if (role === 'eigentuemer' || role === 'verwalter') {\n const findings = result.findings || [];\n const hasRepairHint = findings.some(f => /reparatur.*(8\\.?000|einsparen|liftaro.*pr[üu]f|zus[äa]tzlich)/i.test((f.title||'') + ' ' + (f.description||'')));\n if (!hasRepairHint) {\n findings.push({\n severity: 'blue',\n title: 'Zusätzliches Sparpotenzial bei Reparaturen',\n description: 'Diese Schätzung berücksichtigt nur Wartung und Notruf. Unterjährige Reparaturen sind nicht eingerechnet — gerade dort steckt oft das größte Potenzial. Durch regelmäßige Überprüfung der Reparatur-Rechnungen durch Liftaro lassen sich im Einzelfall bis zu 8.000 € zusätzlich einsparen.',\n tag: 'Reparatur-Prüfung · Liftaro-Service',\n });\n result.findings = findings;\n }\n }\n }\n\n if (check_type === 'angebot') {\n const angebotsumme = Number(result.anonymized_data?.angebotssumme_brutto || result.anonymized_data?.angebotssumme_netto || 0);\n const positionsLeer = !Array.isArray(result.positions_nicht_in_liste) ? 0 : result.positions_nicht_in_liste.length;\n if (!savingsTotal && angebotsumme > 100) {\n const factor = deterministicSavingsFactor(checkNr);\n savingsTotal = Math.round(angebotsumme * factor);\n result.savings_total_eur = savingsTotal;\n result.savings_text = 'rund ' + Math.round(factor * 100) + ' % der Angebotssumme — Schätzwert ohne konkrete Preisliste';\n const findings = result.findings || [];\n findings.push({\n severity: 'amber',\n title: 'Schätzwert ohne Preislisten-Treffer',\n description: 'Keine Angebots-Position fand einen direkten Treffer in der Liftaro-Preisliste. Der ausgewiesene Ersparnis-Wert ist ein Schätzwert (zwischen 30–60 % der Angebotssumme, deterministisch aus der Check-Nr).',\n tag: 'Schätzwert · Preisliste-Lücke',\n });\n result.findings = findings;\n } else if (positionsLeer && savingsTotal) {\n const findings = result.findings || [];\n findings.push({\n severity: 'blue',\n title: 'Positionen ohne Preislisten-Referenz',\n description: positionsLeer + ' Angebots-Position(en) konnten nicht direkt gegen die Liftaro-Preisliste verglichen werden — diese Werte sind grobe Marktschätzungen.',\n tag: 'Preisliste-Lücke',\n });\n result.findings = findings;\n }\n\n if (role === 'eigentuemer' || role === 'verwalter') {\n const findings = result.findings || [];\n const hasRepairHint = findings.some(f => /reparatur.*(8\\.?000|einsparen|liftaro.*pr[üu]f|zus[äa]tzlich)/i.test((f.title||'') + ' ' + (f.description||'')));\n if (!hasRepairHint) {\n findings.push({\n severity: 'blue',\n title: 'Zusätzliches Sparpotenzial bei Reparaturen',\n description: 'Diese Schätzung berücksichtigt nur Wartung und Notruf. Unterjährige Reparaturen sind nicht eingerechnet — gerade dort steckt oft das größte Potenzial. Durch regelmäßige Überprüfung der Reparatur-Rechnungen durch Liftaro lassen sich im Einzelfall bis zu 8.000 € zusätzlich einsparen.',\n tag: 'Reparatur-Prüfung · Liftaro-Service',\n });\n result.findings = findings;\n }\n }\n }\n\n let savingsIndividual = Number(result.savings_individual_eur || 0);\n if (!savingsIndividual && savingsTotal > 0 && meaPool > 0 && meaEigentuemer > 0) {\n savingsIndividual = Math.round(savingsTotal * meaEigentuemer / meaPool);\n }\n\n if (lead?.email) {\n const fullName = ((lead.vorname || '') + ' ' + (lead.nachname || '')).trim() || lead.email;\n const roleLabel = role === 'eigentuemer' ? 'Eigentümer'\n : role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const checkTypeLabel = check_type === 'nebenkosten' ? 'Nebenkostenabrechnung'\n : check_type === 'angebot' ? 'Angebot'\n : 'Wartungsvertrag';\n const ampelLabel = result.ampel === 'rot' ? '🔴 Rot' : result.ampel === 'gelb' ? '🟡 Gelb' : result.ampel === 'gruen' ? '🟢 Grün' : '–';\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const noteLines = [\n '✅ ANALYSE ' + checkNr,\n '', 'Rolle: ' + roleLabel, 'Check-Typ: ' + checkTypeLabel, 'Ampel: ' + ampelLabel,\n savingsTotal ? 'Ersparnis Haus: ' + fmt(savingsTotal) + ' €/Jahr' : '',\n savingsIndividual ? 'Anteil indiv.: ' + fmt(savingsIndividual) + ' €/Jahr' : '',\n 'Adresse: ' + (lead.adresse || '–'), '',\n '— Zusammenfassung —', result.summary || '(keine)',\n ].filter(Boolean);\n const title = '[Vorabcheck] ' + fullName + ' — ' + roleLabel + ' (' + checkNr + ')';\n upsertPipedriveLead({ name: fullName, email: lead.email, phone: lead.telefon || undefined, title, note: noteLines.join('\\n') })\n .then(async (pd: any) => {\n if (!pd.ok || !pd.lead_id) return;\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return;\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + checkNr + \"'\"),\n { headers: { Authorization: 'Bearer ' + k } });\n const rec = (await fr.json())?.records?.[0]?.id;\n if (!rec) return;\n await fetch('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + rec, {\n method: 'PATCH', headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify({ fields: { pipedrive_lead_id: pd.lead_id, pipedrive_person_id: String(pd.person_id || '') } }),\n });\n } catch (e) { /* */ }\n }).catch(e => console.warn('[Pipedrive] Vorabcheck failed:', e?.message || e));\n }\n\n const aufzugPositionen = Array.isArray(result.aufzug_positionen)\n ? result.aufzug_positionen\n .filter((p: any) => p && (p.text || p.betrag_eur))\n .map((p: any) => ({ text: String(p.text || '').trim(), betrag_eur: Number(p.betrag_eur || 0) }))\n : [];\n let aufzugGesamtkosten = Number(result.aufzug_gesamtkosten_eur || 0);\n if (!aufzugGesamtkosten && aufzugPositionen.length) {\n aufzugGesamtkosten = aufzugPositionen.reduce((s, p) => s + (Number(p.betrag_eur) || 0), 0);\n }\n\n return jsonResp({\n ampel: result.ampel,\n summary: result.summary,\n findings: result.findings || [],\n aufzug_count: aufzugCountUser,\n aufzug_positionen: aufzugPositionen,\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n wartung_brutto_used: Number(result.anonymized_data?.betrag_aufzug_brutto || wartungBruttoUser || 0),\n wartung_brutto_source: wartungBruttoUser > 0 ? 'user' : 'ki', // Transparenz: woher kam der Wartungs-Wert?\n verteilerschluessel: String(result.verteilerschluessel || 'unbekannt'),\n parteien_count: Number(result.parteien_count || 0),\n mea_pool_total: meaPool,\n mea_eigentuemer: meaEigentuemer,\n savings_total_eur: savingsTotal,\n savings_individual_eur: savingsIndividual,\n savings_estimate_eur: savingsTotal, // Legacy für altes Frontend\n savings_text: result.savings_text || \"\",\n check_nr: checkNr,\n role: role,\n objekt_adresse: String(result.objekt_adresse || result.anonymized_data?.objekt_adresse || result.anonymized_data?.gebaeude_adresse || result.anonymized_data?.liegenschaft_adresse || '').trim(),\n }, 200, corsHeaders);\n\n } catch (e: any) {\n console.error(\"[liftaro-vorabcheck]\", e);\n return jsonResp({ error: e.message || \"Server-Fehler\" }, 500, corsHeaders);\n }\n}\n\nfunction jsonResp(body: any, status: number, headers: Record) {\n return new Response(JSON.stringify(body), {\n status,\n headers: { ...headers, \"Content-Type\": \"application/json\" },\n });\n}\n\nasync function verifyTurnstile(token: string, secret: string): Promise {\n const res = await fetch(\"https://challenges.cloudflare.com/turnstile/v0/siteverify\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: `secret=${encodeURIComponent(secret)}&response=${encodeURIComponent(token)}`,\n });\n const json = await res.json();\n return !!json.success;\n}\n\nasync function generateCheckNr(): Promise {\n const year = new Date().getFullYear();\n const random = Math.floor(Math.random() * 9000) + 1000;\n return `VC-${year}-${random}`;\n}\n\nasync function saveToAirtable(data: {\n check_nr: string;\n check_type: string;\n role: string;\n lead: any;\n result: any;\n file_name: string;\n cost_eur: number;\n tokens_in: number;\n tokens_out: number;\n model: string;\n duration_ms: number;\n}) {\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { console.warn(\"Airtable-Keys fehlen — überspringe Persistenz\"); return; }\n const at = `https://api.airtable.com/v0/${base}`;\n const headers = { \"Authorization\": `Bearer ${key}`, \"Content-Type\": \"application/json\" };\n\n async function atPostSafe(tableUrl: string, fieldsIn: Record) {\n const fields = { ...fieldsIn };\n for (let i = 0; i < 20; i++) {\n try {\n const r = await fetch(tableUrl, { method: 'POST', headers, body: JSON.stringify({ fields }) });\n if (r.ok) return;\n const txt = await r.text();\n let badField = '';\n try {\n const j = JSON.parse(txt);\n const msg = j?.error?.message || j?.error || '';\n const m = String(msg).match(/Unknown field name:\\s*\"([^\"]+)\"/i);\n if (m) badField = m[1];\n } catch (_) { /* nicht JSON */ }\n if (badField && Object.prototype.hasOwnProperty.call(fields, badField)) {\n delete fields[badField];\n console.warn('[Airtable] retry ohne unbekanntes Feld:', badField);\n continue;\n }\n console.warn('[Airtable]', tableUrl.slice(-30), 'POST fehlgeschlagen:', txt.slice(0, 200));\n return;\n } catch (e: any) { console.warn('[Airtable]', tableUrl, e.message); return; }\n }\n }\n\n const totalEur = Number(data.result.savings_total_eur || data.result.savings_estimate_eur || 0);\n const indivEur = Number(data.result.savings_individual_eur || 0);\n\n await atPostSafe(`${at}/Vorabcheck-Leads`, {\n check_nr: data.check_nr,\n check_type: data.check_type,\n role: data.role,\n vorname: data.lead.vorname,\n nachname: data.lead.nachname,\n email: data.lead.email,\n telefon: data.lead.telefon || \"\",\n adresse: data.lead.adresse,\n file_name: data.file_name,\n savedAt: new Date().toISOString(),\n });\n\n const aufzugPositionen = Array.isArray(data.result.aufzug_positionen) ? data.result.aufzug_positionen : [];\n const aufzugPositionenText = aufzugPositionen\n .map((p: any) => (p.text || '') + ': ' + (Number(p.betrag_eur || 0).toLocaleString('de-DE', { minimumFractionDigits: 2, maximumFractionDigits: 2 })) + ' €')\n .join('\\n');\n let aufzugGesamtkosten = Number(data.result.aufzug_gesamtkosten_eur || 0);\n if (!aufzugGesamtkosten && aufzugPositionen.length) {\n aufzugGesamtkosten = aufzugPositionen.reduce((s: number, p: any) => s + (Number(p.betrag_eur) || 0), 0);\n }\n const aufzugCount = Number(data.result.aufzug_count || 0);\n const kostenProAufzugEur = aufzugCount > 0\n ? Math.round((aufzugGesamtkosten / aufzugCount) * 100) / 100\n : 0;\n const objektAdresse = String(\n data.result.objekt_adresse ||\n data.result.anonymized_data?.objekt_adresse ||\n data.result.anonymized_data?.gebaeude_adresse ||\n data.result.anonymized_data?.liegenschaft_adresse ||\n data.lead?.adresse || ''\n ).trim();\n\n await atPostSafe(`${at}/Vorab-Checks`, {\n check_nr: data.check_nr,\n check_type: data.check_type,\n role: data.role,\n ampel: data.result.ampel,\n summary: data.result.summary,\n savings_estimate_eur: totalEur,\n savings_total_eur: totalEur,\n savings_individual_eur: indivEur,\n aufzug_count: aufzugCount,\n parteien_count: Number(data.result.parteien_count || 0),\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n kosten_pro_aufzug_eur: kostenProAufzugEur,\n aufzug_positionen_text: aufzugPositionenText,\n aufzug_positionen_json: JSON.stringify(aufzugPositionen),\n objekt_adresse: objektAdresse,\n findings_json: JSON.stringify(data.result.findings || []),\n anonymized_data_json: JSON.stringify(data.result.anonymized_data || {}),\n savedAt: new Date().toISOString(),\n });\n\n await atPostSafe(`${at}/API-Cost-Log`, {\n check_nr: data.check_nr,\n endpoint: \"vorabcheck\",\n model: data.model,\n tokens_in: data.tokens_in,\n tokens_out: data.tokens_out,\n cost_eur: Math.round(data.cost_eur * 10000) / 10000,\n duration_ms: data.duration_ms,\n savedAt: new Date().toISOString(),\n });\n}\n","createdAt",["D",1779802331340],"branchVersion","branchId","14ee6524-4f1d-11f1-b63c-ee650bb23af1","id","14ebf442-4f1d-11f1-b63c-ee650bb23af1","liftaroVorabcheckProxy",["D",1778712174884],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Auto-erstellt von Liftaro Angebotscheck (Vorabcheck-Proxy)","imageUrl","b8672cc5-9c71-42c6-931f-a0aabca33bdd","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e049b-6e23-74ee-9bdd-0c49067080a6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":25},"branch",{"_13":83,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"isOwned",56,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","giltglobalinvest","handle","displayName","Patrizio Fontanarosa","avatar","https://lh3.googleusercontent.com/a/ACg8ocL48GSPatvcxwg0cqcSWpW_ddx-HBZAMenADEoTYtVSkvBX8g=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":164,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":165,"_78":166,"_80":167,"_82":25},"tree",[155,156],"files",[155,156],"counts",{"_144":60,"_145":132,"_146":60,"_147":148,"_149":150},"contents",[126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":135,"_32":136,"_30":137,"_129":-5,"_40":41,"_39":138,"_130":121,"_37":139,"_13":140,"_33":141,"_34":142,"_24":25,"_133":-5,"_27":143},{"_42":128,"_32":28,"_30":31,"_129":-5,"_40":41,"_39":14,"_130":25,"_37":131,"_13":132,"_33":20,"_34":36,"_24":25,"_133":-5,"_27":134},"4cd0aaf8-5907-11f1-865e-ee650bb23af1","parentId","latest",["D",1779802331340],1,"label",[28],"efa2673a-5623-11f1-9a50-ee650bb23af1","main.tsx","1540a80c-4f1d-11f1-8df2-ee650bb23af1",49,["D",1779484776927],48,"http","\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.30.0\";\nimport { ROLE_CONTEXTS, DEFAULT_SYSTEM_PROMPTS } from \"https://check.liftaro.de/vorabcheck/prompts.js?v=3\";\nimport { VORABCHECK_TARGET_FIELDS } from \"https://check.liftaro.de/vorabcheck/backend-extras.js?v=5\";\n\nconst MODEL = \"claude-sonnet-4-6\"; // Upgrade von 4.5 → 4.6 für besseres Vision-Verständnis bei Tabellen\nconst COST_PER_M_INPUT_TOKENS = 3.0; // $ pro 1M Input-Tokens (Sonnet 4.6 — Preise ähnlich 4.5)\nconst COST_PER_M_OUTPUT_TOKENS = 15.0; // $ pro 1M Output-Tokens\nconst USD_TO_EUR = 0.92;\n\nlet _promptCache: Record | null = null;\nlet _promptCacheTs = 0;\nconst PROMPT_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function atPatchRetry(url: string, k: string, fields: any, max = 15): Promise<{ ok: boolean, error?: string }> {\n const headers = { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' };\n let a = 0;\n while (a++ < max) {\n const r = await fetch(url, { method: 'PATCH', headers, body: JSON.stringify({ fields }) });\n if (r.ok) return { ok: true };\n const txt = await r.text();\n let bad = '';\n try {\n const j = JSON.parse(txt);\n const m = String(j?.error?.message || j?.error || '').match(/Unknown field name:\\s*\"([^\"]+)\"/i);\n if (m) bad = m[1];\n } catch (_) {}\n if (bad && Object.prototype.hasOwnProperty.call(fields, bad)) { delete fields[bad]; continue; }\n return { ok: false, error: txt.slice(0, 200) };\n }\n return { ok: false, error: 'too many retries' };\n}\n\nasync function loadCustomPrompts(): Promise> {\n if (_promptCache && Date.now() - _promptCacheTs < PROMPT_CACHE_TTL_MS) return _promptCache;\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { _promptCache = {}; _promptCacheTs = Date.now(); return _promptCache; }\n try {\n const res = await fetch(`https://api.airtable.com/v0/${base}/Vorabcheck-Prompts`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(\"HTTP \" + res.status);\n const data = await res.json();\n const map: Record = {};\n (data.records || []).forEach((r: any) => {\n const t = r.fields?.check_type;\n const p = r.fields?.system_prompt;\n if (t && p && p.trim().length > 50) map[t] = p;\n });\n _promptCache = map;\n _promptCacheTs = Date.now();\n return map;\n } catch (e) {\n console.warn(\"loadCustomPrompts:\", e);\n return _promptCache || {};\n }\n}\n\nconst PIPEDRIVE_MASTER_BASE = 'appzhNrhkLSTEaNFW';\nconst PIPEDRIVE_PROJECT_ID = 'p_1777239396379';\nlet _pdCache: { domain: string, token: string } | null = null;\nlet _pdCacheTs = 0;\nconst PD_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function loadPipedriveConfig(): Promise<{ domain: string, token: string } | null> {\n if (_pdCache && Date.now() - _pdCacheTs < PD_CACHE_TTL_MS) return _pdCache;\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n if (!atKey) { _pdCacheTs = Date.now(); return null; }\n try {\n const url = 'https://api.airtable.com/v0/' + PIPEDRIVE_MASTER_BASE + '/Keys?filterByFormula=' +\n encodeURIComponent(\"AND({project_id}='\" + PIPEDRIVE_PROJECT_ID + \"',OR({key_name}='pipedriveDomain',{key_name}='pipedriveApiToken'))\");\n const res = await fetch(url, { headers: { Authorization: 'Bearer ' + atKey } });\n if (!res.ok) throw new Error('HTTP ' + res.status);\n const data = await res.json();\n let domain = '', token = '';\n (data.records || []).forEach((r: any) => {\n if (r.fields?.key_name === 'pipedriveDomain') domain = String(r.fields.key_value || '').trim();\n if (r.fields?.key_name === 'pipedriveApiToken') token = String(r.fields.key_value || '').trim();\n });\n _pdCacheTs = Date.now();\n if (!domain || !token) { _pdCache = null; return null; }\n _pdCache = { domain: domain.replace(/^https?:\\/\\//, '').replace(/\\/$/, ''), token };\n return _pdCache;\n } catch (e) {\n console.warn('[Pipedrive] loadPipedriveConfig:', e);\n return null;\n }\n}\n\nasync function createPipedriveLead(input: {\n name: string;\n email?: string;\n phone?: string;\n org?: string;\n title: string;\n note: string;\n}): Promise<{ ok: boolean; lead_id?: string; person_id?: number; reused?: boolean; error?: string }> {\n return upsertPipedriveLead(input);\n}\n\nasync function upsertPipedriveLead(input: {\n name: string;\n email?: string;\n phone?: string;\n org?: string;\n title: string;\n note: string;\n}): Promise<{ ok: boolean; lead_id?: string; person_id?: number; reused?: boolean; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n let personId: number | null = null;\n let personExisted = false;\n\n if (input.email) {\n try {\n const searchUrl = base + '/persons/search?fields=email&exact_match=true&limit=5&term=' +\n encodeURIComponent(input.email) + '&api_token=' + encodeURIComponent(cfg.token);\n const sr = await fetch(searchUrl);\n const sd = await sr.json();\n if (sd?.success && sd.data?.items?.length) {\n personId = sd.data.items[0].item?.id || null;\n if (personId) personExisted = true;\n }\n } catch (e) { }\n }\n\n if (!personId) {\n const personBody: any = { name: input.name || 'Anonym' };\n if (input.email) personBody.email = [{ value: input.email, primary: true, label: 'work' }];\n if (input.phone) personBody.phone = [{ value: input.phone, primary: true, label: 'work' }];\n const personRes = await fetch(base + '/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(personBody),\n });\n const personData = await personRes.json();\n if (!personData.success) {\n return { ok: false, error: 'Person: ' + JSON.stringify(personData.error || personData).slice(0, 200) };\n }\n personId = personData.data.id;\n }\n\n let orgId: number | null = null;\n if (input.org && input.org.trim() && !personExisted) {\n try {\n const orgRes = await fetch(base + '/organizations' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ name: input.org.trim() }),\n });\n const orgData = await orgRes.json();\n if (orgData.success) orgId = orgData.data.id;\n } catch (e) { }\n }\n\n let leadId: string | null = null;\n let leadReused = false;\n try {\n const leadsUrl = base + '/leads?person_id=' + personId + '&archived_status=not_archived&limit=20&api_token=' + encodeURIComponent(cfg.token);\n const lr = await fetch(leadsUrl);\n const ld = await lr.json();\n if (ld?.success && Array.isArray(ld.data) && ld.data.length > 0) {\n const sorted = ld.data.slice().sort((a: any, b: any) =>\n String(b.add_time || '').localeCompare(String(a.add_time || ''))\n );\n leadId = sorted[0].id;\n leadReused = true;\n }\n } catch (e) { }\n\n if (!leadId) {\n const leadBody: any = { title: input.title, person_id: personId };\n if (orgId) leadBody.organization_id = orgId;\n const leadRes = await fetch(base + '/leads' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(leadBody),\n });\n const leadData = await leadRes.json();\n if (!leadData.success) {\n return { ok: false, error: 'Lead: ' + JSON.stringify(leadData.error || leadData).slice(0, 200), person_id: personId };\n }\n leadId = leadData.data.id;\n }\n\n if (input.note) {\n try {\n const stamp = new Date().toISOString().replace('T', ' ').slice(0, 16) + ' UTC';\n const noteWithStamp = '🕒 ' + stamp + '\\n\\n' + input.note;\n await fetch(base + '/notes' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteWithStamp, lead_id: leadId }),\n });\n } catch (e) { }\n }\n\n console.log('[Pipedrive] ' + (leadReused ? 'Lead reused' : 'Lead created') + ':', leadId,\n 'person=' + personId + (personExisted ? ' (existed)' : ' (new)'));\n return { ok: true, lead_id: leadId, person_id: personId, reused: leadReused };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nconst HV_GENERIC_EMAIL_PREFIXES = [\n 'info', 'kontakt', 'service', 'mail', 'office',\n 'verwaltung', 'hausverwaltung', 'team', 'kundenservice',\n 'support', 'anfrage', 'post', 'zentrale', 'verwalter',\n 'buero', 'hello', 'welcome', 'empfang', 'sekretariat',\n 'wohnen', 'immobilien',\n];\n\nfunction isGenericHvEmail(email: string): boolean {\n if (!email || typeof email !== 'string') return false;\n const e = email.trim().toLowerCase();\n if (!/^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/.test(e)) return false;\n const local = e.split('@')[0];\n return HV_GENERIC_EMAIL_PREFIXES.includes(local);\n}\n\nfunction pickGenericEmailFromPersons(persons: any[]): string | null {\n if (!Array.isArray(persons) || !persons.length) return null;\n for (const p of persons) {\n const emails = Array.isArray(p?.email) ? p.email : [];\n for (const e of emails) {\n const val = String(e?.value || '').trim();\n if (isGenericHvEmail(val)) return val;\n }\n }\n return null;\n}\n\nasync function findPipedriveOrgsByName(name: string, limit = 3): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return [];\n const term = String(name || '').trim();\n if (term.length < 3) return [];\n const termLow = term.toLowerCase();\n const base = 'https://' + cfg.domain + '/api/v1';\n try {\n const url = base + '/organizations/search?term=' + encodeURIComponent(term) +\n '&fields=name&exact_match=false&limit=10&api_token=' + encodeURIComponent(cfg.token);\n const r = await fetch(url);\n const d = await r.json();\n if (!d?.success || !d.data?.items?.length) return [];\n const filtered = d.data.items\n .map((it: any) => ({\n item: it.item,\n score: Number(it.result_score || 0),\n }))\n .filter((x: any) => {\n if (!x.item || !x.item.name) return false;\n const nameLow = String(x.item.name).toLowerCase();\n if (!nameLow.includes(termLow)) return false;\n return x.score >= 0.3 || term.length >= 5; // bei längerem Term Score-Toleranz lockern\n })\n .sort((a: any, b: any) => b.score - a.score)\n .slice(0, limit)\n .map((x: any) => x.item);\n return filtered;\n } catch (e) { console.warn('[Pipedrive] findOrgsByName:', e); return []; }\n}\n\nasync function findPipedriveOrgByName(name: string): Promise {\n const hits = await findPipedriveOrgsByName(name, 1);\n return hits.length ? hits[0] : null;\n}\n\nasync function getOrgGenericEmail(orgId: number): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg || !orgId) return null;\n const base = 'https://' + cfg.domain + '/api/v1';\n try {\n const url = base + '/organizations/' + orgId + '/persons?api_token=' + encodeURIComponent(cfg.token);\n const r = await fetch(url);\n const d = await r.json();\n if (!d?.success || !Array.isArray(d.data)) return null;\n return pickGenericEmailFromPersons(d.data);\n } catch (e) { console.warn('[Pipedrive] getOrgGenericEmail:', e); return null; }\n}\n\nasync function createPipedriveOrgWithEmail(input: {\n name: string;\n email?: string;\n website?: string;\n city?: string;\n source?: string; // 'manuell' | 'ki_serper' | 'user_verifiziert'\n}): Promise<{ ok: boolean; org_id?: number; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const orgBody: any = { name: input.name };\n if (input.city) orgBody.address = input.city;\n const orgRes = await fetch(base + '/organizations' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(orgBody),\n });\n const orgData = await orgRes.json();\n if (!orgData.success) return { ok: false, error: 'Org-Create: ' + JSON.stringify(orgData.error || {}).slice(0, 200) };\n const orgId = orgData.data.id;\n if (input.email && isGenericHvEmail(input.email)) {\n const personBody: any = {\n name: input.name + ' (Allgemein)',\n email: [{ value: input.email, primary: true, label: 'work' }],\n org_id: orgId,\n };\n await fetch(base + '/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(personBody),\n }).catch(() => { });\n }\n return { ok: true, org_id: orgId };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nasync function linkPersonToOrg(personId: number, orgId: number): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg || !personId || !orgId) return false;\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const r = await fetch(base + '/persons/' + personId + auth, {\n method: 'PUT',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ org_id: orgId }),\n });\n const d = await r.json();\n return !!d?.success;\n } catch (e) { console.warn('[Pipedrive] linkPersonToOrg:', e); return false; }\n}\n\nasync function createHvLead(input: {\n orgId: number;\n userFullName: string;\n userEmail?: string;\n savingsTotal?: number;\n checkNr: string;\n role: string;\n hvName: string;\n}): Promise<{ ok: boolean; lead_id?: string; error?: string }> {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return { ok: false, error: 'Pipedrive nicht konfiguriert' };\n const base = 'https://' + cfg.domain + '/api/v1';\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n let leadId: string | null = null;\n let reused = false;\n try {\n const lr = await fetch(base + '/leads?organization_id=' + input.orgId +\n '&archived_status=not_archived&limit=20&api_token=' + encodeURIComponent(cfg.token));\n const ld = await lr.json();\n if (ld?.success && Array.isArray(ld.data) && ld.data.length > 0) {\n const sorted = ld.data.slice().sort((a: any, b: any) =>\n String(b.add_time || '').localeCompare(String(a.add_time || '')));\n leadId = sorted[0].id;\n reused = true;\n }\n } catch (e) { }\n\n if (!leadId) {\n const title = '[HV-Lead] ' + input.hvName + ' — via Vorabcheck ' + input.checkNr;\n const leadBody: any = { title, organization_id: input.orgId };\n const lr = await fetch(base + '/leads' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(leadBody),\n });\n const ld = await lr.json();\n if (!ld.success) return { ok: false, error: 'HV-Lead: ' + JSON.stringify(ld.error || {}).slice(0, 200) };\n leadId = ld.data.id;\n }\n\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const stamp = new Date().toISOString().replace('T', ' ').slice(0, 16) + ' UTC';\n const roleLabel = input.role === 'eigentuemer' ? 'Eigentümer'\n : input.role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const noteLines = [\n '🕒 ' + stamp, '', 'HV-Lead aus Liftaro-Vorabcheck',\n 'Check-Nr: ' + input.checkNr, 'Auftraggeber: ' + input.userFullName + ' (' + roleLabel + ')',\n input.userEmail ? 'E-Mail: ' + input.userEmail : '',\n input.savingsTotal ? 'Sparpotenzial: ' + fmt(input.savingsTotal) + ' €/Jahr' : '',\n '', 'Follow-up: Einsparungsberechnung + Light-Paket',\n ].filter(Boolean);\n try {\n await fetch(base + '/notes' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteLines.join('\\n'), lead_id: leadId }),\n });\n } catch (e) { }\n\n console.log('[Pipedrive] HV-Lead ' + (reused ? 'reused' : 'created') + ':', leadId, 'org=' + input.orgId);\n return { ok: true, lead_id: leadId };\n } catch (e: any) {\n return { ok: false, error: 'Exception: ' + (e.message || String(e)) };\n }\n}\n\nlet _preisrefCache: any[] | null = null;\nlet _preisrefCacheTs = 0;\nconst PREISREF_CACHE_TTL_MS = 5 * 60 * 1000;\n\nasync function loadPreisreferenzen(): Promise {\n if (_preisrefCache && Date.now() - _preisrefCacheTs < PREISREF_CACHE_TTL_MS) return _preisrefCache;\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { _preisrefCache = []; _preisrefCacheTs = Date.now(); return []; }\n try {\n const res = await fetch(`https://api.airtable.com/v0/${base}/Preisreferenzen`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(\"HTTP \" + res.status);\n const data = await res.json();\n const list = (data.records || []).map((r: any) => ({\n position: r.fields?.position || '',\n einheit: r.fields?.einheit || '',\n median_eur: Number(r.fields?.median_eur || 0),\n region: r.fields?.region || '',\n notes: r.fields?.notes || '',\n })).filter((p: any) => p.position && p.median_eur > 0);\n _preisrefCache = list;\n _preisrefCacheTs = Date.now();\n return list;\n } catch (e) {\n console.warn(\"loadPreisreferenzen:\", e);\n return _preisrefCache || [];\n }\n}\n\nfunction deterministicSavingsFactor(seed: string): number {\n let h = 0;\n for (let i = 0; i < seed.length; i++) h = ((h << 5) - h + seed.charCodeAt(i)) | 0;\n return 0.30 + ((h >>> 0) % 1000) / 1000 * 0.30; // 0,30 – 0,60\n}\n\n\nfunction buildSystemPrompt(checkType: string, role: string, customMap: Record): string | null {\n if (customMap[checkType + '.' + role]) return customMap[checkType + '.' + role];\n if (customMap[checkType]) return customMap[checkType];\n\n const base = DEFAULT_SYSTEM_PROMPTS[checkType];\n if (!base) return null;\n const roleCtx = ROLE_CONTEXTS[role] || ROLE_CONTEXTS.mieter;\n return roleCtx + '\\n\\n────────────────────────────────────────\\n\\n' + base;\n}\n\n\nexport default async function (req: Request): Promise {\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n };\n if (req.method === \"OPTIONS\") return new Response(null, { headers: corsHeaders });\n if (req.method !== \"POST\") return jsonResp({ error: \"POST only\" }, 405, corsHeaders);\n\n try {\n const body = await req.json();\n\n if (body.action === 'contact') {\n const c = body.contact || {};\n const name = String(c.name || '').trim();\n const email = String(c.email || '').trim();\n if (!name || !email) return jsonResp({ ok: false, error: 'name und email sind Pflichtfelder' }, 400, corsHeaders);\n const firma = String(c.firma || '').trim();\n const telefon = String(c.telefon || '').trim();\n const paket = String(c.paket || 'andere').toLowerCase();\n const anzahl = parseInt(String(c.anzahl || '0'), 10) || 0;\n const nachricht = String(c.nachricht || '').trim();\n const paketLabel = paket === 'free' ? 'Free (50% Erfolgsbeteiligung)'\n : paket === 'light' ? 'Light (45 €/Monat je Aufzug)'\n : 'Andere / unklar';\n\n try {\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n const atBase = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (atKey && atBase) {\n await fetch('https://api.airtable.com/v0/' + atBase + '/Kontakt-Anfragen', {\n method: 'POST',\n headers: { Authorization: 'Bearer ' + atKey, 'Content-Type': 'application/json' },\n body: JSON.stringify({\n fields: {\n name, email,\n firma: firma || '',\n telefon: telefon || '',\n paket: paketLabel,\n anzahl_aufzuege: anzahl,\n nachricht: nachricht || '',\n savedAt: new Date().toISOString(),\n },\n }),\n });\n }\n } catch (e: any) { console.warn('[Kontakt] Airtable failed:', e.message); }\n\n const noteLines = [\n 'Quelle: Startseite Kontakt-Formular',\n 'Paket-Interesse: ' + paketLabel,\n anzahl ? 'Anzahl Aufzüge: ' + anzahl : 'Anzahl Aufzüge: –',\n 'Firma / Hausverwaltung: ' + (firma || '–'),\n 'Telefon: ' + (telefon || '–'),\n '',\n '— Nachricht —',\n nachricht || '(keine)',\n ];\n const pd = await createPipedriveLead({\n name,\n email,\n phone: telefon || undefined,\n org: firma || undefined,\n title: '[Inbound] ' + name + ' — ' + paketLabel + (anzahl ? ' (' + anzahl + ' Aufzug' + (anzahl === 1 ? '' : 'e') + ')' : ''),\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: pd }, 200, corsHeaders);\n }\n\n if (body.action === 'soft_capture') {\n const lead = body.lead || {};\n const ct = String(body.check_type || '').trim() || 'unbekannt';\n const fileMeta = body.file_meta || {};\n const name = ((String(lead.vorname || '').trim() + ' ' + String(lead.nachname || '').trim()).trim()) || 'Anonym';\n const email = String(lead.email || '').trim();\n const telefon = String(lead.telefon || '').trim();\n const adresse = String(lead.adresse || '').trim();\n const rolle = String(lead.rolle || '').trim();\n const firma = String(lead.firma || '').trim();\n if (!email) return jsonResp({ ok: false, error: 'email Pflicht' }, 400, corsHeaders);\n\n const noteLines = [\n '🟡 SOFT-LEAD — User hat Step 2 abgeschickt, Analyse läuft / könnte abbrechen',\n '',\n 'Quelle: Vorabcheck Public-Landing',\n 'Check-Typ: ' + ct,\n rolle ? 'Rolle: ' + rolle : '',\n adresse ? 'Adresse Objekt: ' + adresse : '',\n firma ? 'Firma: ' + firma : '',\n 'Telefon: ' + (telefon || '–'),\n fileMeta.name ? 'Hochgeladenes Dokument: ' + fileMeta.name : '',\n fileMeta.size ? 'Dateigröße: ' + Math.round(fileMeta.size / 1024) + ' KB' : '',\n ].filter(Boolean);\n\n const pd = await upsertPipedriveLead({\n name,\n email,\n phone: telefon || undefined,\n org: firma || undefined,\n title: '[Vorabcheck Start] ' + name + ' — ' + ct,\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: pd }, 200, corsHeaders);\n }\n\n if (body.action === 'request_liftaro_callback') {\n const c = body.cta || {};\n const userEmail = String(c.user_email || '').trim();\n const userName = String(c.user_name || '').trim() || userEmail || 'Anonym';\n const checkNr = String(c.check_nr || '').trim() || '—';\n const role = String(c.role || 'eigentuemer').trim();\n const savings = Number(c.savings_total_eur || 0);\n const hvName = String(c.hv_name || '').trim();\n if (!userEmail) return jsonResp({ ok: false, error: 'user_email Pflichtfeld' }, 400, corsHeaders);\n\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const roleLabel = role === 'eigentuemer' ? 'Eigentümer'\n : role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const noteLines = [\n '🔥 HOT-LEAD — User hat „Direktkontakt durch Liftaro\" angeklickt',\n '',\n 'User-Wunsch: Liftaro soll proaktiv binnen 24h kontaktieren.',\n '',\n 'Vorabcheck-Kontext:',\n ' Check-Nr: ' + checkNr,\n ' Rolle: ' + roleLabel,\n savings ? ' Sparpotenzial: ' + fmt(savings) + ' € / Jahr' : '',\n hvName ? ' Hausverwaltung (genannt): ' + hvName : ' Hausverwaltung: nicht angegeben',\n '',\n 'Empfehlung Vertrieb:',\n ' → Anruf oder persönliche Mail innerhalb 24h.',\n ' → Konkrete Einsparungsberechnung anbieten.',\n ' → Light-Paket-Pitch anschließen wenn passend.',\n ].filter(Boolean);\n\n const result = await upsertPipedriveLead({\n name: userName,\n email: userEmail,\n title: '🔥 [HOT] ' + userName + ' — wünscht Direktkontakt (' + checkNr + ')',\n note: noteLines.join('\\n'),\n });\n return jsonResp({ ok: true, pipedrive: result }, 200, corsHeaders);\n }\n\n if (body.action === 'list_property_managers') {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return jsonResp({ ok: false, error: 'pipedrive not configured' }, 500, corsHeaders);\n const lim = Math.min(parseInt(String(body.limit || '500'), 10) || 500, 500);\n try {\n const r = await fetch('https://' + cfg.domain + '/api/v1/organizations?start=0&limit=' + lim +\n '&api_token=' + encodeURIComponent(cfg.token));\n const d = await r.json();\n const orgs = (Array.isArray(d.data) ? d.data : []).map((o: any) => ({\n org_id: o.id, name: o.name || '', address: o.address || '',\n person_count: Number(o.people_count || 0),\n }));\n return jsonResp({ ok: true, results: orgs }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'get_property_manager_details') {\n const oid = parseInt(String(body.org_id || '0'), 10);\n if (!oid) return jsonResp({ ok: false, error: 'org_id required' }, 400, corsHeaders);\n const cfg = await loadPipedriveConfig();\n if (!cfg) return jsonResp({ ok: false, error: 'pipedrive not configured' }, 500, corsHeaders);\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n try {\n const oRes = await fetch('https://' + cfg.domain + '/api/v1/organizations/' + oid + auth);\n const oData = await oRes.json();\n if (!oData?.success) return jsonResp({ ok: false, error: 'org not found' }, 404, corsHeaders);\n const org = oData.data;\n const pRes = await fetch('https://' + cfg.domain + '/api/v1/organizations/' + oid + '/persons' + auth);\n const pData = await pRes.json();\n const persons = Array.isArray(pData?.data) ? pData.data : [];\n const genEmail = pickGenericEmailFromPersons(persons);\n let gfName = '', gfTel = '', gfEmail = '';\n const personalP = persons.find((p: any) => {\n const emails = Array.isArray(p?.email) ? p.email : [];\n return emails.some((e: any) => e?.value && !isGenericHvEmail(String(e.value)));\n });\n const firstP = personalP || persons[0];\n if (firstP) {\n gfName = String(firstP.name || '').replace(/\\s*\$Allgemein\$\\s*$/i, '').trim();\n gfEmail = String((Array.isArray(firstP.email) ? firstP.email : []).find((e: any) => e?.value)?.value || '');\n gfTel = String((Array.isArray(firstP.phone) ? firstP.phone : []).find((p: any) => p?.value)?.value || '');\n }\n let strasse = '', plz = '', ort = '';\n const addr = String(org.address || '').trim();\n if (addr) {\n const parts = addr.split(',').map((s: string) => s.trim()).filter(Boolean);\n if (parts.length >= 2) {\n strasse = parts[0];\n const m = parts[1].match(/^(\\d{4,5})\\s+(.+)$/);\n if (m) { plz = m[1]; ort = m[2]; } else ort = parts[1];\n } else { strasse = addr; }\n }\n return jsonResp({ ok: true, details: {\n org_id: org.id, firma: String(org.name || ''), gf: gfName,\n strasse, plz, ort, email: genEmail || gfEmail || '', tel: gfTel,\n } }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'get_verwalter_context') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const enc = encodeURIComponent(\"{check_nr}='\" + cn + \"'\");\n const [vr, lr] = await Promise.all([\n fetch('https://api.airtable.com/v0/' + b + '/Vorab-Checks?filterByFormula=' + enc + '&maxRecords=1',\n { headers: { Authorization: 'Bearer ' + k } }),\n fetch('https://api.airtable.com/v0/' + b + '/Vorabcheck-Leads?filterByFormula=' + enc + '&maxRecords=1',\n { headers: { Authorization: 'Bearer ' + k } }),\n ]);\n const vd = await vr.json(); const ld = await lr.json();\n const vc = vd?.records?.[0]?.fields;\n if (!vc) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const lead = ld?.records?.[0]?.fields || {};\n return jsonResp({ ok: true, ctx: {\n check_nr: cn,\n check_type: vc.check_type || '',\n ampel: vc.ampel || '',\n summary: vc.summary || '',\n savings_total_eur: Number(vc.savings_total_eur || vc.savings_estimate_eur || 0),\n savings_individual_eur: Number(vc.savings_individual_eur || 0),\n aufzug_count: Number(vc.aufzug_count || 0),\n parteien_count: Number(vc.parteien_count || 0),\n role: vc.role || '',\n eigentuemer_name: [lead.vorname, lead.nachname].filter(Boolean).join(' '),\n objekt_adresse: String(vc.objekt_adresse || lead.adresse || ''),\n hv_name: vc.hv_name || '',\n hv_email: vc.hv_email || '',\n hv_telefon: vc.hv_telefon || '',\n hv_adresse: vc.hv_adresse || '',\n hv_website: vc.hv_website || '',\n verwalter_status: vc.verwalter_status || 'offen',\n verwalter_name: vc.verwalter_name || '',\n verwalter_response_at: vc.verwalter_response_at || '',\n } }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'submit_verwalter_response') {\n const cn = String(body.check_nr || '').trim();\n const v = body.verwalter || {};\n const mode = String(body.mode || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n if (!v.name || !v.email) return jsonResp({ ok: false, error: 'name+email pflicht' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n verwalter_name: String(v.name || '').trim(),\n verwalter_email: String(v.email || '').trim(),\n verwalter_telefon: String(v.telefon || '').trim(),\n verwalter_response_mode: mode,\n verwalter_response_at: new Date().toISOString(),\n verwalter_status: 'antwort_erhalten',\n };\n const vFirma = String(v.firma || '').trim();\n if (vFirma) fields.verwalter_firma_name = vFirma;\n const vObj = String(v.objekt_adresse || '').trim();\n if (vObj) { fields.verwalter_objekt_adresse = vObj; fields.objekt_adresse = vObj; }\n if (body.responses) fields.verwalter_response_json = JSON.stringify(body.responses);\n if (mode === 'fragen' && body.responses && typeof body.responses === 'object') {\n const r: any = body.responses;\n if (r.anzahl_aufzuege) {\n const n = parseInt(String(r.anzahl_aufzuege), 10);\n if (n > 0 && n <= 50) fields.vertrag_anzahl_aufzuege = n;\n }\n if (r.wartungen) fields.vertrag_wartungen_pro_jahr = String(r.wartungen);\n if (r.vertragsart === 'voll') fields.vertrag_wartungstyp = 'Vollwartung';\n if (r.vertragsart === 'system') fields.vertrag_wartungstyp = 'Systemwartung';\n if (r.tuev_begl) fields.vertrag_tuev_begleitung = (r.tuev_begl === 'inkl');\n if (r.tuev_pruef) fields.vertrag_tuev_pruefung = (r.tuev_pruef === 'inkl');\n if (r.notruf) fields.vertrag_notruf = (r.notruf === 'inkl');\n fields.vertrag_extracted_at = new Date().toISOString();\n fields.vertrag_extracted_source = 'konfig';\n }\n if (body.pdf_base64 && body.pdf_base64.length > 100) {\n const fname = String(body.pdf_name || 'vertrag.pdf');\n try {\n const up = await fetch('https://content.airtable.com/v0/' + b + '/' + recId + '/verwalter_response_pdf/uploadAttachment', {\n method: 'POST', headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify({ contentType: String(body.pdf_mime || 'application/pdf'), filename: fname, file: body.pdf_base64 }),\n });\n if (!up.ok) fields.verwalter_response_pdf_name = fname + ' (Upload fehlgeschlagen)';\n } catch (e) { fields.verwalter_response_pdf_name = fname; }\n }\n await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 25);\n return jsonResp({ ok: true, applied_fields: Object.keys(fields) }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'set_bearbeiter_status') {\n const cn = String(body.check_nr || '').trim();\n const st = String(body.status || '').trim();\n const allowed = new Set(['offen', 'in_bearbeitung', 'erledigt']);\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n if (!allowed.has(st)) return jsonResp({ ok: false, error: 'status invalid' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n bearbeiter_status: st,\n bearbeiter_status_at: new Date().toISOString(),\n };\n if (body.bearbeiter_name) fields.bearbeiter_name = String(body.bearbeiter_name).trim();\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 10);\n return res.ok ? jsonResp({ ok: true, status: st }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'link_followup_check') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ ok: false, error: 'check_nr missing' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const fields: any = {\n linked_check_id: String(body.linked_check_id || '').trim(),\n linked_check_requestid: String(body.linked_check_requestid || '').trim(),\n linked_check_type: String(body.linked_check_type || '').trim(),\n linked_check_ersparnis: String(body.linked_check_ersparnis || '').trim(),\n linked_check_at: new Date().toISOString(),\n bearbeiter_status: 'in_bearbeitung',\n bearbeiter_status_at: new Date().toISOString(),\n };\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, fields, 15);\n return res.ok ? jsonResp({ ok: true, linked: fields.linked_check_requestid }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'sync_hv_pipedrive') {\n const hvName = String(body.hv_name || '').trim();\n if (!hvName) return jsonResp({ ok: false, error: 'hv_name pflicht' }, 400, corsHeaders);\n try {\n const ex = await findPipedriveOrgByName(hvName);\n if (ex?.id) return jsonResp({ ok: true, action: 'found', org_id: ex.id, org_name: ex.name || hvName }, 200, corsHeaders);\n const c = await createPipedriveOrgWithEmail({\n name: hvName,\n email: String(body.hv_email || '').trim() || undefined,\n city: String(body.hv_adresse || '').trim() || undefined,\n source: body.hv_adresse ? 'ki_web' : 'user_verifiziert',\n });\n if (!c.ok || !c.org_id) return jsonResp({ ok: false, error: 'create failed' }, 500, corsHeaders);\n try {\n const cfg = await loadPipedriveConfig();\n if (cfg && (body.check_nr || body.hv_telefon || body.hv_adresse)) {\n const note = 'Aus Liftaro-Vertragscheck' +\n (body.check_nr ? '\\nCheck-Nr: ' + body.check_nr : '') +\n (body.hv_telefon ? '\\nTel: ' + body.hv_telefon : '') +\n (body.hv_adresse ? '\\nAdresse: ' + body.hv_adresse : '');\n await fetch('https://' + cfg.domain + '/api/v1/notes?api_token=' + encodeURIComponent(cfg.token), {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: note, org_id: c.org_id }),\n }).catch(() => {});\n }\n } catch (_) {}\n return jsonResp({ ok: true, action: 'created', org_id: c.org_id }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'patch_objekt_adresse') {\n const cn = String(body.check_nr || '').trim();\n const addr = String(body.objekt_adresse || '').trim();\n if (!cn || !addr) return jsonResp({ ok: false, error: 'check_nr + objekt_adresse erforderlich' }, 400, corsHeaders);\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + cn + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + k } });\n const recId = (await fr.json())?.records?.[0]?.id;\n if (!recId) return jsonResp({ ok: false, error: 'check not found' }, 404, corsHeaders);\n const res = await atPatchRetry('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + recId, k, { objekt_adresse: addr });\n return res.ok ? jsonResp({ ok: true }, 200, corsHeaders) : jsonResp({ ok: false, error: res.error }, 500, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: e.message }, 500, corsHeaders); }\n }\n if (body.action === 'enrich_property_manager') {\n const name = String(body.name || '').trim();\n const city = String(body.city || '').trim();\n if (!name) return jsonResp({ ok: false, error: 'name required' }, 400, corsHeaders);\n let serperKey = String(Deno.env.get(\"SERPER_API_KEY\") || '').trim();\n if (!serperKey) {\n const atKey = Deno.env.get(\"AIRTABLE_KEY\");\n try {\n const url = 'https://api.airtable.com/v0/' + PIPEDRIVE_MASTER_BASE + '/Keys?filterByFormula=' +\n encodeURIComponent(\"AND({project_id}='\" + PIPEDRIVE_PROJECT_ID + \"',{key_name}='serperApiKey')\");\n const r = await fetch(url, { headers: { Authorization: 'Bearer ' + atKey } });\n const d = await r.json();\n serperKey = String(d?.records?.[0]?.fields?.key_value || '').trim();\n } catch (e) { /* */ }\n }\n if (!serperKey) return jsonResp({ ok: false, error: 'SERPER_API_KEY nicht konfiguriert (Env-Var oder Master-Base)' }, 500, corsHeaders);\n const q = '\"' + name + '\"' + (city ? ' ' + city : '') + ' Hausverwaltung Impressum';\n let snippets = '';\n try {\n const sr = await fetch('https://google.serper.dev/search', {\n method: 'POST',\n headers: { 'X-API-KEY': serperKey, 'Content-Type': 'application/json' },\n body: JSON.stringify({ q, gl: 'de', hl: 'de', num: 5 }),\n });\n const sd = await sr.json();\n const hits = Array.isArray(sd.organic) ? sd.organic.slice(0, 3) : [];\n snippets = hits.map((h: any) => 'URL: ' + (h.link || '') + '\\nTitel: ' + (h.title || '') + '\\nSnippet: ' + (h.snippet || '')).join('\\n\\n');\n } catch (e: any) { return jsonResp({ ok: false, error: 'Serper: ' + e.message }, 500, corsHeaders); }\n if (!snippets) return jsonResp({ ok: false, error: 'Keine Suchergebnisse' }, 404, corsHeaders);\n const anthropic = new Anthropic({ apiKey: Deno.env.get(\"ANTHROPIC_KEY\") });\n const sys = 'Du extrahierst Stammdaten von Hausverwaltungen aus Google-Suchergebnis-Snippets. WICHTIG: Gib NUR Werte zurueck, die WORTWOERTLICH in den Snippets vorkommen. Wenn ein Feld nicht eindeutig im Text steht, setze es auf null. Erfinde NICHTS. Antworte ausschliesslich als JSON ohne Fliesstext und ohne Markdown-Code-Block.';\n const userPrompt = 'Hausverwaltung: \"' + name + '\"' + (city ? ' in ' + city : '') + '\\n\\nExtrahiere die offiziellen Stammdaten.\\n\\nFormat:\\n{\\n \"strasse\": \"...\",\\n \"plz\": \"...\",\\n \"ort\": \"...\",\\n \"telefon\": \"...\",\\n \"email\": \"...\",\\n \"ustidnr\": \"DEXXXXXXXXX\",\\n \"steuernr\": \"...\",\\n \"website\": \"...\"\\n}\\n\\nSuchergebnisse:\\n' + snippets;\n try {\n const msg = await anthropic.messages.create({\n model: 'claude-haiku-4-5',\n max_tokens: 600,\n system: sys,\n messages: [{ role: 'user', content: userPrompt }],\n });\n const txt = (msg.content[0] as any)?.type === 'text' ? (msg.content[0] as any).text : '';\n const jm = txt.match(/\\{[\\s\\S]*\\}/);\n if (!jm) return jsonResp({ ok: false, error: 'KI hat keine Daten geliefert' }, 200, corsHeaders);\n const raw = JSON.parse(jm[0]);\n const snipLow = snippets.toLowerCase();\n const snipNoSpace = snipLow.replace(/\\s+/g, '');\n const data: any = {};\n for (const k of ['strasse','plz','ort','telefon','email','ustidnr','steuernr','website']) {\n const v = raw[k];\n if (v && typeof v === 'string' && v !== 'null' && v.trim().length > 1) {\n const vLow = String(v).toLowerCase();\n const vNoSpace = vLow.replace(/\\s+/g, '');\n if (snipLow.includes(vLow) || snipNoSpace.includes(vNoSpace)) {\n data[k] = String(v).trim();\n }\n }\n }\n return jsonResp({ ok: true, data, snippet_count: snippets.split('\\n\\n').length }, 200, corsHeaders);\n } catch (e: any) { return jsonResp({ ok: false, error: 'Claude: ' + e.message }, 500, corsHeaders); }\n }\n if (body.action === 'create_pm') {\n const n=String(body.name||'').trim(); if(!n) return jsonResp({ok:false,error:'name required'},400,corsHeaders);\n const e=String(body.email||'').trim(), s=String(body.strasse||'').trim(), c=String(body.city||'').trim(), t=String(body.tel||'').trim(), w=String(body.website||'').trim();\n const cr=await createPipedriveOrgWithEmail({name:n,email:e,city:s||c,website:w,source:'inbox_ki'});\n if(!cr.ok) return jsonResp(cr,200,corsHeaders);\n if(t||w||s){const cfg=await loadPipedriveConfig(); if(cfg){const note='🤖 Inbox-KI:\\n'+(s?'Adresse: '+s+(c?', '+c:'')+'\\n':'')+(t?'Telefon: '+t+'\\n':'')+(w?'Website: '+w+'\\n':''); await fetch('https://'+cfg.domain+'/api/v1/notes?api_token='+encodeURIComponent(cfg.token),{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({content:note,org_id:cr.org_id})}).catch(()=>{});}}\n return jsonResp({ok:true,org_id:cr.org_id,name:n},200,corsHeaders);\n }\n if (body.action === 'find_property_manager') {\n const q = String(body.query || '').trim();\n if (q.length < 3) return jsonResp({ ok: true, results: [] }, 200, corsHeaders);\n const orgs = await findPipedriveOrgsByName(q, 3);\n if (!orgs.length) return jsonResp({ ok: true, results: [], source: 'db' }, 200, corsHeaders);\n const enriched = await Promise.all(orgs.map(async (org: any) => {\n const email = await getOrgGenericEmail(org.id);\n return {\n org_id: org.id,\n name: org.name,\n email: email, // null wenn nur personalisierte Mails vorhanden\n city: org.address || '', // best-effort, Pipedrive-Adresse als Volltext\n confidence: email ? 100 : 60, // mit Email = sichere DB-Quelle\n };\n }));\n return jsonResp({ ok: true, source: 'db', results: enriched }, 200, corsHeaders);\n }\n\n if (body.action === 'submit_eigentuemer_cta') {\n const c = body.cta || {};\n const hvName = String(c.hv_name || '').trim();\n const hvEmail = String(c.hv_email || '').trim();\n const hvAddress = String(c.hv_address || '').trim();\n const hvTelefon = String(c.hv_telefon || '').trim();\n const hvWebsite = String(c.hv_website || '').trim();\n const userEmail = String(c.user_email || '').trim();\n const userName = String(c.user_name || '').trim() || userEmail || 'Anonym';\n const checkNr = String(c.check_nr || '').trim() || '—';\n const role = String(c.role || 'eigentuemer').trim();\n const savings = Number(c.savings_total_eur || 0);\n\n if (!hvName) return jsonResp({ ok: false, error: 'hv_name Pflichtfeld' }, 400, corsHeaders);\n\n try {\n let org = await findPipedriveOrgByName(hvName);\n let orgId: number | null = org?.id || null;\n let orgCreated = false;\n if (!orgId) {\n const created = await createPipedriveOrgWithEmail({\n name: hvName,\n email: isGenericHvEmail(hvEmail) ? hvEmail : undefined,\n city: hvAddress || undefined,\n source: hvAddress ? 'ki_web' : 'user_verifiziert',\n });\n if (created.ok && created.org_id) {\n orgId = created.org_id;\n orgCreated = true;\n if (hvTelefon || hvWebsite) {\n const cfgN = await loadPipedriveConfig();\n if (cfgN) {\n const noteContent = '🔍 Aus Web-Suche extrahiert:\\n' +\n (hvAddress ? 'Adresse: ' + hvAddress + '\\n' : '') +\n (hvTelefon ? 'Telefon: ' + hvTelefon + '\\n' : '') +\n (hvWebsite ? 'Website: ' + hvWebsite + '\\n' : '');\n await fetch('https://' + cfgN.domain + '/api/v1/notes?api_token=' + encodeURIComponent(cfgN.token), {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ content: noteContent, org_id: orgId }),\n }).catch(() => { /* non-critical */ });\n }\n }\n }\n }\n\n if (orgId && !orgCreated && hvEmail && isGenericHvEmail(hvEmail)) {\n const existingMail = await getOrgGenericEmail(orgId);\n if (!existingMail) {\n const cfg = await loadPipedriveConfig();\n if (cfg) {\n const auth = '?api_token=' + encodeURIComponent(cfg.token);\n await fetch('https://' + cfg.domain + '/api/v1/persons' + auth, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({\n name: hvName + ' (Allgemein)',\n email: [{ value: hvEmail, primary: true, label: 'work' }],\n org_id: orgId,\n }),\n }).catch(() => { });\n }\n }\n }\n\n let userPersonId: number | null = null;\n if (orgId && userEmail) {\n const cfg = await loadPipedriveConfig();\n if (cfg) {\n try {\n const searchUrl = 'https://' + cfg.domain + '/api/v1/persons/search?fields=email&exact_match=true&limit=5&term=' +\n encodeURIComponent(userEmail) + '&api_token=' + encodeURIComponent(cfg.token);\n const sr = await fetch(searchUrl);\n const sd = await sr.json();\n if (sd?.success && sd.data?.items?.length) {\n userPersonId = sd.data.items[0].item?.id || null;\n }\n } catch (e) { }\n }\n if (userPersonId) await linkPersonToOrg(userPersonId, orgId);\n }\n\n let hvLead: any = { ok: false };\n if (orgId) {\n hvLead = await createHvLead({\n orgId,\n userFullName: userName,\n userEmail,\n savingsTotal: savings,\n checkNr,\n role,\n hvName,\n });\n }\n\n try {\n const ak = Deno.env.get(\"AIRTABLE_KEY\"); const ab = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (ak && ab && checkNr && checkNr !== '—') {\n const fr = await fetch('https://api.airtable.com/v0/' + ab + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + checkNr + \"'\") + '&maxRecords=1', { headers: { Authorization: 'Bearer ' + ak } });\n const rId = (await fr.json())?.records?.[0]?.id;\n if (rId) {\n const hvFields: any = {};\n if (hvName) hvFields.hv_name = hvName;\n if (hvEmail) hvFields.hv_email = hvEmail;\n if (hvTelefon) hvFields.hv_telefon = hvTelefon;\n if (hvAddress) hvFields.hv_adresse = hvAddress;\n if (hvWebsite) hvFields.hv_website = hvWebsite;\n if (orgId) hvFields.hv_pipedrive_org_id = String(orgId);\n if (Object.keys(hvFields).length) {\n await atPatchRetry('https://api.airtable.com/v0/' + ab + '/Vorab-Checks/' + rId, ak, hvFields, 12);\n }\n }\n }\n } catch (e) { /* HV-Patch non-critical */ }\n return jsonResp({\n ok: true,\n org_id: orgId,\n org_created: orgCreated,\n user_person_id: userPersonId,\n hv_lead: hvLead,\n }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: 'Exception: ' + (e.message || String(e)) }, 500, corsHeaders);\n }\n }\n\n if (body.action === 'get_defaults') {\n return jsonResp({\n prompts: DEFAULT_SYSTEM_PROMPTS,\n role_contexts: ROLE_CONTEXTS,\n model: MODEL,\n backend_version: 'V9.90',\n backend_features: ['set_bearbeiter_status', 'link_followup_check', 'vertrag_mapping_konfig', 'patch_retry_on_unknown_field', 'ensure_vorabcheck_schema', 'verwalter_pdf_attachment'],\n }, 200, corsHeaders);\n }\n if (body.action === 'ensure_vorabcheck_schema') {\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return jsonResp({ ok: false, error: 'airtable nicht konfiguriert' }, 500, corsHeaders);\n const TARGET_FIELDS: any[] = VORABCHECK_TARGET_FIELDS;\n try {\n const schemaRes = await fetch('https://api.airtable.com/v0/meta/bases/' + b + '/tables', {\n headers: { Authorization: 'Bearer ' + k },\n });\n if (!schemaRes.ok) {\n const txt = await schemaRes.text();\n let hint = '';\n if (schemaRes.status === 403 || schemaRes.status === 401) {\n hint = ' — Dein Airtable-PAT braucht den Scope schema.bases:read und schema.bases:write. Erweitere ihn unter airtable.com/create/tokens.';\n }\n return jsonResp({ ok: false, error: 'Schema lesen fehlgeschlagen (HTTP ' + schemaRes.status + ')' + hint, raw: txt.slice(0, 300) }, schemaRes.status, corsHeaders);\n }\n const schema = await schemaRes.json();\n const tbl = schema.tables?.find((t: any) => t.name === 'Vorab-Checks');\n if (!tbl) return jsonResp({ ok: false, error: 'Tabelle „Vorab-Checks\" nicht gefunden' }, 404, corsHeaders);\n const existingNames = new Set(tbl.fields.map((f: any) => f.name));\n const created: string[] = [];\n const skipped: string[] = [];\n const failed: any[] = [];\n if (body.dry_run) {\n for (const field of TARGET_FIELDS) {\n if (existingNames.has(field.name)) skipped.push(field.name);\n else created.push(field.name);\n }\n return jsonResp({ ok: true, dry_run: true, would_create: created, already_exists: skipped, total_target: TARGET_FIELDS.length, table_id: tbl.id }, 200, corsHeaders);\n }\n for (const field of TARGET_FIELDS) {\n if (existingNames.has(field.name)) { skipped.push(field.name); continue; }\n const createRes = await fetch('https://api.airtable.com/v0/meta/bases/' + b + '/tables/' + tbl.id + '/fields', {\n method: 'POST',\n headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify(field),\n });\n if (createRes.ok) {\n created.push(field.name);\n } else {\n const txt = await createRes.text();\n failed.push({ name: field.name, status: createRes.status, error: txt.slice(0, 200) });\n }\n }\n return jsonResp({ ok: true, created, skipped, failed, total_target: TARGET_FIELDS.length, table_id: tbl.id }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: e.message }, 500, corsHeaders);\n }\n }\n if (body.action === 'ping') {\n return jsonResp({\n ok: true,\n backend_version: 'V9.90',\n backend_features: ['set_bearbeiter_status', 'link_followup_check', 'vertrag_mapping_konfig', 'patch_retry_on_unknown_field', 'ensure_vorabcheck_schema', 'verwalter_pdf_attachment'],\n model: MODEL,\n }, 200, corsHeaders);\n }\n\n if (body.action === 'correct') {\n const cn = String(body.check_nr || '').trim();\n if (!cn) return jsonResp({ error: 'check_nr fehlt' }, 400, corsHeaders);\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) return jsonResp({ ok: false, warning: 'Airtable nicht konfiguriert' }, 200, corsHeaders);\n const fields = body.fields || {};\n const records: any[] = [];\n Object.keys(fields).forEach(k => {\n const v = fields[k];\n if (v && v.changed) {\n records.push({\n fields: {\n check_nr: cn,\n field_name: k,\n original_value: String(v.original ?? ''),\n corrected_value: String(v.corrected ?? ''),\n savedAt: new Date().toISOString(),\n }\n });\n }\n });\n if (!records.length) return jsonResp({ ok: true, count: 0 }, 200, corsHeaders);\n try {\n const url = `https://api.airtable.com/v0/${base}/Vorabcheck-Korrekturen`;\n for (let i = 0; i < records.length; i += 10) {\n const batch = records.slice(i, i + 10);\n await fetch(url, {\n method: 'POST',\n headers: { Authorization: `Bearer ${key}`, 'Content-Type': 'application/json' },\n body: JSON.stringify({ records: batch }),\n });\n }\n return jsonResp({ ok: true, count: records.length }, 200, corsHeaders);\n } catch (e: any) {\n return jsonResp({ ok: false, error: e.message }, 500, corsHeaders);\n }\n }\n\n const { check_type, file, lead, turnstile_token, consent_given } = body;\n const role = ['mieter','eigentuemer','verwalter'].includes(body.role) ? body.role : 'mieter';\n const aufzugCountUser = Math.max(1, Math.min(50, parseInt(String(body.aufzug_count_user || '1'), 10) || 1));\n const wartungBruttoUser = Math.max(0, parseFloat(String(body.wartung_brutto_user || '0').replace(',', '.')) || 0);\n\n const turnstileSecret = Deno.env.get(\"TURNSTILE_SECRET_KEY\");\n const isDevBypass = String(turnstile_token || '') === 'dev-bypass-token';\n if (turnstileSecret && turnstile_token && !isDevBypass) {\n const ok = await verifyTurnstile(turnstile_token, turnstileSecret);\n if (!ok) return jsonResp({ error: \"Captcha ungültig\" }, 403, corsHeaders);\n }\n\n if (!consent_given) return jsonResp({ error: \"Einwilligung fehlt\" }, 400, corsHeaders);\n\n const custom = await loadCustomPrompts();\n let systemPrompt = buildSystemPrompt(check_type, role, custom);\n if (!systemPrompt) return jsonResp({ error: \"Unbekannter Check-Typ\" }, 400, corsHeaders);\n\n let preisrefList: any[] = [];\n if (check_type === 'angebot') {\n preisrefList = await loadPreisreferenzen();\n if (preisrefList.length) {\n const preisrefBlock =\n '\\n\\n═══════════════════════════════════════════\\n' +\n 'MARKTPREIS-REFERENZEN (verbindlich, NICHT VERHANDELBAR)\\n' +\n '═══════════════════════════════════════════\\n' +\n 'Diese Liste enthält den aktuellen Marktmedian je Position für Aufzug-Reparatur/Wartung. ' +\n 'Vergleiche JEDE Angebots-Position mit dieser Liste:\\n\\n' +\n preisrefList.map((p, i) =>\n (i + 1) + '. ' + p.position + ' — ' + p.median_eur.toFixed(2) + ' € pro ' + p.einheit +\n (p.region ? ' (' + p.region + ')' : '') +\n (p.notes ? ' — ' + p.notes : '')\n ).join('\\n') + '\\n\\n' +\n 'Wenn eine Angebots-Position in dieser Liste auftaucht: nutze den Median als Vergleichsbasis. ' +\n 'Die konkreten Median-€-Werte dürfen in deiner Antwort genannt werden, denn sie sind Liftaro-Marktdaten. ' +\n 'Wenn eine Angebots-Position NICHT in der Liste steht, gib in deiner JSON-Antwort ein Feld ' +\n '\"positions_nicht_in_liste\": [{titel, betrag_eur}] mit den entsprechenden Positionen zurück — ' +\n 'das Backend schätzt dafür einen Fallback-Wert.';\n systemPrompt = systemPrompt + preisrefBlock;\n }\n }\n\n const anthropic = new Anthropic({ apiKey: Deno.env.get(\"ANTHROPIC_KEY\") });\n const t0 = Date.now();\n\n const isPdf = file.mime === \"application/pdf\";\n const userContent: any[] = [\n {\n type: isPdf ? \"document\" : \"image\",\n source: { type: \"base64\", media_type: file.mime, data: file.base64 },\n },\n { type: \"text\", text: \"Prüfe das beigefügte Dokument gemäß den Vorgaben und antworte ausschließlich mit dem geforderten JSON. Falls im Dokument eine Objekt-, Liegenschafts- oder Gebäudeadresse erkennbar ist (z.B. 'Beispielstr. 12, 55116 Mainz'), gib sie zusätzlich als Top-Level-Feld 'objekt_adresse' (String, Format: 'Straße Hausnr., PLZ Ort') zurück. Wenn nicht eindeutig erkennbar, setze 'objekt_adresse' auf einen leeren String.\" },\n ];\n\n const response = await anthropic.messages.create({\n model: MODEL,\n max_tokens: 4096, // Erhöht von 2048 — komplexe Tabellen brauchen mehr Output-Spielraum\n system: systemPrompt,\n messages: [{ role: \"user\", content: userContent }],\n });\n\n const duration_ms = Date.now() - t0;\n const tokens_in = response.usage.input_tokens;\n const tokens_out = response.usage.output_tokens;\n const cost_eur = ((tokens_in * COST_PER_M_INPUT_TOKENS + tokens_out * COST_PER_M_OUTPUT_TOKENS) / 1_000_000) * USD_TO_EUR;\n\n const textBlock = response.content.find((c: any) => c.type === \"text\");\n const rawText = textBlock?.text || \"{}\";\n const cleaned = rawText.replace(/^```json\\s*|\\s*```$/g, \"\").trim();\n let result: any;\n try { result = JSON.parse(cleaned); }\n catch { return jsonResp({ error: \"KI-Antwort konnte nicht geparst werden\", raw: rawText }, 500, corsHeaders); }\n\n const checkNr = await generateCheckNr();\n result.check_nr = checkNr;\n\n await saveToAirtable({\n check_nr: checkNr,\n check_type,\n role,\n lead,\n result,\n file_name: file.name,\n cost_eur,\n tokens_in,\n tokens_out,\n model: MODEL,\n duration_ms,\n });\n\n let savingsTotal = Number(result.savings_total_eur || result.savings_estimate_eur || 0);\n const meaPool = Number(result.mea_pool_total || 0);\n const meaEigentuemer = Number(result.mea_eigentuemer || 0);\n\n if (check_type === 'nebenkosten') {\n const aufzugCount = aufzugCountUser;\n result.aufzug_count = aufzugCount; // Im Response konsistent halten\n let aufzugBrutto = 0;\n let bruttoSource = 'unknown'; // 'user' | 'ki' | 'regex' — für Transparenz\n\n if (wartungBruttoUser > 0) {\n aufzugBrutto = wartungBruttoUser;\n bruttoSource = 'user';\n if (!result.anonymized_data) result.anonymized_data = {};\n result.anonymized_data.betrag_aufzug_brutto = aufzugBrutto;\n console.log('[liftaro-vorabcheck] brutto vom User:', aufzugBrutto);\n } else {\n aufzugBrutto = Number(result.anonymized_data?.betrag_aufzug_brutto || 0);\n if (aufzugBrutto >= 500) bruttoSource = 'ki';\n\n if (!aufzugBrutto || aufzugBrutto < 500) {\n const haystack = String(result.summary || '') + ' ' +\n (result.findings || []).map(f => (f.title||'') + ' ' + (f.description||'')).join(' ');\n const matches = [...haystack.matchAll(/aufzug[a-zäöü\\s\\-/]*wartung[^0-9]{0,40}(\\d{1,3}(?:\\.\\d{3})*(?:,\\d{2})?|\\d{4,6}(?:,\\d{2})?)\\s*(?:€|eur)/gi)];\n if (matches.length) {\n const candidates = matches.map(m => parseFloat(m[1].replace(/\\./g, '').replace(',', '.'))).filter(n => n > 500);\n if (candidates.length) {\n aufzugBrutto = Math.max(...candidates);\n bruttoSource = 'regex';\n console.log('[liftaro-vorabcheck] brutto via Regex aus Klartext:', aufzugBrutto);\n }\n }\n }\n }\n\n const proAnlage = aufzugCount > 0 ? aufzugBrutto / aufzugCount : 0;\n\n if (proAnlage > 1200) {\n const correctTotal = Math.round((proAnlage - 980) * aufzugCount);\n const proAnlageStr = Math.round(proAnlage).toLocaleString('de-DE');\n const diffStr = Math.round(proAnlage - 980).toLocaleString('de-DE');\n const pctSavings = aufzugBrutto > 0 ? Math.round((correctTotal / aufzugBrutto) * 100) : 0;\n\n savingsTotal = correctTotal;\n result.savings_text = 'rund ' + pctSavings + ' % der bisherigen Wartungskosten durch marktgerechte Neuausschreibung';\n\n const summaryHasMarketClaim = /markt|median/i.test(String(result.summary || ''));\n const summaryIsConsistent = summaryHasMarketClaim && /über|ueber|deutlich|teuer/i.test(String(result.summary || ''));\n if (!summaryIsConsistent) {\n result.summary = 'Ihre Wartung kostet ' + proAnlageStr + ' € pro Jahr je Aufzug — das ist rund ' + diffStr + ' € mehr als der übliche Marktpreis für Wartung und Notruf. Optimierungspotenzial vorhanden.';\n }\n if (result.summary) {\n result.summary = String(result.summary).replace(/\\bvon\\s+9\\s?80\\s*(€|EUR)\\b/gi, '').replace(/\$?\\b9\\s?80\\s*(€|EUR)\\b\$?/gi, '').replace(/\\s{2,}/g, ' ').trim();\n }\n if (result.savings_text) {\n result.savings_text = String(result.savings_text).replace(/\\bvon\\s+9\\s?80\\s*(€|EUR)\\b/gi, '').replace(/\$?\\b9\\s?80\\s*(€|EUR)\\b\$?/gi, '').replace(/\\s{2,}/g, ' ').trim();\n }\n\n let findings = result.findings || [];\n findings = findings.filter(f => !/markt|wartung.*(zu\\s+(teuer|hoch)|ueber|über)|optimierung.*?wartung/i.test((f.title||'') + ' ' + (f.description||'')));\n findings.unshift({\n severity: proAnlage > 1800 ? 'warn' : (proAnlage > 1500 ? 'amber' : 'blue'),\n title: 'Wartung teurer als üblich',\n description: 'Die Wartung kostet ' + proAnlageStr + ' € pro Jahr je Aufzug — rund ' + diffStr + ' € mehr als der übliche Marktpreis. Bei einer Neuausschreibung zu marktüblichen Konditionen sparen Sie ' + correctTotal.toLocaleString('de-DE') + ' € pro Jahr.',\n tag: 'Liftaro-Marktreferenz · aktuell ' + proAnlageStr + ' EUR/Jahr',\n });\n\n result.findings = findings;\n\n if ((result.ampel === 'gruen' || result.ampel === 'grün') && proAnlage > 1500) {\n result.ampel = 'gelb';\n }\n\n console.log('[liftaro-vorabcheck] Markt-Override: brutto=' + aufzugBrutto + ', anlagen=' + aufzugCount + ', proAnlage=' + proAnlage + ', diff=' + diffStr + ', ersparnis=' + correctTotal);\n }\n\n if (role === 'eigentuemer' || role === 'verwalter') {\n const findings = result.findings || [];\n const hasRepairHint = findings.some(f => /reparatur.*(8\\.?000|einsparen|liftaro.*pr[üu]f|zus[äa]tzlich)/i.test((f.title||'') + ' ' + (f.description||'')));\n if (!hasRepairHint) {\n findings.push({\n severity: 'blue',\n title: 'Zusätzliches Sparpotenzial bei Reparaturen',\n description: 'Diese Schätzung berücksichtigt nur Wartung und Notruf. Unterjährige Reparaturen sind nicht eingerechnet — gerade dort steckt oft das größte Potenzial. Durch regelmäßige Überprüfung der Reparatur-Rechnungen durch Liftaro lassen sich im Einzelfall bis zu 8.000 € zusätzlich einsparen.',\n tag: 'Reparatur-Prüfung · Liftaro-Service',\n });\n result.findings = findings;\n }\n }\n }\n\n if (check_type === 'angebot') {\n const angebotsumme = Number(result.anonymized_data?.angebotssumme_brutto || result.anonymized_data?.angebotssumme_netto || 0);\n const positionsLeer = !Array.isArray(result.positions_nicht_in_liste) ? 0 : result.positions_nicht_in_liste.length;\n if (!savingsTotal && angebotsumme > 100) {\n const factor = deterministicSavingsFactor(checkNr);\n savingsTotal = Math.round(angebotsumme * factor);\n result.savings_total_eur = savingsTotal;\n result.savings_text = 'rund ' + Math.round(factor * 100) + ' % der Angebotssumme — Schätzwert ohne konkrete Preisliste';\n const findings = result.findings || [];\n findings.push({\n severity: 'amber',\n title: 'Schätzwert ohne Preislisten-Treffer',\n description: 'Keine Angebots-Position fand einen direkten Treffer in der Liftaro-Preisliste. Der ausgewiesene Ersparnis-Wert ist ein Schätzwert (zwischen 30–60 % der Angebotssumme, deterministisch aus der Check-Nr).',\n tag: 'Schätzwert · Preisliste-Lücke',\n });\n result.findings = findings;\n } else if (positionsLeer && savingsTotal) {\n const findings = result.findings || [];\n findings.push({\n severity: 'blue',\n title: 'Positionen ohne Preislisten-Referenz',\n description: positionsLeer + ' Angebots-Position(en) konnten nicht direkt gegen die Liftaro-Preisliste verglichen werden — diese Werte sind grobe Marktschätzungen.',\n tag: 'Preisliste-Lücke',\n });\n result.findings = findings;\n }\n\n if (role === 'eigentuemer' || role === 'verwalter') {\n const findings = result.findings || [];\n const hasRepairHint = findings.some(f => /reparatur.*(8\\.?000|einsparen|liftaro.*pr[üu]f|zus[äa]tzlich)/i.test((f.title||'') + ' ' + (f.description||'')));\n if (!hasRepairHint) {\n findings.push({\n severity: 'blue',\n title: 'Zusätzliches Sparpotenzial bei Reparaturen',\n description: 'Diese Schätzung berücksichtigt nur Wartung und Notruf. Unterjährige Reparaturen sind nicht eingerechnet — gerade dort steckt oft das größte Potenzial. Durch regelmäßige Überprüfung der Reparatur-Rechnungen durch Liftaro lassen sich im Einzelfall bis zu 8.000 € zusätzlich einsparen.',\n tag: 'Reparatur-Prüfung · Liftaro-Service',\n });\n result.findings = findings;\n }\n }\n }\n\n let savingsIndividual = Number(result.savings_individual_eur || 0);\n if (!savingsIndividual && savingsTotal > 0 && meaPool > 0 && meaEigentuemer > 0) {\n savingsIndividual = Math.round(savingsTotal * meaEigentuemer / meaPool);\n }\n\n if (lead?.email) {\n const fullName = ((lead.vorname || '') + ' ' + (lead.nachname || '')).trim() || lead.email;\n const roleLabel = role === 'eigentuemer' ? 'Eigentümer'\n : role === 'verwalter' ? 'Hausverwalter'\n : 'Mieter';\n const checkTypeLabel = check_type === 'nebenkosten' ? 'Nebenkostenabrechnung'\n : check_type === 'angebot' ? 'Angebot'\n : 'Wartungsvertrag';\n const ampelLabel = result.ampel === 'rot' ? '🔴 Rot' : result.ampel === 'gelb' ? '🟡 Gelb' : result.ampel === 'gruen' ? '🟢 Grün' : '–';\n const fmt = (n: number) => Math.round(n).toLocaleString('de-DE');\n const noteLines = [\n '✅ ANALYSE ' + checkNr,\n '', 'Rolle: ' + roleLabel, 'Check-Typ: ' + checkTypeLabel, 'Ampel: ' + ampelLabel,\n savingsTotal ? 'Ersparnis Haus: ' + fmt(savingsTotal) + ' €/Jahr' : '',\n savingsIndividual ? 'Anteil indiv.: ' + fmt(savingsIndividual) + ' €/Jahr' : '',\n 'Adresse: ' + (lead.adresse || '–'), '',\n '— Zusammenfassung —', result.summary || '(keine)',\n ].filter(Boolean);\n const title = '[Vorabcheck] ' + fullName + ' — ' + roleLabel + ' (' + checkNr + ')';\n upsertPipedriveLead({ name: fullName, email: lead.email, phone: lead.telefon || undefined, title, note: noteLines.join('\\n') })\n .then(async (pd: any) => {\n if (!pd.ok || !pd.lead_id) return;\n const k = Deno.env.get(\"AIRTABLE_KEY\"); const b = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!k || !b) return;\n try {\n const fr = await fetch('https://api.airtable.com/v0/' + b + \"/Vorab-Checks?filterByFormula=\" + encodeURIComponent(\"{check_nr}='\" + checkNr + \"'\"),\n { headers: { Authorization: 'Bearer ' + k } });\n const rec = (await fr.json())?.records?.[0]?.id;\n if (!rec) return;\n await fetch('https://api.airtable.com/v0/' + b + '/Vorab-Checks/' + rec, {\n method: 'PATCH', headers: { Authorization: 'Bearer ' + k, 'Content-Type': 'application/json' },\n body: JSON.stringify({ fields: { pipedrive_lead_id: pd.lead_id, pipedrive_person_id: String(pd.person_id || '') } }),\n });\n } catch (e) { /* */ }\n }).catch(e => console.warn('[Pipedrive] Vorabcheck failed:', e?.message || e));\n }\n\n const aufzugPositionen = Array.isArray(result.aufzug_positionen)\n ? result.aufzug_positionen\n .filter((p: any) => p && (p.text || p.betrag_eur))\n .map((p: any) => ({ text: String(p.text || '').trim(), betrag_eur: Number(p.betrag_eur || 0) }))\n : [];\n let aufzugGesamtkosten = Number(result.aufzug_gesamtkosten_eur || 0);\n if (!aufzugGesamtkosten && aufzugPositionen.length) {\n aufzugGesamtkosten = aufzugPositionen.reduce((s, p) => s + (Number(p.betrag_eur) || 0), 0);\n }\n\n return jsonResp({\n ampel: result.ampel,\n summary: result.summary,\n findings: result.findings || [],\n aufzug_count: aufzugCountUser,\n aufzug_positionen: aufzugPositionen,\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n wartung_brutto_used: Number(result.anonymized_data?.betrag_aufzug_brutto || wartungBruttoUser || 0),\n wartung_brutto_source: wartungBruttoUser > 0 ? 'user' : 'ki', // Transparenz: woher kam der Wartungs-Wert?\n verteilerschluessel: String(result.verteilerschluessel || 'unbekannt'),\n parteien_count: Number(result.parteien_count || 0),\n mea_pool_total: meaPool,\n mea_eigentuemer: meaEigentuemer,\n savings_total_eur: savingsTotal,\n savings_individual_eur: savingsIndividual,\n savings_estimate_eur: savingsTotal, // Legacy für altes Frontend\n savings_text: result.savings_text || \"\",\n check_nr: checkNr,\n role: role,\n objekt_adresse: String(result.objekt_adresse || result.anonymized_data?.objekt_adresse || result.anonymized_data?.gebaeude_adresse || result.anonymized_data?.liegenschaft_adresse || '').trim(),\n }, 200, corsHeaders);\n\n } catch (e: any) {\n console.error(\"[liftaro-vorabcheck]\", e);\n return jsonResp({ error: e.message || \"Server-Fehler\" }, 500, corsHeaders);\n }\n}\n\nfunction jsonResp(body: any, status: number, headers: Record) {\n return new Response(JSON.stringify(body), {\n status,\n headers: { ...headers, \"Content-Type\": \"application/json\" },\n });\n}\n\nasync function verifyTurnstile(token: string, secret: string): Promise {\n const res = await fetch(\"https://challenges.cloudflare.com/turnstile/v0/siteverify\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: `secret=${encodeURIComponent(secret)}&response=${encodeURIComponent(token)}`,\n });\n const json = await res.json();\n return !!json.success;\n}\n\nasync function generateCheckNr(): Promise {\n const year = new Date().getFullYear();\n const random = Math.floor(Math.random() * 9000) + 1000;\n return `VC-${year}-${random}`;\n}\n\nasync function saveToAirtable(data: {\n check_nr: string;\n check_type: string;\n role: string;\n lead: any;\n result: any;\n file_name: string;\n cost_eur: number;\n tokens_in: number;\n tokens_out: number;\n model: string;\n duration_ms: number;\n}) {\n const key = Deno.env.get(\"AIRTABLE_KEY\");\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n if (!key || !base) { console.warn(\"Airtable-Keys fehlen — überspringe Persistenz\"); return; }\n const at = `https://api.airtable.com/v0/${base}`;\n const headers = { \"Authorization\": `Bearer ${key}`, \"Content-Type\": \"application/json\" };\n\n async function atPostSafe(tableUrl: string, fieldsIn: Record) {\n const fields = { ...fieldsIn };\n for (let i = 0; i < 20; i++) {\n try {\n const r = await fetch(tableUrl, { method: 'POST', headers, body: JSON.stringify({ fields }) });\n if (r.ok) return;\n const txt = await r.text();\n let badField = '';\n try {\n const j = JSON.parse(txt);\n const msg = j?.error?.message || j?.error || '';\n const m = String(msg).match(/Unknown field name:\\s*\"([^\"]+)\"/i);\n if (m) badField = m[1];\n } catch (_) { /* nicht JSON */ }\n if (badField && Object.prototype.hasOwnProperty.call(fields, badField)) {\n delete fields[badField];\n console.warn('[Airtable] retry ohne unbekanntes Feld:', badField);\n continue;\n }\n console.warn('[Airtable]', tableUrl.slice(-30), 'POST fehlgeschlagen:', txt.slice(0, 200));\n return;\n } catch (e: any) { console.warn('[Airtable]', tableUrl, e.message); return; }\n }\n }\n\n const totalEur = Number(data.result.savings_total_eur || data.result.savings_estimate_eur || 0);\n const indivEur = Number(data.result.savings_individual_eur || 0);\n\n await atPostSafe(`${at}/Vorabcheck-Leads`, {\n check_nr: data.check_nr,\n check_type: data.check_type,\n role: data.role,\n vorname: data.lead.vorname,\n nachname: data.lead.nachname,\n email: data.lead.email,\n telefon: data.lead.telefon || \"\",\n adresse: data.lead.adresse,\n file_name: data.file_name,\n savedAt: new Date().toISOString(),\n });\n\n const aufzugPositionen = Array.isArray(data.result.aufzug_positionen) ? data.result.aufzug_positionen : [];\n const aufzugPositionenText = aufzugPositionen\n .map((p: any) => (p.text || '') + ': ' + (Number(p.betrag_eur || 0).toLocaleString('de-DE', { minimumFractionDigits: 2, maximumFractionDigits: 2 })) + ' €')\n .join('\\n');\n let aufzugGesamtkosten = Number(data.result.aufzug_gesamtkosten_eur || 0);\n if (!aufzugGesamtkosten && aufzugPositionen.length) {\n aufzugGesamtkosten = aufzugPositionen.reduce((s: number, p: any) => s + (Number(p.betrag_eur) || 0), 0);\n }\n const aufzugCount = Number(data.result.aufzug_count || 0);\n const kostenProAufzugEur = aufzugCount > 0\n ? Math.round((aufzugGesamtkosten / aufzugCount) * 100) / 100\n : 0;\n const objektAdresse = String(\n data.result.objekt_adresse ||\n data.result.anonymized_data?.objekt_adresse ||\n data.result.anonymized_data?.gebaeude_adresse ||\n data.result.anonymized_data?.liegenschaft_adresse ||\n data.lead?.adresse || ''\n ).trim();\n\n await atPostSafe(`${at}/Vorab-Checks`, {\n check_nr: data.check_nr,\n check_type: data.check_type,\n role: data.role,\n ampel: data.result.ampel,\n summary: data.result.summary,\n savings_estimate_eur: totalEur,\n savings_total_eur: totalEur,\n savings_individual_eur: indivEur,\n aufzug_count: aufzugCount,\n parteien_count: Number(data.result.parteien_count || 0),\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n kosten_pro_aufzug_eur: kostenProAufzugEur,\n aufzug_positionen_text: aufzugPositionenText,\n aufzug_positionen_json: JSON.stringify(aufzugPositionen),\n objekt_adresse: objektAdresse,\n findings_json: JSON.stringify(data.result.findings || []),\n anonymized_data_json: JSON.stringify(data.result.anonymized_data || {}),\n savedAt: new Date().toISOString(),\n });\n\n await atPostSafe(`${at}/API-Cost-Log`, {\n check_nr: data.check_nr,\n endpoint: \"vorabcheck\",\n model: data.model,\n tokens_in: data.tokens_in,\n tokens_out: data.tokens_out,\n cost_eur: Math.round(data.cost_eur * 10000) / 10000,\n duration_ms: data.duration_ms,\n savedAt: new Date().toISOString(),\n });\n}\n",[136],"pulls","branches","forks","envVars",{"_151":153,"_154":60},"connections",{"_151":60,"_152":60},"count","unfilledCount",4,"emptyCount",{"_42":135,"_32":136,"_30":137,"_129":-5,"_40":41,"_39":138,"_130":121,"_37":161,"_13":140,"_33":141,"_34":142,"_24":25,"_133":-5,"_158":162,"_27":163},{"_42":128,"_32":28,"_30":31,"_129":-5,"_40":41,"_39":14,"_130":25,"_37":157,"_13":132,"_33":20,"_34":36,"_24":25,"_133":-5,"_158":159,"_27":160},["D",1779802331340],"children",[],[28],["D",1779484776927],[],[136],["D",1778712174884],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":25},{"_13":83,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"ctx",{"_76":-5,"_123":201,"_202":203,"_204":205,"_206":25,"_207":25,"_208":25,"_209":121,"_210":-5,"_211":-7,"_212":-7,"_213":60,"_214":25,"_215":25,"_216":-5,"_217":25,"_218":25,"_219":25,"_220":-5},"ENV",{"_172":173,"_174":175,"_176":84,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200},"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 · v51