# ============================================================ # MODULE: Agent Launchpad & Workflow Templates — FASE 4 # HSEQ Intelligence Dashboard # ============================================================ import json import sqlite3 import logging from datetime import datetime from flask import jsonify, request from indexer import DB_PATH from search import search_documents, get_db log = logging.getLogger('module_agents') def init_db_agents(): conn = sqlite3.connect(DB_PATH) c = conn.cursor() c.execute('''CREATE TABLE IF NOT EXISTS agent_tasks ( id INTEGER PRIMARY KEY AUTOINCREMENT, agent_id TEXT NOT NULL, agent_name TEXT NOT NULL, workflow_id TEXT, task_description TEXT NOT NULL, context TEXT, status TEXT DEFAULT 'pending', result TEXT, created_at TEXT DEFAULT CURRENT_TIMESTAMP, started_at TEXT, completed_at TEXT, metadata TEXT )''') conn.commit() conn.close() AGENTS = [ # ── 01_Engineering_Product ────────────────────────────────────────── {"id": "software_architect", "name": "Software Architect", "emoji": "💻", "description": "Software ontwikkeling & systeemarchitectuur", "skills": ["Systeemarchitectuur", "API Design", "Database Modelling", "Technische Blueprint", "Code Review"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "01_Engineering_Product"}, {"id": "backend_developer", "name": "Backend Architect", "emoji": "⚙️", "description": "Backend ontwikkeling — API's, microservices, databases", "skills": ["Backend Development", "API Integratie", "Data Pipelines", "Automatisering", "Server Config"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "01_Engineering_Product"}, {"id": "frontend_developer", "name": "Frontend Developer", "emoji": "🎨", "description": "Frontend ontwikkeling — React, Vue, UI implementatie", "skills": ["UI Implementatie", "Dashboard Development", "Responsive Design", "Interactieve Web apps", "CSS/JS"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "01_Engineering_Product"}, {"id": "database_administrator", "name": "Database Administrator", "emoji": "🗄️", "description": "Database optimalisatie — SQL, NoSQL, performancetuning", "skills": ["Database Optimalisatie", "Data Modelling", "Query Performance", "Backup & Recovery", "Migratie"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "01_Engineering_Product"}, {"id": "product_owner", "name": "Product Owner", "emoji": "🎯", "description": "Productmanagement — roadmap, requirements, stakeholdermanagement", "skills": ["Product Roadmap", "User Stories", "Requirement Analysis", "Stakeholder Management", "MVP Planning"], "deliverable_note": "DOCX rapport + XLSX backlog + HTML dashboard + Kennisdossier (DOCX)", "division": "01_Engineering_Product"}, {"id": "sprint_prioritizer", "name": "Sprint Prioritizer", "emoji": "📊", "description": "Sprint planning — backlog grooming, velocity, capacity", "skills": ["Sprint Planning", "Backlog Grooming", "Velocity Tracking", "Capacity Planning", "Release Planning"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "01_Engineering_Product"}, # ── 02_Design_Creative ────────────────────────────────────────────── {"id": "brand_strategist", "name": "Brand Guardian", "emoji": "🏷️", "description": "Merken identiteit — merkstrategie, positioning, richtlijnen", "skills": ["Merkstrategie", "Brand Positioning", "Huisstijl Ontwerp", "Brand Guidelines", "Visuele Identiteit"], "deliverable_note": "PPTX presentatie + DOCX rapport + HTML dashboard + Kennisdossier (DOCX)", "division": "02_Design_Creative"}, {"id": "graphic_designer", "name": "Graphic Designer", "emoji": "🖌️", "description": "Visueel ontwerp — infographics, iconen, document design", "skills": ["Infographics", "Icon Design", "Document Styling", "Visual Storytelling", "Data Visualisatie"], "deliverable_note": "PPTX presentatie + DOCX rapport + HTML dashboard + Kennisdossier (DOCX)", "division": "02_Design_Creative"}, {"id": "motion_designer", "name": "Motion Designer", "emoji": "🎬", "description": "Animatie & video — motion graphics, visuele storytelling", "skills": ["Motion Graphics", "Animatie", "Video Productie", "Visual Effects", "Storyboarding"], "deliverable_note": "PPTX presentatie + DOCX rapport + HTML dashboard + Kennisdossier (DOCX)", "division": "02_Design_Creative"}, {"id": "presentation_specialist", "name": "Presentation Specialist", "emoji": "📊", "description": "Presentaties & document design — PPTX, rapportages", "skills": ["PPTX Presentaties", "Rapportage Design", "Data Visualisatie", "Slide Master Templates", "Directie-Pitches"], "deliverable_note": "PPTX presentatie + DOCX rapport + HTML dashboard + Kennisdossier (DOCX)", "division": "02_Design_Creative"}, {"id": "ui_designer", "name": "UI Designer", "emoji": "🖼️", "description": "User Interface design — wireframes, mockups, design systems", "skills": ["Wireframes", "Mockups", "Design Systems", "UI Components", "Prototyping"], "deliverable_note": "PPTX presentatie + DOCX rapport + HTML dashboard + Kennisdossier (DOCX)", "division": "02_Design_Creative"}, {"id": "ux_architect", "name": "UX Architect", "emoji": "🧭", "description": "User Experience architectuur — usability, interactiepatronen", "skills": ["UX Research", "Interactieontwerp", "Usability Testing", "Informatiearchitectuur", "Gebruikerstests"], "deliverable_note": "PPTX presentatie + DOCX rapport + HTML dashboard + Kennisdossier (DOCX)", "division": "02_Design_Creative"}, # ── 03_Orchestration ──────────────────────────────────────────────── {"id": "agency_partner", "name": "Agency Partner", "emoji": "🤝", "description": "Agent-orkestratie — pipeline management, taakverdeling", "skills": ["Agent Orkestratie", "Pipeline Management", "Kwaliteitscontrole", "Taakdelegatie", "Workflow Design"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "03_Orchestration"}, {"id": "business_analyst", "name": "Business Analyst", "emoji": "📈", "description": "Business analyse — pipeline analytics, KPI's, rapportages", "skills": ["Business Analytics", "KPI Tracking", "Data Analyse", "Management Rapportages", "Trend Analyse"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "03_Orchestration"}, {"id": "project_manager", "name": "Project Manager", "emoji": "📋", "description": "Projectmanagement — planning, resources, voortgang", "skills": ["Project Planning", "Resource Management", "Risicomanagement", "Mijlpalen", "Voortgangsbewaking"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "03_Orchestration"}, {"id": "resource_planner", "name": "Experiment Tracker", "emoji": "🧪", "description": "Experiment tracking — A/B tests, resource allocatie", "skills": ["A/B Testing", "Experiment Design", "Resource Allocatie", "Metrics & KPI's", "Data-driven Beslissingen"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "03_Orchestration"}, {"id": "communication_manager", "name": "Communication Manager", "emoji": "📨", "description": "Git workflow governance — communicatie, documentbeheer", "skills": ["Git Workflow", "Documentbeheer", "Communicatie", "Change Management", "Release Notes"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "03_Orchestration"}, {"id": "scrum_master", "name": "Scrum Master", "emoji": "🏁", "description": "Scrum begeleiding — sprints, retrospectives, impediments", "skills": ["Scrum Facilitatie", "Sprint Begeleiding", "Retrospectives", "Impediment Management", "Team Coaching"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "03_Orchestration"}, # ── 04_GameDev_Unity_Roblox ───────────────────────────────────────── {"id": "character_artist", "name": "Character Artist", "emoji": "🧑‍🎨", "description": "Karaktercreatie — 3D modellen, textures, rigging", "skills": ["3D Modelleren", "Texturing", "Rigging", "Character Design", "Concept Art"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "04_GameDev_Unity_Roblox"}, {"id": "game_designer", "name": "Game Designer", "emoji": "🎮", "description": "Game design — mechanics, systems, balancering", "skills": ["Game Mechanics", "Systems Design", "Balancering", "Level Flow", "Player Progression"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard + Kennisdossier (DOCX)", "division": "04_GameDev_Unity_Roblox"}, {"id": "level_designer", "name": "Level Designer", "emoji": "🗺️", "description": "Level design — omgevingen, gameplay flow, iteratie", "skills": ["Level Layout", "Gameplay Flow", "Environment Design", "Iteratief Design", "Playtesting"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "04_GameDev_Unity_Roblox"}, {"id": "roblox_scripter", "name": "Roblox Systems Scripter", "emoji": "🧱", "description": "Roblox scripting — Luau, systems, monetization", "skills": ["Luau Scripting", "Roblox Studio", "Systems Scripting", "Monetization", "DataStores"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "04_GameDev_Unity_Roblox"}, {"id": "sound_engineer", "name": "Game Audio Engineer", "emoji": "🔊", "description": "Game audio — geluidseffecten, muziek, interactief geluid", "skills": ["Geluidseffecten", "Muziek Productie", "Interactief Audio", "FMOD/Wwise", "Audio Implementation"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "04_GameDev_Unity_Roblox"}, {"id": "unity_expert", "name": "Unity Architect", "emoji": "🕹️", "description": "Unity architectuur — C#, ECS, performantie optimalisatie", "skills": ["Unity C#", "ECS Architectuur", "Performantie Optimalisatie", "Shader Programming", "Cross-platform"], "deliverable_note": "Broncode + README (MD) + Kennisdossier (DOCX)", "division": "04_GameDev_Unity_Roblox"}, # ── 05_HSEQ_Support ───────────────────────────────────────────────── {"id": "compliance_auditor", "name": "Compliance Auditor", "emoji": "⚖️", "description": "Compliance & auditing specialist — wet- en regelgeving", "skills": ["BRZO 2015 Audits", "ISO 45001/14001/9001", "Gap-analyses", "Seveso III", "Wetgeving Interpretatie", "Certificering"], "deliverable_note": "DOCX rapport + XLSX gap-analyse + HTML overzicht + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "environmental_compliance", "name": "Environmental Compliance Manager", "emoji": "🌍", "description": "Milieu & omgeving — emissies, vergunningen, Omgevingswet", "skills": ["Emissie Registratie", "Omgevingsvergunning", "Omgevingswet", "MER Procedure", "Milieubeheer", "IPPC"], "deliverable_note": "DOCX rapport + XLSX data + HTML dashboard + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "hseq_specialist", "name": "HSEQ Specialist", "emoji": "🔬", "description": "Health, Safety, Environment & Quality — expert in BRZO, Arbowet, Milieu", "skills": ["BRZO compliance", "Risicoanalyse", "Inspectievoorbereiding", "HSEQ advies"], "deliverable_note": "DOCX rapport + XLSX risicotabel + HTML dashboard + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "plaud_specialist", "name": "Plaud Specialist", "emoji": "🎙️", "description": "Audio analyse pipeline — transcriptie, samenvatting, actiepunten", "skills": ["Audio Transcriptie", "Vergader-notulen", "Actiepunten Extractie", "Besluitenlijst", "HSEQ Context"], "deliverable_note": "DOCX rapport + XLSX acties + HTML overzicht + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "qa_engineer", "name": "QA Engineer", "emoji": "✅", "description": "Quality Assurance — ISO 9001, KAM, procesvalidatie", "skills": ["ISO 9001", "KAM", "Procesvalidatie", "Kwaliteitscontrole"], "deliverable_note": "DOCX rapport + XLSX checklist + HTML overzicht + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "support_lead", "name": "Support Lead", "emoji": "🎧", "description": "Support & helpdesk — incidentafhandeling, kennisbank, escalatie", "skills": ["Incidentafhandeling", "Kennisbank Beheer", "Escalatie Protocollen", "SLA Management", "Root Cause Analysis"], "deliverable_note": "DOCX rapport + XLSX overzicht + HTML dashboard + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "technical_writer", "name": "Technical Writer", "emoji": "📝", "description": "Technische documentatie — procedures, handleidingen, rapporten", "skills": ["HSEQ Procedures", "Werkinstructies", "Technische Rapporten", "Beleidsdocumenten", "NEN-ISO 26514"], "deliverable_note": "DOCX procedure + XLSX bijlagen + HTML preview + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "risk_management", "name": "Risk Management Specialist", "emoji": "📊", "description": "Risicomanagement — HAZOP, LOPA, QRA, Bow-Tie", "skills": ["HAZOP Analyse", "LOPA", "QRA", "Bow-Tie", "FMEA/FMECA", "Risicomatrix", "IEC 61511"], "deliverable_note": "DOCX rapport + XLSX risicomatrix + HTML dashboard + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "training_generator", "name": "Training Generator", "emoji": "🎓", "description": "Training ontwikkeling — toolbox talks, e-learning, VCA", "skills": ["Toolbox Talks", "Training Ontwerp", "VCA Basis/VOL", "E-learning Modules", "Quiz & Toetsing", "Didactiek"], "deliverable_note": "Docentenhandleiding (DOCX) + Werkboek (DOCX) + Presentatie (PPTX) + Quiz (HTML) + eLearning (HTML) + Kennisdossier (DOCX)", "division": "05_HSEQ_Support"}, {"id": "pgs15_scanner", "name": "PGS 15 Scanner", "emoji": "🔥", "description": "PGS 15 brandveiligheids scanner — detecteert overtredingen, genereert actieplan", "skills": ["PGS 15 Richtlijnen", "Brandveiligheid", "Opslagregels", "Gevaarlijke Stoffen", "Risicoanalyse"], "deliverable_note": "PGS 15 rapport (DOCX) + XLSX overtredingen + aanbevelingen", "url": "https://mescalinerabbit.shop/pgs15-scanner/", "division": "05_HSEQ_Support"}, {"id": "reach_scanner", "name": "REACH Scanner", "emoji": "🧪", "description": "REACH chemische stoffen scanner — registreert stoffen, volgt ECHA status", "skills": ["REACH Richtlijnen", "Chemie Regels", "ECHA Procedures", "STOFFEN Data", "Milestone Tracking"], "deliverable_note": "REACH rapport (DOCX) + XLSX stoffenregistratie + deadlines", "url": "https://mescalinerabbit.shop/reach-scanner/", "division": "05_HSEQ_Support"}, ] WORKFLOWS = [ {"id": "rie_opstellen", "name": "RI&E Opstellen", "description": "Volledige Risico-Inventarisatie & Evaluatie opstellen", "agents": ["hseq_specialist", "risk_management"], "questions": [ {"id": "company", "label": "Bedrijfsnaam", "type": "text"}, {"id": "sector", "label": "Sector", "type": "select", "options": ["Petrochemie", "Chemie", "Oil & Gas", "Offshore", "Bouw", "Industrie", "Overig"]}, {"id": "employees", "label": "Aantal medewerkers", "type": "select", "options": ["1-10", "11-50", "51-200", "200+"]}, {"id": "activities", "label": "Hoofdactiviteiten", "type": "textarea"}, {"id": "hazardous_substances", "label": "Worden er gevaarlijke stoffen gebruikt?", "type": "select", "options": ["Ja", "Nee", "Onbekend"]}, {"id": "existing_rie", "label": "Is er al een RI&E?", "type": "select", "options": ["Ja, moet geactualiseerd", "Nee, moet nieuw", "Onbekend"]}, ], "output": "RI&E document (DOCX)"}, {"id": "tra_maken", "name": "TRA Maken", "description": "Taakrisicoanalyse opstellen voor specifieke werkzaamheden", "agents": ["hseq_specialist", "qa_engineer"], "questions": [ {"id": "task", "label": "Taak/werkzaamheid", "type": "text"}, {"id": "location", "label": "Locatie", "type": "text"}, {"id": "frequency", "label": "Frequentie", "type": "select", "options": ["Dagelijks", "Wekelijks", "Maandelijks", "Incidenteel"]}, {"id": "hazards", "label": "Bekende gevaren", "type": "textarea"}, {"id": "ppe", "label": "Vereiste PBM", "type": "text"}, ], "output": "TRA document"}, {"id": "training_prep", "name": "Training Prep", "description": "Training voorbereiden met presentatie en quiz", "agents": ["training_generator", "presentation_specialist"], "questions": [ {"id": "topic", "label": "Onderwerp", "type": "text"}, {"id": "target_audience", "label": "Doelgroep", "type": "select", "options": ["Operateurs", "Supervisors", "Management", "Contractors", "Alle medewerkers"]}, {"id": "duration", "label": "Duur", "type": "select", "options": ["30 min", "1 uur", "2 uur", "Halve dag", "Hele dag"]}, {"id": "level", "label": "Niveau", "type": "select", "options": ["Basis", "Gevorderd", "Specialist"]}, ], "output": "PPTX + Quiz"}, {"id": "compliance_check", "name": "Compliance Check", "description": "Uitgebreide compliance check tegen relevante wetgeving", "agents": ["compliance_auditor"], "questions": [ {"id": "company", "label": "Bedrijfsnaam", "type": "text"}, {"id": "regulations", "label": "Relevante wetgeving", "type": "multiselect", "options": ["BRZO", "Seveso", "Arbowet", "Omgevingswet", "PGS", "REACH/CLP", "ISO 45001", "ISO 14001"]}, {"id": "scope", "label": "Scope van de check", "type": "textarea"}, ], "output": "Rapport + aanbevelingen"}, {"id": "audit_prep", "name": "Audit Voorbereiding", "description": "Voorbereiding op interne of externe audit", "agents": ["qa_engineer", "compliance_auditor"], "questions": [ {"id": "audit_type", "label": "Type audit", "type": "select", "options": ["ISO 45001", "ISO 14001", "ISO 9001", "VCA", "ILT inspectie", "BRZO inspectie", "Interne audit"]}, {"id": "scope", "label": "Auditscope", "type": "textarea"}, {"id": "date", "label": "Geplande datum", "type": "text"}, {"id": "previous_findings", "label": "Eerdere bevindingen", "type": "textarea"}, ], "output": "Checklist + voorbereiding"}, {"id": "incident_analyse", "name": "Incident Analyse", "description": "Uitgebreide analyse van een incident met verbetermaatregelen", "agents": ["hseq_specialist"], "questions": [ {"id": "incident_type", "label": "Type incident", "type": "select", "options": ["Lekkage", "Brand/ontploffing", "Blessure", "Milieu-incident", "Near miss", "Bruikbare afwijking"]}, {"id": "description", "label": "Beschrijving van het incident", "type": "textarea"}, {"id": "location", "label": "Locatie", "type": "text"}, {"id": "date", "label": "Datum", "type": "text"}, {"id": "immediate_actions", "label": "Genomen directe maatregelen", "type": "textarea"}, ], "output": "Analyse + verbetermaatregelen"}, ] def register_agent_routes(flask_app, page_func, BASE_PATH="/hseq-dashboard"): @flask_app.route(BASE_PATH + '/agents') def agents_page(): body = '''

