221 lines
17 KiB
PHP
221 lines
17 KiB
PHP
<?php
|
|
/**
|
|
* wevia-fast-path.php — AMBRE-V1 patch
|
|
* Original: 2026-04-17 Opus
|
|
* Patch: 2026-04-21 Ambre · 100% autonomy push
|
|
*
|
|
* Changes (additif pur, zéro suppression):
|
|
* 1. Extended triggers: scan, file, truth registry, wepredict/wtp state
|
|
* 2. Dynamic truth registry snapshot injected into LLM system prompt
|
|
* 3. Anti-hallucination directive (doctrine #4 ZERO FAKE DATA)
|
|
* 4. Obsolete hardcoded chiffres (421/13/146K) REMAIN (ZERO suppression)
|
|
* but dynamic Truth Registry values OVERRIDE in LLM context
|
|
*/
|
|
|
|
// === AMBRE-V1 · dynamic truth snapshot loader (safe, cached in session) ===
|
|
function __ambre_truth_snapshot() {
|
|
static $cached = null;
|
|
if ($cached !== null) return $cached;
|
|
$path = '/var/www/html/api/wevia-truth-registry.json';
|
|
if (!file_exists($path)) { $cached = []; return []; }
|
|
$data = @json_decode(@file_get_contents($path), true);
|
|
if (!is_array($data)) { $cached = []; return []; }
|
|
$cached = [
|
|
'agents' => $data['agents']['count_unique'] ?? $data['agents_count'] ?? null,
|
|
'tools' => $data['tools_count'] ?? null,
|
|
'providers' => $data['providers_count'] ?? null,
|
|
'hcps' => $data['ethica_hcps_total'] ?? null,
|
|
'pages' => $data['pages_count'] ?? null,
|
|
'intents' => $data['intents']['count'] ?? $data['intents_count'] ?? null,
|
|
'skills' => $data['skills']['TOTAL'] ?? $data['skills_total'] ?? null,
|
|
'autonomy' => $data['autonomy_level'] ?? null,
|
|
'nonreg' => $data['nonreg_score'] ?? null,
|
|
'built_at' => $data['built_at'] ?? $data['last_update'] ?? null,
|
|
];
|
|
return $cached;
|
|
}
|
|
|
|
function wevia_fast_path($msg) {
|
|
$m = mb_strtolower(trim($msg));
|
|
$r = null;
|
|
// PRIORITY BYPASS
|
|
if (preg_match('/reconcil|bilan|dirty|l99|saas|tout.*verif|ethica.*pays|ethica.*valid|ethica.*enrich|ethica.*campag|ethica.*maroc|ethica.*tunisie|ethica.*alger|medecins.*maroc|medecins.*tunisie|medecins.*alger|specialite|gap.*detail|ethica.*count|ethica.*countries|ethica.*repartition|hcp.*count/i', $m)) return null;
|
|
|
|
// === WAVE-267 Route vers master-api pour intents puissants (additif pur) ===
|
|
// intents_pool, orchestrate_parallele, auto-wire NL → master-api.php (qui sait faire)
|
|
if (preg_match('/^intents.?pool$|^pool.?intents$|combien.*capacit|nombre.*intent|liste.*intent|quelles.*capacit/i', $m)
|
|
|| preg_match('/^orchestrate.*(en.*parallele|parallele.*:|:)/i', $m)
|
|
|| preg_match('/^cable un intent |^wire.*intent|cree un intent pour|nouveau.*intent.*pour/i', $m)
|
|
|| preg_match('/^quelle.*heure|^donne.*heure|^date serveur/i', $m)
|
|
|| preg_match('/^multiagent|^multi.?agent.*(parallele|verifier|check)|^mobilise.*agent/i', $m)) {
|
|
$ch = curl_init('http://127.0.0.1/api/wevia-master-api.php');
|
|
curl_setopt($ch, CURLOPT_POST, 1);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query(['message' => $msg]));
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
curl_setopt($ch, CURLOPT_TIMEOUT, 15);
|
|
$resp = curl_exec($ch);
|
|
curl_close($ch);
|
|
if ($resp) {
|
|
$j = @json_decode($resp, true);
|
|
if (is_array($j) && isset($j['content'])) {
|
|
return ['tool' => ($j['tool'] ?? 'master-api'), 'content' => $j['content'], 'provider' => ($j['provider'] ?? 'master-api')];
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
// === END WAVE-267 ===
|
|
|
|
if (preg_match('/reconcil|bilan|dirty|l99|saas|tout.*verif|ethica.*pays|ethica.*valid|ethica.*enrich|ethica.*campag|ethica.*maroc|ethica.*tunisie|ethica.*alger|medecins.*maroc|medecins.*tunisie|medecins.*alger|specialite|gap.*detail|ethica.*count|ethica.*countries|ethica.*repartition|hcp.*count/i', $m)) return null;
|
|
if ($m === 'ping' || strpos($m, 'ping') === 0) {
|
|
$r = trim(@shell_exec('echo S95:$(timeout 1 ping -c1 -W1 10.1.0.3 2>/dev/null | grep -oP "time=\K[0-9.]+") Groq:$(curl -so/dev/null -w%{http_code} -m2 https://api.groq.com 2>/dev/null)'));
|
|
} elseif (strpos($m, 'nonreg') !== false && strpos($m, 'lance') === false && strpos($m, 'run') === false) {
|
|
$d = @json_decode(@file_get_contents(__DIR__.'/nonreg-latest.json'),true); $r = $d ? 'NONREG: '.$d['pass'].'/'.$d['total'].' ('.$d['score'].'%)' : 'NONREG: run check';
|
|
} elseif ($m === 'aide' || $m === 'help') {
|
|
$r = "WEVIA MASTER 421 tools. reconcile dirty l99 ports providers git ethica crons docker nonreg ping aide";
|
|
} elseif (strpos($m, 'sovereign') !== false && strpos($m, 'health') !== false) {
|
|
$r = trim(@shell_exec('curl -s --max-time 5 http://127.0.0.1:4000/health'));
|
|
} elseif (strpos($m, 'diagn') !== false || (strpos($m, 'health') !== false && strpos($m, 'sovereign') === false)) {
|
|
$r = trim(@shell_exec('echo "LOAD: $(cat /proc/loadavg)" && echo "RAM: $(free -m | grep Mem)" && echo "DISK: $(df -h / | tail -1)" && echo "FPM: $(pgrep -c php-fpm) workers"'));
|
|
} elseif (strpos($m, 'disk') !== false || strpos($m, 'espace') !== false) {
|
|
$r = trim(@shell_exec('df -h / | tail -1'));
|
|
} elseif (strpos($m, 'reconcil') !== false || strpos($m, 'bilan') !== false || strpos($m, 'multiagent') !== false || strpos($m, 'mobilise') !== false || (strpos($m, 'diagno') !== false && strpos($m, 'complet') !== false) || (strpos($m, 'tout') !== false && strpos($m, 'verif') !== false)) {
|
|
$cmds = [];
|
|
$cmds[] = 'echo "=GIT=" && cd /var/www/html && echo "Dirty:$(git status -s|wc -l)" && git status -s 2>/dev/null|head -15';
|
|
$cmds[] = 'echo "=PORTS=" && ss -tlnp 2>/dev/null|grep -oP ":\K[0-9]+"|sort -un|tr "\n" " "';
|
|
$cmds[] = 'echo "" && echo "=SOVEREIGN=" && curl -s -m3 localhost:4000/health 2>/dev/null|head -c 80';
|
|
$cmds[] = 'echo "" && echo "=NONREG=" && php8.4 /var/www/html/api/nonreg-quick.php 2>/dev/null|tail -1';
|
|
$cmds[] = 'echo "=L99=" && echo "Pages:$(ls /var/www/html/*.html|wc -l) Wiki:$(ls /opt/weval-l99/wiki/*.json 2>/dev/null|wc -l)"';
|
|
$cmds[] = 'echo "=CRONS=" && echo "Active:$(crontab -l 2>/dev/null|grep -cv ^#)"';
|
|
$r = trim(@shell_exec(implode(' && ', $cmds)));
|
|
} elseif (strpos($m, 'dirty') !== false || strpos($m, 'fichiers modif') !== false) {
|
|
$r = trim(@shell_exec('cd /var/www/html && echo "DIRTY FILES:" && git status --short 2>/dev/null|head -40'));
|
|
} elseif (strpos($m, 'git push') !== false || strpos($m, 'commit') !== false || strpos($m, 'pousse') !== false) {
|
|
$r = trim(@shell_exec('cd /var/www/html && git add -A && git commit -m "auto-wevia-master" 2>&1|tail -3 && git push 2>&1|tail -3'));
|
|
} elseif (strpos($m, 'git') !== false) {
|
|
$r = trim(@shell_exec('cd /var/www/html && echo "DIRTY:$(git status -s|wc -l)" && git log --oneline -3 2>/dev/null'));
|
|
} elseif (strpos($m, 'l99') !== false || strpos($m, 'saas') !== false) {
|
|
$r = trim(@shell_exec('echo "Pages:$(ls /var/www/html/*.html|wc -l) Wiki:$(ls /opt/weval-l99/wiki/*.json 2>/dev/null|wc -l)" && echo "Last wiki:" && ls -lt /opt/weval-l99/wiki/*.json 2>/dev/null|head -3'));
|
|
} elseif (preg_match('/\bport\b/', $m)) {
|
|
$r = trim(@shell_exec('ss -tlnp 2>/dev/null|grep LISTEN|head -25'));
|
|
} elseif ((strpos($m, 'ethica') !== false || preg_match('/hcp|medecin|combien.*(maroc|tunis|alger)/i', $m))) {
|
|
$r = trim(@shell_exec('curl -s -m5 http://127.0.0.1/api/ethica-country-api.php 2>/dev/null') ?: 'Ethica: 146K HCPs');
|
|
} elseif (strpos($m, 'provider') !== false || strpos($m, 'cascade') !== false) {
|
|
$r = trim(@shell_exec('curl -s -m3 localhost:4000/health 2>/dev/null') ?: 'Sovereign: check');
|
|
} elseif (strpos($m, 'cron') !== false) {
|
|
$r = trim(@shell_exec('echo "Active:$(crontab -l 2>/dev/null|grep -cv "^#")" && crontab -l 2>/dev/null|grep -v "^#"|head -10'));
|
|
} elseif (strpos($m, 'docker') !== false) {
|
|
$r = trim(@shell_exec('docker ps --format "{{.Names}}: {{.Status}}" 2>/dev/null|head -10'));
|
|
} elseif (strpos($m, 'toolhub') !== false || (strpos($m, 'tool') !== false && strpos($m, 'count') !== false)) {
|
|
$reg = @json_decode(@file_get_contents('/var/www/html/api/wevia-tool-registry.json'), true);
|
|
$r = "TOOLS: " . count($reg['tools'] ?? []) . " wired in registry";
|
|
} elseif (strpos($m, 'kpi') !== false && strpos($m, 'refresh') !== false) {
|
|
$r = trim(@shell_exec('curl -s http://127.0.0.1/api/em-live-kpi.php --max-time 12 > /var/www/html/api/em-kpi-cache.json 2>/dev/null && echo KPI_CACHE_REFRESHED'));
|
|
} elseif (strpos($m, 's95') !== false && (strpos($m, 'clean') !== false || strpos($m, 'disk') !== false)) {
|
|
$r = trim(@shell_exec('ssh -p 49222 -i /var/www/.ssh/wevads_key -o StrictHostKeyChecking=no -o ConnectTimeout=3 root@10.1.0.3 "journalctl --vacuum-size=500M 2>/dev/null; find /var/log -name *.gz -delete 2>/dev/null; find /tmp -mtime +1 -delete 2>/dev/null; df -h / | awk NR==2" 2>/dev/null'));
|
|
} elseif (strpos($m, 'contrat') !== false || strpos($m, 'contract') !== false || strpos($m, 'nda') !== false) {
|
|
$r = trim(@shell_exec('curl -s http://127.0.0.1/api/contract-api.php?action=stats --max-time 3 2>/dev/null'));
|
|
} elseif (strpos($m, 'factur') !== false || strpos($m, 'invoice') !== false) {
|
|
$r = trim(@shell_exec('curl -s http://127.0.0.1/api/invoice-api.php?action=stats --max-time 3 2>/dev/null'));
|
|
} elseif (strpos($m, 'devis') !== false || strpos($m, 'quote') !== false) {
|
|
$r = trim(@shell_exec('curl -s http://127.0.0.1/api/quote-api.php?action=stats --max-time 3 2>/dev/null'));
|
|
} elseif (strpos($m, 'social') !== false || strpos($m, 'linkedin') !== false) {
|
|
$r = trim(@shell_exec('curl -s http://127.0.0.1/api/social-media-api.php --max-time 3 2>/dev/null | head -c 500'));
|
|
} elseif (strpos($m, 'deerflow') !== false || strpos($m, 'deer') !== false) {
|
|
$r = trim(@shell_exec('curl -s -o /dev/null -w "DeerFlow:%{http_code}" http://127.0.0.1:3002/ --max-time 2 2>/dev/null && curl -s -o /dev/null -w " API:%{http_code}" http://127.0.0.1:8001/health --max-time 2 2>/dev/null && echo " Qdrant:$(curl -s -o /dev/null -w %{http_code} http://127.0.0.1:6333/collections --max-time 2 2>/dev/null)"'));
|
|
} elseif (strpos($m, 'arena') !== false) {
|
|
$r = trim(@shell_exec('php -r \'$h=@json_decode(@file_get_contents("http://127.0.0.1:4000/health"),true);if($h&&$h["status"]==="ok"){foreach($h["providers"]??[] as $p)echo "$p:UP\n";echo "Active:".$h["active"]."/".$h["total"]."\nPrimary:".($h["primary"]??"auto");}else echo "Sovereign:DOWN";\''));
|
|
} elseif (strpos($m, 'strateg') !== false || strpos($m, 'priorit') !== false) {
|
|
$r = "TOP3 Q2: 1.Cloud Scaleway 5POC 240KMAD 2.Ethica 3K/mois 3.Growth 3RDV/sem Pipeline:3.5MMAD";
|
|
} elseif (preg_match('/^(bonjour|hello|hi|salut|hey)/i', $m)) {
|
|
$r = "WEVIA Master IA souveraine WEVAL. 421 tools, 13 providers, 146K HCPs. Tapez: reconcile dirty l99 ports providers git ethica crons docker nonreg ping aide";
|
|
}
|
|
// === AMBRE-V1 · EXTENDED TRIGGERS (additif pur, fin 100% autonomie) ===
|
|
elseif (strpos($m, 'truth registry') !== false || preg_match('/source.*verit|read.*truth|truth.*source|registry.*stat/i', $m)) {
|
|
$raw = @file_get_contents('https://weval-consulting.com/api/opus-arch-generic.php?tool=read_truth_registry');
|
|
$d = @json_decode($raw, true);
|
|
$inner = is_array($d) ? @json_decode($d['output'] ?? '', true) : null;
|
|
if (is_array($inner) && !empty($inner['headlines'])) {
|
|
$lines = [];
|
|
foreach ($inner['headlines'] as $k=>$v) $lines[] = "$k: $v";
|
|
$r = "TRUTH REGISTRY (live, honest) · " . implode(' · ', $lines);
|
|
} else {
|
|
$r = "TRUTH REGISTRY: callable via /api/opus-arch-generic.php?tool=read_truth_registry (honest, zero hallucination)";
|
|
}
|
|
}
|
|
elseif (preg_match('/scan.*(file|fichier)|etat.*(fichier|wepredict|wtp|hub|page)|file.*info|wepredict.*state|wtp.*state/i', $m)) {
|
|
// WAVE 203: honest path extraction — enrichment of existing logic
|
|
$path = null;
|
|
// P1: explicit absolute path in the message
|
|
if (preg_match('#(/var/www/[A-Za-z0-9_./\-]+\.(html|php|json|js|md|txt))#', $m, $pm)) {
|
|
$path = $pm[1];
|
|
}
|
|
// P2: filename-only mention (e.g. "wevia.html", "scan_file director-chat.html")
|
|
elseif (preg_match('/\b([a-zA-Z0-9][a-zA-Z0-9_\-]{1,63}\.(html|php|json))\b/i', $m, $pm)) {
|
|
$fn = $pm[1];
|
|
foreach (['/var/www/html/', '/var/www/html/api/', '/var/www/html/wevia-ia/', '/var/www/weval/', '/var/www/weval/wevia-ia/'] as $dir) {
|
|
if (file_exists($dir . $fn)) { $path = $dir . $fn; break; }
|
|
}
|
|
if (!$path) $path = '/var/www/html/' . $fn; // honest fallback (will 404 via scan_file)
|
|
}
|
|
// P3: preserved existing alias keywords
|
|
if ($path === null) {
|
|
$path = '/var/www/html/wepredict.html';
|
|
if (preg_match('/all.ia.hub|hub\.html/i', $m)) $path = '/var/www/html/all-ia-hub.html';
|
|
elseif (preg_match('/wtp|technology.platform/i', $m)) $path = '/var/www/html/weval-technology-platform.html';
|
|
elseif (preg_match('/orchestrator/i', $m)) $path = '/var/www/html/wevia-orchestrator.html';
|
|
elseif (preg_match('/master/i', $m)) $path = '/var/www/html/wevia-master.html';
|
|
}
|
|
$raw = @file_get_contents("https://weval-consulting.com/api/opus-arch-generic.php?tool=scan_file&path=" . urlencode($path));
|
|
$d = @json_decode($raw, true);
|
|
$inner = is_array($d) ? @json_decode($d['output'] ?? '', true) : null;
|
|
if (is_array($inner) && $inner['ok']) {
|
|
$r = "SCAN " . basename($inner['path']) . " · " . $inner['size_kb'] . "KB · v=" . $inner['version'] . " · mtime=" . $inner['mtime'] . " · md5=" . substr($inner['md5'], 0, 8);
|
|
} else {
|
|
$r = "SCAN FILE: path=$path · intent non câblé ou fichier introuvable · zéro hallucination";
|
|
}
|
|
}
|
|
// === END AMBRE-V1 EXTENDED TRIGGERS ===
|
|
// LLM FALLBACK: si aucun intent technique matché et message > 30 chars → sovereign direct
|
|
if ($r === null && mb_strlen($m) > 30) {
|
|
// === AMBRE-V1 · dynamic truth snapshot for LLM grounding (doctrine #4) ===
|
|
$tr = __ambre_truth_snapshot();
|
|
$live_facts = '';
|
|
if (!empty($tr)) {
|
|
$live_facts = "\n\nFACTS LIVE (Truth Registry · source unique · override toute autre valeur):";
|
|
if ($tr['agents'] !== null) $live_facts .= "\n- Agents uniques: " . $tr['agents'];
|
|
if ($tr['tools'] !== null) $live_facts .= "\n- Tools: " . $tr['tools'];
|
|
if ($tr['providers'] !== null) $live_facts .= "\n- Providers IA: " . $tr['providers'];
|
|
if ($tr['hcps'] !== null) $live_facts .= "\n- HCPs pharma Ethica: " . $tr['hcps'];
|
|
if ($tr['pages'] !== null) $live_facts .= "\n- Pages plateforme: " . $tr['pages'];
|
|
if ($tr['intents'] !== null) $live_facts .= "\n- Intents: " . $tr['intents'];
|
|
if ($tr['skills'] !== null) $live_facts .= "\n- Skills: " . $tr['skills'];
|
|
if ($tr['autonomy'] !== null) $live_facts .= "\n- Autonomy: " . $tr['autonomy'];
|
|
if ($tr['built_at'] !== null) $live_facts .= "\n- Registry built at: " . $tr['built_at'];
|
|
}
|
|
$anti_hall = "\n\nDOCTRINE #4 ZERO FAKE DATA : si une information n'est pas dans FACTS LIVE ci-dessus, dis 'je ne sais pas' ou 'intent non câblé'. N'INVENTE JAMAIS un chiffre, un nom, un email, une date. Reste concis et honnête.";
|
|
|
|
$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. Tu aides Yacine avec des réponses directes, concrètes et en français. Tu connais: WEVADS (email marketing), Ethica (146K HCPs pharma), 13 providers IA gratuits, 421 tools, 223 pages." . $live_facts . $anti_hall],
|
|
["role"=>"user","content"=>$msg]
|
|
],
|
|
"max_tokens" => 500,
|
|
"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"=>"sovereign-direct","content"=>$txt,"tool"=>"llm-fallback","model"=>$d2["model"]??"auto"];
|
|
}
|
|
if ($r === null) return null;
|
|
return ['provider'=>'fast-path','content'=>$r,'tool'=>'fast-path'];
|
|
}
|