Spaces:
Runtime error
Runtime error
Update app.py
Browse files
app.py
CHANGED
|
@@ -4,8 +4,7 @@ import time
|
|
| 4 |
import json
|
| 5 |
from fastapi import FastAPI, Request
|
| 6 |
from fastapi.responses import StreamingResponse
|
| 7 |
-
# ืืืืื ื
|
| 8 |
-
from phonikud import Phonikud, phonemize
|
| 9 |
from google import genai
|
| 10 |
from google.genai import types
|
| 11 |
|
|
@@ -14,7 +13,7 @@ logger = logging.getLogger(__name__)
|
|
| 14 |
|
| 15 |
app = FastAPI()
|
| 16 |
|
| 17 |
-
# ืืขืื ืช ืืืืื (
|
| 18 |
MODEL_PATH = "./phonikud-1.0.int8.onnx"
|
| 19 |
pk = Phonikud(MODEL_PATH) if os.path.exists(MODEL_PATH) else None
|
| 20 |
|
|
@@ -26,7 +25,7 @@ async def chat_proxy(request: Request):
|
|
| 26 |
body = await request.json()
|
| 27 |
messages = body.get("messages", [])
|
| 28 |
|
| 29 |
-
# ืื ืืืช ืืง
|
| 30 |
system_instruction = ""
|
| 31 |
contents = []
|
| 32 |
for msg in messages:
|
|
@@ -36,7 +35,7 @@ async def chat_proxy(request: Request):
|
|
| 36 |
role = "user" if msg["role"] == "user" else "model"
|
| 37 |
contents.append(types.Content(role=role, parts=[types.Part(text=msg["content"])]))
|
| 38 |
|
| 39 |
-
# 1.
|
| 40 |
response = client.models.generate_content(
|
| 41 |
model='gemini-2.5-flash',
|
| 42 |
contents=contents,
|
|
@@ -46,23 +45,21 @@ async def chat_proxy(request: Request):
|
|
| 46 |
original_text = response.text or ""
|
| 47 |
logger.info(f"Gemini: {original_text}")
|
| 48 |
|
| 49 |
-
# 2. ืืคืืื ืืคืื ืืืช
|
| 50 |
final_output = original_text
|
| 51 |
if pk and original_text:
|
| 52 |
try:
|
| 53 |
-
#
|
| 54 |
vocalized = pk.add_diacritics(original_text)
|
| 55 |
-
#
|
| 56 |
-
|
| 57 |
-
#
|
| 58 |
-
|
| 59 |
-
|
| 60 |
-
|
| 61 |
-
logger.info(f"Cartesia Phonemes: {final_output}")
|
| 62 |
except Exception as e:
|
| 63 |
logger.error(f"Phonemization failed: {e}")
|
| 64 |
|
| 65 |
-
# 3. ืืืจืื
|
| 66 |
def generate_vapi_stream():
|
| 67 |
chat_id = f"chatcmpl-{int(time.time())}"
|
| 68 |
chunk = {
|
|
@@ -81,4 +78,8 @@ async def chat_proxy(request: Request):
|
|
| 81 |
|
| 82 |
except Exception as e:
|
| 83 |
logger.error(f"Error: {str(e)}")
|
| 84 |
-
return {"error": str(e)}, 500
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 4 |
import json
|
| 5 |
from fastapi import FastAPI, Request
|
| 6 |
from fastapi.responses import StreamingResponse
|
| 7 |
+
from phonikud import Phonikud, phonemize # ืืืืื ืจืฉืื ืืืกืคืจืืื
|
|
|
|
| 8 |
from google import genai
|
| 9 |
from google.genai import types
|
| 10 |
|
|
|
|
| 13 |
|
| 14 |
app = FastAPI()
|
| 15 |
|
| 16 |
+
# ืืขืื ืช ืืืืื (ืืงืืืฅ ืืืื ืืืืืช ืืชืืงืืื ืืจืืฉืืช ืฉื ื-Space)
|
| 17 |
MODEL_PATH = "./phonikud-1.0.int8.onnx"
|
| 18 |
pk = Phonikud(MODEL_PATH) if os.path.exists(MODEL_PATH) else None
|
| 19 |
|
|
|
|
| 25 |
body = await request.json()
|
| 26 |
messages = body.get("messages", [])
|
| 27 |
|
| 28 |
+
# ืื ืืืช ืืืงืฉืจ ืืื ืืื
|
| 29 |
system_instruction = ""
|
| 30 |
contents = []
|
| 31 |
for msg in messages:
|
|
|
|
| 35 |
role = "user" if msg["role"] == "user" else "model"
|
| 36 |
contents.append(types.Content(role=role, parts=[types.Part(text=msg["content"])]))
|
| 37 |
|
| 38 |
+
# 1. ืงืืืช ืชืฉืืื ื-Gemini
|
| 39 |
response = client.models.generate_content(
|
| 40 |
model='gemini-2.5-flash',
|
| 41 |
contents=contents,
|
|
|
|
| 45 |
original_text = response.text or ""
|
| 46 |
logger.info(f"Gemini: {original_text}")
|
| 47 |
|
| 48 |
+
# 2. ืืคืืื ืืคืื ืืืช IPA (ืืฉืืื ืืืืืืจ)
|
| 49 |
final_output = original_text
|
| 50 |
if pk and original_text:
|
| 51 |
try:
|
| 52 |
+
# ืืืกืคืช ื ืืงืื
|
| 53 |
vocalized = pk.add_diacritics(original_text)
|
| 54 |
+
# ืืืจื ืืคืื ืืืช IPA
|
| 55 |
+
ipa = phonemize(vocalized)
|
| 56 |
+
# ืขืืืคื ืืงืจืืกืื (ื ืืงืื ืชืืืื ืืื ืืื ืืืืืช ืืฆืืจื)
|
| 57 |
+
final_output = f"<<{ipa.replace('|', '')}>>"
|
| 58 |
+
logger.info(f"IPA for Cartesia: {final_output}")
|
|
|
|
|
|
|
| 59 |
except Exception as e:
|
| 60 |
logger.error(f"Phonemization failed: {e}")
|
| 61 |
|
| 62 |
+
# 3. ืืืจืื ืืคืืจืื ืฉืืืืคื ืืืื ื
|
| 63 |
def generate_vapi_stream():
|
| 64 |
chat_id = f"chatcmpl-{int(time.time())}"
|
| 65 |
chunk = {
|
|
|
|
| 78 |
|
| 79 |
except Exception as e:
|
| 80 |
logger.error(f"Error: {str(e)}")
|
| 81 |
+
return {"error": str(e)}, 500
|
| 82 |
+
|
| 83 |
+
if __name__ == "__main__":
|
| 84 |
+
import uvicorn
|
| 85 |
+
uvicorn.run(app, host="0.0.0.0", port=7860)
|