Wave 114 auto

async-llm-worker.py

@@ -0,0 +1,31 @@
+#!/usr/bin/env python3
+"""WEVAL Async LLM Worker - Redis queue -> Sovereign API"""
+import redis, json, time, urllib.request
+
+r = redis.Redis(host='127.0.0.1', port=6379, decode_responses=True)
+
+def call_sovereign(prompt, max_tokens=150):
+    try:
+        data = json.dumps({"model":"auto","messages":[{"role":"user","content":prompt}],"max_tokens":max_tokens}).encode()
+        req = urllib.request.Request("http://127.0.0.1:4000/v1/chat/completions", data=data, headers={"Content-Type":"application/json"})
+        resp = urllib.request.urlopen(req, timeout=15)
+        d = json.loads(resp.read().decode())
+        return {"provider":d.get("provider","?"),"text":d["choices"][0]["message"]["content"]}
+    except Exception as e:
+        return {"provider":"error","text":str(e)}
+
+print("[WORKER] Listening...")
+while True:
+    try:
+        item = r.brpop("wevia:llm:queue", timeout=30)
+        if not item: continue
+        job = json.loads(item[1])
+        job_id = job.get("id","?")
+        result = call_sovereign(job.get("prompt",""), job.get("max_tokens",150))
+        result["job_id"] = job_id
+        r.set(f"wevia:llm:results:{job_id}", json.dumps(result), ex=300)
+        r.publish(f"wevia:llm:done:{job_id}", json.dumps(result))
+        print(f"[WORKER] {job_id}: {result['provider']}")
+    except Exception as e:
+        print(f"[WORKER] Error: {e}")
+        time.sleep(1)

wevia-autofix-intents.php

