import os import gradio as gr from fastapi import FastAPI, Request from fastapi.responses import JSONResponse, RedirectResponse, HTMLResponse from huggingface_hub import InferenceClient, HfApi, create_repo from duckduckgo_search import DDGS import json import uuid from datetime import datetime token = os.environ.get("HF_TOKEN") client = InferenceClient("Qwen/Qwen2.5-Coder-7B-Instruct", token=token) api = HfApi(token=token) app = FastAPI() # ----------------------------------------------------- # Custom API Endpoint for the Cypher Coder CLI Client # ----------------------------------------------------- def search_web(query): try: ddgs = DDGS() results = list(ddgs.text(query, max_results=4)) if not results: return "Aucun résultat trouvé sur le web." formatted = [] for r in results: formatted.append(f"Titre: {r['title']}\nRésumé: {r['body']}\nLien: {r['href']}") return "\n\n".join(formatted) except Exception as e: return f"Erreur lors de la recherche: {str(e)}" def save_log(username: str, message: str, response: str): if not token: return try: user = api.whoami()["name"] repo_id = f"{user}/cypher-coder-logs" try: create_repo(repo_id, token=token, repo_type="dataset", private=True, exist_ok=True) except Exception: pass log_entry = { "username": username, "timestamp": datetime.utcnow().isoformat(), "message": message, "response": response } file_path = f"logs/{username}/{datetime.utcnow().strftime('%Y%m%d_%H%M%S')}_{uuid.uuid4().hex[:8]}.json" content_bytes = json.dumps(log_entry, ensure_ascii=False, indent=2).encode("utf-8") from io import BytesIO api.upload_file( path_or_fileobj=BytesIO(content_bytes), path_in_repo=file_path, repo_id=repo_id, repo_type="dataset", token=token ) except Exception as e: print(f"Erreur d'enregistrement du log de discussion: {e}") @app.get("/") async def root(request: Request): try: with open("index.html", "r", encoding="utf-8") as f: html_content = f.read() return HTMLResponse(content=html_content, status_code=200) except Exception as e: return HTMLResponse(content=f"Error loading interface: {str(e)}", status_code=500) @app.get("/api/user-profile") async def user_profile(request: Request): username = request.headers.get("x-hf-user-name") or "invité" avatar = request.headers.get("x-hf-user-avatar") or "" email = request.headers.get("x-hf-user-email") or "" return {"username": username, "avatar": avatar, "email": email} @app.post("/api/chat") async def chat(request: Request): try: body = await request.json() messages = body.get("messages", []) client_tools = body.get("tools", []) username = body.get("username", "local-user") # dynamic inference parameters model = body.get("model", "Qwen/Qwen2.5-Coder-7B-Instruct") temperature = body.get("temperature", None) top_p = body.get("top_p", None) max_tokens = body.get("max_tokens", 2048) # Associer les outils locaux du client et l'outil de recherche web du serveur all_tools = list(client_tools) search_tool_def = { "type": "function", "function": { "name": "search_web", "description": "Recherche des informations actualisées ou de la documentation technique sur internet.", "parameters": { "type": "object", "properties": { "query": { "type": "string", "description": "La requête de recherche." } }, "required": ["query"] } } } all_tools.append(search_tool_def) # Choisir le client et le fournisseur (provider) appropriés provider = None if model and ("Llama-3.3-70B" in model or "Llama-3.1-70B" in model): provider = "together" if provider: local_client = InferenceClient(model=model, provider=provider, token=token) else: local_client = client # Boucle d'agent côté serveur pour exécuter search_web de manière transparente use_tools = True while True: try: if provider: response = local_client.chat_completion( messages=messages, tools=all_tools if use_tools else None, max_tokens=max_tokens, temperature=temperature, top_p=top_p, stream=False ) else: response = local_client.chat_completion( model=model, messages=messages, tools=all_tools if use_tools else None, max_tokens=max_tokens, temperature=temperature, top_p=top_p, stream=False ) except Exception as e: err_msg = str(e) if use_tools and ("tools" in err_msg or "UNSUPPORTED_OPENAI_PARAMS" in err_msg or "422" in err_msg): use_tools = False continue else: raise e choice = response.choices[0] # Vérifier si l'IA veut appeler des outils if choice.message.tool_calls: has_search_call = False for tc in choice.message.tool_calls: if tc.function.name == "search_web": has_search_call = True break if has_search_call: # Ajouter l'appel de l'outil du modèle à l'historique messages.append({ "role": "assistant", "tool_calls": [ { "id": tc.id, "type": tc.type, "function": { "name": tc.function.name, "arguments": tc.function.arguments } } for tc in choice.message.tool_calls ] }) # Exécuter les appels search_web et ajouter les résultats for tc in choice.message.tool_calls: if tc.function.name == "search_web": try: args = json.loads(tc.function.arguments) q = args.get("query", "") search_res = search_web(q) messages.append({ "role": "tool", "name": "search_web", "tool_call_id": tc.id, "content": search_res }) except Exception as parse_err: messages.append({ "role": "tool", "name": "search_web", "tool_call_id": tc.id, "content": f"Erreur de décodage des arguments: {str(parse_err)}" }) else: # Laisser les outils locaux vides pour ce tour messages.append({ "role": "tool", "name": tc.function.name, "tool_call_id": tc.id, "content": "En attente d'exécution locale..." }) # Relancer la génération avec le contexte de recherche mis à jour continue else: # Contient uniquement des outils locaux pour le client message_data = { "role": choice.message.role, "content": choice.message.content, "tool_calls": [ { "id": tc.id, "type": tc.type, "function": { "name": tc.function.name, "arguments": tc.function.arguments } } for tc in choice.message.tool_calls ] } user_msg_content = "" for msg in reversed(messages): if msg.get("role") == "user": user_msg_content = msg.get("content", "") break save_log(username, user_msg_content, choice.message.content or "[Appels d'outils locaux demandés]") return JSONResponse(content={"message": message_data}) else: # Réponse textuelle finale sans outil message_data = { "role": choice.message.role, "content": choice.message.content } user_msg_content = "" for msg in reversed(messages): if msg.get("role") == "user": user_msg_content = msg.get("content", "") break save_log(username, user_msg_content, choice.message.content or "") return JSONResponse(content={"message": message_data}) except Exception as e: return JSONResponse(content={"error": str(e)}, status_code=500) # ----------------------------------------------------- # Gradio Web Interface (Documentation & Chat) # ----------------------------------------------------- SYSTEM_PROMPT = """Tu es Cypher Coder, un agent de programmation IA ultra-intelligent fonctionnant dans un terminal (CLI). Tu as été conçu et développé par DJAKOUA KWANKAM, un brillant étudiant en informatique à l'Institut Universitaire de Technologie de Douala (IUT). Tu devez toujours te présenter comme tel. Tu as accès à des outils locaux (comme lire des fichiers, écrire/modifier des fichiers, exécuter des commandes dans le terminal) qui s'exécutent sur la machine locale de l'utilisateur. Ces outils te sont fournis via le protocole CLI de Cypher Coder. Pour les informations en temps réel ou la documentation externe, tu peux aussi utiliser la recherche web. [CAPABILITÉS SYSTÈME ET COMMANDES CLI CLASSÉES PAR CATÉGORIES] : Tu connais et es capable d'utiliser ou de suggérer les commandes CLI suivantes selon le contexte : 1. Navigation & Système de fichiers : - ls / list : Lister les fichiers et dossiers du répertoire courant - ls -la : Lister avec permissions, taille, fichiers cachés - cd : Changer de répertoire - cd .. : Remonter d'un niveau - pwd : Afficher le chemin absolu du répertoire courant - tree : Afficher l'arborescence sous forme d'arbre - mkdir : Créer un dossier - mkdir -p : Créer des dossiers imbriqués en une commande - rmdir : Supprimer un dossier vide - touch : Créer un fichier vide - rm : Supprimer un fichier - rm -rf : Supprimer un dossier et son contenu récursivement - cp : Copier un fichier - cp -r : Copier un dossier récursivement - mv : Déplacer ou renommer un fichier/dossier - find -name "*.py" : Rechercher des fichiers par nom/pattern - locate : Recherche rapide dans la base de données de fichiers - stat : Afficher métadonnées d'un fichier (taille, dates, permissions) - du -sh : Taille d'un dossier (human readable) - df -h : Espace disque disponible sur toutes les partitions 2. Lecture & Édition de fichiers : - cat : Afficher le contenu d'un fichier - less : Afficher le contenu paginé (scrollable) - head -n 20 : Afficher les N premières lignes - tail -n 20 : Afficher les N dernières lignes - tail -f : Suivre un fichier en temps réel (logs) - grep "pattern" : Chercher un pattern dans un fichier - grep -r "pattern" : Recherche récursive dans un dossier - grep -n "pattern" : Chercher avec numéros de lignes - sed 's/old/new/g' : Remplacer du texte dans un fichier - awk '{print $1}' : Extraire/traiter des colonnes de texte - wc -l : Compter les lignes d'un fichier - diff : Comparer deux fichiers - nano : Éditer un fichier (éditeur simple) - vim : Éditer un fichier (éditeur avancé) - echo "text" > file : Écrire du texte dans un fichier (écrase) - echo "text" >> file : Ajouter du texte à la fin d'un fichier - sort : Trier les lignes d'un fichier - uniq : Supprimer les lignes dupliquées - cut -d',' -f1 : Extraire une colonne d'un CSV 3. Processus & Ressources système : - ps aux : Lister tous les processus en cours - top / htop : Moniteur de processus interactif en temps réel - kill : Terminer un processus par son PID - kill -9 : Forcer la fermeture d'un processus - killall : Tuer tous les processus par nom - jobs : Lister les tâches en arrière-plan du shell - bg : Mettre une tâche en arrière-plan - fg : Ramener une tâche en avant-plan - nohup & : Lancer un processus qui survive à la fermeture du terminal - screen / tmux : Multiplexeur de terminal (sessions persistantes) - free -h : Afficher la RAM utilisée/disponible - uptime : Durée de fonctionnement du système - lscpu : Informations sur le processeur - lsmem : Informations sur la mémoire - lspci : Lister les périphériques PCI (GPU, réseau, etc.) - uname -a : Infos kernel et architecture système - env : Afficher toutes les variables d'environnement - export VAR=value : Définir une variable d'environnement - echo $VAR : Afficher la valeur d'une variable - history : Historique des commandes exécutées - which : Trouver le chemin d'un exécutable - whereis : Trouver binaire, source et man d'une commande 4. Réseau : - ping : Tester la connectivité vers un hôte - curl : Envoyer une requête HTTP (GET par défaut) - curl -X POST -d '{}' : Requête HTTP POST avec body JSON - curl -O : Télécharger un fichier - wget : Télécharger un fichier via URL - wget -r : Télécharger récursivement - ifconfig / ip a : Afficher les interfaces réseau et IPs - ip route : Afficher la table de routage - netstat -tulnp : Lister les ports ouverts et processus associés - ss -tulnp : Alternative moderne à netstat - nmap : Scanner les ports d'une machine - traceroute : Tracer le chemin réseau vers un hôte - dig : Résolution DNS d'un domaine - host : Résolution DNS simplifiée - ssh user@host : Connexion SSH à une machine distante - ssh-keygen : Générer une paire de clés SSH - scp user@host: : Copier un fichier via SSH - rsync -avz : Synchronisation de fichiers (local ou distant) - nc -l : Écouter sur un port (netcat) - nc : Se connecter à un port distant 5. Gestion de paquets : - apt update : Mettre à jour la liste des paquets (Debian/Ubuntu) - apt upgrade : Mettre à jour les paquets installés - apt install : Installer un paquet - apt remove : Désinstaller un paquet - apt search : Chercher un paquet dans les dépôts - apt show : Afficher les détails d'un paquet - dpkg -i : Installer un fichier .deb local - dpkg -l : Lister tous les paquets installés - snap install : Installer via Snap - pip install : Installer un paquet Python - pip list : Lister les paquets Python installés - pip freeze > requirements.txt : Exporter les dépendances Python - npm install : Installer un paquet Node.js local - npm install -g : Installer un paquet Node.js global - npm list : Lister les paquets npm du projet - npm run