🤖 Agent Launchpad

Start gespecialiseerde HSEQ-agents voor complexe taken.

{% for agent in agents %}
{{agent.emoji}}
{{agent.name}}
{% if agent.url %} {% endif %}
{{agent.description}}
{% for skill in agent.skills[:3] %} {{skill}} {% endfor %}
{% if agent.deliverable_note %}
📦 {{agent.deliverable_note}}
{% endif %}
{% endfor %}

📋 Workflow Templates

{% for wf in workflows %}
{{wf.name}}
{{wf.description}}
Agents: {{wf.agents|length}} 📦 {{wf.output}}
{% endfor %}

📊 Taak Historie

⏳ Executor status laden...
Laden...
''' return page_func(body, page_title='Agent Launchpad', active='agents', agents=AGENTS, workflows=WORKFLOWS, agents_json=json.dumps(AGENTS), workflows_json=json.dumps(WORKFLOWS)) @flask_app.route(BASE_PATH + '/api/agents') def api_agents_list(): return jsonify({'agents': AGENTS}) @flask_app.route(BASE_PATH + '/api/agents/task', methods=['POST']) def api_agents_task_create(): d = request.get_json() agent_id = d.get('agent_id', '') agent_name = d.get('agent_name', agent_id) task_desc = d.get('task_description', '') context = d.get('context', '') workflow_id = d.get('workflow_id') if not agent_id or not task_desc: return jsonify({'error': 'Agent en taakbeschrijving zijn verplicht'}), 400 kb_context = '' try: results = search_documents(task_desc) if results and results.get('results'): for r in results['results'][:5]: content = r.get('content','') or r.get('snippet','') or '' if content: kb_context += "\n--- %s [%s] ---\n%s\n" % (r.get('title',''), r.get('category',''), content[:2000]) except Exception as e: log.warning(f'KB search failed: {e}') conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO agent_tasks (agent_id, agent_name, workflow_id, task_description, context, status, metadata) VALUES (?,?,?,?,?,?,?)', (agent_id, agent_name, workflow_id, task_desc, context or kb_context, 'pending', json.dumps({'kb_context': kb_context[:8000], 'submitted_context': context}))) conn.commit() task_id = conn.execute('SELECT last_insert_rowid()').fetchone()[0] conn.close() return jsonify({'ok': True, 'task_id': task_id, 'message': 'Taak gestart voor %s' % agent_name}) @flask_app.route(BASE_PATH + '/api/agents/tasks') def api_agents_tasks_list(): conn = sqlite3.connect(DB_PATH) rows = conn.execute('SELECT id, agent_id, agent_name, workflow_id, task_description, status, created_at, completed_at FROM agent_tasks ORDER BY created_at DESC LIMIT 50').fetchall() conn.close() return jsonify({'tasks': [ {'id':r[0],'agent_id':r[1],'agent_name':r[2],'workflow_id':r[3], 'task_description':r[4],'status':r[5],'created_at':r[6],'completed_at':r[7]} for r in rows]}) @flask_app.route(BASE_PATH + '/api/agents/task/') def api_agents_task_get(task_id): conn = sqlite3.connect(DB_PATH) row = conn.execute('SELECT id, agent_id, agent_name, workflow_id, task_description, context, status, result, created_at, started_at, completed_at, metadata, deliverable_file FROM agent_tasks WHERE id=?', (task_id,)).fetchone() conn.close() if not row: return jsonify({'error': 'Taak niet gevonden'}), 404 return jsonify({'id':row[0],'agent_id':row[1],'agent_name':row[2],'workflow_id':row[3], 'task_description':row[4],'context':row[5],'status':row[6],'result':row[7], 'created_at':row[8],'started_at':row[9],'completed_at':row[10],'metadata':row[11], 'deliverable_file':row[12]}) @flask_app.route(BASE_PATH + '/api/agents/workflows') def api_agents_workflows_list(): return jsonify({'workflows': WORKFLOWS}) @flask_app.route(BASE_PATH + '/api/agents/workflow//run', methods=['POST']) def api_agents_workflow_run(workflow_id): wf = next((w for w in WORKFLOWS if w['id'] == workflow_id), None) if not wf: return jsonify({'error': 'Workflow niet gevonden'}), 404 d = request.get_json() or {} conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO agent_tasks (agent_id, agent_name, workflow_id, task_description, context, status, metadata) VALUES (?,?,?,?,?,?,?)', (wf['agents'][0], wf['name'], workflow_id, wf['name']+': '+json.dumps(d), json.dumps(d), 'pending', json.dumps({'workflow_answers': d}))) conn.commit() task_id = conn.execute('SELECT last_insert_rowid()').fetchone()[0] conn.close() return jsonify({'ok': True, 'task_id': task_id, 'workflow': wf['name']}) @flask_app.route(BASE_PATH + '/api/kb/search') def api_kb_search(): q = request.args.get('q', '').strip() if not q: return jsonify({'results': []}) try: results = search_documents(q, limit=10) items = [] for r in results.get('results', [])[:10]: items.append({'id': r.get('id'), 'title': r.get('title') or r.get('filename', ''), 'category': r.get('category', '')}) return jsonify({'results': items}) except: return jsonify({'results': []})