Spaces:
Sleeping
Sleeping
Update app.py
Browse files
app.py
CHANGED
|
@@ -7,6 +7,7 @@ from fastapi.middleware.cors import CORSMiddleware
|
|
| 7 |
from pydantic import BaseModel
|
| 8 |
from typing import List, Dict
|
| 9 |
import uvicorn
|
|
|
|
| 10 |
|
| 11 |
# Initialiser l'application FastAPI
|
| 12 |
app = FastAPI()
|
|
@@ -26,7 +27,8 @@ app.mount("/static", StaticFiles(directory="static"), name="static")
|
|
| 26 |
class MockRequest(BaseModel):
|
| 27 |
"""Définit la structure attendue pour le corps de la requête POST."""
|
| 28 |
parameter: str
|
| 29 |
-
|
|
|
|
| 30 |
|
| 31 |
class ConnectionManager:
|
| 32 |
"""Gère les connexions WebSocket actives."""
|
|
@@ -89,6 +91,7 @@ async def mock_endpoint(payload: MockRequest):
|
|
| 89 |
"""
|
| 90 |
try:
|
| 91 |
input_string = payload.parameter
|
|
|
|
| 92 |
provided_secret = payload.secret
|
| 93 |
|
| 94 |
# Vérification du secret AVANT tout traitement
|
|
@@ -107,6 +110,15 @@ async def mock_endpoint(payload: MockRequest):
|
|
| 107 |
if not manager.active_connections:
|
| 108 |
raise HTTPException(status_code=503, detail="Aucun client WebSocket n'est connecté.")
|
| 109 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 110 |
# Envoyer le message via WebSocket et obtenir un "future" pour la réponse
|
| 111 |
print("Envoi du message au client WebSocket...")
|
| 112 |
response_future = await manager.broadcast(input_string)
|
|
|
|
| 7 |
from pydantic import BaseModel
|
| 8 |
from typing import List, Dict
|
| 9 |
import uvicorn
|
| 10 |
+
import json
|
| 11 |
|
| 12 |
# Initialiser l'application FastAPI
|
| 13 |
app = FastAPI()
|
|
|
|
| 27 |
class MockRequest(BaseModel):
|
| 28 |
"""Définit la structure attendue pour le corps de la requête POST."""
|
| 29 |
parameter: str
|
| 30 |
+
model: str = "gemini-2.5-pro"
|
| 31 |
+
secret: str
|
| 32 |
|
| 33 |
class ConnectionManager:
|
| 34 |
"""Gère les connexions WebSocket actives."""
|
|
|
|
| 91 |
"""
|
| 92 |
try:
|
| 93 |
input_string = payload.parameter
|
| 94 |
+
provided_model = payload.model
|
| 95 |
provided_secret = payload.secret
|
| 96 |
|
| 97 |
# Vérification du secret AVANT tout traitement
|
|
|
|
| 110 |
if not manager.active_connections:
|
| 111 |
raise HTTPException(status_code=503, detail="Aucun client WebSocket n'est connecté.")
|
| 112 |
|
| 113 |
+
# Créer un dictionnaire avec les données à envoyer
|
| 114 |
+
message_data = {
|
| 115 |
+
"prompt": input_string,
|
| 116 |
+
"model": selected_model
|
| 117 |
+
}
|
| 118 |
+
|
| 119 |
+
# Envoyer le message via WebSocket (sérialiser en JSON)
|
| 120 |
+
response_future = await manager.broadcast(json.dumps(message_data))
|
| 121 |
+
|
| 122 |
# Envoyer le message via WebSocket et obtenir un "future" pour la réponse
|
| 123 |
print("Envoi du message au client WebSocket...")
|
| 124 |
response_future = await manager.broadcast(input_string)
|