[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",24,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.tsx","latestPath","fileId","1540a80c-4f1d-11f1-8df2-ee650bb23af1","name","fileType","http","content","// ---\n// LIFTARO VORABCHECK — val.town HTTP-Endpoint\n//\n// Setup-Anleitung:\n// 1. Auf val.town anmelden (kostenlos): https://www.val.town\n// 2. Neuen HTTP val anlegen (z.B. \"liftaroVorabcheck\")\n// 3. Diesen Code einfügen\n// 4. Im val.town Secrets-Tab folgende Variablen anlegen:\n// - ANTHROPIC_KEY (dein Anthropic API Key)\n// - TURNSTILE_SECRET_KEY (Cloudflare Turnstile Secret)\n// - AIRTABLE_KEY (dein Airtable Personal Access Token)\n// - AIRTABLE_BASE_ID (Base-ID der Liftaro-Base, z.B. appXXXX)\n// 5. Den Endpoint deployen\n// 6. Die HTTP-URL aus dem val (z.B. https://USERNAME-liftaroVorabcheck.web.val.run)\n// ins Frontend bei LIFTARO_API_URL eintragen\n// ---\n\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.30.0\";\n\n// ---\n// Konfiguration\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\n// ---\n// Prompt-Loader — liest Custom-Prompts aus Airtable mit 5-Min-Cache.\n// Fallback auf die hardcoded DEFAULT_SYSTEM_PROMPTS weiter unten.\n// ---\nlet _promptCache: Record | null = null;\nlet _promptCacheTs = 0;\nconst PROMPT_CACHE_TTL_MS = 5 * 60 * 1000;\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\n// ---\n// Pipedrive-Integration: Lead pro Vorabcheck + pro Kontaktformular.\n// Token & Domain liegen in der Liftaro-Master-Base als Keys\n// 'pipedriveDomain' und 'pipedriveApiToken'. 5-Min-Cache.\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 // Legacy-Wrapper — leitet auf den neuen upsertPipedriveLead um (Dedup-fähig).\n return upsertPipedriveLead(input);\n}\n\n// ---\n// upsertPipedriveLead — Dedup per Email:\n// 1. Person via Email-Suche finden, sonst anlegen\n// 2. Vorhandenen offenen (nicht-archivierten) Lead der Person nutzen,\n// sonst neuen anlegen\n// 3. Note in jedem Fall ANHÄNGEN (Verlauf bleibt erhalten)\n//\n// Resultat: 1 Pipedrive-Lead pro Kontakt, alle Touchpoints als Notes.\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 // 1a) Person-Suche per Email\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 // Erstes exaktes Match\n personId = sd.data.items[0].item?.id || null;\n if (personId) personExisted = true;\n }\n } catch (e) { }\n }\n\n // 1b) Person anlegen, wenn nicht gefunden\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 // 2) Organization (optional) — nur bei neuen Personen / neuen Leads\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 // 3a) Existierenden, nicht-archivierten Lead der Person finden\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 // Neuesten offenen Lead nehmen (Pipedrive sortiert default ASC nach Erstelldatum)\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 // 3b) Neuen Lead anlegen, wenn keiner offen ist\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 // 4) Note IMMER anhängen — egal ob neuer oder reused Lead\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\n// ---\n// HAUSVERWALTUNGS-SUCHE (Phase 1: Pipedrive-DB-Lookup, Phase 4: Serper+KI)\n// ---\n// Whitelist für allgemeine, nicht-personalisierte Geschäfts-Mails einer HV.\n// Nur diese Local-Parts gelten als \"öffentlich\" und werden auto-befüllt.\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 // Exakter Match: \"info@…\" → true. \"info.maier@…\" → false (zu spezifisch).\n return HV_GENERIC_EMAIL_PREFIXES.includes(local);\n}\n\n// Persons einer Organization → erste generische (allgemeine) Email zurückgeben.\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\n// Pipedrive-Org-Suche nach Namen — strikt (case-insensitive Substring-Check)\n// + Score-Schwelle, damit Pipedrive's Fuzzy-Search keine zufälligen Treffer durchlässt.\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 // Substring-Match: term muss case-insensitive im Namen vorkommen\n const nameLow = String(x.item.name).toLowerCase();\n if (!nameLow.includes(termLow)) return false;\n // Score-Schwelle: 0.3 ist ein moderater Cut-Off, Pipedrive's Top-Match liegt typisch bei 0.5-1.0\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\n// Single-Treffer-Wrapper für Submit-Pfad\nasync function findPipedriveOrgByName(name: string): Promise {\n const hits = await findPipedriveOrgsByName(name, 1);\n return hits.length ? hits[0] : null;\n}\n\n// Allgemeine Geschäfts-Email einer Org aus den verknüpften Persons holen.\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\n// Org in Pipedrive anlegen (für KI-Fallback, Phase 4).\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 // Custom-Field „Quelle\" + Website können später hinzugefügt werden, sobald\n // die Field-IDs in Pipedrive bekannt sind. Vorerst nur Name + optional Address.\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 // Wenn allgemeine Email vorhanden: als „Default-Person\" der Org anlegen\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\n// Person an Org linken (User → HV-Org).\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\n// HV-Lead erzeugen — separater Lead aus B2B-Sicht.\n// Pipeline: orgId ist der „Eigentümer\" des Leads (B2B-Pipeline).\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 // 1. Existierenden offenen HV-Lead suchen → Dedup pro Org\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 // 2. Neuen HV-Lead anlegen wenn keiner offen\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 // 3. Note mit Vorabcheck-Kontext anhängen (jedes Mal)\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,\n '',\n 'HV-Lead automatisch erzeugt aus einem Liftaro-Vorabcheck.',\n '',\n 'Trigger-Vorabcheck:',\n ' Check-Nr: ' + input.checkNr,\n ' Rolle des Auftraggebers: ' + roleLabel,\n ' Name: ' + input.userFullName,\n input.userEmail ? ' E-Mail: ' + input.userEmail : '',\n input.savingsTotal ? ' Identifiziertes Sparpotenzial: ' + fmt(input.savingsTotal) + ' € / Jahr' : '',\n '',\n 'Vertriebs-Aufhänger:',\n ' Der Auftraggeber hat das Sparpotenzial bereits an diese HV weitergeleitet.',\n ' Möglicher Folgekontakt: Konkrete Einsparungsberechnung + Light-Paket-Angebot.',\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\n// ---\n// Preisreferenzen — Marktmedian-Liste pro Angebots-Position.\n// Wird bei check_type=angebot der KI als Kontext mitgegeben.\n// 5-Min-Cache wie bei den Custom-Prompts.\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\n// Deterministischer Pseudo-Random aus check_nr (für Fallback wenn KI nichts in Preisliste findet).\n// 30 % bis 60 % Ersparnis vom Angebotsbetrag — Wert pro check_nr stabil.\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// ---\n// Rollen-spezifischer Kontext, der vor jeden Default-Prompt\n// gehängt wird. Sorgt für die korrekte rechtliche Einordnung\n// (Mieter vs. WEG-Eigentümer vs. Verwalter).\n// ---\nconst ROLE_CONTEXTS: Record = {\n mieter: `ROLLEN-KONTEXT: MIETER (Wohnraum-Mietvertrag)\n\nDer Nutzer ist Mieter. Folgendes gilt rechtlich:\n- § 2 BetrKV definiert abschließend, welche Kosten als Betriebskosten umgelegt werden dürfen.\n- Aufzug-Wartung, Strom, Aufsicht/Bedienung, TÜV/ZÜS-Prüfung, Reinigung → umlagefähig.\n- Reparaturen, Instandsetzung, Modernisierung, Verwaltungskosten → NICHT umlagefähig (§ 1 Abs. 2 BetrKV).\n- Bei Vollwartungsverträgen MUSS ein Vorwegabzug für Instandsetzungs-Anteile erfolgen (BGH VIII ZR 123/14, ca. 20–50 % je Vertragsumfang). Fehlender Vorwegabzug = unzulässige Umlage.\n- § 556 Abs. 3 BGB: 12 Monate Einwendungsfrist ab Erhalt der Nebenkostenabrechnung.\n- Erdgeschoss-Mieter: Aufzugskosten nur dann zulässig, wenn vertraglich vereinbart (LG-Rechtsprechung uneinheitlich).\n\n⚠ VORSICHTS-REGEL für Mieter (sehr wichtig):\nMarkiere einen Posten NUR DANN als rechtswidrig/fehlerhaft (Severity \"warn\"/Ampel \"rot\"), wenn der Verstoß\nEINDEUTIG aus dem Dokument hervorgeht. Beispiele für eindeutig:\n · Position \"Reparatur Aufzug\" oder \"Instandsetzung Aufzug\" wird unter umlagefähige Betriebskosten gezogen.\n · Position \"Modernisierung Aufzug\" wird umgelegt.\n · Explizit erwähnter Vollwartungsvertrag OHNE Vorwegabzug.\nNICHT als Fehler markieren bei (nicht eindeutigen Hinweisen):\n · Hohe Wartungspauschale alleine — kann viele plausible Gründe haben (Anlagengröße, Hochhaus, Notruf, Hersteller-Service).\n · Unklarer Vertragstyp — wenn das Dokument nicht eindeutig Vollwartung sagt: kein Vorwegabzug-Befund.\n · Nicht erkennbare Verteilerschlüssel-Diskussion (Erdgeschoss etc.) — ohne Vertragsklausel-Info bleibt das spekulativ.\nBei Unsicherheit: severity \"blue\" (Hinweis \"bitte separat prüfen lassen\") oder \"amber\" — NIEMALS \"warn\" auf Verdacht.\nDie Ampel \"rot\" darf nur kommen, wenn es mindestens einen \"warn\"-Befund mit eindeutiger Belegstelle aus dem Dokument gibt.\n\nSPRACHE: Bei eindeutigen Verstößen klar und durchsetzungs-orientiert formulieren mit §-Bezug (z.B. \"Verstoß gegen § 1 Abs. 2 BetrKV\"). Bei Zweifelsfällen offen formulieren (\"Hinweis\", \"bitte prüfen lassen\", \"ggf. separat klären\"). KEINE Rechtsberatung.`,\n\n eigentuemer: `ROLLEN-KONTEXT: EIGENTÜMER (WEG-Mitglied oder Selbstnutzer)\n\nDer Nutzer ist Eigentümer. Folgendes gilt:\n- Alle Aufzugskosten (Wartung, Reparatur, Instandsetzung) werden in der WEG-Abrechnung umgelegt — es gibt KEINE Umlage-Beschränkung wie bei Mietern.\n- Relevante Prüfung: Marktangemessenheit der Konditionen, Vertragsoptimierungs-Potenzial, Vollwartung vs. Teilwartung, Servicestunden-Sätze, Vertragslaufzeit/Kündigungsfristen.\n- Befunde wie \"Reparaturen versteckt\" sind hier KEIN Rechtsverstoß, sondern Transparenz-/Verhandlungs-Argument.\n- Eigentümer kann als Vertragspartner direkt eine Optimierung anstoßen.\n\nSPRACHE: Sachlich, wirtschaftlich orientiert. §-Bezug nur wo relevant (z.B. WEG-Recht bei Verteilerschlüssel). Fokus auf konkrete Einsparungs-Hebel.`,\n\n verwalter: `ROLLEN-KONTEXT: HAUSVERWALTER (Verwaltungsmandat)\n\nDer Nutzer ist Hausverwalter. Folgendes gilt:\n- Verwaltet möglicherweise mehrere Anlagen → Ersparnis-Hochrechnung \"pro Anlage + portfolio-weit\" ist besonders relevant.\n- Hat Verantwortung gegenüber Eigentümern (WEG) bzw. Vermietern und muss wirtschaftlich + rechtssicher handeln.\n- Kann als Vertragspartner direkt Vertragsoptimierungen einleiten.\n- Relevante Prüfung: Optimierungs-Hebel, Compliance-Risiken (z.B. fehlender Vorwegabzug bei Mieter-Umlage), Marktbenchmarks.\n\nSPRACHE: Professionell, knapp, kennzahlen-orientiert. Bezugnahme auf §§ wo relevant — insbesondere bei Konstellationen, wo Mietumlage betroffen ist (dann Mietrecht-Hinweis).`,\n};\n\nfunction buildSystemPrompt(checkType: string, role: string, customMap: Record): string | null {\n // 1. Custom-Prompt aus Airtable bevorzugen (Schlüssel \"checkType.role\" oder \"checkType\")\n if (customMap[checkType + '.' + role]) return customMap[checkType + '.' + role];\n if (customMap[checkType]) return customMap[checkType];\n\n // 2. Default-Prompt + Rollen-Kontext vorne anhängen\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// ---\n// DEFAULT-System-Prompts pro Check-Typ (Fallback, wenn nichts in\n// Airtable hinterlegt ist).\n//\n// HINWEIS: Diese Default-Prompts werden zur Laufzeit mit einem\n// rollen-spezifischen Vorspann (siehe ROLE_CONTEXTS) kombiniert.\n// ---\nconst DEFAULT_SYSTEM_PROMPTS: Record = {\n nebenkosten: `Du bist Aufzug-Experte und Bau-/Mietrechts-Analyst bei Liftaro. Du prüfst Nebenkostenabrechnungen auf die Aufzug-Position.\n\n═══════════════════════════════════════════\nTASK 1 (HÖCHSTE PRIORITÄT): DATEN EXTRAHIEREN\n═══════════════════════════════════════════\nSuche im Dokument die Aufzug-Wartungs-Position. Typische Bezeichnungen:\n · \"Aufzugskosten/Wartung/TÜV\"\n · \"Aufzugswartung Haus X\"\n · \"Aufzugswartung\"\n · \"Aufzug Wartung\"\n · \"Wartung Aufzug\"\n · \"Aufzugskosten\" (wenn nichts spezifischeres da ist)\n\nDaraus extrahiere den **GESAMT-Wartungsbetrag** — das ist der Wert in der\nGESAMT-Spalte (auch genannt: \"Gesamt\", \"Verteilungsrelevante Beträge\",\n\"Ausgaben Gesamt\", \"Brutto\"). Das ist NICHT \"Ihr Anteil\" / \"Ihr Betrag\".\n\nKONKRETE BEISPIELE (du musst genau lesen können):\n\nBeispiel A — tabellarisch mit MEA-Schlüssel:\n Konto Bezeichnung Verteilungsrelevante Beträge Schlüssel Gesamt Ihr Anteil Ihr Betrag\n 5000 Aufzugskosten/Wartung/TÜV 8.832,46 MEA 10000 81 71,54\n → betrag_aufzug_brutto = 8832.46 (NICHT 71.54!)\n\nBeispiel B — Haus-Position:\n Aufzugswartung Haus 9 Miteigentumsanteile 17.051 1.263 2.100,00 155,55\n → betrag_aufzug_brutto = 2100.00 (NICHT 155.55!)\n\nBeispiel C — Einfach:\n Aufzugswartung 450,00 € (Einheit)\n → betrag_aufzug_brutto = 450.00\n\nWichtige Regeln zur Extraktion:\n- IMMER den größten EUR-Wert der Aufzug-Wartungs-Zeile nehmen, NIE den Eigentümer-Anteil\n- Bei mehreren Aufzug-Wartungs-Positionen (z.B. mehrere Häuser): ADDIERE die Gesamt-Werte\n- Wenn du dir bei einem Wert nicht 100 % sicher bist: 0 zurückgeben, NIE raten\n- Tausender-Trenner ist Punkt, Dezimal-Komma: \"8.832,46\" = 8832.46\n\n═══════════════════════════════════════════\nTASK 2: RECHTLICHE BEWERTUNG (kurz)\n═══════════════════════════════════════════\n\n🎯 ZWEI SEPARATE BEWERTUNGEN — IMMER BEIDE DURCHFÜHREN:\n\nA) RECHTLICHE KORREKTHEIT (steuert \"ampel\" + warn-Findings)\n - Wird die Abrechnung rechtlich/formal korrekt aufgestellt?\n - Bei sauberer Trennung umlagefähig/nicht-umlagefähig: Ampel \"gruen\"\n - Bei eindeutigen Verstößen: Ampel \"gelb\"/\"rot\"\n\nB) MARKT-OPTIMIERUNG (steuert \"savings_total_eur\" — UNABHÄNGIG von A!)\n - Vergleich der Wartungskosten mit dem Liftaro-Marktmedian (980 €/Anlage/Jahr).\n - Eine \"rechtlich saubere\" Abrechnung kann trotzdem WIRTSCHAFTLICH überteuert sein —\n das ist KEIN Rechtsverstoß, aber ein Optimierungs-Hinweis für den Auftraggeber.\n - Markt-Optimierung IMMER durchführen, auch wenn Ampel \"gruen\" ist.\n - Bei Wartung über Median: Erzeuge ein \"amber\" oder \"blue\" Finding \"Optimierungspotenzial:\n Wartungspauschale X EUR liegt Y EUR über dem Marktmedian von 980 EUR. Geschätzte Ersparnis\n bei Neuausschreibung: Z EUR/Jahr.\"\n - savings_total_eur = (tatsächliche_Wartung_pro_Anlage − 980) × Anzahl_Aufzüge\n (exakte Differenz zum Marktmedian — kein Sicherheits-/Verhandlungsfaktor abziehen)\n (NICHT mehr null setzen, nur weil Ampel grün ist!)\n - savings_text z.B. \"rund X % der bisherigen Wartungskosten durch marktgerechte Konditionen\"\n\n⚠ ANTI-HALLUZINATIONS-REGEL (sehr wichtig):\n- Stelle NIE Behauptungen auf, die nicht direkt aus dem Dokument belegbar sind.\n- \"Vollwartungsvertrag\" darfst Du NUR annehmen, wenn das Wort/der Begriff (oder eindeutige Synonyme wie \"Vollwartung\", \"inkl. Reparaturen\", \"all-inclusive Wartung\") tatsächlich im Dokument steht.\n- Wenn nur eine Position \"Wartung\" und separat eine Position \"Instandhaltung/Reparatur\" auftaucht → das spricht STARK GEGEN Vollwartung. In diesem Fall KEIN Vorwegabzug-Befund erzeugen.\n- Wenn Du den Vertragstyp aus dem Dokument NICHT bestimmen kannst → \"vollwartung_erwaehnt\": false und KEIN Finding zum Vorwegabzug. Stattdessen optional ein blue-Finding: \"Vertragstyp unklar — bitte Wartungsvertrag separat prüfen lassen.\"\n\n⚠ ZUSÄTZLICHE VORSICHTS-REGEL bei Mieter-Rolle:\nBei Nebenkostenabrechnungen, die einem MIETER vorgelegt werden, gilt: Markiere die Abrechnung NUR DANN als\nfehlerhaft (Ampel \"rot\" oder Severity \"warn\"), wenn der Fehler OFFENSICHTLICH und EINDEUTIG aus dem Dokument\nhervorgeht (z.B. eine Position \"Reparatur Aufzug\" steht klar unter umlagefähigen Betriebskosten, oder ein\nausdrücklicher Vollwartungsvertrag ohne ausgewiesenen Vorwegabzug). Wenn nur ein Verdacht besteht oder das\nDokument unklar ist → severity \"blue\"/\"amber\" (Hinweis statt Verstoß), Ampel \"gruen\" oder \"gelb\".\nLiftaro will Mieter NICHT zu unbegründeten Streitigkeiten ermutigen — nur bei eindeutigen Verstößen klare Kante.\n\nPRÜFE FOLGENDE PUNKTE:\n\n1. UMLAGEFÄHIGKEIT (§ 2 Nr. 7 BetrKV)\n - Umlagefähig: Wartung, Strom, Aufsicht, TÜV (ZÜS), Reinigung\n - NICHT umlagefähig (§ 1 Abs. 2 BetrKV): Reparaturen, Instandsetzung, Modernisierung\n - Bei Mieter: Verstöße klar als solche benennen mit §-Bezug.\n - Bei Eigentümer/Verwalter: als Transparenz-Hinweis formulieren (kein Rechtsverstoß).\n - WICHTIG: Wenn Instandhaltung in der Abrechnung BEREITS unter \"nicht umlagefähig\" geführt wird → das ist KORREKT, kein Verstoß. Lobe das ausdrücklich.\n\n2. VOLLWARTUNGSVERTRAG — nur prüfen wenn EXPLIZIT erwähnt\n - Voraussetzung: Das Dokument erwähnt Vollwartung wörtlich.\n - Bei expliziter Vollwartung + Mieter-Umlage muss ein Vorwegabzug für Instandsetzung erfolgen (20–50 %, BGH VIII ZR 123/14).\n - Wenn nicht ausgewiesen UND Vollwartung explizit → Rotflag bei Mieter.\n - Bei separat ausgewiesener Instandhaltung → KEIN Vollwartungs-Vermutung, KEIN Vorwegabzug-Befund.\n\n3. WARTUNGSPAUSCHALE — LIFTARO-REFERENZWERT (verbindlich, NICHT VERHANDELBAR)\n - **Marktmedian Wohnaufzug INKL. Notruf/Bereitschaftsdienst: 980 €/Jahr je Anlage**\n - Dieser Wert ist die Liftaro-Referenz aus Marktdaten. Verwende ihn als HARTE Vergleichsbasis. Erfinde KEINE anderen Median-Werte.\n - **WICHTIG — Diskretion bei der Ausgabe:** Den konkreten Wert \"980 €\" NIE wörtlich in summary, savings_text oder findings nennen. Stattdessen sprich vom \"branchenüblichen Marktmedian\", \"Marktreferenz für Wartung und Notruf\" oder \"marktüblichem Vergleichswert\". Die Differenz und die Ersparnis dürfen genannt werden — nur die Median-Zahl selbst nicht.\n\n PFLICHT-RECHENGANG (immer durchführen):\n a) Hole den Aufzug-Brutto-Betrag aus der Abrechnung (z.B. \"Aufzugswartung Haus 9: 2.100 €\")\n b) Teile durch aufzug_count (z.B. 2.100 / 1 = 2.100 € pro Anlage und Jahr)\n c) Vergleiche mit 980 €:\n · pro_anlage ≤ 1.200 → marktüblich, kein Befund (savings_total_eur = 0)\n · 1.200 < pro_anlage ≤ 1.500 → leicht erhöht (blue/amber-Hinweis)\n · 1.500 < pro_anlage ≤ 1.800 → deutlich über Markt (amber/warn)\n · pro_anlage > 1.800 → KLAR ZU TEUER (warn, konkrete Ersparnis ausweisen)\n d) Ersparnis bei Neuausschreibung zum Median = (pro_anlage − 980) × aufzug_count\n (KEINEN Verhandlungs-Faktor abziehen — wenn der Vertrag auf Median geht, ist genau das die Ersparnis.)\n\n KONKRETES BEISPIEL (für Konsistenz-Check):\n \"Aufzugswartung Haus 9: 2.100 €, 1 Aufzug\"\n → pro_anlage = 2.100 €\n → 2.100 > 1.800 → KLAR ZU TEUER\n → savings_total_eur = (2.100 − 980) × 1 = 1.120 € (intern berechnen, NICHT den Median-Wert anzeigen)\n → savings_text = \"rund 53 % der bisherigen Wartungskosten durch Neuausschreibung zu marktüblichen Konditionen\"\n → summary muss das WIDERSPIEGELN, NICHT \"unter Marktmedian\" behaupten!\n → finding-Description: \"liegt rund 1.120 € über dem branchenüblichen Marktmedian\" (KEINE konkrete 980-Zahl!)\n\n VERBOT: Schreibe NIE \"unter Marktmedian\" oder \"marktüblich\" wenn pro_anlage > 1.200 €.\n Achtung: Hohe Beträge können in Sondersituationen gerechtfertigt sein (hochwertige/seltene Anlage, mehrere Wartungen p.a., Großgebäude mit ständigem Notruf-Bedarf). Bei Anhaltspunkten dafür: Befund-Severity um eine Stufe abmildern — aber NICHT die mathematische Aussage drehen.\n\n4. SERVICESTUNDEN-SATZ\n - Marktüblich 95–125 €/h, regional unterschiedlich\n - >140 €/h → gelb, >160 €/h → rot\n\n5. ANZAHL WARTUNGEN P.A.\n - TRBS 1201 Teil 4: 2 Wartungen/Jahr für Wohnaufzüge ausreichend\n - 4 Wartungen → gelb (kann ok sein bei stark genutzten Anlagen)\n\n6. VERTEILUNGSSCHLÜSSEL\n - Erdgeschoss-Mieter zahlt nur wenn vertraglich vereinbart (Mieter-spezifisch)\n - Übliche Schlüssel: m² Wohnfläche oder Person oder Miteigentumsanteile (MEA)\n\n7. FRIST § 556 Abs. 3 BGB (nur Mieter)\n - 12 Monate ab Erhalt der Abrechnung für Einwendungen\n\n8. ANLAGEN-ERFASSUNG (immer extrahieren — wichtig für Hochrechnung)\n - aufzug_count: Wie viele Aufzüge sind in der Abrechnung enthalten?\n · \"Aufzugswartung Haus 9\" → 1 Aufzug\n · \"Aufzugswartung Haus 9, 11, 15\" → 3 Aufzüge\n · Wenn nicht ersichtlich → 0 (heißt: unbekannt)\n\n - verteilerschluessel: WELCHER Schlüssel wird für die Aufzug-Position genutzt?\n · \"mea\" → Miteigentumsanteile (üblich bei WEG)\n · \"qm\" → Wohnfläche\n · \"einheit\" → gleichmäßig pro Wohneinheit\n · \"person\" → pro Person\n · \"unbekannt\" → wenn nicht ersichtlich\n\n - WENN verteilerschluessel === \"mea\" (Miteigentumsanteile):\n · mea_pool_total: Die GESAMT-MEA der Aufzug-Position (das ist NICHT 100.000 — sondern nur die Summe für den Aufzug-Verteilerschlüssel, z.B. 17.051 für \"Aufzugswartung Haus 9\").\n · mea_eigentuemer: Der MEA-Anteil des anfragenden Eigentümers an der Aufzug-Position (z.B. 1.263).\n · parteien_count: NUR setzen, wenn aus dem Dokument klar hervorgeht, wie viele Parteien sich den Aufzug-Pool teilen. Sonst 0. NIE die \"73 Einheiten\" einer anderen Position (z.B. Hausreinigung) übernehmen — der Aufzug betrifft oft nur EIN Haus mit weniger Parteien.\n\n - WENN verteilerschluessel === \"einheit\" (gleiche Anzahl pro Partei):\n · parteien_count: Anzahl Einheiten am Verteilerschlüssel der Aufzug-Position direkt (z.B. wenn Aufzug-Position \"Einheiten 13\" → 13 Parteien).\n · mea_pool_total / mea_eigentuemer leer/0 lassen.\n\n - WENN verteilerschluessel === \"qm\" oder \"person\":\n · Beides leer lassen (nur individuelle Berechnung aus \"Ihr Anteil EUR\" möglich).\n · parteien_count: 0, sofern nicht eindeutig ableitbar.\n\n - Mathematische Konsistenz: Die KI MUSS sicherstellen, dass aufzug_count * Wartung pro Anlage ≈ Gesamt-Aufzug-Position. Wenn das nicht passt → Werte korrigieren.\n\nANTWORTE NUR MIT JSON, OHNE MARKDOWN-CODE-BLOCKS:\n{\n \"ampel\": \"gruen\" | \"gelb\" | \"rot\",\n \"summary\": \"Ein-Satz-Bewertung\",\n \"findings\": [\n {\n \"severity\": \"warn\" | \"amber\" | \"blue\",\n \"title\": \"Kurze Überschrift\",\n \"description\": \"1–2 Sätze Erklärung mit konkreten Beträgen wenn möglich\",\n \"tag\": \"z.B. § 2 Nr. 7 BetrKV oder Position 4.2\"\n }\n ],\n \"aufzug_count\": Zahl (Anzahl erkannter Aufzüge in der Abrechnung, 0 wenn unklar),\n \"verteilerschluessel\": \"mea\" | \"qm\" | \"einheit\" | \"person\" | \"unbekannt\",\n \"parteien_count\": Zahl (NUR bei verteilerschluessel \"einheit\" oder \"person\", sonst 0 — siehe Regel oben),\n \"mea_pool_total\": Zahl (Gesamt-MEA der Aufzug-Position, NUR bei verteilerschluessel \"mea\"; sonst 0),\n \"mea_eigentuemer\": Zahl (MEA-Anteil des Anfragenden, NUR bei verteilerschluessel \"mea\"; sonst 0),\n \"savings_total_eur\": Zahl (geschätzte jährliche Gesamtersparnis fürs ganze Haus in EUR, 0 wenn keine),\n \"savings_individual_eur\": Zahl (geschätzte jährliche Ersparnis für die anfragende Partei in EUR — bei MEA: savings_total_eur * mea_eigentuemer / mea_pool_total; bei Einheit: savings_total_eur / parteien_count; 0 wenn nicht berechenbar),\n \"savings_estimate_eur\": Zahl (Legacy-Feld; identisch zu savings_total_eur),\n \"savings_text\": \"z.B. 'rund 40% der bisherigen Aufzug-Kosten'\",\n \"anonymized_data\": {\n \"abrechnungszeitraum\": \"z.B. 2024\",\n \"betrag_aufzug_brutto\": Zahl (ABSOLUTER Wartungsbetrag aus Zeile \"Aufzugswartung … X EUR\" Gesamt-Spalte; NICHT die Differenz zum Median, NICHT der Eigentümer-Anteil, NICHT die Ersparnis. Bei \"Aufzugswartung Haus 9: 2.100 EUR\" → 2100.),\n \"verteilerschluessel\": \"mea\" | \"qm\" | \"einheit\" | \"person\" | \"unbekannt\",\n \"vollwartung_erwaehnt\": true | false,\n \"vorwegabzug_ausgewiesen\": true | false,\n \"anzahl_wartungen\": Zahl | null,\n \"anzahl_aufzuege\": Zahl,\n \"mea_pool_total\": Zahl,\n \"anbieter_branche\": \"kone\" | \"schindler\" | \"tk-elevator\" | \"otis\" | \"sonstige\" | \"unbekannt\"\n },\n \"aufzug_positionen\": [\n { \"text\": \"Wörtlicher Positionsname aus der Abrechnung (z.B. 'Aufzugskosten/Wartung/TÜV')\",\n \"betrag_eur\": Zahl (Gesamt-Betrag dieser Position; aus der Gesamt-Spalte) }\n ],\n \"aufzug_gesamtkosten_eur\": Zahl (Summe ALLER Aufzug-bezogenen Positionen aus der Abrechnung — Wartung, Notruf, Instandhaltung, TÜV, Strom, etc. zusammen)\n}\n\nWICHTIG zu aufzug_positionen + aufzug_gesamtkosten_eur:\n- Finde JEDE Zeile in der Abrechnung, die \"Aufzug\" / \"Aufzugs…\" im Namen enthält (Wartung, Instandhaltung, Notruf, TÜV, Strom Aufzugsanlage, …).\n- Übernimm den Positions-Text 1:1 wörtlich aus der Abrechnung (kein Umformulieren, kein Kürzen).\n- betrag_eur ist immer der GESAMT-Betrag der Zeile (aus der Gesamt-Spalte), NICHT der Eigentümer-Anteil.\n- aufzug_gesamtkosten_eur = Summe aller betrag_eur in aufzug_positionen. Beide Felder müssen konsistent sein.\n- Wenn keine Aufzug-Position gefunden: leeres Array [] und 0.\n\nWICHTIG: anonymized_data darf KEINE personenbezogenen Daten enthalten (keine Namen, Adressen, Kontonummern).`,\n\n angebot: `Du bist Aufzug-Experte bei Liftaro. Du prüfst Reparatur- oder Wartungs-Angebote auf Plausibilität.\n\nPRÜFE:\n1. Marktüblichkeit der Positionspreise (Reparaturkomponenten, Servicestunden)\n2. Vollständigkeit (Gewährleistung, Lieferzeit, Anschrift, Steuer-ID)\n3. Auffällige Klauseln (lange Bindefristen, Preisgleitklauseln)\n4. Anlagen-Bezug: wie viele Aufzüge betrifft das Angebot? Welche Anzahl Parteien profitiert?\n\nLIFTARO-REFERENZWERTE (verbindlich, aus Marktdaten):\n- Wartungspauschale inkl. Notruf: **Median 980 €/Jahr** je Wohnaufzug\n- Servicestunden-Satz: 95–125 €/h Wohnaufzug, 110–145 €/h Gewerbe\n- Bei Wartungsangeboten > ~1.500 €/Jahr deutlich über Markt → konkret Ersparnis ausweisen\n- Geschätzte Ersparnis bei Neuausschreibung = (Angebotsbetrag − 980) (exakte Differenz)\n\nBei Mieter: §-Bezug bei umlagefähigkeitsrelevanten Themen (Reparatur vs. Wartung).\nBei Eigentümer/Verwalter: wirtschaftlich/sachlich.\n\nANTWORTE NUR MIT JSON:\n{\n \"ampel\": \"gruen\" | \"gelb\" | \"rot\",\n \"summary\": \"...\",\n \"findings\": [{ \"severity\": \"warn\"|\"amber\"|\"blue\", \"title\": \"...\", \"description\": \"...\", \"tag\": \"...\" }],\n \"aufzug_count\": Zahl,\n \"parteien_count\": Zahl,\n \"savings_total_eur\": Zahl,\n \"savings_individual_eur\": Zahl,\n \"savings_estimate_eur\": Zahl,\n \"savings_text\": \"...\",\n \"anonymized_data\": {\n \"angebotssumme_netto\": Zahl,\n \"angebotssumme_brutto\": Zahl,\n \"gewaehrleistung_monate\": Zahl | null,\n \"lieferzeit_wochen\": Zahl | null,\n \"anzahl_aufzuege\": Zahl,\n \"anbieter_branche\": \"...\"\n }\n}`,\n\n vertrag: `Du bist Aufzug-Experte bei Liftaro. Du prüfst Wartungsverträge auf ungünstige Konditionen.\n\nPRÜFE:\n1. Laufzeit & Kündigungsfrist (typisch: 3 Monate vor Ablauf, max. 5 Jahre Erstlaufzeit)\n2. Vertragstyp (Voll- vs. Teilwartung) — bei Mieter-Umlage: Vorwegabzug-Pflicht für Instandsetzung (BGH VIII ZR 123/14)\n3. Preisgleitklauseln\n4. Anzahl Wartungen p.a. (TRBS 1201 Teil 4)\n5. Bereitschaftsdienst / Notruf-Kosten\n6. Anzahl Anlagen im Vertrag + Anzahl Parteien zur Ersparnis-Hochrechnung\n\nLIFTARO-REFERENZWERTE (verbindlich, aus Marktdaten):\n- Wartungspauschale inkl. Notruf/Bereitschaft: **Median 980 €/Jahr** je Wohnaufzug\n- Bewertung pro Anlage:\n · bis ~1.200 €/Jahr → marktüblich\n · 1.200–1.500 € → leicht erhöht (Hinweis)\n · 1.500–1.800 € → deutlich über Markt (amber/warn, Optimierung nennen)\n · über 1.800 € → klar zu teuer (warn, Ersparnis konkret ausweisen)\n- Geschätzte Ersparnis bei Neuausschreibung = (Vertragsbetrag − 980) (exakte Differenz)\n- Bei mehreren Anlagen im Vertrag immer pro Anlage rechnen (Summe ÷ Anzahl)\n\nBei Mieter: Mietrechtliche Konsequenzen mit §-Bezug benennen, wenn die Vertragsgestaltung die Umlagefähigkeit beeinflusst.\nBei Eigentümer/Verwalter: Optimierungs- und Verhandlungs-Hebel.\n\nANTWORTE NUR MIT JSON:\n{\n \"ampel\": \"gruen\" | \"gelb\" | \"rot\",\n \"summary\": \"...\",\n \"findings\": [{ \"severity\": \"warn\"|\"amber\"|\"blue\", \"title\": \"...\", \"description\": \"...\", \"tag\": \"...\" }],\n \"aufzug_count\": Zahl,\n \"parteien_count\": Zahl,\n \"savings_total_eur\": Zahl,\n \"savings_individual_eur\": Zahl,\n \"savings_estimate_eur\": Zahl,\n \"savings_text\": \"...\",\n \"anonymized_data\": {\n \"vertragstyp\": \"vollwartung\" | \"teilwartung\" | \"unbekannt\",\n \"laufzeit_jahre\": Zahl | null,\n \"kuendigungsfrist_monate\": Zahl | null,\n \"kosten_pro_jahr\": Zahl,\n \"anzahl_wartungen\": Zahl | null,\n \"anzahl_aufzuege\": Zahl,\n \"anzahl_parteien\": Zahl,\n \"anbieter_branche\": \"...\"\n }\n}`,\n};\n\n// ---\n// Hauptfunktion\n// ---\nexport default async function (req: Request): Promise {\n // CORS für GitHub-Pages-Frontend\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 // ---\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 // 1) Airtable-Backup (best-effort)\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 // 2) Pipedrive-Lead anlegen\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 // ---\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 // Async — Frontend muss nicht warten\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 // ---\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 // ---\n // Liefert Top-3 Treffer (Substring-Match) zum User-Auswählen — User sieht echte Org-Namen statt\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 // Pro Treffer: generische Email holen (parallel)\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 // ---\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 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 // 1) HV-Org finden ODER anlegen\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 source: 'user_verifiziert',\n });\n if (created.ok && created.org_id) { orgId = created.org_id; orgCreated = true; }\n }\n\n // 2) Wenn HV-Org existiert aber Email noch leer → user-übergebene Mail nachtragen (nur generisch)\n if (orgId && !orgCreated && hvEmail && isGenericHvEmail(hvEmail)) {\n const existingMail = await getOrgGenericEmail(orgId);\n if (!existingMail) {\n // Anonyme Default-Person mit der Mail an die Org hängen\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 // 3) User-Lead via Email finden → an Org linken\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 // 4) HV-Lead anlegen (separater B2B-Lead)\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 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 // ---\n if (body.action === 'get_defaults') {\n return jsonResp({\n prompts: DEFAULT_SYSTEM_PROMPTS,\n role_contexts: ROLE_CONTEXTS,\n model: MODEL,\n }, 200, corsHeaders);\n }\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 // Airtable: max 10 Records pro POST-Batch\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 // Rolle normalisieren (Default = mieter, falls Frontend keinen Wert sendet)\n const role = ['mieter','eigentuemer','verwalter'].includes(body.role) ? body.role : 'mieter';\n // Vom Nutzer bestätigte Aufzug-Anzahl (Frontend-Pflichtfeld). Default 1.\n const aufzugCountUser = Math.max(1, Math.min(50, parseInt(String(body.aufzug_count_user || '1'), 10) || 1));\n // Optionaler User-Wert für die Wartungssumme. > 0 = User hat Wert eingetragen → Vorrang vor KI.\n const wartungBruttoUser = Math.max(0, parseFloat(String(body.wartung_brutto_user || '0').replace(',', '.')) || 0);\n\n // 1. Turnstile validieren (wenn konfiguriert)\n const turnstileSecret = Deno.env.get(\"TURNSTILE_SECRET_KEY\");\n if (turnstileSecret && turnstile_token) {\n const ok = await verifyTurnstile(turnstile_token, turnstileSecret);\n if (!ok) return jsonResp({ error: \"Captcha ungültig\" }, 403, corsHeaders);\n }\n\n // 2. Consent prüfen\n if (!consent_given) return jsonResp({ error: \"Einwilligung fehlt\" }, 400, corsHeaders);\n\n // 3. Check-Type validieren + Prompt zusammenbauen (Rolle-Kontext + Default)\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 // 3b. Bei Angebots-Checks: Preisreferenzen als Kontext anhängen, damit die KI\n // jede Angebots-Position gegen den Marktmedian aus Airtable prüfen kann.\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 // 4. Anthropic-Call\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.\" },\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 // 5. JSON parsen\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 // 6. Check-Nummer erzeugen\n const checkNr = await generateCheckNr();\n result.check_nr = checkNr;\n\n // 7. Lead + Vorab-Check in Airtable speichern\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 // 8. Return — nur die Daten, die das Frontend braucht\n // savings_total_eur ist die Gesamthaus-Ersparnis (Fallback: legacy savings_estimate_eur)\n // savings_individual_eur ist die Ersparnis für die anfragende Partei\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 // SICHERHEITSNETZ A: Markt-Ersparnis IMMER selbst rechnen — der KI-Rechnung wird NICHT mehr vertraut.\n // Strategie: brutto-Wartungsbetrag erstmal aus anonymized_data lesen, sonst per Regex aus\n // dem Klartext (summary + findings) extrahieren. Dann mit Median 980 €/Anlage/Jahr vergleichen.\n if (check_type === 'nebenkosten') {\n // User-Angabe hat Vorrang vor KI-Schätzung (aus Dokument oft nicht eindeutig ableitbar)\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 // Höchste Priorität: User hat den Wert manuell eingetragen\n aufzugBrutto = wartungBruttoUser;\n bruttoSource = 'user';\n // anonymized_data konsistent halten — User-Wert auch dort speichern\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 // Fallback 1: KI-extrahierter Wert aus anonymized_data\n aufzugBrutto = Number(result.anonymized_data?.betrag_aufzug_brutto || 0);\n if (aufzugBrutto >= 500) bruttoSource = 'ki';\n\n // Fallback 2: Regex aus Klartext, wenn KI-Wert fehlt oder verdächtig klein\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 // Authoritative Berechnung — überschreibt IMMER die KI-Werte, wenn der Markt-Vergleich greift\n if (proAnlage > 1200) {\n // Ersparnis = exakte Differenz zwischen aktuellem Wartungspreis und Marktmedian.\n // Kein \"Verhandlungsfaktor\" mehr — wenn neu ausgeschrieben wird, ist genau das die\n // erreichbare Ersparnis.\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 // pctSavings = exakter prozentualer Anteil (Differenz/Brutto)\n const pctSavings = aufzugBrutto > 0 ? Math.round((correctTotal / aufzugBrutto) * 100) : 0;\n\n // Authoritative-Override (savings + summary + finding + ampel)\n savingsTotal = correctTotal;\n result.savings_text = 'rund ' + pctSavings + ' % der bisherigen Wartungskosten durch marktgerechte Neuausschreibung';\n\n // Summary überschreiben, wenn KI eine falsche/keine Marktposition genannt hat.\n // Konkreten Median-Wert (980 €) NICHT erwähnen — nur generische Marktreferenz.\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 // Falls die KI selbst die konkrete 980-Zahl in summary geschrieben hat → entfernen\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 // Selbe Säuberung für savings_text\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 // Vorhandenes Markt-Finding ENTFERNEN (KI-Mathe ist meist falsch), durch authoritatives ersetzen\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 // Ampel anpassen: bei deutlich über Markt mindestens gelb\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 // Zusatz-Hinweis für Eigentümer und Hausverwalter — IMMER (unabhängig davon, ob die Wartung\n // überteuert ist). Das Sparpotenzial dieser Auswertung deckt nur Wartung + Notruf ab.\n // Bei unterjährigen Reparaturen kann Liftaro im Einzelfall bis zu 8.000 € zusätzlich einsparen.\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 // ---\n // Deterministisch 30–60 % vom Angebotsbetrag, basierend auf check_nr-Hash.\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 // Wenn KI keine Ersparnis liefert, aber wir kennen die Angebotssumme: schätzen\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 // KI hat Ersparnis berechnet, aber einzelne Positionen waren nicht in der Liste — Hinweis\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 // Auch für Angebote: Reparatur-Hinweis bei Eigentümer/Verwalter\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 // Sicherheitsnetz B: Wenn MEA-Werte da sind und savings_individual_eur leer,\n // rechnen wir selbst — verhindert \"73 Parteien\"-Fehler bei MEA-Verteilung\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 // 7b. Pipedrive-Lead anlegen — best-effort, blockiert die Response nicht.\n // Jeder Vorabcheck mit Kontaktdaten landet als Lead in der Sales-Pipeline.\n // (Steht hier UNTERHALB der Savings-Berechnung, weil savingsTotal/savingsIndividual\n // hier final feststehen — TDZ-Bug bei früherer Position behoben.)\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 ABGESCHLOSSEN — Check-Nr ' + checkNr,\n '',\n 'Rolle: ' + roleLabel,\n 'Check-Typ: ' + checkTypeLabel,\n 'Ampel: ' + ampelLabel,\n savingsTotal ? 'Geschätzte Gesamtersparnis (Haus): ' + fmt(savingsTotal) + ' €/Jahr' : 'Geschätzte Gesamtersparnis: –',\n savingsIndividual ? 'Geschätzte individuelle Ersparnis: ' + fmt(savingsIndividual) + ' €/Jahr' : '',\n 'Adresse Objekt: ' + (lead.adresse || '–'),\n '',\n '— Zusammenfassung —',\n result.summary || '(keine)',\n ].filter(Boolean);\n const note = noteLines.join('\\n');\n const title = '[Vorabcheck] ' + fullName + ' — ' + roleLabel + ' (' + checkNr + ')';\n // Async, fehlerresistent — upsertPipedriveLead dedupliziert per Email\n createPipedriveLead({\n name: fullName,\n email: lead.email,\n phone: lead.telefon || undefined,\n title,\n note,\n }).catch(e => console.warn('[Pipedrive] Vorabcheck failed:', e?.message || e));\n }\n\n // Aufzug-Positionen + Gesamtkosten aus KI-Antwort durchreichen (defensiv normalisieren)\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 }, 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\n// ---\n// Helpers\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 // Fortlaufende Nummer aus Airtable (oder einfacher Zähler via val.town blob)\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 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 // Lead-Tabelle (mit PII)\n await fetch(`${at}/Vorabcheck-Leads`, {\n method: \"POST\", headers,\n body: JSON.stringify({\n fields: {\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 }).catch(e => console.warn(\"Lead-Save:\", e.message));\n\n // Aufzug-Positionen + Gesamtkosten aus dem Result\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\n // Vorab-Check-Tabelle (anonymisiert für KI-Lernen)\n await fetch(`${at}/Vorab-Checks`, {\n method: \"POST\", headers,\n body: JSON.stringify({\n fields: {\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: Number(data.result.aufzug_count || 0),\n parteien_count: Number(data.result.parteien_count || 0),\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n aufzug_positionen_text: aufzugPositionenText,\n aufzug_positionen_json: JSON.stringify(aufzugPositionen),\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 }).catch(e => console.warn(\"VorabCheck-Save:\", e.message));\n\n // Cost-Tracking\n await fetch(`${at}/API-Cost-Log`, {\n method: \"POST\", headers,\n body: JSON.stringify({\n fields: {\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 }).catch(e => console.warn(\"Cost-Log:\", e.message));\n}\n","\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.30.0\";\n\nconst MODEL = \"claude-sonnet-4-6\";\nconst COST_PER_M_INPUT_TOKENS = 3.0;\nconst COST_PER_M_OUTPUT_TOKENS = 15.0;\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 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?:\\/\\\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\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\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\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\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\n const nameLow = String(x.item.name).toLowerCase();\n if (!nameLow.includes(termLow)) return false;\n\n return x.score >= 0.3 || term.length >= 5;\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 getOrgFullDetails(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 orgUrl = base + '/organizations/' + orgId + '?api_token=' + encodeURIComponent(cfg.token);\n const orgRes = await fetch(orgUrl);\n const orgData = await orgRes.json();\n if (!orgData?.success || !orgData.data) return null;\n const org = orgData.data;\n\n const personsUrl = base + '/organizations/' + orgId + '/persons?api_token=' + encodeURIComponent(cfg.token);\n const personsRes = await fetch(personsUrl);\n const personsData = await personsRes.json();\n const persons = Array.isArray(personsData?.data) ? personsData.data : [];\n\n const genericEmail = pickGenericEmailFromPersons(persons);\n\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 const emails = Array.isArray(firstP.email) ? firstP.email : [];\n const phones = Array.isArray(firstP.phone) ? firstP.phone : [];\n const pEmail = emails.find((e: any) => e?.value)?.value || '';\n const pPhone = phones.find((p: any) => p?.value)?.value || '';\n gfEmail = String(pEmail || '');\n gfTel = String(pPhone || '');\n }\n\n let strasse = '', plz = '', ort = '';\n const addrFull = String(org.address || '').trim();\n if (addrFull) {\n const parts = addrFull.split(',').map((s: string) => s.trim()).filter(Boolean);\n if (parts.length >= 2) {\n strasse = parts[0];\n const plzOrt = parts[1].match(/^(\\d{4,5})\\s+(.+)$/);\n if (plzOrt) { plz = plzOrt[1]; ort = plzOrt[2]; }\n else ort = parts[1];\n } else { strasse = addrFull; }\n }\n return {\n org_id: org.id,\n firma: String(org.name || ''),\n gf: gfName,\n strasse, plz, ort,\n email: genericEmail || gfEmail || '',\n tel: gfTel,\n website: '',\n person_count: persons.length,\n };\n } catch (e) { console.warn('[Pipedrive] getOrgFullDetails:', e); return null; }\n}\n\nasync function listAllOrgs(opts: { start?: number; limit?: number } = {}): Promise {\n const cfg = await loadPipedriveConfig();\n if (!cfg) return [];\n const base = 'https://' + cfg.domain + '/api/v1';\n const start = opts.start || 0;\n const limit = Math.min(opts.limit || 500, 500);\n try {\n const url = base + '/organizations?start=' + start + '&limit=' + limit +\n '&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 [];\n return d.data.map((o: any) => ({\n org_id: o.id,\n name: o.name || '',\n address: o.address || '',\n person_count: Number(o.people_count || 0),\n updated_at: o.update_time || o.add_time || '',\n }));\n } catch (e) { console.warn('[Pipedrive] listAllOrgs:', e); return []; }\n}\n\nasync function createPipedriveOrgWithEmail(input: {\n name: string;\n email?: string;\n website?: string;\n city?: string;\n source?: string;\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\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\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\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,\n '',\n 'HV-Lead automatisch erzeugt aus einem Liftaro-Vorabcheck.',\n '',\n 'Trigger-Vorabcheck:',\n ' Check-Nr: ' + input.checkNr,\n ' Rolle des Auftraggebers: ' + roleLabel,\n ' Name: ' + input.userFullName,\n input.userEmail ? ' E-Mail: ' + input.userEmail : '',\n input.savingsTotal ? ' Identifiziertes Sparpotenzial: ' + fmt(input.savingsTotal) + ' € / Jahr' : '',\n '',\n 'Vertriebs-Aufhänger:',\n ' Der Auftraggeber hat das Sparpotenzial bereits an diese HV weitergeleitet.',\n ' Möglicher Folgekontakt: Konkrete Einsparungsberechnung + Light-Paket-Angebot.',\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;\n}\n\nconst ROLE_CONTEXTS: Record = {\n mieter: `ROLLEN-KONTEXT: MIETER (Wohnraum-Mietvertrag)\n\nDer Nutzer ist Mieter. Folgendes gilt rechtlich:\n- § 2 BetrKV definiert abschließend, welche Kosten als Betriebskosten umgelegt werden dürfen.\n- Aufzug-Wartung, Strom, Aufsicht/Bedienung, TÜV/ZÜS-Prüfung, Reinigung → umlagefähig.\n- Reparaturen, Instandsetzung, Modernisierung, Verwaltungskosten → NICHT umlagefähig (§ 1 Abs. 2 BetrKV).\n- Bei Vollwartungsverträgen MUSS ein Vorwegabzug für Instandsetzungs-Anteile erfolgen (BGH VIII ZR 123/14, ca. 20–50 % je Vertragsumfang). Fehlender Vorwegabzug = unzulässige Umlage.\n- § 556 Abs. 3 BGB: 12 Monate Einwendungsfrist ab Erhalt der Nebenkostenabrechnung.\n- Erdgeschoss-Mieter: Aufzugskosten nur dann zulässig, wenn vertraglich vereinbart (LG-Rechtsprechung uneinheitlich).\n\n⚠ VORSICHTS-REGEL für Mieter (sehr wichtig):\nMarkiere einen Posten NUR DANN als rechtswidrig/fehlerhaft (Severity \"warn\"/Ampel \"rot\"), wenn der Verstoß\nEINDEUTIG aus dem Dokument hervorgeht. Beispiele für eindeutig:\n · Position \"Reparatur Aufzug\" oder \"Instandsetzung Aufzug\" wird unter umlagefähige Betriebskosten gezogen.\n · Position \"Modernisierung Aufzug\" wird umgelegt.\n · Explizit erwähnter Vollwartungsvertrag OHNE Vorwegabzug.\nNICHT als Fehler markieren bei (nicht eindeutigen Hinweisen):\n · Hohe Wartungspauschale alleine — kann viele plausible Gründe haben (Anlagengröße, Hochhaus, Notruf, Hersteller-Service).\n · Unklarer Vertragstyp — wenn das Dokument nicht eindeutig Vollwartung sagt: kein Vorwegabzug-Befund.\n · Nicht erkennbare Verteilerschlüssel-Diskussion (Erdgeschoss etc.) — ohne Vertragsklausel-Info bleibt das spekulativ.\nBei Unsicherheit: severity \"blue\" (Hinweis \"bitte separat prüfen lassen\") oder \"amber\" — NIEMALS \"warn\" auf Verdacht.\nDie Ampel \"rot\" darf nur kommen, wenn es mindestens einen \"warn\"-Befund mit eindeutiger Belegstelle aus dem Dokument gibt.\n\nSPRACHE: Bei eindeutigen Verstößen klar und durchsetzungs-orientiert formulieren mit §-Bezug (z.B. \"Verstoß gegen § 1 Abs. 2 BetrKV\"). Bei Zweifelsfällen offen formulieren (\"Hinweis\", \"bitte prüfen lassen\", \"ggf. separat klären\"). KEINE Rechtsberatung.`,\n\n eigentuemer: `ROLLEN-KONTEXT: EIGENTÜMER (WEG-Mitglied oder Selbstnutzer)\n\nDer Nutzer ist Eigentümer. Folgendes gilt:\n- Alle Aufzugskosten (Wartung, Reparatur, Instandsetzung) werden in der WEG-Abrechnung umgelegt — es gibt KEINE Umlage-Beschränkung wie bei Mietern.\n- Relevante Prüfung: Marktangemessenheit der Konditionen, Vertragsoptimierungs-Potenzial, Vollwartung vs. Teilwartung, Servicestunden-Sätze, Vertragslaufzeit/Kündigungsfristen.\n- Befunde wie \"Reparaturen versteckt\" sind hier KEIN Rechtsverstoß, sondern Transparenz-/Verhandlungs-Argument.\n- Eigentümer kann als Vertragspartner direkt eine Optimierung anstoßen.\n\nSPRACHE: Sachlich, wirtschaftlich orientiert. §-Bezug nur wo relevant (z.B. WEG-Recht bei Verteilerschlüssel). Fokus auf konkrete Einsparungs-Hebel.`,\n\n verwalter: `ROLLEN-KONTEXT: HAUSVERWALTER (Verwaltungsmandat)\n\nDer Nutzer ist Hausverwalter. Folgendes gilt:\n- Verwaltet möglicherweise mehrere Anlagen → Ersparnis-Hochrechnung \"pro Anlage + portfolio-weit\" ist besonders relevant.\n- Hat Verantwortung gegenüber Eigentümern (WEG) bzw. Vermietern und muss wirtschaftlich + rechtssicher handeln.\n- Kann als Vertragspartner direkt Vertragsoptimierungen einleiten.\n- Relevante Prüfung: Optimierungs-Hebel, Compliance-Risiken (z.B. fehlender Vorwegabzug bei Mieter-Umlage), Marktbenchmarks.\n\nSPRACHE: Professionell, knapp, kennzahlen-orientiert. Bezugnahme auf §§ wo relevant — insbesondere bei Konstellationen, wo Mietumlage betroffen ist (dann Mietrecht-Hinweis).`,\n};\n\nfunction buildSystemPrompt(checkType: string, role: string, customMap: Record): string | null {\n\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\nconst DEFAULT_SYSTEM_PROMPTS: Record = {\n nebenkosten: `Du bist Aufzug-Experte und Bau-/Mietrechts-Analyst bei Liftaro. Du prüfst Nebenkostenabrechnungen auf die Aufzug-Position.\n\n═══════════════════════════════════════════\nTASK 1 (HÖCHSTE PRIORITÄT): DATEN EXTRAHIEREN\n═══════════════════════════════════════════\nSuche im Dokument die Aufzug-Wartungs-Position. Typische Bezeichnungen:\n · \"Aufzugskosten/Wartung/TÜV\"\n · \"Aufzugswartung Haus X\"\n · \"Aufzugswartung\"\n · \"Aufzug Wartung\"\n · \"Wartung Aufzug\"\n · \"Aufzugskosten\" (wenn nichts spezifischeres da ist)\n\nDaraus extrahiere den **GESAMT-Wartungsbetrag** — das ist der Wert in der\nGESAMT-Spalte (auch genannt: \"Gesamt\", \"Verteilungsrelevante Beträge\",\n\"Ausgaben Gesamt\", \"Brutto\"). Das ist NICHT \"Ihr Anteil\" / \"Ihr Betrag\".\n\nKONKRETE BEISPIELE (du musst genau lesen können):\n\nBeispiel A — tabellarisch mit MEA-Schlüssel:\n Konto Bezeichnung Verteilungsrelevante Beträge Schlüssel Gesamt Ihr Anteil Ihr Betrag\n 5000 Aufzugskosten/Wartung/TÜV 8.832,46 MEA 10000 81 71,54\n → betrag_aufzug_brutto = 8832.46 (NICHT 71.54!)\n\nBeispiel B — Haus-Position:\n Aufzugswartung Haus 9 Miteigentumsanteile 17.051 1.263 2.100,00 155,55\n → betrag_aufzug_brutto = 2100.00 (NICHT 155.55!)\n\nBeispiel C — Einfach:\n Aufzugswartung 450,00 € (Einheit)\n → betrag_aufzug_brutto = 450.00\n\nWichtige Regeln zur Extraktion:\n- IMMER den größten EUR-Wert der Aufzug-Wartungs-Zeile nehmen, NIE den Eigentümer-Anteil\n- Bei mehreren Aufzug-Wartungs-Positionen (z.B. mehrere Häuser): ADDIERE die Gesamt-Werte\n- Wenn du dir bei einem Wert nicht 100 % sicher bist: 0 zurückgeben, NIE raten\n- Tausender-Trenner ist Punkt, Dezimal-Komma: \"8.832,46\" = 8832.46\n\n═══════════════════════════════════════════\nTASK 2: RECHTLICHE BEWERTUNG (kurz)\n═══════════════════════════════════════════\n\n🎯 ZWEI SEPARATE BEWERTUNGEN — IMMER BEIDE DURCHFÜHREN:\n\nA) RECHTLICHE KORREKTHEIT (steuert \"ampel\" + warn-Findings)\n - Wird die Abrechnung rechtlich/formal korrekt aufgestellt?\n - Bei sauberer Trennung umlagefähig/nicht-umlagefähig: Ampel \"gruen\"\n - Bei eindeutigen Verstößen: Ampel \"gelb\"/\"rot\"\n\nB) MARKT-OPTIMIERUNG (steuert \"savings_total_eur\" — UNABHÄNGIG von A!)\n - Vergleich der Wartungskosten mit dem Liftaro-Marktmedian (980 €/Anlage/Jahr).\n - Eine \"rechtlich saubere\" Abrechnung kann trotzdem WIRTSCHAFTLICH überteuert sein —\n das ist KEIN Rechtsverstoß, aber ein Optimierungs-Hinweis für den Auftraggeber.\n - Markt-Optimierung IMMER durchführen, auch wenn Ampel \"gruen\" ist.\n - Bei Wartung über Median: Erzeuge ein \"amber\" oder \"blue\" Finding \"Optimierungspotenzial:\n Wartungspauschale X EUR liegt Y EUR über dem Marktmedian von 980 EUR. Geschätzte Ersparnis\n bei Neuausschreibung: Z EUR/Jahr.\"\n - savings_total_eur = (tatsächliche_Wartung_pro_Anlage − 980) × Anzahl_Aufzüge\n (exakte Differenz zum Marktmedian — kein Sicherheits-/Verhandlungsfaktor abziehen)\n (NICHT mehr null setzen, nur weil Ampel grün ist!)\n - savings_text z.B. \"rund X % der bisherigen Wartungskosten durch marktgerechte Konditionen\"\n\n⚠ ANTI-HALLUZINATIONS-REGEL (sehr wichtig):\n- Stelle NIE Behauptungen auf, die nicht direkt aus dem Dokument belegbar sind.\n- \"Vollwartungsvertrag\" darfst Du NUR annehmen, wenn das Wort/der Begriff (oder eindeutige Synonyme wie \"Vollwartung\", \"inkl. Reparaturen\", \"all-inclusive Wartung\") tatsächlich im Dokument steht.\n- Wenn nur eine Position \"Wartung\" und separat eine Position \"Instandhaltung/Reparatur\" auftaucht → das spricht STARK GEGEN Vollwartung. In diesem Fall KEIN Vorwegabzug-Befund erzeugen.\n- Wenn Du den Vertragstyp aus dem Dokument NICHT bestimmen kannst → \"vollwartung_erwaehnt\": false und KEIN Finding zum Vorwegabzug. Stattdessen optional ein blue-Finding: \"Vertragstyp unklar — bitte Wartungsvertrag separat prüfen lassen.\"\n\n⚠ ZUSÄTZLICHE VORSICHTS-REGEL bei Mieter-Rolle:\nBei Nebenkostenabrechnungen, die einem MIETER vorgelegt werden, gilt: Markiere die Abrechnung NUR DANN als\nfehlerhaft (Ampel \"rot\" oder Severity \"warn\"), wenn der Fehler OFFENSICHTLICH und EINDEUTIG aus dem Dokument\nhervorgeht (z.B. eine Position \"Reparatur Aufzug\" steht klar unter umlagefähigen Betriebskosten, oder ein\nausdrücklicher Vollwartungsvertrag ohne ausgewiesenen Vorwegabzug). Wenn nur ein Verdacht besteht oder das\nDokument unklar ist → severity \"blue\"/\"amber\" (Hinweis statt Verstoß), Ampel \"gruen\" oder \"gelb\".\nLiftaro will Mieter NICHT zu unbegründeten Streitigkeiten ermutigen — nur bei eindeutigen Verstößen klare Kante.\n\nPRÜFE FOLGENDE PUNKTE:\n\n1. UMLAGEFÄHIGKEIT (§ 2 Nr. 7 BetrKV)\n - Umlagefähig: Wartung, Strom, Aufsicht, TÜV (ZÜS), Reinigung\n - NICHT umlagefähig (§ 1 Abs. 2 BetrKV): Reparaturen, Instandsetzung, Modernisierung\n - Bei Mieter: Verstöße klar als solche benennen mit §-Bezug.\n - Bei Eigentümer/Verwalter: als Transparenz-Hinweis formulieren (kein Rechtsverstoß).\n - WICHTIG: Wenn Instandhaltung in der Abrechnung BEREITS unter \"nicht umlagefähig\" geführt wird → das ist KORREKT, kein Verstoß. Lobe das ausdrücklich.\n\n2. VOLLWARTUNGSVERTRAG — nur prüfen wenn EXPLIZIT erwähnt\n - Voraussetzung: Das Dokument erwähnt Vollwartung wörtlich.\n - Bei expliziter Vollwartung + Mieter-Umlage muss ein Vorwegabzug für Instandsetzung erfolgen (20–50 %, BGH VIII ZR 123/14).\n - Wenn nicht ausgewiesen UND Vollwartung explizit → Rotflag bei Mieter.\n - Bei separat ausgewiesener Instandhaltung → KEIN Vollwartungs-Vermutung, KEIN Vorwegabzug-Befund.\n\n3. WARTUNGSPAUSCHALE — LIFTARO-REFERENZWERT (verbindlich, NICHT VERHANDELBAR)\n - **Marktmedian Wohnaufzug INKL. Notruf/Bereitschaftsdienst: 980 €/Jahr je Anlage**\n - Dieser Wert ist die Liftaro-Referenz aus Marktdaten. Verwende ihn als HARTE Vergleichsbasis. Erfinde KEINE anderen Median-Werte.\n - **WICHTIG — Diskretion bei der Ausgabe:** Den konkreten Wert \"980 €\" NIE wörtlich in summary, savings_text oder findings nennen. Stattdessen sprich vom \"branchenüblichen Marktmedian\", \"Marktreferenz für Wartung und Notruf\" oder \"marktüblichem Vergleichswert\". Die Differenz und die Ersparnis dürfen genannt werden — nur die Median-Zahl selbst nicht.\n\n PFLICHT-RECHENGANG (immer durchführen):\n a) Hole den Aufzug-Brutto-Betrag aus der Abrechnung (z.B. \"Aufzugswartung Haus 9: 2.100 €\")\n b) Teile durch aufzug_count (z.B. 2.100 / 1 = 2.100 € pro Anlage und Jahr)\n c) Vergleiche mit 980 €:\n · pro_anlage ≤ 1.200 → marktüblich, kein Befund (savings_total_eur = 0)\n · 1.200 < pro_anlage ≤ 1.500 → leicht erhöht (blue/amber-Hinweis)\n · 1.500 < pro_anlage ≤ 1.800 → deutlich über Markt (amber/warn)\n · pro_anlage > 1.800 → KLAR ZU TEUER (warn, konkrete Ersparnis ausweisen)\n d) Ersparnis bei Neuausschreibung zum Median = (pro_anlage − 980) × aufzug_count\n (KEINEN Verhandlungs-Faktor abziehen — wenn der Vertrag auf Median geht, ist genau das die Ersparnis.)\n\n KONKRETES BEISPIEL (für Konsistenz-Check):\n \"Aufzugswartung Haus 9: 2.100 €, 1 Aufzug\"\n → pro_anlage = 2.100 €\n → 2.100 > 1.800 → KLAR ZU TEUER\n → savings_total_eur = (2.100 − 980) × 1 = 1.120 € (intern berechnen, NICHT den Median-Wert anzeigen)\n → savings_text = \"rund 53 % der bisherigen Wartungskosten durch Neuausschreibung zu marktüblichen Konditionen\"\n → summary muss das WIDERSPIEGELN, NICHT \"unter Marktmedian\" behaupten!\n → finding-Description: \"liegt rund 1.120 € über dem branchenüblichen Marktmedian\" (KEINE konkrete 980-Zahl!)\n\n VERBOT: Schreibe NIE \"unter Marktmedian\" oder \"marktüblich\" wenn pro_anlage > 1.200 €.\n Achtung: Hohe Beträge können in Sondersituationen gerechtfertigt sein (hochwertige/seltene Anlage, mehrere Wartungen p.a., Großgebäude mit ständigem Notruf-Bedarf). Bei Anhaltspunkten dafür: Befund-Severity um eine Stufe abmildern — aber NICHT die mathematische Aussage drehen.\n\n4. SERVICESTUNDEN-SATZ\n - Marktüblich 95–125 €/h, regional unterschiedlich\n - >140 €/h → gelb, >160 €/h → rot\n\n5. ANZAHL WARTUNGEN P.A.\n - TRBS 1201 Teil 4: 2 Wartungen/Jahr für Wohnaufzüge ausreichend\n - 4 Wartungen → gelb (kann ok sein bei stark genutzten Anlagen)\n\n6. VERTEILUNGSSCHLÜSSEL\n - Erdgeschoss-Mieter zahlt nur wenn vertraglich vereinbart (Mieter-spezifisch)\n - Übliche Schlüssel: m² Wohnfläche oder Person oder Miteigentumsanteile (MEA)\n\n7. FRIST § 556 Abs. 3 BGB (nur Mieter)\n - 12 Monate ab Erhalt der Abrechnung für Einwendungen\n\n8. ANLAGEN-ERFASSUNG (immer extrahieren — wichtig für Hochrechnung)\n - aufzug_count: Wie viele Aufzüge sind in der Abrechnung enthalten?\n · \"Aufzugswartung Haus 9\" → 1 Aufzug\n · \"Aufzugswartung Haus 9, 11, 15\" → 3 Aufzüge\n · Wenn nicht ersichtlich → 0 (heißt: unbekannt)\n\n - verteilerschluessel: WELCHER Schlüssel wird für die Aufzug-Position genutzt?\n · \"mea\" → Miteigentumsanteile (üblich bei WEG)\n · \"qm\" → Wohnfläche\n · \"einheit\" → gleichmäßig pro Wohneinheit\n · \"person\" → pro Person\n · \"unbekannt\" → wenn nicht ersichtlich\n\n - WENN verteilerschluessel === \"mea\" (Miteigentumsanteile):\n · mea_pool_total: Die GESAMT-MEA der Aufzug-Position (das ist NICHT 100.000 — sondern nur die Summe für den Aufzug-Verteilerschlüssel, z.B. 17.051 für \"Aufzugswartung Haus 9\").\n · mea_eigentuemer: Der MEA-Anteil des anfragenden Eigentümers an der Aufzug-Position (z.B. 1.263).\n · parteien_count: NUR setzen, wenn aus dem Dokument klar hervorgeht, wie viele Parteien sich den Aufzug-Pool teilen. Sonst 0. NIE die \"73 Einheiten\" einer anderen Position (z.B. Hausreinigung) übernehmen — der Aufzug betrifft oft nur EIN Haus mit weniger Parteien.\n\n - WENN verteilerschluessel === \"einheit\" (gleiche Anzahl pro Partei):\n · parteien_count: Anzahl Einheiten am Verteilerschlüssel der Aufzug-Position direkt (z.B. wenn Aufzug-Position \"Einheiten 13\" → 13 Parteien).\n · mea_pool_total / mea_eigentuemer leer/0 lassen.\n\n - WENN verteilerschluessel === \"qm\" oder \"person\":\n · Beides leer lassen (nur individuelle Berechnung aus \"Ihr Anteil EUR\" möglich).\n · parteien_count: 0, sofern nicht eindeutig ableitbar.\n\n - Mathematische Konsistenz: Die KI MUSS sicherstellen, dass aufzug_count * Wartung pro Anlage ≈ Gesamt-Aufzug-Position. Wenn das nicht passt → Werte korrigieren.\n\nANTWORTE NUR MIT JSON, OHNE MARKDOWN-CODE-BLOCKS:\n{\n \"ampel\": \"gruen\" | \"gelb\" | \"rot\",\n \"summary\": \"Ein-Satz-Bewertung\",\n \"findings\": [\n {\n \"severity\": \"warn\" | \"amber\" | \"blue\",\n \"title\": \"Kurze Überschrift\",\n \"description\": \"1–2 Sätze Erklärung mit konkreten Beträgen wenn möglich\",\n \"tag\": \"z.B. § 2 Nr. 7 BetrKV oder Position 4.2\"\n }\n ],\n \"aufzug_count\": Zahl (Anzahl erkannter Aufzüge in der Abrechnung, 0 wenn unklar),\n \"verteilerschluessel\": \"mea\" | \"qm\" | \"einheit\" | \"person\" | \"unbekannt\",\n \"parteien_count\": Zahl (NUR bei verteilerschluessel \"einheit\" oder \"person\", sonst 0 — siehe Regel oben),\n \"mea_pool_total\": Zahl (Gesamt-MEA der Aufzug-Position, NUR bei verteilerschluessel \"mea\"; sonst 0),\n \"mea_eigentuemer\": Zahl (MEA-Anteil des Anfragenden, NUR bei verteilerschluessel \"mea\"; sonst 0),\n \"savings_total_eur\": Zahl (geschätzte jährliche Gesamtersparnis fürs ganze Haus in EUR, 0 wenn keine),\n \"savings_individual_eur\": Zahl (geschätzte jährliche Ersparnis für die anfragende Partei in EUR — bei MEA: savings_total_eur * mea_eigentuemer / mea_pool_total; bei Einheit: savings_total_eur / parteien_count; 0 wenn nicht berechenbar),\n \"savings_estimate_eur\": Zahl (Legacy-Feld; identisch zu savings_total_eur),\n \"savings_text\": \"z.B. 'rund 40% der bisherigen Aufzug-Kosten'\",\n \"anonymized_data\": {\n \"abrechnungszeitraum\": \"z.B. 2024\",\n \"betrag_aufzug_brutto\": Zahl (ABSOLUTER Wartungsbetrag aus Zeile \"Aufzugswartung … X EUR\" Gesamt-Spalte; NICHT die Differenz zum Median, NICHT der Eigentümer-Anteil, NICHT die Ersparnis. Bei \"Aufzugswartung Haus 9: 2.100 EUR\" → 2100.),\n \"verteilerschluessel\": \"mea\" | \"qm\" | \"einheit\" | \"person\" | \"unbekannt\",\n \"vollwartung_erwaehnt\": true | false,\n \"vorwegabzug_ausgewiesen\": true | false,\n \"anzahl_wartungen\": Zahl | null,\n \"anzahl_aufzuege\": Zahl,\n \"mea_pool_total\": Zahl,\n \"anbieter_branche\": \"kone\" | \"schindler\" | \"tk-elevator\" | \"otis\" | \"sonstige\" | \"unbekannt\"\n },\n \"aufzug_positionen\": [\n { \"text\": \"Wörtlicher Positionsname aus der Abrechnung (z.B. 'Aufzugskosten/Wartung/TÜV')\",\n \"betrag_eur\": Zahl (Gesamt-Betrag dieser Position; aus der Gesamt-Spalte) }\n ],\n \"aufzug_gesamtkosten_eur\": Zahl (Summe ALLER Aufzug-bezogenen Positionen aus der Abrechnung — Wartung, Notruf, Instandhaltung, TÜV, Strom, etc. zusammen)\n}\n\nWICHTIG zu aufzug_positionen + aufzug_gesamtkosten_eur:\n- Finde JEDE Zeile in der Abrechnung, die \"Aufzug\" / \"Aufzugs…\" im Namen enthält (Wartung, Instandhaltung, Notruf, TÜV, Strom Aufzugsanlage, …).\n- Übernimm den Positions-Text 1:1 wörtlich aus der Abrechnung (kein Umformulieren, kein Kürzen).\n- betrag_eur ist immer der GESAMT-Betrag der Zeile (aus der Gesamt-Spalte), NICHT der Eigentümer-Anteil.\n- aufzug_gesamtkosten_eur = Summe aller betrag_eur in aufzug_positionen. Beide Felder müssen konsistent sein.\n- Wenn keine Aufzug-Position gefunden: leeres Array [] und 0.\n\nWICHTIG: anonymized_data darf KEINE personenbezogenen Daten enthalten (keine Namen, Adressen, Kontonummern).`,\n\n angebot: `Du bist Aufzug-Experte bei Liftaro. Du prüfst Reparatur- oder Wartungs-Angebote auf Plausibilität.\n\nPRÜFE:\n1. Marktüblichkeit der Positionspreise (Reparaturkomponenten, Servicestunden)\n2. Vollständigkeit (Gewährleistung, Lieferzeit, Anschrift, Steuer-ID)\n3. Auffällige Klauseln (lange Bindefristen, Preisgleitklauseln)\n4. Anlagen-Bezug: wie viele Aufzüge betrifft das Angebot? Welche Anzahl Parteien profitiert?\n\nLIFTARO-REFERENZWERTE (verbindlich, aus Marktdaten):\n- Wartungspauschale inkl. Notruf: **Median 980 €/Jahr** je Wohnaufzug\n- Servicestunden-Satz: 95–125 €/h Wohnaufzug, 110–145 €/h Gewerbe\n- Bei Wartungsangeboten > ~1.500 €/Jahr deutlich über Markt → konkret Ersparnis ausweisen\n- Geschätzte Ersparnis bei Neuausschreibung = (Angebotsbetrag − 980) (exakte Differenz)\n\nBei Mieter: §-Bezug bei umlagefähigkeitsrelevanten Themen (Reparatur vs. Wartung).\nBei Eigentümer/Verwalter: wirtschaftlich/sachlich.\n\nANTWORTE NUR MIT JSON:\n{\n \"ampel\": \"gruen\" | \"gelb\" | \"rot\",\n \"summary\": \"...\",\n \"findings\": [{ \"severity\": \"warn\"|\"amber\"|\"blue\", \"title\": \"...\", \"description\": \"...\", \"tag\": \"...\" }],\n \"aufzug_count\": Zahl,\n \"parteien_count\": Zahl,\n \"savings_total_eur\": Zahl,\n \"savings_individual_eur\": Zahl,\n \"savings_estimate_eur\": Zahl,\n \"savings_text\": \"...\",\n \"anonymized_data\": {\n \"angebotssumme_netto\": Zahl,\n \"angebotssumme_brutto\": Zahl,\n \"gewaehrleistung_monate\": Zahl | null,\n \"lieferzeit_wochen\": Zahl | null,\n \"anzahl_aufzuege\": Zahl,\n \"anbieter_branche\": \"...\"\n }\n}`,\n\n vertrag: `Du bist Aufzug-Experte bei Liftaro. Du prüfst Wartungsverträge auf ungünstige Konditionen.\n\nPRÜFE:\n1. Laufzeit & Kündigungsfrist (typisch: 3 Monate vor Ablauf, max. 5 Jahre Erstlaufzeit)\n2. Vertragstyp (Voll- vs. Teilwartung) — bei Mieter-Umlage: Vorwegabzug-Pflicht für Instandsetzung (BGH VIII ZR 123/14)\n3. Preisgleitklauseln\n4. Anzahl Wartungen p.a. (TRBS 1201 Teil 4)\n5. Bereitschaftsdienst / Notruf-Kosten\n6. Anzahl Anlagen im Vertrag + Anzahl Parteien zur Ersparnis-Hochrechnung\n\nLIFTARO-REFERENZWERTE (verbindlich, aus Marktdaten):\n- Wartungspauschale inkl. Notruf/Bereitschaft: **Median 980 €/Jahr** je Wohnaufzug\n- Bewertung pro Anlage:\n · bis ~1.200 €/Jahr → marktüblich\n · 1.200–1.500 € → leicht erhöht (Hinweis)\n · 1.500–1.800 € → deutlich über Markt (amber/warn, Optimierung nennen)\n · über 1.800 € → klar zu teuer (warn, Ersparnis konkret ausweisen)\n- Geschätzte Ersparnis bei Neuausschreibung = (Vertragsbetrag − 980) (exakte Differenz)\n- Bei mehreren Anlagen im Vertrag immer pro Anlage rechnen (Summe ÷ Anzahl)\n\nBei Mieter: Mietrechtliche Konsequenzen mit §-Bezug benennen, wenn die Vertragsgestaltung die Umlagefähigkeit beeinflusst.\nBei Eigentümer/Verwalter: Optimierungs- und Verhandlungs-Hebel.\n\nANTWORTE NUR MIT JSON:\n{\n \"ampel\": \"gruen\" | \"gelb\" | \"rot\",\n \"summary\": \"...\",\n \"findings\": [{ \"severity\": \"warn\"|\"amber\"|\"blue\", \"title\": \"...\", \"description\": \"...\", \"tag\": \"...\" }],\n \"aufzug_count\": Zahl,\n \"parteien_count\": Zahl,\n \"savings_total_eur\": Zahl,\n \"savings_individual_eur\": Zahl,\n \"savings_estimate_eur\": Zahl,\n \"savings_text\": \"...\",\n \"anonymized_data\": {\n \"vertragstyp\": \"vollwartung\" | \"teilwartung\" | \"unbekannt\",\n \"laufzeit_jahre\": Zahl | null,\n \"kuendigungsfrist_monate\": Zahl | null,\n \"kosten_pro_jahr\": Zahl,\n \"anzahl_wartungen\": Zahl | null,\n \"anzahl_aufzuege\": Zahl,\n \"anzahl_parteien\": Zahl,\n \"anbieter_branche\": \"...\"\n }\n}`,\n};\n\nexport default async function (req: Request): Promise {\n\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 start = parseInt(String(body.start || '0'), 10) || 0;\n const limit = Math.min(parseInt(String(body.limit || '500'), 10) || 500, 500);\n const orgs = await listAllOrgs({ start, limit });\n return jsonResp({ ok: true, results: orgs }, 200, corsHeaders);\n }\n\n if (body.action === 'get_property_manager_details') {\n const orgId = parseInt(String(body.org_id || '0'), 10);\n if (!orgId) return jsonResp({ ok: false, error: 'org_id Pflichtfeld' }, 400, corsHeaders);\n const details = await getOrgFullDetails(orgId);\n if (!details) return jsonResp({ ok: false, error: 'Org nicht gefunden' }, 404, corsHeaders);\n return jsonResp({ ok: true, details }, 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\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,\n city: org.address || '',\n confidence: email ? 100 : 60,\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 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\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 source: 'user_verifiziert',\n });\n if (created.ok && created.org_id) { orgId = created.org_id; orgCreated = true; }\n }\n\n if (orgId && !orgCreated && hvEmail && isGenericHvEmail(hvEmail)) {\n const existingMail = await getOrgGenericEmail(orgId);\n if (!existingMail) {\n\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 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 }, 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\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\n const role = ['mieter','eigentuemer','verwalter'].includes(body.role) ? body.role : 'mieter';\n\n const aufzugCountUser = Math.max(1, Math.min(50, parseInt(String(body.aufzug_count_user || '1'), 10) || 1));\n\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 if (turnstileSecret && turnstile_token) {\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.\" },\n ];\n\n const response = await anthropic.messages.create({\n model: MODEL,\n max_tokens: 4096,\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\n const aufzugCount = aufzugCountUser;\n result.aufzug_count = aufzugCount;\n let aufzugBrutto = 0;\n let bruttoSource = 'unknown';\n\n if (wartungBruttoUser > 0) {\n\n aufzugBrutto = wartungBruttoUser;\n bruttoSource = 'user';\n\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\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\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\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\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\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\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\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 ABGESCHLOSSEN — Check-Nr ' + checkNr,\n '',\n 'Rolle: ' + roleLabel,\n 'Check-Typ: ' + checkTypeLabel,\n 'Ampel: ' + ampelLabel,\n savingsTotal ? 'Geschätzte Gesamtersparnis (Haus): ' + fmt(savingsTotal) + ' €/Jahr' : 'Geschätzte Gesamtersparnis: –',\n savingsIndividual ? 'Geschätzte individuelle Ersparnis: ' + fmt(savingsIndividual) + ' €/Jahr' : '',\n 'Adresse Objekt: ' + (lead.adresse || '–'),\n '',\n '— Zusammenfassung —',\n result.summary || '(keine)',\n ].filter(Boolean);\n const note = noteLines.join('\\n');\n const title = '[Vorabcheck] ' + fullName + ' — ' + roleLabel + ' (' + checkNr + ')';\n\n createPipedriveLead({\n name: fullName,\n email: lead.email,\n phone: lead.telefon || undefined,\n title,\n note,\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',\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,\n savings_text: result.savings_text || \"\",\n check_nr: checkNr,\n role: role,\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\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 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 fetch(`${at}/Vorabcheck-Leads`, {\n method: \"POST\", headers,\n body: JSON.stringify({\n fields: {\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 }).catch(e => console.warn(\"Lead-Save:\", e.message));\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\n await fetch(`${at}/Vorab-Checks`, {\n method: \"POST\", headers,\n body: JSON.stringify({\n fields: {\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: Number(data.result.aufzug_count || 0),\n parteien_count: Number(data.result.parteien_count || 0),\n aufzug_gesamtkosten_eur: aufzugGesamtkosten,\n aufzug_positionen_text: aufzugPositionenText,\n aufzug_positionen_json: JSON.stringify(aufzugPositionen),\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 }).catch(e => console.warn(\"VorabCheck-Save:\", e.message));\n\n await fetch(`${at}/API-Cost-Log`, {\n method: \"POST\", headers,\n body: JSON.stringify({\n fields: {\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 }).catch(e => console.warn(\"Cost-Log:\", e.message));\n}\n","createdAt",["D",1779119870567],"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",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"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",{"_43":44,"_32":45,"_38":152,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":153,"_79":154,"_81":155,"_83":25},"tree",[147],"files",[147],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"527f1448-52d2-11f1-a3f7-ee650bb23af1","parentId","latest",["D",1779119870567],23,"label",[28],"pulls","branches",1,"forks","envVars",{"_143":145,"_146":61},"connections",{"_143":61,"_144":61},"count","unfilledCount",4,"emptyCount",{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":148,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_149":150,"_27":151},["D",1779119870567],"children",[],[28],["D",1778712174884],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_124":189,"_190":191,"_192":193,"_194":25,"_195":25,"_196":25,"_197":122,"_198":-5,"_199":-7,"_200":-7,"_201":61,"_202":25,"_203":25,"_204":-5,"_205":25,"_206":25,"_207":25,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":85,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"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 · v24