Update Flathub stats to January 2026

Disclosure: I developed this code utilizing LSPs and LLMs. All changes have been manually reviewed by me.

Author: FreddyFunk

flathub-stats/src/main.rs

@@ -6,6 +6,11 @@ mod app_id;
 
 #[derive(serde::Deserialize)]
 pub struct Stats {
+    /// New format (2026+): { "app.id": { "CC": (downloads, updates) } }
+    #[serde(default)]
+    ref_by_country: HashMap<String, HashMap<String, (u64, u64)>>,
+    /// Old format (pre-2026): { "app.id/arch": { "channel": (downloads, updates) } }
+    #[serde(default)]
     refs: HashMap<String, HashMap<String, (u64, u64)>>,
 }
 
@@ -23,8 +28,8 @@ fn leap_year(year: u16) -> bool {
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error>> {
-    let year = 2025;
-    let month = 9;
+    let year = 2026;
+    let month = 1;
     let days = match month {
         1 | 3 | 5 | 7 | 8 | 10 | 12 => 31,
         4 | 6 | 9 | 11 => 30,
@@ -41,16 +46,27 @@ async fn main() -> Result<(), Box<dyn Error>> {
     let mut ref_downloads = HashMap::<AppId, u64>::new();
     for day in 1..=days {
         let stats = stats(year, month, day).await?;
-        for (r, archs) in stats.refs {
-            for (_arch, (downloads, _updates)) in archs {
-                let id = r.split('/').next().unwrap();
-                *ref_downloads.entry(AppId::new(&id)).or_insert(0) += downloads;
+        if !stats.ref_by_country.is_empty() {
+            for (app_id, countries) in stats.ref_by_country {
+                let total: u64 = countries.values().map(|(dl, _)| *dl).sum();
+                if total > 0 {
+                    *ref_downloads.entry(AppId::new(&app_id)).or_insert(0) += total;
+                }
+            }
+        } else {
+            for (r, archs) in stats.refs {
+                for (_arch, (downloads, _updates)) in archs {
+                    let id = r.split('/').next().unwrap();
+                    *ref_downloads.entry(AppId::new(&id)).or_insert(0) += downloads;
+                }
             }
         }
     }
 
     let bitcode = bitcode::encode(&ref_downloads);
     fs::write(format!("res/flathub-stats.bitcode-v0-6"), &bitcode)?;
 
+    println!("Wrote stats for {} apps", ref_downloads.len());
+
     Ok(())
 }

res/flathub-stats.bitcode-v0-6

@@ -196,7 +196,7 @@ impl AppstreamCache {
 
     /// Versioned filename of cache
     fn cache_filename() -> &'static str {
-        "appstream_cache-v2.bitcode-v0-6"
+        "appstream_cache-v3.bitcode-v0-6"
     }
 
     /// Remove all files from cache not matching filename