1use serde::Deserialize;
14use std::collections::BTreeMap;
15
16const RAW: &str = cmduse_core::ZEN_JSON;
19
20pub const DEFAULT_PLAN: &str = "go";
22
23#[derive(Debug, Clone, Deserialize)]
24pub struct RateVariant {
25 pub peak: Option<String>,
26 #[serde(rename = "tierMaxTokens")]
27 pub tier_max_tokens: Option<u64>,
28 #[serde(rename = "tierMinTokens")]
29 pub tier_min_tokens: Option<u64>,
30 pub input: f64,
31 pub output: f64,
32 #[serde(rename = "cacheRead")]
33 pub cache_read: f64,
34 #[serde(rename = "cacheWrite")]
35 pub cache_write: f64,
36}
37
38#[derive(Debug, Clone, Deserialize)]
39pub struct Model {
40 pub id: String,
41 pub name: String,
42 pub variants: Vec<RateVariant>,
43}
44
45#[derive(Debug, Clone, Deserialize)]
46pub struct WindowShare {
47 #[serde(rename = "fiveHour")]
48 pub five_hour: f64,
49 pub weekly: f64,
50 pub monthly: f64,
51}
52
53#[derive(Debug, Clone, Deserialize)]
55pub struct GoPlan {
56 pub label: String,
57 #[serde(rename = "priceUsd")]
58 pub price_usd: f64,
59 #[serde(rename = "allowanceByModel")]
61 pub allowance_by_model: BTreeMap<String, f64>,
62}
63
64#[derive(Debug, Clone, Deserialize)]
65pub struct Go {
66 #[serde(rename = "windowShare")]
67 pub window_share: WindowShare,
68 pub models: Vec<Model>,
70 pub plans: BTreeMap<String, GoPlan>,
72}
73
74#[derive(Debug, Clone, Deserialize)]
75pub struct Zen {
76 pub models: Vec<Model>,
77}
78
79#[derive(Debug, Clone, Deserialize)]
80pub struct Catalog {
81 #[serde(rename = "extractedAt")]
82 pub extracted_at: String,
83 pub go: Go,
84 pub zen: Zen,
85}
86
87pub fn catalog() -> Catalog {
89 serde_json::from_str(RAW)
90 .expect("core/zen.json is generated; regenerate with scripts/extract-zen.ts")
91}
92
93impl Catalog {
94 pub fn plan_ids(&self) -> Vec<&str> {
97 self.go.plans.keys().map(String::as_str).collect()
98 }
99
100 pub fn plan(&self, plan_id: &str) -> Option<&GoPlan> {
101 self.go.plans.get(plan_id)
102 }
103
104 pub fn go_limit(&self, plan_id: &str, model_id: &str) -> Option<f64> {
107 self.plan(plan_id)
108 .and_then(|plan| plan.allowance_by_model.get(model_id).copied())
109 }
110}
111
112pub fn window_cap(limit: f64, share: f64) -> f64 {
114 limit * share
115}
116
117#[cfg(test)]
118mod tests {
119 use super::*;
120
121 #[test]
122 fn catalogue_parses_and_carries_both_plans() {
123 let c = catalog();
124 assert!(c.go.models.len() > 20, "go models: {}", c.go.models.len());
125 assert!(!c.zen.models.is_empty());
126 assert_eq!(c.plan_ids(), vec!["go", "go-plus"]);
127 assert_eq!(c.plan("go").map(|p| p.price_usd), Some(10.0));
128 assert_eq!(c.plan("go-plus").map(|p| p.price_usd), Some(40.0));
129 assert_eq!(c.go_limit("go", "glm-5.3-flash"), Some(60.0));
130 assert_eq!(c.go_limit("go-plus", "glm-5.3-flash"), Some(180.0));
131 assert_eq!(c.go_limit("go", "nope-not-a-model"), None);
132 assert_eq!(c.go_limit("nope-not-a-plan", "glm-5.3-flash"), None);
133 }
134
135 #[test]
136 fn plans_share_the_model_set_and_differ_on_allowance() {
137 let c = catalog();
138 let go = c.plan("go").expect("go");
139 let plus = c.plan("go-plus").expect("go-plus");
140 assert_eq!(go.label, "Go");
141 assert_eq!(plus.label, "Go Plus");
142 assert_eq!(go.allowance_by_model.len(), plus.allowance_by_model.len());
143 assert!(plus
146 .allowance_by_model
147 .iter()
148 .all(|(id, _)| go.allowance_by_model.contains_key(id)));
149 assert!(plus
150 .allowance_by_model
151 .iter()
152 .any(|(id, limit)| go.allowance_by_model.get(id).is_some_and(|g| limit > g)));
153 }
154
155 #[test]
156 fn window_split_matches_the_docs() {
157 let c = catalog();
158 assert_eq!(c.go.window_share.five_hour, 0.2);
159 assert_eq!(c.go.window_share.weekly, 0.5);
160 assert_eq!(c.go.window_share.monthly, 1.0);
161 assert_eq!(window_cap(60.0, c.go.window_share.five_hour), 12.0);
162 }
163
164 #[test]
165 fn tiered_and_peak_variants_are_kept() {
166 let c = catalog();
167 let qwen =
168 c.go.models
169 .iter()
170 .find(|m| m.id == "qwen3.7-plus")
171 .expect("qwen3.7-plus");
172 assert_eq!(qwen.variants.len(), 2);
173 assert!(qwen
174 .variants
175 .iter()
176 .any(|v| v.tier_max_tokens == Some(256_000)));
177 let deepseek =
178 c.go.models
179 .iter()
180 .find(|m| m.id == "deepseek-v4-flash")
181 .expect("deepseek");
182 assert!(deepseek
183 .variants
184 .iter()
185 .any(|v| v.peak.as_deref() == Some("peak")));
186 }
187}