@@ -0,0 +1,28 @@
+<?php
+/**
+ * WEVIA AUTOFIX INTENTS v1.0 — 14avr2026
+ * Port-conflict-resolver + autofix-service-down + git-reconcile
+ * Loaded by wevia-autonomous.php
+ */
+function wevia_autofix_intents($msg, &$intents) {
+    // PORT-CONFLICT-RESOLVER
+    if (preg_match("/port.*(occup|bloqu|confli|libere|free|kill)|fuser.*kill|502.*apache|apache.*502|bad.*gateway|apache.*down|service.*down/i", $msg)) {
+        $port = "5890";
+        if (preg_match("/port\s*(\d{4,5})/i", $msg, $pm)) $port = $pm[1];
+        $intents[] = ["name" => "ssh_exec", "desc" =”Ü<EFBFBD>ÛÛ™›XÝ™\ÛÛ™\ŽˆÚ[Ü<EFBFBD>	Ü<EFBFBD>
+È™\Ý\<5C>\XÚLˆ‹œ\˜[\ȈOˆȘÛYˆOˆ™XÚÈÔ•БQ“Ô‘Nˆ	‰ˆ<EFBFBD>\Ù\ˆ]ˆ	Ü<EFBFBD>ÝÜ<EFBFBD>‰ŒNÈ<EFBFBD>\Ù\ˆZÈ	Ü<EFBFBD>ÝÜ<EFBFBD>‹Ù]‹Û<EFBFBD>[ÈÛY\NÈÞ\Ý[XÝ™\Ý\<5C>\XÚLˆ<EFBFBD>‰ŒNÈÛY\ŽÈXÚÈÔ•ÐQ•TŽˆ	‰ˆ<EFBFBD>\Ù\ˆ]ˆ	Ü<EFBFBD>ÝÜ<EFBFBD>‰ŒNÈXÚÈÕUTΈ	‰ˆÞ\Ý[XÝ\ËXXÝ]™H\XÚLŽÈÝ\›\Ùˆ[ÈÙ]‹Û<EFBFBD>[]ÈÉ^ÚØÛÙ_H‹ËÌL<EFBFBD>ËŒŒŒNŽ
+
+ËÈ<EFBFBD>‹Ù]‹Û<EFBFBD>[	‰ˆXÚȈTPÒWÓÒ׈XÚȈTPÒWÑ<EFBFBD>RSˆ—WNˆ™]\›ˆ<EFBFBD>YNˆB‚ˆËÈUUÑ’VTÑT•’PÑKQÕÓ‚ˆYˆ
+™Y×ÛX]Ú
+‹Ø]]Ë<EFBFBD>Ùš^™\\™KŠ<4B>Ý]š^Š˜[Ù\<5C>šXÙKŠ™˜Z[YÝ]Šœ™\\™KÚH‹	\ÙÊJHˆ	[<EFBFBD>[<EFBFBD>Ö×HHÈ›˜[YHˆB'76…öW†V2"Â&FW62"Óâ$WFöf—‚ÆÂf–ÆVB6W'f–6W2"Â'&×2"Óâ²&6ÖB"Ѐ‰%aôÀì<C380>™½È<C2BD>ÍÙŒ<C399>¥¸<C2A5>…Á…<C381>¡”È<E2809D>¹<EFBFBD>¥¹à<C2B9>Á¡Àà¸Ôµ™Á´ì<C2B4>‘¼<E28098>Lõp<C3B5>¡ÍåÍÑ•µ<E280A2>Ñ°<C391>¥Ìµ…<C2B5>Ñ¥Ù”<C399>p‘ÍÙŒ€È/dev/null); if [ \"\$S\" != \"active\" ]; then echo \"FIX: \$svc was \$S\"; systemctl restart \$svc 2Ù]‹Û<E280B9>[È’VQW	
+
+’VQ
+ÌJJNÈšNÈÛ™NÈXÚÈ‘’VQˆ	’VQÙ\<EFBFBD>šXÙ\׎ÈÞ\Ý[XÝ\ËXXÝ]™H\XÚLˆ™Ú[ž<0B>KYœH—WNˆ™]\›ˆ<1C>YNˆB‚ˆËÈÒUT‘PÓÓ<C393>ÒSBˆYˆ
+™Y×ÛX]Ú
+‹ÙÚ]ŠŠ™XÛÛ˜Ú[ÛX[Ÿ\<EFBFBD>_\ÚŠ˜[ÛÛ[Z]Š˜[
+_™XÛÛ˜Ú[KÚH‹	\ÙÊJHˆ	[<5B>[<5B>Ö×HHÈ›˜[YHˆOˆœÜÚÙ^XÈ‹™\ØȈB$v—B&V6öæ6–ÆRÆÂ&W÷2"Â'&×2"Ð<>l‰<6C>µ<EFBFBD>ˆ€ôø€‰<E282AC><E280B0>€½Ù…ȽÝÝܽ¡Ñµ°€˜˜<CB9C><CB9C>¥Ð<C2A5>…‘<E280A6>€µ€˜˜<CB9C><CB9C>¥Ð<C2A5><C390>½µµ¥Ð€µ´<C2B5>p‰UQ<µI
+=9
+%1<14>p<EFBFBD>¡‘…Ñ”€¬•d•´•<C2B4>´• •4¥pˆ€Èø˜Ä<CB9C>ð<EFBFBD>Ñ…¥°€´Ì€˜˜<CB9C><CB9C>¥Ð<C2A5>ÁÕÍ <C38D>½É¥<C389>¥¸<C2A5>µ…¥¸€Èø˜Ä<CB9C>ð<EFBFBD>Ñ…¥°€´Ìì<C38C>•<EFBFBD>¡¼€´´µ=AP´´´ì<C2B4><C3AC><EFBFBD>€½½Áнݕم°µ°ä䀘˜<CB9C><CB9C>¥Ð<C2A5>…‘<E280A6>€µ€˜˜<CB9C><CB9C>¥Ð<C2A5><C390>½µµ¥Ð€µ´<C2B5>p‰UQ<µI
+=9
+%1<14>p<EFBFBD>¡‘…Ñ”€¬•d•´•<C2B4>´• •4¥pˆ€È&1 | tail -3 && git push origin main 2	ŒHZ[LÎÈXÚÈÓ‘H—WNˆ™]\›ˆ<1C>YNˆB‚ˆËÈNKTÐPTËUTUBˆYˆ
+™Y×ÛX]Ú