통화 녹음 파일 내려받기: Presigned URL과 1시간 만료 처리

{
  "callHistoryId": "8f3f8fd9-7ab8-4a26-b523-4f8eb7d38b85",
  "status": "ANSWERED",
  "tag": "AI_TO_DIRECT",
  "isRecorded": true,
  "recordingAI": {
    "url": "https://storage.example.com/recording-ai.wav",
    "expiresAt": "2026-03-12T03:40:00.000Z",
    "contentLength": 1234567,
    "contentType": "audio/wav"
  },
  "recordingDirect": {
    "url": "https://storage.example.com/recording-direct.wav",
    "expiresAt": "2026-03-12T03:40:00.000Z",
    "contentLength": 2345678,
    "contentType": "audio/wav"
  }
}

# 1) 상세 조회
curl -G "https://studio-gateway.zerocall.kr/call-history/8f3f8fd9-7ab8-4a26-b523-4f8eb7d38b85" \
  -H "x-api-key: $KAT_API_KEY" \
  --data-urlencode "groupId=1"

# 2) 응답의 recordingAI.url 값을 RECORDING_URL에 넣고 내려받기(API 키 헤더 없음)
curl -fSL -o 8f3f8fd9-ai.wav "$RECORDING_URL"

import os
from datetime import datetime, timedelta, timezone
from pathlib import Path

import requests

BASE_URL = "https://studio-gateway.zerocall.kr"
api = requests.Session()
api.headers.update({"x-api-key": os.environ["KAT_API_KEY"]})
MARGIN = timedelta(minutes=5)  # 만료까지 5분 미만이면 다시 조회


def get_call(group_id, call_history_id):
    resp = api.get(f"{BASE_URL}/call-history/{call_history_id}",
                   params={"groupId": group_id}, timeout=15)
    resp.raise_for_status()
    body = resp.json()
    return body["result"] if isinstance(body, dict) and "result" in body else body


def expires_soon(rec):
    expires_at = datetime.fromisoformat(rec["expiresAt"].replace("Z", "+00:00"))
    return expires_at - datetime.now(timezone.utc) < MARGIN


def fetch_file(rec, dest):
    tmp = dest.with_suffix(".part")
    # Presigned URL에는 API 키를 보내지 않으므로 세션 대신 requests.get을 씁니다.
    with requests.get(rec["url"], stream=True, timeout=60) as r:
        r.raise_for_status()
        with open(tmp, "wb") as f:
            for chunk in r.iter_content(chunk_size=256 * 1024):
                f.write(chunk)
    size = tmp.stat().st_size
    if rec.get("contentLength") and size != rec["contentLength"]:
        tmp.unlink()
        raise IOError(f"크기 불일치: {size} != {rec['contentLength']}")
    tmp.rename(dest)


def download_recordings(group_id, call_history_id, out_dir="recordings"):
    call = get_call(group_id, call_history_id)
    if not call.get("isRecorded") or call.get("status") != "ANSWERED":
        return []  # 녹음·요약·STT가 없는 통화
    saved = []
    for field, suffix in (("recordingAI", "ai"), ("recordingDirect", "direct")):
        rec = call.get(field)
        if not rec or not rec.get("url"):
            continue
        dest = Path(out_dir) / str(group_id) / f"{call_history_id}-{suffix}.wav"
        if dest.exists():
            saved.append(dest)  # 이미 받은 파일
            continue
        if expires_soon(rec):
            rec = get_call(group_id, call_history_id).get(field) or {}
            if not rec.get("url") or expires_soon(rec):
                raise RuntimeError(f"{call_history_id} {field}: 유효한 URL을 받지 못했습니다.")
        dest.parent.mkdir(parents=True, exist_ok=True)
        fetch_file(rec, dest)
        saved.append(dest)
    return saved


print(download_recordings(1, "8f3f8fd9-7ab8-4a26-b523-4f8eb7d38b85"))

const fs = require('node:fs');
const { Readable } = require('node:stream');
const { pipeline } = require('node:stream/promises');

const BASE_URL = 'https://studio-gateway.zerocall.kr';

async function getCall(groupId, callHistoryId) {
  const url = `${BASE_URL}/call-history/${callHistoryId}?groupId=${groupId}`;
  const res = await fetch(url, { headers: { 'x-api-key': process.env.KAT_API_KEY } });
  if (!res.ok) throw new Error(`call-history ${res.status}`);
  const body = await res.json();
  return body.result ?? body;
}

async function saveRecording(rec, path) {
  const res = await fetch(rec.url); // Presigned URL: API 키 헤더 없이 요청
  if (!res.ok) throw new Error(`download ${res.status}`);
  await pipeline(Readable.fromWeb(res.body), fs.createWriteStream(path));
}

(async () => {
  const call = await getCall(1, '8f3f8fd9-7ab8-4a26-b523-4f8eb7d38b85');
  if (call.isRecorded && call.recordingAI?.url) {
    await saveRecording(call.recordingAI, `${call.callHistoryId}-ai.wav`);
  }
})();