Contextual Correction

import time
import json
import requests

BASE_URL = "https://api.fennec-asr.com/api/v1"
API_KEY = "YOUR_API_KEY_HERE"  # <-- put your API key here
AUDIO_URL = "https://upload.wikimedia.org/wikipedia/commons/3/3f/En-History_of_Corpus_Christi%2C_Texas.ogg"

CONTEXT_STRING = "The city being referred to is Corpus Christi. Make sure any potential confusions are corrected."
APPLY_CORRECTION_FLAG = True  # set to False to disable

# Polling
POLL_INTERVAL_SECONDS = 3
MAX_WAIT_SECONDS = 300

def submit_job():
    headers = {"Content-Type": "application/json", "X-API-Key": API_KEY}
    payload = {
        "audio": AUDIO_URL,
        "context": CONTEXT_STRING,
        "apply_contextual_correction": APPLY_CORRECTION_FLAG,
    }

    print("--- Submitting URL Transcription with Contextual Correction ---")
    print(f"Audio URL: {AUDIO_URL}")
    print(f"Applying Correction: {APPLY_CORRECTION_FLAG}")
    print(f"Context: '{CONTEXT_STRING}'")
    print("---------------------------------------------------------------")

    resp = requests.post(f"{BASE_URL}/transcribe/url",
                         headers=headers,
                         data=json.dumps(payload),
                         timeout=60)
    resp.raise_for_status()
    job_id = resp.json().get("job_id")
    if not job_id:
        raise RuntimeError("No job_id returned from submit endpoint.")
    print(f"✅ Job submitted successfully! Job ID: {job_id}\n")
    return job_id


def poll_job(job_id):
    headers = {"X-API-Key": API_KEY}
    status_url = f"{BASE_URL}/transcribe/status/{job_id}"

    start = time.monotonic()
    while time.monotonic() - start < MAX_WAIT_SECONDS:
        print("Polling for status...")
        try:
            resp = requests.get(status_url, headers=headers, timeout=30)
            if resp.status_code != 200:
                print(f"  Error polling status: HTTP {resp.status_code}")
                time.sleep(POLL_INTERVAL_SECONDS)
                continue

            data = resp.json()
            status = data.get("status")
            print(f"  Current status: '{status}'")

            if status == "completed":
                return data
            if status == "failed":
                return data
        except requests.exceptions.RequestException as e:
            print(f"  Polling error: {e}")

        time.sleep(POLL_INTERVAL_SECONDS)

    return {"status": "timeout", "transcript": None}


def main():
    try:
        job_id = submit_job()
        result = poll_job(job_id)

        status = result.get("status")
        if status == "completed":
            transcript = result.get("transcript") or ""
            print("\n🎉 Transcription complete!")
            print("-" * 60)
            print(transcript)
            print("-" * 60)
            if SAVE_TO:
                with open(SAVE_TO, "w", encoding="utf-8") as f:
                    f.write(transcript)
                print(f"💾 Transcript saved to: {SAVE_TO}")
        elif status == "failed":
            print("\n❌ Transcription failed.")
            print("Error:", result.get("transcript"))
        else:
            print("\n⏰ Polling timed out.")
    except requests.exceptions.RequestException as e:
        print(f"An error occurred: {e}")
    except Exception as e:
        print(f"Unexpected error: {e}")


if __name__ == "__main__":
    main()

#!/usr/bin/env node
"use strict";

const BASE = "https://api.fennec-asr.com/api/v1";
const KEY = process.env.ASR_API_KEY;
const url =
  process.argv[2] ||
  "https://upload.wikimedia.org/wikipedia/commons/3/3f/En-History_of_Corpus_Christi%2C_Texas.ogg";

const CONTEXT =
  "The city being referred to is Corpus Christi. Make sure any potential confusions are corrected.";
const APPLY = true; // set to false to disable
const wait = (ms: number) => new Promise((r) => setTimeout(r, ms));

(async () => {
  if (!KEY) throw new Error("Set ASR_API_KEY");

  const payload = {
    audio: url,
    context: CONTEXT,
    apply_contextual_correction: APPLY,
  };

  const sub = await fetch(`${BASE}/transcribe/url`, {
    method: "POST",
    headers: {
      "X-API-Key": KEY,
      "Content-Type": "application/json",
    },
    body: JSON.stringify(payload),
  }).then((r) => r.json());

  if (!sub?.job_id) throw new Error("No job_id");

  for (;;) {
    const s = await fetch(`${BASE}/transcribe/status/${sub.job_id}`, {
      headers: { "X-API-Key": KEY },
    }).then((r) => r.json());

    if (s.status === "completed") return void console.log(s.transcript || "");
    if (s.status === "failed") {
      console.error("Failed:", s.transcript || "");
      process.exit(1);
    }
    await wait(3000);
  }
})().catch((e) => {
  console.error(e.message || e);
  process.exit(1);
});