2026-02-26-client-1772084432205.txt

export async function get_notes({ limit = 10, category } = {}) {
  try {
    const notesFile = resolve(__dirname, '../notes/notes.json');
    if (!existsSync(notesFile)) return 'Nog geen notities opgeslagen.';
    let notes = JSON.parse(readFileSync(notesFile, 'utf-8'));
    if (category) notes = notes.filter(n => n.category === category);
    notes = notes.slice(0, limit);
    if (!notes.length) return 'Geen notities gevonden' + (category ? ` voor categorie '${category}'` : '') + '.';
    return notes.map(n => {
      const date = new Date(n.timestamp).toLocaleString('nl-NL', { day: '2-digit', month: '2-digit', hour: '2-digit', minute: '2-digit' });
      return `[${date}] (${n.category}) ${n.text}`;
    }).join('\n');
  } catch (e) {
    return 'Fout bij ophalen notities: ' + e.message;
  }
}

export async function get_kanban_tasks({ column = 'all', limit = 10 } = {}) {
  try {
    const data = await fetchJson('http://tasks.local/api/tasks');
    let tasks = data.tasks || data;
    if (column !== 'all') tasks = tasks.filter(t => t.column === column);
    tasks = tasks.filter(t => t.column !== 'done' || column === 'done').slice(0, limit);
    if (!tasks.length) return 'Geen taken gevonden' + (column !== 'all' ? ` in kolom '${column}'` : '') + '.';
    return tasks.map(t => `[${t.column.toUpperCase()}] ${t.title}${t.description ? ' — ' + t.description.slice(0, 80) : ''}`).join('\n');
  } catch (e) {
    return 'Fout bij ophalen taken: ' + e.message;
  }
}

export async function get_whatsapp_recent_messages({ limit = 10 } = {}) {
  try {
    const db = '/home/ubuntu/whatsapp-bot/data/whatsapp.db';
    const result = execSync(
      `sqlite3 -separator '|' ${db} "SELECT sender, chat_id, body, timestamp FROM messages ORDER BY timestamp DESC LIMIT ${limit};"`
      , { timeout: 5000 }
    ).toString().trim();
    if (!result) return 'Geen recente berichten gevonden.';
    return result.split('\n').map(line => {
      const [sender, chat, body, ts] = line.split('|');
      const date = ts ? new Date(ts).toLocaleString('nl-NL', { day: '2-digit', month: '2-digit', hour: '2-digit', minute: '2-digit' }) : '?';
      const chatName = chat?.includes('g.us') ? '(groep)' : '(prive)';
      return `[${date}] ${chatName} ${(body || '').slice(0, 120)}`;
    }).join('\n');
  } catch (e) {
    return 'Fout bij ophalen WhatsApp berichten: ' + e.message;
  }
}

export async function run_transcript_analyzer({ all = false } = {}) {
  try {
    mkdirSync(resolve(__dirname, '../jobs/logs'), { recursive: true });
    const jobId = Date.now().toString();
    const logFile = resolve(__dirname, `../jobs/logs/${jobId}-analyzer.log`);
    const cmd = `node ${resolve(__dirname, '../analyzer/analyze.mjs')}${all ? ' --all' : ''}`;
    const { spawn } = await import('child_process');
    const child = spawn('bash', ['-c', `${cmd} > ${logFile} 2>&1`], { detached: true, stdio: 'ignore' });
    child.unref();
    const jobs = existsSync(resolve(__dirname, '../jobs/jobs.json'))
      ? JSON.parse(readFileSync(resolve(__dirname, '../jobs/jobs.json'), 'utf-8')) : [];
    jobs.unshift({ id: jobId, name: 'Transcript Analyzer', command: cmd, status: 'running', startedAt: new Date().toISOString(), logFile });
    writeFileSync(resolve(__dirname, '../jobs/jobs.json'), JSON.stringify(jobs, null, 2));
    return `Transcript-analyzer gestart als achtergrondtaak (ID: ${jobId}). Gebruik check_background_task met dit ID om de status te zien. Log: ${logFile}`;
  } catch (e) {
    return 'Fout bij starten analyzer: ' + e.message;
  }
}

export async function get_available_tools({ search } = {}) {
  try {
    const registry = JSON.parse(readFileSync(resolve(__dirname, 'registry.json'), 'utf-8'));
    let tools = registry.filter(t => t.name && t.description);
    if (search) {
      const q = search.toLowerCase();
      tools = tools.filter(t => t.name.toLowerCase().includes(q) || t.description.toLowerCase().includes(q));
    }
    if (!tools.length) return 'Geen tools gevonden' + (search ? ` voor "${search}"` : '') + '.';
    return `${tools.length} tools beschikbaar:\n` + tools.map(t => `• ${t.name}: ${t.description.slice(0, 100)}`).join('\n');
  } catch (e) {
    return 'Fout bij ophalen tools: ' + e.message;
  }
}