API sənədləri

import requests

BASE = "https://milligram.az/voice"   # birbaşa server: http://SERVER_IP:4009
KEY = "asr_..."                                 # yuxarıda yaratdığınız açar
H = {"X-API-Key": KEY}

me = requests.get(f"{BASE}/me", headers=H).json()
print(me["balance"], "saniyə balans")

BASE=https://milligram.az/voice
KEY=asr_...

curl -s "$BASE/me" -H "X-API-Key: $KEY"
# {"id":1,"username":"...","balance":33651}

# Nömrələr cavabdan götürülür, əl ilə yazılmır:
up = requests.post(f"{BASE}/upload-file", headers=H,
                   files={"file": ("audio.mp3", open("audio.mp3", "rb"))}).json()
# {"temp_id": "cd0463e8-8e7b-...", "duration": 25, "enough_balance": true}
temp_id = up["temp_id"]

job = requests.post(f"{BASE}/transcribe-uploaded", headers=H,
                    data={"temp_id": temp_id}).json()
# {"record_id": 12, "status": "processing", "punct": true}
rid = job["record_id"]          # <-- bundan sonra hər yerdə BU işlənir

requests.get(f"{BASE}/files/{rid}", headers=H)                       # vəziyyət
requests.get(f"{BASE}/files/{rid}/download", params={"fmt": "json"})  # nəticə

# Nömrəni itirsəniz - siyahıdan tapın:
for f in requests.get(f"{BASE}/files", headers=H).json():
    print(f["id"], f["original_name"], f["status"])

# jq varsa nömrələr avtomatik götürülür:
TEMP_ID=$(curl -s -X POST "$BASE/upload-file" -H "X-API-Key: $KEY" \
  -F "file=@audio.mp3" | jq -r .temp_id)
echo "$TEMP_ID"      # cd0463e8-8e7b-...

ID=$(curl -s -X POST "$BASE/transcribe-uploaded" -H "X-API-Key: $KEY" \
  -F "temp_id=$TEMP_ID" | jq -r .record_id)
echo "$ID"           # 12   <-- bundan sonra hər yerdə $ID işlənir

# jq yoxdursa cavabı ekranda görüb dəyəri əl ilə yazın:
#   {"record_id":12,"status":"processing",...}   ->   ID=12

# Nömrəni itirsəniz - siyahıdan tapın:
curl -s "$BASE/files" -H "X-API-Key: $KEY" | jq '.[] | {id, original_name, status}'

# --- A) Fayl ---
with open("audio.mp3", "rb") as f:
    up = requests.post(f"{BASE}/upload-file", headers=H,
                       files={"file": ("audio.mp3", f)}).json()
print(up["duration_fmt"], "| balans yetərli:", up["enough_balance"])

job = requests.post(f"{BASE}/transcribe-uploaded", headers=H,
                    data={"temp_id": up["temp_id"], "punct": "true"}).json()
rid = job["record_id"]

# --- B) Link ---
URL = "https://www.youtube.com/watch?v=XXXXXXXXXXX"

# əvvəlcə yoxla (heç nə tutulmur): müddət nə qədər, balans çatırmı
probe = requests.post(f"{BASE}/probe-link", headers=H, data={"url": URL}).json()
print(probe["duration_fmt"], probe["enough_balance"])

job = requests.post(f"{BASE}/transcribe-link", headers=H,
                    data={"url": URL, "punct": "false"}).json()
rid = job["record_id"]

# --- A) Fayl ---
curl -s -X POST "$BASE/upload-file" -H "X-API-Key: $KEY" -F "file=@audio.mp3"
# {"temp_id":"cd0463e8-...","duration":25,"duration_fmt":"0 dəq. 25 san.",
#  "enough_balance":true,"balance":33651}

curl -s -X POST "$BASE/transcribe-uploaded" -H "X-API-Key: $KEY" \
  -F "temp_id=$TEMP_ID" -F "punct=true"
# {"record_id":12,"status":"processing","punct":true,...}

# --- B) Link ---
URL="https://www.youtube.com/watch?v=XXXXXXXXXXX"

curl -s -X POST "$BASE/probe-link" -H "X-API-Key: $KEY" -F "url=$URL"
# {"duration":189,"duration_fmt":"3 dəq. 9 san.","enough_balance":true}

curl -s -X POST "$BASE/transcribe-link" -H "X-API-Key: $KEY" \
  -F "url=$URL" -F "punct=false"
# {"record_id":13,"status":"downloading",...}

# --- A) Polling ---
import time

while True:
    info = requests.get(f"{BASE}/files/{rid}", headers=H).json()
    if not info["processing"]:
        break
    if info["progress"]:
        print(info["progress"]["current"], "/", info["progress"]["total"])
    time.sleep(3)

if info["status"] == "error":
    raise SystemExit("transkripsiya alınmadı")
print(info["transcript"])

# --- B) Canlı axın (SSE) ---
import json

