API Key 异步媒体完整调用

export JUSP_BASE_URL='https://api.jusuanhub.com/v1'
export JUSP_API_KEY='<API_KEY>'
export JUSP_MODEL='minimax-h3'
export JUSP_IDEMPOTENCY_KEY="$(openssl rand -hex 16)"

jq -n --arg model "$JUSP_MODEL" '{
  model:$model,
  generationMode:"t2v",
  prompt:"清晨的海岸，镜头缓慢推进，柔和的自然光",
  resolutionTier:"768p",
  orientation:"landscape",
  aspectRatio:"16:9",
  seconds:5
}' |
curl --fail-with-body --max-time 60 "$JUSP_BASE_URL/media/generations" \
  -H "Authorization: Bearer $JUSP_API_KEY" \
  -H "Idempotency-Key: $JUSP_IDEMPOTENCY_KEY" \
  -H 'Content-Type: application/json' \
  --data-binary @- --output create.json

{
  "jobId": "job_...",
  "jobUrl": "https://api.jusuanhub.com/v1/jobs/job_...?model=minimax-h3",
  "status": "queued"
}

JOB_URL="$(jq -er '.jobUrl' create.json)"
curl --fail-with-body --max-time 60 "$JOB_URL" \
  -H "Authorization: Bearer $JUSP_API_KEY" \
  --output job.json

CONTENT_URL="$(jq -er '.outputs[0].contentUrl // .assets[0].contentUrl' job.json)"
curl --fail-with-body --location --max-time 300 "$CONTENT_URL" \
  -H "Authorization: Bearer $JUSP_API_KEY" \
  --output result.mp4

MARKED_URL="${CONTENT_URL}&deliveryMode=marked"
while :; do
  STATUS="$(curl --silent --show-error --location --max-time 300 \
    -H "Authorization: Bearer $JUSP_API_KEY" \
    --dump-header marked.headers \
    --output marked.body \
    --write-out '%{http_code}' \
    "$MARKED_URL")"
  if [ "$STATUS" = 200 ]; then
    mv marked.body result-marked.mp4
    break
  fi
  if [ "$STATUS" != 202 ]; then
    printf '带标识下载失败，HTTP %s\n' "$STATUS" >&2
    cat marked.body >&2
    exit 1
  fi
  WAIT_SECONDS="$(jq -r '.retryAfterSeconds // 2' marked.body)"
  sleep "$WAIT_SECONDS"
done

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.nio.file.Path;
import java.time.Duration;
import java.util.Set;
import java.util.UUID;

public final class H3Example {
  private static final URI BASE = URI.create("https://api.jusuanhub.com/v1");
  private final String key = System.getenv("JUSP_API_KEY");
  private final ObjectMapper json = new ObjectMapper();
  private final HttpClient http = HttpClient.newBuilder()
      .connectTimeout(Duration.ofSeconds(10)).build();

  private HttpRequest.Builder authenticated(URI uri) {
    if (!uri.getScheme().equals(BASE.getScheme()) ||
        !uri.getAuthority().equals(BASE.getAuthority()))
      throw new IllegalArgumentException("拒绝向非 API 来源发送 Key");
    return HttpRequest.newBuilder(uri)
        .timeout(Duration.ofSeconds(60))
        .header("Authorization", "Bearer " + key);
  }

  public void run() throws Exception {
    var payload = json.createObjectNode()
        .put("model", "minimax-h3")
        .put("generationMode", "t2v")
        .put("prompt", "清晨的海岸，镜头缓慢推进，柔和的自然光")
        .put("resolutionTier", "768p")
        .put("orientation", "landscape")
        .put("aspectRatio", "16:9")
        .put("seconds", 5);
    var createRequest = authenticated(BASE.resolve("/v1/media/generations"))
        .header("Content-Type", "application/json")
        .header("Idempotency-Key", UUID.randomUUID().toString())
        .POST(HttpRequest.BodyPublishers.ofString(json.writeValueAsString(payload)))
        .build();
    var createResponse = http.send(createRequest, HttpResponse.BodyHandlers.ofString());
    if (createResponse.statusCode() / 100 != 2)
      throw new IllegalStateException(createResponse.body());
    JsonNode job = json.readTree(createResponse.body());
    URI jobUrl = URI.create(job.path("jobUrl").asText());

    var terminal = Set.of("succeeded", "failed", "canceled");
    var deadline = System.nanoTime() + Duration.ofMinutes(30).toNanos();
    while (!terminal.contains(job.path("status").asText())) {
      if (System.nanoTime() >= deadline)
        throw new IllegalStateException("本地等待结束；保留 jobUrl 稍后恢复");
      Thread.sleep(Math.max(1, job.path("retryAfterSeconds").asInt(3)) * 1000L);
      var response = http.send(
          authenticated(jobUrl).GET().build(), HttpResponse.BodyHandlers.ofString());
      if (response.statusCode() / 100 != 2)
        throw new IllegalStateException(response.body());
      job = json.readTree(response.body());
    }
    if (!job.path("status").asText().equals("succeeded"))
      throw new IllegalStateException(job.toString());
    // 原样 contentUrl 默认返回无可见水印的 source master。
    URI contentUrl = URI.create(job.path("outputs").get(0).path("contentUrl").asText());
    var download = http.send(
        authenticated(contentUrl).timeout(Duration.ofMinutes(5)).GET().build(),
        HttpResponse.BodyHandlers.ofFile(Path.of("result.mp4")));
    if (download.statusCode() / 100 != 2)
      throw new IllegalStateException("下载失败：" + download.statusCode());
  }
}