Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b6765a9bc8 | ||
|
|
efdda0ed00 | ||
|
|
8a32c16ff4 | ||
|
|
4ce11d0bfe | ||
|
|
b3d92558fc | ||
|
|
ec37ac06fe | ||
|
|
6f7e3efd6e | ||
|
|
f794937fd8 | ||
|
|
4b80ff404f | ||
|
|
9288e849af | ||
|
|
00a92de1c4 |
No files matched your search
@@ -5,56 +5,124 @@ Ce projet est un laboratoire d'intelligence artificielle personnel. Il agit comm
|
|||||||
L'interface visuelle est inspirée de l'ergonomie de Gemini, avec le logo stylisé A38 (cerveau en réseau neuronal néon) comme charte graphique centrale.
|
L'interface visuelle est inspirée de l'ergonomie de Gemini, avec le logo stylisé A38 (cerveau en réseau neuronal néon) comme charte graphique centrale.
|
||||||
|
|
||||||
## 🏗️ Stack Technique & Architecture
|
## 🏗️ Stack Technique & Architecture
|
||||||
- **Backend :** FastAPI (Python) modulaire (une fonction = un module).
|
|
||||||
- **Frontend :** Vue.js + Tailwind CSS (Responsive / Mobile-first).
|
* **Backend :** FastAPI (Python) modulaire (une fonction = un module) asynchrone (httpx, asyncio).
|
||||||
- **Base de Données :** PostgreSQL (gestion des utilisateurs, historiques, suivi financier).
|
* **Frontend :** Vue.js + Tailwind CSS (Responsive / Mobile-first).
|
||||||
- **Traitement Documentaire :** LibreOffice Headless (génération/conversion Excel, Word, PDF).
|
* **Base de Données :** PostgreSQL (gestion des utilisateurs, historiques, suivi financier).
|
||||||
- **Déploiement :** Docker, géré via Dockge et Gitea, sécurisé sur grappe RAID.
|
* **Traitement Documentaire :** LibreOffice Headless (génération/conversion Excel, Word, PDF).
|
||||||
|
* **Déploiement :** Docker, géré via Dockge et Gitea, sécurisé sur grappe RAID.
|
||||||
|
|
||||||
## 📌 Règles de Versioning (SemVer)
|
## 📌 Règles de Versioning (SemVer)
|
||||||
|
|
||||||
Le développement suit un versioning strict (format `vX.Y.Z`) synchronisé avec les tags Gitea et GitHub, affiché dynamiquement sur l'interface :
|
Le développement suit un versioning strict (format `vX.Y.Z`) synchronisé avec les tags Gitea et GitHub, affiché dynamiquement sur l'interface :
|
||||||
- **Majeur (X) :** Changement profond d'architecture ou refonte globale.
|
|
||||||
- **Mineur (Y) :** Validation et ajout d'une nouvelle fonctionnalité de la roadmap.
|
* **Majeur (X) :** Changement profond d'architecture ou refonte globale.
|
||||||
- **Patch (Z) :** Corrections de bugs, correctifs de sécurité ou ajustements visuels mineurs.
|
* **Mineur (Y) :** Validation et ajout d'une nouvelle fonctionnalité de la roadmap.
|
||||||
|
* **Patch (Z) :** Corrections de bugs, correctifs de sécurité ou ajustements visuels mineurs.
|
||||||
|
|
||||||
|
## 📦 Récupération des Paquets Docker (Tags)
|
||||||
|
|
||||||
|
Les images Docker sont construites automatiquement par les pipelines CI/CD lors de la création d'un tag.
|
||||||
|
|
||||||
|
* **Sur Gitea :** Depuis la page principale de votre dépôt, naviguez dans l'onglet **Packages** (ou Paquets). Vous y trouverez le registre de conteneurs avec toutes les versions taguées (`v0.10.1`, `latest`, etc.).
|
||||||
|
* **Sur GitHub :** Depuis la page principale du dépôt, regardez dans la colonne de droite la section **Packages**. Cliquez dessus pour accéder au GitHub Container Registry (`ghcr.io/votre-utilisateur/aethas38-multi-ia`) et visualiser la liste des tags disponibles à tirer via Docker/Dockge.
|
||||||
|
|
||||||
## 🚀 ROADMAP & CAHIER DES CHARGES
|
## 🚀 ROADMAP & CAHIER DES CHARGES
|
||||||
|
|
||||||
### Sécurité & Infrastructure
|
### Sécurité & Infrastructure
|
||||||
- [x] Installation stricte via Dockge et Gitea (création automatique des dossiers inclus).
|
|
||||||
- [x] Sécurisation de la totalité du projet (fichiers, BDD PostgreSQL) sur le stockage RAID.
|
* [x] Installation stricte via Dockge et Gitea (création automatique des dossiers inclus).
|
||||||
- [x] Mots de passe cryptés (bcrypt), protection anti-brute force.
|
|
||||||
- [x] Authentification 2FA obligatoire (Keepassium, Authenticator, etc.).
|
|
||||||
- [x] Déconnexion automatique (timer invisible / session JWT) après 60 minutes d'inactivité.
|
* [x] Sécurisation de la totalité du projet (fichiers, BDD PostgreSQL) sur le stockage RAID.
|
||||||
- [x] Configuration de GitHub Actions / Gitea Actions pour la création automatique des paquets Docker (Tags SemVer + latest).
|
|
||||||
- [x] Horodatage UTC en base de données pour immunité au changement d'heure français (Prévention crash 2FA).
|
|
||||||
- [ ] Procédure de réinitialisation/modification du mot de passe (Admin et Utilisateurs).
|
* [x] Mots de passe cryptés (bcrypt), protection anti-brute force.
|
||||||
|
|
||||||
|
|
||||||
|
* [x] Authentification 2FA obligatoire (Keepassium, Authenticator, etc.).
|
||||||
|
|
||||||
|
|
||||||
|
* [x] Déconnexion automatique (timer invisible / session JWT) après 60 minutes d'inactivité.
|
||||||
|
|
||||||
|
|
||||||
|
* [x] Configuration de GitHub Actions / Gitea Actions pour la création automatique des paquets Docker (Tags SemVer + latest).
|
||||||
|
|
||||||
|
|
||||||
|
* [x] Horodatage UTC en base de données pour immunité au changement d'heure français (Prévention crash 2FA).
|
||||||
|
|
||||||
|
|
||||||
|
* [x] Rotation automatique des logs système : génération d'un fichier log par jour avec purge stricte des fichiers de plus de 7 jours.
|
||||||
|
* [ ] Procédure de réinitialisation/modification du mot de passe (Admin et Utilisateurs).
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
### Administration & Gestion des Utilisateurs
|
### Administration & Gestion des Utilisateurs
|
||||||
- [x] Assistant de première installation (création du compte admin complet).
|
|
||||||
- [ ] Refonte du setup initial (Super Admin) : Obligation de configurer le serveur mail (aide opérateurs FR/Gmail) et proposition de saisie des clés API.
|
* [x] Assistant de première installation (création du compte admin complet).
|
||||||
- [ ] Intégration de la roue crantée (Paramètres) en bas de la barre latérale.
|
|
||||||
- [ ] Page de configuration Utilisateur : changement d'email (avec validation via lien envoyé) et de mot de passe.
|
|
||||||
- [ ] Page de configuration Admin : ajout/modification de fournisseurs, clés API, et serveur mail en permanence.
|
* [x] Refonte du setup initial (Super Admin) : Obligation de configurer le serveur mail (aide opérateurs FR/Gmail) et paramétrage complet des clés fournisseurs IA (OpenRouter, Groq, Gemini, DeepSeek, Mistral, Cloudflare, HF).
|
||||||
- [ ] Hiérarchie des rôles : Un Admin peut proposer l'élévation d'un User en Admin (formulaire soumis à la validation exclusive du Super Admin).
|
* [x] Intégration de la roue crantée (Paramètres) en bas de la barre latérale.
|
||||||
- [ ] Export de l'activité Admin : Fichier Excel avec KPI, graphiques "camembert", et suivi financier par utilisateur.
|
* [ ] Page de configuration Utilisateur : changement d'email (avec validation via lien envoyé) et de mot de passe.
|
||||||
- [ ] Suivi financier en temps réel et vérification du budget API.
|
|
||||||
- [ ] Envoi de rapport d'activité automatisé chaque jeudi à 04h00.
|
|
||||||
|
* [ ] Page de configuration Admin : ajout/modification de fournisseurs, clés API, et serveur mail en permanence.
|
||||||
|
|
||||||
|
|
||||||
|
* [ ] Hiérarchie des rôles : Un Admin peut proposer l'élévation d'un User en Admin (formulaire soumis à la validation exclusive du Super Admin).
|
||||||
|
|
||||||
|
|
||||||
|
* [ ] Export de l'activité Admin : Fichier Excel avec KPI, graphiques "camembert", et suivi financier par utilisateur.
|
||||||
|
|
||||||
|
|
||||||
|
* [ ] Suivi financier en temps réel et vérification du budget API.
|
||||||
|
|
||||||
|
|
||||||
|
* [ ] Envoi de rapport d'activité automatisé chaque jeudi à 04h00.
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
### Expérience Utilisateur (UI/UX)
|
### Expérience Utilisateur (UI/UX)
|
||||||
- [x] Thème moderne (Gemini-like) et 100% compatible smartphones.
|
|
||||||
- [x] Refonte de la gestion des projets : séparation Épinglés (en haut) / Non Épinglés (Récents).
|
* [x] Thème moderne (Gemini-like) et 100% compatible smartphones.
|
||||||
- [x] Arrêt de la création automatique de nouveau projet à l'ouverture.
|
|
||||||
- [x] Intégration permanente du logo AETHAS38 en local (Setup / Login / Dashboard).
|
|
||||||
- [ ] Indicateur visuel (Loader/Animation) signalant que l'IA AETHAS38 "réfléchit" ou travaille.
|
* [x] Refonte de la gestion des projets : séparation Épinglés (en haut) / Non Épinglés (Récents).
|
||||||
- [ ] Fonctionnalité de renommage manuel des discussions/projets.
|
|
||||||
|
|
||||||
|
* [x] Arrêt de la création automatique de nouveau projet à l'ouverture.
|
||||||
|
|
||||||
|
|
||||||
|
* [x] Intégration permanente du logo AETHAS38 en local (Setup / Login / Dashboard).
|
||||||
|
|
||||||
|
|
||||||
|
* [x] Indicateur visuel (Loader/Animation) signalant que l'IA AETHAS38 "réfléchit" ou travaille.
|
||||||
|
* [x] Fonctionnalité de renommage manuel des discussions/projets.
|
||||||
|
* [ ] Affichage natif et fluide des images directement dans le flux de la discussion.
|
||||||
|
* [ ] Système de partage des réponses sur les réseaux et messageries externes (Facebook, WhatsApp, etc.).
|
||||||
|
|
||||||
### Moteur IA, Modèles & Fonctionnalités
|
### Moteur IA, Modèles & Fonctionnalités
|
||||||
- [ ] Pipeline multi-agents : 1 Rédacteur de prompt, jusqu'à 5 Travailleurs, 1 Concaténeur final.
|
|
||||||
- [ ] Extraction automatisée des modèles disponibles chez les fournisseurs (sauvegarde txt horodatée ex: "07/10/2026 à 10h00").
|
* [x] Cœur asynchrone pour la parallélisation des appels API (module `orchestrator.py`).
|
||||||
- [ ] Tâche planifiée (CRON) pour la mise à jour des modèles toutes les 12h (le timer se reset si mise à jour manuelle).
|
* [ ] Pipeline multi-agents complet avec sélection dynamique :
|
||||||
- [ ] Classement, filtrage (Gratuit/Payant) et catégorisation des modèles (Texte, Code, Image, Audio, Vidéo).
|
* Possibilité de sélectionner de 1 à 5 travailleurs IA en parallèle.
|
||||||
- [ ] Upload manuel du fichier d'extraction des modèles avec intégration dans l'interface filtrable.
|
* Si un seul travailleur est sélectionné, bypass automatique du prompteur et du concaténeur.
|
||||||
- [ ] Traduction automatisée des descriptions des modèles via Ollama (local) ou Gemini.
|
* Si > 1 travailleur, activation de la chaîne complète (1 Prompteur ➔ N Travailleurs ➔ 1 Concaténeur).
|
||||||
- [ ] Interface d'aide à la décision pour le choix des modèles selon la tâche souhaitée.
|
|
||||||
- [ ] Mécanisme de fallback / termes génériques pour les appels API (protection contre le dépassement des quotas Gemini).
|
|
||||||
- [ ] Téléchargement des requêtes, réponses et fichiers générés (Excel, PDF, TXT, Images).
|
* [ ] Extraction, mise à jour (via tâche planifiée CRON toutes les 12h ou manuelle) et gestion des modèles depuis les API fournisseurs vers la BDD.
|
||||||
|
* [ ] Page spécifique d'interface pour les modèles permettant l'export, l'import manuel d'un fichier d'extraction, et la sélection.
|
||||||
|
* [ ] Extraction unitaire des retours IA.
|
||||||
|
* [ ] Extraction/Téléchargement de la totalité d'une conversation dans des formats utiles aux différents fournisseurs (JSONL, TXT, etc.).
|
||||||
|
* [ ] Détection et téléchargement ciblé de pièces jointes ou blocs spécifiques (Code brut, fichiers Excel `.xlsx`) générés par l'IA en respectant le nommage exact demandé.
|
||||||
|
* [ ] Classement, filtrage (Gratuit/Payant) et catégorisation des modèles (Texte, Code, Image, Audio, Vidéo).
|
||||||
|
|
||||||
|
|
||||||
|
* [ ] Traduction automatisée des descriptions des modèles via Ollama (local) ou Gemini.
|
||||||
|
|
||||||
|
|
||||||
|
* [ ] Interface d'aide à la décision pour le choix des modèles selon la tâche souhaitée.
|
||||||
|
|
||||||
|
|
||||||
|
* [ ] Mécanisme de fallback / termes génériques pour les appels API (protection contre le dépassement des quotas Gemini).
|
||||||
@@ -0,0 +1,20 @@
|
|||||||
|
# 📚 WIKI AETHAS38 - Configuration des Fournisseurs IA
|
||||||
|
|
||||||
|
Ce document détaille la procédure pour obtenir les clés API avec les droits complets (Inférence + Accès financier) nécessaires au fonctionnement de l'Orchestrateur AETHAS38.
|
||||||
|
|
||||||
|
## 1. OpenRouter (Prioritaire)
|
||||||
|
OpenRouter agit comme un agrégateur. C'est le fournisseur recommandé car il permet d'accéder à presque tous les modèles (y compris Gemini, Claude, Llama) avec un seul portefeuille prépayé.
|
||||||
|
* **Obtenir la clé API :** Allez sur [OpenRouter Keys](https://openrouter.ai/keys). Créez une clé standard sans limite de crédit pour permettre à AETHAS38 de requêter les modèles.
|
||||||
|
* **Accès Financier (Management Key) :** Pour que AETHAS38 lise votre solde en temps réel, vous devez générer une clé spécifique d'administration (Management Key) sur la même page, ou accorder les droits `read_balance` à votre clé API principale selon les dernières mises à jour de leur interface.
|
||||||
|
|
||||||
|
## 2. Google Gemini Studio
|
||||||
|
* **Obtenir la clé API :** Rendez-vous sur [Google AI Studio](https://aistudio.google.com/app/apikey).
|
||||||
|
* **Levée des quotas :** Par défaut, la clé est gratuite mais soumise à des limites strictes (ex: 15 requêtes/minute) qui bloqueront le travail en parallèle d'AETHAS38. Pour un accès total, liez votre projet AI Studio à un compte de facturation Google Cloud Platform (GCP).
|
||||||
|
|
||||||
|
## 3. DeepSeek & Groq
|
||||||
|
* **DeepSeek :** [DeepSeek Platform](https://platform.deepseek.com/api_keys). Facturation à l'usage (Token). Il faut provisionner le compte par carte bancaire (Top-up).
|
||||||
|
* **Groq :** [Groq Console](https://console.groq.com/keys). Actuellement en phase gratuite avec quotas de requêtes très élevés, idéal pour les travailleurs de base de l'orchestrateur.
|
||||||
|
|
||||||
|
## 4. Cloudflare Workers AI & HuggingFace
|
||||||
|
* **Cloudflare :** [Cloudflare Dash](https://dash.cloudflare.com/profile/api-tokens). Créez un token personnalisé avec la permission `Workers AI : Read/Write`. L'ID de compte (Account ID) est visible dans la barre latérale droite de l'aperçu de la zone.
|
||||||
|
* **HuggingFace :** [HF Settings](https://huggingface.co/settings/tokens). Générez un token *Fine-Grained* et cochez les permissions liées à l'`Inference API` pour permettre l'exécution des modèles serverless.
|
||||||
@@ -0,0 +1,52 @@
|
|||||||
|
from openai import OpenAI
|
||||||
|
from fastapi import HTTPException
|
||||||
|
from .models import SystemSettings
|
||||||
|
|
||||||
|
def get_ai_response(messages: list, settings: SystemSettings) -> str:
|
||||||
|
"""Route la conversation vers le premier fournisseur IA disponible, priorité à Gemini Direct."""
|
||||||
|
if not settings:
|
||||||
|
raise HTTPException(status_code=500, detail="Configuration système introuvable.")
|
||||||
|
|
||||||
|
formatted_messages = [{"role": msg.role, "content": msg.content} for msg in messages]
|
||||||
|
|
||||||
|
try:
|
||||||
|
# 1. Priorité absolue : Test Gemini direct
|
||||||
|
if settings.gemini_api_key:
|
||||||
|
client = OpenAI(
|
||||||
|
base_url="https://generativelanguage.googleapis.com/v1beta/openai/",
|
||||||
|
api_key=settings.gemini_api_key
|
||||||
|
)
|
||||||
|
# Correction : Utilisation exacte du modèle 3.5 Flash-Lite
|
||||||
|
model = "gemini-3.5-flash-lite"
|
||||||
|
response = client.chat.completions.create(model=model, messages=formatted_messages)
|
||||||
|
|
||||||
|
# 2. Test OpenRouter (Fallback)
|
||||||
|
elif settings.openrouter_api_key:
|
||||||
|
client = OpenAI(base_url="https://openrouter.ai/api/v1", api_key=settings.openrouter_api_key)
|
||||||
|
model = "google/gemini-3.5-flash-lite"
|
||||||
|
response = client.chat.completions.create(
|
||||||
|
model=model,
|
||||||
|
messages=formatted_messages,
|
||||||
|
extra_headers={"HTTP-Referer": "https://aethas38.duckdns.org", "X-Title": "AETHAS38"}
|
||||||
|
)
|
||||||
|
|
||||||
|
# 3. Test DeepSeek
|
||||||
|
elif settings.deepseek_api_key:
|
||||||
|
client = OpenAI(base_url="https://api.deepseek.com/v1", api_key=settings.deepseek_api_key)
|
||||||
|
model = "deepseek-chat"
|
||||||
|
response = client.chat.completions.create(model=model, messages=formatted_messages)
|
||||||
|
|
||||||
|
# 4. Test Groq
|
||||||
|
elif settings.groq_api_key:
|
||||||
|
client = OpenAI(base_url="https://api.groq.com/openai/v1", api_key=settings.groq_api_key)
|
||||||
|
model = "llama3-8b-8192"
|
||||||
|
response = client.chat.completions.create(model=model, messages=formatted_messages)
|
||||||
|
|
||||||
|
else:
|
||||||
|
raise HTTPException(status_code=400, detail="Aucune clé API IA n'est configurée.")
|
||||||
|
|
||||||
|
return response.choices[0].message.content
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Erreur API IA : {str(e)}")
|
||||||
|
raise HTTPException(status_code=502, detail=f"Détail du fournisseur : {str(e)}")
|
||||||
@@ -0,0 +1,24 @@
|
|||||||
|
import logging
|
||||||
|
from logging.handlers import TimedRotatingFileHandler
|
||||||
|
import os
|
||||||
|
|
||||||
|
# Création du dossier logs à la racine du projet
|
||||||
|
log_dir = os.path.join(os.getcwd(), "logs")
|
||||||
|
os.makedirs(log_dir, exist_ok=True)
|
||||||
|
|
||||||
|
# Configuration du logger
|
||||||
|
system_logger = logging.getLogger("AETHAS38_Logger")
|
||||||
|
system_logger.setLevel(logging.INFO)
|
||||||
|
|
||||||
|
# Rotation tous les jours à minuit, conservation sur 7 jours
|
||||||
|
handler = TimedRotatingFileHandler(
|
||||||
|
filename=os.path.join(log_dir, "aethas38_system.log"),
|
||||||
|
when="midnight",
|
||||||
|
interval=1,
|
||||||
|
backupCount=7,
|
||||||
|
encoding="utf-8"
|
||||||
|
)
|
||||||
|
|
||||||
|
formatter = logging.Formatter('%(asctime)s - %(levelname)s - %(message)s', datefmt='%d/%m/%Y %H:%M:%S')
|
||||||
|
handler.setFormatter(formatter)
|
||||||
|
system_logger.addHandler(handler)
|
||||||
+57
-113
@@ -7,23 +7,23 @@ import os
|
|||||||
|
|
||||||
# Importation de nos modules locaux
|
# Importation de nos modules locaux
|
||||||
from .database import engine, Base, get_db
|
from .database import engine, Base, get_db
|
||||||
from .models import User, Project, Message
|
|
||||||
from .auth import get_password_hash, generate_totp_secret, get_totp_uri, verify_password, verify_totp, create_access_token, verify_token
|
from .auth import get_password_hash, generate_totp_secret, get_totp_uri, verify_password, verify_totp, create_access_token, verify_token
|
||||||
from .schemas import AdminCreate, LoginRequest, ProjectCreate, ProjectResponse, ProjectRename, MessageCreate, MessageResponse
|
from .schemas import AdminCreate, LoginRequest, ProjectCreate, ProjectResponse, ProjectRename, MessageCreate, MessageResponse
|
||||||
from .models import User, Project, Message, SystemSettings
|
from .models import User, Project, Message, SystemSettings
|
||||||
|
from .orchestrator import run_orchestrator, sync_providers_models
|
||||||
|
from .models import User, Project, Message, SystemSettings, AIModel
|
||||||
|
|
||||||
# Création des tables dans la base de données
|
# Création des tables dans la base de données
|
||||||
Base.metadata.create_all(bind=engine)
|
Base.metadata.create_all(bind=engine)
|
||||||
|
|
||||||
app = FastAPI(title="AETHAS38 - Orchestrateur Multi-IA")
|
app = FastAPI(title="AETHAS38 - Orchestrateur Multi-IA")
|
||||||
|
|
||||||
# Configuration des fichiers statiques (images, css locaux, etc.)
|
# Configuration des fichiers statiques
|
||||||
assets_path = os.path.join(os.getcwd(), "frontend", "assets")
|
assets_path = os.path.join(os.getcwd(), "frontend", "assets")
|
||||||
os.makedirs(assets_path, exist_ok=True) # Crée le dossier s'il n'existe pas
|
os.makedirs(assets_path, exist_ok=True)
|
||||||
app.mount("/static", StaticFiles(directory=assets_path), name="static")
|
app.mount("/assets", StaticFiles(directory=assets_path), name="assets")
|
||||||
|
|
||||||
def is_setup_required(db: Session) -> bool:
|
def is_setup_required(db: Session) -> bool:
|
||||||
"""Vérifie si la base de données contient au moins un administrateur."""
|
|
||||||
admin = db.query(User).filter(User.is_admin == True).first()
|
admin = db.query(User).filter(User.is_admin == True).first()
|
||||||
return admin is None
|
return admin is None
|
||||||
|
|
||||||
@@ -35,152 +35,82 @@ def read_root(db: Session = Depends(get_db)):
|
|||||||
|
|
||||||
@app.get("/setup")
|
@app.get("/setup")
|
||||||
def setup_page(db: Session = Depends(get_db)):
|
def setup_page(db: Session = Depends(get_db)):
|
||||||
"""Affiche l'interface d'installation Vue.js."""
|
|
||||||
if not is_setup_required(db):
|
if not is_setup_required(db):
|
||||||
return RedirectResponse(url="/login")
|
return RedirectResponse(url="/login")
|
||||||
|
|
||||||
frontend_path = os.path.join(os.getcwd(), "frontend", "index.html")
|
frontend_path = os.path.join(os.getcwd(), "frontend", "index.html")
|
||||||
if not os.path.exists(frontend_path):
|
if not os.path.exists(frontend_path):
|
||||||
raise HTTPException(status_code=404, detail="Interface introuvable.")
|
raise HTTPException(status_code=404, detail="Interface introuvable.")
|
||||||
|
|
||||||
return FileResponse(frontend_path)
|
return FileResponse(frontend_path)
|
||||||
|
|
||||||
@app.get("/login")
|
@app.get("/login")
|
||||||
def login_page(db: Session = Depends(get_db)):
|
def login_page(db: Session = Depends(get_db)):
|
||||||
"""Affiche la page de connexion sécurisée."""
|
|
||||||
if is_setup_required(db):
|
if is_setup_required(db):
|
||||||
return RedirectResponse(url="/setup")
|
return RedirectResponse(url="/setup")
|
||||||
|
|
||||||
frontend_path = os.path.join(os.getcwd(), "frontend", "login.html")
|
frontend_path = os.path.join(os.getcwd(), "frontend", "login.html")
|
||||||
if not os.path.exists(frontend_path):
|
if not os.path.exists(frontend_path):
|
||||||
raise HTTPException(status_code=404, detail="Interface de connexion introuvable.")
|
raise HTTPException(status_code=404, detail="Interface de connexion introuvable.")
|
||||||
|
|
||||||
return FileResponse(frontend_path)
|
return FileResponse(frontend_path)
|
||||||
|
|
||||||
@app.post("/api/setup")
|
@app.post("/api/setup")
|
||||||
def create_admin(admin_data: AdminCreate, db: Session = Depends(get_db)):
|
def create_admin(admin_data: AdminCreate, db: Session = Depends(get_db)):
|
||||||
"""Reçoit les données du frontend, crée l'admin, sauvegarde la configuration et retourne le QR Code 2FA."""
|
|
||||||
if not is_setup_required(db):
|
if not is_setup_required(db):
|
||||||
raise HTTPException(
|
raise HTTPException(status_code=status.HTTP_403_FORBIDDEN, detail="L'installation a déjà été effectuée.")
|
||||||
status_code=status.HTTP_403_FORBIDDEN,
|
|
||||||
detail="L'installation a déjà été effectuée."
|
|
||||||
)
|
|
||||||
|
|
||||||
# Création du Super Admin
|
|
||||||
hashed_pw = get_password_hash(admin_data.password)
|
hashed_pw = get_password_hash(admin_data.password)
|
||||||
totp_secret = generate_totp_secret()
|
totp_secret = generate_totp_secret()
|
||||||
new_admin = User(
|
new_admin = User(email=admin_data.email, username=admin_data.username, hashed_password=hashed_pw, totp_secret=totp_secret, is_admin=True)
|
||||||
email=admin_data.email,
|
|
||||||
username=admin_data.username,
|
|
||||||
hashed_password=hashed_pw,
|
|
||||||
totp_secret=totp_secret,
|
|
||||||
is_admin=True
|
|
||||||
)
|
|
||||||
db.add(new_admin)
|
db.add(new_admin)
|
||||||
|
|
||||||
# Sauvegarde des paramètres système
|
|
||||||
new_settings = SystemSettings(
|
new_settings = SystemSettings(
|
||||||
smtp_host=admin_data.smtp_host,
|
smtp_host=admin_data.smtp_host, smtp_port=admin_data.smtp_port, smtp_user=admin_data.smtp_user, smtp_password=admin_data.smtp_password,
|
||||||
smtp_port=admin_data.smtp_port,
|
openrouter_api_key=admin_data.openrouter_api_key, openrouter_management_key=admin_data.openrouter_management_key,
|
||||||
smtp_user=admin_data.smtp_user,
|
groq_api_key=admin_data.groq_api_key, gemini_api_key=admin_data.gemini_api_key, deepseek_api_key=admin_data.deepseek_api_key,
|
||||||
smtp_password=admin_data.smtp_password,
|
mistral_api_key=admin_data.mistral_api_key, cloudflare_account_id=admin_data.cloudflare_account_id, cloudflare_api_token=admin_data.cloudflare_api_token,
|
||||||
openrouter_api_key=admin_data.openrouter_api_key,
|
|
||||||
openrouter_management_key=admin_data.openrouter_management_key,
|
|
||||||
groq_api_key=admin_data.groq_api_key,
|
|
||||||
gemini_api_key=admin_data.gemini_api_key,
|
|
||||||
deepseek_api_key=admin_data.deepseek_api_key,
|
|
||||||
mistral_api_key=admin_data.mistral_api_key,
|
|
||||||
cloudflare_account_id=admin_data.cloudflare_account_id,
|
|
||||||
cloudflare_api_token=admin_data.cloudflare_api_token,
|
|
||||||
huggingface_api_key=admin_data.huggingface_api_key
|
huggingface_api_key=admin_data.huggingface_api_key
|
||||||
)
|
)
|
||||||
db.add(new_settings)
|
db.add(new_settings)
|
||||||
|
|
||||||
db.commit()
|
db.commit()
|
||||||
db.refresh(new_admin)
|
db.refresh(new_admin)
|
||||||
|
|
||||||
totp_uri = get_totp_uri(totp_secret, new_admin.username)
|
return {"message": "Configuration terminée avec succès.", "totp_secret": totp_secret, "totp_uri": get_totp_uri(totp_secret, new_admin.username)}
|
||||||
return {
|
|
||||||
"message": "Configuration terminée avec succès.",
|
|
||||||
"totp_secret": totp_secret,
|
|
||||||
"totp_uri": totp_uri
|
|
||||||
}
|
|
||||||
|
|
||||||
@app.post("/api/login")
|
@app.post("/api/login")
|
||||||
def login(login_data: LoginRequest, response: Response, db: Session = Depends(get_db)):
|
def login(login_data: LoginRequest, response: Response, db: Session = Depends(get_db)):
|
||||||
"""Vérifie les identifiants et crée une session de 60 minutes."""
|
|
||||||
user = db.query(User).filter(User.username == login_data.username).first()
|
user = db.query(User).filter(User.username == login_data.username).first()
|
||||||
|
|
||||||
# Vérification de l'utilisateur et du mot de passe
|
|
||||||
if not user or not verify_password(login_data.password, user.hashed_password):
|
if not user or not verify_password(login_data.password, user.hashed_password):
|
||||||
raise HTTPException(
|
raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED, detail="Identifiants incorrects.")
|
||||||
status_code=status.HTTP_401_UNAUTHORIZED,
|
|
||||||
detail="Nom d'utilisateur ou mot de passe incorrect."
|
|
||||||
)
|
|
||||||
|
|
||||||
# Vérification du code 2FA
|
|
||||||
if not verify_totp(user.totp_secret, login_data.totp_code):
|
if not verify_totp(user.totp_secret, login_data.totp_code):
|
||||||
raise HTTPException(
|
raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED, detail="Code 2FA invalide.")
|
||||||
status_code=status.HTTP_401_UNAUTHORIZED,
|
|
||||||
detail="Code 2FA invalide."
|
|
||||||
)
|
|
||||||
|
|
||||||
# Création du jeton de session
|
|
||||||
access_token = create_access_token(data={"sub": user.username})
|
access_token = create_access_token(data={"sub": user.username})
|
||||||
|
response.set_cookie(key="session_token", value=access_token, httponly=True, max_age=3600, samesite="lax")
|
||||||
# Injection du jeton dans un cookie sécurisé (invisible pour le JavaScript côté client)
|
|
||||||
response.set_cookie(
|
|
||||||
key="session_token",
|
|
||||||
value=access_token,
|
|
||||||
httponly=True,
|
|
||||||
max_age=3600, # 3600 secondes = 60 minutes
|
|
||||||
samesite="lax"
|
|
||||||
)
|
|
||||||
|
|
||||||
return {"message": "Connexion réussie"}
|
return {"message": "Connexion réussie"}
|
||||||
|
|
||||||
@app.get("/dashboard")
|
@app.get("/dashboard")
|
||||||
def dashboard(request: Request):
|
def dashboard(request: Request):
|
||||||
"""Route protégée : affiche l'interface principale si le cookie est valide."""
|
|
||||||
token = request.cookies.get("session_token")
|
token = request.cookies.get("session_token")
|
||||||
if not token:
|
if not token or not verify_token(token):
|
||||||
return RedirectResponse(url="/login")
|
return RedirectResponse(url="/login")
|
||||||
|
|
||||||
payload = verify_token(token)
|
|
||||||
if not payload:
|
|
||||||
return RedirectResponse(url="/login")
|
|
||||||
|
|
||||||
frontend_path = os.path.join(os.getcwd(), "frontend", "dashboard.html")
|
frontend_path = os.path.join(os.getcwd(), "frontend", "dashboard.html")
|
||||||
if not os.path.exists(frontend_path):
|
|
||||||
raise HTTPException(status_code=404, detail="Interface du tableau de bord introuvable.")
|
|
||||||
|
|
||||||
return FileResponse(frontend_path)
|
return FileResponse(frontend_path)
|
||||||
|
|
||||||
# --- GESTION DES PROJETS ---
|
# --- GESTION DES PROJETS ---
|
||||||
|
|
||||||
def get_current_user(request: Request, db: Session = Depends(get_db)):
|
def get_current_user(request: Request, db: Session = Depends(get_db)):
|
||||||
"""Extrait l'utilisateur actuel à partir du cookie de session JWT."""
|
|
||||||
token = request.cookies.get("session_token")
|
token = request.cookies.get("session_token")
|
||||||
if not token:
|
if not token: raise HTTPException(status_code=401, detail="Non authentifié")
|
||||||
raise HTTPException(status_code=401, detail="Non authentifié")
|
|
||||||
|
|
||||||
payload = verify_token(token)
|
payload = verify_token(token)
|
||||||
if not payload:
|
if not payload: raise HTTPException(status_code=401, detail="Session expirée")
|
||||||
raise HTTPException(status_code=401, detail="Session expirée")
|
|
||||||
|
|
||||||
user = db.query(User).filter(User.username == payload.get("sub")).first()
|
user = db.query(User).filter(User.username == payload.get("sub")).first()
|
||||||
if not user:
|
if not user: raise HTTPException(status_code=401, detail="Utilisateur introuvable")
|
||||||
raise HTTPException(status_code=401, detail="Utilisateur introuvable")
|
|
||||||
return user
|
return user
|
||||||
|
|
||||||
@app.get("/api/projects", response_model=List[ProjectResponse])
|
@app.get("/api/projects", response_model=List[ProjectResponse])
|
||||||
def get_projects(db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
def get_projects(db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
"""Récupère tous les projets de l'utilisateur connecté."""
|
|
||||||
return db.query(Project).filter(Project.user_id == current_user.id).order_by(Project.created_at.desc()).all()
|
return db.query(Project).filter(Project.user_id == current_user.id).order_by(Project.created_at.desc()).all()
|
||||||
|
|
||||||
@app.post("/api/projects", response_model=ProjectResponse)
|
@app.post("/api/projects", response_model=ProjectResponse)
|
||||||
def create_project(project: ProjectCreate, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
def create_project(project: ProjectCreate, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
"""Crée un nouveau projet pour l'utilisateur connecté."""
|
|
||||||
new_project = Project(title=project.title, user_id=current_user.id)
|
new_project = Project(title=project.title, user_id=current_user.id)
|
||||||
db.add(new_project)
|
db.add(new_project)
|
||||||
db.commit()
|
db.commit()
|
||||||
@@ -189,11 +119,8 @@ def create_project(project: ProjectCreate, db: Session = Depends(get_db), curren
|
|||||||
|
|
||||||
@app.put("/api/projects/{project_id}/rename", response_model=ProjectResponse)
|
@app.put("/api/projects/{project_id}/rename", response_model=ProjectResponse)
|
||||||
def rename_project(project_id: int, project_data: ProjectRename, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
def rename_project(project_id: int, project_data: ProjectRename, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
"""Renomme un projet existant."""
|
|
||||||
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
||||||
if not project:
|
if not project: raise HTTPException(status_code=404, detail="Projet introuvable")
|
||||||
raise HTTPException(status_code=404, detail="Projet introuvable")
|
|
||||||
|
|
||||||
project.title = project_data.title
|
project.title = project_data.title
|
||||||
db.commit()
|
db.commit()
|
||||||
db.refresh(project)
|
db.refresh(project)
|
||||||
@@ -201,11 +128,8 @@ def rename_project(project_id: int, project_data: ProjectRename, db: Session = D
|
|||||||
|
|
||||||
@app.put("/api/projects/{project_id}/pin", response_model=ProjectResponse)
|
@app.put("/api/projects/{project_id}/pin", response_model=ProjectResponse)
|
||||||
def toggle_pin_project(project_id: int, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
def toggle_pin_project(project_id: int, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
"""Bascule le statut épinglé (is_pinned) d'un projet."""
|
|
||||||
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
||||||
if not project:
|
if not project: raise HTTPException(status_code=404, detail="Projet introuvable")
|
||||||
raise HTTPException(status_code=404, detail="Projet introuvable")
|
|
||||||
|
|
||||||
project.is_pinned = not project.is_pinned
|
project.is_pinned = not project.is_pinned
|
||||||
db.commit()
|
db.commit()
|
||||||
db.refresh(project)
|
db.refresh(project)
|
||||||
@@ -213,11 +137,8 @@ def toggle_pin_project(project_id: int, db: Session = Depends(get_db), current_u
|
|||||||
|
|
||||||
@app.delete("/api/projects/{project_id}")
|
@app.delete("/api/projects/{project_id}")
|
||||||
def delete_project(project_id: int, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
def delete_project(project_id: int, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
"""Supprime définitivement un projet et tous ses messages associés."""
|
|
||||||
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
||||||
if not project:
|
if not project: raise HTTPException(status_code=404, detail="Projet introuvable")
|
||||||
raise HTTPException(status_code=404, detail="Projet introuvable")
|
|
||||||
|
|
||||||
db.delete(project)
|
db.delete(project)
|
||||||
db.commit()
|
db.commit()
|
||||||
return {"message": "Projet supprimé"}
|
return {"message": "Projet supprimé"}
|
||||||
@@ -226,21 +147,44 @@ def delete_project(project_id: int, db: Session = Depends(get_db), current_user:
|
|||||||
|
|
||||||
@app.get("/api/projects/{project_id}/messages", response_model=List[MessageResponse])
|
@app.get("/api/projects/{project_id}/messages", response_model=List[MessageResponse])
|
||||||
def get_messages(project_id: int, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
def get_messages(project_id: int, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
"""Récupère tous les messages d'un projet spécifique."""
|
|
||||||
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
||||||
if not project:
|
if not project: raise HTTPException(status_code=404, detail="Projet introuvable")
|
||||||
raise HTTPException(status_code=404, detail="Projet introuvable")
|
|
||||||
return db.query(Message).filter(Message.project_id == project_id).order_by(Message.created_at.asc()).all()
|
return db.query(Message).filter(Message.project_id == project_id).order_by(Message.created_at.asc()).all()
|
||||||
|
|
||||||
@app.post("/api/projects/{project_id}/messages", response_model=MessageResponse)
|
@app.post("/api/projects/{project_id}/messages", response_model=List[MessageResponse])
|
||||||
def create_message(project_id: int, message: MessageCreate, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
async def create_message(project_id: int, message: MessageCreate, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
"""Ajoute un message à un projet."""
|
"""Ajoute un message, lance l'Orchestrateur asynchrone et retourne l'historique."""
|
||||||
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
project = db.query(Project).filter(Project.id == project_id, Project.user_id == current_user.id).first()
|
||||||
if not project:
|
if not project: raise HTTPException(status_code=404, detail="Projet introuvable")
|
||||||
raise HTTPException(status_code=404, detail="Projet introuvable")
|
|
||||||
|
|
||||||
new_message = Message(role=message.role, content=message.content, project_id=project_id)
|
user_message = Message(role=message.role, content=message.content, project_id=project_id)
|
||||||
db.add(new_message)
|
db.add(user_message)
|
||||||
db.commit()
|
db.commit()
|
||||||
db.refresh(new_message)
|
|
||||||
return new_message
|
history = db.query(Message).filter(Message.project_id == project_id).order_by(Message.created_at.asc()).all()
|
||||||
|
settings = db.query(SystemSettings).first()
|
||||||
|
|
||||||
|
# Configuration temporaire (sera remplacée par les choix du Frontend à la Phase 2)
|
||||||
|
# Ex pour tester le pipeline complet : {"workers": ["gemini-3.5-flash-lite", "google/gemini-1.5-pro"]}
|
||||||
|
orchestrator_config = {"workers": ["gemini-3.5-flash-lite"]}
|
||||||
|
|
||||||
|
ai_response_text = await run_orchestrator(history, settings, orchestrator_config)
|
||||||
|
|
||||||
|
ai_message = Message(role="assistant", content=ai_response_text, project_id=project_id)
|
||||||
|
db.add(ai_message)
|
||||||
|
db.commit()
|
||||||
|
|
||||||
|
return db.query(Message).filter(Message.project_id == project_id).order_by(Message.created_at.asc()).all()
|
||||||
|
|
||||||
|
@app.post("/api/models/sync")
|
||||||
|
async def trigger_model_sync(db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
|
"""Déclenche manuellement l'extraction et la mise à jour des modèles depuis les API."""
|
||||||
|
if not current_user.is_admin:
|
||||||
|
raise HTTPException(status_code=403, detail="Accès réservé aux administrateurs.")
|
||||||
|
settings = db.query(SystemSettings).first()
|
||||||
|
return await sync_providers_models(db, settings)
|
||||||
|
|
||||||
|
@app.get("/api/models")
|
||||||
|
def get_models(db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
|
||||||
|
"""Renvoie la liste complète des modèles stockés en base de données."""
|
||||||
|
return db.query(AIModel).order_by(AIModel.name.asc()).all()
|
||||||
+32
-25
@@ -1,58 +1,44 @@
|
|||||||
from sqlalchemy import Column, Integer, String, Boolean, DateTime, ForeignKey, Text
|
from sqlalchemy import Column, Integer, String, Boolean, ForeignKey, DateTime, Float
|
||||||
from sqlalchemy.orm import relationship
|
from sqlalchemy.orm import relationship
|
||||||
from datetime import datetime, timezone
|
from datetime import datetime, timezone
|
||||||
from .database import Base
|
from .database import Base
|
||||||
|
|
||||||
class User(Base):
|
class User(Base):
|
||||||
__tablename__ = "users"
|
__tablename__ = "users"
|
||||||
|
|
||||||
id = Column(Integer, primary_key=True, index=True)
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
email = Column(String, unique=True, index=True, nullable=False)
|
email = Column(String, unique=True, index=True)
|
||||||
username = Column(String, unique=True, index=True, nullable=False)
|
username = Column(String, unique=True, index=True)
|
||||||
hashed_password = Column(String, nullable=False)
|
hashed_password = Column(String)
|
||||||
totp_secret = Column(String, nullable=False)
|
totp_secret = Column(String)
|
||||||
is_admin = Column(Boolean, default=False)
|
is_admin = Column(Boolean, default=False)
|
||||||
|
projects = relationship("Project", back_populates="owner")
|
||||||
# Relation : Un utilisateur peut avoir plusieurs projets
|
|
||||||
projects = relationship("Project", back_populates="owner", cascade="all, delete-orphan")
|
|
||||||
|
|
||||||
|
|
||||||
class Project(Base):
|
class Project(Base):
|
||||||
__tablename__ = "projects"
|
__tablename__ = "projects"
|
||||||
|
|
||||||
id = Column(Integer, primary_key=True, index=True)
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
title = Column(String, nullable=False)
|
title = Column(String, index=True)
|
||||||
created_at = Column(DateTime, default=lambda: datetime.now(timezone.utc))
|
created_at = Column(DateTime, default=lambda: datetime.now(timezone.utc))
|
||||||
is_pinned = Column(Boolean, default=False)
|
is_pinned = Column(Boolean, default=False)
|
||||||
user_id = Column(Integer, ForeignKey("users.id"), nullable=False)
|
user_id = Column(Integer, ForeignKey("users.id"))
|
||||||
|
|
||||||
# Relations
|
|
||||||
owner = relationship("User", back_populates="projects")
|
owner = relationship("User", back_populates="projects")
|
||||||
messages = relationship("Message", back_populates="project", cascade="all, delete-orphan")
|
messages = relationship("Message", back_populates="project", cascade="all, delete-orphan")
|
||||||
|
|
||||||
|
|
||||||
class Message(Base):
|
class Message(Base):
|
||||||
__tablename__ = "messages"
|
__tablename__ = "messages"
|
||||||
|
|
||||||
id = Column(Integer, primary_key=True, index=True)
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
role = Column(String, nullable=False) # Ex: 'user', 'assistant', 'worker_1', 'system'
|
role = Column(String)
|
||||||
content = Column(Text, nullable=False)
|
content = Column(String)
|
||||||
created_at = Column(DateTime, default=lambda: datetime.now(timezone.utc))
|
created_at = Column(DateTime, default=lambda: datetime.now(timezone.utc))
|
||||||
project_id = Column(Integer, ForeignKey("projects.id"), nullable=False)
|
project_id = Column(Integer, ForeignKey("projects.id"))
|
||||||
|
|
||||||
# Relation
|
|
||||||
project = relationship("Project", back_populates="messages")
|
project = relationship("Project", back_populates="messages")
|
||||||
|
|
||||||
class SystemSettings(Base):
|
class SystemSettings(Base):
|
||||||
__tablename__ = "system_settings"
|
__tablename__ = "system_settings"
|
||||||
|
|
||||||
id = Column(Integer, primary_key=True, index=True)
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
# Serveur Mail (Obligatoire)
|
|
||||||
smtp_host = Column(String, nullable=False)
|
smtp_host = Column(String, nullable=False)
|
||||||
smtp_port = Column(Integer, nullable=False)
|
smtp_port = Column(Integer, nullable=False)
|
||||||
smtp_user = Column(String, nullable=False)
|
smtp_user = Column(String, nullable=False)
|
||||||
smtp_password = Column(String, nullable=False)
|
smtp_password = Column(String, nullable=False)
|
||||||
# Clés API (Optionnelles)
|
|
||||||
openrouter_api_key = Column(String, nullable=True)
|
openrouter_api_key = Column(String, nullable=True)
|
||||||
openrouter_management_key = Column(String, nullable=True)
|
openrouter_management_key = Column(String, nullable=True)
|
||||||
groq_api_key = Column(String, nullable=True)
|
groq_api_key = Column(String, nullable=True)
|
||||||
@@ -62,3 +48,24 @@ class SystemSettings(Base):
|
|||||||
cloudflare_account_id = Column(String, nullable=True)
|
cloudflare_account_id = Column(String, nullable=True)
|
||||||
cloudflare_api_token = Column(String, nullable=True)
|
cloudflare_api_token = Column(String, nullable=True)
|
||||||
huggingface_api_key = Column(String, nullable=True)
|
huggingface_api_key = Column(String, nullable=True)
|
||||||
|
|
||||||
|
class AIModel(Base):
|
||||||
|
"""Stocke la liste des modèles extraits depuis les fournisseurs."""
|
||||||
|
__tablename__ = "ai_models"
|
||||||
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
|
provider = Column(String, index=True)
|
||||||
|
model_id = Column(String, unique=True, index=True)
|
||||||
|
name = Column(String)
|
||||||
|
context_length = Column(Integer)
|
||||||
|
pricing_prompt = Column(Float)
|
||||||
|
pricing_completion = Column(Float)
|
||||||
|
last_updated = Column(DateTime, default=lambda: datetime.now(timezone.utc))
|
||||||
|
|
||||||
|
class FinancialLog(Base):
|
||||||
|
"""Suivi financier par fournisseur."""
|
||||||
|
__tablename__ = "financial_logs"
|
||||||
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
|
provider = Column(String, index=True)
|
||||||
|
balance = Column(Float)
|
||||||
|
total_usage = Column(Float)
|
||||||
|
checked_at = Column(DateTime, default=lambda: datetime.now(timezone.utc))
|
||||||
@@ -0,0 +1,127 @@
|
|||||||
|
import asyncio
|
||||||
|
import httpx
|
||||||
|
from openai import AsyncOpenAI
|
||||||
|
from fastapi import HTTPException
|
||||||
|
from sqlalchemy.orm import Session
|
||||||
|
from .models import SystemSettings, AIModel
|
||||||
|
from .logger import system_logger
|
||||||
|
from datetime import datetime, timezone
|
||||||
|
|
||||||
|
# --- PARTIE 1 : EXTRACTION DES MODÈLES ---
|
||||||
|
async def sync_providers_models(db: Session, settings: SystemSettings):
|
||||||
|
"""Extrait et met à jour les modèles depuis les fournisseurs configurés."""
|
||||||
|
added_or_updated = 0
|
||||||
|
|
||||||
|
# httpx.AsyncClient permet des requêtes non-bloquantes (ultra rapide)
|
||||||
|
async with httpx.AsyncClient() as client:
|
||||||
|
# 1. OpenRouter (Exemple principal pour l'extraction massive)
|
||||||
|
if settings.openrouter_api_key:
|
||||||
|
try:
|
||||||
|
response = await client.get("https://openrouter.ai/api/v1/models")
|
||||||
|
if response.status_code == 200:
|
||||||
|
for item in response.json().get("data", []):
|
||||||
|
model_id = item["id"]
|
||||||
|
existing = db.query(AIModel).filter(AIModel.model_id == model_id).first()
|
||||||
|
|
||||||
|
pricing = item.get("pricing", {})
|
||||||
|
# Conversion en coût pour 1 Million de tokens
|
||||||
|
p_prompt = float(pricing.get("prompt", 0)) * 1000000 if pricing.get("prompt") else 0.0
|
||||||
|
p_comp = float(pricing.get("completion", 0)) * 1000000 if pricing.get("completion") else 0.0
|
||||||
|
|
||||||
|
if existing:
|
||||||
|
existing.pricing_prompt = p_prompt
|
||||||
|
existing.pricing_completion = p_comp
|
||||||
|
existing.last_updated = datetime.now(timezone.utc)
|
||||||
|
else:
|
||||||
|
new_model = AIModel(
|
||||||
|
provider="openrouter",
|
||||||
|
model_id=model_id,
|
||||||
|
name=item["name"],
|
||||||
|
context_length=item.get("context_length", 0),
|
||||||
|
pricing_prompt=p_prompt,
|
||||||
|
pricing_completion=p_comp
|
||||||
|
)
|
||||||
|
db.add(new_model)
|
||||||
|
added_or_updated += 1
|
||||||
|
except Exception as e:
|
||||||
|
system_logger.error(f"Erreur Sync OpenRouter: {e}")
|
||||||
|
|
||||||
|
db.commit()
|
||||||
|
return {"status": "success", "models_processed": added_or_updated}
|
||||||
|
|
||||||
|
# --- PARTIE 2 : MOTEUR MULTI-AGENTS ---
|
||||||
|
def get_client_for_model(model_id: str, settings: SystemSettings):
|
||||||
|
"""Retourne le client AsyncOpenAI approprié selon le modèle sélectionné."""
|
||||||
|
if "gemini" in model_id.lower() and settings.gemini_api_key:
|
||||||
|
return AsyncOpenAI(base_url="https://generativelanguage.googleapis.com/v1beta/openai/", api_key=settings.gemini_api_key)
|
||||||
|
elif settings.openrouter_api_key:
|
||||||
|
return AsyncOpenAI(base_url="https://openrouter.ai/api/v1", api_key=settings.openrouter_api_key)
|
||||||
|
raise ValueError(f"Aucun fournisseur configuré pour {model_id}")
|
||||||
|
|
||||||
|
async def ask_agent(client, model_id, messages, is_openrouter=False):
|
||||||
|
"""Appel asynchrone à un modèle IA."""
|
||||||
|
kwargs = {"model": model_id, "messages": messages}
|
||||||
|
if is_openrouter:
|
||||||
|
kwargs["extra_headers"] = {"HTTP-Referer": "https://aethas38.duckdns.org", "X-Title": "AETHAS38 Orchestrator"}
|
||||||
|
|
||||||
|
response = await client.chat.completions.create(**kwargs)
|
||||||
|
return response.choices[0].message.content
|
||||||
|
|
||||||
|
async def run_orchestrator(history: list, settings: SystemSettings, config: dict) -> str:
|
||||||
|
"""
|
||||||
|
Gère la logique : 1 Prompteur -> N Travailleurs -> 1 Concaténeur.
|
||||||
|
Le dictionnaire 'config' proviendra de l'interface graphique.
|
||||||
|
"""
|
||||||
|
workers = config.get("workers", [])
|
||||||
|
if not workers:
|
||||||
|
workers = ["gemini-3.5-flash-lite"] # Fallback de sécurité
|
||||||
|
|
||||||
|
user_prompt = history[-1].content
|
||||||
|
formatted_history = [{"role": msg.role, "content": msg.content} for msg in history[:-1]]
|
||||||
|
|
||||||
|
# SCÉNARIO 1 : Un seul travailleur (Pas besoin de prompteur/concaténeur)
|
||||||
|
if len(workers) == 1:
|
||||||
|
worker_model = workers[0]
|
||||||
|
client = get_client_for_model(worker_model, settings)
|
||||||
|
messages = formatted_history + [{"role": "user", "content": user_prompt}]
|
||||||
|
return await ask_agent(client, worker_model, messages, "openrouter" in worker_model.lower())
|
||||||
|
|
||||||
|
# SCÉNARIO 2 : Multi-Travailleurs (Le pipeline complet)
|
||||||
|
try:
|
||||||
|
# Étape 1 : Le Prompteur améliore la requête
|
||||||
|
prompter_model = config.get("prompter", "gemini-3.5-flash-lite")
|
||||||
|
p_client = get_client_for_model(prompter_model, settings)
|
||||||
|
p_messages = [{"role": "system", "content": "Tu es un expert en Prompt Engineering. Optimise la requête de l'utilisateur pour qu'elle soit claire, directive et parfaite pour des IAs de génération. Retourne UNIQUEMENT le prompt optimisé."}]
|
||||||
|
p_messages.append({"role": "user", "content": user_prompt})
|
||||||
|
|
||||||
|
system_logger.info("Démarrage du Prompteur...")
|
||||||
|
optimized_prompt = await ask_agent(p_client, prompter_model, p_messages)
|
||||||
|
|
||||||
|
# Étape 2 : Les Travailleurs en parallèle (Magie de l'Asynchrone)
|
||||||
|
system_logger.info(f"Lancement de {len(workers)} travailleurs en parallèle...")
|
||||||
|
w_tasks = []
|
||||||
|
for w_model in workers:
|
||||||
|
w_client = get_client_for_model(w_model, settings)
|
||||||
|
w_messages = formatted_history + [{"role": "user", "content": optimized_prompt}]
|
||||||
|
# On stocke les tâches sans les attendre immédiatement
|
||||||
|
w_tasks.append(ask_agent(w_client, w_model, w_messages, "openrouter" in w_model.lower()))
|
||||||
|
|
||||||
|
# 'gather' exécute toutes les requêtes en même temps !
|
||||||
|
workers_responses = await asyncio.gather(*w_tasks, return_exceptions=True)
|
||||||
|
|
||||||
|
# Étape 3 : Le Concaténeur synthétise
|
||||||
|
concat_model = config.get("concatenator", "gemini-3.5-flash-lite")
|
||||||
|
c_client = get_client_for_model(concat_model, settings)
|
||||||
|
|
||||||
|
synthesis_prompt = f"Voici la requête initiale : {user_prompt}\n\nVoici les réponses de {len(workers)} experts IA différents :\n"
|
||||||
|
for i, resp in enumerate(workers_responses):
|
||||||
|
synthesis_prompt += f"--- EXPERT {i+1} ---\n{resp if not isinstance(resp, Exception) else 'Erreur de génération'}\n\n"
|
||||||
|
synthesis_prompt += "Fais une synthèse finale parfaite, complète et structurée de ces réponses, en gardant le meilleur de chacune."
|
||||||
|
|
||||||
|
system_logger.info("Démarrage du Concaténeur...")
|
||||||
|
c_messages = [{"role": "user", "content": synthesis_prompt}]
|
||||||
|
return await ask_agent(c_client, concat_model, c_messages)
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
system_logger.error(f"Erreur Pipeline Multi-Agents: {e}")
|
||||||
|
raise HTTPException(status_code=502, detail=f"Échec de l'orchestration : {str(e)}")
|
||||||
+26
-22
@@ -26,12 +26,11 @@
|
|||||||
<div id="app" class="flex w-full h-full relative bg-aethas-dark">
|
<div id="app" class="flex w-full h-full relative bg-aethas-dark">
|
||||||
<div v-if="isSidebarOpen" @click="toggleSidebar" class="md:hidden fixed inset-0 bg-black/60 z-40 transition-opacity"></div>
|
<div v-if="isSidebarOpen" @click="toggleSidebar" class="md:hidden fixed inset-0 bg-black/60 z-40 transition-opacity"></div>
|
||||||
|
|
||||||
<!-- BARRE LATÉRALE -->
|
|
||||||
<div :class="['transition-all duration-300 flex-shrink-0 relative z-50', isSidebarOpen ? 'w-72' : 'w-0']">
|
<div :class="['transition-all duration-300 flex-shrink-0 relative z-50', isSidebarOpen ? 'w-72' : 'w-0']">
|
||||||
<aside :class="['absolute top-0 left-0 h-full w-72 bg-aethas-panel border-r border-gray-700 flex flex-col transition-transform duration-300', isSidebarOpen ? 'translate-x-0' : '-translate-x-full']">
|
<aside :class="['absolute top-0 left-0 h-full w-72 bg-aethas-panel border-r border-gray-700 flex flex-col transition-transform duration-300', isSidebarOpen ? 'translate-x-0' : '-translate-x-full']">
|
||||||
<div class="p-4 border-b border-gray-700 flex items-center justify-between">
|
<div class="p-4 border-b border-gray-700 flex items-center justify-between">
|
||||||
<div class="flex items-center gap-3">
|
<div class="flex items-center gap-3">
|
||||||
<img src="/static/logo.png" alt="Logo" class="w-10 h-10 rounded-full border border-aethas-cyan object-cover bg-gray-800 flex-shrink-0">
|
<img src="/assets/logo.png" alt="Logo" class="w-10 h-10 rounded-full border border-aethas-cyan object-cover bg-gray-800 flex-shrink-0">
|
||||||
<span class="font-bold text-lg tracking-wider neon-text">AETHAS38</span>
|
<span class="font-bold text-lg tracking-wider neon-text">AETHAS38</span>
|
||||||
</div>
|
</div>
|
||||||
<button @click="toggleSidebar" class="md:hidden text-gray-400 hover:text-white"><i data-lucide="x" class="w-5 h-5"></i></button>
|
<button @click="toggleSidebar" class="md:hidden text-gray-400 hover:text-white"><i data-lucide="x" class="w-5 h-5"></i></button>
|
||||||
@@ -44,7 +43,6 @@
|
|||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="flex-1 overflow-y-auto p-4 space-y-6">
|
<div class="flex-1 overflow-y-auto p-4 space-y-6">
|
||||||
<!-- Projets Épinglés -->
|
|
||||||
<div v-if="pinnedProjects.length > 0">
|
<div v-if="pinnedProjects.length > 0">
|
||||||
<h3 class="text-xs font-semibold text-gray-400 uppercase tracking-wider mb-3">Épinglés</h3>
|
<h3 class="text-xs font-semibold text-gray-400 uppercase tracking-wider mb-3">Épinglés</h3>
|
||||||
<ul class="space-y-1">
|
<ul class="space-y-1">
|
||||||
@@ -62,7 +60,6 @@
|
|||||||
</ul>
|
</ul>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Projets Récents -->
|
|
||||||
<div>
|
<div>
|
||||||
<h3 class="text-xs font-semibold text-gray-400 uppercase tracking-wider mb-3">Récents</h3>
|
<h3 class="text-xs font-semibold text-gray-400 uppercase tracking-wider mb-3">Récents</h3>
|
||||||
<ul class="space-y-1">
|
<ul class="space-y-1">
|
||||||
@@ -82,20 +79,24 @@
|
|||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="p-4 border-t border-gray-700 flex items-center gap-2">
|
<div class="p-4 border-t border-gray-700 flex justify-between items-center">
|
||||||
|
<div class="flex items-center gap-2">
|
||||||
<div class="w-8 h-8 rounded-full bg-gradient-to-tr from-aethas-cyan to-aethas-purple flex items-center justify-center text-sm font-bold shadow-md">{{ username.charAt(0).toUpperCase() }}</div>
|
<div class="w-8 h-8 rounded-full bg-gradient-to-tr from-aethas-cyan to-aethas-purple flex items-center justify-center text-sm font-bold shadow-md">{{ username.charAt(0).toUpperCase() }}</div>
|
||||||
<span class="text-sm font-medium">{{ username }}</span>
|
<span class="text-sm font-medium">{{ username }}</span>
|
||||||
</div>
|
</div>
|
||||||
|
<button class="text-gray-400 hover:text-white transition-colors" title="Paramètres">
|
||||||
|
<i data-lucide="settings" class="w-5 h-5"></i>
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
</aside>
|
</aside>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- ZONE PRINCIPALE -->
|
|
||||||
<main class="flex-1 flex flex-col min-w-0 z-10 transition-all duration-300">
|
<main class="flex-1 flex flex-col min-w-0 z-10 transition-all duration-300">
|
||||||
<header class="flex items-center justify-between p-4 border-b border-gray-700 bg-aethas-panel h-[73px]">
|
<header class="flex items-center justify-between p-4 border-b border-gray-700 bg-aethas-panel h-[73px]">
|
||||||
<div class="flex items-center gap-3">
|
<div class="flex items-center gap-3">
|
||||||
<button @click="toggleSidebar" class="text-gray-400 hover:text-white transition-colors p-1.5 rounded hover:bg-gray-700"><i data-lucide="menu" class="w-6 h-6"></i></button>
|
<button @click="toggleSidebar" class="text-gray-400 hover:text-white transition-colors p-1.5 rounded hover:bg-gray-700"><i data-lucide="menu" class="w-6 h-6"></i></button>
|
||||||
<div v-show="!isSidebarOpen" class="flex items-center gap-2 transition-opacity duration-300">
|
<div v-show="!isSidebarOpen" class="flex items-center gap-2 transition-opacity duration-300">
|
||||||
<img src="/static/logo.png" alt="Logo" class="w-8 h-8 rounded-full border border-aethas-cyan object-cover bg-gray-800 flex-shrink-0">
|
<img src="/assets/logo.png" alt="Logo" class="w-8 h-8 rounded-full border border-aethas-cyan object-cover bg-gray-800 flex-shrink-0">
|
||||||
<span class="font-bold text-lg neon-text">AETHAS38</span>
|
<span class="font-bold text-lg neon-text">AETHAS38</span>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
@@ -105,14 +106,12 @@
|
|||||||
</div>
|
</div>
|
||||||
</header>
|
</header>
|
||||||
|
|
||||||
<!-- Affichage par défaut -->
|
|
||||||
<div v-if="!activeProject" class="flex-1 overflow-y-auto p-4 md:p-8 flex flex-col items-center justify-center">
|
<div v-if="!activeProject" class="flex-1 overflow-y-auto p-4 md:p-8 flex flex-col items-center justify-center">
|
||||||
<img src="/static/logo.png" alt="AETHAS38 Logo" class="w-24 h-24 mb-6 rounded-full border-2 border-aethas-cyan shadow-[0_0_15px_rgba(6,182,212,0.5)] object-cover bg-gray-800 flex-shrink-0">
|
<img src="/assets/logo.png" alt="AETHAS38 Logo" class="w-24 h-24 mb-6 rounded-full border-2 border-aethas-cyan shadow-[0_0_15px_rgba(6,182,212,0.5)] object-cover bg-gray-800 flex-shrink-0">
|
||||||
<h2 class="text-2xl font-bold text-gray-200 mb-2 text-center">Comment puis-je vous aider aujourd'hui ?</h2>
|
<h2 class="text-2xl font-bold text-gray-200 mb-2 text-center">Comment puis-je vous aider aujourd'hui ?</h2>
|
||||||
<p class="text-gray-500 text-sm text-center">Sélectionnez ou créez un projet pour commencer.</p>
|
<p class="text-gray-500 text-sm text-center">Sélectionnez ou créez un projet pour commencer.</p>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Zone de Chat -->
|
|
||||||
<div v-else class="flex-1 overflow-y-auto p-4 md:p-8 space-y-6 flex flex-col" id="chat-container">
|
<div v-else class="flex-1 overflow-y-auto p-4 md:p-8 space-y-6 flex flex-col" id="chat-container">
|
||||||
<div v-if="messages.length === 0" class="flex-1 flex items-center justify-center text-gray-500 italic">Démarrez la conversation ci-dessous.</div>
|
<div v-if="messages.length === 0" class="flex-1 flex items-center justify-center text-gray-500 italic">Démarrez la conversation ci-dessous.</div>
|
||||||
|
|
||||||
@@ -125,7 +124,6 @@
|
|||||||
<div class="text-gray-200 whitespace-pre-wrap text-sm leading-relaxed">{{ msg.content }}</div>
|
<div class="text-gray-200 whitespace-pre-wrap text-sm leading-relaxed">{{ msg.content }}</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Indicateur de chargement IA -->
|
|
||||||
<div v-if="isAiThinking" class="max-w-3xl rounded-2xl p-4 bg-aethas-panel mr-auto border border-aethas-cyan/30 w-24">
|
<div v-if="isAiThinking" class="max-w-3xl rounded-2xl p-4 bg-aethas-panel mr-auto border border-aethas-cyan/30 w-24">
|
||||||
<div class="flex items-center gap-2 mb-2">
|
<div class="flex items-center gap-2 mb-2">
|
||||||
<i data-lucide="bot" class="w-4 h-4 text-aethas-cyan"></i>
|
<i data-lucide="bot" class="w-4 h-4 text-aethas-cyan"></i>
|
||||||
@@ -139,7 +137,6 @@
|
|||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Saisie du Prompt -->
|
|
||||||
<div class="p-4 md:p-6 w-full max-w-4xl mx-auto">
|
<div class="p-4 md:p-6 w-full max-w-4xl mx-auto">
|
||||||
<div class="relative flex items-end bg-gray-800 border border-gray-600 rounded-2xl p-2 shadow-lg focus-within:border-aethas-cyan focus-within:ring-1 focus-within:ring-aethas-cyan transition-all">
|
<div class="relative flex items-end bg-gray-800 border border-gray-600 rounded-2xl p-2 shadow-lg focus-within:border-aethas-cyan focus-within:ring-1 focus-within:ring-aethas-cyan transition-all">
|
||||||
<button class="p-3 text-gray-400 hover:text-aethas-cyan transition-colors flex-shrink-0" :disabled="!activeProject || isAiThinking"><i data-lucide="paperclip" class="w-5 h-5"></i></button>
|
<button class="p-3 text-gray-400 hover:text-aethas-cyan transition-colors flex-shrink-0" :disabled="!activeProject || isAiThinking"><i data-lucide="paperclip" class="w-5 h-5"></i></button>
|
||||||
@@ -264,26 +261,33 @@
|
|||||||
nextTick(() => lucide.createIcons());
|
nextTick(() => lucide.createIcons());
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await fetch(`/api/projects/${activeProject.value.id}/messages`, {
|
const response = await fetch(`/api/projects/${activeProject.value.id}/messages`, {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
headers: { 'Content-Type': 'application/json' },
|
headers: { 'Content-Type': 'application/json' },
|
||||||
body: JSON.stringify({ role: 'user', content: userText })
|
body: JSON.stringify({ role: 'user', content: userText })
|
||||||
});
|
});
|
||||||
|
|
||||||
// SIMULATION TEMPORAIRE : Attente de l'IA (2 secondes)
|
if (response.ok) {
|
||||||
setTimeout(() => {
|
const data = await response.json();
|
||||||
isAiThinking.value = false;
|
if (Array.isArray(data)) {
|
||||||
scrollToBottom();
|
messages.value = data;
|
||||||
// La prochaine étape remplacera ce setTimeout par le véritable appel au moteur IA !
|
} else {
|
||||||
}, 2000);
|
selectProject(activeProject.value);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
const err = await response.json();
|
||||||
|
alert("Erreur de l'IA: " + err.detail);
|
||||||
|
}
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error("Erreur envoi message", error);
|
console.error("Erreur envoi message", error);
|
||||||
|
} finally {
|
||||||
isAiThinking.value = false;
|
isAiThinking.value = false;
|
||||||
|
scrollToBottom();
|
||||||
|
nextTick(() => lucide.createIcons());
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
const togglePin = async (projectId) => { /* ... code existant identique ... */
|
const togglePin = async (projectId) => {
|
||||||
try {
|
try {
|
||||||
const response = await fetch(`/api/projects/${projectId}/pin`, { method: 'PUT' });
|
const response = await fetch(`/api/projects/${projectId}/pin`, { method: 'PUT' });
|
||||||
if (response.ok) {
|
if (response.ok) {
|
||||||
@@ -294,7 +298,7 @@
|
|||||||
} catch (error) { console.error(error); }
|
} catch (error) { console.error(error); }
|
||||||
};
|
};
|
||||||
|
|
||||||
const deleteProject = async (projectId) => { /* ... code existant identique ... */
|
const deleteProject = async (projectId) => {
|
||||||
if (!confirm("Voulez-vous vraiment supprimer ce projet ?")) return;
|
if (!confirm("Voulez-vous vraiment supprimer ce projet ?")) return;
|
||||||
try {
|
try {
|
||||||
const response = await fetch(`/api/projects/${projectId}`, { method: 'DELETE' });
|
const response = await fetch(`/api/projects/${projectId}`, { method: 'DELETE' });
|
||||||
|
|||||||
+1
-1
@@ -22,7 +22,7 @@
|
|||||||
|
|
||||||
<div id="app" class="w-full max-w-3xl transition-all duration-500 my-8">
|
<div id="app" class="w-full max-w-3xl transition-all duration-500 my-8">
|
||||||
<div class="text-center mb-8">
|
<div class="text-center mb-8">
|
||||||
<img src="/static/logo.png" alt="AETHAS38 Logo" class="w-24 h-24 mx-auto mb-4 rounded-full border-2 border-aethas-cyan shadow-[0_0_15px_rgba(6,182,212,0.5)] object-cover bg-gray-800">
|
<img src="/assets/logo.png" alt="AETHAS38 Logo" class="w-24 h-24 mx-auto mb-4 rounded-full border-2 border-aethas-cyan shadow-[0_0_15px_rgba(6,182,212,0.5)] object-cover bg-gray-800">
|
||||||
<h1 class="text-3xl font-bold tracking-wider neon-text">AETHAS38</h1>
|
<h1 class="text-3xl font-bold tracking-wider neon-text">AETHAS38</h1>
|
||||||
<p class="text-gray-400 text-sm mt-2">Configuration Initiale (Super Admin)</p>
|
<p class="text-gray-400 text-sm mt-2">Configuration Initiale (Super Admin)</p>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
+23
-33
@@ -6,26 +6,12 @@
|
|||||||
<title>AETHAS38 - Connexion</title>
|
<title>AETHAS38 - Connexion</title>
|
||||||
<script src="https://cdn.tailwindcss.com"></script>
|
<script src="https://cdn.tailwindcss.com"></script>
|
||||||
<script>
|
<script>
|
||||||
tailwind.config = {
|
tailwind.config = { darkMode: 'class', theme: { extend: { colors: { aethas: { dark: '#0f172a', panel: '#1e293b', cyan: '#06b6d4', purple: '#a855f7' } } } } }
|
||||||
darkMode: 'class',
|
|
||||||
theme: {
|
|
||||||
extend: {
|
|
||||||
colors: {
|
|
||||||
aethas: {
|
|
||||||
dark: '#0f172a', panel: '#1e293b', cyan: '#06b6d4', purple: '#a855f7'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
</script>
|
</script>
|
||||||
<script src="https://unpkg.com/vue@3/dist/vue.global.js"></script>
|
<script src="https://unpkg.com/vue@3/dist/vue.global.js"></script>
|
||||||
<style>
|
<style>
|
||||||
body { background-color: #0f172a; color: #f8fafc; font-family: 'Inter', sans-serif; }
|
body { background-color: #0f172a; color: #f8fafc; font-family: 'Inter', sans-serif; }
|
||||||
.glass-panel {
|
.glass-panel { background: rgba(30, 41, 59, 0.7); backdrop-filter: blur(10px); border: 1px solid rgba(6, 182, 212, 0.2); box-shadow: 0 4px 30px rgba(0, 0, 0, 0.5); }
|
||||||
background: rgba(30, 41, 59, 0.7); backdrop-filter: blur(10px);
|
|
||||||
border: 1px solid rgba(6, 182, 212, 0.2); box-shadow: 0 4px 30px rgba(0, 0, 0, 0.5);
|
|
||||||
}
|
|
||||||
.neon-text { background: linear-gradient(to right, #06b6d4, #a855f7); -webkit-background-clip: text; -webkit-text-fill-color: transparent; }
|
.neon-text { background: linear-gradient(to right, #06b6d4, #a855f7); -webkit-background-clip: text; -webkit-text-fill-color: transparent; }
|
||||||
</style>
|
</style>
|
||||||
</head>
|
</head>
|
||||||
@@ -33,16 +19,14 @@
|
|||||||
|
|
||||||
<div id="app" class="w-full max-w-md transition-all duration-500">
|
<div id="app" class="w-full max-w-md transition-all duration-500">
|
||||||
<div class="text-center mb-8">
|
<div class="text-center mb-8">
|
||||||
<img src="https://via.placeholder.com/150x150/0f172a/06b6d4?text=Logo+A38" alt="AETHAS38 Logo" class="w-24 h-24 mx-auto mb-4 rounded-full border-2 border-aethas-cyan shadow-[0_0_15px_rgba(6,182,212,0.5)]">
|
<img src="/assets/logo.png" alt="AETHAS38 Logo" class="w-24 h-24 mx-auto mb-4 rounded-full border-2 border-aethas-cyan shadow-[0_0_15px_rgba(6,182,212,0.5)] object-cover bg-gray-800">
|
||||||
<h1 class="text-3xl font-bold tracking-wider neon-text">AETHAS38</h1>
|
<h1 class="text-3xl font-bold tracking-wider neon-text">AETHAS38</h1>
|
||||||
<p class="text-gray-400 text-sm mt-2">Authentification Sécurisée</p>
|
<p class="text-gray-400 text-sm mt-2">Authentification Sécurisée</p>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="glass-panel rounded-2xl p-6 sm:p-8">
|
<div class="glass-panel rounded-2xl p-6 sm:p-8">
|
||||||
<form @submit.prevent="submitLogin" class="space-y-5">
|
<form @submit.prevent="submitLogin" class="space-y-5">
|
||||||
<div v-if="errorMessage" class="p-3 bg-red-900/50 border border-red-500 rounded text-red-200 text-sm text-center">
|
<div v-if="errorMessage" class="p-3 bg-red-900/50 border border-red-500 rounded text-red-200 text-sm text-center">{{ errorMessage }}</div>
|
||||||
{{ errorMessage }}
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div>
|
<div>
|
||||||
<label class="block text-sm font-medium text-gray-300 mb-1">Nom d'utilisateur</label>
|
<label class="block text-sm font-medium text-gray-300 mb-1">Nom d'utilisateur</label>
|
||||||
@@ -56,11 +40,11 @@
|
|||||||
|
|
||||||
<div>
|
<div>
|
||||||
<label class="block text-sm font-medium text-gray-300 mb-1">Code 2FA (6 chiffres)</label>
|
<label class="block text-sm font-medium text-gray-300 mb-1">Code 2FA (6 chiffres)</label>
|
||||||
<input v-model="form.totp_code" type="text" inputmode="numeric" pattern="[0-9]{6}" required maxlength="6" class="w-full bg-aethas-dark border border-gray-600 rounded-lg px-4 py-2.5 focus:outline-none focus:border-aethas-cyan focus:ring-1 focus:ring-aethas-cyan transition-colors text-center tracking-widest text-lg" placeholder="123456">
|
<input v-model="form.totp_code" type="text" required pattern="[0-9]{6}" class="w-full bg-aethas-dark border border-gray-600 rounded-lg px-4 py-2.5 focus:outline-none focus:border-aethas-cyan focus:ring-1 focus:ring-aethas-cyan transition-colors text-center tracking-widest text-lg" placeholder="123456">
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<button type="submit" :disabled="isSubmitting" class="w-full bg-gradient-to-r from-aethas-cyan to-aethas-purple hover:opacity-90 text-white font-semibold py-3 px-4 rounded-lg transition-all shadow-[0_0_10px_rgba(168,85,247,0.4)] flex justify-center items-center mt-6">
|
<button type="submit" :disabled="isLoading" class="w-full bg-gradient-to-r from-aethas-cyan to-aethas-purple hover:opacity-90 text-white font-semibold py-3 px-4 rounded-lg transition-all shadow-[0_0_10px_rgba(168,85,247,0.4)] flex justify-center items-center mt-6">
|
||||||
<span v-if="isSubmitting">Vérification...</span>
|
<span v-if="isLoading">Connexion...</span>
|
||||||
<span v-else>Se connecter</span>
|
<span v-else>Se connecter</span>
|
||||||
</button>
|
</button>
|
||||||
</form>
|
</form>
|
||||||
@@ -68,37 +52,43 @@
|
|||||||
</div>
|
</div>
|
||||||
|
|
||||||
<script>
|
<script>
|
||||||
const { createApp, reactive, ref } = Vue;
|
const { createApp, ref, reactive } = Vue;
|
||||||
|
|
||||||
createApp({
|
createApp({
|
||||||
setup() {
|
setup() {
|
||||||
const form = reactive({ username: '', password: '', totp_code: '' });
|
const form = reactive({ username: '', password: '', totp_code: '' });
|
||||||
const isSubmitting = ref(false);
|
const isLoading = ref(false);
|
||||||
const errorMessage = ref('');
|
const errorMessage = ref('');
|
||||||
|
|
||||||
const submitLogin = async () => {
|
const submitLogin = async () => {
|
||||||
isSubmitting.value = true;
|
isLoading.value = true;
|
||||||
errorMessage.value = '';
|
errorMessage.value = '';
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const response = await fetch('/api/login', {
|
const response = await fetch('/api/login', {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
headers: { 'Content-Type': 'application/json' },
|
headers: { 'Content-Type': 'application/json' },
|
||||||
body: JSON.stringify(form)
|
body: JSON.stringify(form)
|
||||||
});
|
});
|
||||||
const data = await response.json();
|
|
||||||
if (!response.ok) throw new Error(data.detail || "Erreur de connexion");
|
|
||||||
|
|
||||||
// Redirection vers le tableau de bord une fois connecté
|
const data = await response.json();
|
||||||
window.location.href = "/dashboard";
|
|
||||||
|
if (!response.ok) {
|
||||||
|
throw new Error(data.detail || "Erreur de connexion");
|
||||||
|
}
|
||||||
|
|
||||||
|
window.location.href = '/dashboard';
|
||||||
|
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
errorMessage.value = error.message;
|
errorMessage.value = error.message;
|
||||||
} finally {
|
} finally {
|
||||||
isSubmitting.value = false;
|
isLoading.value = false;
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
return { form, isSubmitting, errorMessage, submitLogin };
|
|
||||||
|
return { form, isLoading, errorMessage, submitLogin };
|
||||||
}
|
}
|
||||||
}).mount('#app');
|
}).mount('#app');
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
</body>
|
</body>
|
||||||
</html>
|
</html>
|
||||||
@@ -11,3 +11,5 @@ python-multipart
|
|||||||
bcrypt
|
bcrypt
|
||||||
email-validator
|
email-validator
|
||||||
PyJWT
|
PyJWT
|
||||||
|
openai
|
||||||
|
httpx
|
||||||
Reference in new issue
Block a user