Donna

import { IncomingMessage, ServerResponse, createServer } from 'http' import { networkInterfaces } from 'os' import { existsSync, readFileSync } from 'fs' import { join } from 'path' import { app } from 'electron' import { classifyInput, saveEntry, getDashboard } from '../services/classifier' import { readSettings } from '../services/settings-store' import { transcribeAudio } from '../services/llm-service' export const MOBILE_PORT = 3847 // ─── NETZWERK-IP ────────────────────────────────────────────────────────────── export function getLocalIp(): string { const nets = networkInterfaces() for (const iface of Object.values(nets)) { if (!iface) continue for (const config of iface) { if (config.family === 'IPv4' && !config.internal) return config.address } } return '127.0.0.1' } export function getMobileUrl(): string { return `http://${getLocalIp()}:${MOBILE_PORT}` } // ─── AVATAR ─────────────────────────────────────────────────────────────────── let _avatarCache: Buffer | null | undefined = undefined function getAvatarBuffer(): Buffer | null { if (_avatarCache !== undefined) return _avatarCache const base = app.isPackaged ? (process as NodeJS.Process & { resourcesPath: string }).resourcesPath : join(app.getAppPath(), 'resources') const candidates = [ join(base, 'donna.png'), join(base, 'donna.jpg'), join(process.cwd(), 'resources', 'donna.png'), join(process.cwd(), 'resources', 'donna.jpg'), ] for (const p of candidates) { if (existsSync(p)) { _avatarCache = readFileSync(p); return _avatarCache } } _avatarCache = null return null } // ─── HELPERS ────────────────────────────────────────────────────────────────── function readBody(req: IncomingMessage): Promise { return new Promise((resolve, reject) => { let raw = '' req.on('data', chunk => { raw += chunk }) req.on('end', () => { try { resolve(JSON.parse(raw)) } catch { resolve({}) } }) req.on('error', reject) }) } function sendJson(res: ServerResponse, status: number, data: unknown) { const body = JSON.stringify(data) res.writeHead(status, { 'Content-Type': 'application/json', 'Access-Control-Allow-Origin': '*', 'Access-Control-Allow-Headers': 'Content-Type', }) res.end(body) } // ─── PWA-ASSETS ─────────────────────────────────────────────────────────────── const ICON_SVG = `` const MANIFEST_JSON = JSON.stringify({ name: 'The Donna', short_name: 'Donna', description: 'Deine strategische Assistentin', start_url: '/', display: 'standalone', orientation: 'portrait', background_color: '#1B1F3B', theme_color: '#1B1F3B', lang: 'de', icons: [{ src: '/icon.svg', sizes: 'any', type: 'image/svg+xml', purpose: 'any maskable' }], }) // ─── MOBILE HTML ────────────────────────────────────────────────────────────── const MOBILE_HTML = ` Donna

DONNA

Donna denkt kurz nach\u2026

DONNA

Titel

Kategorie

DONNA

\u2713

Gespeichert

` // ─── SERVER ─────────────────────────────────────────────────────────────────── export function startMobileServer(): void { const server = createServer(async (req: IncomingMessage, res: ServerResponse) => { const url = req.url ?? '/' const method = req.method ?? 'GET' // CORS preflight if (method === 'OPTIONS') { res.writeHead(204, { 'Access-Control-Allow-Origin': '*', 'Access-Control-Allow-Methods': 'GET, POST, OPTIONS', 'Access-Control-Allow-Headers': 'Content-Type', }) res.end() return } try { // ── Mobile UI if (url === '/' && method === 'GET') { res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' }) res.end(MOBILE_HTML) return } // ── Avatar if (url === '/avatar.png' && method === 'GET') { const buf = getAvatarBuffer() if (buf) { const ext = buf[0] === 0xff ? 'jpeg' : 'png' res.writeHead(200, { 'Content-Type': `image/${ext}`, 'Cache-Control': 'public, max-age=3600' }) res.end(buf) } else { res.writeHead(404) res.end('Not found') } return } // ── PWA-Assets if (url === '/icon.svg' && method === 'GET') { res.writeHead(200, { 'Content-Type': 'image/svg+xml', 'Cache-Control': 'public, max-age=86400' }) res.end(ICON_SVG) return } if (url === '/manifest.json' && method === 'GET') { res.writeHead(200, { 'Content-Type': 'application/manifest+json', 'Cache-Control': 'public, max-age=86400' }) res.end(MANIFEST_JSON) return } // ── Klassifikation if (url === '/api/classify' && method === 'POST') { const body = await readBody(req) as { text?: string } if (!body.text?.trim()) { sendJson(res, 400, { ok: false, error: 'Kein Text angegeben' }) return } const settings = readSettings() const result = await classifyInput(body.text.trim(), settings.preferredLlm) sendJson(res, 200, { ok: true, data: result }) return } // ── Speichern if (url === '/api/save' && method === 'POST') { const body = await readBody(req) // eslint-disable-next-line @typescript-eslint/no-explicit-any const id = saveEntry(body as any) sendJson(res, 200, { ok: true, id }) return } // ── Whisper-Transkription if (url === '/api/transcribe' && method === 'POST') { const body = await readBody(req) as { audio?: string; mimeType?: string } if (!body.audio) { sendJson(res, 400, { ok: false, error: 'Keine Audiodaten' }) return } const text = await transcribeAudio(body.audio, body.mimeType || 'audio/webm') sendJson(res, 200, { ok: true, text }) return } // ── Dashboard if (url === '/api/dashboard' && method === 'GET') { const data = getDashboard() sendJson(res, 200, { ok: true, data }) return } res.writeHead(404) res.end('Not found') } catch (err) { sendJson(res, 500, { ok: false, error: err instanceof Error ? err.message : String(err), }) } }) server.on('error', (err: NodeJS.ErrnoException) => { if (err.code === 'EADDRINUSE') { console.warn(`[Donna Mobile] Port ${MOBILE_PORT} bereits belegt – Mobile UI nicht verfügbar`) } else { console.error('[Donna Mobile] Server-Fehler:', err) } }) server.listen(MOBILE_PORT, '0.0.0.0', () => { console.log(`[Donna Mobile] Erreichbar unter: ${getMobileUrl()}`) }) }