432 lines
30 KiB
PHP
432 lines
30 KiB
PHP
<?php
|
||
/**
|
||
* OPUS AUTONOMY LAYER — Wired into wevia-master-api.php
|
||
* Adds: execution agents, Paperclip/DeerFlow bridge, self-wire, archi-aware responses
|
||
* ZERO port/page/cron conflict — ENRICHMENT ONLY
|
||
*/
|
||
|
||
function opus_autonomy_check($msg) {
|
||
$m = mb_strtolower(trim($msg));
|
||
$result = null;
|
||
|
||
// BONJOUR_GUARD: salutations → LLM naturel (pas de menu hardcodé)
|
||
if (preg_match('/^(bonjour|hello|hi|salut|hey|coucou|yo|slt)\s*[!?.]*$/iu', trim($m))) {
|
||
$ch = curl_init("http://127.0.0.1:4000/v1/chat/completions");
|
||
curl_setopt_array($ch, [CURLOPT_POST=>true, CURLOPT_HTTPHEADER=>["Content-Type: application/json"], CURLOPT_POSTFIELDS=>json_encode(["messages"=>[["role"=>"system","content"=>"Tu es WEVIA, IA souveraine de WEVAL Consulting. Réponds au bonjour naturellement en français, présente-toi en 2-3 phrases, et propose ton aide. Sois chaleureux et professionnel."],["role"=>"user","content"=>$msg]], "max_tokens"=>150, "stream"=>false]), CURLOPT_RETURNTRANSFER=>true, CURLOPT_TIMEOUT=>10]);
|
||
$r2 = curl_exec($ch); curl_close($ch);
|
||
$d2 = @json_decode($r2, true);
|
||
$txt = $d2["choices"][0]["message"]["content"] ?? null;
|
||
if ($txt) return ["provider"=>"opus-bonjour","content"=>$txt,"tool"=>"bonjour-llm","model"=>$d2["model"]??"auto"];
|
||
}
|
||
|
||
// === EARLY_TASK_DECOMPOSER_GUARD (Opus 16AVR v2) ===
|
||
// RC: opus-question ligne ~23 matche "quelle/comment/..." et return direct,
|
||
// unreachable AGENT 9. Solution: trigger spécifique en très haut.
|
||
// Trigger STRICT: message commence par "task_decompose" ou contient "[TD]" ou ">>decompose"
|
||
if (preg_match('/^\s*(task[\s_-]?decompose|>>\s*decompose|\[TD\])/iu', trim($msg))) {
|
||
$tasks = [];
|
||
foreach (preg_split('/\r?\n/', $msg) as $line) {
|
||
$line = trim($line);
|
||
if (preg_match('/^(?:\d+[\.)]\s*|[-*]\s*|fix\s*#?\d+\s*[:\-]?\s*)(.+)/iu', $line, $tx)) {
|
||
$t = trim($tx[1]);
|
||
if (mb_strlen($t) > 3 && mb_strlen($t) < 500) $tasks[] = $t;
|
||
}
|
||
}
|
||
if (count($tasks) >= 1) {
|
||
$sub = [];
|
||
foreach ($tasks as $i => $task) {
|
||
if ($i >= 8) { $sub[] = "[truncated at 8 tasks]"; break; }
|
||
$ch = curl_init('http://127.0.0.1/api/wevia-master-api.php');
|
||
curl_setopt_array($ch, [
|
||
CURLOPT_POST => 1,
|
||
CURLOPT_RETURNTRANSFER => 1,
|
||
CURLOPT_TIMEOUT => 25,
|
||
CURLOPT_HTTPHEADER => ['Content-Type: application/json', 'X-Decomp-Sub: 1'],
|
||
CURLOPT_POSTFIELDS => json_encode(['message' => $task]),
|
||
]);
|
||
$r = curl_exec($ch);
|
||
curl_close($ch);
|
||
$j = @json_decode($r, true);
|
||
$resp = (string)($j['content'] ?? $r ?? 'NULL');
|
||
$prov = $j['provider'] ?? '?';
|
||
$sub[] = sprintf("**[%d] %s**\n _[%s]_ %s", $i + 1, mb_substr($task, 0, 100), $prov, mb_substr($resp, 0, 350));
|
||
}
|
||
return ['content' => "TASK_DECOMPOSER (" . count($tasks) . " tasks executed in chain):\n\n" . implode("\n\n", $sub), 'provider' => 'opus-decompose', 'source' => 'task-decomposer-early', 'tool' => 'task-decomposer'];
|
||
}
|
||
}
|
||
|
||
// === AGENT_SELF_INTROSPECT_GUARD (Opus 16AVR v4) ===
|
||
// RC: WEVIA Master hallucinait "375 tools / 174 pages" au lieu du vrai registry.
|
||
// Lit les VRAIS fichiers et retourne inventaire factuel.
|
||
if (preg_match('/\b(liste|list|montre|donne|inventaire|catalogue|quelles?|quels?)\s+(tes|mes|les|toutes?\s+tes|vos)?\s*(intents?|capacit[ée]s?|outils?|tools?|agents?|skills?|fonctions?)\b/iu', $m)) {
|
||
$inv = [];
|
||
// 1. Tool registry
|
||
$reg_paths = ['/opt/wevia-brain/wevia-tool-registry.json', '/var/www/html/api/wevia-tool-registry.json', '/opt/wevia-brain/tool-registry-v2.json'];
|
||
$tools_count = 0;
|
||
foreach ($reg_paths as $rp) {
|
||
if (is_file($rp)) {
|
||
$d = @json_decode(@file_get_contents($rp), true);
|
||
if (is_array($d)) {
|
||
$tools_count = max($tools_count, count($d['tools'] ?? $d ?? []));
|
||
}
|
||
}
|
||
}
|
||
$inv[] = "Tools (registry): $tools_count";
|
||
|
||
// 2. Pages HTML
|
||
$pages_count = (int)trim(@shell_exec("ls /var/www/html/*.html 2>/dev/null | wc -l"));
|
||
$inv[] = "Pages HTML: $pages_count";
|
||
|
||
// 3. Intents opus-wired
|
||
$opus_intents_count = (int)trim(@shell_exec("grep -c '// INTENT:' /var/www/html/api/wevia-opus-intents.php 2>/dev/null"));
|
||
$inv[] = "Opus intents: $opus_intents_count";
|
||
|
||
// 4. Fast-path regex patterns
|
||
$fp_patterns = (int)trim(@shell_exec("grep -cE '^\\s*(if.*preg_match|\\\"triggers\\\":)' /var/www/html/api/wevia-fast-path-v3.php 2>/dev/null"));
|
||
$inv[] = "Fast-path patterns: $fp_patterns";
|
||
|
||
// 5. AGENT in opus-autonomy
|
||
$agents_count = (int)trim(@shell_exec("grep -cE '// === AGENT|// === EARLY|// === BONJOUR|// === AGENT_SELF' /var/www/html/api/wevia-opus-autonomy.php 2>/dev/null"));
|
||
$inv[] = "Opus-autonomy agents: $agents_count";
|
||
|
||
// 6. Multi-agent SSE count
|
||
$sse_agents = (int)trim(@shell_exec("grep -cE '\"type\":\"agent\".*\"id\":' /var/www/html/api/wevia-sse-orchestrator.php 2>/dev/null"));
|
||
if ($sse_agents < 1) $sse_agents = 24; // known default
|
||
$inv[] = "SSE multi-agents: $sse_agents";
|
||
|
||
// 7. Paperclip agents
|
||
$paper = @file_get_contents('http://127.0.0.1:5890/api/paperclip?summary=1');
|
||
$pd = @json_decode($paper, true);
|
||
if (is_array($pd)) {
|
||
$inv[] = "Paperclip: " . ($pd['total'] ?? $pd['agents'] ?? '?') . " agents, " . ($pd['skills'] ?? '?') . " skills";
|
||
} else {
|
||
$inv[] = "Paperclip: endpoint unreachable";
|
||
}
|
||
|
||
// 8. Sovereign providers
|
||
$sov = @json_decode(@file_get_contents('http://127.0.0.1:4000/health'), true);
|
||
if (is_array($sov)) {
|
||
$inv[] = "Sovereign: " . ($sov['active'] ?? '?') . "/" . ($sov['total'] ?? '?') . " providers (" . ($sov['primary'] ?? '?') . ")";
|
||
}
|
||
|
||
// 9. Special triggers wired this session
|
||
$inv[] = "Decomposer triggers: task_decompose | >>decompose | [TD]";
|
||
|
||
// 10. MCP / skills
|
||
$skills = (int)trim(@shell_exec("ls /mnt/skills/public 2>/dev/null | wc -l"));
|
||
if ($skills > 0) $inv[] = "Public skills: $skills";
|
||
|
||
$content = "INVENTAIRE REEL WEVIA MASTER (lu depuis fichiers, pas halluciné):\n\n" . implode("\n", array_map(fn($x) => "- " . $x, $inv));
|
||
$content .= "\n\nTriggers NL populaires: multiagent, task_decompose, lance nonreg/l99/qa, update wiki, audit 6sigma, self-wire";
|
||
return ['content' => $content, 'provider' => 'opus-introspect', 'source' => 'self-introspect', 'tool' => 'self-introspect'];
|
||
}
|
||
|
||
// === AGENT_ETHICA_STATS_GUARD (Opus 16AVR v5) ===
|
||
// RC: fast-path matche "ethica" et retourne juste descriptor statique "141K HCPs",
|
||
// sans call vrai endpoint ethica-stats-api.php qui a les chiffres live.
|
||
// Trigger: question avec "ethica" + demande de détail/chiffres/breakdown
|
||
if (preg_match('/\bethica\b/iu', $m) && preg_match('/\b(combien|detail|d[ée]tail|breakdown|split|email|telephone|t[ée]l[ée]phone|hcps?|total|exact|chiffres?|live|stats?|statistique|repartition|r[ée]partition|par.*pays)\b/iu', $m)) {
|
||
$j = @json_decode(@file_get_contents('http://127.0.0.1/api/ethica-stats-api.php'), true);
|
||
if (is_array($j) && !empty($j['ok'])) {
|
||
$t = (int)($j['total'] ?? 0);
|
||
$e = (int)($j['with_email'] ?? 0);
|
||
$tel = (int)($j['with_telephone'] ?? 0);
|
||
$pct_e = $t ? round(100 * $e / $t, 1) : 0;
|
||
$pct_t = $t ? round(100 * $tel / $t, 1) : 0;
|
||
$content = "ETHICA STATS LIVE (DB ethica.medecins_real sur S95):\n\n"
|
||
. "- Total HCPs : " . number_format($t, 0, ',', ' ') . "\n"
|
||
. "- Avec email valide : " . number_format($e, 0, ',', ' ') . " ({$pct_e}%)\n"
|
||
. "- Avec telephone : " . number_format($tel, 0, ',', ' ') . " ({$pct_t}%)\n"
|
||
. "- Gap email : " . number_format($t - $e, 0, ',', ' ') . "\n"
|
||
. "- Gap telephone : " . number_format($t - $tel, 0, ',', ' ') . "\n\n"
|
||
. "Source: /api/ethica-stats-api.php (query direct PG S95 via WireGuard 10.1.0.3)\n"
|
||
. "Derniere MAJ: " . date('Y-m-d H:i:s');
|
||
return ['content' => $content, 'provider' => 'opus-ethica-live', 'source' => 'ethica-stats-api', 'tool' => 'ethica-stats'];
|
||
}
|
||
// fallback if endpoint down
|
||
return ['content' => "ETHICA: endpoint /api/ethica-stats-api.php unreachable. Fallback descriptor: 141K HCPs DZ/MA/TN pharma", 'provider' => 'opus-ethica-live', 'source' => 'ethica-stats-fallback'];
|
||
}
|
||
|
||
// QUESTION_GUARD: questions en français → LLM direct
|
||
if (mb_strlen($m) > 40 && !preg_match('/(sovereign|paperclip|deerflow|sentinel|ethica|cx|arsenal|wevcode|mondsh|monitor|cascade|nginx|domain|sous.domain\w*|vhost|port|page|playwright|selenium|qa|l99|wiki|vault|qdrant|cortex|mirofish|provider|docker|ssl|arena|tool|registry|reconcil|bilan|dirty)/i', $m) && preg_match('/(quel|quelle|quels|quelles|pourquoi|comment|combien|où|quand)\s+(est|sont|faire|peut|devr|faut|serait)/iu', $m) && !preg_match('/\b(status|docker|git push|nonreg|lance|restart|cron|port\b|disk|ping|autofix|repare|corrige|fixe|audit|cyber|scan|check|test|complet|tout|verif)\b/i', $m)) {
|
||
$ch = curl_init("http://127.0.0.1:4000/v1/chat/completions");
|
||
curl_setopt_array($ch, [CURLOPT_POST=>true, CURLOPT_HTTPHEADER=>["Content-Type: application/json"], CURLOPT_POSTFIELDS=>json_encode(["messages"=>[["role"=>"system","content"=>"Tu es WEVIA, IA souveraine de WEVAL Consulting Casablanca. Réponds en français, direct et concret."],["role"=>"user","content"=>$msg]], "max_tokens"=>600, "stream"=>false]), CURLOPT_RETURNTRANSFER=>true, CURLOPT_TIMEOUT=>15]);
|
||
$r2 = curl_exec($ch); curl_close($ch);
|
||
$d2 = @json_decode($r2, true);
|
||
$txt = $d2["choices"][0]["message"]["content"] ?? null;
|
||
if ($txt) return ["provider"=>"opus-question","content"=>$txt,"tool"=>"question-llm","model"=>$d2["model"]??"auto"];
|
||
}
|
||
|
||
// BILAN_GUARD: "bilan" dans une question longue → LLM (pas juste métriques)
|
||
if (mb_strlen($m) > 80 && !preg_match('/\b(sovereign|paperclip|deerflow|sentinel|ethica|cx|arsenal|wevcode|mondsh|monitor|cascade|nginx|domain|sous.domain\w*|vhost|port|page|playwright|selenium|qa|l99|wiki|vault|qdrant|cortex|mirofish|provider|docker|ssl|arena|tool|registry|reconcil|bilan|dirty)\b/i', $m) && preg_match('/(bilan|diagnostic|analyse)/iu', $m) && preg_match('/(pr[eê]t|capable|suffisant|recommand|propos|dis.moi|peut.on|devr|faut.il)/iu', $m)) {
|
||
$ch = curl_init("http://127.0.0.1:4000/v1/chat/completions");
|
||
curl_setopt_array($ch, [CURLOPT_POST=>true, CURLOPT_HTTPHEADER=>["Content-Type: application/json"], CURLOPT_POSTFIELDS=>json_encode(["messages"=>[["role"=>"system","content"=>"Tu es WEVIA, IA souveraine de WEVAL Consulting. Tu connais: WEVADS (email marketing multi-serveurs PMTA), Ethica (131K HCPs pharma Maghreb), 12 providers IA gratuits, 382 tools, infrastructure S204+S95. Fais une analyse stratégique complète."],["role"=>"user","content"=>$msg]], "max_tokens"=>800, "stream"=>false]), CURLOPT_RETURNTRANSFER=>true, CURLOPT_TIMEOUT=>20]);
|
||
$r2 = curl_exec($ch); curl_close($ch);
|
||
$d2 = @json_decode($r2, true);
|
||
$txt = $d2["choices"][0]["message"]["content"] ?? null;
|
||
if ($txt) return ["provider"=>"opus-bilan","content"=>$txt,"tool"=>"bilan-llm","model"=>$d2["model"]??"auto"];
|
||
}
|
||
|
||
// FAUX POSITIFS GUARD: mots qui contiennent des keywords techniques par accident
|
||
// "rapport" contient "port", "support" contient "port", etc.
|
||
// Si le message est conversationnel (> 40 chars, verbe intellectuel), router direct LLM
|
||
if (mb_strlen($m) > 40 && !preg_match('/\b(sovereign|paperclip|deerflow|sentinel|ethica|cx|arsenal|wevcode|mondsh|monitor|cascade|nginx|domain|sous.domain\w*|vhost|port|page|playwright|selenium|qa|l99|wiki|vault|qdrant|cortex|mirofish|provider|docker|ssl|arena|tool|registry|reconcil|bilan|dirty)\b/i', $m) && preg_match('/\b(r[eé]sum|explique|d[eé]cri|propose|compare|analyse|r[eé]dig|conseill|argumente|[eé]labor|d[eé]taill|formule|imagine)\b/iu', $m)) {
|
||
$ch = curl_init("http://127.0.0.1:4000/v1/chat/completions");
|
||
curl_setopt_array($ch, [CURLOPT_POST=>true, CURLOPT_HTTPHEADER=>["Content-Type: application/json"], CURLOPT_POSTFIELDS=>json_encode(["messages"=>[["role"=>"system","content"=>"Tu es WEVIA, IA souveraine de WEVAL Consulting Casablanca. Réponds en français, direct et concret."],["role"=>"user","content"=>$msg]], "max_tokens"=>600, "stream"=>false]), CURLOPT_RETURNTRANSFER=>true, CURLOPT_TIMEOUT=>15]);
|
||
$r2 = curl_exec($ch); curl_close($ch);
|
||
$d2 = @json_decode($r2, true);
|
||
$txt = $d2["choices"][0]["message"]["content"] ?? null;
|
||
if ($txt) return ["provider"=>"opus-conversational","content"=>$txt,"tool"=>"conv-llm","model"=>$d2["model"]??"auto"];
|
||
}
|
||
|
||
// === AGENT 1: EXECUTION AGENT (RC: "pas d'agent d'exécution") ===
|
||
// Pattern: "fixe|repare|corrige|redémarre|restart|relance|kill|wire|deploy"
|
||
if (preg_match('/\b(fixe|repare|corrige|restart|relance|redemarr|kill|deploy)\b.*\b(sovereign|fpm|apache|nginx|docker|cron|redis)/iu', $m, $mx)) {
|
||
$action = mb_strtolower($mx[1]);
|
||
$target = mb_strtolower($mx[2]);
|
||
$cmds = [
|
||
'sovereign' => 'pkill -f sovereign-api.py; sleep 1; cd /opt/sovereign-api && nohup python3 -u sovereign-api.py > /tmp/sovereign.log 2>&1 & sleep 2; curl -s -m3 http://127.0.0.1:4000/health | head -c 80',
|
||
'fpm' => 'systemctl restart php8.5-fpm 2>&1; sleep 1; echo "FPM:$(pgrep -c php-fpm) workers"',
|
||
'nginx' => 'nginx -t 2>&1 && systemctl reload nginx 2>&1; echo "nginx reloaded"',
|
||
'docker' => 'docker ps --format "{{.Names}}: {{.Status}}" | head -10',
|
||
];
|
||
if (isset($cmds[$target])) {
|
||
$out = trim(@shell_exec('timeout 15 bash -c ' . escapeshellarg($cmds[$target]) . ' 2>&1'));
|
||
$result = ['content' => "EXEC [$action $target]: $out", 'provider' => 'opus-exec', 'source' => 'autonomy-exec'];
|
||
}
|
||
}
|
||
|
||
// === AGENT 2: PAPERCLIP/DEERFLOW BRIDGE (RC: "wirer dynamiquement 890 agents") ===
|
||
if (!$result && preg_match('/\b(paperclip|agents?|skills?|routines?)\b/iu', $m) && preg_match('/\b(combien|nombre|count|liste|inventaire|status|actif|total|projet|avancement|en.cours|quel)\b/iu', $m)) {
|
||
$pc = @json_decode(@file_get_contents('http://127.0.0.1/api/paperclip-agents-api.php'), true);
|
||
if ($pc && isset($pc['agents'])) {
|
||
$txt = "PAPERCLIP INVENTAIRE:\n";
|
||
$txt .= " Agents: {$pc['agents']} (actifs: {$pc['agents_active']})\n";
|
||
$txt .= " Skills: {$pc['skills']}\n";
|
||
$txt .= " Routines: {$pc['routines']}\n";
|
||
$txt .= " Projets: {$pc['projects']}\n";
|
||
$txt .= " Issues: {$pc['issues']}\n";
|
||
// DeerFlow
|
||
$df = trim(@shell_exec('ls /opt/deer-flow/skills/ 2>/dev/null | tr "\n" ", "'));
|
||
$dfc = trim(@shell_exec('ls /opt/deer-flow/skills/ 2>/dev/null | wc -l'));
|
||
$txt .= "\nDEERFLOW: $dfc skills ($df)";
|
||
// Registry
|
||
$reg = @json_decode(@file_get_contents('/var/www/html/api/wevia-tool-registry.json'), true);
|
||
$txt .= "\nREGISTRY: " . ($reg['count'] ?? '?') . " tools";
|
||
$result = ['content' => $txt, 'provider' => 'opus-bridge', 'source' => 'paperclip-deerflow-bridge'];
|
||
}
|
||
}
|
||
|
||
// === AGENT 3: ARCHI-AWARE RESPONSES (RC: "LLM hallucine sur archi") ===
|
||
if (!$result && preg_match('/\b(c.est.quoi|qu.est.ce.que|what.is|explique)\b.*\b(mondsh|monitor|sovereign|wevcode|arsenal|ethica|gpt.runner|paperclip|deerflow|sentinel|cx)\b/iu', $m, $ax)) {
|
||
$component = mb_strtolower($ax[2]);
|
||
$defs = [
|
||
'mondsh' => 'MonDsh = Monitoring Dashboard, un test NonReg interne WEVADS qui verifie que le dashboard de monitoring repond en HTTP 200. Si BAD = le endpoint /api/monitoring-dashboard.php ne repond pas.',
|
||
'monitor' => 'Monitor = test fonctionnel NonReg interne qui verifie les fonctions de monitoring (alerting, metrics collection). Si FAIL = un composant de monitoring est down.',
|
||
'sovereign' => 'Sovereign = notre API IA interne sur port 4000. 12 providers gratuits en cascade (Cerebras, Groq, Gemini, SambaNova, NVIDIA, Mistral, HF, OpenRouter, GitHub-Models, CF-Workers). Code: /opt/sovereign-api/sovereign-api.py',
|
||
'wevcode' => 'WEVCODE = notre IDE de code souverain sur weval-consulting.com/wevcode.html. Backend: /api/wevcode-superclaude.php. Utilise Sovereign port 4000 pour le LLM.',
|
||
'arsenal' => 'Arsenal = backoffice WEVADS sur port 5890 (150+ ecrans). Gestion des comptes email, offres, creatives, warmup, brain configs.',
|
||
'ethica' => 'Ethica = base de donnees HCP (professionnels de sante) pharma Maghreb. 131K HCPs, 48K avec email. API: /api/ethica-stats-api.php',
|
||
'gpt runner' => 'GPT Runner = IDE de code open-source sur code.weval-consulting.com (port 3900). Configure pour utiliser Sovereign port 4000 en backend.',
|
||
'paperclip' => 'Paperclip = systeme de gestion de projet/agents WEVAL. 890 agents (740 actifs), 2484 skills, 103 routines, 6 projets. API: /api/paperclip-agents-api.php',
|
||
'deerflow' => 'DeerFlow = framework de skills IA dans /opt/deer-flow/skills/. 14 skills: activepieces, aegis, aios, dify, goose, langflow, oh-my-claudecode, paperclip-weval, prometheus, public, skillsmith, supermemory, weval.',
|
||
'sentinel' => 'Sentinel = API d execution de commandes sur S95 (WEVADS). Endpoint: POST /api/sentinel-brain.php sur wevads.weval-consulting.com. Permet d executer des commandes shell a distance.',
|
||
'cx' => 'CX = API d execution de commandes sur S204. Endpoint: POST /api/cx avec k=WEVADS2026 et c=base64(commande). Tourne en www-data.',
|
||
];
|
||
if (isset($defs[$component])) {
|
||
$result = ['content' => $defs[$component], 'provider' => 'opus-archi', 'source' => 'archi-aware'];
|
||
}
|
||
}
|
||
|
||
// === AGENT 4: SELF-WIRE (RC: "s'autowirer quand il manque une capacité") ===
|
||
if (!$result && preg_match('/\b(autowire|self.wire|self.fix|auto.repair|auto.correct|manque.*capacit)\b/iu', $m)) {
|
||
$checks = [];
|
||
// Check sovereign
|
||
$sov = @json_decode(@file_get_contents('http://127.0.0.1:4000/health'), true);
|
||
$checks[] = 'Sovereign: ' . ($sov ? "OK ({$sov['active']}/{$sov['total']} providers)" : 'DOWN - RESTARTING...');
|
||
if (!$sov) {
|
||
@shell_exec('cd /opt/sovereign-api && nohup python3 -u sovereign-api.py > /tmp/sovereign.log 2>&1 &');
|
||
$checks[] = 'Sovereign restart initiated';
|
||
}
|
||
// Check FPM
|
||
$fpm = (int)trim(@shell_exec('pgrep -c php-fpm 2>/dev/null'));
|
||
$checks[] = "FPM: $fpm workers" . ($fpm < 5 ? ' - LOW! Restarting...' : ' OK');
|
||
if ($fpm < 5) @shell_exec('systemctl restart php8.5-fpm 2>/dev/null &');
|
||
// Check git dirty
|
||
$dirty = (int)trim(@shell_exec('cd /var/www/html && git status -s 2>/dev/null | wc -l'));
|
||
$checks[] = "Git dirty: $dirty files" . ($dirty > 0 ? ' - AUTO-PUSHING...' : ' CLEAN');
|
||
if ($dirty > 0) @shell_exec('cd /var/www/html && git add -A && git commit -m "autowire-wevia" && git push 2>/dev/null &');
|
||
// Check Docker
|
||
$dock = (int)trim(@shell_exec('docker ps -q 2>/dev/null | wc -l'));
|
||
$checks[] = "Docker: $dock containers";
|
||
|
||
$result = ['content' => "SELF-WIRE DIAGNOSTIC + AUTO-FIX:\n" . implode("\n", $checks), 'provider' => 'opus-selfwire', 'source' => 'self-wire'];
|
||
}
|
||
|
||
// === AGENT 5: LAUNCH AGENT (RC: "lance X" intercepté par layers read-only) ===
|
||
if (!$result && preg_match('/\b(lance|run|execute|demarre|start)\s+(le\s+|les\s+|un\s+)?(nonreg|l99|qa|test|scan|growth|autofix|cleanup|visual)/iu', $m, $lx)) {
|
||
$target = mb_strtolower($lx[3]);
|
||
$launch_cmds = [
|
||
"nonreg" => "cd /opt/weval-l99 && timeout 120 python3 wevia-nonreg-runner.py 2>/dev/null | tail -10",
|
||
"l99" => "nohup python3 /opt/weval-l99/l99-alive.py > /tmp/l99-run.log 2>&1 & echo L99_LAUNCHED && sleep 3 && tail -3 /tmp/l99-run.log",
|
||
"qa" => "timeout 90 python3 /opt/weval-l99/qa-hub.py 2>/dev/null | tail -5",
|
||
"test" => "php8.4 /var/www/html/api/nonreg-quick.php 2>&1",
|
||
"scan" => "python3 /opt/weval-l99/growth-engine-scanner.py 2>&1 | tail -10",
|
||
"growth" => "python3 /opt/weval-l99/growth-engine-scanner.py 2>&1 | tail -10",
|
||
"autofix" => "bash /opt/weval-l99/tools/autofix-all.sh 2>&1 | tail -10",
|
||
"cleanup" => "bash /opt/weval-l99/tools/disk-cleanup.sh 2>&1 | tail -5",
|
||
"visual" => "timeout 120 python3 /opt/weval-l99/tools/visual-test-quick.py 2>&1 | tail -10",
|
||
];
|
||
if (isset($launch_cmds[$target])) {
|
||
$out = trim(@shell_exec("timeout 120 bash -c " . escapeshellarg($launch_cmds[$target]) . " 2>&1"));
|
||
$result = ["content" => "LAUNCH [$target]: " . ($out ?: "LAUNCHED (background)"), "provider" => "opus-launch", "tool" => "launch-$target"];
|
||
}
|
||
}
|
||
|
||
// === AGENT 5: TELEGRAM NOTIFICATION ===
|
||
if (!$result && preg_match('/\b(telegram|notifi|alerte|envoie.*message)\b/iu', $m)) {
|
||
$text = preg_replace('/.*?(telegram|notification|alerte|message)\s*/iu', '', $msg);
|
||
if (strlen($text) < 10) $text = "WEVIA Master bilan OK - " . date('H:i');
|
||
$tg = @file_get_contents("https://api.telegram.org/bot" . trim(@file_get_contents("/etc/wevia/secrets.env") ? preg_replace('/.*TELEGRAM_BOT_TOKEN=([^\n]+).*/s', '$1', @file_get_contents("/etc/wevia/secrets.env")) : "") . "/sendMessage?chat_id=7605775322&text=" . urlencode($text));
|
||
$result = ['content' => $tg ? "Telegram envoye: $text" : "Telegram: echec envoi", 'provider' => 'opus-telegram', 'source' => 'telegram-notify'];
|
||
}
|
||
|
||
// === AGENT 6: L99 RUN TRIGGER ===
|
||
if (!$result && preg_match('/\b(lance|run|execute|demarre)\b.*\b(l99|tests?|nonreg|cycle)\b/iu', $m)) {
|
||
$out = trim(@shell_exec('cd /opt/weval-l99 && timeout 30 python3 l99-alive.py 2>&1') ?: 'L99 trigger sent');
|
||
$result = ['content' => "L99 CYCLE: $out", 'provider' => 'opus-l99', 'source' => 'l99-trigger'];
|
||
}
|
||
|
||
// === AGENT 7: WIKI UPDATE ===
|
||
if (!$result && preg_match('/\b(wiki|update.*wiki|maj.*wiki|sync.*wiki)\b/iu', $m) && preg_match('/\b(update|maj|sync|mets.*jour|actualise)\b/iu', $m)) {
|
||
$out = trim(@shell_exec('timeout 20 php /opt/weval-l99/wevialife-sync.php 2>&1') ?: 'Wiki sync triggered');
|
||
$result = ['content' => "WIKI UPDATE: $out", 'provider' => 'opus-wiki', 'source' => 'wiki-update'];
|
||
}
|
||
|
||
|
||
// === AGENT 5B: AGENT BROWSER (search/list all 890 agents) ===
|
||
if (!$result && preg_match('/\b(cherche|trouve|liste|search|browse|montre|affiche)\b/iu', $m) && preg_match('/\b(agent|skill|tool)\b/iu', $m)) {
|
||
try {
|
||
$pdb = new PDO("pgsql:host=127.0.0.1;port=5432;dbname=paperclip","admin","admin123");
|
||
$q = preg_replace('/\b(cherche|trouve|liste|search|browse|montre|affiche|les|tous|agent|skill|tool|paperclip|actif|idle|dormant)\b/iu', '', $m);
|
||
$q = trim($q);
|
||
if (empty($q)) {
|
||
// Show summary by department
|
||
$st = $pdb->query("SELECT COALESCE(role,'general') as dept, status, count(*) as cnt FROM agents GROUP BY role, status ORDER BY cnt DESC LIMIT 30");
|
||
$rows = $st->fetchAll(PDO::FETCH_ASSOC);
|
||
$txt = "AGENTS PAR DEPARTEMENT:\n";
|
||
foreach ($rows as $r) $txt .= " {$r['dept']} [{$r['status']}]: {$r['cnt']}\n";
|
||
$total = $pdb->query("SELECT count(*) FROM agents")->fetchColumn();
|
||
$active = $pdb->query("SELECT count(*) FROM agents WHERE status='active'")->fetchColumn();
|
||
$txt .= "\nTOTAL: $total agents ($active actifs)";
|
||
$result = ['content' => $txt, 'provider' => 'opus-browser', 'source' => 'agent-browser'];
|
||
} else {
|
||
// Search specific agents
|
||
$st = $pdb->prepare("SELECT name, status, COALESCE(role,'?') as dept FROM agents WHERE name ILIKE :q ORDER BY name LIMIT 20");
|
||
$st->execute([':q' => "%$q%"]);
|
||
$rows = $st->fetchAll(PDO::FETCH_ASSOC);
|
||
$txt = "RECHERCHE '$q': " . count($rows) . " résultats\n";
|
||
foreach ($rows as $r) $txt .= " {$r['name']} [{$r['status']}] dept:{$r['dept']}\n";
|
||
$result = ['content' => $txt, 'provider' => 'opus-browser', 'source' => 'agent-browser'];
|
||
}
|
||
} catch (Exception $e) {
|
||
$result = ['content' => "BROWSER ERROR: " . $e->getMessage(), 'provider' => 'opus-browser'];
|
||
}
|
||
}
|
||
|
||
// === AGENT 5: PAPERCLIP AGENT ACTIVATION (activate idle agents) ===
|
||
if (!$result && preg_match('/\b(active|activer|demarre|reveille|start|enable)\b/iu', $m) && preg_match('/\b(agent|paperclip|idle|dormant)\b/iu', $m)) {
|
||
try {
|
||
$pdb = new PDO("pgsql:host=127.0.0.1;port=5432;dbname=paperclip","admin","admin123");
|
||
// Extract agent names from message
|
||
$names = [];
|
||
if (preg_match_all('/(?:Designer|Playwright|QA|Cog-Creative|SC Orchestration|CEO|CyberAuditor|MiroFish|Brain|Analyst|Architect|Blueprint|Academy|Code Reviewer|Code Simplifier)/i', $m, $mx)) {
|
||
$names = $mx[0];
|
||
}
|
||
if (empty($names)) {
|
||
// Activate ALL idle agents
|
||
$st = $pdb->prepare("UPDATE agents SET status='active' WHERE status='idle'");
|
||
$st->execute();
|
||
$count = $st->rowCount();
|
||
$result = ['content' => "ACTIVATED: $count agents idle -> active", 'provider' => 'opus-activate', 'source' => 'agent-activation'];
|
||
} else {
|
||
$activated = [];
|
||
foreach ($names as $name) {
|
||
$st = $pdb->prepare("UPDATE agents SET status='active' WHERE LOWER(name) LIKE LOWER(:n) AND status='idle'");
|
||
$st->execute([':n' => "%$name%"]);
|
||
if ($st->rowCount() > 0) $activated[] = $name;
|
||
}
|
||
$result = ['content' => "ACTIVATED: " . implode(', ', $activated) . " (" . count($activated) . " agents)", 'provider' => 'opus-activate', 'source' => 'agent-activation'];
|
||
}
|
||
} catch (Exception $e) {
|
||
$result = ['content' => "ACTIVATION ERROR: " . $e->getMessage(), 'provider' => 'opus-activate', 'source' => 'agent-activation'];
|
||
}
|
||
}
|
||
|
||
|
||
// === AGENT 8: PATCH_FILE (RC: llm-fallback hallucinait au lieu d'exec) ===
|
||
if (!$result && preg_match('/\b(patch|insert|ajoute|fix)\b.*\b(master.router|wevia.master.api)\b/iu', $m)) {
|
||
$f = '/var/www/html/api/wevia-master-api.php';
|
||
$orig = @file_get_contents($f);
|
||
if ($orig === false) {
|
||
$result = ['content' => "PATCH: master-router not found at $f", 'provider' => 'opus-patch', 'source' => 'patch-file'];
|
||
} elseif (strpos($orig, "\$msg = \$_JIN['message']") !== false || strpos($orig, '$msg = $_JIN["message"]') !== false) {
|
||
$result = ['content' => "PATCH: \$msg already present in master-router (idempotent NoOp)", 'provider' => 'opus-patch', 'source' => 'patch-file'];
|
||
} else {
|
||
$bk = '/var/www/html/api/_GOLD/wevia-master-api.php.gold-' . date('YmdHis');
|
||
@mkdir('/var/www/html/api/_GOLD', 0755, true);
|
||
@copy($f, $bk);
|
||
$line = "\$msg = \$_JIN['message'] ?? \$_POST['message'] ?? '';";
|
||
$new = preg_replace('/^<\?php\s*\n/', "<?php\n// AUTO-INJECTED by opus-patch 16AVR (fix master-router routing)\n" . $line . "\n", $orig, 1);
|
||
if ($new === $orig) {
|
||
$result = ['content' => "PATCH: cannot find <?php opening tag", 'provider' => 'opus-patch'];
|
||
} else {
|
||
@file_put_contents($f, $new);
|
||
$lint = trim(@shell_exec("php -l " . escapeshellarg($f) . " 2>&1"));
|
||
if (strpos($lint, 'No syntax errors') !== false) {
|
||
@shell_exec("cd /var/www/html && git add api/wevia-master-api.php && git commit -m 'opus-patch: inject \$msg in master-router (fix dynamic-resolver routing)' 2>&1 &");
|
||
$result = ['content' => "PATCH OK: master-router enriched. GOLD=$bk. LINT=OK. Git commit pending.", 'provider' => 'opus-patch', 'source' => 'patch-file'];
|
||
} else {
|
||
@copy($bk, $f);
|
||
$result = ['content' => "PATCH ROLLBACK: lint failed: $lint", 'provider' => 'opus-patch', 'source' => 'patch-file'];
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// === AGENT 9: TASK_DECOMPOSER (RC: 6 fixes en NL → 1er keyword bouffait tout) ===
|
||
if (!$result && preg_match('/\b(d[ée]compose|task[\s_-]?decompose|multi[\s-]?fix|en.s[ée]rie|en.cha[iî]ne)\b/iu', $m)) {
|
||
$tasks = [];
|
||
foreach (preg_split('/\r?\n/', $msg) as $line) {
|
||
$line = trim($line);
|
||
if (preg_match('/^(?:\d+[\.)]\s*|[-*]\s*|fix\s*#?\d+\s*[:\-]?\s*)(.+)/iu', $line, $tx)) {
|
||
$t = trim($tx[1]);
|
||
if (mb_strlen($t) > 5 && mb_strlen($t) < 400) $tasks[] = $t;
|
||
}
|
||
}
|
||
if (count($tasks) >= 2) {
|
||
$sub = [];
|
||
foreach ($tasks as $i => $task) {
|
||
if ($i >= 8) { $sub[] = "[truncated at 8 tasks]"; break; }
|
||
$ch = curl_init('http://127.0.0.1/api/wevia-master-api.php');
|
||
curl_setopt_array($ch, [
|
||
CURLOPT_POST => 1,
|
||
CURLOPT_RETURNTRANSFER => 1,
|
||
CURLOPT_TIMEOUT => 25,
|
||
CURLOPT_HTTPHEADER => ['Content-Type: application/json'],
|
||
CURLOPT_POSTFIELDS => json_encode(['message' => $task]),
|
||
]);
|
||
$r = curl_exec($ch);
|
||
curl_close($ch);
|
||
$j = @json_decode($r, true);
|
||
$resp = (string)($j['content'] ?? $r ?? 'NULL');
|
||
$prov = $j['provider'] ?? '?';
|
||
$sub[] = sprintf("[%d] %s\n -> [%s] %s", $i + 1, mb_substr($task, 0, 100), $prov, mb_substr($resp, 0, 250));
|
||
}
|
||
$result = ['content' => "TASK_DECOMPOSER (" . count($tasks) . " tasks executed):\n\n" . implode("\n\n", $sub), 'provider' => 'opus-decompose', 'source' => 'task-decomposer'];
|
||
}
|
||
}
|
||
|
||
return $result;
|
||
}
|