sunox 0.0.10

Generate AI music from your terminal via direct Suno web workflows
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

use super::SunoClient;
use super::types::{Clip, GenerateRequest, GenerateResponse};
use crate::core::CliError;

impl SunoClient {
    /// Submit a music generation request (custom mode or inspiration mode).
    /// Posts only to the current `/api/generate/v2-web/` route. The older
    /// `/api/generate/v2/` route returned `Token validation failed` after Suno
    /// migrated creates to `v2-web` server-side in the April 2026 capture.
    /// Wrapped in `with_auth_retry` so a single stale-JWT failure recovers
    /// transparently via Clerk refresh.
    pub async fn generate(&self, req: &GenerateRequest) -> Result<Vec<Clip>, CliError> {
        if req.token.is_none() {
            let mut challenge = self.generation_challenge().await?;
            if challenge.required && self.try_refresh_jwt_for_challenge_recheck().await? {
                challenge = self.generation_challenge().await?;
            }
            if challenge.required {
                return Err(generation_challenge_error(&challenge));
            }
        }

        let body = self.generation_request_body(req).await?;
        self.with_auth_retry(|| async {
            let resp = self
                .post("/api/generate/v2-web/")
                .json(&body)
                .send()
                .await?;
            let resp = self.check_response(resp).await?;
            let result: GenerateResponse = resp.json().await?;
            Ok(result.clips)
        })
        .await
    }

    /// Fetch clips by IDs. Batches in pairs because Suno's feed endpoint can
    /// drop results when queried with larger mixed batches.
    /// Each chunk is wrapped in `with_auth_retry` so explicit wait/status
    /// flows survive Suno's JWT staleness window mid-generation.
    pub async fn get_clips(&self, ids: &[String]) -> Result<Vec<Clip>, CliError> {
        let mut all_clips = Vec::new();
        for chunk in ids.chunks(2) {
            let ids_param = chunk.join(",");
            let path = format!("/api/feed/?ids={ids_param}");
            let clips: Vec<Clip> = self
                .with_auth_retry(|| async {
                    let resp = self.get(&path).send().await?;
                    let resp = self.check_response(resp).await?;
                    let clips: Vec<Clip> = resp.json().await?;
                    Ok(clips)
                })
                .await?;
            all_clips.extend(clips);
        }
        Ok(all_clips)
    }

    async fn generation_request_body(
        &self,
        req: &GenerateRequest,
    ) -> Result<serde_json::Value, CliError> {
        let mut body = serde_json::to_value(req)?;
        if generation_user_tier_is_empty(&body)
            && let Some(user_tier) = self.current_generation_user_tier().await
            && let Some(metadata) = body
                .get_mut("metadata")
                .and_then(|value| value.as_object_mut())
        {
            metadata.insert("user_tier".into(), serde_json::Value::String(user_tier));
        }
        Ok(body)
    }

    async fn current_generation_user_tier(&self) -> Option<String> {
        self.billing_info()
            .await
            .ok()
            .and_then(|info| info.plan.id)
            .map(|tier| tier.trim().to_string())
            .filter(|tier| !tier.is_empty())
    }
}

fn generation_user_tier_is_empty(body: &serde_json::Value) -> bool {
    body.get("metadata")
        .and_then(|metadata| metadata.get("user_tier"))
        .and_then(|user_tier| user_tier.as_str())
        .map(|user_tier| user_tier.trim().is_empty())
        .unwrap_or(true)
}

fn generation_challenge_error(challenge: &super::challenge::GenerationChallenge) -> CliError {
    let version = challenge
        .captcha_version
        .map(|version| version.to_string())
        .unwrap_or_else(|| "unknown".to_string());
    CliError::Config(format!(
        "Suno requires a generation challenge (captcha_version={version}). When stored Clerk refresh material is available, Sunox refreshes the JWT once and repeats the challenge preflight before showing this message. Complete a manual generation challenge in the Suno web app and retry, provide a valid challenge token with --token <token>, or force the browser-backed solver with --captcha."
    ))
}