# bilet 60 saniyəlik və birdəfəlikdir - açar URL-ə düşmür
ticket = requests.post(f"{BASE}/stream/{rid}/ticket", headers=H).json()["ticket"]

with requests.get(f"{BASE}/stream/{rid}", params={"ticket": ticket},
                  stream=True, timeout=(30, 3600)) as r:
    for line in r.iter_lines(decode_unicode=True):
        if not line or not line.startswith("data:"):
            continue                      # ": keep-alive" sətirləri buraxılır
        ev = json.loads(line[5:])
        if ev["type"] == "segment":
            print(ev["text"])             # XAM seqment (canlı)
        elif ev["type"] == "complete":
            print(ev["transcript"])       # punktuasiyalı YEKUN mətn
            break
        elif ev["type"] == "error":
            print("xəta:", ev["message"])
            break

# --- A) Polling ---
curl -s "$BASE/files/$ID" -H "X-API-Key: $KEY"
# {"status":"transcribing","processing":true,"progress":{"current":3,"total":38}}
# ... processing:false olana qədər təkrarlayın

# --- B) Canlı axın (SSE) ---
TICKET=$(curl -s -X POST "$BASE/stream/$ID/ticket" -H "X-API-Key: $KEY" | jq -r .ticket)
curl -N "$BASE/stream/$ID?ticket=$TICKET"

dl = f"{BASE}/files/{rid}/download"

txt = requests.get(dl, headers=H, params={"fmt": "txt"}).text
srt = requests.get(dl, headers=H, params={"fmt": "srt"}).text
data = requests.get(dl, headers=H, params={"fmt": "json"}).json()

open("audio.srt", "w", encoding="utf-8").write(srt)

data["transcript"]      # tam mətn
data["duration"]        # saniyə
data["words"][0]        # {"word": "salam", "start": 1.24, "end": 1.61}
data["cues"][0]         # sətir: start, end, text, words

# $ID yuxarıda `record_id`-dən gəlir (məs. 12)
curl -s "$BASE/files/$ID/download?fmt=txt"  -H "X-API-Key: $KEY"
curl -s "$BASE/files/$ID/download?fmt=srt"  -H "X-API-Key: $KEY" -o audio.srt
curl -s "$BASE/files/$ID/download?fmt=json" -H "X-API-Key: $KEY" -o audio.json

# Sözləri vaxtı ilə yenidən yaz - mətn və SRT yenidən qurulur
words = [{"word": "Salam", "start": 0.0, "end": 0.4},
         {"word": "dünya.", "start": 0.4, "end": 0.9}]
requests.post(f"{BASE}/files/{rid}/words", headers=H, json={"words": words})

requests.get(f"{BASE}/files", headers=H).json()        # siyahı
requests.delete(f"{BASE}/files/{rid}", headers=H)      # sil

curl -s -X POST "$BASE/files/$ID/words" -H "X-API-Key: $KEY" \
  -H "Content-Type: application/json" \
  -d '{"words":[{"word":"Salam","start":0,"end":0.4}]}'

curl -s "$BASE/files" -H "X-API-Key: $KEY"             # siyahı
curl -s -X DELETE "$BASE/files/$ID" -H "X-API-Key: $KEY"   # sil

# (istəyə görə) referansın mətnini ASR ilə al
with open("ref.wav", "rb") as f:
    ref_text = requests.post(f"{BASE}/tts/ref-transcribe", headers=H,
                             files={"file": f}).json()["text"]

with open("ref.wav", "rb") as f:
    job = requests.post(f"{BASE}/tts/generate", headers=H, files={"ref_audio": f},
                        data={"ref_text": ref_text,
                              "gen_text": "Salam, bu sınaq mətnidir.",
                              "speed": 0,      # 0 = avtomatik
                              "seed": 44}).json()

while True:
    rec = requests.get(f"{BASE}/tts/files/{job['id']}", headers=H).json()
    if rec["status"] in ("completed", "error"):
        break
    time.sleep(1.5)

audio = requests.get(BASE + rec["audio_url"]).content   # WAV, 24 kHz (imzalı link, ~12 saat keçərli)
open("tts.wav", "wb").write(audio)

curl -s -X POST "$BASE/tts/ref-transcribe" -H "X-API-Key: $KEY" -F file=@ref.wav

curl -s -X POST "$BASE/tts/generate" -H "X-API-Key: $KEY" \
  -F ref_audio=@ref.wav -F "ref_text=Referans səsdə deyilən mətn" \
  -F "gen_text=Salam, bu sınaq mətnidir."
# -> {"id": 7, "status": "queued", "queue_position": 0, ...}

curl -s "$BASE/tts/files/7" -H "X-API-Key: $KEY"     # status: completed -> audio_url
curl -s "$BASE/media/..._tts.wav?e=...&s=..." -o tts.wav   # audio_url olduğu kimi; ~12 saat keçərli